Parcourir la source

bugfix:定时任务修改

lyx il y a 3 mois
Parent
commit
24fcd5f19f
1 fichiers modifiés avec 48 ajouts et 40 suppressions
  1. 48 40
      alien-job/src/main/java/shop/alien/job/store/LifeCouponJob.java

+ 48 - 40
alien-job/src/main/java/shop/alien/job/store/LifeCouponJob.java

@@ -218,16 +218,18 @@ public class LifeCouponJob {
                 }
             }
         }
-        // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
-        LambdaUpdateWrapper<LifeCoupon> updateWrapper = new LambdaUpdateWrapper<>();
-        // 设置更新条件,根据优惠券的 ID 进行更新
-        updateWrapper.in(LifeCoupon::getId,endCouponIds)
-                // 设置要更新的字段,将优惠券的状态更新为 3
-                .set(LifeCoupon::getStatus, CouponStatusEnum.ENDED.getCode());
-        // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
-        int updateNum = lifeCouponMapper.update(null, updateWrapper);
-        System.out.println("执行修改代金券状态 ===> 已结束 优惠券列表 ===> " + endCouponIds);
-        System.out.println("执行修改代金券状态 ===> 已结束 优惠券数量 ===> " + updateNum);
+        if(!endCouponIds.isEmpty()){
+            // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
+            LambdaUpdateWrapper<LifeCoupon> updateWrapper = new LambdaUpdateWrapper<>();
+            // 设置更新条件,根据优惠券的 ID 进行更新
+            updateWrapper.in(LifeCoupon::getId,endCouponIds)
+                    // 设置要更新的字段,将优惠券的状态更新为 3
+                    .set(LifeCoupon::getStatus, CouponStatusEnum.ENDED.getCode());
+            // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
+            int updateNum = lifeCouponMapper.update(null, updateWrapper);
+            System.out.println("执行修改代金券状态 ===> 已结束 优惠券列表 ===> " + endCouponIds);
+            System.out.println("执行修改代金券状态 ===> 已结束 优惠券数量 ===> " + updateNum);
+        }
 // --------------------------------------------------------------------------------------------------------
         // 创建另一个 LambdaUpdateWrapper 用于查询状态为 0 的生活优惠券
         LambdaUpdateWrapper<LifeCoupon> selectWrapper2 = new LambdaUpdateWrapper<>();
@@ -250,16 +252,18 @@ public class LifeCouponJob {
                 }
             }
         }
