自动获取投流号增加开关

api-module/src/main/java/com/tzld/piaoquan/api/job/GzhReplyVideoRefreshJob.java

@@ -71,7 +71,7 @@ public class GzhReplyVideoRefreshJob {
                 .collect(Collectors.groupingBy(AdPutCreativeComponentCostData::getWxId));
         CountDownLatch cdl = new CountDownLatch(costDataMap.size());
         // 获取所有投流账号信息
-        String accountMapSql = "SELECT account_id, account_name from loghubods.feishu_wechat_mp_account_base;";
+        String accountMapSql = "SELECT account_id, account_name from loghubods.feishu_wechat_mp_account_base where account_status = '开';";
         List<Record> accountList = OdpsUtil.getOdpsData(accountMapSql);
         Map<String, String> accountMap = new HashMap<>();
         if (CollectionUtils.isNotEmpty(accountList)) {
@@ -82,7 +82,7 @@ public class GzhReplyVideoRefreshJob {
             }
         }
         // 服务号投流账号
-        String fwhAccountMapSql = "SELECT account_id, account_name from loghubods.feishu_wechat_fwh_account_base;";
+        String fwhAccountMapSql = "SELECT account_id, account_name from loghubods.feishu_wechat_fwh_account_base where account_status = '开';";
         List<Record> fwhAccountList = OdpsUtil.getOdpsData(fwhAccountMapSql);
         if (CollectionUtils.isNotEmpty(fwhAccountList)) {
             for (Record record : fwhAccountList) {