|
@@ -1,8 +1,10 @@
|
|
|
package cn.com.ctop.job.kuaishou.handler;
|
|
|
|
|
|
+import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouAccountMaterialReportDailyService;
|
|
|
import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouReportAccountDailyService;
|
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
+import org.jeecg.common.util.DateUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
@@ -16,6 +18,8 @@ public class KuaishouDailyAccountReportLoadEtlJob {
|
|
|
|
|
|
@Autowired
|
|
|
private IEtlKuaishouReportAccountDailyService iEtlKuaishouReportAccountDailyService;
|
|
|
+ @Autowired
|
|
|
+ private IEtlKuaishouAccountMaterialReportDailyService etlKuaishouAccountMaterialReportDailyService;
|
|
|
|
|
|
@XxlJob("kuaishouDailyAccountReportLoadEtl")
|
|
|
public void execute() throws Exception {
|
|
@@ -26,4 +30,18 @@ public class KuaishouDailyAccountReportLoadEtlJob {
|
|
|
XxlJobHelper.log(e.getMessage());
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 快手账户素材数据清洗任务
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ @XxlJob("etlKuaishouAccountMaterialReportDailyData")
|
|
|
+ public void etlKuaishouAccountMaterialReportDailyData() throws Exception {
|
|
|
+ try {
|
|
|
+ etlKuaishouAccountMaterialReportDailyService.etlKuaishouAccountMaterialReportDailyData(DateUtils.formatDate());
|
|
|
+ XxlJobHelper.log("queryEveryDayDataForAccount success");
|
|
|
+ } catch (Exception e) {
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|