فهرست منبع

提交获取数据逻辑代码

syh 5 سال پیش
والد
کامیت
c8f9d133bf

+ 0 - 3
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/controller/ByteDanceAdvertiserPostController.java

@@ -1,6 +1,5 @@
 package org.jeecg.modules.ctop.controller;
 
-import cn.com.ctop.bytedance.service.IReportService;
 import cn.com.ctop.common.module.entity.CtopOauthToken;
 import cn.com.ctop.common.module.service.ICtopOauthTokenService;
 import cn.com.ctop.common.module.service.IFileInfoService;
@@ -285,7 +284,5 @@ public class ByteDanceAdvertiserPostController {
     @Autowired
     private ICtopOauthTokenService tokenService;
     @Autowired
-    private IReportService reportService;
-    @Autowired
     private IKuaishouInterfaceService kuaishouInterfaceService;
 }

+ 45 - 45
jeecg-boot-module-system/src/test/java/org/jeecg/SampleTest.java

@@ -64,7 +64,7 @@ public class SampleTest {
 
         Date getDate = DateUtils.addDay(new Date(), -1);
         //1:查询当日数据
-        List<CtopOauthToken> tokens = tokenService.getTokenListByType(4 + "");
+        List<CtopOauthToken> tokens = tokenService.getTokenListByType(2 + "");
         if (null == tokens || tokens.size() <= 0) {
             log.info("定时获取头条数据异常:为获取到可用的token");
             return;
@@ -94,61 +94,61 @@ public class SampleTest {
         Date endDate = new Date();
         Date hourlyStartDate = DateUtils.addDay(endDate, -7);
         Date startDate = DateUtils.addDay(endDate, -170);
-        List<CtopOauthToken> bytedanceTokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE);
-        if (null != bytedanceTokens && bytedanceTokens.size() > 0) {
-            bytedanceTokens.forEach(token -> {
-                //1: 获取广告主信息数据
-                reportService.getAdvertiserReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
-                //2:获取广告组信息数据
-                reportService.getAdvertiserCampaignReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
-                //3:获取广告计划信息数据
-                reportService.getAdvertiserPlanReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
-                //4: 获取广告创意信息数据
-                reportService.getAdvertiserCreativeReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
-
-                //1: 获取广告主信息数据
-                reportService.getAdvertiserReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
-                //2:获取广告组信息数据
-                reportService.getAdvertiserCampaignReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
-                //3:获取广告计划信息数据
-                reportService.getAdvertiserPlanReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
-                //4: 获取广告创意信息数据
-                reportService.getAdvertiserCreativeReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
-            });
-        }
+//        List<CtopOauthToken> bytedanceTokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE);
+//        if (null != bytedanceTokens && bytedanceTokens.size() > 0) {
+//            bytedanceTokens.forEach(token -> {
+//                //1: 获取广告主信息数据
+//                reportService.getAdvertiserReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+//                //2:获取广告组信息数据
+//                reportService.getAdvertiserCampaignReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+//                //3:获取广告计划信息数据
+//                reportService.getAdvertiserPlanReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+//                //4: 获取广告创意信息数据
+//                reportService.getAdvertiserCreativeReport(token, startDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+//
+//                //1: 获取广告主信息数据
+//                reportService.getAdvertiserReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
+//                //2:获取广告组信息数据
+//                reportService.getAdvertiserCampaignReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
+//                //3:获取广告计划信息数据
+//                reportService.getAdvertiserPlanReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
+//                //4: 获取广告创意信息数据
+//                reportService.getAdvertiserCreativeReport(token, hourlyStartDate, endDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY);
+//            });
+//        }
         List<CtopOauthToken> kuaishouTokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_KUAISHOU);
         if (null != kuaishouTokens && kuaishouTokens.size() > 0) {
             for (CtopOauthToken token : kuaishouTokens) {
                 for (int i = 0; i < 7; i++) {
                     Date getStartDate = DateUtils.addDay(endDate, -i);
                     //1: 获取广告主信息数据
-                    kuaishouInterfaceService.getAdvertiserReportHourly(token, getStartDate, getStartDate);
+//                    kuaishouInterfaceService.getAdvertiserReportHourly(token, getStartDate, getStartDate);
                     //2:获取广告计划信息数据
-                    kuaishouInterfaceService.getAdvertiserCampaignReportHourly(token, getStartDate, getStartDate);
+//                    kuaishouInterfaceService.getAdvertiserCampaignReportHourly(token, getStartDate, getStartDate);
                     //3:获取广告组信息数据
                     kuaishouInterfaceService.getAdvertiserGroupReportHourly(token, getStartDate, getStartDate);
                     //4: 获取广告创意信息数据
-                    kuaishouInterfaceService.getAdvertiserCreativeReportHourly(token, getStartDate, getStartDate);
-                }
-                for (int i = 0; i < 6; i++) {
-                    Date getStartDate = new Date();
-                    Date getEndDate = new Date();
-                    if (i == 0) {
-                        getStartDate = DateUtils.addDay(endDate, -175 + i * 30);
-                        getEndDate = DateUtils.addDay(endDate, -150 + i * 30);
-                    } else {
-                        getStartDate = DateUtils.addDay(endDate, -180 + i * 30);
-                        getEndDate = DateUtils.addDay(endDate, -150 + i * 30);
-                    }
-                    //1: 获取广告主信息数据
-                    kuaishouInterfaceService.getAdvertiserReportDaily(token, getStartDate, getEndDate);
-                    //2:获取广告计划信息数据
-                    kuaishouInterfaceService.getAdvertiserCampaignReportDaily(token, getStartDate, getEndDate);
-                    //3:获取广告组信息数据
-                    kuaishouInterfaceService.getAdvertiserGroupReportDaily(token, getStartDate, getEndDate);
-                    //4: 获取广告创意信息数据
-                    kuaishouInterfaceService.getAdvertiserCreativeReportDaily(token, getStartDate, getEndDate);
+//                    kuaishouInterfaceService.getAdvertiserCreativeReportHourly(token, getStartDate, getStartDate);
                 }
+//                for (int i = 0; i < 6; i++) {
+//                    Date getStartDate = new Date();
+//                    Date getEndDate = new Date();
+//                    if (i == 0) {
+//                        getStartDate = DateUtils.addDay(endDate, -175 + i * 30);
+//                        getEndDate = DateUtils.addDay(endDate, -150 + i * 30);
+//                    } else {
+//                        getStartDate = DateUtils.addDay(endDate, -180 + i * 30);
+//                        getEndDate = DateUtils.addDay(endDate, -150 + i * 30);
+//                    }
+//                    //1: 获取广告主信息数据
+//                    kuaishouInterfaceService.getAdvertiserReportDaily(token, getStartDate, getEndDate);
+//                    //2:获取广告计划信息数据
+//                    kuaishouInterfaceService.getAdvertiserCampaignReportDaily(token, getStartDate, getEndDate);
+//                    //3:获取广告组信息数据
+//                    kuaishouInterfaceService.getAdvertiserGroupReportDaily(token, getStartDate, getEndDate);
+//                    //4: 获取广告创意信息数据
+//                    kuaishouInterfaceService.getAdvertiserCreativeReportDaily(token, getStartDate, getEndDate);
+//                }
             }
         }
     }

