修改

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/entity/ClMaterialTaskInfo.java

@@ -6,6 +6,7 @@ public class ClMaterialTaskInfo {
     /**
      * 管家账户ID
      */
+    private Long id;
     private Long materialId;
 
     /**
@@ -55,6 +56,14 @@ public class ClMaterialTaskInfo {
 
     private Integer isExist;
 
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
     public Long getMaterialId() {
         return materialId;
     }
@@ -146,7 +155,8 @@ public class ClMaterialTaskInfo {
     @Override
     public String toString() {
         return "ClMaterialTaskInfo{" +
-                "materialId=" + materialId +
+                "id=" + id +
+                ", materialId=" + materialId +
                 ", adxUrl='" + adxUrl + '\'' +
                 ", batchId='" + batchId + '\'' +
                 ", taskStatus='" + taskStatus + '\'' +

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/ClTaskStatusMapper.xml

@@ -14,14 +14,13 @@
             <if test="playletId != null">playlet_id = #{playletId},</if>
             <if test="folderId != null">folder_id = #{folderId},</if>
             <if test="isExist != null">is_exist = #{isExist},</if>
-
         </trim>
-        where material_id = #{materialId}
+        where id = #{id}
     </update>
 
 
     <select id="getClTaskListByStatus" resultType="com.alibaba.fastjson.JSONObject">
-        select material_id, batch_id
+        select id, batch_id
         from deepthink.cl_material_task_info
         where task_status in (
                               '0',

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/IClTaskStatusService.java

@@ -7,5 +7,5 @@ import java.util.List;
 public interface IClTaskStatusService {
     List<JSONObject> getClTaskListByStatus(String status);
 
-    void downLoadTaskResult(Long materialId,String batchId);
+    void downLoadTaskResult(Long id,String batchId);
 }

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/ClTaskStatusServiceImpl.java

@@ -42,7 +42,7 @@ public class ClTaskStatusServiceImpl implements IClTaskStatusService {
     }
 
     @Override
-    public void downLoadTaskResult(Long materialId, String batchId) {
+    public void downLoadTaskResult(Long id, String batchId) {
         try {
             String url = "https://openapi.mobgi.com/api/material/downLoadTaskResult";
             JSONObject jsonObject = new JSONObject();
@@ -63,13 +63,13 @@ public class ClTaskStatusServiceImpl implements IClTaskStatusService {
                                 Long clMaterialId = detail.getLong("material_id");
                                 Integer isExist = detail.getInteger("is_exist");
                                 ClMaterialTaskInfo update = new ClMaterialTaskInfo();
-                                update.setMaterialId(materialId);
+                                update.setId(id);
                                 update.setTaskStatus(status);
                                 update.setTaskMessage(taskMessage);
                                 update.setFileUrl(fileUrl);
                                 update.setClMaterialId(clMaterialId);
                                 update.setIsExist(isExist);
-                                log.info("素材ID：{}，推送状态：{}", materialId, status);
+                                log.info("id：{}，推送状态：{}", id, status);
                                 taskStatusMapper.updateClMaterialTaskInfo(update);
                             }
 
@@ -78,8 +78,8 @@ public class ClTaskStatusServiceImpl implements IClTaskStatusService {
                     }
 
 
-                }else {
-                    log.error("获取推送接口错误，materialId：{}，返回信息：{}",materialId,clJson);
+                } else {
+                    log.error("获取推送接口错误，id：{}，返回信息：{}", id, clJson);
                 }
             }
 

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/CLMaterialTaskJob.java

@@ -44,9 +44,9 @@ public class CLMaterialTaskJob {
         if (!Check.isNull(taskList)) {
             for (int i = 0; i < taskList.size(); i++) {
                 JSONObject jsonObject = taskList.get(i);
-                Long materialId = jsonObject.getLong("material_id");
+                Long id = jsonObject.getLong("id");
                 String batchId = jsonObject.getString("batch_id");
-                clTaskStatusService.downLoadTaskResult(materialId, batchId);
+                clTaskStatusService.downLoadTaskResult(id, batchId);
             }
         }
     }