|
@@ -8,18 +8,67 @@ import cn.com.ctop.common.module.mapper.UserAllocationMapper;
|
|
import cn.com.ctop.common.module.service.IMaterialCutFrameService;
|
|
import cn.com.ctop.common.module.service.IMaterialCutFrameService;
|
|
import cn.com.ctop.common.module.service.IOauthConfigService;
|
|
import cn.com.ctop.common.module.service.IOauthConfigService;
|
|
import cn.com.ctop.common.module.service.IUserAllocationService;
|
|
import cn.com.ctop.common.module.service.IUserAllocationService;
|
|
-import cn.com.ctop.common.module.utils.*;
|
|
|
|
-import cn.com.ctop.kuaishou.modules.ai.service.*;
|
|
|
|
-import cn.com.ctop.kuaishou.modules.batch.entity.*;
|
|
|
|
|
|
+import cn.com.ctop.common.module.utils.Check;
|
|
|
|
+import cn.com.ctop.common.module.utils.CtopAdConstant;
|
|
|
|
+import cn.com.ctop.common.module.utils.HttpUtils;
|
|
|
|
+import cn.com.ctop.common.module.utils.JsonUtil;
|
|
|
|
+import cn.com.ctop.common.module.utils.KuaishouInterfaceConstant;
|
|
|
|
+import cn.com.ctop.common.module.utils.PropertiesUtils;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.ai.service.IAiCreativeLimitService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouAccountCreativeOverrunInfoService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouAppPackageService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouDirectionalPackageService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouLandpagePackageService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouPopulationGroupService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouAdvertiserBaseInfo;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouAppList;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCampaign;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCreative;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouDailyFlows;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroup;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouImageGet;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouRegionListChildren;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouRegionListParent;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouTargetingTags;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouVideoGet;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaishouPopulation;
|
|
import cn.com.ctop.kuaishou.modules.batch.entity.vo.ConvertVo;
|
|
import cn.com.ctop.kuaishou.modules.batch.entity.vo.ConvertVo;
|
|
-import cn.com.ctop.kuaishou.modules.batch.mapper.*;
|
|
|
|
-import cn.com.ctop.kuaishou.modules.batch.service.*;
|
|
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouAdvertiserBaseInfoMapper;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouAppListMapper;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouGroupMapper;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouRegionListChildrenMapper;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouRegionListParentMapper;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouTargetingTagsMapper;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouCampaignService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouCreativeService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouDailyFlowsService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouGroupService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouHistoryReportTaskService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouImageGetService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouOverRunSendMessageService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouVideoGetService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouPopulationService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.batch.service.IWarningOperationService;
|
|
import cn.com.ctop.kuaishou.modules.material.entity.KuaishouResult;
|
|
import cn.com.ctop.kuaishou.modules.material.entity.KuaishouResult;
|
|
import cn.com.ctop.kuaishou.modules.material.entity.KuaishouResultToken;
|
|
import cn.com.ctop.kuaishou.modules.material.entity.KuaishouResultToken;
|
|
-import cn.com.ctop.kuaishou.modules.report.entity.*;
|
|
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportDailyAccount;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportDailyCampaign;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportDailyCreative;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportDailyCreativeStatistic;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportHourlyAccount;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportHourlyCampaign;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportHourlyCreative;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportHourlyCreativeStatistic;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportHourlyGroup;
|
|
import cn.com.ctop.kuaishou.modules.report.mapper.KuaishouReportDailyAccountMapper;
|
|
import cn.com.ctop.kuaishou.modules.report.mapper.KuaishouReportDailyAccountMapper;
|
|
import cn.com.ctop.kuaishou.modules.report.mapper.KuaishouReportDailyCampaignMapper;
|
|
import cn.com.ctop.kuaishou.modules.report.mapper.KuaishouReportDailyCampaignMapper;
|
|
-import cn.com.ctop.kuaishou.modules.report.service.*;
|
|
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IKuaishouReportDailyCampaignService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IKuaishouReportDailyCreativeService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IKuaishouReportHourlyAccountService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IKuaishouReportHourlyCampaignService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IKuaishouReportHourlyCreativeService;
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IKuaishouReportHourlyGroupService;
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSONArray;
|
|
import com.alibaba.fastjson.JSONArray;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
@@ -54,7 +103,11 @@ import java.io.IOException;
|
|
import java.lang.reflect.ParameterizedType;
|
|
import java.lang.reflect.ParameterizedType;
|
|
import java.lang.reflect.Type;
|
|
import java.lang.reflect.Type;
|
|
import java.text.SimpleDateFormat;
|
|
import java.text.SimpleDateFormat;
|
|
-import java.util.*;
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
|
|
+import java.util.Date;
|
|
|
|
+import java.util.HashMap;
|
|
|
|
+import java.util.List;
|
|
|
|
+import java.util.Map;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.Executors;
|
|
|
|
|
|
@@ -130,6 +183,7 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
|
|
private IKuaishouAppPackageService appPackageService;
|
|
private IKuaishouAppPackageService appPackageService;
|
|
@Autowired
|
|
@Autowired
|
|
private UserAllocationMapper allocationMapper;
|
|
private UserAllocationMapper allocationMapper;
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
public void getAdvertiserReportHourly(CtopOauthToken token, Date startDate, Date endDate) {
|
|
public void getAdvertiserReportHourly(CtopOauthToken token, Date startDate, Date endDate) {
|
|
try {
|
|
try {
|
|
@@ -268,8 +322,10 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
|
|
if (!Check.isNull(videoGetList)) {
|
|
if (!Check.isNull(videoGetList)) {
|
|
videoGetService.replaceBatch(videoGetList);
|
|
videoGetService.replaceBatch(videoGetList);
|
|
}
|
|
}
|
|
-
|
|
|
|
- getVideoListByPage(token, startDate, endDate, page + 1);
|
|
|
|
|
|
+ Integer total_count = resultJson.getJSONObject("data").getInteger("total_count");
|
|
|
|
+ if (!Check.isNull(total_count) && total_count == 500) {
|
|
|
|
+ getVideoListByPage(token, startDate, endDate, page + 1);
|
|
|
|
+ }
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
@@ -781,26 +837,26 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
|
|
@Override
|
|
@Override
|
|
public void loadKuaishouDataSingle(CtopOauthToken token) throws java.text.ParseException {
|
|
public void loadKuaishouDataSingle(CtopOauthToken token) throws java.text.ParseException {
|
|
String beginDateStr = allocationMapper.getUserAllocation(token.getAccountId()).getAuthBeginTime();
|
|
String beginDateStr = allocationMapper.getUserAllocation(token.getAccountId()).getAuthBeginTime();
|
|
- beginDateStr = Check.isNull(beginDateStr) ? DateUtils.formatDate(DateUtils.addDay(new Date(),-180),"yyyy-MM-dd") : beginDateStr;
|
|
|
|
- Date beginDate = DateUtils.parseDate(beginDateStr,DateUtils.WEB_FORMAT);
|
|
|
|
- Date endDate = DateUtils.addDay(new Date(),-1);
|
|
|
|
- while (!beginDate.after(endDate)){
|
|
|
|
- beginDate = DateUtils.addDay(beginDate,1);
|
|
|
|
|
|
+ beginDateStr = Check.isNull(beginDateStr) ? DateUtils.formatDate(DateUtils.addDay(new Date(), -180), "yyyy-MM-dd") : beginDateStr;
|
|
|
|
+ Date beginDate = DateUtils.parseDate(beginDateStr, DateUtils.WEB_FORMAT);
|
|
|
|
+ Date endDate = DateUtils.addDay(new Date(), -1);
|
|
|
|
+ while (!beginDate.after(endDate)) {
|
|
|
|
+ beginDate = DateUtils.addDay(beginDate, 1);
|
|
getAdvertiserReportHourly(token, beginDate, beginDate);
|
|
getAdvertiserReportHourly(token, beginDate, beginDate);
|
|
getAdvertiserReportDaily(token, beginDate, beginDate, null);
|
|
getAdvertiserReportDaily(token, beginDate, beginDate, null);
|
|
}
|
|
}
|
|
// Date endDate = new Date();
|
|
// Date endDate = new Date();
|
|
// for (int i = 0; i < 7; i++) {
|
|
// for (int i = 0; i < 7; i++) {
|
|
// Date getStartDate = DateUtils.addDay(endDate, -i);
|
|
// Date getStartDate = DateUtils.addDay(endDate, -i);
|
|
- //1: 获取广告主信息数据
|
|
|
|
|
|
+ //1: 获取广告主信息数据
|
|
// getAdvertiserReportHourly(token, beginDate, endDate);
|
|
// getAdvertiserReportHourly(token, beginDate, endDate);
|
|
// getAdvertiserReportDaily(token, beginDate, endDate, null);
|
|
// getAdvertiserReportDaily(token, beginDate, endDate, null);
|
|
- //2:获取广告计划信息数据
|
|
|
|
- //getAdvertiserCampaignReportHourly(token, getStartDate, getStartDate);
|
|
|
|
- //3:获取广告组信息数据
|
|
|
|
- // getAdvertiserGroupReportHourly(token, getStartDate, getStartDate);
|
|
|
|
- //4: 获取广告创意信息数据
|
|
|
|
- // getAdvertiserCreativeReportHourly(token, getStartDate, getStartDate);
|
|
|
|
|
|
+ //2:获取广告计划信息数据
|
|
|
|
+ //getAdvertiserCampaignReportHourly(token, getStartDate, getStartDate);
|
|
|
|
+ //3:获取广告组信息数据
|
|
|
|
+ // getAdvertiserGroupReportHourly(token, getStartDate, getStartDate);
|
|
|
|
+ //4: 获取广告创意信息数据
|
|
|
|
+ // getAdvertiserCreativeReportHourly(token, getStartDate, getStartDate);
|
|
// }
|
|
// }
|
|
//获取全量广告计划数据
|
|
//获取全量广告计划数据
|
|
getCampaignList(token, null, null);
|
|
getCampaignList(token, null, null);
|
|
@@ -810,7 +866,7 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
|
|
getCreativeList(token, null, null);
|
|
getCreativeList(token, null, null);
|
|
getAppList(token.getAccountId(), token.getAccessToken());
|
|
getAppList(token.getAccountId(), token.getAccessToken());
|
|
log.info("----------------开始历史数据获取,accountId:{}", token.getAccountId());
|
|
log.info("----------------开始历史数据获取,accountId:{}", token.getAccountId());
|
|
- String endDateStr = DateUtils.formatDate(endDate,"yyyy-MM-dd");
|
|
|
|
|
|
+ String endDateStr = DateUtils.formatDate(endDate, "yyyy-MM-dd");
|
|
// String startDate = DateUtils.addMonth(endDateStr, -1);
|
|
// String startDate = DateUtils.addMonth(endDateStr, -1);
|
|
historyReportTaskService.createTask(token.getAccountId(), token.getAccessToken(), beginDateStr, endDateStr, CtopAdConstant.KUAISHOU_LOAD_JOB_TYPE_HISTORY);
|
|
historyReportTaskService.createTask(token.getAccountId(), token.getAccessToken(), beginDateStr, endDateStr, CtopAdConstant.KUAISHOU_LOAD_JOB_TYPE_HISTORY);
|
|
getVideoList(token, null, null);
|
|
getVideoList(token, null, null);
|