caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优惠券动态时间判定。

Browse Source
This commit is contained in:
lifenlong 2021-06-19 17:43:04 +08:00
parent 4e87ad22c1
commit d7b0ff4cd1
1 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
framework/src/main/java/cn/lili/modules/promotion/serviceimpl/CouponServiceImpl.java
View File

@ -89,14 +89,18 @@ public class CouponServiceImpl extends ServiceImpl<CouponMapper, Coupon> impleme
this.updateScopePromotionGoods(coupon); this.updateScopePromotionGoods(coupon);
// 保存到MONGO中 // 保存到MONGO中
this.mongoTemplate.save(coupon); this.mongoTemplate.save(coupon);
PromotionMessage promotionMessage = new PromotionMessage(coupon.getId(), PromotionTypeEnum.COUPON.name(), PromotionStatusEnum.START.name(), coupon.getStartTime(), coupon.getEndTime()); //如果优惠券是固定时间则添加延时任务
TimeTriggerMsg timeTriggerMsg = new TimeTriggerMsg(TimeExecuteConstant.PROMOTION_EXECUTOR, if (coupon.getRangeDayType().equals(CouponRangeDayEnum.FIXEDTIME.name())) {
coupon.getStartTime().getTime(), PromotionMessage promotionMessage = new PromotionMessage(coupon.getId(), PromotionTypeEnum.COUPON.name(), PromotionStatusEnum.START.name(), coupon.getStartTime(), coupon.getEndTime());
promotionMessage, TimeTriggerMsg timeTriggerMsg = new TimeTriggerMsg(TimeExecuteConstant.PROMOTION_EXECUTOR,
DelayQueueTools.wrapperUniqueKey(DelayTypeEnums.PROMOTION, (promotionMessage.getPromotionType() + promotionMessage.getPromotionId())), coupon.getStartTime().getTime(),
rocketmqCustomProperties.getPromotionTopic()); promotionMessage,
// 发送促销活动开始的延时任务 DelayQueueTools.wrapperUniqueKey(DelayTypeEnums.PROMOTION, (promotionMessage.getPromotionType() + promotionMessage.getPromotionId())),
this.timeTrigger.addDelay(timeTriggerMsg); rocketmqCustomProperties.getPromotionTopic());
// 发送促销活动开始的延时任务
this.timeTrigger.addDelay(timeTriggerMsg);
}
return coupon; return coupon;
} }
@ -278,12 +282,14 @@ public class CouponServiceImpl extends ServiceImpl<CouponMapper, Coupon> impleme
throw new ServiceException("优惠券折扣必须小于10且大于0"); throw new ServiceException("优惠券折扣必须小于10且大于0");
} }
long nowTime = DateUtil.getDateline() * 1000; if (coupon.getRangeDayType().equals(CouponRangeDayEnum.FIXEDTIME.name())) {
if (coupon.getStartTime().getTime() < nowTime && coupon.getEndTime().getTime() > nowTime) { long nowTime = DateUtil.getDateline() * 1000;
throw new ServiceException("活动时间小于当前时间，不能进行编辑删除操作"); if (coupon.getStartTime().getTime() < nowTime && coupon.getEndTime().getTime() > nowTime) {
} throw new ServiceException("活动时间小于当前时间，不能进行编辑删除操作");
}
PromotionTools.checkPromotionTime(coupon.getStartTime().getTime(), coupon.getEndTime().getTime()); PromotionTools.checkPromotionTime(coupon.getStartTime().getTime(), coupon.getEndTime().getTime());
}
this.checkCouponScope(coupon); this.checkCouponScope(coupon);
//对状态的处理.如果未传递状态则需要 根据当前时间来确认优惠券状态 //对状态的处理.如果未传递状态则需要 根据当前时间来确认优惠券状态
@ -326,7 +332,7 @@ public class CouponServiceImpl extends ServiceImpl<CouponMapper, Coupon> impleme
* @param coupon 优惠券参数 * @param coupon 优惠券参数
*/ */
private void promotionStatusEmpty(CouponVO coupon) { private void promotionStatusEmpty(CouponVO coupon) {
if (StringUtils.isEmpty(coupon.getPromotionStatus())) { if (StringUtils.isEmpty(coupon.getPromotionStatus()) && coupon.getRangeDayType().equals(CouponRangeDayEnum.FIXEDTIME.name())) {
//格式时间 //格式时间
long startTme = coupon.getStartTime().getTime() / 1000; long startTme = coupon.getStartTime().getTime() / 1000;
long endTime = coupon.getEndTime().getTime() / 1000; long endTime = coupon.getEndTime().getTime() / 1000;