diff --git a/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/FeedbackExceptionCheckJob.java b/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/FeedbackExceptionCheckJob.java
index b3e2242..2249634 100644
--- a/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/FeedbackExceptionCheckJob.java
+++ b/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/FeedbackExceptionCheckJob.java
@@ -10,7 +10,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
- * 安全责任清单 - 定时任务2：反馈异常检测
+ * 安全责任清单 - 定时任务：反馈异常检测
*
* 执行周期：每月1日0时（cron = "0 0 0 1 * ?"）
*
@@ -35,9 +35,6 @@ public class FeedbackExceptionCheckJob implements Job {
*
* 由XXL-Job调度框架调用，执行反馈异常检测逻辑。
* 执行成功返回SUCCESS，异常时返回FAIL及错误信息。
- *
- * @param param XXL-Job传入的参数（当前任务未使用）
- * @return 执行结果，成功返回ReturnT.SUCCESS，失败返回ReturnT.FAIL_CODE及异常信息
*/
@Override
@JobRegister(cron = "0 55 10 * * ?", jobDesc = "安全责任清单-反馈异常检测", triggerStatus = 1)
diff --git a/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/TaskStatusUpdateJob.java b/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/TaskStatusUpdateJob.java
index c1ffa02..eff8110 100644
--- a/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/TaskStatusUpdateJob.java
+++ b/web-adapter/src/main/java/com/zcloud/safetyDutyList/job/TaskStatusUpdateJob.java
@@ -10,7 +10,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
- * 安全责任清单 - 定时任务1：更新清单状态和任务状态
+ * 安全责任清单 - 定时任务：更新清单状态和任务状态
*
* 执行周期：每月1日0时（cron = "0 0 0 1 * ?"）
*
@@ -43,12 +43,12 @@ public class TaskStatusUpdateJob implements Job {
@JobRegister(cron = "0 0 0 1 * ?", jobDesc = "安全责任清单-更新清单和任务状态", triggerStatus = 1)
@XxlJob("com.zcloud.safetyDutyList.job.TaskStatusUpdateJob")
public ReturnT execute(String param) {
- log.info("【安全责任清单】开始执行更新清单和任务状态定时任务");
+ log.info("【定时任务-安全责任清单-检测任务完成】开始执行更新清单和任务状态定时任务");
try {
taskListService.updateExpiredTaskListStatus();
- log.info("【安全责任清单】更新清单和任务状态定时任务执行完成");
+ log.info("【定时任务-安全责任清单-检测任务完成】更新清单和任务状态定时任务执行完成");
} catch (Exception e) {
- log.error("【安全责任清单】更新清单和任务状态定时任务执行异常", e);
+ log.error("【定时任务-安全责任清单-检测任务完成】更新清单和任务状态定时任务执行异常", e);
return new ReturnT<>(ReturnT.FAIL_CODE, e.getMessage());
}
return ReturnT.SUCCESS;
diff --git a/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/FeedbackController.java b/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/FeedbackController.java
index add1f9c..1f1fad5 100644
--- a/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/FeedbackController.java
+++ b/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/FeedbackController.java
@@ -15,7 +15,7 @@ import org.springframework.web.bind.annotation.*;
/**
* 执行反馈控制器
*
- * 提供反馈提交、反馈列表查询、反馈周期分组查询、反馈异常记录查询等接口，
+ * 提供反馈提交、反馈列表查询、反馈周期分组查询、反馈详情等接口，
* 委托TaskListServiceI处理业务逻辑。
*/
@Api(tags = "执行反馈")
diff --git a/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/StatisticsController.java b/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/StatisticsController.java
index b2c028b..938d8a6 100644
--- a/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/StatisticsController.java
+++ b/web-adapter/src/main/java/com/zcloud/safetyDutyList/web/tasklist/StatisticsController.java
@@ -17,11 +17,11 @@ import org.springframework.web.bind.annotation.*;
public class StatisticsController {
private final TaskListServiceI taskListService;
- @ApiOperation("获取统计信息")
- @PostMapping("/list")
- public MultiResponse statistics(@RequestBody TaskListStatisticsQry qry) {
- return taskListService.statistics(qry);
- }
+// @ApiOperation("获取统计信息")
+// @PostMapping("/list")
+// public MultiResponse statistics(@RequestBody TaskListStatisticsQry qry) {
+// return taskListService.statistics(qry);
+// }
@ApiOperation("获取企业统计（股份端）")
@PostMapping("/corpStatistics")
diff --git a/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/FeedbackExceptionCheckExe.java b/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/FeedbackExceptionCheckExe.java
index 64c01b8..fa3667e 100644
--- a/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/FeedbackExceptionCheckExe.java
+++ b/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/FeedbackExceptionCheckExe.java
@@ -4,9 +4,11 @@ import com.zcloud.safetyDutyList.domain.enums.ExceptionTypeEnum;
import com.zcloud.safetyDutyList.domain.gateway.tasklist.FeedbackExceptionGateway;
import com.zcloud.safetyDutyList.domain.gateway.tasklist.FeedbackGateway;
import com.zcloud.safetyDutyList.domain.gateway.tasklist.TaskDetailGateway;
+import com.zcloud.safetyDutyList.domain.gateway.tasklist.TaskListGateway;
import com.zcloud.safetyDutyList.domain.model.tasklist.FeedbackE;
import com.zcloud.safetyDutyList.domain.model.tasklist.FeedbackExceptionE;
import com.zcloud.safetyDutyList.domain.model.tasklist.TaskDetailE;
+import com.zcloud.safetyDutyList.domain.model.tasklist.TaskListE;
import com.zcloud.safetyDutyList.domain.util.FeedbackCycleUtil;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -19,20 +21,23 @@ import java.util.List;
/**
* 反馈异常检测执行器
*
- * 处理定时任务2的业务逻辑：检测所有进行中任务的反馈异常情况。
+ * 处理定时任务2的业务逻辑：检测已下发清单下所有任务的反馈异常情况。
*
* 处理流程：
- * 1. 查询所有进行中的任务(task_status=1)
- * 2. 根据每个任务的反馈周期类型(feedback_cycle_type)计算上一阶段的周期标识
- * 3. 检查上一阶段是否已存在异常记录，避免重复添加
- * 4. 检查上一阶段是否有反馈记录，若无则判定为异常
- * 5. 为异常任务创建反馈异常记录，写入safety_accountability_feedback_exception表
+ * 1. 查询所有已下发且周期时间完整的清单（issue_status=1, period_start_time/end_time不为空）
+ * 2. 遍历每个清单，获取其下所有任务
+ * 3. 对每个任务，以清单的周期起始时间判断是否仍处于首个反馈周期内
+ * 4. 若仍处于首周期，跳过（首周期尚未结束，不应判定异常）
+ * 5. 若已过首周期，计算上一阶段周期标识，检查是否有反馈记录
+ * 6. 若上一阶段无反馈且无异常记录，则创建反馈异常记录
*
- * 反馈周期判定规则：
- * feedback_cycle_type=1（每月）：每个月都需要反馈至少一次，上一阶段=上个月
- * feedback_cycle_type=2（每季度）：每个季度都需要反馈至少一次，上一阶段=上个季度
- * feedback_cycle_type=3（每半年）：每半年都需要反馈至少一次，上一阶段=上个半年
- * feedback_cycle_type=4（年）：一年内必须反馈至少一次，上一阶段=去年
+ * 首周期判断逻辑（以清单periodStartTime为准）：
+ * 将periodStartTime和当前时间分别生成周期标识，若相同则仍在首周期内。
+ * 例如：清单起始时间2026年7月，当前2026年7月12日：
+ * 每月→首周期=2026-07=当前周期→跳过
+ * 每季度→首周期=2026-Q3=当前周期→跳过
+ * 每半年→首周期=2026-H2=当前周期→跳过
+ * 每年→首周期=2026-Y=当前周期→跳过
*
* 事务控制：整个检测过程在同一事务中执行，确保异常记录写入的原子性
*/
@@ -41,79 +46,101 @@ import java.util.List;
@AllArgsConstructor
public class FeedbackExceptionCheckExe {
- /** 任务详情网关，用于查询进行中的任务列表 */
+ private final TaskListGateway taskListGateway;
+
private final TaskDetailGateway taskDetailGateway;
- /** 反馈网关，用于查询任务的反馈记录 */
private final FeedbackGateway feedbackGateway;
- /** 反馈异常网关，用于查询已有异常记录和新增异常记录 */
private final FeedbackExceptionGateway feedbackExceptionGateway;
/**
* 执行反馈异常检测
*
- * 遍历所有进行中的任务，根据反馈周期类型判断上一阶段是否有反馈记录，
- * 若无反馈则创建反馈异常记录。
+ * 遍历所有已下发且周期时间完整的清单，对每个清单下的任务进行反馈异常检测。
*/
@Transactional(rollbackFor = Exception.class)
public void execute() {
- // 步骤1：获取所有进行中的任务
- List inProgressTasks = taskDetailGateway.listInProgress();
- if (inProgressTasks == null || inProgressTasks.isEmpty()) {
- log.info("【安全责任清单】没有进行中的任务需要检测");
+
+ // 查询所有已下发且周期时间完整的清单
+ List issuedList = taskListGateway.listIssuedWithPeriod();
+ if (issuedList == null || issuedList.isEmpty()) {
+ log.info("【定时任务-安全责任清单-检测反馈异常】没有已下发且周期时间完整的清单需要检测");
return;
}
- log.info("【安全责任清单】查询到{}条进行中任务需要检测反馈异常", inProgressTasks.size());
- for (TaskDetailE taskDetail : inProgressTasks) {
- Integer feedbackCycleType = taskDetail.getFeedbackCycleType();
- // 反馈周期类型为空则跳过，无法判定异常
- if (feedbackCycleType == null) {
- log.warn("【安全责任清单】任务[{}]反馈周期类型为空，跳过检测", taskDetail.getTaskDetailId());
+ log.info("【定时任务-安全责任清单-检测反馈异常】查询到{}条已下发清单需要检测反馈异常", issuedList.size());
+
+ // 遍历每个清单
+ for (TaskListE taskList : issuedList) {
+
+ // 获取清单下的任务
+ List taskDetails = taskDetailGateway.listByTaskListId(taskList.getTaskListId());
+ if (taskDetails == null || taskDetails.isEmpty()) {
continue;
}
- // 步骤2：根据反馈周期类型计算上一阶段的周期标识
- // 例如：每月->上月"2026-04"，每季度->上季度"2026-Q1"，每半年->上半年"2025-H2"，每年->去年"2025"
- String previousPeriodFlag = FeedbackCycleUtil.generatePreviousPeriodFlag(feedbackCycleType);
- if (previousPeriodFlag == null) {
- log.warn("【安全责任清单】任务[{}]无法生成上一阶段周期标识，feedbackCycleType={}",
- taskDetail.getTaskDetailId(), feedbackCycleType);
- continue;
- }
-
- // 步骤3：检查上一阶段是否已有异常记录，避免重复添加
- boolean alreadyHasException = checkExistingException(taskDetail.getTaskDetailId(), previousPeriodFlag);
- if (alreadyHasException) {
- log.info("【安全责任清单】任务[{}]在周期[{}]已存在异常记录，跳过",
- taskDetail.getTaskDetailId(), previousPeriodFlag);
- continue;
- }
-
- // 步骤4：获取该任务的反馈列表，判断上一阶段是否有反馈记录
- boolean hasFeedback = checkPreviousPeriodFeedback(taskDetail.getTaskDetailId(), previousPeriodFlag);
-
- if (!hasFeedback) {
- // 步骤5：上一阶段无反馈记录，判定为异常，添加反馈异常记录
- createFeedbackException(taskDetail, previousPeriodFlag);
- log.info("【安全责任清单】任务[{}]在周期[{}]未反馈，已添加异常记录",
- taskDetail.getTaskDetailId(), previousPeriodFlag);
- } else {
- log.info("【安全责任清单】任务[{}]在周期[{}]已正常反馈",
- taskDetail.getTaskDetailId(), previousPeriodFlag);
+ // 遍历每个任务
+ for (TaskDetailE taskDetail : taskDetails) {
+ checkTaskFeedback(taskList, taskDetail);
}
}
}
+ /**
+ * 检测单个任务的反馈异常
+ *
+ * @param taskList 所属清单（用于获取周期起始时间）
+ * @param taskDetail 任务详情
+ */
+ private void checkTaskFeedback(TaskListE taskList, TaskDetailE taskDetail) {
+ Integer feedbackCycleType = taskDetail.getFeedbackCycleType();
+ if (feedbackCycleType == null) {
+ log.warn("【定时任务-安全责任清单-检测反馈异常】任务[{}]反馈周期类型为空，跳过检测", taskDetail.getTaskDetailId());
+ return;
+ }
+
+ // 当前时间处于首周期，跳过
+ if (FeedbackCycleUtil.isFirstCycle(feedbackCycleType, taskList.getPeriodStartTime())) {
+ log.info("【定时任务-安全责任清单-检测反馈异常】清单[{}]任务[{}]周期类型为{}，仍处于首周期内，跳过检测",
+ taskList.getTaskListId(), taskDetail.getTaskDetailId(), feedbackCycleType);
+ return;
+ }
+
+ // 上一阶段周期标识
+ String previousPeriodFlag = FeedbackCycleUtil.generatePreviousPeriodFlag(feedbackCycleType);
+ if (previousPeriodFlag == null) {
+ log.warn("【定时任务-安全责任清单-检测反馈异常】任务[{}]无法生成上一阶段周期标识，feedbackCycleType={}",
+ taskDetail.getTaskDetailId(), feedbackCycleType);
+ return;
+ }
+
+ // 异常记录是否存在
+ boolean alreadyHasException = checkExistingException(taskDetail.getTaskDetailId(), previousPeriodFlag);
+ if (alreadyHasException) {
+ log.info("【定时任务-安全责任清单-检测反馈异常】任务[{}]在周期[{}]已存在异常记录，跳过",
+ taskDetail.getTaskDetailId(), previousPeriodFlag);
+ return;
+ }
+
+ // 上一阶段周期标识对应的反馈记录是否存在
+ boolean hasFeedback = checkPreviousPeriodFeedback(taskDetail.getTaskDetailId(), previousPeriodFlag);
+
+ if (!hasFeedback) {
+ createFeedbackException(taskDetail, previousPeriodFlag);
+ log.info("【定时任务-安全责任清单-检测反馈异常】任务[{}]在周期[{}]未反馈，已添加异常记录",
+ taskDetail.getTaskDetailId(), previousPeriodFlag);
+ } else {
+ log.info("【定时任务-安全责任清单-检测反馈异常】任务[{}]在周期[{}]已正常反馈",
+ taskDetail.getTaskDetailId(), previousPeriodFlag);
+ }
+ }
+
/**
* 检查上一阶段是否已有异常记录
- *
- * 查询该任务的所有异常记录，筛选出与上一阶段周期标识匹配的记录，
- * 若存在则说明该阶段的异常已被记录，无需重复添加。
*
* @param taskDetailId 任务详情ID
- * @param previousPeriodFlag 上一阶段的周期标识（如"2026-04"、"2026-Q1"等）
+ * @param previousPeriodFlag 上一阶段的周期标识
* @return true-已存在异常记录，false-不存在异常记录
*/
private boolean checkExistingException(String taskDetailId, String previousPeriodFlag) {
@@ -121,19 +148,15 @@ public class FeedbackExceptionCheckExe {
if (exceptionList == null || exceptionList.isEmpty()) {
return false;
}
- // 遍历异常记录，判断是否存在与上一阶段周期标识匹配的记录
return exceptionList.stream()
.anyMatch(e -> previousPeriodFlag.equals(e.getExceptionPeriodFlag()));
}
/**
* 检查上一阶段是否有反馈记录
- *
- * 查询该任务的所有反馈记录，筛选出与上一阶段周期标识匹配的记录，
- * 若存在至少一条则说明该阶段已正常反馈。
*
* @param taskDetailId 任务详情ID
- * @param previousPeriodFlag 上一阶段的周期标识（如"2026-04"、"2026-Q1"等）
+ * @param previousPeriodFlag 上一阶段的周期标识
* @return true-存在反馈记录，false-不存在反馈记录
*/
private boolean checkPreviousPeriodFeedback(String taskDetailId, String previousPeriodFlag) {
@@ -141,23 +164,12 @@ public class FeedbackExceptionCheckExe {
if (feedbackList == null || feedbackList.isEmpty()) {
return false;
}
- // 遍历反馈记录，判断是否存在与上一阶段周期标识匹配的反馈
return feedbackList.stream()
.anyMatch(f -> previousPeriodFlag.equals(f.getFeedbackPeriodFlag()));
}
/**
* 创建反馈异常记录
- *
- * 当检测到任务在上一阶段未提交反馈时，创建一条反馈异常记录，
- * 写入safety_accountability_feedback_exception表。
- *
- * 记录内容包括：
- * - 任务详情ID和清单ID：关联到具体的任务和清单
- * - 异常周期标识：标识哪个周期未反馈
- * - 异常周期起止时间：该周期的起止时间范围
- * - 异常类型：未按时反馈(1)
- * - 异常时间：当前检测时间
*
* @param taskDetail 未按时反馈的任务详情
* @param previousPeriodFlag 上一阶段的周期标识
@@ -166,21 +178,17 @@ public class FeedbackExceptionCheckExe {
FeedbackExceptionE exceptionE = new FeedbackExceptionE();
exceptionE.init();
- // 设置关联的任务详情ID和清单ID
exceptionE.setTaskDetailId(taskDetail.getTaskDetailId());
exceptionE.setTaskListId(taskDetail.getTaskListId());
- // 设置异常周期标识（如"2026-04"、"2026-Q1"等）
exceptionE.setExceptionPeriodFlag(previousPeriodFlag);
- // 根据周期标识计算该周期的起止时间，用于记录异常的时间范围
LocalDateTime[] periodTime = FeedbackCycleUtil.getPeriodTime(previousPeriodFlag);
- if (periodTime != null) {
+ if (periodTime != null && periodTime.length == 2) {
exceptionE.setExceptionPeriodStartTime(periodTime[0]);
exceptionE.setExceptionPeriodEndTime(periodTime[1]);
}
- // 设置异常类型为"未按时反馈"，异常时间为当前时间
exceptionE.setExceptionType(ExceptionTypeEnum.NOT_FEEDBACK.getCode());
exceptionE.setExceptionTime(LocalDateTime.now());
diff --git a/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/TaskListStatusUpdateExe.java b/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/TaskListStatusUpdateExe.java
index a15f948..fbd43b2 100644
--- a/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/TaskListStatusUpdateExe.java
+++ b/web-app/src/main/java/com/zcloud/safetyDutyList/command/tasklist/TaskListStatusUpdateExe.java
@@ -47,16 +47,17 @@ public class TaskListStatusUpdateExe {
// 步骤1：查询所有状态为进行中(status=1)且周期结束时间(period_end_time)小于当前时间的清单
List expiredList = taskListGateway.listExpiredInProgress();
if (expiredList == null || expiredList.isEmpty()) {
- log.info("【安全责任清单】没有需要更新的过期清单");
+ log.info("【定时任务-安全责任清单-检测任务完成】没有需要更新的过期清单");
return;
}
- log.info("【安全责任清单】查询到{}条过期清单需要更新状态", expiredList.size());
+
+ log.info("【定时任务-安全责任清单-检测任务完成】查询到{}条过期清单需要更新状态", expiredList.size());
for (TaskListE taskListE : expiredList) {
// 步骤2：将清单状态从进行中(1)更新为已完成(2)
taskListE.setStatus(TaskStatusEnum.COMPLETED.getCode());
taskListGateway.update(taskListE);
- log.info("【安全责任清单】清单[{}]状态已更新为已完成", taskListE.getTaskListId());
+ log.info("【定时任务-安全责任清单-检测任务完成】清单[{}]状态已更新为已完成", taskListE.getTaskListId());
// 步骤3：查询该清单下所有任务详情，将进行中的任务更新为已完成
List detailList = taskDetailGateway.listByTaskListId(taskListE.getTaskListId());
@@ -66,7 +67,7 @@ public class TaskListStatusUpdateExe {
if (TaskStatusEnum.IN_PROGRESS.getCode().equals(detailE.getTaskStatus())) {
detailE.setTaskStatus(TaskStatusEnum.COMPLETED.getCode());
taskDetailGateway.update(detailE);
- log.info("【安全责任清单】任务[{}]状态已更新为已完成", detailE.getTaskDetailId());
+ log.info("【定时任务-安全责任清单-检测任务完成】任务[{}]状态已更新为已完成", detailE.getTaskDetailId());
}
}
}
diff --git a/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/gateway/tasklist/TaskListGateway.java b/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/gateway/tasklist/TaskListGateway.java
index ad5bb32..0ebdc60 100644
--- a/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/gateway/tasklist/TaskListGateway.java
+++ b/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/gateway/tasklist/TaskListGateway.java
@@ -68,4 +68,15 @@ public interface TaskListGateway {
* @return 已过期的进行中清单列表
*/
List listExpiredInProgress();
+
+ /**
+ * 查询所有已下发且周期时间完整的清单
+ *
+ * 查询条件：issue_status=1（已下发）且 period_start_time IS NOT NULL 且 period_end_time IS NOT NULL
+ * 且 period_end_time不超过当前时间1个月（超过1个月不再检测异常）
+ * 用于定时任务2：反馈异常检测，以清单周期起始时间判断是否跳过检测
+ *
+ * @return 已下发且周期时间完整的清单列表
+ */
+ List listIssuedWithPeriod();
}
diff --git a/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/model/tasklist/TaskListE.java b/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/model/tasklist/TaskListE.java
index 2fdf81a..9b1bc75 100644
--- a/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/model/tasklist/TaskListE.java
+++ b/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/model/tasklist/TaskListE.java
@@ -25,9 +25,9 @@ public class TaskListE extends BaseE {
private Integer status;
private LocalDateTime periodStartTime;
private LocalDateTime periodEndTime;
- private BigDecimal score;
- private Long scoreUserId;
- private Long scoreDepartmentId;
+ private BigDecimal ratingScore;
+ private Long ratingUserId;
+ private Long ratingDepartmentId;
private Long createCorpId;
private Long createDepartmentId;
private Long createUserId;
diff --git a/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/util/FeedbackCycleUtil.java b/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/util/FeedbackCycleUtil.java
index de8ea34..471bd0a 100644
--- a/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/util/FeedbackCycleUtil.java
+++ b/web-domain/src/main/java/com/zcloud/safetyDutyList/domain/util/FeedbackCycleUtil.java
@@ -16,7 +16,7 @@ import java.time.LocalDateTime;
* 每月： "2026-05" （年-月）
* 每季度： "2026-Q1" （年-季度，Q1=1-3月，Q2=4-6月，Q3=7-9月，Q4=10-12月）
* 每半年： "2026-H1" （年-半年，H1=1-6月，H2=7-12月）
- * 每年： "2026" （年）
+ * 每年： "2026-Y" （年-Y）
*/
public class FeedbackCycleUtil {
@@ -26,26 +26,21 @@ public class FeedbackCycleUtil {
* 根据周期标识的格式自动识别周期类型，返回该周期的起始时间和结束时间。
* 起始时间为该周期第一天的00:00:00，结束时间为该周期最后一天的23:59:59。
*
- * @param periodFlag 周期标识（如"2026-05"、"2026-Q1"、"2026-H1"、"2026"）
+ * @param periodFlag 周期标识（如"2026-05"、"2026-Q1"、"2026-H1"、"2026-Y"）
* @return 长度为2的LocalDateTime数组，[0]=起始时间，[1]=结束时间；若无法识别则返回null
*/
public static LocalDateTime[] getPeriodTime(String periodFlag) {
if (periodFlag == null || periodFlag.isEmpty()) {
return null;
}
- // 根据周期标识中的特征字符判断周期类型
if (periodFlag.contains("-Q")) {
- // 包含"-Q"标识，为季度周期（如"2026-Q1"）
return getQuarterPeriod(periodFlag);
} else if (periodFlag.contains("-H")) {
- // 包含"-H"标识，为半年周期（如"2026-H1"）
return getHalfYearPeriod(periodFlag);
- } else if (periodFlag.contains("-") && periodFlag.length() == 7) {
- // 包含"-"且长度为7，为月度周期（如"2026-05"）
- return getMonthPeriod(periodFlag);
- } else if (periodFlag.length() == 4) {
- // 长度为4的纯数字，为年度周期（如"2026"）
+ } else if (periodFlag.contains("-Y")) {
return getYearPeriod(periodFlag);
+ } else if (periodFlag.contains("-") && periodFlag.length() == 7) {
+ return getMonthPeriod(periodFlag);
}
return null;
}
@@ -62,9 +57,7 @@ public class FeedbackCycleUtil {
String[] parts = periodFlag.split("-");
int year = Integer.parseInt(parts[0]);
int month = Integer.parseInt(parts[1]);
- // 起始时间：该月1日00:00:00
LocalDateTime start = LocalDateTime.of(year, month, 1, 0, 0, 0);
- // 结束时间：该月最后一天23:59:59
LocalDateTime end = LocalDateTime.of(year, month, LocalDate.of(year, month, 1).lengthOfMonth(), 23, 59, 59);
return new LocalDateTime[]{start, end};
}
@@ -84,12 +77,9 @@ public class FeedbackCycleUtil {
String[] parts = periodFlag.split("-Q");
int year = Integer.parseInt(parts[0]);
int quarter = Integer.parseInt(parts[1]);
- // 计算季度的起始月份和结束月份
int startMonth = (quarter - 1) * 3 + 1;
int endMonth = startMonth + 2;
- // 起始时间：季度首月1日00:00:00
LocalDateTime start = LocalDateTime.of(year, startMonth, 1, 0, 0, 0);
- // 结束时间：季度末月最后一天23:59:59
LocalDateTime end = LocalDateTime.of(year, endMonth, LocalDate.of(year, endMonth, 1).lengthOfMonth(), 23, 59, 59);
return new LocalDateTime[]{start, end};
}
@@ -109,12 +99,9 @@ public class FeedbackCycleUtil {
String[] parts = periodFlag.split("-H");
int year = Integer.parseInt(parts[0]);
int half = Integer.parseInt(parts[1]);
- // 计算半年的起始月份和结束月份
int startMonth = (half - 1) * 6 + 1;
int endMonth = startMonth + 5;
- // 起始时间：半年首月1日00:00:00
LocalDateTime start = LocalDateTime.of(year, startMonth, 1, 0, 0, 0);
- // 结束时间：半年末月最后一天23:59:59
LocalDateTime end = LocalDateTime.of(year, endMonth, LocalDate.of(year, endMonth, 1).lengthOfMonth(), 23, 59, 59);
return new LocalDateTime[]{start, end};
}
@@ -122,16 +109,15 @@ public class FeedbackCycleUtil {
/**
* 解析年度周期的起止时间
*
- * 例如："2026" -> [2026-01-01 00:00:00, 2026-12-31 23:59:59]
+ * 例如："2026-Y" -> [2026-01-01 00:00:00, 2026-12-31 23:59:59]
*
- * @param periodFlag 年度周期标识（格式："yyyy"）
+ * @param periodFlag 年度周期标识（格式："yyyy-Y"）
* @return 起止时间数组
*/
private static LocalDateTime[] getYearPeriod(String periodFlag) {
- int year = Integer.parseInt(periodFlag);
- // 起始时间：1月1日00:00:00
+ String yearStr = periodFlag.replace("-Y", "");
+ int year = Integer.parseInt(yearStr);
LocalDateTime start = LocalDateTime.of(year, 1, 1, 0, 0, 0);
- // 结束时间：12月31日23:59:59
LocalDateTime end = LocalDateTime.of(year, 12, 31, 23, 59, 59);
return new LocalDateTime[]{start, end};
}
@@ -143,7 +129,7 @@ public class FeedbackCycleUtil {
* feedbackCycle=1（每月）： "2026-05"
* feedbackCycle=2（每季度）： "2026-Q1"
* feedbackCycle=3（每半年）： "2026-H1"
- * feedbackCycle=4（每年）： "2026"
+ * feedbackCycle=4（每年）： "2026-Y"
*
* @param feedbackCycle 反馈周期类型（1-每月，2-每季度，3-每半年，4-每年）
* @param time 参考时间，若为null则使用当前时间
@@ -156,21 +142,15 @@ public class FeedbackCycleUtil {
int year = time.getYear();
switch (feedbackCycle) {
case 1:
- // 每月：格式为"年-月"，如"2026-05"
return String.format("%d-%02d", year, time.getMonthValue());
case 2:
- // 每季度：格式为"年-Q季度"，如"2026-Q1"
- // 季度计算：(月份-1)/3 + 1，如5月=(5-1)/3+1=Q2
int quarter = (time.getMonthValue() - 1) / 3 + 1;
return String.format("%d-Q%d", year, quarter);
case 3:
- // 每半年：格式为"年-H半年"，如"2026-H1"
- // 1-6月为H1，7-12月为H2
int half = time.getMonthValue() <= 6 ? 1 : 2;
return String.format("%d-H%d", year, half);
case 4:
- // 每年：格式为"年"，如"2026"
- return String.valueOf(year);
+ return String.format("%d-Y", year);
default:
return null;
}
@@ -185,7 +165,7 @@ public class FeedbackCycleUtil {
* feedbackCycle=1（每月）： 上个月，如当前2026-05则返回"2026-04"
* feedbackCycle=2（每季度）： 上个季度，如当前Q1则返回上年Q4，当前Q2则返回当年Q1
* feedbackCycle=3（每半年）： 上个半年，如当前H1则返回上年H2，当前H2则返回当年H1
- * feedbackCycle=4（每年）： 去年，如当前2026则返回"2025"
+ * feedbackCycle=4（每年）： 去年，如当前2026-Y则返回"2025-Y"
*
* @param feedbackCycle 反馈周期类型（1-每月，2-每季度，3-每半年，4-每年）
* @return 上一阶段周期标识，若周期类型不合法则返回null
@@ -194,12 +174,9 @@ public class FeedbackCycleUtil {
LocalDateTime now = LocalDateTime.now();
switch (feedbackCycle) {
case 1:
- // 每月：回退一个月，如2026-05 -> 2026-04
LocalDateTime lastMonth = now.minusMonths(1);
return String.format("%d-%02d", lastMonth.getYear(), lastMonth.getMonthValue());
case 2:
- // 每季度：回退一个季度
- // 若当前为Q1(1-3月)，则上一季度为上年的Q4；否则为当年的上一季度
int currentQuarter = (now.getMonthValue() - 1) / 3 + 1;
if (currentQuarter == 1) {
return String.format("%d-Q4", now.getYear() - 1);
@@ -207,8 +184,6 @@ public class FeedbackCycleUtil {
return String.format("%d-Q%d", now.getYear(), currentQuarter - 1);
}
case 3:
- // 每半年：回退一个半年
- // 若当前为H1(1-6月)，则上一半年为上年的H2；否则为当年的H1
int currentHalf = now.getMonthValue() <= 6 ? 1 : 2;
if (currentHalf == 1) {
return String.format("%d-H2", now.getYear() - 1);
@@ -216,13 +191,47 @@ public class FeedbackCycleUtil {
return String.format("%d-H1", now.getYear());
}
case 4:
- // 每年：回退一年，如2026 -> 2025
- return String.valueOf(now.getYear() - 1);
+ return String.format("%d-Y", now.getYear() - 1);
default:
return null;
}
}
+ /**
+ * 判断当前时间是否仍处于清单的首个反馈周期内
+ *
+ * 用于反馈异常检测定时任务，判断是否应该检查上一周期的反馈情况。
+ * 如果当前时间仍处于清单的首个反馈周期内，说明该周期尚未结束，不应检测异常；
+ * 只有当首个反馈周期已结束，进入第二个或之后的周期时，才需要检测上一周期。
+ *
+ * 判断方式：根据清单周期起始时间生成"首周期标识"，根据当前时间生成"当前周期标识"，
+ * 若两者相同则说明仍在首周期内，应跳过检测。
+ *
+ * 示例（清单周期起始时间为2026年7月，当前时间为2026年7月12日）：
+ * 每月→首周期=2026-07，当前=2026-07 → 相同 → 跳过
+ * 每季度→首周期=2026-Q3，当前=2026-Q3 → 相同 → 跳过
+ * 每半年→首周期=2026-H2，当前=2026-H2 → 相同 → 跳过
+ * 每年→首周期=2026-Y，当前=2026-Y → 相同 → 跳过
+ *
+ * 示例（清单周期起始时间为2026年7月，当前时间为2026年8月1日）：
+ * 每月→首周期=2026-07，当前=2026-08 → 不同 → 检查2026-07
+ * 每季度→首周期=2026-Q3，当前=2026-Q3 → 相同 → 跳过
+ * 每半年→首周期=2026-H2，当前=2026-H2 → 相同 → 跳过
+ * 每年→首周期=2026-Y，当前=2026-Y → 相同 → 跳过
+ *
+ * @param feedbackCycle 反馈周期类型（1-每月，2-每季度，3-每半年，4-每年）
+ * @param periodStartTime 清单周期起始时间
+ * @return true-仍在首周期内应跳过检测，false-首周期已结束应检测上一周期
+ */
+ public static boolean isFirstCycle(Integer feedbackCycle, LocalDateTime periodStartTime) {
+ if (periodStartTime == null) {
+ return true;
+ }
+ String firstCycleFlag = generatePeriodFlag(feedbackCycle, periodStartTime);
+ String currentCycleFlag = generatePeriodFlag(feedbackCycle, LocalDateTime.now());
+ return firstCycleFlag != null && firstCycleFlag.equals(currentCycleFlag);
+ }
+
/**
* 判断给定周期标识是否为当前周期
*
diff --git a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/gatewayimpl/tasklist/TaskListGatewayImpl.java b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/gatewayimpl/tasklist/TaskListGatewayImpl.java
index 94ff3ca..f887909 100644
--- a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/gatewayimpl/tasklist/TaskListGatewayImpl.java
+++ b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/gatewayimpl/tasklist/TaskListGatewayImpl.java
@@ -144,4 +144,18 @@ public class TaskListGatewayImpl implements TaskListGateway {
}
return eList;
}
+
+ @Override
+ public List listIssuedWithPeriod() {
+ List doList = taskListRepository.listIssuedWithPeriod();
+ List eList = new ArrayList<>();
+ if (doList != null) {
+ for (TaskListDO d : doList) {
+ TaskListE e = new TaskListE();
+ BeanUtils.copyProperties(d, e);
+ eList.add(e);
+ }
+ }
+ return eList;
+ }
}
diff --git a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/mapper/tasklist/TaskListMapper.java b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/mapper/tasklist/TaskListMapper.java
index 1502cfc..9c2eed8 100644
--- a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/mapper/tasklist/TaskListMapper.java
+++ b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/mapper/tasklist/TaskListMapper.java
@@ -32,6 +32,8 @@ public interface TaskListMapper extends BaseMapper {
List listExpiredInProgress();
+ List listIssuedWithPeriod();
+
IPage corpStatistics(IPage iPage, Map params);
IPage evaluationList(IPage iPage, Map params);
diff --git a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/impl/tasklist/TaskListRepositoryImpl.java b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/impl/tasklist/TaskListRepositoryImpl.java
index e378189..697715e 100644
--- a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/impl/tasklist/TaskListRepositoryImpl.java
+++ b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/impl/tasklist/TaskListRepositoryImpl.java
@@ -73,6 +73,11 @@ public class TaskListRepositoryImpl extends BaseRepositoryImpl listIssuedWithPeriod() {
+ return taskListMapper.listIssuedWithPeriod();
+ }
+
@Override
public PageResponse corpStatistics(Map params) {
IPage iPage = new Query().getPage(params);
diff --git a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/tasklist/TaskListRepository.java b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/tasklist/TaskListRepository.java
index 3251e6b..69da2e7 100644
--- a/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/tasklist/TaskListRepository.java
+++ b/web-infrastructure/src/main/java/com/zcloud/safetyDutyList/persistence/repository/tasklist/TaskListRepository.java
@@ -32,6 +32,8 @@ public interface TaskListRepository extends BaseRepository {
List listExpiredInProgress();
+ List listIssuedWithPeriod();
+
PageResponse corpStatistics(Map params);
PageResponse evaluationList(Map params);
diff --git a/web-infrastructure/src/main/resources/mapper/tasklist/TaskListMapper.xml b/web-infrastructure/src/main/resources/mapper/tasklist/TaskListMapper.xml
index c8e2b3e..bee0101 100644
--- a/web-infrastructure/src/main/resources/mapper/tasklist/TaskListMapper.xml
+++ b/web-infrastructure/src/main/resources/mapper/tasklist/TaskListMapper.xml
@@ -141,6 +141,12 @@
WHERE status = 1 AND issue_status = 1 AND (period_end_time IS NOT NULL AND period_end_time < NOW())
+
+