| | |
| | | import org.yeshi.utils.entity.DateInfo;
|
| | |
|
| | | import com.aliyun.openservices.ons.api.Message;
|
| | | import com.aliyun.openservices.ons.api.Producer;
|
| | | 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.dto.user.coupon.UserSystemCouponUseMQMsgDTO;
|
| | | import com.yeshi.fanli.entity.accept.AcceptData;
|
| | | import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum;
|
| | | import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
| | |
| | | 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.MQMsgBodyFactory;
|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
| | | import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
| | | import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
|
| | |
| | |
|
| | | @Resource(name = "orderTransactionProducer")
|
| | | private TransactionProducer orderTransactionProducer;
|
| | | |
| | |
|
| | | @Resource
|
| | | private UserSystemCouponActivateService userSystemCouponActivateService;
|
| | | |
| | | @Resource(name = "producer")
|
| | | private Producer producer;
|
| | |
|
| | |
|
| | |
|
| | | @Override
|
| | |
| | | userCoupon.setEndTime(endTime);
|
| | | userCoupon.setCreateTime(new Date());
|
| | | userCoupon.setUpdateTime(new Date());
|
| | | // 插入数据库
|
| | | insertSelective(userCoupon);
|
| | | userSystemCouponMapper.insertSelective(userCoupon);
|
| | | |
| | | if(coupon.getType() == CouponTypeEnum.freeCoupon) {
|
| | | userSystemCouponActivateService.addActivateRecord(userCoupon.getId());
|
| | | }
|
| | |
|
| | | executor.execute(new Runnable() {
|
| | | @Override
|
| | |
| | | throw new UserSystemCouponException(1, "订单信息获取失败");
|
| | |
|
| | | // 版本区分:2.0.2
|
| | | if (VersionUtil.greaterThan_2_0_2(acceptData.getPlatform(), acceptData.getVersion())) {
|
| | | if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) {
|
| | | Date thirdCreateTime = orderVO.getThirdCreateTime();
|
| | | if (thirdCreateTime != null) {
|
| | | long downOrderTime = thirdCreateTime.getTime();
|
| | |
| | |
|
| | | Order order = orderService.findOrderByOrderIdAndType(orderNo, sourceType);
|
| | | if (order == null)
|
| | | return;
|
| | | throw new UserSystemCouponException(1, "该订单不存在");
|
| | |
|
| | | /* 奖金计算 以及相关红包信息处理 */
|
| | |
|
| | |
| | | // 提成金额
|
| | | BigDecimal money = MoneyBigDecimalUtil.mul(hongBao, percent);
|
| | |
|
| | | UserSystemCouponUseMQMsgDTO mqMsg = new UserSystemCouponUseMQMsgDTO(userSystemCoupon.getId(),
|
| | | order.getOrderId(), sourceType);
|
| | | UserSystemCouponUseMQMsg mqMsg = new UserSystemCouponUseMQMsg(userSystemCoupon.getId(), order.getOrderId(),
|
| | | sourceType, systemCoupon.getType().name());
|
| | | // 事务消息
|
| | | Message msg = new Message(MQTopicName.TOPIC_SYSTEM_COUPON_USE.name(), systemCoupon.getType().name(),
|
| | | new Gson().toJson(mqMsg).getBytes());
|
| | | Message msg =MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.useSystemCoupon,
|
| | | mqMsg);
|
| | | try {
|
| | | SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
| | | @Override
|
| | |
| | | }, null);
|
| | | System.out.println(result);
|
| | | } catch (Exception e) {
|
| | | throw new Exception();
|
| | | e.printStackTrace();
|
| | | throw e;
|
| | | }
|
| | | }
|
| | | }
|
| | |
| | | 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) +")待激活");
|
| | | userCouponVO.setCouponEffect(
|
| | | "(" + activateCount + "/" + Integer.parseInt(activateNum) + ")待激活");
|
| | | }
|
| | | } else if (CouponTypeEnum.welfareFreeCoupon == type) {
|
| | | jumpBtn = new HashMap<String, Object>();
|
| | |
| | | }
|
| | | tips = tips.replace("{口令}", token).replace("{下载链接}", configService.get("app_down_link"));
|
| | |
|
| | | return createUserCouponVOo(userSystemCoupon, systemCoupon, giveRecord, tips);
|
| | | UserSystemCouponVO couponVO = createUserCouponVOo(userSystemCoupon, systemCoupon, giveRecord, tips);
|
| | | |
| | | UserSystemCouponUseMQMsg msg = new UserSystemCouponUseMQMsg();
|
| | | msg.setUserSystemCouponId(id);
|
| | | msg.setCouponType(type.name());
|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.systemCouponDrawback,
|
| | | msg);
|
| | | try {
|
| | | producer.send(message);
|
| | | } catch (Exception e) {
|
| | | throw new UserSystemCouponException(1, "创建赠送信息失败");
|
| | | }
|
| | | |
| | | return couponVO;
|
| | | }
|
| | |
|
| | | private UserSystemCouponVO createUserCouponVOo(UserSystemCoupon userSystemCoupon, SystemCoupon systemCoupon,
|
| | |
| | |
|
| | | return userCouponVO;
|
| | | }
|
| | |
|
| | |
|
| | | @Transactional
|
| | | @Override
|
| | |
| | | sendBackGiveCoupon(list);
|
| | | }
|
| | |
|
| | | |
| | | @Override
|
| | | @RequestSerializableByKeyService(key = "#id")
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public void sendBackByGiveId(Long couponId) {
|
| | | if (couponId == null)
|
| | | return;
|
| | | |
| | | UserSystemCoupon userCoupon = userSystemCouponMapper.selectByPrimaryKey(couponId);
|
| | | if (userCoupon == null)
|
| | | return;
|
| | | |
| | | Integer state = userCoupon.getState();
|
| | | if (state != UserSystemCoupon.STATE_IN_USE)
|
| | | return;
|
| | | |
| | | UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByCouponId(couponId);
|
| | | if (giveRecord == null)
|
| | | return;
|
| | | |
| | | if (giveRecord.getState() != null && giveRecord.getState() != UserSystemCouponGiveRecord.STATE_INIT) |
| | | return;
|
| | | |
| | | // 更新赠送记录
|
| | | UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord();
|
| | | updateRecord.setId(giveRecord.getId());
|
| | | updateRecord.setState(UserSystemCouponGiveRecord.STATE_OVERDUE);
|
| | | userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateRecord);
|
| | | |
| | | // 口令失效
|
| | | tokenRecordService.invalidByCoupon(giveRecord.getId());
|
| | |
|
| | |
|
| | | Date now = new Date();
|
| | | Date endTime = userCoupon.getEndTime();
|
| | | if (endTime != null && endTime.getTime() < now.getTime()) {
|
| | | List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>();
|
| | | list.add(userCoupon);
|
| | | updateCounponInvalid(list);
|
| | | return;
|
| | | }
|
| | |
|
| | | // 退回券
|
| | | UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
|
| | | userSystemCoupon.setId(userCoupon.getId());
|
| | | userSystemCoupon.setGive(false);
|
| | | userSystemCoupon.setUseTime(null);
|
| | | userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
|
| | | userSystemCoupon.setUpdateTime(new Date());
|
| | | userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
|
| | |
|
| | | // 使用记录
|
| | | UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(couponId);
|
| | | if (useRecord != null) {
|
| | | UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();
|
| | | useRecordUpdate.setId(useRecord.getId());
|
| | | useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
|
| | | useRecordUpdate.setUpdateTime(new Date());
|
| | | userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);
|
| | | }
|
| | |
|
| | | SystemCoupon systemCoupon = userCoupon.getSystemCoupon();
|
| | | if (systemCoupon != null)
|
| | | systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
| | |
|
| | | if (systemCoupon == null)
|
| | | return;
|
| | |
|
| | | // 退回消息
|
| | | String couponName = systemCoupon.getName();
|
| | | if (CouponTypeEnum.freeCouponGive == systemCoupon.getType()) {
|
| | | couponName = "免单券";
|
| | | } else if (CouponTypeEnum.rebatePercentCoupon == systemCoupon.getType()) {
|
| | | couponName = "奖励券";
|
| | | }
|
| | |
|
| | | String beiZhu = "请到我的-福利中心查看";
|
| | | SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
| | | MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();
|
| | | msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON);
|
| | | msgOther.setTitle(couponName + "退回");
|
| | | msgOther.setGiveType("你赠送的" + couponName + "未被成功领取");
|
| | | msgOther.setGiveTime(sd.format(giveRecord.getGiveTime()));
|
| | | msgOther.setReturnTime(sd.format(new Date()));
|
| | | userOtherMsgNotificationService.tokenGiveMsg(giveRecord.getGiveUid(), beiZhu, msgOther);
|
| | | }
|
| | | |
| | | |
| | | @Override
|
| | | public void sendBackGiveCoupon(List<UserSystemCouponGiveRecord> overdueList) {
|
| | | for (UserSystemCouponGiveRecord record : overdueList) {
|
| | | if (record.getState() != null && record.getState() != UserSystemCouponGiveRecord.STATE_INIT) |
| | | continue;
|
| | | |
| | | // 更新赠送记录
|
| | | UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord();
|
| | | updateRecord.setId(record.getId());
|
| | |
| | | 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());
|
| | | public void triggerFreeCouponActivate(Long uid, String orderNo, Integer source) {
|
| | | if (uid == null || source == null || StringUtil.isNullOrEmpty(orderNo)) |
| | | return;
|
| | | |
| | | UserSystemCoupon coupon = userSystemCouponMapper.getNeedActivateCouponByType(uid,
|
| | | CouponTypeEnum.freeCoupon.name());
|
| | | if (coupon == null)
|
| | | return;
|
| | |
|
| | | Long id = coupon.getId();
|
| | | UserSystemCouponActivate couponActivate = userSystemCouponActivateService.selectForUpdate(id);
|
| | | if (couponActivate == null)
|
| | | return;
|
| | |
|
| | | // 验证同订单是否存在
|
| | | String key = orderNo + "_" + source;
|
| | | String ordernos = couponActivate.getOrdernos();
|
| | | if (!StringUtil.isNullOrEmpty(ordernos)) {
|
| | | String[] array = ordernos.split(",");
|
| | | if (array != null)
|
| | | for (int i= 0; i < array.length; i ++) {
|
| | | if (array[i].equals(key))
|
| | | return;
|
| | | }
|
| | | }
|
| | |
|
| | | // 激活数量
|
| | | 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) {
|
| | | if (count >= limitNum) {
|
| | | result = true;
|
| | | state = UserSystemCouponActivate.STATE_END;
|
| | | }
|
| | | |
| | |
|
| | | if (StringUtil.isNullOrEmpty(ordernos)) {
|
| | | ordernos = key;
|
| | | } else {
|
| | | ordernos = ordernos + "," + key;
|
| | | }
|
| | | |
| | | UserSystemCouponActivate updateActivate = new UserSystemCouponActivate();
|
| | | updateActivate.setId(id);
|
| | | updateActivate.setState(state);
|
| | | updateActivate.setCount(count);
|
| | | updateActivate.setOrdernos(ordernos);
|
| | | updateActivate.setUpdateTime(new Date());
|
| | | userSystemCouponActivateService.updateByPrimaryKeySelective(updateActivate);
|
| | | |
| | |
|
| | | // 激活奖励券
|
| | | if (result) {
|
| | | activateFreeCoupon(coupon, limitNum);
|
| | | }
|
| | | }
|
| | | |
| | |
|
| | | /**
|
| | | * 激活券
|
| | | * |
| | | * @param coupon
|
| | | * @param activateNum
|
| | | */
|
| | |
| | | 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");
|
| | |
| | | userCoupon.setStartTime(nowDate);
|
| | | userCoupon.setUpdateTime(new Date());
|
| | | userSystemCouponMapper.updateByPrimaryKeySelective(userCoupon);
|
| | | |
| | |
|
| | | // 消息
|
| | | executor.execute(new Runnable() {
|
| | | @Override
|
| | | public void run() {
|
| | | UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByReceiveId(coupon.getId());
|
| | | UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService
|
| | | .getByReceiveId(coupon.getId());
|
| | | if (giveRecord == null)
|
| | | return;
|
| | |
|