From ce1415bcfe6e5ce5627bcac21f7efb5c2122b289 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BF=9E=E6=89=AC?= Date: Sun, 25 Jun 2023 14:38:27 +0800 Subject: [PATCH] =?UTF-8?q?=E8=87=AA=E5=8A=A8=E6=9B=B4=E6=96=B0=E6=88=BF?= =?UTF-8?q?=E9=97=B4=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mapper/HyPartnerInterviewPlanMapper.xml | 44 +++++++++---------- .../java/com/cool/store/job/JobHandler.java | 39 +++++++++++----- .../HyPartnerInterviewPlanServiceImpl.java | 3 +- 3 files changed, 51 insertions(+), 35 deletions(-) diff --git a/coolstore-partner-dao/src/main/resources/mapper/HyPartnerInterviewPlanMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/HyPartnerInterviewPlanMapper.xml index 640204bc2..6e1ab1f6d 100644 --- a/coolstore-partner-dao/src/main/resources/mapper/HyPartnerInterviewPlanMapper.xml +++ b/coolstore-partner-dao/src/main/resources/mapper/HyPartnerInterviewPlanMapper.xml @@ -203,16 +203,16 @@ set room_status = #{roomStatus},update_time = now() - and hpip.room_status = #{record.roomStatus} + and room_status = #{record.roomStatus} - - and hpip.start_time >= #{record.startTime} + + and start_time >= #{record.startTime} - - and hpip.end_time <= #{record.endTime} + + and end_time <= #{record.endTime} - and hpip.deleted = #{deleted} + and deleted = #{deleted} @@ -222,16 +222,16 @@ set room_status = #{roomStatus},update_time = now() - and hpip.room_status = #{record.roomStatus} + and room_status = #{record.roomStatus} - - and hpip.start_time >= #{record.startTime} + + and start_time >= #{record.startTime} - - and hpip.start_time <= #{record.endTime} + + and start_time <= #{record.endTime} - and hpip.deleted = #{deleted} + and deleted = #{deleted} @@ -241,16 +241,16 @@ set room_status = #{roomStatus},update_time = now() - and hpip.room_status = #{record.roomStatus} + and room_status = #{record.roomStatus} - - and hpip.end_time >= #{record.startTime} + + and end_time >= #{record.startTime} - - and hpip.end_time <= #{record.endTime} + + and end_time <= #{record.endTime} - and hpip.deleted = #{deleted} + and deleted = #{deleted} @@ -353,10 +353,10 @@ and hpip.room_status = #{record.roomStatus} - + and hpip.start_time >= #{record.startTime} - + and hpip.end_time <= #{record.endTime} @@ -415,10 +415,10 @@ and partner_id = #{record.partnerId} - + and start_time = #{record.startTime} - + and end_time = #{record.endTime} 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 d5fe9b58c..4f5ae6b51 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 @@ -39,25 +39,40 @@ public class JobHandler { */ @XxlJob("updateInterviewOverTime") public void updateInterviewOverTime(){ - log.info("面试超时定时任务开始"); - hyPartnerInterviewPlanService.updateInterviewOverTime(); - log.info("面试超时定时任务结束"); - XxlJobHelper.handleSuccess(); + try { + log.info("面试超时定时任务开始"); + hyPartnerInterviewPlanService.updateInterviewOverTime(); + log.info("面试超时定时任务结束"); + XxlJobHelper.handleSuccess(); + }catch (Exception e){ + log.error("面试超时定时任务异常",e); + XxlJobHelper.log("面试超时定时任务异常"+e.getMessage()); + } } @XxlJob("openInterviewRoom") public void openInterviewRoom(){ - log.info("房间状态开启定时任务开始"); - hyPartnerInterviewPlanService.openInterviewRoom(); - log.info("房间状态开启定时任务结束"); - XxlJobHelper.handleSuccess(); + try { + log.info("房间状态开启定时任务开始"); + hyPartnerInterviewPlanService.openInterviewRoom(); + log.info("房间状态开启定时任务结束"); + XxlJobHelper.handleSuccess(); + }catch (Exception e){ + log.error("房间状态开启定时任务异常",e); + XxlJobHelper.log("房间状态开启定时任务异常"+e.getMessage()); + } } public void updateAbsentInterview(){ - log.info("面试缺席定时任务开始"); - hyPartnerInterviewPlanService.updateAbsentInterview(); - log.info("面试缺席定时任务结束"); - XxlJobHelper.handleSuccess(); + try { + log.info("面试缺席定时任务开始"); + hyPartnerInterviewPlanService.updateAbsentInterview(); + log.info("面试缺席定时任务结束"); + XxlJobHelper.handleSuccess(); + }catch (Exception e){ + log.error("面试缺席定时任务异常",e); + XxlJobHelper.log("面试缺席定时任务异常"+e.getMessage()); + } } 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 369b0f6a4..891b1ca02 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 @@ -174,8 +174,9 @@ public class HyPartnerInterviewPlanServiceImpl implements HyPartnerInterviewPlan public void openInterviewRoom() { //更新会议开始时间为十分钟之内的房间状态为开启 Date startTime = new Date(); + String startTimeStr = DateUtil.formatDateTime(startTime); HyPartnerInterviewPlanDO hyPartnerInterviewPlanDO = new HyPartnerInterviewPlanDO(); - hyPartnerInterviewPlanDO.setStartTime(startTime); + hyPartnerInterviewPlanDO.setStartTime(DateUtil.parseDateTime(startTimeStr)); hyPartnerInterviewPlanDO.setEndTime(DateUtil.offsetMinute(startTime,10)); hyPartnerInterviewPlanDO.setRoomStatus(RoomStatus.WAIT_FOR_OPEN.getCode()); hyPartnerInterviewPlanDO.setDeleted(false);