|
@@ -408,7 +408,7 @@ public class MatchVideoServiceImpl {
|
|
|
log.error("上传小程序视频线程异常", e);
|
|
|
}
|
|
|
}
|
|
|
- log.info("启动匹配小程序线程结束");
|
|
|
+ log.info("上传小程序视频线程结束");
|
|
|
countDownLatch.countDown();
|
|
|
}));
|
|
|
}
|
|
@@ -440,6 +440,7 @@ public class MatchVideoServiceImpl {
|
|
|
}
|
|
|
|
|
|
public void processUploadCrawlerVideo(MatchVideo matchVideo) {
|
|
|
+ log.info("processUploadCrawlerVideo matchVideo={}", matchVideo);
|
|
|
if (matchVideo.getContentStatus() != ContentStatusEnum.CRAWLER_SUCCESS.getStatusCode()) {
|
|
|
return;
|
|
|
}
|
|
@@ -452,7 +453,7 @@ public class MatchVideoServiceImpl {
|
|
|
}
|
|
|
String lockKey = String.format(UPLOAD_CRAWLER_LOCK_KEY, matchVideo.getContentId());
|
|
|
String lockValue = UUID.randomUUID().toString();
|
|
|
- boolean lock = redisLock.tryLock(lockKey, lockValue, 10, TimeUnit.MINUTES);
|
|
|
+ boolean lock = redisLock.tryLock(lockKey, lockValue, 20, TimeUnit.MINUTES);
|
|
|
if (lock) {
|
|
|
boolean res = crawlerVideoService.uploadCrawlerVideo(matchVideo);
|
|
|
if (res) {
|