suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

定时任务调整

Browse Source
This commit is contained in:
zhangchenbiao
2023-08-17 10:06:20 +08:00
parent 637780c52f
commit 4d62a3cd87
3 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
coolstore-partner-common/src/main/java/com/cool/store/constants/CommonConstants.java
View File

@@ -105,6 +105,8 @@ public class CommonConstants {
public static final int HUNDRED = 100; public static final int HUNDRED = 100;
public static final int FIVE_HUNDRED = 100; public static final int FIVE_HUNDRED = 100;
public static final int ONE_THOUSAND = 1000; public static final int ONE_THOUSAND = 1000;
public static final int FIFTY_FIVE = 55;
public static final int SIXTY_FIVE = 65;
public static final String ONE_STR = "1"; public static final String ONE_STR = "1";

5
coolstore-partner-service/src/main/java/com/cool/store/job/JobHandler.java
View File

@@ -1,11 +1,14 @@
package com.cool.store.job; package com.cool.store.job;
import com.cool.store.constants.CommonConstants;
import com.cool.store.service.EnterpriseSyncService; import com.cool.store.service.EnterpriseSyncService;
import com.cool.store.service.FollowTaskService; import com.cool.store.service.FollowTaskService;
import com.cool.store.service.HyPartnerInterviewPlanService; import com.cool.store.service.HyPartnerInterviewPlanService;
import com.cool.store.utils.UUIDUtils;
import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -83,6 +86,7 @@ public class JobHandler {
@XxlJob("followTaskAnHourAgoRemind") @XxlJob("followTaskAnHourAgoRemind")
public void followTaskAnHourAgoRemind(){ public void followTaskAnHourAgoRemind(){
try { try {
MDC.put(CommonConstants.REQUEST_ID, UUIDUtils.get8UUID());
log.info("跟进任务前一小时提醒开始"); log.info("跟进任务前一小时提醒开始");
followTaskService.followTaskAnHourAgoRemind(); followTaskService.followTaskAnHourAgoRemind();
log.info("跟进任务前一小时提醒结束"); log.info("跟进任务前一小时提醒结束");
@@ -96,6 +100,7 @@ public class JobHandler {
@XxlJob("followTaskDailyRemind") @XxlJob("followTaskDailyRemind")
public void followTaskDailyRemind(){ public void followTaskDailyRemind(){
try { try {
MDC.put(CommonConstants.REQUEST_ID, UUIDUtils.get8UUID());
log.info("跟进任务提醒开始"); log.info("跟进任务提醒开始");
followTaskService.followTaskDailyRemind(); followTaskService.followTaskDailyRemind();
log.info("跟进任务提醒结束"); log.info("跟进任务提醒结束");

4
coolstore-partner-service/src/main/java/com/cool/store/service/impl/FollowTaskServiceImpl.java
View File

@@ -189,8 +189,8 @@ public class FollowTaskServiceImpl implements FollowTaskService {
//获取一个小时后的任务 //获取一个小时后的任务
Boolean hasNext = true; Boolean hasNext = true;
int pageNum = CommonConstants.ONE, pageSize = CommonConstants.HUNDRED; int pageNum = CommonConstants.ONE, pageSize = CommonConstants.HUNDRED;
String startTime = DateUtil.format(DateUtils.addMinutes(new Date(), -CommonConstants.FIVE), CoolDateUtils.DATE_FORMAT_SEC); String startTime = DateUtil.format(DateUtils.addMinutes(new Date(), CommonConstants.FIFTY_FIVE), CoolDateUtils.DATE_FORMAT_SEC);
String endTime = DateUtil.format(DateUtils.addMinutes(new Date(), CommonConstants.FIVE), CoolDateUtils.DATE_FORMAT_SEC); String endTime = DateUtil.format(DateUtils.addMinutes(new Date(), CommonConstants.SIXTY_FIVE), CoolDateUtils.DATE_FORMAT_SEC);
while (hasNext){ while (hasNext){
Page<HyFollowTaskDO> undoTaskList = hyFollowTaskDAO.getUndoTaskPage(startTime, endTime, pageNum, pageSize); Page<HyFollowTaskDO> undoTaskList = hyFollowTaskDAO.getUndoTaskPage(startTime, endTime, pageNum, pageSize);
if(CollectionUtils.isEmpty(undoTaskList)){ if(CollectionUtils.isEmpty(undoTaskList)){