淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -1,124 +1,136 @@
package com.yeshi.fanli.service.impl.money;



import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.yeshi.fanli.dao.mybatis.money.TeamRewardDebtMapper;

import com.yeshi.fanli.dao.mybatis.money.TeamRewardDebtRepayHistoryMapper;

import com.yeshi.fanli.entity.money.TeamRewardDebt;

import com.yeshi.fanli.entity.money.TeamRewardDebtRepayHistory;

import com.yeshi.fanli.exception.money.TeamRewardDebtException;

import com.yeshi.fanli.service.inter.money.TeamRewardDebtService;



@Service

public class TeamRewardDebtServiceImpl implements TeamRewardDebtService {

   @Resource

   private TeamRewardDebtMapper teamRewardDebtMapper;



   @Resource

   private TeamRewardDebtRepayHistoryMapper teamRewardDebtRepayHistoryMapper;



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void addDebt(TeamRewardDebt debt) throws TeamRewardDebtException {

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

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

      }

      if (debt.getCreateTime() == null)

         debt.setCreateTime(new Date());

      debt.setLeftMoney(debt.getOriginMoney());

      teamRewardDebtMapper.insertSelective(debt);

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void repayDebt(Long debtId, BigDecimal money) throws TeamRewardDebtException {

      TeamRewardDebt debt = teamRewardDebtMapper.selectByPrimaryKeyForUpdate(debtId);

      if (debt == null)

         throw new TeamRewardDebtException(1, "债务ID不存在");

      if (money == null || money.compareTo(new BigDecimal(0)) <= 0)

         throw new TeamRewardDebtException(3, "还钱必须大于0");

      if (debt.getLeftMoney().compareTo(money) < 0)

         throw new TeamRewardDebtException(2, "还钱过多");

      // 还钱

      TeamRewardDebt update = new TeamRewardDebt();

      update.setId(debt.getId());

      update.setLeftMoney(debt.getLeftMoney().subtract(money));

      update.setUpdateTime(new Date());

      teamRewardDebtMapper.updateByPrimaryKeySelective(update);

      // 加入还钱记录

      TeamRewardDebtRepayHistory record = new TeamRewardDebtRepayHistory();

      record.setCreateTime(new Date());

      record.setDebt(debt);

      record.setMoney(money);

      record.setUid(debt.getUid());

      teamRewardDebtRepayHistoryMapper.insertSelective(record);

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public BigDecimal repayDebtByUid(Long uid,Date maxEstimatePayTime, BigDecimal money) throws TeamRewardDebtException {

      // 还钱

      long count = countNeedRepayDebt(uid,maxEstimatePayTime);

      int page = (int) (count % 200 == 0 ? count / 200 : count / 200 + 1);

      List<TeamRewardDebt> totalList = new ArrayList<>();

      for (int i = 0; i < page; i++) {

         List<TeamRewardDebt> tempList = listNeedRepayDebt(uid,maxEstimatePayTime, i + 1, 200);

         if (tempList != null && tempList.size() > 0) {

            totalList.addAll(tempList);

         }

      }



      // 剩余资金

      BigDecimal leftMoney = new BigDecimal(money.toString());



      for (TeamRewardDebt debt : totalList) {

         if (leftMoney.compareTo(new BigDecimal(0)) <= 0)// 余额不足扣款

            break;

         BigDecimal repayMoney = null;

         if (debt.getLeftMoney().compareTo(leftMoney) >= 0)

            repayMoney = new BigDecimal(leftMoney.toString());

         else

            repayMoney = debt.getLeftMoney();

         try {

            repayDebt(debt.getId(), repayMoney);

            leftMoney = leftMoney.subtract(repayMoney);

         } catch (TeamRewardDebtException e) {

            // 上笔还款未成功，继续下一笔还款

         }

      }



      return leftMoney;// 返回剩余的资金

   }



   @Override

   public List<TeamRewardDebt> listNeedRepayDebt(Long uid,Date maxEstimatePayTime, int page, int count) {

      return teamRewardDebtMapper.listByLeftMoneyAndUidAndMaxEstimatePayTime(new BigDecimal("0.01"), null, uid,maxEstimatePayTime, (page - 1) * count, count);

   }



   @Override

   public long countNeedRepayDebt(Long uid,Date maxEstimatePayTime) {

      return teamRewardDebtMapper.countByLeftMoneyAndUidAndMaxEstimatePayTime(new BigDecimal("0.01"), null, uid,maxEstimatePayTime);

   }



   @Override

   public BigDecimal getTotalDebtMoney(Long uid,Date maxEstimatePayTime) {

      BigDecimal money = teamRewardDebtMapper.sumLeftMoneyByUid(uid, maxEstimatePayTime);

      if (money == null)

         money = new BigDecimal(0);

      return money;

   }



   @Override

   public TeamRewardDebt selectBySourceId(Long sourceId) {

      return teamRewardDebtMapper.selectBySourceId(sourceId);

   }



}

package com.yeshi.fanli.service.impl.money;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

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;

import com.yeshi.fanli.dao.mybatis.money.TeamRewardDebtMapper;
import com.yeshi.fanli.dao.mybatis.money.TeamRewardDebtRepayHistoryMapper;
import com.yeshi.fanli.entity.money.TeamRewardDebt;
import com.yeshi.fanli.entity.money.TeamRewardDebtRepayHistory;
import com.yeshi.fanli.exception.money.TeamRewardDebtException;
import com.yeshi.fanli.service.inter.money.TeamRewardDebtService;

@Service
public class TeamRewardDebtServiceImpl implements TeamRewardDebtService {
    @Resource
    private TeamRewardDebtMapper teamRewardDebtMapper;

