yumeng преди 3 години
родител
ревизия
1e5a8767e8

+ 77 - 49
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/controller/TestController.java

@@ -1,60 +1,31 @@
 package org.jeecg.modules.ctop.controller;
 
-import cn.com.ctop.common.module.entity.*;
 import cn.com.ctop.common.module.mapper.CtopOauthTokenMapper;
 import cn.com.ctop.common.module.mapper.MailLogMapper;
 import cn.com.ctop.common.module.mapper.UserAllocationMapper;
 import cn.com.ctop.common.module.service.*;
-import cn.com.ctop.common.module.utils.*;
-import cn.com.ctop.common.module.vo.ResFileDTO;
-import cn.com.ctop.crawler.modules.core.entity.CrawlerDouyinMusicTask;
+import cn.com.ctop.common.module.utils.Check;
+import cn.com.ctop.common.module.utils.CorpWexinUtils;
 import cn.com.ctop.crawler.modules.core.service.CrawlerDouyinMusicTaskService;
 import cn.com.ctop.crawler.modules.douyin.service.DouyinMusicService;
-import cn.com.ctop.kuaishou.modules.ai.entity.AiKuaishouAdvertiserStrategy;
-import cn.com.ctop.kuaishou.modules.ai.service.IAiKuaishouAdvertiserStrategyService;
-import cn.com.ctop.kuaishou.modules.ai.service.IAiKuaishouCreateCreativeService;
-import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCreative;
-import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroup;
-import cn.com.ctop.kuaishou.modules.batch.entity.KuaishouProgramCreative;
 import cn.com.ctop.kuaishou.modules.batch.service.*;
 import cn.com.ctop.kuaishou.modules.graphql.service.IKuaishouWebInterfaceService;
-import cn.com.ctop.kuaishou.modules.material.entity.KuaishouAccessToken;
-import cn.com.ctop.kuaishou.modules.material.entity.KuaishouResultToken;
-import cn.com.ctop.kuaishou.modules.report.entity.KuaiShouProjectData;
 import cn.com.ctop.kuaishou.modules.report.service.IKuaiShouDailyAgentService;
 import cn.com.ctop.kuaishou.modules.report.service.IKuaiShouProjectDataService;
-import cn.com.ctop.kuaishou.modules.report.service.IKuaishouAudienceReportDailyService;
 import cn.com.ctop.manage.modules.material.service.IMaterialUploadService;
-import cn.com.ctop.toutiao.modules.link.service.IETLReportBytedanceVideoService;
-import cn.com.ctop.toutiao.modules.material.service.IByteDanceAdvertiserDataService;
-import cn.com.ctop.toutiao.modules.material.service.IBytedanceEffectVideoInfoService;
-import cn.com.ctop.toutiao.modules.report.entity.BytedanceCheckReportTaskInfo;
-import cn.com.ctop.toutiao.modules.report.service.*;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import cn.com.ctop.toutiao.modules.report.service.IBytedanceReportService;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.ibatis.annotations.Param;
-import org.jeecg.common.api.vo.Result;
-import org.jeecg.common.util.DateUtils;
-import org.quartz.JobExecutionException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
-import java.io.IOException;
-import java.io.InputStream;
-import java.math.BigDecimal;
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
-import java.util.*;
+import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
-import static org.jeecg.common.util.DateUtils.getAnotherDay;
-
 /**
  * @author jeecg-boot
  */
