Browse Source

增加-智投助手查询逻辑

yumeng 8 months ago
parent
commit
128f9d2b07

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

@@ -66,7 +66,7 @@ public class XxlJobTrigger {
                 accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getBytedanceList();
             }
             if (mediaId == 2) { // 查询快手需要拉取的账户列表
-                 accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getKuaiShouAccountList();
+                accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getKuaiShouAccountList();
             }
             if (mediaId == 3) { // 查询广点通需要拉取的账户列表
                 accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getAdqList();
@@ -86,9 +86,16 @@ public class XxlJobTrigger {
             if (mediaId == 8) { // 头条 ltv3账户获取
                 accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getBytedanceLtv3AccountList();
             }
-
+            if (mediaId == 9) { // 智投助手-半小时
+                accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getPolicyConfigList(1);
+            }
+            if (mediaId == 10) { // 智投助手-一小时
+                accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getPolicyConfigList(2);
+            }
+            if (mediaId == 11) { // 智投助手-一天
+                accountList = XxlJobAdminConfig.getAdminConfig().getAccountDaoDao().getPolicyConfigList(2);
+            }
         }
-
         int finalFailRetryCount = failRetryCount >= 0 ? failRetryCount : jobInfo.getExecutorFailRetryCount();
         XxlJobGroup group = XxlJobAdminConfig.getAdminConfig().getXxlJobGroupDao().load(jobInfo.getJobGroup());
 

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

@@ -24,4 +24,6 @@ public interface AccountDao {
     List<String> getKuaishouAdminadvertiserIds();
 
     List<String> getBytedanceLtv3AccountList();
+
+    List<String> getPolicyConfigList(@Param("scheduleType") Integer scheduleType);
 }

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

@@ -67,4 +67,9 @@
                        LEFT JOIN deepthink.bytedance_auth_list t3 ON t2.admin_advertiser_id = t3.admin_advertiser_id) t
         WHERE t.param IS NOT NULL
     </select>
+    <select id="getPolicyConfigList" resultType="java.lang.String">
+        select id
+        from deepthink.zt_policy_config
+        where schedule_type = #{scheduleType}
+    </select>
 </mapper>

+ 6 - 0
xxl-job-admin/src/main/resources/templates/jobinfo/jobinfo.index.ftl

@@ -210,6 +210,9 @@
                                 <option value="6">快手-短剧经营者平台</option>
                                 <option value="7">快手-罗盘刷新最新账户</option>
                                 <option value="8">头条-ltv3账户获取</option>
+                                <option value="9">智投助手_半小时</option>
+                                <option value="10">智投助手_一小时</option>
+                                <option value="11">智投助手_每天</option>
 
                             </select>
                         </div>
@@ -533,6 +536,9 @@ exit 0
                                 <option value="6">快手-短剧经营者平台</option>
                                 <option value="7">快手-罗盘刷新最新账户</option>
                                 <option value="8">头条-ltv3账户获取</option>
+                                <option value="9">智投助手_半小时</option>
+                                <option value="10">智投助手_一小时</option>
+                                <option value="11">智投助手_每天</option>
                             </select>
                         </div>