浏览代码

人群报表组级维度数据

zhaoxian 4 年之前
父节点
当前提交
b3aff7f492

+ 3 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/KuaiShouCampaignMapper.java

@@ -1,6 +1,7 @@
 package cn.com.ctop.kuaishou.modules.batch.mapper;
 package cn.com.ctop.kuaishou.modules.batch.mapper;
 
 
 import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCampaign;
 import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCampaign;
+import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Param;
 
 
@@ -17,4 +18,6 @@ public interface KuaiShouCampaignMapper extends BaseMapper<KuaiShouCampaign> {
     void replaceBatch(@Param(value = "campaigns") List<KuaiShouCampaign> campaigns);
     void replaceBatch(@Param(value = "campaigns") List<KuaiShouCampaign> campaigns);
 
 
     List<Long> queryIdsByPutStatus(Long accountId,String putStatus);
     List<Long> queryIdsByPutStatus(Long accountId,String putStatus);
+
+    JSONArray queryCampaignIdByAccountId(Long accountId);
 }
 }

+ 6 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/mapper/xml/KuaiShouCampaignMapper.xml

@@ -41,4 +41,10 @@
         WHERE account_id = #{accountId}
         WHERE account_id = #{accountId}
         AND put_status = #{putStatus}
         AND put_status = #{putStatus}
     </select>
     </select>
+    <select id="queryCampaignIdByAccountId" resultType="java.lang.Long">
+        SELECT campaign_id
+        FROM
+        ctop_kuaishou_campaign
+        WHERE account_id = #{accountId}
+    </select>
 </mapper>
 </mapper>

+ 6 - 2
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouAudienceReportDailyServiceImpl.java

@@ -6,6 +6,7 @@ import cn.com.ctop.common.module.utils.Check;
 import cn.com.ctop.common.module.utils.HttpUtils;
 import cn.com.ctop.common.module.utils.HttpUtils;
 import cn.com.ctop.common.module.utils.KuaishouInterfaceConstant;
 import cn.com.ctop.common.module.utils.KuaishouInterfaceConstant;
 import cn.com.ctop.common.module.utils.PropertiesUtils;
 import cn.com.ctop.common.module.utils.PropertiesUtils;
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouCampaignMapper;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouAudienceReportDaily;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouAudienceReportDaily;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouAudienceReportDailyAge;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouAudienceReportDailyAge;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouAudienceReportDailyBussiness;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouAudienceReportDailyBussiness;
@@ -43,6 +44,8 @@ import java.util.Map;
 public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<KuaishouAudienceReportDailyMapper, KuaishouAudienceReportDaily> implements IKuaishouAudienceReportDailyService {
 public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<KuaishouAudienceReportDailyMapper, KuaishouAudienceReportDaily> implements IKuaishouAudienceReportDailyService {
 
 
     @Autowired
     @Autowired
+    private KuaiShouCampaignMapper kuaiShouCampaignMapper;
+    @Autowired
     private KuaishouAudienceReportDailyProvinceMapper provinceMapper;
     private KuaishouAudienceReportDailyProvinceMapper provinceMapper;
     @Autowired
     @Autowired
     private KuaishouAudienceReportDailyAgeMapper ageMapper;
     private KuaishouAudienceReportDailyAgeMapper ageMapper;
@@ -70,6 +73,7 @@ public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<Kuaishou
     public void crowdAnalysisReport(CtopOauthToken token, String date, String type, Integer page, Integer pageSize) {
     public void crowdAnalysisReport(CtopOauthToken token, String date, String type, Integer page, Integer pageSize) {
         long start = System.currentTimeMillis();
         long start = System.currentTimeMillis();
         try {
         try {
+            JSONArray campaignIdList = kuaiShouCampaignMapper.queryCampaignIdByAccountId(token.getAccountId());
             String url = urlPath + KuaishouInterfaceConstant.AUDIENCE_REPORT;
             String url = urlPath + KuaishouInterfaceConstant.AUDIENCE_REPORT;
             JSONArray reportDims = new JSONArray();
             JSONArray reportDims = new JSONArray();
             reportDims.add(type);
             reportDims.add(type);
@@ -78,6 +82,7 @@ public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<Kuaishou
             headers.put("Content-Type", "application/json");
             headers.put("Content-Type", "application/json");
             JSONObject requestJson = new JSONObject();
             JSONObject requestJson = new JSONObject();
             requestJson.put("advertiser_id", token.getAccountId());
             requestJson.put("advertiser_id", token.getAccountId());
+            requestJson.put("campaign_ids", campaignIdList);
             requestJson.put("start_date", date);
             requestJson.put("start_date", date);
             requestJson.put("end_date", date);
             requestJson.put("end_date", date);
             requestJson.put("report_dims", reportDims);
             requestJson.put("report_dims", reportDims);
@@ -91,7 +96,6 @@ public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<Kuaishou
                     JSONObject datas = resultJson.getJSONObject("data");
                     JSONObject datas = resultJson.getJSONObject("data");
                     JSONArray details = datas.getJSONArray("details");
                     JSONArray details = datas.getJSONArray("details");
                     if (!Check.isNull(details)) {
                     if (!Check.isNull(details)) {
-                        System.out.println(type + ",size:" + details.size());
                         for (int i = 0; i < details.size(); i++) {
                         for (int i = 0; i < details.size(); i++) {
                             JSONObject obj = details.getJSONObject(i);
                             JSONObject obj = details.getJSONObject(i);
                             if ("province".equals(type)) {
                             if ("province".equals(type)) {
@@ -145,7 +149,7 @@ public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<Kuaishou
                             }
                             }
                         }
                         }
                     }
                     }
-                }else{
+                } else {
                     log.error("查询人群分析报表数据返回信息错误:accountId:{},返回信息:{}", token.getAccountId(), resultJson);
                     log.error("查询人群分析报表数据返回信息错误:accountId:{},返回信息:{}", token.getAccountId(), resultJson);
                 }
                 }
             }
             }