Merge remote-tracking branch 'origin/div' into div

admin

2019-11-25 e65037e672ecab852e2a6c5b242cdadfd1a58b33

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

New file
@@ -0,0 +1,162 @@
package com.yeshi.fanli.service.impl.redpack;



import java.math.BigDecimal;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.DateUtil;



import com.google.gson.Gson;

import com.yeshi.fanli.dao.mybatis.redpack.RedPackForbidMapper;

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

import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail.MsgTypeMoneyTypeEnum;

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

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

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

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

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

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

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

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

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

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

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



@Service

public class RedPackForbidServiceImpl implements RedPackForbidService {



   @Resource

   private RedPackForbidMapper redPackForbidMapper;

	
   @Resource

   private RedPackForbidRecordService redPackForbidRecordService;

	
   @Resource

   private RedPackBalanceService redPackBalanceService;

	
   @Resource

   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;

	
	
   @Override

   @Transactional(rollbackFor = Exception.class)

   public void addForbid(RedPackForbidRecord record) throws RedPackForbidException {

      Long uid = record.getUid();

      if (uid == null || uid <= 0)

         throw new RedPackForbidException(1,"用户id不能为空");

		
      Integer type = record.getType();

      if (type == null)

         throw new RedPackForbidException(1,"封禁时间不能为空");

		
      String time = null;

      Date endTime = null;

      Date nowTime = new Date();

      if (type == RedPackForbidRecord.TYPE_ONE_MONTH) {

         time = "1个月";

         endTime = DateUtil.plusMonths(nowTime, 1);

      } else if (type == RedPackForbidRecord.TYPE_THREE_MONTH) {

         time = "3个月";

         endTime = DateUtil.plusMonths(nowTime, 3);

      } else if (type == RedPackForbidRecord.TYPE_SIX_MONTH) {

         time = "半年";

         endTime = DateUtil.plusMonths(nowTime, 6);

      } else if (type == RedPackForbidRecord.TYPE_ONE_YEAR) {

         time = "1年";

         endTime = DateUtil.plusYears(nowTime, 1);

      } else if (type == RedPackForbidRecord.TYPE_HUNDRED_YEAR) {

         time = "永久";

         endTime = DateUtil.plusYears(nowTime, 100);

      } else {

         throw new RedPackForbidException(1,"封禁时间类型不正确");

      }

	
      // 查询余额

      BigDecimal balance = new BigDecimal(0);

      RedPackBalance redPackBalance = redPackBalanceService.selectForUpdate(uid);

      if (redPackBalance != null && redPackBalance.getMoney() != null)

         balance = redPackBalance.getMoney();

		
      // 加入封禁

      RedPackForbid redPackForbid = new RedPackForbid();

      redPackForbid.setId(uid);

      redPackForbid.setEndTime(endTime);

      redPackForbid.setCreateTime(nowTime);

      redPackForbidMapper.insertSelective(redPackForbid);

		
      // 加入封禁记录

      record.setEndTime(endTime);

      record.setMoney(balance);

      record.setCreateTime(nowTime);

      redPackForbidRecordService.insertSelective(record);

		
      // 清空红包

      try {

         redPackBalanceService.resetRedPack(uid, RedPackDetailFactory.createForbid(record));

      } catch (RedPackBalanceException e) {

         throw new RedPackForbidException(1, e.getMsg());

      } catch (RedPackDetailException e) {

         throw new RedPackForbidException(1, e.getMsg());

      }

		
      //消息

      MsgRedPackExchangeContentDTO dto = new MsgRedPackExchangeContentDTO();

      dto.setTime(time);

      dto.setReason("红包产生、使用、赠送环节涉嫌违规");

      dto.setHandle("清空所有红包余额");

      userMoneyMsgNotificationService.redPackMsg(record.getUid(), MsgTypeMoneyTypeEnum.redPackForbid, new Gson().toJson(dto), "封禁信息无法申诉，请按照规则使用红包功能");

   }



	
   @Override

   @Transactional(rollbackFor = Exception.class)

   public void deduct(RedPackForbidRecord record) throws RedPackForbidException {

      Long uid = record.getUid();

      if (uid == null || uid <= 0)

         throw new RedPackForbidException(1,"用户id不能为空");

		
      BigDecimal money = record.getMoney();

      if (money == null)

         throw new RedPackForbidException(1,"扣除金额不能为空");

		
      // 清空红包

      try {

         redPackBalanceService.subRedPack(uid, money, RedPackDetailFactory.createDeduct(record));

      } catch (RedPackBalanceException e) {

         throw new RedPackForbidException(1, e.getMsg());

      } catch (RedPackDetailException e) {

         throw new RedPackForbidException(1, e.getMsg());

      }

   }

	
   @Override

   public void delete(List<Long> idsList) {

      if (idsList != null)

         for (Long id : idsList)

            redPackForbidMapper.deleteByPrimaryKey(id);



   }

	
   @Override

   public boolean verifyForbid(Long uid) {

      if (uid != null) {

         RedPackForbid redPackForbid = redPackForbidMapper.selectByPrimaryKey(uid);

         if (redPackForbid != null) {

            if (redPackForbid.getEndTime() == null || redPackForbid.getEndTime().getTime() > java.lang.System.currentTimeMillis()) {

               return true;

            } else {

               // 时间已过，解除封禁

               redPackForbidMapper.deleteByPrimaryKey(uid);

               return false;

            }

         }

      }

      return false;

   }

	
	
}