Merge remote-tracking branch 'origin/master'

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

@@ -79,7 +79,8 @@
         url,
         promotion_create_time,
         promotion_modify_time,
-        playlet_series_url_list
+        playlet_series_url_list,
+        status_first
         )
         values
         <foreach collection="list" item="item" separator=",">
@@ -93,7 +94,8 @@
             #{item.url},
             #{item.promotion_create_time},
             #{item.promotion_modify_time},
-            #{item.playlet_series_url_list}
+            #{item.playlet_series_url_list},
+            #{item.status_first}
             )
         </foreach>
     </insert>

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

@@ -104,7 +104,7 @@
         on t.advertiser_id = x.advertiser_id
         join deepthink.bytedance_auth_list a
         on x.admin_advertiser_id = a.admin_advertiser_id
-        where t.om_task_status is null or t.om_task_status not in (4,6,7,8)
+        where (t.om_task_status is null or t.om_task_status not in (6,7,8))
         <if test="advertiserId != null">
             and t.advertiser_id = ${advertiserId}
         </if>
@@ -117,7 +117,7 @@
         on t.advertiser_id = x.advertiser_id
         join deepthink.bytedance_auth_list a
         on x.admin_advertiser_id = a.admin_advertiser_id
-        where t.om_task_status not in (1,2,6)
+        where (t.om_task_status not in (1,2,4) or t.om_task_status is null)
         and (t.end_time is null or t.end_time >= unix_timestamp(date_add(now(),Interval -65 day)))
         <if test="advertiserId != null">
             and t.advertiser_id = ${advertiserId}

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

@@ -22,78 +22,58 @@
         pay_counts,
         order_counts
         )