-        // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
-        LambdaUpdateWrapper<LifeCoupon> updateWrapper2 = new LambdaUpdateWrapper<>();
-        // 设置更新条件,根据优惠券的 ID 进行更新
-        updateWrapper.eq(LifeCoupon::getId, startCouponIds)
-                // 设置要更新的字段,将优惠券的状态更新为 1
-                .set(LifeCoupon::getStatus, CouponStatusEnum.ONGOING.getCode());
-        // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
-        int updateNum2 = lifeCouponMapper.update(null, updateWrapper2);
-        System.out.println("执行修改代金券状态 ===> 进行中 优惠券列表 ===> " + startCouponIds);
-        System.out.println("执行修改代金券状态 ===> 进行中 优惠券数量 ===> " + updateNum2);
+        if(!startCouponIds.isEmpty()){
+            // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
+            LambdaUpdateWrapper<LifeCoupon> updateWrapper2 = new LambdaUpdateWrapper<>();
+            // 设置更新条件,根据优惠券的 ID 进行更新
+            updateWrapper2.in(LifeCoupon::getId, startCouponIds)
+                    // 设置要更新的字段,将优惠券的状态更新为 1
+                    .set(LifeCoupon::getStatus, CouponStatusEnum.ONGOING.getCode());
+            // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
+            int updateNum2 = lifeCouponMapper.update(null, updateWrapper2);
+            System.out.println("执行修改代金券状态 ===> 进行中 优惠券列表 ===> " + startCouponIds);
+            System.out.println("执行修改代金券状态 ===> 进行中 优惠券数量 ===> " + updateNum2);
+        }
     }
 
     /**
@@ -314,16 +318,18 @@ public class LifeCouponJob {
                 }
             }
         }
-        // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
-        LambdaUpdateWrapper<LifeGroupBuyMain> updateWrapper = new LambdaUpdateWrapper<>();
-        // 设置更新条件,根据优惠券的 ID 进行更新
-        updateWrapper.in(LifeGroupBuyMain::getId,endCouponIds)
-                // 设置要更新的字段,将优惠券的状态更新为 7
-                .set(LifeGroupBuyMain::getStatus, CouponStatusEnum.ENDED.getCode());
-        // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
-        int updateNum = lifeGroupBuyMainMapper.update(null, updateWrapper);
-        System.out.println("执行修改团购状态 ===> 已结束 优惠券列表 ===> " + endCouponIds);
-        System.out.println("执行修改团购状态 ===> 已结束 优惠券数量 ===> " + updateNum);
+        if(!endCouponIds.isEmpty()) {
+            // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
+            LambdaUpdateWrapper<LifeGroupBuyMain> updateWrapper = new LambdaUpdateWrapper<>();
+            // 设置更新条件,根据优惠券的 ID 进行更新
+            updateWrapper.in(LifeGroupBuyMain::getId, endCouponIds)
+                    // 设置要更新的字段,将优惠券的状态更新为 7
+                    .set(LifeGroupBuyMain::getStatus, CouponStatusEnum.ENDED.getCode());
+            // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
+            int updateNum = lifeGroupBuyMainMapper.update(null, updateWrapper);
+            System.out.println("执行修改团购状态 ===> 已结束 优惠券列表 ===> " + endCouponIds);
+            System.out.println("执行修改团购状态 ===> 已结束 优惠券数量 ===> " + updateNum);
+        }
 // --------------------------------------------------------------------------------------------------------
         // 创建另一个 LambdaUpdateWrapper 用于查询状态为 0 的生活优惠券
         LambdaUpdateWrapper<LifeGroupBuyMain> selectWrapper2 = new LambdaUpdateWrapper<>();
@@ -346,15 +352,17 @@ public class LifeCouponJob {
                 }
             }
         }
-        // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
-        LambdaUpdateWrapper<LifeGroupBuyMain> updateWrapper2 = new LambdaUpdateWrapper<>();
-        // 设置更新条件,根据优惠券的 ID 进行更新
-        updateWrapper.eq(LifeGroupBuyMain::getId, startCouponIds)
-                // 设置要更新的字段,将优惠券的状态更新为 1
-                .set(LifeGroupBuyMain::getStatus, CouponStatusEnum.ONGOING.getCode());
-        // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
-        int updateNum2 = lifeGroupBuyMainMapper.update(null, updateWrapper2);
-        System.out.println("执行修改团购状态 ===> 进行中 优惠券列表 ===> " + startCouponIds);
-        System.out.println("执行修改团购状态 ===> 进行中 优惠券数量 ===> " + updateNum2);
+        if (!startCouponIds.isEmpty()) {
+            // 创建一个 LambdaUpdateWrapper 用于更新生活优惠券的状态
+            LambdaUpdateWrapper<LifeGroupBuyMain> updateWrapper2 = new LambdaUpdateWrapper<>();
+            // 设置更新条件,根据优惠券的 ID 进行更新
+            updateWrapper2.in(LifeGroupBuyMain::getId, startCouponIds)
+                    // 设置要更新的字段,将优惠券的状态更新为 1
+                    .set(LifeGroupBuyMain::getStatus, CouponStatusEnum.ONGOING.getCode());
+            // 调用 lifeCouponMapper 的 update 方法,根据上述条件更新优惠券的状态
+            int updateNum2 = lifeGroupBuyMainMapper.update(null, updateWrapper2);
+            System.out.println("执行修改团购状态 ===> 进行中 优惠券列表 ===> " + startCouponIds);
+            System.out.println("执行修改团购状态 ===> 进行中 优惠券数量 ===> " + updateNum2);
+        }
     }
 }