push

yd-csf-api/src/main/java/com/yd/csf/api/handler/CalmSendJobHandler.java

 package com.yd.csf.api.handler;
 package com.yd.csf.api.handler;
 
 
+import com.alibaba.fastjson.JSON;
+import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import com.xxl.job.core.handler.annotation.XxlJob;
+import com.yd.csf.service.service.ICalmTaskService;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
 
 
+import java.time.LocalDateTime;
+import java.util.Objects;
+
 /**
 /**
  * 冷静期定时发送任务处理器 - XXL-Job定时任务执行器
  * 冷静期定时发送任务处理器 - XXL-Job定时任务执行器
  * 使用@XxlJob注解方式
  * 使用@XxlJob注解方式
@@ -12,12 +19,34 @@ import org.springframework.stereotype.Component;
 @Slf4j
 @Slf4j
 public class CalmSendJobHandler {
 public class CalmSendJobHandler {
 
 
+    @Autowired
+    private ICalmTaskService iCalmTaskService;
+
     /**
     /**
      * XXL-Job任务执行入口方法
      * XXL-Job任务执行入口方法
      */
      */
     @XxlJob("calmSendJobHandler")
     @XxlJob("calmSendJobHandler")
     public void execute() throws Exception {
     public void execute() throws Exception {
-
+//        //主任务发送时间
+//        LocalDateTime taskSendTime = LocalDateTime.now();
+//        // 从XXL-Job参数中获取任务ID
+//        String param = XxlJobHelper.getJobParam();
+//        // 记录任务开始日志
+//        log.info("开始冷静期定时发送任务，参数: {}", param);
+//
+//        // 解析任务参数（参数为冷静期定时任务业务ID）
+//        String taskBizId = param;
+//        // 根据冷静期定时任务业务ID查询冷静期定时任务信息
+//        EmailTask emailTask = iCalmTaskService.queryOne(taskBizId);
+//        log.info("根据邮件任务业务ID查询邮件任务信息: {}: " + JSON.toJSONString(emailTask));
+//
+//        // 检查邮件任务是否存在
+//        if (Objects.isNull(emailTask)) {
+//            // 记录错误并返回
+//            XxlJobHelper.log("邮件任务不存在: " + taskBizId);
+//            XxlJobHelper.handleFail("邮件任务不存在");
+//            return;
+//        }
     }
     }
 
 
 }
 }
\ No newline at end of file

yd-csf-service/src/main/java/com/yd/csf/service/service/ICalmTaskService.java

@@ -13,4 +13,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
  */
 public interface ICalmTaskService extends IService<CalmTask> {
 public interface ICalmTaskService extends IService<CalmTask> {
 
 
+    CalmTask queryOne(String calmTaskBizId);
 }
 }

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/CalmTaskServiceImpl.java

@@ -17,4 +17,13 @@ import org.springframework.stereotype.Service;
 @Service
 @Service
 public class CalmTaskServiceImpl extends ServiceImpl<CalmTaskMapper, CalmTask> implements ICalmTaskService {
 public class CalmTaskServiceImpl extends ServiceImpl<CalmTaskMapper, CalmTask> implements ICalmTaskService {
 
 
+    /**
+     * 查询单个对象
+     * @param calmTaskBizId
+     * @return
+     */
+    @Override
+    public CalmTask queryOne(String calmTaskBizId) {
+        return null;
+    }
 }
 }