满减活动定时任务

cash-api/market-server/src/main/java/com/czg/task/AAMarketTasks.java

@@ -0,0 +1,46 @@
+package com.czg.task;
+
+import jakarta.annotation.Resource;
+import org.springframework.scheduling.annotation.Scheduled;
+
+/**
+ * market服务 任务总调度
+ * @author ww
+ * @description
+ */
+public class AAMarketTasks {
+    //生日有礼奖励发放
+    @Resource
+    private BirthdayGiftTask birthdayGiftTask;
+    @Scheduled(cron = "0 0 12 * * ?")
+    public void birthdayGiftTask() {
+        birthdayGiftTask.deliver();
+    }
+
+
+    //优惠券 过期
+    @Resource
+    private CouponTask couponTask;
+    @Scheduled(cron = "0 30 * * * ? ")
+    public void couponTask() {
+        couponTask.task();
+    }
+
+    //会员奖励发放
+    @Resource
+    private MemberTask memberTask;
+    @Scheduled(cron = "0 0 1 * * ? ")
+    public void memberTask() {
+        memberTask.task();
+    }
+
+    //满减活动定时任务
+    @Resource
+    private DiscountActivityTask discountActivityTask;
+    @Scheduled(cron = "1 0 0 * * ? ")
+    public void discountActivityTask() {
+        discountActivityTask.task();
+    }
+
+
+}

cash-api/market-server/src/main/java/com/czg/task/BirthdayGiftTask.java

@@ -31,7 +31,7 @@ public class BirthdayGiftTask {
     /**
      * 生日有礼奖励发放
      */
-    @Scheduled(cron = "0 0 12 * * ?")
+//    @Scheduled(cron = "0 0 12 * * ?")
     public void deliver() {
         birthdayGiftService.deliver();
     }

cash-api/market-server/src/main/java/com/czg/task/CouponTask.java

@@ -31,8 +31,8 @@ public class CouponTask {
     /**
      * 优惠券 过期
      */
-    @Scheduled(cron = "0 30 * * * ? ")
-    public void deliver() {
+//    @Scheduled(cron = "0 30 * * * ? ")
+    public void task() {
         try {
             LocalDateTime now = LocalDateTime.now();
             mkShopCouponRecordService.update(new MkShopCouponRecord().setStatus(2), new QueryWrapper()

cash-api/market-server/src/main/java/com/czg/task/DiscountActivityTask.java

@@ -0,0 +1,38 @@
+package com.czg.task;
+
+import com.czg.market.entity.MkDiscountActivity;
+import com.czg.market.service.MkDiscountActivityService;
+import com.mybatisflex.core.query.QueryWrapper;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+
+/**
+ * 满减活动定时任务
+ *
+ * @author ww
+ * @description
+ */
+@Slf4j
+@Component
+public class DiscountActivityTask {
+    @Resource
+    private MkDiscountActivityService discountActivityService;
+
+    /**
+     * 满减活动 过期
+     */
+    public void task() {
+        discountActivityService.update(new MkDiscountActivity().setStatus(2),
+                new QueryWrapper()
+                        .eq(MkDiscountActivity::getStatus, 1)
+                        .le(MkDiscountActivity::getValidStartTime, LocalDateTime.now())
+                        .gt(MkDiscountActivity::getValidEndTime, LocalDateTime.now())
+        );
+        discountActivityService.update(new MkDiscountActivity().setStatus(3),
+                new QueryWrapper().le(MkDiscountActivity::getValidEndTime, LocalDateTime.now())
+        );
+    }
+}

cash-api/market-server/src/main/java/com/czg/task/MemberTask.java

@@ -37,8 +37,8 @@ public class MemberTask {
     /**
      * 奖励发放
      */
-    @Scheduled(cron = "0 0 1 * * ? ")
-    public void deliver() {
+//    @Scheduled(cron = "0 0 1 * * ? ")
+    public void task() {
         shopUserService.list(new QueryWrapper().eq(ShopUser::getIsVip, 1).lt(ShopUser::getNextDeliverTime, DateUtil.date().toLocalDateTime())).forEach(item -> {
             memberConfigService.deliver(item.getSourceShopId(), item.getUserId(), TableValueConstant.MemberExpFlow.Type.MEMBER_TASK, null, null, null);
         });