修改配置文件 添加系统券返利到账订阅

admin

2019-10-29 634a8abd408e87e58b4b8e9f52ddf309b43652d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java

@@ -12,15 +12,25 @@


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.msg.MsgOtherCouponActivateDTO;

import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO;

import com.yeshi.fanli.dto.msg.MsgOtherSystemGiveDTO;

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.entity.bus.user.Order;

@@ -37,6 +47,8 @@
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.order.HongBaoException;

import com.yeshi.fanli.exception.user.UserInfoExtraException;

import com.yeshi.fanli.exception.user.UserSystemCouponException;

import com.yeshi.fanli.log.LogHelper;

@@ -66,8 +78,11 @@
import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TokenUtil;

import com.yeshi.fanli.util.VersionUtil;

import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;

import com.yeshi.fanli.util.factory.msg.MsgOtherSystemGiveDTOFactory;

import com.yeshi.fanli.util.rocketmq.MQTagConstant;

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;

@@ -149,6 +164,12 @@


   @Resource

   private TokenRecordService tokenRecordService;



   @Resource(name = "transactionManager")

   private DataSourceTransactionManager transactionManager;



   @Resource(name = "orderTransactionProducer")

   private TransactionProducer orderTransactionProducer;



   @Override

   public int insertSelective(UserSystemCoupon record) {

@@ -764,55 +785,79 @@


   @Transactional

   @Override

   public void useOrderCoupon(Long uid, Long id, String orderNo, Integer sourceType)

   public void useOrderCoupon(Long uid, Long id, String orderNo, Integer sourceType, AcceptData acceptData)

         throws UserSystemCouponException, Exception {



      if (id == null) {

      if (id == null)

         throw new UserSystemCouponException(1, "券id不存在");

      }



      if (sourceType == null) {

      if (sourceType == null)

         sourceType = Constant.SOURCE_TYPE_TAOBAO;

      }



      // 用户券

      UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id);

      if (userSystemCoupon == null) {

      if (userSystemCoupon == null)

         throw new UserSystemCouponException(1, "券信息不存在");

      }



      if (userSystemCoupon.getUid().longValue() != uid) {

      if (userSystemCoupon.getUid().longValue() != uid)

         throw new UserSystemCouponException(1, "不属于该用户的券");

      }



      Integer state = userSystemCoupon.getState();

      Integer stateActivated = userSystemCoupon.getStateActivated();

      if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated) {

      if (UserSystemCoupon.STATE_CAN_USE != state || 1 != stateActivated)

         throw new UserSystemCouponException(1, "该券不能被使用");

      }



      // 系统券信息

      SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();

      if (systemCoupon != null && systemCoupon.getId() != null) {

         systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());

         if (systemCoupon == null) {

         if (systemCoupon == null)

            throw new UserSystemCouponException(1, "券已不存在");

         }

      }



      if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) {

      if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon)

         throw new UserSystemCouponException(1, "券类型不匹配");

      }



      if (orderNo == null || orderNo.trim().length() == 0) {

      if (orderNo == null || orderNo.trim().length() == 0)

         throw new UserSystemCouponException(1, "订单号不存在");

      }



      // 订单

      CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(uid, orderNo, CommonOrder.STATE_JS,

            sourceType);

      if (orderVO == null) {

      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

            if (downOrderTime > limitDate) {

               Date endDay = DateUtil.plusDayDate(4, thirdCreateTime);

               long currentTime = java.lang.System.currentTimeMillis();

               if (endDay.getTime() > currentTime) {

                  boolean valid = false;

                  DateInfo dateInfo = DateUtil.dateDiff3(currentTime, endDay.getTime());

                  if (dateInfo != null) {

                     if (dateInfo.getDay() > 0)

                        valid = true;



                     if (!valid && dateInfo.getHour() > 0)

                        valid = true;



                     if (!valid && dateInfo.getMinute() > 0)

                        valid = true;



                     if (!valid && dateInfo.getSecond() >= 0)

                        valid = true;

                  }



                  if (!valid)

                     throw new UserSystemCouponException(1, "该订单已不能使用使用奖励券，详情请咨询客服");

               }

            }

         }

      }



      BigDecimal hongBao = orderVO.getHongBao();

@@ -835,6 +880,36 @@
         // 提成金额

         BigDecimal money = MoneyBigDecimalUtil.mul(hongBao, percent);



         UserSystemCouponUseMQMsgDTO mqMsg = new UserSystemCouponUseMQMsgDTO(userSystemCoupon.getId(),

               order.getOrderId(), sourceType);

         // 事务消息

         Message msg = new Message(MQTopicName.TOPIC_SYSTEM_COUPON_USE.name(), systemCoupon.getType().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);

@@ -853,14 +928,10 @@
         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());



         /* 用户券信息状态及记录处理 */



@@ -871,23 +942,33 @@
         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();

      }



   }

@@ -1510,12 +1591,12 @@
   }



   @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));