品牌日志

yujian

2019-12-20 eda5d0e998204c7a49ab84d8528569b765bec2f9

 fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackGiveRecordServiceImpl.java

@@ -23,12 +23,12 @@
import com.yeshi.fanli.entity.redpack.RedPackDetail;

import com.yeshi.fanli.entity.redpack.RedPackDetail.RedPackDetailTypeEnum;

import com.yeshi.fanli.entity.redpack.RedPackGiveRecord;

import com.yeshi.fanli.exception.redpack.RedPackBalanceException;

import com.yeshi.fanli.exception.redpack.RedPackGiveRecordException;

import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;

import com.yeshi.fanli.service.inter.redpack.RedPackBalanceService;

import com.yeshi.fanli.service.inter.redpack.RedPackConfigService;

import com.yeshi.fanli.service.inter.redpack.RedPackDetailService;

import com.yeshi.fanli.service.inter.redpack.RedPackForbidService;

import com.yeshi.fanli.service.inter.redpack.RedPackGiveRecordService;

import com.yeshi.fanli.service.inter.user.TokenRecordService;

import com.yeshi.fanli.util.Constant;

@@ -60,6 +60,9 @@
   @Resource

   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;



   @Resource

   private RedPackForbidService redPackForbidService;

	
   @Resource(name = "producer")

   private Producer producer;



@@ -118,29 +121,27 @@
      if (uid == null || amount == null)

         throw new RedPackGiveRecordException(1, "参数不正确");



      if(redPackForbidService.verifyForbid(uid))

         throw new RedPackGiveRecordException(1, "红包功能已被封禁");

		
      String giveMin = redPackConfigService.getValueByKey("give_money_min");

      String giveMax = redPackConfigService.getValueByKey("give_money_max");

      if (amount.compareTo(new BigDecimal(giveMin)) < 0 || amount.compareTo(new BigDecimal(giveMax)) > 0)

         throw new RedPackGiveRecordException(1, "赠送金额至少" + giveMin + "元至多" + giveMax + "元");



      BigDecimal balance = null;

      try {

         balance = redPackBalanceService.getBalance(uid);

      } catch (RedPackBalanceException e1) {

         throw new RedPackGiveRecordException(1, e1.getMsg());

      }



      BigDecimal balance = redPackBalanceService.getBalance(uid);

      if (balance == null || amount.compareTo(balance) > 0)

         throw new RedPackGiveRecordException(1, "余额不足");



      Date nowDate = new Date();

      Date endTime = DateUtil.plusDayDate(Constant.TOKEN_DAYS, new Date());

      // 赠送记录

      RedPackGiveRecord giveRecord = new RedPackGiveRecord();

      giveRecord.setAmount(amount);

      giveRecord.setGiveUid(uid);

      giveRecord.setState(RedPackGiveRecord.STATE_INIT);

      giveRecord.setGiveTime(nowDate);

      giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, new Date()));

      giveRecord.setEndTime(endTime);

      redPackGiveRecordMapper.insertSelective(giveRecord);



      // 口令记录

@@ -149,7 +150,7 @@
      tokenRecord.setIdentify(giveRecord.getId() + "");

      tokenRecord.setType(TokenTypeEnum.redPack);

      tokenRecord.setStartTime(nowDate);

      tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, new Date()));

      tokenRecord.setEndTime(endTime);

      tokenRecord.setState(0);

      tokenRecordService.insertSelective(tokenRecord);



@@ -178,13 +179,13 @@
      msg.setUid(uid);

      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.redPackGiftDrawback,

            msg);

      // 延迟一分钟

      message.setStartDeliverTime(endTime.getTime() + 1000 * 60);

      try {

         producer.send(message);

      } catch (Exception e) {

         throw new RedPackGiveRecordException(1, "红包创建失败");

      }

		


      return tips;

   }