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

拒审重提提交

zhouzeyu@c-top.com.cn 3 éve
szülő
commit
7417452d72

+ 3 - 1
jeecg-boot-module-system/src/main/java/cn/com/ctop/kuaishou/modules/batch/entity/KuaiShouCreative.java

@@ -224,7 +224,9 @@ public class KuaiShouCreative {
     private Integer creativeCategory;
     private String creativeTag;
 
-    private Integer submit_size;
+    private Integer submitSize;
 
     private Integer resubmit;
+
+    private String copyWriterId;
 }

+ 5 - 4
jeecg-boot-module-system/src/main/java/cn/com/ctop/kuaishou/modules/document/mapper/AuditRejectedResubmitMapper.java

@@ -4,17 +4,18 @@ import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCreative;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.Date;
 import java.util.List;
 
 @Mapper
 public interface AuditRejectedResubmitMapper {
-    List<KuaiShouCreative> getCreativeList(@Param("status") int status,@Param("date") String date);
+    List<KuaiShouCreative> getCreativeList(@Param("status") int status, @Param("date") String date);
 
     List<String> getRejectThesaurusListByStatus(@Param("status") int status);
 
-    void updateCreativeResubmit(@Param("creativeId") String creativeId,@Param("status") int status);
-
-    void updateCreativeResubmitSize(@Param("creativeId") Long creativeId);
+    void updateCreativeResubmit(@Param("creativeId") String creativeId, @Param("status") int status);
 
+    void updateCreativeResubmitSize(@Param("creativeId") Long creativeId,@Param("copyWriterId") String copyWriterId);
 
+    void saveCopyWriterCenter(@Param("copyWriterId") String copyWriterId, @Param("creativeId") String creativeId, @Param("date") Date date);
 }

+ 6 - 5
jeecg-boot-module-system/src/main/java/cn/com/ctop/kuaishou/modules/document/mapper/DocumentLibraryMapper.java

