到期提醒创建任务修改

wangqian
1 parent d558e0c6
Showing 4 changed files with 27 additions and 13 deletions
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/controller/admin/assigntasks/vo/AssignTasksSaveReqVO.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/assigntasks/AssignTasksServiceImpl.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/assigntasksinfo/AssignTasksInfoServiceImpl.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/assigntasksinfo/QuartzRemindService.java
@@ -43,8 +43,11 @@ public class AssignTasksSaveReqVO {
     private Integer parentFinish;
     @Schema(description = "整体完成时间（仅当parent_finish=1时有值）")
-    @JsonFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
-    private Date finishTime;
+    @JsonFormat(
+            pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND,
+            timezone = "GMT+8",
+            shape = JsonFormat.Shape.STRING
+    )    private Date finishTime;
     @Schema(description = "任务备注（如：特殊要求、注意事项等）")
     private String note;
@@ -72,6 +72,19 @@ public class AssignTasksServiceImpl implements AssignTasksService {
     @Transactional(rollbackFor = Exception.class)
     @Override
     public Long createAssignTasks(AssignTasksSaveReqVO createReqVO) {
+        // 核心校验逻辑
+        Date deadline = createReqVO.getDeadline();
+        // 1. 先校验deadline是否为空（避免空指针）
+        if (deadline == null) {
+            throw exception0(BAD_REQUEST.getCode(), "到期日不能为空");
+        }
+        // 2. 获取当前时间（绑定业务时区，避免时区偏差）
+        Date now = new Date();
+        // 3. 核心判断：到期日 小于 当前时间 → 抛出异常
+        if (deadline.before(now)) {
+            throw exception0(BAD_REQUEST.getCode(), "到期日不能小于当前日期");
+        }
+        //
         // 插入
         AssignTasksDO assignTasks = BeanUtils.toBean(createReqVO, AssignTasksDO.class);
         assignTasksMapper.insert(assignTasks);
@@ -85,8 +85,8 @@ public class AssignTasksInfoServiceImpl implements AssignTasksInfoService {
     // 时间格式常量（与之前保持一致）
     public static final String FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND = "yyyy-MM-dd HH:mm:ss";
-    // 提前提醒的天数（3天）
-    private static final long REMIND_ADVANCE_DAYS = 3L;
+    // 提前提醒（3小时）
+    private static final long REMIND_ADVANCE_HOURS = 3L;
     // 1. 定义线程安全的格式化器（全局复用，无需重复创建）
     private static final DateTimeFormatter DEADLINE_FORMATTER = DateTimeFormatter
@@ -179,7 +179,6 @@ public class AssignTasksInfoServiceImpl implements AssignTasksInfoService {
                 // add by 20260307 初始化单位积分
                 unitIntegralService.createUnitIntegral(CommonConstants.UNIT_INTEGRAL_UNIT_TYPE_01, String.valueOf(companyId), assignTaskInfo.getCompanyName());
                 try {
-                    //保存成功后创建定时器，3天执行
                     // 1. 获取截止时间并校验非空
                     LocalDateTime deadline = assignTasks.getDeadline();
                     if (deadline == null) {
@@ -188,16 +187,16 @@ public class AssignTasksInfoServiceImpl implements AssignTasksInfoService {
                         return;
                     }
-                    // 2. 计算：当前时间 + 3天 是否超过截止时间（即截止时间不足3天）
+                    // 2. 计算：当前时间 + 3小时 是否超过截止时间（即截止时间不足3小时）
                     LocalDateTime now = LocalDateTime.now(DEFAULT_ZONE); // 当前东八区时间
-                    LocalDateTime remindThreshold = now.plusDays(REMIND_ADVANCE_DAYS);
+                    LocalDateTime remindThreshold = now.plusHours(REMIND_ADVANCE_HOURS);
-                    // 核心判断：截止时间 <= （当前时间+3天） → 不足3天，不创建定时任务
+                    // 核心判断：截止时间 <= （当前时间+3小时） → 不足3小时，不创建定时任务
                     if (deadline.isBefore(remindThreshold) || deadline.isEqual(remindThreshold)) {
                         String formattedDeadline = deadline.format(DATE_FORMATTER);
                         String formattedThreshold = remindThreshold.format(DATE_FORMATTER);
-                        log.info("任务ID={} 无需创建定时任务：截止时间={}，不足{}天（阈值时间={}）",
-                                assignTaskInfo.getId(), formattedDeadline, REMIND_ADVANCE_DAYS, formattedThreshold);
+                        log.info("任务ID={} 无需创建定时任务：截止时间={}，不足{}小时（阈值时间={}）",
+                                assignTaskInfo.getId(), formattedDeadline, REMIND_ADVANCE_HOURS, formattedThreshold);
                         return; // 直接返回，不创建定时任务
                     }
@@ -10,7 +10,6 @@ import org.springframework.stereotype.Service;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.Set;
-import java.util.concurrent.TimeUnit;
 /**
  * 动态注册到期提醒Quartz任务的服务
@@ -36,8 +35,8 @@ public class QuartzRemindService {
 			throw new IllegalArgumentException("任务信息不完整，无法注册提醒");
 		}
-		// 2. 计算触发时间：到期时间 - 3天
-		Date triggerTime = new Date(expireTime.getTime() - TimeUnit.DAYS.toMillis(3));
+		// 2. 计算触发时间：到期时间 - 3小时
+		Date triggerTime = new Date(expireTime.getTime() - 3 * 60 * 60 * 1000L);
 		// 3. 定义JobKey（唯一标识：任务ID + 组名）
 		JobKey jobKey = new JobKey("REMIND_JOB_" + jobId, REMIND_JOB_GROUP);