@@ -133,7 +104,7 @@ public class TestController {
 
     @Autowired
     private IBatchService batchService;
-    static ExecutorService videoService = Executors.newFixedThreadPool(8);
+    static ExecutorService videoService = Executors.newFixedThreadPool(10);
     @Autowired
     private IMaterialUploadService materialUploadService;
     @Autowired
@@ -145,7 +116,64 @@ public class TestController {
     private String jobUrl;
 
 
-    @GetMapping(value = "/getProgramCreative")
+    @GetMapping(value = "/updateMaterial")
+    public void updateMaterial() {
+
+        List<String> codeList = materialInfoService.getCodeList();
+        for (int i = 0; i < codeList.size(); i++) {
+            String s = codeList.get(i);
+            if (Check.isNull(s)) {
+                continue;
+            }
+            Integer num = materialInfoService.getCountByCode(s);
+            if (num > 0) {
+                videoService.submit(new Runnable() {
+                    @Override
+                    public void run() {
+                        try {
+                            System.err.println(s);
+                            materialInfoService.updateByCode(s);
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                });
+            }
+        }
+    }
+
+
+
+
+
+    @GetMapping(value = "/updateByteDanceMaterial")
+    public void updateByteDanceMaterial() {
+
+        List<String> codeList = materialInfoService.getBytedanceCodeList();
+        for (int i = 0; i < codeList.size(); i++) {
+            String s = codeList.get(i);
+            if (Check.isNull(s)) {
+                continue;
+            }
+            Integer num = materialInfoService.getBytedanceCountByCode(s);
+            if (num > 0) {
+                videoService.submit(new Runnable() {
+                    @Override
+                    public void run() {
+                        try {
+                            System.err.println(s);
+                            materialInfoService.updateByteDanceByCode(s);
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                });
+            }
+        }
+    }
+
+
+  /*  @GetMapping(value = "/getProgramCreative")
     public void getProgramCreative() {
         List<Long> list = new ArrayList();
 
@@ -233,9 +261,9 @@ public class TestController {
             });
         }
     }
+*/
 
-
-    @GetMapping(value = "/updateProgramCreative")
+   /* @GetMapping(value = "/updateProgramCreative")
     public void updateProgramCreative() {
         List<Long> list = new ArrayList();
         list.add(10173366L);
@@ -298,8 +326,8 @@ public class TestController {
 
         }
     }
-
-
+*/
+/*
     @GetMapping(value = "/campaignList")
     public void campaignList() {
         List<Long> list = new ArrayList();
@@ -330,10 +358,10 @@ public class TestController {
 
         }
 
-    }
+    }*/
 
 
-    @GetMapping(value = "/creativeList")
+    /*@GetMapping(value = "/creativeList")
     public void creativeList() {
         List<Long> list = new ArrayList();
         list.add(10108671L);
@@ -460,9 +488,9 @@ public class TestController {
 
         }
     }
+*/
 
-
-    @GetMapping("/testSend")
+   /* @GetMapping("/testSend")
     public void testSend(String userId) {
 
         JSONObject weChatId = mailLogMapper.getWChatIdByUserId(userId);
@@ -1477,14 +1505,14 @@ public class TestController {
     private IKuaishouStrategyService kuaishouStrategyService;
     static ExecutorService executorServic1e = Executors.newFixedThreadPool(5);
 
-    /**
+    *//**
      * 勿动勿删,煜一人群报表数据拉取接口。
      *
      * @param
      * @return void
      * @throws
      * @author ZHAOXA
-     */
+     *//*
     @PostMapping(value = "/getAudienceData")
     public Result getAudienceData(@RequestBody JSONObject request) throws Exception {
         Long accountId = request.getLong("accountId");
@@ -1624,7 +1652,7 @@ public class TestController {
         token.setAccessToken("2d25790930310af270d2160652111ccf263d3b4f");
 
         advertiserDataService.getMaterialList(token);
-    }
+    }*/
 
 
 }

+ 13 - 1
module-common/src/main/java/cn/com/ctop/common/module/mapper/MaterialInfoMapper.java

@@ -38,5 +38,17 @@ public interface MaterialInfoMapper extends BaseMapper<MaterialInfo> {
 
     JSONArray getIdListByProject(Long projectId);
 
-     // List<MaterialInfo> getListByParams(String tagCode, String type, Integer status, String materialName, String code, String startDate, String endDate, List<Long> projectIds, String ascription, String clipId, String shotId, String planId, Integer offlineFlag);
+    List<String> getCodeList();
+
+    Integer getCountByCode(@Param("code") String code);
+
+    void updateByCode(@Param("signature") String signature);
+
+    List<String> getBytedanceCodeList();
+
+    Integer getBytedanceCountByCode(@Param("code") String code);
+
+    void updateByteDanceByCode(@Param("code") String code);
+
+    // List<MaterialInfo> getListByParams(String tagCode, String type, Integer status, String materialName, String code, String startDate, String endDate, List<Long> projectIds, String ascription, String clipId, String shotId, String planId, Integer offlineFlag);
 }

+ 29 - 0
module-common/src/main/java/cn/com/ctop/common/module/mapper/xml/MaterialInfoMapper.xml

@@ -1,6 +1,19 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="cn.com.ctop.common.module.mapper.MaterialInfoMapper">
+    <update id="updateByCode">
+        UPDATE ctop_material_info
+        SET sync_kuaishou = 2
+        WHERE
+	   `code` = #{signature}
+
+    </update>
+    <update id="updateByteDanceByCode">
+        UPDATE ctop_material_info
+        SET sync_bytedance = 2
+        WHERE
+	   `code` = #{code}
+    </update>
 
 
     <select id="getProjectIdByAccountId" resultType="java.lang.Long">
@@ -175,5 +188,21 @@
         and status != 2
 
     </select>
+    <select id="getCodeList" resultType="java.lang.String">
+         SELECT `code`  from  ctop_material_info WHERE sync_kuaishou = 1
+         GROUP BY `code`
+    </select>
+    <select id="getCountByCode" resultType="java.lang.Integer">
+        SELECT count(1)  from  ctop_kuaishou_video_get WHERE signature = #{code}
+
+    </select>
+    <select id="getBytedanceCodeList" resultType="java.lang.String">
+         SELECT `code`  from  ctop_material_info WHERE sync_bytedance = 1
+         GROUP BY `code`
+
+    </select>
+    <select id="getBytedanceCountByCode" resultType="java.lang.Integer">
+        SELECT count(1)  from  ctop_bytedance_video_info WHERE signature = #{code}
+    </select>
 
 </mapper>

+ 12 - 0
module-common/src/main/java/cn/com/ctop/common/module/service/IMaterialInfoService.java

@@ -82,4 +82,16 @@ public interface IMaterialInfoService extends IService<MaterialInfo> {
     JSONArray getIdListByProject(Long projectId);
 
     Map<String, Object> getListByParams(String tagCode, String type, Integer status, String materialName, List<Long> projectIds, String code, String startDate, String endDate, String userId, String clipId, String shotId, String planId, Integer offlineFlag, Integer pageNo, Integer pageSize);
+
+    List<String> getCodeList();
+
+    Integer getCountByCode(String s);
+
+    void updateByCode(String s);
+
+    List<String> getBytedanceCodeList();
+
+    Integer getBytedanceCountByCode(String s);
+
+    void updateByteDanceByCode(String s);
 }

+ 30 - 0
module-common/src/main/java/cn/com/ctop/common/module/service/impl/MaterialInfoServiceImpl.java

@@ -860,6 +860,36 @@ public class MaterialInfoServiceImpl extends ServiceImpl<MaterialInfoMapper, Mat
         return result;
     }
 
+    @Override
+    public List<String> getCodeList() {
+        return materialInfoMapper.getCodeList();
+    }
+
+    @Override
+    public Integer getCountByCode(String s) {
+        return materialInfoMapper.getCountByCode(s);
+    }
+
+    @Override
+    public void updateByCode(String s) {
+        materialInfoMapper.updateByCode(s);
+    }
+
+    @Override
+    public List<String> getBytedanceCodeList() {
+        return materialInfoMapper.getBytedanceCodeList();
+    }
+
+    @Override
+    public Integer getBytedanceCountByCode(String s) {
+        return materialInfoMapper.getBytedanceCountByCode(s);
+    }
+
+    @Override
+    public void updateByteDanceByCode(String s) {
+        materialInfoMapper.updateByteDanceByCode(s);
+    }
+
 
     @Override
     public JSONArray getIdListByProject(Long projectId) {