-        SELECT
-            t3.date,
-            t0.official_account_id,
-            t0.responsibility_person_id,
-            t2.app_id,
-            t0.id,
-            t3.new_users,
-            t1.new_pay_users,
-            t1.new_pay_counts,
-            t1.new_order_counts,
-            t1.new_pay_amount,
-            t1.new_xn_pay_amount,
-            t1.pay_amount,
-            t1.xn_pay_amount,
-            t1.pay_users,
-            t1.pay_counts,
-            t1.order_counts
-        FROM
-            (
-                SELECT
-                    DATE_FORMAT( activation_time, '%Y%m%d' ) as 'date',
-                        link_id,
-                    count( DISTINCT uid ) AS 'new_users'
-                FROM
-                    thirtpart.ly_user_activation_info
-                WHERE
-                    DATE_FORMAT( activation_time, '%Y%m%d' ) = #{nowDate}
-                GROUP BY
-                    link_id
-            ) t3
-                LEFT JOIN	thirtpart.ly_link t0 ON t0.id = t3.link_id
-                LEFT JOIN (
-                SELECT
-                    consume_date,
+        SELECT t3.date,
+               t0.official_account_id,
+               t0.responsibility_person_id,
+               t2.app_id,
+               t0.id,
+               t3.new_users,
+               t1.new_pay_users,
+               t1.new_pay_counts,
+               t1.new_order_counts,
+               t1.new_pay_amount,
+               t1.new_xn_pay_amount,
+               t1.pay_amount,
+               t1.xn_pay_amount,
+               t1.pay_users,
+               t1.pay_counts,
+               t1.order_counts
+        FROM (SELECT DATE_FORMAT(activation_time, '%Y%m%d') as 'date', link_id,
+                     count(DISTINCT uid) AS 'new_users'
+              FROM thirtpart.ly_user_activation_info
+              WHERE DATE_FORMAT(activation_time, '%Y%m%d') = #{nowDate}
+              GROUP BY link_id) t3
+                 LEFT JOIN thirtpart.ly_link t0 ON t0.id = t3.link_id
+                 LEFT JOIN (SELECT consume_date,
 
-                    link_id,
+                                   link_id,
 
-                    count( DISTINCT CASE WHEN t1.consume_date = DATE_FORMAT( t1.activation_time, '%Y%m%d' ) THEN t1.uid END ) AS 'new_pay_users',
+                                   count(DISTINCT CASE
+                                                      WHEN t1.consume_date =
+                                                           DATE_FORMAT(t1.activation_time, '%Y%m%d') AND t1.STATUS = 1
+                                                          THEN t1.uid END) AS 'new_pay_users', SUM(IF(
+                        t1.consume_date = DATE_FORMAT(t1.activation_time, '%Y%m%d') AND t1.STATUS = 1, 1,
+                        0)) AS 'new_pay_counts', SUM(IF(t1.consume_date = DATE_FORMAT(t1.activation_time, '%Y%m%d'), 1,
+                                                        0)) AS 'new_order_counts', IFNULL( ROUND(
+                        SUM(IF(t1.consume_date = DATE_FORMAT(t1.activation_time, '%Y%m%d') AND t1.STATUS = 1,
+                               t1.total_fee, 0)), 2),0.00 ) AS 'new_pay_amount', IFNULL(ROUND(SUM(IF(
+                        t1.consume_date = DATE_FORMAT(t1.activation_time, '%Y%m%d') AND t1.STATUS = 1 AND
+                        (t1.pay_merchant = 15 OR pay_type = 20), total_fee, 0)),
+                                                                                              2),0.00 ) AS 'new_xn_pay_amount', IFNULL( ROUND(SUM(if(t1.STATUS = 1, t1.total_fee, 0)), 2), 0.00 ) AS 'pay_amount', IFNULL( ROUND(
+                        SUM(IF(t1.STATUS = 1 AND (t1.pay_merchant = 15 OR pay_type = 20), total_fee, 0)),
+                        2), 0.00 ) AS 'xn_pay_amount', count(DISTINCT CASE WHEN t1.STATUS = 1 THEN t1.uid END ) AS 'pay_users', SUM(IF(t1.STATUS = 1, 1, 0)) AS 'pay_counts', count( t1.order_no ) AS 'order_counts'
 
-                        SUM(IF( t1.consume_date = DATE_FORMAT( t1.activation_time, '%Y%m%d' ) AND t1.STATUS = 1, 1, 0 )) AS 'new_pay_counts',
-
-                        SUM(IF( t1.consume_date = DATE_FORMAT( t1.activation_time, '%Y%m%d' ), 1, 0 )) AS 'new_order_counts',
-
-                        IFNULL(	ROUND( SUM( IF ( t1.consume_date = DATE_FORMAT( t1.activation_time, '%Y%m%d' ), t1.total_fee, 0 )), 2 ),0.00 ) AS 'new_pay_amount',
-
-                        IFNULL(ROUND(SUM(IF(t1.consume_date = DATE_FORMAT( t1.activation_time, '%Y%m%d') AND ( t1.pay_merchant = 15 OR pay_type = 20 ),	total_fee,0 )),	2 ),0.00 ) AS 'new_xn_pay_amount',
-
-                        IFNULL( ROUND( SUM( t1.total_fee ), 2 ), 0.00 ) AS 'pay_amount',
-
-                        IFNULL( ROUND( SUM( IF ( t1.pay_merchant = 15 OR pay_type = 20, total_fee, 0 )), 2 ), 0.00 ) AS 'xn_pay_amount',
-
-                        count( DISTINCT t1.uid ) AS 'pay_users',
-
-                        SUM(IF( t1.STATUS = 1, 1, 0 )) AS 'pay_counts',
-
-                        count( t1.order_no ) AS 'order_counts'
-
-                FROM
-                    thirtpart.ly_pay_record t1
-                WHERE
-                    consume_date = #{nowDate}
-                GROUP BY
-                    link_id
-            ) t1 ON  t3.link_id = t1.link_id
-                LEFT JOIN thirtpart.ly_official_accounts t2 ON t0.official_account_id = t2.id
+                            FROM thirtpart.ly_pay_record t1
+                            WHERE consume_date = #{nowDate}
+                            GROUP BY link_id) t1 ON t3.link_id = t1.link_id
+                 LEFT JOIN thirtpart.ly_official_accounts t2 ON t0.official_account_id = t2.id
         WHERE official_account_id is not null
-        GROUP BY
-            t3.link_id
+        GROUP BY t3.link_id
     </insert>
 
     <insert id="cleanCPSIaaDailyReports">
-        replace into thirtpart.cps_link_data_report
+        replace
+        into thirtpart.cps_link_data_report
         (
                 stat_date,
                 official_account_id,
@@ -118,90 +98,78 @@
                 iaa_amount,
 				active_users
                 )
