|
|
|
@ -46,34 +46,11 @@ public class StorePromotionDataJob {
|
|
|
|
|
sysTaskDO = new SysTaskDO(TASK_NAME_USER_BEHAVIOR,TASK_STATUS_RUNNING,TASK_TYPE_USER_BEHAVIOR,new Date());
|
|
|
|
|
sysTaskDOMapper.insert(sysTaskDO);
|
|
|
|
|
log.info("<--获取联系客户统计数据定时任务执行-->");
|
|
|
|
|
customerBehaviorJob.handle(DateUtils.addDay(new Date(),-3),DateUtils.addDay(new Date(),-1),sysTaskDO);
|
|
|
|
|
customerBehaviorJob.handle(DateUtils.addDay(new Date(),-3),new Date(),sysTaskDO);
|
|
|
|
|
log.info("<--获取联系客户统计数据定时任务结束-->");
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("获取联系客户统计数据任务出错", e);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Scheduled(cron = "0 0/15 9/1 * * ??")
|
|
|
|
|
public void syncTodayData(){
|
|
|
|
|
try {
|
|
|
|
|
int random = new Random().nextInt(100);
|
|
|
|
|
Thread.sleep(random*100);
|
|
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:00");
|
|
|
|
|
QueryWrapper<SysTaskDO> qw = new QueryWrapper<>();
|
|
|
|
|
qw.eq("type",TASK_TYPE_USER_BEHAVIOR_TODAY).eq("create_time",sdf.format(new Date())).last("limit 1");
|
|
|
|
|
SysTaskDO sysTaskDO = sysTaskDOMapper.selectOne(qw);
|
|
|
|
|
if (sysTaskDO == null){
|
|
|
|
|
sysTaskDO = new SysTaskDO(TASK_NAME_USER_BEHAVIOR_TODAY,TASK_STATUS_RUNNING,TASK_TYPE_USER_BEHAVIOR_TODAY,new Date());
|
|
|
|
|
sysTaskDOMapper.insert(sysTaskDO);
|
|
|
|
|
log.info("<--获取联系客户统计数据定时任务执行-->");
|
|
|
|
|
customerBehaviorJob.handle(new Date(),new Date(),sysTaskDO);
|
|
|
|
|
log.info("<--获取联系客户统计数据定时任务结束-->");
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("获取联系客户统计数据任务出错", e);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|