wangyunpeng 3 giorni fa
parent
commit
6a3397f2ca

+ 12 - 4
core/src/main/java/com/tzld/supply/job/ContentMediaSearchJob.java

@@ -112,15 +112,23 @@ public class ContentMediaSearchJob {
         return spiderContentMediaMapper.countByExample(example);
     }
 
+    private List<SpiderContentMedia> getSpiderContentMediaList(Long contentId, String mediaType) {
+        SpiderContentMediaExample example = new SpiderContentMediaExample();
+        example.createCriteria().andContentIdEqualTo(contentId).andMediaTypeEqualTo(mediaType);
+        return spiderContentMediaMapper.selectByExample(example);
+    }
+
     @XxlJob("contentMediaImageCheckJob")
     public ReturnT<String> contentMediaImageCheckJob(String param) {
         Long startTime = DateUtils.getTodayStart();
+        Long endTime = startTime + 86400 * 1000;
+        List<SpiderContentMedia> mediaList;
         if (StringUtils.isNotBlank(param)) {
-            startTime = DateUtils.getStartOfDay(param, "yyyyMMdd");
+            mediaList = getSpiderContentMediaList(Long.parseLong(param), SpiderContentMediaTypeEnum.IMAGE.getMsg());
+        } else {
+            mediaList = spiderMapperExt.getMediaSearchSpiderContentMedia(SpiderContentStatusEnum.PASSED.getCode(),
+                    startTime, endTime, SpiderContentMediaStatusEnum.WAITING.getCode(), SpiderContentMediaTypeEnum.IMAGE.getMsg());
         }
-        Long endTime = startTime + 86400 * 1000;
-        List<SpiderContentMedia> mediaList = spiderMapperExt.getMediaSearchSpiderContentMedia(SpiderContentStatusEnum.PASSED.getCode(),
-                startTime, endTime, SpiderContentMediaStatusEnum.WAITING.getCode(), SpiderContentMediaTypeEnum.IMAGE.getMsg());
         if (CollectionUtil.isEmpty(mediaList)) {
             return ReturnT.SUCCESS;
         }

+ 2 - 1
server/src/test/java/ProduceTest.java

@@ -24,8 +24,9 @@ public class ProduceTest {
 
     @Test
     public void test() {
-        String contentId = "25835";
+        String contentId = "26177";
         contentMediaSearchJob.contentImageMediaSearchJob(contentId);
+        contentMediaSearchJob.contentMediaImageCheckJob(contentId);
         contentMediaSearchJob.contentVideoMediaSearchJob(contentId);
         videoGenerateJob.videoVoiceGenerateJob(contentId);
         ProduceVideoExample example = new ProduceVideoExample();