|
@@ -4,6 +4,7 @@ import cn.com.ctop.common.module.entity.CtopOauthToken;
|
|
import cn.com.ctop.common.module.service.ICtopOauthTokenService;
|
|
import cn.com.ctop.common.module.service.ICtopOauthTokenService;
|
|
import cn.com.ctop.common.module.utils.CtopAdConstant;
|
|
import cn.com.ctop.common.module.utils.CtopAdConstant;
|
|
import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
|
|
import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
|
|
|
|
+import lombok.SneakyThrows;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.jeecg.common.util.DateUtils;
|
|
import org.jeecg.common.util.DateUtils;
|
|
import org.quartz.Job;
|
|
import org.quartz.Job;
|
|
@@ -11,6 +12,8 @@ import org.quartz.JobExecutionContext;
|
|
import org.quartz.JobExecutionException;
|
|
import org.quartz.JobExecutionException;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
|
|
|
+import java.text.ParseException;
|
|
|
|
+import java.text.SimpleDateFormat;
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.ExecutorService;
|
|
@@ -30,19 +33,22 @@ public class KuaishouNowDateGroupJob implements Job {
|
|
|
|
|
|
|
|
|
|
Thread thread = new Thread() {
|
|
Thread thread = new Thread() {
|
|
|
|
+ @SneakyThrows
|
|
@Override
|
|
@Override
|
|
public void run() {
|
|
public void run() {
|
|
//1:查询当日数据
|
|
//1:查询当日数据
|
|
- Date nowDate = DateUtils.getDate();
|
|
|
|
|
|
+ Date endDate = DateUtils.getDate();
|
|
|
|
+ String anotherDay = DateUtils.getAnotherDay("yyyy-MM-dd", DateUtils.formatDate(endDate), -1);
|
|
|
|
+ SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
|
+ Date startDate = sim.parse(anotherDay);
|
|
List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_KUAISHOU);
|
|
List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_KUAISHOU);
|
|
- executorService = Executors.newFixedThreadPool(8);
|
|
|
|
|
|
+ executorService = Executors.newFixedThreadPool(5);
|
|
tokens.forEach(token -> {
|
|
tokens.forEach(token -> {
|
|
executorService.submit(new Runnable() {
|
|
executorService.submit(new Runnable() {
|
|
@Override
|
|
@Override
|
|
public void run() {
|
|
public void run() {
|
|
try {
|
|
try {
|
|
- //1:获取全量广告组数据
|
|
|
|
- kuaishouInterfaceService.getGroupList(token, nowDate, nowDate);
|
|
|
|
|
|
+ kuaishouInterfaceService.getGroupList(token, startDate, endDate);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
} finally {
|
|
} finally {
|
|
@@ -58,4 +64,17 @@ public class KuaishouNowDateGroupJob implements Job {
|
|
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ /* public static void main(String[] args) throws ParseException {
|
|
|
|
+ Date nowDate = DateUtils.getDate();
|
|
|
|
+ String anotherDay = DateUtils.getAnotherDay("yyyy-MM-dd", DateUtils.formatDate(nowDate), -1);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
|
+ Date endDate = sim.parse(anotherDay);
|
|
|
|
+ String s = DateUtils.formatDate(endDate);
|
|
|
|
+ System.err.println(s);
|
|
|
|
+
|
|
|
|
+ }*/
|
|
}
|
|
}
|