adq

xxl-job-admin/src/main/java/com/xxl/job/admin/core/trigger/XxlJobTrigger.java

@@ -63,13 +63,13 @@ public class XxlJobTrigger {
         if (subAccount.equals("1")) {
             Integer mediaId = Integer.valueOf(jobInfo.getMediaId());
             if (mediaId == 1) { // 查询字节需要拉取的账户列表
-                 accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getLiveAccountList();
+                accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getLiveAccountList();
             }
             if (mediaId == 2) { // 查询快手需要拉取的账户列表
                 // accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getLiveDuanJuAccountList();
             }
             if (mediaId == 3) { // 查询广点通需要拉取的账户列表
-                // accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getKWaixiaodianAccessList();
+                accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getAdqList();
             }
         }
 

xxl-job-admin/src/main/java/com/xxl/job/admin/dao/AccountDao.java

@@ -13,7 +13,7 @@ public interface AccountDao {
 
     List<String> getLiveDuanJuAccountList();
 
-    List<String> getKWaixiaodianAccessList();
+    List<String> getAdqList();
 
     List<String> getRuixuanAllAccessList();
 }

xxl-job-admin/src/main/resources/mybatis-mapper/AccountMapper.xml

@@ -22,9 +22,11 @@
   AND advertiser_name NOT LIKE '%暂停%'
     </select>
 
-    <select id="getKWaixiaodianAccessList" resultType="java.lang.String">
-        SELECT id
-        FROM ruixuan.kwaixiaodian_access_token
+    <select id="getAdqList" resultType="java.lang.String">
+        SELECT concat(t1.advertiser_id, '_', t2.access_token) AS 'param'
+        FROM adq_advertiser_list t1
+                 LEFT JOIN deepthink.adq_auth_list t2
+                           ON t1.admin_advertiser_id = t2.admin_advertiser_id
     </select>
 
     <select id="getRuixuanAllAccessList" resultType="java.lang.String">