فهرست منبع

Merge remote-tracking branch 'origin/master'

yumeng 5 سال پیش
والد
کامیت
e9e16b9125

+ 57 - 0
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/job/BytedancePlanLoadJob.java

@@ -0,0 +1,57 @@
+package org.jeecg.modules.ctop.job;
+
+import cn.com.ctop.common.module.entity.CtopOauthToken;
+import cn.com.ctop.common.module.service.ICtopOauthTokenService;
+import cn.com.ctop.common.module.utils.CtopAdConstant;
+import cn.com.ctop.toutiao.service.IByteDanceAdvertiserDataService;
+import cn.com.ctop.toutiao.service.IByteDanceCreativeService;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+@Slf4j
+public class BytedancePlanLoadJob implements Job {
+    @Autowired
+    private ICtopOauthTokenService tokenService;
+    static ExecutorService executorService = null;
+    @Autowired
+    private IByteDanceAdvertiserDataService advertiserDataService;
+    @Autowired
+    private IByteDanceCreativeService creativeService;
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+
+        Thread thread = new Thread() {
+            @Override
+            public void run() {
+                //1:查询当日数据
+                List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE);
+                executorService = Executors.newFixedThreadPool(4);
+                tokens.forEach(token -> {
+                    executorService.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            try {
+                                //1:获取当日广告计划数据
+                                advertiserDataService.getAdvertiserPlan(token, "", null, null);
+                            } catch (Exception e) {
+                                e.printStackTrace();
+                            } finally {
+                            }
+                        }
+                    });
+                });
+                log.info("头条全量计划数据获取完成");
+            }
+
+        };
+        thread.start();
+    }
+}

+ 12 - 12
jeecg-boot-module-system/src/main/java/org/jeecg/modules/system/service/impl/PerformanceServiceImpl2.java

@@ -1628,10 +1628,10 @@ public class PerformanceServiceImpl2 extends ServiceImpl<PerformanceMapper, Perf
     public List<UserDto2> kuaishouPerformanceInfoNow() {
         //0 获取当前季度的时间
         Map<String, Integer> dateMap = DateUtils.getYearQuarter(new Date());
-        //Integer year = dateMap.get("year");
-        //Integer quarter = dateMap.get("quarter");
-        int year = 2019;
-        int quarter = 4;
+        Integer year = dateMap.get("year");
+        Integer quarter = dateMap.get("quarter");
+        //int year = 2019;
+        //int quarter = 4;
         Map<String, String> timeMap = DateUtils.quarterStartEndDate(year, quarter);
         String startTime = timeMap.get("startDate");
         String endTime = timeMap.get("endDate");
@@ -1670,10 +1670,10 @@ public class PerformanceServiceImpl2 extends ServiceImpl<PerformanceMapper, Perf
     public List<UserDto2> kuaishouYouhuaPerformanceInfoNow() {
         //0 获取当前季度的时间
         Map<String, Integer> dateMap = DateUtils.getYearQuarter(new Date());
-        //Integer year = dateMap.get("year");
-        //Integer quarter = dateMap.get("quarter");
-        int year = 2019;
-        int quarter = 4;
+        Integer year = dateMap.get("year");
+        Integer quarter = dateMap.get("quarter");
+        //int year = 2019;
+        //int quarter = 4;
         Map<String, String> timeMap = DateUtils.quarterStartEndDate(year, quarter);
         String startTime = timeMap.get("startDate");
         String endTime = timeMap.get("endDate");
@@ -1698,10 +1698,10 @@ public class PerformanceServiceImpl2 extends ServiceImpl<PerformanceMapper, Perf
     public List<UserDto2> toutiaoYouhuaPerformanceInfoNow() {
         //0 获取当前季度的时间
         Map<String, Integer> dateMap = DateUtils.getYearQuarter(new Date());
-        //Integer year = dateMap.get("year");
-        //Integer quarter = dateMap.get("quarter");
-        int year = 2019;
-        int quarter = 4;
+        Integer year = dateMap.get("year");
+        Integer quarter = dateMap.get("quarter");
+        //int year = 2019;
+        //int quarter = 4;
         Map<String, String> timeMap = DateUtils.quarterStartEndDate(year, quarter);
         String startTime = timeMap.get("startDate");
         String endTime = timeMap.get("endDate");

+ 5 - 5
performance-appraisal/src/main/java/cn/com/ctop/userefficientvideomap/mapper/xml/UserEfficientVideoMapMapper.xml

@@ -509,7 +509,7 @@
         where c.signature is not null and d.id is not null
         and DATE_FORMAT(d.create_time,'%Y-%m-%d') &gt;= #{startDate}
         and DATE_FORMAT(d.create_time,'%Y-%m-%d') &lt;= #{endDate}
-        where e.plan_id = #{userId}
+        and e.plan_id = #{userId}
     </select>
 
     <!-- 头条根据clip_id获取视频总消耗 -->
@@ -524,7 +524,7 @@
         where c.signature is not null and d.id is not null
         and DATE_FORMAT(d.create_time,'%Y-%m-%d') &gt;= #{startDate}
         and DATE_FORMAT(d.create_time,'%Y-%m-%d') &lt;= #{endDate}
-        where e.clip_id = #{userId}
+        and e.clip_id = #{userId}
     </select>
 
     <!-- 头条根据shot_id获取视频总消耗 -->
@@ -539,7 +539,7 @@
         where c.signature is not null and d.id is not null
         and DATE_FORMAT(d.create_time,'%Y-%m-%d') &gt;= #{startDate}
         and DATE_FORMAT(d.create_time,'%Y-%m-%d') &lt;= #{endDate}
-        where e.shot_id = #{userId}
+        and e.shot_id = #{userId}
     </select>
 
     <!-- 根据year、quarter、user_id获取季度总绩效 -->
@@ -756,7 +756,7 @@
         left join sys_user u on ud.user_id = u.id
         left join sys_user_role ur on u.id = ur.user_id
         left join sys_role r on ur.role_id = r.id
-        WHERE b.parent_id = '0dd29c09d2c94f98ae91902094c6cf68'  <!-- 快手运营部 -->
+        WHERE b.parent_id = '024b0dc0840045afb048022a8c61253f'  <!-- 快手运营部 -->
     </select>
 
     <!-- 获取北京头条运营部所有优化师得信息 -->
@@ -771,7 +771,7 @@
         left join sys_user u on ud.user_id = u.id
         left join sys_user_role ur on u.id = ur.user_id
         left join sys_role r on ur.role_id = r.id
-        WHERE b.parent_id = '989799ba602e40fcb03f522d5284b705'  <!-- 头条运营部 -->
+        WHERE b.parent_id = 'c869de6bedc44a50803e45a4611df05e'  <!-- 头条运营部 -->
     </select>
 
     <!-- 获取快手单个优化师当前账户下的总消耗 -->