-        select
-            t.date,
-            t.official_account_id,
-            t.responsibility_person_id,
-            t.app_id,
-            t.link_id,
-            t1.new_users,
-            t3.new_pay_users,
-            t3.new_pay_counts,
-            t3.new_order_counts,
-            t3.new_pay_amount,
-            t3.new_xn_pay_amount,
-            t3.pay_amount,
-            t3.xn_pay_amount,
-            t3.pay_users,
-            t3.pay_counts,
-            t3.order_counts,
-            t0.new_iaa_users,
-            t0.new_iaa_counts,
-            t0.new_iaa_amount,
-            t0.iaa_users,
-            t0.iaa_counts,
-            t0.iaa_amount,
-            t.active_users
-        FROM
-            (
-                SELECT
-                    t.date,
-                    t.link_id,
-                    t.official_account_id,
-                    t0.responsibility_person_id,
-                    t2.app_id,
-                    COUNT( DISTINCT t.uid) as 'active_users'
-                FROM thirtpart.ly_user_login_record t
-                         LEFT JOIN  thirtpart.ly_link t0 ON t0.id = t.link_id
-                         LEFT JOIN thirtpart.ly_official_accounts t2 ON t.official_account_id = t2.id
-                where date = #{nowDate}
-                  AND link_id >0
-                  AND t0.responsibility_person_id is not null
-                GROUP BY link_id
-                ) t
-                LEFT JOIN
-                (
-                SELECT
-                    t.link_id,
-                    count(distinct case when SUBSTR(dying_time,1,10) = SUBSTR(event_time,1,10) then uid end) 'new_iaa_users',
-                        sum(if(SUBSTR(dying_time,1,10) = SUBSTR(event_time,1,10) ,1,0)) 'new_iaa_counts',
-                        IFNULL(ROUND(sum(if(SUBSTR(dying_time,1,10) = SUBSTR(event_time,1,10) ,cost/100000,0)),2),0.00) 'new_iaa_amount',
-                        count(distinct uid) 'iaa_users',
-                        sum(1) 'iaa_counts',
-                        IFNULL(ROUND(sum(cost/100000),2),0.00)  'iaa_amount'
-                FROM
-                    media_api.bytedance_webhook_ma_ecpm t
-                where t.stat_date = #{nowDate}
-                GROUP BY t.link_id
-            ) t0 ON t.link_id = t0.link_id
-                LEFT JOIN (
-                SELECT
-                    t0.id,
-                    t0.official_account_id,
-                    t0.responsibility_person_id,
-                    count(DISTINCT t.uid) AS 'new_users'
-                FROM thirtpart.ly_user_activation_info t
-                         LEFT JOIN thirtpart.ly_link t0 ON t.link_id = t0.id
-                WHERE DATE_FORMAT(t.activation_time, '%Y%m%d') =#{nowDate}
-                GROUP BY t0.id
-            ) t1 ON t.link_id = t1.id
-                LEFT JOIN
-            (
-                SELECT
-                    link_id,
-                    new_pay_users,
-                    new_pay_counts,
-                    new_order_counts,
-                    new_pay_amount,
-                    new_xn_pay_amount,
-                    pay_amount,
-                    xn_pay_amount,
-                    pay_users,
-                    pay_counts,order_counts
-                FROM thirtpart.cps_link_data_report WHERE
-                    stat_date = #{nowDate}
-            ) t3 ON t3.link_id = t.link_id
-        GROUP BY t.link_id
+        SELECT IFNULL(t.date, t0.date),
+               tt.official_account_id,
+               tt.responsibility_person_id,
+               tt.app_id,
+               tt.id,
+               t1.new_users,
+               t3.new_pay_users,
+               t3.new_pay_counts,
+               t3.new_order_counts,
+               t3.new_pay_amount,
+               t3.new_xn_pay_amount,
+               t3.pay_amount,
+               t3.xn_pay_amount,
+               t3.pay_users,
+               t3.pay_counts,
+               t3.order_counts,
+               t0.new_iaa_users,
+               t0.new_iaa_counts,
+               t0.new_iaa_amount,
+               t0.iaa_users,
+               t0.iaa_counts,
+               t0.iaa_amount,
+               t.active_users
+        FROM (SELECT t0.id,
+                     t0.responsibility_person_id,
+                     t0.official_account_id,
+                     t2.app_id
+              FROM thirtpart.ly_link t0
+                       LEFT JOIN thirtpart.ly_official_accounts t2 ON t0.official_account_id = t2.id) tt
+                 LEFT JOIN
+             (SELECT t.date, t.link_id, COUNT(DISTINCT t.uid) as 'active_users'
+              FROM thirtpart.ly_user_login_record t
+              where date = #{nowDate}
+                AND link_id
+                  >0
+              GROUP BY link_id) t ON tt.id = t.link_id
+                 LEFT JOIN
+             (SELECT t.stat_date as 'date', t.link_id,
+                     count(distinct case
+                                        when SUBSTR(dying_time, 1, 10) = SUBSTR(event_time, 1, 10)
+                                            then uid end) 'new_iaa_users', sum(if(SUBSTR(dying_time, 1, 10) = SUBSTR(event_time, 1, 10), 1, 0)) 'new_iaa_counts', IFNULL(ROUND(
+                             sum(if(SUBSTR(dying_time, 1, 10) = SUBSTR(event_time, 1, 10), cost / 100000, 0)),
+                             2),0.00) 'new_iaa_amount', count(distinct uid) 'iaa_users', sum(1) 'iaa_counts', IFNULL(ROUND(sum(cost / 100000), 2),0.00) 'iaa_amount'
+              FROM media_api.bytedance_webhook_ma_ecpm t
+                       LEFT JOIN thirtpart.ly_link t0 ON t.link_id = t0.id
+              where t.stat_date = #{nowDate}
+              GROUP BY t.link_id
+              ORDER BY t.link_id) t0 ON tt.id = t0.link_id
+                 LEFT JOIN (SELECT t0.id,
+                                   DATE_FORMAT(t.activation_time, '%Y%m%d') as 'date', t0.official_account_id,
+                                   t0.responsibility_person_id,
+                                   count(DISTINCT t.uid) AS 'new_users'
+                            FROM thirtpart.ly_user_activation_info t
+                                     LEFT JOIN thirtpart.ly_link t0 ON t.link_id = t0.id
+                            WHERE DATE_FORMAT(t.activation_time, '%Y%m%d') = #{nowDate}
+                            GROUP BY t0.id) t1 ON tt.id = t1.id
+                 LEFT JOIN
+             (SELECT link_id,
+                     new_pay_users,
+                     new_pay_counts,
+                     new_order_counts,
+                     new_pay_amount,
+                     new_xn_pay_amount,
+                     pay_amount,
+                     xn_pay_amount,
+                     pay_users,
+                     pay_counts,
+                     order_counts
+              FROM thirtpart.cps_link_data_report
+              WHERE stat_date = #{nowDate}) t3 ON t3.link_id = tt.id
+        WHERE t0.iaa_amount is not null
+        GROUP BY tt.id
     </insert>
 
 </mapper>

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

@@ -97,7 +97,6 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
                 filtering.put("promotion_modify_time", date);
             }
             filtering.put("status_first", "PROMOTION_STATUS_ALL");
