diff --git a/coolstore-partner-service/src/main/java/com/cool/store/job/JobHandler.java b/coolstore-partner-service/src/main/java/com/cool/store/job/JobHandler.java index 1780a81e2..183974e29 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/job/JobHandler.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/job/JobHandler.java @@ -63,18 +63,18 @@ public class JobHandler { } } - @XxlJob("updateAbsentInterview") - public void updateAbsentInterview(){ - try { - log.info("面试缺席定时任务开始"); - hyPartnerInterviewPlanService.updateAbsentInterview(); - log.info("面试缺席定时任务结束"); - XxlJobHelper.handleSuccess(); - }catch (Exception e){ - log.error("面试缺席定时任务异常",e); - XxlJobHelper.log("面试缺席定时任务异常"+e.getMessage()); - } - } +// @XxlJob("updateAbsentInterview") +// public void updateAbsentInterview(){ +// try { +// log.info("面试缺席定时任务开始"); +// hyPartnerInterviewPlanService.updateAbsentInterview(); +// log.info("面试缺席定时任务结束"); +// XxlJobHelper.handleSuccess(); +// }catch (Exception e){ +// log.error("面试缺席定时任务异常",e); +// XxlJobHelper.log("面试缺席定时任务异常"+e.getMessage()); +// } +// } @XxlJob("approvalReminder") public void approvalReminder(){ diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/HyPartnerInterviewPlanServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/HyPartnerInterviewPlanServiceImpl.java index 31c0d1b37..f4aae65c8 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/HyPartnerInterviewPlanServiceImpl.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/HyPartnerInterviewPlanServiceImpl.java @@ -179,11 +179,14 @@ public class HyPartnerInterviewPlanServiceImpl implements HyPartnerInterviewPlan return; } List lineIds = overTimeReserveLineList.stream().map(o -> o.getId()).collect(Collectors.toList()); - List interviewBaseInfoList = hyPartnerInterviewMapper.getInterviewBaseInfoListByLineIds(lineIds); - if(CollectionUtils.isEmpty(interviewBaseInfoList)){ - return; + for (Long lineId : lineIds) { + CloseFollowRequest closeFollowRequest = new CloseFollowRequest(); + closeFollowRequest.setRejectPublicReason("超时未预约"); + closeFollowRequest.setRejectRealReason("超时未预约"); + closeFollowRequest.setLineId(lineId); + closeFollowRequest.setType("overtime_interview"); + hyPartnerLineInfoService.closeOrPassFollow(null,closeFollowRequest); } - handleOverTimeInterview(interviewBaseInfoList,"超时未预约"); } @Override @@ -192,7 +195,7 @@ public class HyPartnerInterviewPlanServiceImpl implements HyPartnerInterviewPlan //更新会议开始时间为5分钟之内的房间状态为开启,会议状态变为已开始 Date startTime = new Date(); - List waitForOpenInterviewLineList = hyPartnerLineInfoMapper.getWaitForOpenInterviewLineList(startTime, DateUtil.offsetMinute(startTime, 5)); + List waitForOpenInterviewLineList = hyPartnerLineInfoMapper.getWaitForOpenInterviewLineList(DateUtil.offsetDay(startTime,-2), DateUtil.offsetMinute(startTime, 5)); if(CollectionUtils.isEmpty(waitForOpenInterviewLineList)){ return; } @@ -248,6 +251,7 @@ public class HyPartnerInterviewPlanServiceImpl implements HyPartnerInterviewPlan for (Long lineId : lineIds) { CloseFollowRequest closeFollowRequest = new CloseFollowRequest(); closeFollowRequest.setRejectPublicReason(rejectPublicReason); + closeFollowRequest.setRejectRealReason(rejectPublicReason); closeFollowRequest.setLineId(lineId); closeFollowRequest.setType("overtime_interview"); hyPartnerLineInfoService.closeOrPassFollow(null,closeFollowRequest);