发放券+优先购;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/candy/task/CandyMgtCouponTaskController.java

@@ -61,6 +61,9 @@ public class CandyMgtCouponTaskController {
                         case 4:// 折扣券
                             platformCandyCouponService.issueDiscountCouponHandler(mgtCoupon, coupon);
                             break;
+                        case 101:// 优先券
+                            platformCandyCouponService.issuePriorityCouponHandler(mgtCoupon, coupon);
+                            break;
                         default:
                             log.warn("发放券任务总数:{},任务{}无法处理，无效的券类型[mcouponId:{},couType:{}]", taskSize, i, mgtCoupon.getMcouponId(), coupon.getCouType());
                             break;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/candy/PlatformCandyCouponService.java

@@ -175,6 +175,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
     private void processForAllMember(CandyMgtCoupon mgtCoupon, CandyCoupon coupon, List<CandyCouponRuleDto> couponRuleDtoList) {
         List<CandyUserCoupon> initUserCouponList = new ArrayList<>();
         LocalDateTime now = LocalDateTime.now();
+        LocalDateTime duedAt = now.plusDays(coupon.getValidity()).withHour(23).withMinute(59).withSecond(59);
 
         LocalDateTime nowEndTime = now.withHour(23).withMinute(59).withSecond(59);
         LambdaQueryWrapper<AdamUserMember> queryWrapper = Wrappers.lambdaQuery(AdamUserMember.class).eq(AdamUserMember::getState, 1)
@@ -204,7 +205,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
                     userCoupon.setCouponId(coupon.getCouponId());
                     userCoupon.setState(1);
                     userCoupon.setBindAt(now);
-                    userCoupon.setDuedAt(coupon.getExpireAt());
+                    userCoupon.setDuedAt(duedAt);
                     userCoupon.setCreatedAt(now);
 
                     initUserCouponList.add(userCoupon);
@@ -248,6 +249,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
     private void processForUserCoupon(CandyMgtCoupon mgtCoupon, CandyCoupon coupon, List<CandyCouponRuleDto> couponRuleDtoList) {
         List<CandyUserCoupon> initUserCouponList = new ArrayList<>();
         LocalDateTime now = LocalDateTime.now();
+        LocalDateTime duedAt = now.plusDays(coupon.getValidity()).withHour(23).withMinute(59).withSecond(59);
 
         String eventLimit = mgtCoupon.getEventLimit();
         String[] eventLimitArr = eventLimit.split(",");
@@ -266,7 +268,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
                     userCoupon.setCouponId(coupon.getCouponId());
                     userCoupon.setState(1);
                     userCoupon.setBindAt(now);
-                    userCoupon.setDuedAt(coupon.getExpireAt());
+                    userCoupon.setDuedAt(duedAt);
                     userCoupon.setCreatedAt(now);
 
                     initUserCouponList.add(userCoupon);
@@ -344,4 +346,16 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
     public void issueDiscountCouponHandler(final CandyMgtCoupon mgtCoupon, final CandyCoupon coupon) {
         this.issueCouponProcessing(mgtCoupon, coupon);
     }
+
+    /**
+     * <p>
+     * 发放优先券
+     * </p>
+     *
+     * @param mgtCoupon CandyMgtCoupon
+     * @param coupon    CandyCoupon
+     */
+    public void issuePriorityCouponHandler(final CandyMgtCoupon mgtCoupon, final CandyCoupon coupon) {
+        this.issueCouponProcessing(mgtCoupon, coupon);
+    }
 }