From f3c83214e7b0eadacf925351d1a9625c44a59bd2 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期三, 30 十月 2019 10:31:09 +0800
Subject: [PATCH] 券激活
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 151 ++++++++++++++++++++++++++++---------------------
1 files changed, 86 insertions(+), 65 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
index 15ab9f9..20afbe3 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
@@ -39,6 +39,7 @@
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.bus.user.UserSystemCoupon;
+import com.yeshi.fanli.entity.bus.user.UserSystemCouponActivate;
import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord;
import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
import com.yeshi.fanli.entity.common.JumpDetailV2;
@@ -47,7 +48,6 @@
import com.yeshi.fanli.entity.system.SystemCoupon;
import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
-import com.yeshi.fanli.exception.money.UserMoneyDetailException;
import com.yeshi.fanli.exception.user.UserInfoExtraException;
import com.yeshi.fanli.exception.user.UserSystemCouponException;
import com.yeshi.fanli.log.LogHelper;
@@ -79,6 +79,7 @@
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TokenUtil;
import com.yeshi.fanli.util.VersionUtil;
+import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;
import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
import com.yeshi.fanli.util.factory.msg.MsgOtherSystemGiveDTOFactory;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
@@ -2443,77 +2444,97 @@
}
-
+ @RequestSerializableByKeyService(key = "#uid")
@Override
- @Transactional
- public void activateFreeCoupon(Long uid) {
- List<UserSystemCoupon> list = userSystemCouponMapper.getNeedActivateFreeCouponByType(uid, CouponTypeEnum.freeCoupon.name());
- if (list == null || list.size() == 0)
+ @Transactional(rollbackFor = Exception.class)
+ public void triggerFreeCouponActivate(Long uid) {
+ UserSystemCoupon coupon = userSystemCouponMapper.getNeedActivateCouponByType(uid, CouponTypeEnum.freeCoupon.name());
+ if (coupon == null)
return;
-
- UserSystemCoupon coupon = list.get(0);
- Date nowDate = new Date();
- Date endTime2 = coupon.getEndTime();
- if (endTime2 != null && endTime2.getTime() <= nowDate.getTime())
- return; // 宸插け鏁�
- SystemCoupon systemCoupon = coupon.getSystemCoupon();
- if (systemCoupon == null)
- return; // 鍒稿凡涓嶅瓨鍦�
-
- systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
- if (systemCoupon == null || systemCoupon.getType() != CouponTypeEnum.freeCoupon)
- return; // 鍒哥被鍨嬩笉鍖归厤
-
+ Long id = coupon.getId();
+ UserSystemCouponActivate couponActivate = userSystemCouponActivateService.selectForUpdate(id);
- // 娣诲姞婵�娲绘暟閲�
- String activateNum = configService.get("free_coupon_activate_num");
- boolean activate = userSystemCouponActivateService.addActivateCount(coupon.getId(), Integer.parseInt(activateNum));
+ // 婵�娲绘暟閲�
+ boolean result = false;
+ int limitNum = Integer.parseInt(configService.get("free_coupon_activate_num"));
- // 婵�娲诲埜
- if (activate) {
+ Integer state = couponActivate.getState();
+ int count = couponActivate.getCount();
+ count++;
+ if(count >= limitNum) {
+ result = true;
+ state = UserSystemCouponActivate.STATE_END;
+ }
- try {
- Integer expiryDay = systemCoupon.getExpiryDay();
- String endDay = DateUtil.plusDay(expiryDay - 1, nowDate);
- SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- if (endDay != null && endDay.trim().length() > 0) {
- endDay += " 23:59:59";
- }
- Date endTime = format.parse(endDay);
-
- UserSystemCoupon userCoupon = new UserSystemCoupon();
- userCoupon.setId(coupon.getId());
- userCoupon.setStateActivated(1);
- userCoupon.setEndTime(endTime);
- userCoupon.setStartTime(nowDate);
- userCoupon.setUpdateTime(new Date());
- userSystemCouponMapper.updateByPrimaryKeySelective(userCoupon);
-
- // 璧犻�佽褰�
- UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByReceiveId(coupon.getId());
- if (giveRecord == null)
- return;
-
- Long giveUid = giveRecord.getGiveUid();
- UserInfo userInfo = userInfoService.selectByPKey(giveUid);
- if (userInfo == null)
- return;
-
- String beiZhu = "璇峰埌鎴戠殑-绂忓埄涓績涓煡鐪�";
- SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
- MsgOtherCouponActivateDTO msgOther = new MsgOtherCouponActivateDTO();
- msgOther.setTitle("鍏嶅崟鍒告縺娲�");
- msgOther.setType("鍏嶅崟鍒哥郴缁熷凡鑷姩婵�娲�");
- msgOther.setExplain("婊¤冻" + systemCoupon.getActivateDay() + "澶╁唴浜х敓" + activateNum + "绗斿凡鍒拌处杩斿埄璁㈠崟");
- msgOther.setGiveUser("鏄电О锛�" + userInfo.getNickName() + " ID锛�" + giveUid);
- msgOther.setReceiveTime(sd.format(giveRecord.getReceiveTime()));
- msgOther.setValidityTime(expiryDay + "澶�");
- userOtherMsgNotificationService.giveCouponActivateMsg(uid, beiZhu, msgOther);
- } catch (Exception e) {
- e.printStackTrace();
- LogHelper.errorDetailInfo(e);
+ UserSystemCouponActivate updateActivate = new UserSystemCouponActivate();
+ updateActivate.setId(id);
+ updateActivate.setState(state);
+ updateActivate.setCount(count);
+ updateActivate.setUpdateTime(new Date());
+ userSystemCouponActivateService.updateByPrimaryKeySelective(updateActivate);
+
+ // 婵�娲诲鍔卞埜
+ if (result) {
+ activateFreeCoupon(coupon, limitNum);
+ }
+ }
+
+ /**
+ * 婵�娲诲埜
+ * @param coupon
+ * @param activateNum
+ */
+ @Transactional
+ private void activateFreeCoupon(UserSystemCoupon coupon, int limitNum) {
+ try {
+ Date nowDate = new Date();
+ SystemCoupon systemCoupon = coupon.getSystemCoupon();
+
+ Integer expiryDay = systemCoupon.getExpiryDay();
+ String endDay = DateUtil.plusDay(expiryDay - 1, nowDate);
+ SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ if (endDay != null && endDay.trim().length() > 0) {
+ endDay += " 23:59:59";
}
+ Date endTime = format.parse(endDay);
+
+ UserSystemCoupon userCoupon = new UserSystemCoupon();
+ userCoupon.setId(coupon.getId());
+ userCoupon.setStateActivated(1);
+ userCoupon.setEndTime(endTime);
+ userCoupon.setStartTime(nowDate);
+ userCoupon.setUpdateTime(new Date());
+ userSystemCouponMapper.updateByPrimaryKeySelective(userCoupon);
+
+ // 娑堟伅
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByReceiveId(coupon.getId());
+ if (giveRecord == null)
+ return;
+
+ Long giveUid = giveRecord.getGiveUid();
+ UserInfo userInfo = userInfoService.selectByPKey(giveUid);
+ if (userInfo == null)
+ return;
+
+ String beiZhu = "璇峰埌鎴戠殑-绂忓埄涓績涓煡鐪�";
+ SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
+ MsgOtherCouponActivateDTO msgOther = new MsgOtherCouponActivateDTO();
+ msgOther.setTitle("鍏嶅崟鍒告縺娲�");
+ msgOther.setType("鍏嶅崟鍒哥郴缁熷凡鑷姩婵�娲�");
+ msgOther.setExplain("婊¤冻" + systemCoupon.getActivateDay() + "澶╁唴浜х敓" + limitNum + "绗斿凡鍒拌处杩斿埄璁㈠崟");
+ msgOther.setGiveUser("鏄电О锛�" + userInfo.getNickName() + " ID锛�" + giveUid);
+ msgOther.setReceiveTime(sd.format(giveRecord.getReceiveTime()));
+ msgOther.setValidityTime(expiryDay + "澶�");
+ userOtherMsgNotificationService.giveCouponActivateMsg(coupon.getUid(), beiZhu, msgOther);
+ }
+ });
+ } catch (Exception e) {
+ e.printStackTrace();
+ LogHelper.errorDetailInfo(e);
}
}
}
--
Gitblit v1.8.0