Forráskód Böngészése

清洗项目素材池

zhaoxian 4 éve
szülő
commit
c16d4ac2d0

+ 1 - 1
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouProjectVideoGetJob.java

@@ -33,7 +33,7 @@ public class KuaishouProjectVideoGetJob {
         //2快手,1开启的项目
         List<Project> projects = projectService.listByMediaType(2, 0);
         projects.forEach(project -> executorService.submit(() -> {
-            projectVideoGetService.clearProjectVideo(project.getId(),1);
+            projectVideoGetService.clearProjectVideo(project.getId(),1,null);
         }));
         XxlJobHelper.log("清洗项目素材完成");
     }

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/controller/KuaishouProjectVideoGetController.java

@@ -241,7 +241,7 @@ public class KuaishouProjectVideoGetController {
     @GetMapping(value = "/clearProjectVideo")
     public Result<Object> clearProjectVideo(Long projectId) {
         try {
-            kuaishouProjectVideoGetService.clearProjectVideo(projectId,1);
+            kuaishouProjectVideoGetService.clearProjectVideo(projectId,1,null);
         } catch (Exception e) {
             log.error(e.getMessage(), e);
         }

+ 2 - 2
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaiShouVideoGetMapper.xml

@@ -306,8 +306,8 @@
         INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
         WHERE t1.`status` =0
         AND t2.project_id=#{projectId}
-        <if test="updateTime!=null">
-            AND t1.update_time >=#{updateTime}
+        <if test="updateTime!=null and updateTime!=''">
+            AND t1.update_time &gt;=#{updateTime}
         </if>
         group by t1.signature
     </select>

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaishouProjectVideoGetService.java

@@ -17,7 +17,7 @@ public interface IKuaishouProjectVideoGetService extends IService<KuaishouProjec
     /**
      * 清洗项目数据
      */
-    void clearProjectVideo(Long projectId, Integer pageStart);
+    void clearProjectVideo(Long projectId, Integer pageStart,String updateTime);
 
     Result<Object> queryPageList(KuaishouProjectVideoGet kuaishouProjectVideoGet, Integer pageNo, Integer pageSize);
 

+ 5 - 3
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouProjectVideoGetServiceImpl.java

@@ -62,10 +62,12 @@ public class KuaishouProjectVideoGetServiceImpl extends ServiceImpl<KuaishouProj
     private IKuaiShouVideoGetService videoGetService;
 
     @Override
-    public void clearProjectVideo(Long projectId, Integer pageNo) {
+    public void clearProjectVideo(Long projectId, Integer pageNo, String updateTime) {
         try {
             log.info("清洗快手项目素材数据,projectId:{},pageNo:{}", projectId, pageNo);
-            String updateTime = projectVideoGetMapper.queryLatestUpdateTime(projectId);
+            if (Check.isNull(updateTime) && pageNo == 1) {
+                updateTime = projectVideoGetMapper.queryLatestUpdateTime(projectId);
+            }
             PageHelper.startPage(pageNo, 1500);
             List<KuaishouProjectVideoGet> list = videoGetMapper.selectProjectVideo(projectId, updateTime);
             if (Check.isNull(list)) {
@@ -73,7 +75,7 @@ public class KuaishouProjectVideoGetServiceImpl extends ServiceImpl<KuaishouProj
             }
             projectVideoGetMapper.replaceBatch(list);
             Thread.sleep(500);
-            clearProjectVideo(projectId, pageNo + 1);
+            clearProjectVideo(projectId, pageNo + 1, updateTime);
         } catch (Exception e) {
             log.error("清洗项目数据异常", e);
         }