fix(promotion-service): 发送服务通知

src/main/java/com/wangxiaolu/promotion/xxljobtask/ActivityStautsHandler.java

@@ -3,7 +3,6 @@ package com.wangxiaolu.promotion.xxljobtask;
 
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.wangxiaolu.promotion.common.enums.FlagType;
 import com.wangxiaolu.promotion.domain.activity.mapper.entity.TemporaryActivityTaskClockDO;
@@ -66,7 +65,17 @@ public class ActivityStautsHandler {
     @XxlJob("sendSubscribeMessage")
     public void sendSubscribeMessage() {
         DateTime undoDateTime = DateUtil.offsetMinute(new Date(), -15);
-        // 查询没有做随机任务的， 超过15分钟的，但是状态还是1进行中的  状态改成未完成，表示未拍照做任务
+        /**
+         * 处理未开始的随机任务状态更新
+         * <p>
+         * 查询所有符合以下条件的临时活动任务：
+         * 1. 任务状态为【待开始】
+         * 2. 任务类型为【随机任务】
+         * 3. 未被标记为删除
+         * 4. 要求锁定时间小于等于指定截止时间（undoDateTime）
+         * <p>
+         * 将符合条件的任务状态更新为【未完成】，并重置订阅发送标志为【未发送】
+         */
         List<TemporaryActivityTaskClockDO> unstartList = taskClockService.list(new LambdaQueryWrapper<TemporaryActivityTaskClockDO>()
                 .eq(TemporaryActivityTaskClockDO::getTaskStatus, ActivityClockTaskStatus.TO_BE_START.getType())
                 .eq(TemporaryActivityTaskClockDO::getTaskType, ActivityPhotoType.RANDOM_TASK.getType())
@@ -102,7 +111,7 @@ public class ActivityStautsHandler {
                 .eq(TemporaryActivityTaskClockDO::getIsDelete, FlagType.NO.getType())
                 .between(TemporaryActivityTaskClockDO::getRequiredlockTime,  undoDateTime  ,new Date())
         );
-
+        // 进行中的 还没发通知的
         List<TemporaryActivityTaskClockDO> startingList = taskClockService.list(new LambdaQueryWrapper<TemporaryActivityTaskClockDO>()
                 .eq(TemporaryActivityTaskClockDO::getTaskStatus, ActivityClockTaskStatus.STARTING.getType())
                 .eq(TemporaryActivityTaskClockDO::getIsSendSubscribe, FlagType.NO.getType())
@@ -141,7 +150,7 @@ public class ActivityStautsHandler {
      * @param taskClockDO
      */
     private void sendWxMessage(TemporaryActivityTaskClockDO taskClockDO) {
-        if(ObjectUtil.isNotEmpty(taskClockDO.getSubscribeTime())){
+//        if(ObjectUtil.isEmpty(taskClockDO.getSubscribeTime())){
             // 2. 构建模板数据（根据小程序订阅模板的字段定义）
             Map<String, String> data = new HashMap<>();
             // 模板中的字段1发布人
@@ -174,7 +183,7 @@ public class ActivityStautsHandler {
                 taskClockDO.setSubscribeTime(new Date());
                 taskClockDO.setSubscribeStatus(FlagType.YES.getType());
             }
-        }
+//        }
     }