记得上下班打卡 | git大法好,push需谨慎

Commit f3340a62 authored by 张国柄's avatar 张国柄

~API:发放券Task`bind_at`赋值逻辑调整;

parent a5b480c3
...@@ -212,6 +212,11 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C ...@@ -212,6 +212,11 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
int totalCount = userMemberCount, eventAmt = mgtCoupon.getEventAmt(); int totalCount = userMemberCount, eventAmt = mgtCoupon.getEventAmt();
log.info("发放券处理中:目标全体会员[总数:{},发放量:{}]", userMemberCount, eventAmt); log.info("发放券处理中:目标全体会员[总数:{},发放量:{}]", userMemberCount, eventAmt);
String mcouponId = mgtCoupon.getMcouponId();
String couponId = coupon.getCouponId();
LocalDateTime couponEffectAt = coupon.getEffectAt();
LocalDateTime couponExpireAt = coupon.getExpireAt();
// 会员权益券失效时间duedAt需要同步会员到期时间expiryAt // 会员权益券失效时间duedAt需要同步会员到期时间expiryAt
Integer exclusively = mgtCoupon.getExclusively(); Integer exclusively = mgtCoupon.getExclusively();
boolean isMemberRightsCoupon = exclusively == 1; boolean isMemberRightsCoupon = exclusively == 1;
...@@ -231,18 +236,18 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C ...@@ -231,18 +236,18 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
CandyUserCoupon userCoupon = new CandyUserCoupon(); CandyUserCoupon userCoupon = new CandyUserCoupon();
userCoupon.setUcouponId(IDGenerator.get32UUID()); userCoupon.setUcouponId(IDGenerator.get32UUID());
userCoupon.setMcouponId(mgtCoupon.getMcouponId()); userCoupon.setMcouponId(mcouponId);
userCoupon.setUid(userMember.getUid()); userCoupon.setUid(userMember.getUid());
userCoupon.setCouponId(coupon.getCouponId()); userCoupon.setCouponId(couponId);
userCoupon.setExclusive(exclusively); userCoupon.setExclusive(exclusively);
userCoupon.setState(1); userCoupon.setState(1);
// userCoupon.setBindAt(coupon.getEffectAt()); // userCoupon.setBindAt(couponEffectAt);
// userCoupon.setDuedAt(coupon.getExpireAt()); // userCoupon.setDuedAt(couponExpireAt);
userCoupon.setBindAt(now); userCoupon.setBindAt(null == couponEffectAt ? now : couponEffectAt);
if (isMemberRightsCoupon) { if (isMemberRightsCoupon) {
userCoupon.setDuedAt(userMember.getExpiryAt()); userCoupon.setDuedAt(userMember.getExpiryAt());
} else { } else {
userCoupon.setDuedAt(coupon.getExpireAt()); userCoupon.setDuedAt(couponExpireAt);
} }
userCoupon.setCreatedAt(now); userCoupon.setCreatedAt(now);
...@@ -296,6 +301,11 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C ...@@ -296,6 +301,11 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
AbstractRedisUtil redisAdamUtil = redisDataSourceUtil.getRedisAdamUtil(); AbstractRedisUtil redisAdamUtil = redisDataSourceUtil.getRedisAdamUtil();
String mcouponId = mgtCoupon.getMcouponId();
String couponId = coupon.getCouponId();
LocalDateTime couponEffectAt = coupon.getEffectAt();
LocalDateTime couponExpireAt = coupon.getExpireAt();
// 指定手机号发放券中,会员权益券失效时间duedAt需要同步会员到期时间expiryAt // 指定手机号发放券中,会员权益券失效时间duedAt需要同步会员到期时间expiryAt
Integer exclusively = mgtCoupon.getExclusively(); Integer exclusively = mgtCoupon.getExclusively();
boolean isMemberRightsCoupon = exclusively == 1; boolean isMemberRightsCoupon = exclusively == 1;
...@@ -306,19 +316,19 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C ...@@ -306,19 +316,19 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
if (StringUtils.isNotEmpty(uid)) { if (StringUtils.isNotEmpty(uid)) {
CandyUserCoupon userCoupon = new CandyUserCoupon(); CandyUserCoupon userCoupon = new CandyUserCoupon();
userCoupon.setUcouponId(IDGenerator.get32UUID()); userCoupon.setUcouponId(IDGenerator.get32UUID());
userCoupon.setMcouponId(mgtCoupon.getMcouponId()); userCoupon.setMcouponId(mcouponId);
userCoupon.setUid(uid); userCoupon.setUid(uid);
userCoupon.setCouponId(coupon.getCouponId()); userCoupon.setCouponId(couponId);
userCoupon.setExclusive(exclusively); userCoupon.setExclusive(exclusively);
userCoupon.setState(1); userCoupon.setState(1);
// userCoupon.setBindAt(coupon.getEffectAt()); // userCoupon.setBindAt(coupon.getEffectAt());
userCoupon.setBindAt(now); userCoupon.setBindAt(null == couponEffectAt ? now : couponEffectAt);
if (isMemberRightsCoupon) { if (isMemberRightsCoupon) {
AdamUserMemberVo vo = (AdamUserMemberVo) redisAdamUtil.get(AdamRedisConst.INFO_USER_MEMBER.concat(uid)); AdamUserMemberVo vo = (AdamUserMemberVo) redisAdamUtil.get(AdamRedisConst.INFO_USER_MEMBER.concat(uid));
userCoupon.setDuedAt(null != vo && vo.isActive() ? vo.getExpiryAt() : coupon.getExpireAt()); userCoupon.setDuedAt(null != vo && vo.isActive() ? vo.getExpiryAt() : couponExpireAt);
} else { } else {
userCoupon.setDuedAt(coupon.getExpireAt()); userCoupon.setDuedAt(couponExpireAt);
} }
userCoupon.setCreatedAt(now); userCoupon.setCreatedAt(now);
...@@ -345,7 +355,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C ...@@ -345,7 +355,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
redisCandyUtil.set(uckey, vos); redisCandyUtil.set(uckey, vos);
}); });
} else { } else {
throw new LiquidnetServiceException("-1", String.format("券发放失败[mcouponId=%s]", mgtCoupon.getMcouponId())); throw new LiquidnetServiceException("-1", String.format("券发放失败[mcouponId=%s]", mcouponId));
} }
} }
log.info("发放券处理中:目标指定手机号[总数:{},发放量:{},实际处理:{}]", limitSize, eventAmt, pl); log.info("发放券处理中:目标指定手机号[总数:{},发放量:{},实际处理:{}]", limitSize, eventAmt, pl);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment