修改配置

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

@@ -2,23 +2,38 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="cn.com.ctop.job.bytedance.data.mapper.BytedanceRefreshTokenMapper">
     <update id="updateTokenByAdminAdvertiserId">
-        UPDATE deepthink.bytedance_auth_list
-        SET access_token  = #{updateAccessToken},
-            refresh_token = #{updateRefreshToken},
-            token_update_time = now()
+        UPDATE nuojing_data.media_auth_account
+        SET access_token             = #{updateAccessToken},
+            refresh_token            = #{updateRefreshToken},
+            access_token_expire_time = DATE_ADD(now(), INTERVAL 24 HOUR)
         WHERE admin_advertiser_id = #{adminAdvertiserId}
+          AND media_type = 1
     </update>
 
 
     <select id="getTokenList" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT admin_advertiser_id AS 'adminAdvertiserId', access_token AS 'accessToken', refresh_token AS 'refreshToken', app_id AS 'appId', secret AS 'secret'
-        FROM deepthink.bytedance_auth_list
+        SELECT a.admin_advertiser_id AS 'adminAdvertiserId',
+               a.access_token        AS 'accessToken',
+               a.refresh_token       AS 'refreshToken',
+               a.app_id              AS 'appId',
+               COALESCE(c.client_secret, c.app_secret) AS 'secret'
+        FROM nuojing_data.media_auth_account a
+                 JOIN nuojing_data.media_auth_config c
+                      ON c.media_type = a.media_type AND c.app_id = a.app_id
+        WHERE a.media_type = 1
     </select>
 
     <select id="getTokenToRefreshList" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT admin_advertiser_id AS 'adminAdvertiserId', access_token AS 'accessToken', refresh_token AS 'refreshToken', app_id AS 'appId', secret AS 'secret'
-        FROM deepthink.bytedance_auth_list
-        where timestampdiff(HOUR,token_update_time,now()) >= 23 or token_update_time is null
+        SELECT a.admin_advertiser_id AS 'adminAdvertiserId',
+               a.access_token        AS 'accessToken',
+               a.refresh_token       AS 'refreshToken',
+               a.app_id              AS 'appId',
+               COALESCE(c.client_secret, c.app_secret) AS 'secret'
+        FROM nuojing_data.media_auth_account a
+                 JOIN nuojing_data.media_auth_config c
+                      ON c.media_type = a.media_type AND c.app_id = a.app_id
+        WHERE a.media_type = 1
+          AND timestampdiff(HOUR, a.update_time, now()) >= 23
     </select>
 
     <select id="onlyGetToken" resultType="java.lang.String">

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

@@ -89,4 +89,25 @@ public class BytedanceAccountReportJob {
     }
 
 
+
+    @XxlJob("nowDailyAccountReport")
+    public void nowDailyAccountReport() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String[] s = param.split("_");
+        Long advertiserId = Long.valueOf(s[0]);
+        String accessToken = s[1];
+        dailyExecutorService.submit(new Runnable() {
+            @Override
+            public void run() {
+                accountReportService.getBytedanceAccountDaily(advertiserId, accessToken, nowDate, nowDate, 1, 1);
+            }
+        });
+    }
+
+
 }

nj_job-bytedance/src/main/resources/application.yml

@@ -136,7 +136,7 @@ xxl:
       logpath: /data/webapp/nj_job-bytedance/log
       logretentiondays: 3
     admin:
-      addresses: http://192.168.10.211:9003/xxl-job-admin
+      addresses: http://127.0.0.1:9003/xxl-job-admin
 api:
   bytedance:
     api-prefix: https://ad.oceanengine.com/open_api