-
             params.put("filtering", filtering);
             params.put("page", page);
             params.put("page_size", 20);//最大20

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

@@ -38,6 +38,29 @@ public class TotalRankPushServiceImpl implements ITotalRankPushService {
 
     @Override
     public void send() {
+        List<String> userIds = Arrays.asList(
+        "44fbaed6",//zhaotx
+        "ebeeced9",//yumeng
+        "c5f6b59d",//余洋
+        "a3235a61",//楼子君
+        "265g9ef1",//王舒
+        "d834552b",//何梦豪
+        "59g6d358",//陈秋灵
+        "13dfc1gg",//刘恩麟
+        "58e7a98a",//xsq
+        "2ga9669f",//angaoqi
+        "b9e2ac3e",//wangdan
+        "bg5dcf61",//wangxuedi
+        "ga91e5d5",//yangcheng
+        "e1db71eb",//maojun
+        "dc653318",//zhangkaiwen
+        "ce65d5c1",//zhoutong
+        "ae982dg9"//lijinhua
+        );
+        send(userIds);
+    }
+    private void send(List<String> userIds)
+    {
         List<JSONObject> users = reportsPushMapper.selectUserList();
         List<String> mobiles = users.stream().map(user -> user.getString("phonenumber"))
                 .filter(s -> s != null && s.length() == 11)
@@ -117,20 +140,9 @@ public class TotalRankPushServiceImpl implements ITotalRankPushService {
         p3p4List.forEach(sb::append);
         sb.append(p5);
 
-        sendToFeishu(token, sb.toString(), "44fbaed6");//zhaotx
-        sendToFeishu(token, sb.toString(), "c5f6b59d");//余洋
-        sendToFeishu(token, sb.toString(), "a3235a61");//楼子君
-        sendToFeishu(token, sb.toString(), "265g9ef1");//王舒
-        sendToFeishu(token, sb.toString(), "d834552b");//何梦豪
-        sendToFeishu(token, sb.toString(), "59g6d358");//陈秋灵
-        sendToFeishu(token, sb.toString(), "13dfc1gg");//刘恩麟
-        sendToFeishu(token, sb.toString(), "58e7a98a");//xsq
-        sendToFeishu(token, sb.toString(), "2ga9669f");//angaoqi
-        sendToFeishu(token, sb.toString(), "b9e2ac3e");//wangdan
-        sendToFeishu(token, sb.toString(), "bg5dcf61");//wangxuedi
-        sendToFeishu(token, sb.toString(), "ga91e5d5");//yangcheng
-        sendToFeishu(token, sb.toString(), "e1db71eb");//maojun
-        sendToFeishu(token, sb.toString(), "dc653318");//zhangkaiwen
+        for (String userId : userIds){
+            sendToFeishu(token, sb.toString(), userId);
+        }
 
     }
 

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

@@ -144,6 +144,7 @@ public class BytedanceReportRetryJob {
 
         List<JSONObject> changDuRetry = channelService.getChangDuRetry();
         if (!Check.isNull(changDuRetry)) {
+            ExecutorService executorService = Executors.newFixedThreadPool(1);
             for (int i = 0; i < changDuRetry.size(); i++) {
                 JSONObject jsonObject = changDuRetry.get(i);
                 Long id = jsonObject.getLong("id");
@@ -157,7 +158,12 @@ public class BytedanceReportRetryJob {
                 String appId = jsonObject.getString("channelAppId");
                 String appName = jsonObject.getString("channelAppName");
                 if ("changdu_order".equals(dataDimension)) {
-                    channelService.getOrderList(startDate, endDate, appId, appName, channelAccountId, secretKey, 1, id, isSend);
+                    executorService.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            channelService.getOrderList(startDate, endDate, appId, appName, channelAccountId, secretKey, 1, id, isSend);
+                        }
+                    });
                 }
             }
         } else {
@@ -166,6 +172,7 @@ public class BytedanceReportRetryJob {
 
         List<JSONObject> maEcpmRetryJob = miniAppService.getMaEcpmRetryJob();
         if (!Check.isNull(maEcpmRetryJob)) {
+            ExecutorService executorService = Executors.newFixedThreadPool(1);
             for (int i = 0; i < maEcpmRetryJob.size(); i++) {
                 JSONObject jsonObject = maEcpmRetryJob.get(i);
                 Long id = jsonObject.getLong("id");
@@ -175,7 +182,12 @@ public class BytedanceReportRetryJob {
                 Integer isSend = jsonObject.getInteger("isSend");
                 if (dataDimension != null && dataDimension.startsWith("ma_ecpm:")) {
                     String appId = dataDimension.split(":")[1];
-                    miniAppService.getMaEcpm(startDate, endDate, appId, 1, id, isSend);
+                    executorService.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            miniAppService.getMaEcpm(startDate, endDate, appId, 1, id, isSend);
+                        }
+                    });
                 }
             }
         } else {
@@ -184,6 +196,7 @@ public class BytedanceReportRetryJob {
 
         List<JSONObject> xingTuRetryJob = bytedanceXingTuService.getXingTuRetryJob();
         if (!Check.isNull(xingTuRetryJob)) {
+            ExecutorService executorService = Executors.newFixedThreadPool(2);
             for (int i = 0; i < xingTuRetryJob.size(); i++) {
                 JSONObject jsonObject = xingTuRetryJob.get(i);
                 Long id = jsonObject.getLong("id");
@@ -196,11 +209,26 @@ public class BytedanceReportRetryJob {
                 Long taskId = jsonObject.getJSONObject("msg").getLong("taskId");
 
                 if ("xingtu_task_list".equalsIgnoreCase(dataDimension)) {
-                    bytedanceXingTuService.getXingTuTaskList(advertiserId, accessToken, startDate, endDate, 1, id, null, isSend);
+                    executorService.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            bytedanceXingTuService.getXingTuTaskList(advertiserId, accessToken, startDate, endDate, 1, id, null, isSend);
+                        }
+                    });
                 } else if ("xingtu_task_info".equalsIgnoreCase(dataDimension)) {
-                    bytedanceXingTuService.getXingTuTaskInfo(advertiserId, taskId, accessToken, id, null, isSend);
+                    executorService.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            bytedanceXingTuService.getXingTuTaskInfo(advertiserId, taskId, accessToken, id, null, isSend);
+                        }
+                    });
                 } else if ("xingtu_task_report".equalsIgnoreCase(dataDimension)) {
-                    bytedanceXingTuService.getXingTuTaskReport(advertiserId, taskId, accessToken, 1, id, null, isSend);
+                    executorService.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            bytedanceXingTuService.getXingTuTaskReport(advertiserId, taskId, accessToken, 1, id, null, isSend);
+                        }
+                    });
                 }
             }
         } else {

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

@@ -8,9 +8,10 @@ import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
-import org.springframework.web.bind.annotation.RequestParam;
 
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 
 @Slf4j
@@ -34,24 +35,36 @@ public class BytedanceXingTuJob {
 
     @XxlJob("xingTuTaskInfo")
     public void taskInfo() {
+        ExecutorService executorService = Executors.newFixedThreadPool(4);
         List<JSONObject> xingTuTasks = bytedanceXingTuService.getXingTuActiveTask(null);
         for (JSONObject taskJson : xingTuTasks) {
             Long advId = taskJson.getLong("advertiser_id");
             Long taskId = taskJson.getLong("task_id");
             String accessToken = taskJson.getString("access_token");
-            bytedanceXingTuService.getXingTuTaskInfo(advId, taskId, accessToken, null, 1, null);
+            executorService.submit(new Runnable() {
+                @Override
+                public void run() {
+                    bytedanceXingTuService.getXingTuTaskInfo(advId, taskId, accessToken, null, 1, null);
+                }
+            });
         }
 
     }
 
     @XxlJob("xingTuTaskReport")
     public void taskReport() {
+        ExecutorService executorService = Executors.newFixedThreadPool(4);
         List<JSONObject> xingTuTasks = bytedanceXingTuService.getXingTuReportTask(null);
         for (JSONObject taskJson : xingTuTasks) {
             Long advId = taskJson.getLong("advertiser_id");
             Long taskId = taskJson.getLong("task_id");
             String accessToken = taskJson.getString("access_token");
-            bytedanceXingTuService.getXingTuTaskReport(advId, taskId, accessToken, 1, null, 1, null);
+            executorService.submit(new Runnable() {
+                @Override
+                public void run() {
+                    bytedanceXingTuService.getXingTuTaskReport(advId, taskId, accessToken, 1, null, 1, null);
+                }
+            });
         }
 
     }

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

@@ -3,6 +3,7 @@ package cn.com.ctop.job.bytedance.handler;
 
 import cn.com.ctop.job.bytedance.data.service.IToolsSiteService;
 import cn.com.ctop.job.bytedance.data.utils.Check;
+import cn.com.ctop.job.bytedance.data.utils.HttpUtils;
 import com.alibaba.fastjson.JSONObject;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
@@ -92,6 +93,12 @@ public class ToolsSiteJob {
                 toolsSiteService.publishSiteStatus(o.getLong("advertiser_id"), o.getString("task_id"));
             }));
         }
+
+        //更新短剧剧集时长字段
+        String url = "https://api.deepthink.artlinkworld.cn/hrJava/videos/getVideosInfo";
+        HttpUtils.httpPostRequest(url, null, null);
+
+
     }
 
 }