| | |
|---|
| | |
|
|---|
| | | import org.springframework.context.annotation.Lazy;
|
|---|
| | | import org.springframework.core.task.TaskExecutor;
|
|---|
| | | import org.springframework.jdbc.datasource.DataSourceTransactionManager;
|
|---|
| | | import org.springframework.scheduling.annotation.Async;
|
|---|
| | | import org.springframework.stereotype.Service;
|
|---|
| | | import org.springframework.transaction.annotation.Transactional;
|
|---|
| | | import org.springframework.transaction.support.DefaultTransactionDefinition;
|
|---|
| | | import org.yeshi.utils.DateUtil;
|
|---|
| | | import org.yeshi.utils.entity.DateInfo;
|
|---|
| | |
|
|---|
| | | import com.aliyun.openservices.ons.api.Message;
|
|---|
| | | import com.aliyun.openservices.ons.api.SendResult;
|
|---|
| | | import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
|
|---|
| | | import com.aliyun.openservices.ons.api.transaction.TransactionProducer;
|
|---|
| | | import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
|
|---|
| | | import com.google.gson.Gson;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.user.UserSystemCouponMapper;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.body.UserSystemCouponUseMQMsg;
|
|---|
| | | import com.yeshi.fanli.dto.msg.MsgOtherCouponActivateDTO;
|
|---|
| | | import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO;
|
|---|
| | | import com.yeshi.fanli.entity.accept.AcceptData;
|
|---|
| | |
|---|
| | | 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;
|
|---|
| | |
|---|
| | | import com.yeshi.fanli.service.inter.user.TokenRecordService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponActivateService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
|---|
| | |
|---|
| | | 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;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
|---|
| | | import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
|
|---|
| | | import com.yeshi.fanli.vo.order.CommonOrderVO;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TokenRecordService tokenRecordService;
|
|---|
| | |
|
|---|
| | | @Resource(name = "transactionManager")
|
|---|
| | | private DataSourceTransactionManager transactionManager;
|
|---|
| | |
|
|---|
| | | @Resource(name = "orderTransactionProducer")
|
|---|
| | | private TransactionProducer orderTransactionProducer;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserSystemCouponActivateService userSystemCouponActivateService;
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int insertSelective(UserSystemCoupon record) {
|
|---|
| | |
|---|
| | | if (systemCoupon == null)
|
|---|
| | | throw new UserSystemCouponException(1, "券已不存在");
|
|---|
| | | }
|
|---|
| | | |
|---|
| | |
|
|---|
| | | if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon)
|
|---|
| | | throw new UserSystemCouponException(1, "券类型不匹配");
|
|---|
| | |
|
|---|
| | |
|---|
| | | sourceType);
|
|---|
| | | if (orderVO == null)
|
|---|
| | | throw new UserSystemCouponException(1, "订单信息获取失败");
|
|---|
| | | |
|---|
| | |
|
|---|
| | | // 版本区分：2.0.2
|
|---|
| | | if (VersionUtil.greaterThan_2_0_2(acceptData.getPlatform(), acceptData.getVersion())) {
|
|---|
| | | Date thirdCreateTime = orderVO.getThirdCreateTime();
|
|---|
| | | if (thirdCreateTime != null) {
|
|---|
| | | long downOrderTime = thirdCreateTime.getTime();
|
|---|
| | | long limitDate = Long.parseLong("1573315200000"); // TODO 日期待确定2019-11-10
|
|---|
| | | long limitDate = Long.parseLong("1573315200000"); // TODO
|
|---|
| | | // 日期待确定2019-11-10
|
|---|
| | | if (downOrderTime > limitDate) {
|
|---|
| | | Date endDay = DateUtil.plusDayDate(4, thirdCreateTime);
|
|---|
| | | long currentTime = java.lang.System.currentTimeMillis();
|
|---|
| | |
|---|
| | | boolean valid = false;
|
|---|
| | | DateInfo dateInfo = DateUtil.dateDiff3(currentTime, endDay.getTime());
|
|---|
| | | if (dateInfo != null) {
|
|---|
| | | if (dateInfo.getDay() > 0) |
|---|
| | | if (dateInfo.getDay() > 0)
|
|---|
| | | valid = true;
|
|---|
| | |
|
|---|
| | | if (!valid && dateInfo.getHour() > 0)
|
|---|
| | | valid = true;
|
|---|
| | | |
|---|
| | |
|
|---|
| | | if (!valid && dateInfo.getMinute() > 0) |
|---|
| | | if (!valid && dateInfo.getMinute() > 0)
|
|---|
| | | valid = true;
|
|---|
| | | |
|---|
| | |
|
|---|
| | | if (!valid && dateInfo.getSecond() >= 0)
|
|---|
| | | valid = true;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | if (!valid) |
|---|
| | |
|
|---|
| | | if (!valid)
|
|---|
| | | throw new UserSystemCouponException(1, "该订单已不能使用使用奖励券，详情请咨询客服");
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|---|
| | | // 提成金额
|
|---|
| | | BigDecimal money = MoneyBigDecimalUtil.mul(hongBao, percent);
|
|---|
| | |
|
|---|
| | | UserSystemCouponUseMQMsg mqMsg = new UserSystemCouponUseMQMsg(userSystemCoupon.getId(), order.getOrderId(),
|
|---|
| | | sourceType, systemCoupon.getType().name());
|
|---|
| | | // 事务消息
|
|---|
| | | Message msg = new Message(MQTopicName.TOPIC_USER.name(), UserTopicTagEnum.useSystemCoupon.name(),
|
|---|
| | | new Gson().toJson(mqMsg).getBytes());
|
|---|
| | | try {
|
|---|
| | | SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
| | | @Override
|
|---|
| | | public TransactionStatus execute(Message arg0, Object arg1) {
|
|---|
| | | try {
|
|---|
| | | useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }, null);
|
|---|
| | | System.out.println(result);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | throw new Exception();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | | public void useRewardCouponCore(UserSystemCoupon userSystemCoupon, BigDecimal money, BigDecimal hongBao, Long uid,
|
|---|
| | | Order order) throws Exception {
|
|---|
| | | org.springframework.transaction.TransactionStatus transactionStatus = transactionManager
|
|---|
| | | .getTransaction(new DefaultTransactionDefinition());
|
|---|
| | | try {
|
|---|
| | | // 1、插入红包数据
|
|---|
| | | HongBaoV2 hongBaoV2 = new HongBaoV2();
|
|---|
| | | hongBaoV2.setMoney(money);
|
|---|
| | |
|---|
| | | orderHongBaoMapService.addOrderHongBaoMap(hongBaoV2, order);
|
|---|
| | |
|
|---|
| | | // 3.插入资金明细,用户余额
|
|---|
| | | UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(orderNo, sourceType, money,
|
|---|
| | | new UserInfo(uid));
|
|---|
| | | UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(order.getOrderId(),
|
|---|
| | | order.getOrderType(), money, new UserInfo(uid));
|
|---|
| | | userMoneyDetailService.addUserMoneyDetail(userMoneyDetail);
|
|---|
| | | userInfoService.addMoney(new UserInfo(uid), money);
|
|---|
| | |
|
|---|
| | | // 插入资金通知
|
|---|
| | | userMoneyMsgNotificationService.orderReward(uid, orderNo, sourceType, money,
|
|---|
| | | userInfoService.selectByPKey(uid).getMyHongBao());
|
|---|
| | |
|
|---|
| | | /* 用户券信息状态及记录处理 */
|
|---|
| | |
|
|---|
| | |
|---|
| | | userSystemCoupon.setUpdateTime(date);
|
|---|
| | | userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
|---|
| | |
|
|---|
| | | SystemCoupon coupon = systemCouponService.selectByPrimaryKey(userSystemCoupon.getSystemCoupon().getId());
|
|---|
| | |
|
|---|
| | | // 插入使用券记录
|
|---|
| | | UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
|
|---|
| | | couponRecord.setState(UserSystemCouponRecord.STATE_SUCCESS);
|
|---|
| | | couponRecord.setGoodSource(sourceType);
|
|---|
| | | couponRecord.setOrderNo(orderNo);
|
|---|
| | | couponRecord.setGoodSource(order.getOrderType());
|
|---|
| | | couponRecord.setOrderNo(order.getOrderId());
|
|---|
| | | couponRecord.setUserSystemCoupon(userSystemCoupon);
|
|---|
| | | couponRecord.setCouponType(systemCoupon.getType().name());
|
|---|
| | | couponRecord.setCouponType(coupon.getType().name());
|
|---|
| | | couponRecord.setCreateTime(date);
|
|---|
| | | couponRecord.setUpdateTime(date);
|
|---|
| | | userSystemCouponRecordService.insertSelective(couponRecord);
|
|---|
| | |
|
|---|
| | | // 插入资金通知
|
|---|
| | | userMoneyMsgNotificationService.orderReward(uid, order.getOrderId(), order.getOrderType(), money,
|
|---|
| | | userInfoService.selectByPKey(uid).getMyHongBao());
|
|---|
| | | // 消息推送
|
|---|
| | | try {
|
|---|
| | | userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, orderNo);
|
|---|
| | | userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, order.getOrderId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | }
|
|---|
| | | transactionManager.commit(transactionStatus);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | transactionManager.rollback(transactionStatus);
|
|---|
| | | throw new Exception();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | @Transactional(rollbackFor=Exception.class)
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void systemGiveRewardCoupon(Long uid, int num, String orderId, Integer orderType, String reason)
|
|---|
| | | throws Exception {
|
|---|
| | | // 添加奖励券
|
|---|
| | | insertUserCoupon(uid, CouponTypeEnum.rebatePercentCoupon.name(), "系统赠送",
|
|---|
| | | new BigDecimal(configService.get("exchange_rebate_percent")),false);
|
|---|
| | | new BigDecimal(configService.get("exchange_rebate_percent")), false);
|
|---|
| | | // 添加奖励券消息
|
|---|
| | | userOtherMsgNotificationService.systemGiveRewardCoupon(uid, null, MsgOtherSystemGiveDTOFactory
|
|---|
| | | .createRewardCouponGive(num, "请按照返利奖励券规则使用", "返利奖励券", orderId, orderType, reason));
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | | @Override
|
|---|
| | | public List<UserSystemCouponVO> getCouponList(long start, int count, Long uid)
|
|---|
| | | public List<UserSystemCouponVO> getCouponList(AcceptData acceptData, long start, int count, Long uid)
|
|---|
| | | throws UserSystemCouponException, Exception {
|
|---|
| | |
|
|---|
| | | // 过期券
|
|---|
| | |
|---|
| | | listTip.add("满足条件后，系统将自动激活，并在消息-其它消息中提醒。");
|
|---|
| | | userCouponVO.setTips(listTip);
|
|---|
| | | userCouponVO.setPopup(true);
|
|---|
| | |
|
|---|
| | | // 验证是否已累计3单
|
|---|
| | | executor.execute(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | freeCouponActivate(userCouponVO.getId(), uid, userCouponVO.getCreateTime());
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | |
|
|---|
| | | // 统计待激活数量
|
|---|
| | | if (VersionUtil.greaterThan_2_0_2(acceptData.getPlatform(), acceptData.getVersion())) {
|
|---|
| | | int activateCount = userSystemCouponActivateService.getActivateCount(userCouponVO.getId());
|
|---|
| | | String activateNum = configService.get("free_coupon_activate_num");
|
|---|
| | | userCouponVO.setCouponEffect(
|
|---|
| | | "(" + activateCount + "/" + Integer.parseInt(activateNum) + ")待激活");
|
|---|
| | | }
|
|---|
| | | } else if (CouponTypeEnum.welfareFreeCoupon == type) {
|
|---|
| | | jumpBtn = new HashMap<String, Object>();
|
|---|
| | | if (inviteCode != null && inviteCode.trim().length() > 0) {
|
|---|
| | |
|---|
| | | userCouponVO.setRemainDays(remainDays);
|
|---|
| | |
|
|---|
| | | return userCouponVO;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 免单券激活
|
|---|
| | | * |
|---|
| | | * @param uid
|
|---|
| | | */
|
|---|
| | | public void freeCouponActivate(Long id, Long uid, Date date) {
|
|---|
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|---|
| | | long count = commonOrderCountService.countValidOrderByDate(uid, sdf.format(date));
|
|---|
| | |
|
|---|
| | | String activateNum = configService.get("free_coupon_activate_num");
|
|---|
| | | int num = Integer.parseInt(activateNum);
|
|---|
| | |
|
|---|
| | | if (count >= num) {
|
|---|
| | | UserSystemCoupon coupon = userSystemCouponMapper.selectByPrimaryKey(id);
|
|---|
| | | if (coupon == null || coupon.getState() != UserSystemCoupon.STATE_CAN_USE
|
|---|
| | | || coupon.getStateActivated() != 0)
|
|---|
| | | return;
|
|---|
| | |
|
|---|
| | | 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;
|
|---|
| | |
|
|---|
| | | 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(id);
|
|---|
| | | 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() + "天内产生" + num + "笔已到账返利订单");
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | |
|---|
| | | return userSystemCouponMapper.getFreeCouponByType(uid, type);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestSerializableByKeyService(key = "#uid")
|
|---|
| | | @Override
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void triggerFreeCouponActivate(Long uid) {
|
|---|
| | | UserSystemCoupon coupon = userSystemCouponMapper.getNeedActivateCouponByType(uid,
|
|---|
| | | CouponTypeEnum.freeCoupon.name());
|
|---|
| | | if (coupon == null)
|
|---|
| | | return;
|
|---|
| | |
|
|---|
| | | Long id = coupon.getId();
|
|---|
| | | UserSystemCouponActivate couponActivate = userSystemCouponActivateService.selectForUpdate(id);
|
|---|
| | |
|
|---|
| | | // 激活数量
|
|---|
| | | boolean result = false;
|
|---|
| | | int limitNum = Integer.parseInt(configService.get("free_coupon_activate_num"));
|
|---|
| | |
|
|---|
| | | Integer state = couponActivate.getState();
|
|---|
| | | int count = couponActivate.getCount();
|
|---|
| | | count++;
|
|---|
| | | if (count >= limitNum) {
|
|---|
| | | result = true;
|
|---|
| | | state = UserSystemCouponActivate.STATE_END;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