    @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 || StringUtil.isNullOrEmpty(debt.getTradeId()) || debt.getSourceType() == null) {
            throw new TeamRewardDebtException(1, "数据不完整");
        }
        if (debt.getCreateTime() == null)
            debt.setCreateTime(new Date());
        debt.setLeftMoney(debt.getOriginMoney());
        teamRewardDebtMapper.insertSelective(debt);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public void repayDebt(Long debtId, BigDecimal money, String beizhu) throws TeamRewardDebtException {
        TeamRewardDebt debt = teamRewardDebtMapper.selectByPrimaryKeyForUpdate(debtId);
        if (debt == null)
            throw new TeamRewardDebtException(1, "债务ID不存在");
        if (money == null || money.compareTo(new BigDecimal(0)) <= 0)
            throw new TeamRewardDebtException(3, "还钱必须大于0");
        if (debt.getLeftMoney().compareTo(money) < 0)
            throw new TeamRewardDebtException(2, "还钱过多");
        // 还钱
        TeamRewardDebt update = new TeamRewardDebt();
        update.setId(debt.getId());
        update.setLeftMoney(debt.getLeftMoney().subtract(money));
        update.setUpdateTime(new Date());
        teamRewardDebtMapper.updateByPrimaryKeySelective(update);
        // 加入还钱记录
        TeamRewardDebtRepayHistory record = new TeamRewardDebtRepayHistory();
        record.setCreateTime(new Date());
        record.setDebt(debt);
        record.setMoney(money);
        record.setUid(debt.getUid());
        record.setBeiZhu(beizhu);
        teamRewardDebtRepayHistoryMapper.insertSelective(record);
        //还钱是否还完
        if (update.getLeftMoney().compareTo(new BigDecimal(0)) <= 0) {
            //已经还完钱
            userOrderWeiQuanRecordService.weiQuanMoneyReturn(debt.getUid(), debt.getTradeId(), debt.getSourceType());
        }
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public BigDecimal repayDebtByUid(Long uid, Date maxEstimatePayTime, BigDecimal money) throws TeamRewardDebtException {
        // 还钱
        long count = countNeedRepayDebt(uid, maxEstimatePayTime);
        int page = (int) (count % 200 == 0 ? count / 200 : count / 200 + 1);
        List<TeamRewardDebt> totalList = new ArrayList<>();
        for (int i = 0; i < page; i++) {
            List<TeamRewardDebt> tempList = listNeedRepayDebt(uid, maxEstimatePayTime, i + 1, 200);
            if (tempList != null && tempList.size() > 0) {
                totalList.addAll(tempList);
            }
        }

        // 剩余资金
        BigDecimal leftMoney = new BigDecimal(money.toString());

        for (TeamRewardDebt debt : totalList) {
            if (leftMoney.compareTo(new BigDecimal(0)) <= 0)// 余额不足扣款
                break;
            BigDecimal repayMoney = null;
            if (debt.getLeftMoney().compareTo(leftMoney) >= 0)
                repayMoney = new BigDecimal(leftMoney.toString());
            else
                repayMoney = debt.getLeftMoney();
            try {
                repayDebt(debt.getId(), repayMoney,null);
                leftMoney = leftMoney.subtract(repayMoney);
            } catch (TeamRewardDebtException e) {
                // 上笔还款未成功，继续下一笔还款
            }
        }

        return leftMoney;// 返回剩余的资金
    }

    @Override
    public List<TeamRewardDebt> listNeedRepayDebt(Long uid, Date maxEstimatePayTime, int page, int count) {
        return teamRewardDebtMapper.listByLeftMoneyAndUidAndMaxEstimatePayTime(new BigDecimal("0.01"), null, uid, maxEstimatePayTime, (page - 1) * count, count);
    }

    @Override
    public long countNeedRepayDebt(Long uid, Date maxEstimatePayTime) {
        return teamRewardDebtMapper.countByLeftMoneyAndUidAndMaxEstimatePayTime(new BigDecimal("0.01"), null, uid, maxEstimatePayTime);
    }

    @Override
    public BigDecimal getTotalDebtMoney(Long uid, Date maxEstimatePayTime) {
        BigDecimal money = teamRewardDebtMapper.sumLeftMoneyByUid(uid, maxEstimatePayTime);
        if (money == null)
            money = new BigDecimal(0);
        return money;
    }

    @Override
    public TeamRewardDebt selectBySourceId(Long sourceId) {
        return teamRewardDebtMapper.selectBySourceId(sourceId);
    }

}