|
|
|
@ -48,7 +48,7 @@ public class CustomerImpressionTask {
|
|
|
|
|
}
|
|
|
|
|
for (List<JSONObject> splitClients : splitList) {
|
|
|
|
|
Runnable task = () -> splitClients.forEach((p) -> {
|
|
|
|
|
System.out.println("当前执行到" + p.getIntValue("client_id"));
|
|
|
|
|
// System.out.println("当前执行到" + p.getIntValue("client_id"));
|
|
|
|
|
customerImpressionService.generateTag(p.getIntValue("client_id"));
|
|
|
|
|
});
|
|
|
|
|
generatePool.execute(task);
|
|
|
|
@ -56,8 +56,8 @@ public class CustomerImpressionTask {
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Scheduled(cron = "0/1 * * * * ?")
|
|
|
|
|
public void customerImpressionGenerateInfo() {
|
|
|
|
|
synchronizedScheduler.executeProcess("manage_task:CustomerImpression", 1_000, () -> customerImpressionService.generateInfo());
|
|
|
|
|
}
|
|
|
|
|
// @Scheduled(cron = "0/1 * * * * ?")
|
|
|
|
|
// public void customerImpressionGenerateInfo() {
|
|
|
|
|
// synchronizedScheduler.executeProcess("manage_task:CustomerImpression", 1_000, () -> customerImpressionService.generateInfo());
|
|
|
|
|
// }
|
|
|
|
|
}
|
|
|
|
|