浏览代码

提交获取数据逻辑代码

syh 5 年之前
父节点
当前提交
2d4fe6a57f

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

@@ -15,18 +15,17 @@ import cn.com.ctop.toutiao.service.IByteDanceCustomAudienceService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.shiro.SecurityUtils;
 import org.apache.shiro.SecurityUtils;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.common.system.vo.LoginUser;
-import org.jeecg.common.util.DateUtils;
 import org.jeecg.modules.system.entity.SysDictItem;
 import org.jeecg.modules.system.entity.SysDictItem;
 import org.jeecg.modules.system.service.ISysDictItemService;
 import org.jeecg.modules.system.service.ISysDictItemService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.bind.annotation.*;
 
 
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletRequest;
-import java.util.Date;
 import java.util.HashMap;
 import java.util.HashMap;
 import java.util.List;
 import java.util.List;
 import java.util.Map;
 import java.util.Map;
@@ -36,6 +35,7 @@ import java.util.Map;
  *
  *
  * @author 宋英豪
  * @author 宋英豪
  */
  */
+@Slf4j
 @RestController
 @RestController
 @RequestMapping("toutiao")
 @RequestMapping("toutiao")
 public class ByteDanceAdvertiserPostController {
 public class ByteDanceAdvertiserPostController {
@@ -263,32 +263,8 @@ public class ByteDanceAdvertiserPostController {
     @GetMapping("loadAllData")
     @GetMapping("loadAllData")
     public Map<String, Object> loadAllData() {
     public Map<String, Object> loadAllData() {
         Map<String, Object> result = new HashMap<>();
         Map<String, Object> result = new HashMap<>();
-        Date endDate = new Date();
-//        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);
         List<CtopOauthToken> kuaishouTokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_KUAISHOU);
         kuaishouInterfaceService.loadAllKuaishouData(kuaishouTokens);
         kuaishouInterfaceService.loadAllKuaishouData(kuaishouTokens);
-
         ResultMapUtils.setResultMap(result, StatusCode.COMMON_SUCCESS.getCode());
         ResultMapUtils.setResultMap(result, StatusCode.COMMON_SUCCESS.getCode());
         return result;
         return result;
     }
     }
@@ -296,49 +272,11 @@ public class ByteDanceAdvertiserPostController {
     @GetMapping("loadSingleData")
     @GetMapping("loadSingleData")
     public Map<String, Object> loadSingleData(Long accountId) {
     public Map<String, Object> loadSingleData(Long accountId) {
         Map<String, Object> result = new HashMap<>();
         Map<String, Object> result = new HashMap<>();
-        Date endDate = new Date();
-        Date hourlyStartDate = DateUtils.addDay(endDate, -7);
-        Date startDate = DateUtils.addDay(endDate, -180);
         CtopOauthToken token = tokenService.getOauthTokenByAccountId(accountId + "");
         CtopOauthToken token = tokenService.getOauthTokenByAccountId(accountId + "");
-        if (null != token) {
-            if (null != token.getMediaId() && token.getMediaId().equals(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE)) {
-                //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);
-            }
-            if (null != token.getMediaId() && token.getMediaId().equals(CtopAdConstant.PLATFORM_TYPE_KUAISHOU)) {
-                //1: 获取广告主信息数据
-                kuaishouInterfaceService.getAdvertiserReportDaily(token, startDate, endDate);
-                //2:获取广告计划信息数据
-                kuaishouInterfaceService.getAdvertiserCampaignReportDaily(token, startDate, endDate);
-                //3:获取广告组信息数据
-                kuaishouInterfaceService.getAdvertiserGroupReportDaily(token, startDate, endDate);
-                //4: 获取广告创意信息数据
-                kuaishouInterfaceService.getAdvertiserCreativeReportDaily(token, startDate, endDate);
-
-                //1: 获取广告主信息数据
-                kuaishouInterfaceService.getAdvertiserReportHourly(token, hourlyStartDate, endDate);
-                //2:获取广告计划信息数据
-                kuaishouInterfaceService.getAdvertiserCampaignReportHourly(token, hourlyStartDate, endDate);
-                //3:获取广告组信息数据
-                kuaishouInterfaceService.getAdvertiserGroupReportHourly(token, hourlyStartDate, endDate);
-                //4: 获取广告创意信息数据
-                kuaishouInterfaceService.getAdvertiserCreativeReportHourly(token, hourlyStartDate, endDate);
-            }
+        if (null != token && token.getMediaId() == CtopAdConstant.PLATFORM_TYPE_KUAISHOU) {
+            kuaishouInterfaceService.loadKuaishouDataSingle(token);
+        } else {
+            log.info("token异常");
         }
         }
         ResultMapUtils.setResultMap(result, StatusCode.COMMON_SUCCESS.getCode());
         ResultMapUtils.setResultMap(result, StatusCode.COMMON_SUCCESS.getCode());
         return result;
         return result;