到期提醒创建任务修改

wangqian
1 parent 79d3c0d9
Showing 3 changed files with 32 additions and 6 deletions
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/job/task/ExpireRemindJob.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
@@ -81,7 +81,7 @@ public class ExpireRemindJob implements Job {
 //			LocalDateTime now = LocalDateTime.now();
 //			// 计算当前时间到到期时间的时长（单位：小时）
 //			long hoursUntilDeadline = java.time.Duration.between(now, deadline).toHours();
-//			// 核心判断：到期前不足3小时（包括已过期），不提醒
+//			// 核心判断：到期前不足3天时（包括已过期），不提醒
 //			if (hoursUntilDeadline < 3) {
 //				log.info("【到期提醒Job】任务到期前不足3小时，无需提醒，任务ID：{}，到期时间：{}，当前时间：{}",
 //						taskId, deadline, now);
@@ -85,6 +85,9 @@ 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;
+
     // 1. 定义线程安全的格式化器（全局复用，无需重复创建）
     private static final DateTimeFormatter DEADLINE_FORMATTER = DateTimeFormatter
             .ofPattern(FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
@@ -176,20 +179,42 @@ public class AssignTasksInfoServiceImpl implements AssignTasksInfoService {
                 // add by 20260307 初始化单位积分
                 unitIntegralService.createUnitIntegral(CommonConstants.UNIT_INTEGRAL_UNIT_TYPE_01, String.valueOf(companyId), assignTaskInfo.getCompanyName());
                 try {
-                    //保存成功后创建定时器，3小时执行
-                    // 2. 安全转换LocalDateTime到Date（指定东八区，避免时区问题）
+                    //保存成功后创建定时器，3天执行
+                    // 1. 获取截止时间并校验非空
                     LocalDateTime deadline = assignTasks.getDeadline();
+                    if (deadline == null) {
+                        log.warn("创建定时任务失败：任务ID={}，截止时间为空", assignTaskInfo.getId());
+                        // 可根据业务需求抛出异常或直接返回
+                        return;
+                    }
+
+                    // 2. 计算：当前时间 + 3天 是否超过截止时间（即截止时间不足3天）
+                    LocalDateTime now = LocalDateTime.now(DEFAULT_ZONE); // 当前东八区时间
+                    LocalDateTime remindThreshold = now.plusDays(REMIND_ADVANCE_DAYS);
+
+                    // 核心判断：截止时间 <= （当前时间+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);
+                        return; // 直接返回，不创建定时任务
+                    }
+
+                    // 3. 安全转换LocalDateTime到Date（指定东八区，避免时区问题）
                     Date triggerDate = Date.from(
                             deadline.atZone(DEFAULT_ZONE)  // 绑定东八区（业务时区）
                                     .toInstant()          // 转为Instant
                     );
  
-                    // 3. 规范日志输出（使用占位符，格式化时间）
+                    // 4. 规范日志输出（使用占位符，格式化时间）
                     String formattedDeadline = deadline.format(DATE_FORMATTER);
                     log.info("创建定时任务：任务ID={}, 截止时间(LocalDateTime)={}, 转换后Date时间={}",
                             assignTaskInfo.getId(),
                             formattedDeadline,
                             triggerDate);
+
+                    // 5. 注册定时任务
                     quartzRemindService.registerRemindJob(assignTaskInfo.getId(), triggerDate);
                 } catch (SchedulerException exception) {
                     throw exception0(BAD_REQUEST.getCode(),"创建到期定时提醒异常");
@@ -10,6 +10,7 @@ import org.springframework.stereotype.Service;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
  
 /**
  * 动态注册到期提醒Quartz任务的服务
@@ -35,8 +36,8 @@ public class QuartzRemindService {
 			throw new IllegalArgumentException("任务信息不完整，无法注册提醒");
 		}
  
-		// 2. 计算触发时间：到期时间 - 3小时
-		Date triggerTime = new Date(expireTime.getTime() - 3 * 60 * 60 * 1000L);
+		// 2. 计算触发时间：到期时间 - 3天
+		Date triggerTime = new Date(expireTime.getTime() - TimeUnit.DAYS.toMillis(3));
  
 		// 3. 定义JobKey（唯一标识：任务ID + 组名）
 		JobKey jobKey = new JobKey("REMIND_JOB_" + jobId, REMIND_JOB_GROUP);