bytedance

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

@@ -63,7 +63,7 @@ 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().getBytedanceList();
             }
             if (mediaId == 2) { // 查询快手需要拉取的账户列表
                 // accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getLiveDuanJuAccountList();

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

@@ -7,13 +7,9 @@ import java.util.List;
 
 @Mapper
 public interface AccountDao {
-    List<String> getAccountList(@Param("mediaId") Integer valueOf);
-
-    List<String> getLiveAccountList();
-
-    List<String> getLiveDuanJuAccountList();
 
     List<String> getAdqList();
 
-    List<String> getRuixuanAllAccessList();
+
+    List<String> getBytedanceList();
 }

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

@@ -3,24 +3,9 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.xxl.job.admin.dao.AccountDao">
 
-    <select id="getAccountList" resultType="java.lang.String">
-        SELECT account_id
-        from `jeecg-boot`.ctop_user_allocation
-        where media_id = #{mediaId}
-          and account_status = 0
-    </select>
 
-    <select id="getLiveAccountList" resultType="java.lang.String">
-        SELECT account_id
-        from `ruixuan`.kuaishou_account
-        where account_status = 1
-    </select>
-    <select id="getLiveDuanJuAccountList" resultType="java.lang.String">
-        SELECT advertiser_id
-        FROM media_api.compass_bind_advertisers
-        WHERE advertiser_id != 39526067
-  AND advertiser_name NOT LIKE '%暂停%'
-    </select>
+
+
 
     <select id="getAdqList" resultType="java.lang.String">
         SELECT concat(t1.advertiser_id, '_', t2.access_token) AS 'param'
@@ -29,23 +14,15 @@
                            ON t1.admin_advertiser_id = t2.admin_advertiser_id
     </select>
 
-    <select id="getRuixuanAllAccessList" resultType="java.lang.String">
-        select CONCAT('ruixuan_', id)
-        from ruixuan.kuaishou_access_token
-        UNION
-        select CONCAT('miaogousi_', id)
-        from miaogousi.kuaishou_access_token
-        UNION
-        select CONCAT('rocket_', id)
-        from rocket.kuaishou_access_token
-        UNION
-        select CONCAT('yufu_', id)
-        from yufu.kuaishou_access_token
-        UNION
-        select CONCAT('yuxiu_', id)
-        from yuxiu.kuaishou_access_token
-        UNION
-        select CONCAT('zhishui_', id)
-        from zhishui.kuaishou_access_token
+
+    <select id="getBytedanceList" resultType="java.lang.String">
+        SELECT concat(t1.advertiser_id, '_', t3.access_token) AS 'param'
+        FROM (SELECT advertiser_id
+              FROM media_api.bytedance_promoter_report_hour
+              WHERE stat_time_day = date_format(CURDATE() - INTERVAL 1 DAY, '%Y%m%d')
+              GROUP BY advertiser_id) t1
+                 LEFT JOIN deepthink.bytedance_advertiser_list t2 ON t1.advertiser_id = t2.advertiser_id
+                 LEFT JOIN bytedance_auth_list t3 ON t2.admin_advertiser_id = t3.admin_advertiser_id
+
     </select>
 </mapper>