|
@@ -160,20 +160,6 @@ public class NewMatchVideoServiceImpl implements NewMatchVideoService {
|
|
|
newUploadCrawlerVideoPoolExecutor);
|
|
|
}
|
|
|
|
|
|
- private void processUploadCrawlerVideo(NewMatchVideo newMatchVideo) {
|
|
|
- boolean updateSuccess = false;
|
|
|
- try {
|
|
|
- updateSuccess = crawlerVideoService.uploadCrawlerVideo(newMatchVideo.getContentId(), newMatchVideo.getFlowPoolLevel());
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("Failed to upload crawler video content for ID: {}", newMatchVideo.getContentId(), e);
|
|
|
- }
|
|
|
-
|
|
|
- updateVideoStatus(newMatchVideo, updateSuccess,
|
|
|
- NewContentStatusEnum.KIMI_SUCCESS,
|
|
|
- NewContentStatusEnum.KIMI_FAIL);
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
private void processKimiMatchContent(NewMatchVideo newMatchVideo) {
|
|
|
boolean updateSuccess = false;
|
|
|
try {
|
|
@@ -202,6 +188,20 @@ public class NewMatchVideoServiceImpl implements NewMatchVideoService {
|
|
|
NewContentStatusEnum.CRAWLER_FAIL);
|
|
|
}
|
|
|
|
|
|
+ private void processUploadCrawlerVideo(NewMatchVideo newMatchVideo) {
|
|
|
+ boolean updateSuccess = false;
|
|
|
+ try {
|
|
|
+ updateSuccess = crawlerVideoService.uploadCrawlerVideo(newMatchVideo.getContentId(), newMatchVideo.getFlowPoolLevel());
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("Failed to upload crawler video content for ID: {}", newMatchVideo.getContentId(), e);
|
|
|
+ }
|
|
|
+
|
|
|
+ updateVideoStatus(newMatchVideo, updateSuccess,
|
|
|
+ NewContentStatusEnum.ELT_SUCCESS,
|
|
|
+ NewContentStatusEnum.ELT_FAIL);
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
private String getRootContentId(String contentId) {
|
|
|
ProducePlanExeRecordExample example = new ProducePlanExeRecordExample();
|
|
|
example.createCriteria().andPlanExeIdEqualTo(contentId);
|