刷单风险规则优化

admin

2020-11-09 2147d023563a7c9d05d97547c00d6b0162c0644c

 fanli/src/main/java/com/yeshi/fanli/service/impl/money/TeamRewardDebtServiceImpl.java

@@ -7,6 +7,9 @@


import javax.annotation.Resource;



import com.yeshi.fanli.entity.order.UserOrderWeiQuanRecord;

import com.yeshi.fanli.service.inter.order.UserOrderWeiQuanRecordService;

import com.yeshi.fanli.util.StringUtil;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



@@ -25,10 +28,13 @@
   @Resource

   private TeamRewardDebtRepayHistoryMapper teamRewardDebtRepayHistoryMapper;



    @Resource

    private UserOrderWeiQuanRecordService userOrderWeiQuanRecordService;



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void addDebt(TeamRewardDebt debt) throws TeamRewardDebtException {

      if (debt == null || debt.getOriginMoney() == null || debt.getOriginMoney() == null || debt.getUid() == null) {

        if (debt == null || debt.getOriginMoney() == null || debt.getOriginMoney() == null || debt.getUid() == null || StringUtil.isNullOrEmpty(debt.getTradeId()) || debt.getSourceType() == null) {

         throw new TeamRewardDebtException(1, "数据不完整");

      }

      if (debt.getCreateTime() == null)

@@ -60,6 +66,11 @@
      record.setMoney(money);

      record.setUid(debt.getUid());

      teamRewardDebtRepayHistoryMapper.insertSelective(record);

        //还钱是否还完

        if (update.getLeftMoney().compareTo(new BigDecimal(0)) <= 0) {

            //已经还完钱

            userOrderWeiQuanRecordService.weiQuanMoneyReturn(debt.getUid(), debt.getTradeId(), debt.getSourceType());

        }

   }



   @Transactional(rollbackFor = Exception.class)