yumeng 1 سال پیش
والد
کامیت
8f66cc8882
1فایلهای تغییر یافته به همراه71 افزوده شده و 0 حذف شده
  1. 71 0
      job-adq/src/main/java/cn/com/ctop/job/adq/handler/AdqCreativeReportJob.java

+ 71 - 0
job-adq/src/main/java/cn/com/ctop/job/adq/handler/AdqCreativeReportJob.java

@@ -0,0 +1,71 @@
+package cn.com.ctop.job.adq.handler;
+
+
+import cn.com.ctop.job.adq.data.service.IAdqReportService;
+import cn.com.ctop.job.adq.data.utils.Check;
+import cn.com.ctop.job.adq.data.utils.DateUtils;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+
+/**
+ * 广告主定时任务
+ *
+ * @throws Exception
+ */
+@Slf4j
+@Component
+public class AdqCreativeReportJob {
+    private static ExecutorService hourExecutorService = Executors.newFixedThreadPool(3);
+    @Autowired
+    private IAdqReportService adqReportService;
+
+    @XxlJob("nowDateCreativeHour")
+    public void creativeHour() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String[] s = param.split("_");
+        Long advertiserId = Long.valueOf(s[0]);
+        String accessToken = s[1];
+        hourExecutorService.submit(new Runnable() {
+            @Override
+            public void run() {
+                adqReportService.getAdqCreativeHour(advertiserId, accessToken, nowDate, nowDate, 1);
+            }
+        });
+    }
+
+
+    @XxlJob("yesDateCreativeHour")
+    public void yesDateCreativeHour() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesDate = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+        String[] s = param.split("_");
+        Long advertiserId = Long.valueOf(s[0]);
+        String accessToken = s[1];
+        hourExecutorService.submit(new Runnable() {
+            @Override
+            public void run() {
+                adqReportService.getAdqCreativeHour(advertiserId, accessToken, yesDate, yesDate, 1);
+            }
+        });
+    }
+
+}