@@ -6,6 +6,7 @@ import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 @Mapper
 public interface DocumentLibraryMapper {
@@ -14,13 +15,13 @@ public interface DocumentLibraryMapper {
 
     List<JSONObject> getDocumentLibraryList(@Param("list") List<String> list, @Param("keywords") String keywords, @Param("startDate") String startDate, @Param("endDate") String endDate, @Param("status") String status);
 
-    void updateStatus(@Param("copyWriterId")String copyWriterId, @Param("status")String status);
+    void updateStatus(@Param("copyWriterId") String copyWriterId, @Param("status") String status);
 
-    List<JSONObject> getRefusedList(@Param("copyWriterId")String copyWriterId);
+    List<JSONObject> getRefusedList(@Param("copyWriterId") String copyWriterId);
 
-    List<String> getAcoountId(@Param("copyWriterId")String copyWriterId);
+    List<String> getAcoountId(@Param("copyWriterId") String copyWriterId);
 
-    List<String> getDataByAccountId(@Param("accountId")String accountId, @Param("copyWriterId")String copyWriterId);
+    List<String> getDataByAccountId(@Param("accountId") String accountId, @Param("copyWriterId") String copyWriterId);
 
-    List<String> getDocumentByAccountId(@Param("accountId")String accountId,@Param("description")String description);
+    List<Map<String,String>> getDocumentByAccountId(@Param("accountId") String accountId, @Param("copyWriterId") String copyWriterId);
 }

+ 5 - 1
jeecg-boot-module-system/src/main/java/cn/com/ctop/kuaishou/modules/document/mapper/xml/AuditRejectedResubmitMapper.xml

@@ -19,6 +19,10 @@
     </update>
 
     <update id="updateCreativeResubmitSize">
-        update ctop_kuaishou_creative set submit_size=submit_size+1 where creative_id=#{creativeId}
+        update ctop_kuaishou_creative set submit_size=submit_size+1,copy_writer_id=#{copyWriterId} where creative_id=#{creativeId}
     </update>
+
+    <insert id="saveCopyWriterCenter">
+        replace into ctop_document_library_center (creative_id,copy_writer_id,create_time) values (#{creativeId},#{copyWriterId},#{date})
+    </insert>
 </mapper>

+ 5 - 2
jeecg-boot-module-system/src/main/java/cn/com/ctop/kuaishou/modules/document/mapper/xml/DocumentLibraryMapper.xml

@@ -56,8 +56,11 @@
         select id from ctop_document_library  where account_id=#{accountId} and copy_writer_id=#{copyWriterId}
      </select>
 
-    <select id="getDocumentByAccountId" resultType="String">
-        select copy_writer from ctop_document_library  where account_id=#{accountId} and copy_writer!=#{description}
+    <select id="getDocumentByAccountId" resultType="Map">
+        select copy_writer_id as 'copyWriterId',copy_writer as 'copyWriter' from ctop_document_library  where account_id=#{accountId}
+        <if test="copyWriterId!=null and copyWriterId!=''">
+            and copy_writer_id !=#{copyWriterId}
+        </if>
      </select>
 
 </mapper>

+ 12 - 10
jeecg-boot-module-system/src/main/java/cn/com/ctop/kuaishou/modules/document/service/impl/AuditRejectedResubmitServiceImpl.java

@@ -12,7 +12,6 @@ import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouUpdateService;
 import cn.com.ctop.kuaishou.modules.document.mapper.AuditRejectedResubmitMapper;
 import cn.com.ctop.kuaishou.modules.document.mapper.DocumentLibraryMapper;
 import cn.com.ctop.kuaishou.modules.document.service.AuditRejectedResubmitService;
-import cn.com.ctop.kuaishou.modules.document.service.DocumentLibraryService;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import lombok.extern.slf4j.Slf4j;
@@ -70,7 +69,7 @@ public class AuditRejectedResubmitServiceImpl implements AuditRejectedResubmitSe
         calendar.roll(Calendar.DAY_OF_YEAR, -1);
         try {
             log.info(formatter.format(calendar.getTime()));
-            creativeList = auditRejectedResubmitMapper.getCreativeList(42,formatter.format(calendar.getTime()));
+            creativeList = auditRejectedResubmitMapper.getCreativeList(42, formatter.format(calendar.getTime()));
             //可重提词组
             List<String> submit = auditRejectedResubmitMapper.getRejectThesaurusListByStatus(0);
             //不可重提词组
@@ -89,7 +88,7 @@ public class AuditRejectedResubmitServiceImpl implements AuditRejectedResubmitSe
                         //重提
                         log.info("进行重提:{}", reviewDetail);
                         Integer submit_size = obj.getSubmitSize();
-                        if(submit_size<2){
+                        if (submit_size < 2) {
                             JSONObject updateJson = new JSONObject();
                             updateJson.put("creativeId", obj.getCreativeId());
                             //更换封面
@@ -104,20 +103,23 @@ public class AuditRejectedResubmitServiceImpl implements AuditRejectedResubmitSe
                                 }
                             }
                             //更换文案
-                            List<String> documentByAccountId = documentLibraryMapper.getDocumentByAccountId(String.valueOf(obj.getAccountId()),obj.getDescription());
-                            if(!documentByAccountId.isEmpty()){
-                                updateJson.put("description", documentByAccountId.get(0));
+                            List<Map<String, String>> documentByAccountId = documentLibraryMapper.getDocumentByAccountId(String.valueOf(obj.getAccountId()), obj.getCopyWriterId());
+                            if (!documentByAccountId.isEmpty()) {
+                                updateJson.put("description", documentByAccountId.get(0).get("copyWriter"));
                             }
                             Map<String, Object> creativeMap = updateService.updateCreative(oauthToken.getAccessToken(), obj.getAccountId(), updateJson);
                             Integer code = (Integer) creativeMap.get("code");
                             if (code == 0) {
-                                auditRejectedResubmitMapper.updateCreativeResubmitSize(obj.getCreativeId());
+                                //修改重提次数和文案id
+                                auditRejectedResubmitMapper.updateCreativeResubmitSize(obj.getCreativeId(), documentByAccountId.get(0).get("copyWriterId"));
+                                //插入文案关联创意表信息
+                                auditRejectedResubmitMapper.saveCopyWriterCenter(documentByAccountId.get(0).get("copyWriterId"), String.valueOf(obj.getCreativeId()), new Date());
                                 log.info("拒审重提成功,accountId:{},creativeId:{}", obj.getAccountId(), obj.getCreativeId());
                             } else {
-                                log.info("拒审重提失败,accountId:{},creativeId:{}",  obj.getAccountId(), obj.getCreativeId());
+                                log.info("拒审重提失败,accountId:{},creativeId:{}", obj.getAccountId(), obj.getCreativeId());
                             }
-                        }else {
-                            log.info("重提次数已达上限:accountId:{},creativeId:{}",obj.getAccountId(), obj.getCreativeId());
+                        } else {
+                            log.info("重提次数已达上限:accountId:{},creativeId:{}", obj.getAccountId(), obj.getCreativeId());
                         }
 
                     } else {