fix

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/ZtPolicyMapper.java

@@ -74,6 +74,7 @@ public interface ZtPolicyMapper {
     List<JSONObject> promotionGroupToProjectData(@Param("idList") List<String> idList);
     @DS("selectdb")
     List<JSONObject> projectData(@Param("idList") List<String> idList);
+
     List<JSONObject> balanceData(@Param("idList") List<String> idList);
 
     List<JSONObject> indicatorList(@Param("indicatorIds") List<Long> indicatorIds);

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

@@ -446,7 +446,9 @@
     <select id="projectData" resultType="com.alibaba.fastjson.JSONObject">
         select project_id as target_id, bid_type as bytedance_project_bid_type,
                roi_goal as bytedance_project_roi_goal,
-               cpa_bid as bytedance_project_cpa_bid
+               cpa_bid as bytedance_project_cpa_bid,
+        external_action as bytedance_project_external_action,
+        deep_external_action as bytedance_project_deep_external_action
         from media_api.bytedance_cdp_project_list
         where project_id in
         <foreach collection="idList" item="item" open="(" close=")" separator=",">
@@ -454,7 +456,7 @@
         </foreach>
     </select>
     <select id="balanceData" resultType="com.alibaba.fastjson.JSONObject">
-        select advertiser_id as target_id, (wallet_total_balance_valid+balance) as bytedance_advertiser_balance
+        select advertiser_id as target_id, (wallet_total_balance_valid + balance) as bytedance_advertiser_balance
         from media_api.bytedance_advertiser_fund
         where advertiser_id in
         <foreach collection="idList" item="item" open="(" close=")" separator=",">
@@ -503,7 +505,7 @@
     <select id="promotionTargetNameInfo" resultType="com.alibaba.fastjson.JSONObject">
         select tb1.advertiser_id as advertiserId, tb2.advertiser_name as advertiserName,
         ad_id as targetId, ad_name as targetName
-        from application.media_ad_report_daily
+        from application.media_ad_report_daily tb1
         left join tidb.deepthink.advertiser_bind_info tb2 on tb1.advertiser_id = tb2.advertiser_id
         where stat_date >= DATE_SUB(CURRENT_DATE(), INTERVAL 9 DAY)
         and ad_id in

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/ZtPolicyRunServiceImpl.java

@@ -51,7 +51,7 @@ public class ZtPolicyRunServiceImpl implements IZtPolicyRunService {
 
     @Override
     public void test() {
-        run(60021L);
+        run(27L);
 //        run(24L);
 //        run(25L);
 //        run(30021L);
@@ -103,7 +103,7 @@ public class ZtPolicyRunServiceImpl implements IZtPolicyRunService {
             //批量查询过程
             Map<String, JSONObject> matchConditionExtraRecordInfo = new HashMap<>();//记录的额外信息
             Map<String, Object> dataResMap = new HashMap<>();//id -> 查询结果
-            if ("bytedance".equals(dataSource)){//几个特殊字段获取
+            if (dataSource.startsWith("bytedance")){//几个特殊字段获取
                 for (int index = 0; index < policy.getTargetResIds().size(); ) {
                     List<String> subResIds = policy.getTargetResIds().subList(index, Math.min(index+500, policy.getTargetResIds().size()));
                     List<JSONObject> data = null;
@@ -111,13 +111,12 @@ public class ZtPolicyRunServiceImpl implements IZtPolicyRunService {
                         data = ztPolicyConfigMapper.promotionGroupToProjectData(subResIds);
                     }else if ("bytedance_promote_status".equals(indicatorCode)){
                         data = ztPolicyConfigMapper.promotionData(subResIds);
-                        data.forEach(o -> dataResMap.put(o.getString("project_id"), o.get(indicatorCode)));
                     }else if ("bytedance_advertiser_balance".equals(indicatorCode)){
                         data = ztPolicyConfigMapper.balanceData(subResIds);
                     }else {
                         data = ztPolicyConfigMapper.projectData(subResIds);
                     }
-                    data.forEach(o -> dataResMap.put(o.getString("project_id"), o.get(indicatorCode)));
+                    data.forEach(o -> dataResMap.put(o.getString("target_id"), o.get(indicatorCode)));
                     index += 500;
                 }
             }else {//自定义指标通用字段