+ 3 - 2
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouInterfaceServiceImpl.java

@@ -581,7 +581,7 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
             detailJson.put("photo_like", like);
             var hourlyGroup = JSONObject.toJavaObject(detailJson, KuaishouReportHourlyGroup.class);
             hourlyGroup.setAccountId(token.getAccountId());
-            hourlyGroup.setId("" + hourlyGroup.getAccountId() + hourlyGroup.getGroupId() + hourlyGroup.getStatDate() + hourlyGroup.getStatHour());
+            hourlyGroup.setId("" + hourlyGroup.getAccountId() + hourlyGroup.getUnitId() + hourlyGroup.getStatDate() + hourlyGroup.getStatHour());
             hourlyGroupService.saveOrUpdate(hourlyGroup);
         }
         getGroupHourlyReportByPage(token, startDate, endDate, page + 1);
@@ -603,6 +603,7 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
         KuaishouResult<KuaishouReportHourlyGroup> kuaishouResult = null;
         try {
             String result = HttpUtils.httpPostRequest(url, param, headers);
+            System.out.println(result);
             ObjectMapper mapper = new ObjectMapper();
             mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
             kuaishouResult = mapper.readValue(result, new TypeReference<KuaishouResult<KuaishouReportHourlyGroup>>() {
@@ -610,7 +611,7 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
             List<KuaishouReportHourlyGroup> hourlyGroups = kuaishouResult.getData().getDetails();
             hourlyGroups.forEach((hourlyGroup) -> {
                 hourlyGroup.setAccountId(advertiserId);
-                hourlyGroup.setId("" + hourlyGroup.getAccountId() + hourlyGroup.getGroupId() + hourlyGroup.getStatDate() + hourlyGroup.getStatHour());
+                hourlyGroup.setId("" + hourlyGroup.getAccountId() + hourlyGroup.getUnitId() + hourlyGroup.getStatDate() + hourlyGroup.getStatHour());
                 hourlyGroupService.saveOrUpdate(hourlyGroup);
             });
         } catch (Exception e) {

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/entity/KuaishouReportHourlyGroup.java

@@ -17,7 +17,7 @@ public class KuaishouReportHourlyGroup implements Serializable {
     private String id;
     private Long accountId;
     @JsonProperty("unit_id")
-    private Long groupId;
+    private Long unitId;
     @JsonProperty("stat_date")
     private String statDate;
     @JsonProperty("stat_hour")