From 80ea368c15a4db967099cbc1fcf48fa4c214079f Mon Sep 17 00:00:00 2001
From: liaoxuwei <5789413@qq.com>
Date: Thu, 17 Apr 2025 17:59:08 +0800
Subject: [PATCH] =?UTF-8?q?=E7=97=85=E5=81=87=E6=89=A3=E5=88=86=E8=A7=84?=
=?UTF-8?q?=E5=88=99=E5=85=A8=E5=A4=A91=E5=88=86=E5=8D=8A=E5=A4=A90.5?=
=?UTF-8?q?=E5=88=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../applicationservice/StaffCheckSummaryService.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/StaffCheckSummaryService.java b/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/StaffCheckSummaryService.java
index 6e26b3ae..8964d40b 100644
--- a/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/StaffCheckSummaryService.java
+++ b/attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/StaffCheckSummaryService.java
@@ -15,6 +15,7 @@ import com.mortals.xhx.module.staff.service.StaffPerformSummaryEditService;
import com.mortals.xhx.module.staff.service.StaffPerformSummaryService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.QueryTimeoutException;
import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
@@ -67,6 +68,7 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
try {
StaffCheckSummaryQuery query = cacheService.brpop(KEY_CHECK_SUMMARY_CACHE,60, StaffCheckSummaryQuery.class);
if(!ObjectUtils.isEmpty(query)){
+ log.info("缁╂晥鍒嗘暟姹囨€诲紑濮�:" + JSONObject.toJSONString(query));
if(StringUtils.isNotEmpty(query.getCheckTimeStart())){
Date date = DateUtil.parse(query.getCheckTimeStart(),"yyyy-MM-dd");
query.setCheckTimeStart(DateUtil.beginOfMonth(date).toDateStr());
@@ -131,7 +133,6 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
checkOtherRecordService.summaryCheck(query);
}
if(query.getCheckType()==null){
- log.info("缁╂晥鍒嗘暟姹囨€诲紑濮�:"+ JSONObject.toJSONString(query));
checkAttendRecordService.summaryCheck(query);
checkEffectRecordService.summaryCheck(query);
checkGoworkRecordService.summaryCheck(query);
@@ -152,14 +153,16 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
} catch (InterruptedException e2) {
}
- } catch (Exception e) {
- // log.error("寮傚父", e);
+ } catch (QueryTimeoutException e) {
+ } catch (Exception e) {
+ log.error("缁╂晥鍒嗘暟姹囨€诲紓甯�", e);
try {
Thread.sleep(waitTime);
} catch (InterruptedException e2) {
}
}
+
}
}
});
--
2.24.3