Преглед на файлове

头条获取素材报表数据任务-修改

yangzian преди 3 години
родител
ревизия
0a28768b7c

+ 2 - 2
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceVideoReportJob.java

@@ -20,7 +20,7 @@ public class ByteDanceVideoReportJob {
     private IByteDanceVideoReportDailyService byteDanceVideoReportDailyService;
 
     // TODO 待删除
-    @XxlJob("byteDanceVideoReport")
+   /* @XxlJob("byteDanceVideoReport")
     public void execute() throws Exception {
         String getDate2 = DateUtils.formatDate(DateUtils.addDay(new Date(), -2));
         XxlJobHelper.log("头条视频报表清洗数据定时任务开始, 执行时间为:" + getDate2);
@@ -29,5 +29,5 @@ public class ByteDanceVideoReportJob {
         String getDate = DateUtils.formatDate(DateUtils.addDay(new Date(), -1));
         XxlJobHelper.log("头条视频报表清洗数据定时任务开始, 执行时间为:" + getDate);
         byteDanceVideoReportDailyService.videoInfoList(getDate, getDate);
-    }
+    }*/
 }

+ 1 - 1
module-toutiao/src/main/java/cn/com/ctop/toutiao/modules/report/mapper/xml/ByteDanceVideoReportDailyMapper.xml

@@ -1095,7 +1095,7 @@
         from ctop_bytedance_report_material_daily a
         left join ctop_user_allocation b on a.account_id = b.account_id
         left join user_company c on b.user_id = c.user_id
-        left join (select signature,video_url,material_id from ctop_bytedance_video_info group by material_id) d on
+        left join (select signature,video_url,material_id from ctop_bytedance_video_info where account_id = #{accountId} group by material_id) d on
         a.material_id = d.material_id
         where c.company_id = #{companyId}
         and stat_datetime >= #{startDate}

+ 23 - 15
module-toutiao/src/main/java/cn/com/ctop/toutiao/modules/report/service/impl/ByteDanceVideoReportDailyServiceImpl.java

@@ -1,6 +1,8 @@
 package cn.com.ctop.toutiao.modules.report.service.impl;
 
 import cn.com.ctop.common.module.constant.CtopRoleCodeConstant;
+import cn.com.ctop.common.module.entity.CtopOauthToken;
+import cn.com.ctop.common.module.mapper.CtopOauthTokenMapper;
 import cn.com.ctop.toutiao.modules.report.DTO.AccountVideoDTO;
 import cn.com.ctop.toutiao.modules.report.entity.ByteDanceVideoReportDaily;
 import cn.com.ctop.toutiao.modules.report.mapper.ByteDanceVideoReportDailyMapper;
@@ -35,6 +37,9 @@ public class ByteDanceVideoReportDailyServiceImpl extends ServiceImpl<ByteDanceV
     @Resource
     private ByteDanceVideoReportDailyMapper byteDanceVideoReportDailyMapper;
 
+    @Resource
+    private CtopOauthTokenMapper ctopOauthTokenMapper;
+
     @Override
     public void videoInfoList(String startDate, String endDate){
         //华南
@@ -51,23 +56,26 @@ public class ByteDanceVideoReportDailyServiceImpl extends ServiceImpl<ByteDanceV
         wrapper.le("stat_datetime",endDate);
         wrapper.eq("company_id", companyId);
         byteDanceVideoReportDailyMapper.delete(wrapper);
-
-        List<ByteDanceVideoReportDaily> mList = byteDanceVideoReportDailyMapper.videoInfoList(startDate, endDate, companyId, null);
-        if(null!=mList&&!mList.isEmpty()){
-            List<ByteDanceVideoReportDaily> reports = new ArrayList<>();
-            for(ByteDanceVideoReportDaily report :mList){
-                if(null == report.getMaterialName()|| "".equals(report.getMaterialName().trim())){
-                    report.setMaterialName("-");
-                }
-                if(null == report.getProjectName()|| "".equals(report.getProjectName().trim())){
-                    report.setProjectName("-");
-                }
-                if(null == report.getAdvertiserName()|| "".equals(report.getAdvertiserName().trim())){
-                    report.setAdvertiserName("-");
+        //获取所有头条账户
+        List<CtopOauthToken> listToken = ctopOauthTokenMapper.selectToutiaoToken();
+        for (CtopOauthToken token : listToken) {
+            List<ByteDanceVideoReportDaily> mList = byteDanceVideoReportDailyMapper.videoInfoList(startDate, endDate, companyId, token.getAccountId());
+            if(null!=mList&&!mList.isEmpty()){
+                List<ByteDanceVideoReportDaily> reports = new ArrayList<>();
+                for(ByteDanceVideoReportDaily report :mList){
+                    if(null == report.getMaterialName()|| "".equals(report.getMaterialName().trim())){
+                        report.setMaterialName("-");
+                    }
+                    if(null == report.getProjectName()|| "".equals(report.getProjectName().trim())){
+                        report.setProjectName("-");
+                    }
+                    if(null == report.getAdvertiserName()|| "".equals(report.getAdvertiserName().trim())){
+                        report.setAdvertiserName("-");
+                    }
+                    reports.add(report);
                 }
-                reports.add(report);
+                byteDanceVideoReportDailyMapper.insertBatch(reports);
             }
-            byteDanceVideoReportDailyMapper.insertBatch(reports);
         }
     }