|
@@ -955,36 +955,21 @@ public class BytedanceReportServiceImpl implements IBytedanceReportService {
|
|
requestMap.put("task_id", task.getTaskId());
|
|
requestMap.put("task_id", task.getTaskId());
|
|
String localPath = DownloadUtils.downloadByUrl(requestMap, downloadPath, url, token.getAccessToken(), fileName);
|
|
String localPath = DownloadUtils.downloadByUrl(requestMap, downloadPath, url, token.getAccessToken(), fileName);
|
|
// if(task.getAccountId() !=1649961222605831L && task.getAccountId() != 1643726941045772L){
|
|
// if(task.getAccountId() !=1649961222605831L && task.getAccountId() != 1643726941045772L){
|
|
-
|
|
|
|
-
|
|
|
|
- if(type == 1){
|
|
|
|
- //素材异步报表
|
|
|
|
- if(task.getTaskId() == 847656L){
|
|
|
|
- bytedanceDailyReportTaskMapper.loadBytedanceDailyCreativeFileAsync("D:\\data\\report\\history\\1649961222605831_type1_847656_1588935984126.csv");
|
|
|
|
- }else{
|
|
|
|
- bytedanceDailyReportTaskMapper.loadBytedanceDailyCreativeFileAsync(localPath);
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
-
|
|
|
|
- }else if(type == 2){
|
|
|
|
- //账户异步报表
|
|
|
|
- bytedanceDailyReportTaskMapper.loadBytedanceDailyAccountFileAsync(localPath);
|
|
|
|
- }else if(type == 3){
|
|
|
|
- //campaign异步报表
|
|
|
|
- bytedanceDailyReportTaskMapper.loadBytedanceDailyCampaignFileAsync(localPath);
|
|
|
|
- }else if(type == 4){
|
|
|
|
- //plan异步报表
|
|
|
|
- if(task.getTaskId() == 849925L) {
|
|
|
|
- bytedanceDailyReportTaskMapper.loadBytedanceDailyPlanFileAsync("D:\\data\\report\\history\\1649961222605831_type1_847656_1588935984126.csv");
|
|
|
|
- }else{
|
|
|
|
-
|
|
|
|
- bytedanceDailyReportTaskMapper.loadBytedanceDailyPlanFileAsync(localPath);
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
-
|
|
|
|
- }else{
|
|
|
|
- log.error("异步报表类型传入错误,task_id:" + task.getTaskId() + ";类型:" + type);
|
|
|
|
- }
|
|
|
|
|
|
+ if(type == 1){
|
|
|
|
+ //素材异步报表
|
|
|
|
+ bytedanceDailyReportTaskMapper.loadBytedanceDailyCreativeFileAsync(localPath);
|
|
|
|
+ }else if(type == 2){
|
|
|
|
+ //账户异步报表
|
|
|
|
+ bytedanceDailyReportTaskMapper.loadBytedanceDailyAccountFileAsync(localPath);
|
|
|
|
+ }else if(type == 3){
|
|
|
|
+ //campaign异步报表
|
|
|
|
+ bytedanceDailyReportTaskMapper.loadBytedanceDailyCampaignFileAsync(localPath);
|
|
|
|
+ }else if(type == 4){
|
|
|
|
+ //plan异步报表
|
|
|
|
+ bytedanceDailyReportTaskMapper.loadBytedanceDailyPlanFileAsync(localPath);
|
|
|
|
+ }else{
|
|
|
|
+ log.error("异步报表类型传入错误,task_id:" + task.getTaskId() + ";类型:" + type);
|
|
|
|
+ }
|
|
// }
|
|
// }
|
|
}
|
|
}
|
|
|
|
|