头条-修改账户名称

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/controller/BytedanceController.java

@@ -46,7 +46,12 @@ public class BytedanceController {
 
     @GetMapping("/accountReport")
     public void getChannel(String param) {
-        List<JSONObject> allList = promoterReportService.getAllList();
+
+        List<JSONObject>  infos = adminAdvertiserListService.getAdvertiserInfos();
+        System.err.println(infos);
+        adminAdvertiserListService.batchUpdateAdvertiserName(infos);
+
+      /*  List<JSONObject> allList = promoterReportService.getAllList();
         for (int i = 0; i < allList.size(); i++) {
             JSONObject jsonObject = allList.get(i);
             Long advertiserId = jsonObject.getLong("advertiserId");
@@ -56,13 +61,15 @@ public class BytedanceController {
                 @Override
                 public void run() {
                     if (!Check.isNull(accessToken)) {
-                        accountReportService.getBytedanceAccountDaily(advertiserId, accessToken, "2025-02-15", "2025-03-25", 1, 1);
-                  //      accountReportService.getBytedanceAccountHour(advertiserId, accessToken, "2025-02-15", "2025-03-25", 1, 1);
+                        accountReportService.getBytedanceAccountDaily(advertiserId, accessToken, "2025-01-01", "2025-03-25", 1, 1);
+                    //    accountReportService.getBytedanceAccountHour(advertiserId, accessToken, "2025-01-01", "2025-03-25", 1, 1);
+                      //  promoterReportService.getBytedancePromoterHour(advertiserId, accessToken, "2025-01-01", "2025-03-25", 1, 1);
+                        promoterReportService.getBytedancePromoterDaily(advertiserId, accessToken, "2025-01-01", "2025-03-25", 1, 1);
                     }
                 }
             });
 
-        }
+        }*/
 
 
     }

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

@@ -1,10 +1,15 @@
 package cn.com.ctop.job.bytedance.data.mapper;
 
 import cn.com.ctop.job.bytedance.data.entity.BytedanceAdvertiserList;
+import com.alibaba.fastjson.JSONObject;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
 public interface AdminAdvertiserListMapper {
     void replaceBytedanceAdvertiserLists(@Param("adds") List<BytedanceAdvertiserList> advertiserLists);
+
+    List<JSONObject> getAdvertiserInfos();
+
+    void batchUpdateAdvertiserName(@Param("infos") List<JSONObject> infos);
 }

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

@@ -22,4 +22,20 @@
         on duplicate key update
         advertiser_name= VALUES(advertiser_name)
     </insert>
+    <update id="batchUpdateAdvertiserName">
+        <foreach collection="infos" item="info" separator=";">
+            UPDATE deepthink.advertiser_bind_info
+            SET advertiser_name = #{info.advertiserName}
+            WHERE advertiser_id = #{info.advertiserId}
+        </foreach>
+
+    </update>
+    <select id="getAdvertiserInfos" resultType="com.alibaba.fastjson.JSONObject">
+        SELECT t1.advertiser_id AS 'advertiserId', t2.advertiser_name AS 'advertiserName'
+        FROM deepthink.advertiser_bind_info t1
+                 LEFT JOIN deepthink.bytedance_advertiser_list t2
+                           ON t1.advertiser_id = t2.advertiser_id
+        WHERE t1.media_type = 1
+          AND t1.advertiser_name != t2.advertiser_name
+    </select>
 </mapper>

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

@@ -25,9 +25,12 @@
     </select>
     <select id="getAllList" resultType="com.alibaba.fastjson.JSONObject">
 
-        select t1.advertiser_id as 'advertiserId', t2.access_token as 'accessToken'
-        from deepthink.bytedance_advertiser_list t1
-                 left join deepthink.bytedance_auth_list t2 on t1.admin_advertiser_id = t2.admin_advertiser_id
+        SELECT t1.advertiser_id AS 'advertiserId', t2.access_token AS 'accessToken'
+        FROM deepthink.bytedance_advertiser_list t1
+                 LEFT JOIN deepthink.bytedance_auth_list t2 ON t1.admin_advertiser_id = t2.admin_advertiser_id
+        WHERE t2.admin_advertiser_id IN (1821394663286810,
+                                         1689471010162701
+            )
     </select>
 
     <insert id="replacePromoterReportHour">

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

@@ -2,8 +2,14 @@ package cn.com.ctop.job.bytedance.data.service;
 
 import com.alibaba.fastjson.JSONObject;
 
+import java.util.List;
+
 public interface IAdminAdvertiserListService {
     JSONObject bytedanceAdvertiserThreadPool(Integer totalPage, Integer pageSize, Long adminAdvertiserId, Long ccAccountId, String accessToken);
 
     JSONObject getBytedanceAccountListTotal(Long advertiserId, Long advertiserId1, String accessToken, Integer pageNum, Integer pageSize);
+
+    List<JSONObject> getAdvertiserInfos();
+
+    void batchUpdateAdvertiserName(List<JSONObject> infos);
 }

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

@@ -101,6 +101,16 @@ public class AdminAdvertiserListServiceImpl implements IAdminAdvertiserListServi
         return returnJson;
     }
 
+    @Override
+    public List<JSONObject> getAdvertiserInfos() {
+        return adminAdvertiserListMapper.getAdvertiserInfos();
+    }
+
+    @Override
+    public void batchUpdateAdvertiserName(List<JSONObject> infos) {
+        adminAdvertiserListMapper.batchUpdateAdvertiserName(infos);
+    }
+
     // 分页结果包装类
     static class PageResult {
         private final int pageNumber;

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

@@ -10,6 +10,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
@@ -56,4 +57,13 @@ public class AdminAdvertiserListJob {
     }
 
 
+    @XxlJob("batchUpdateAdvertiserName")
+    public void batchUpdateAdvertiserName() throws Exception {
+        List<JSONObject> infos = adminAdvertiserListService.getAdvertiserInfos();
+        if (!Check.isNull(infos)) {
+            adminAdvertiserListService.batchUpdateAdvertiserName(infos);
+        }
+    }
+
+
 }