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.InviteOrderSubsidyDebtMapper;
|
import com.yeshi.fanli.dao.mybatis.money.InviteOrderSubsidyDebtRepayHistoryMapper;
|
import com.yeshi.fanli.entity.money.InviteOrderSubsidyDebt;
|
import com.yeshi.fanli.entity.money.InviteOrderSubsidyDebtRepayHistory;
|
import com.yeshi.fanli.exception.money.InviteOrderSubsidyDebtException;
|
import com.yeshi.fanli.service.inter.money.InviteOrderSubsidyDebtService;
|
|
@Service
|
public class InviteOrderSubsidyDebtServiceImpl implements InviteOrderSubsidyDebtService {
|
@Resource
|
private InviteOrderSubsidyDebtMapper inviteOrderSubsidyDebtMapper;
|
|
@Resource
|
private InviteOrderSubsidyDebtRepayHistoryMapper inviteOrderSubsidyDebtRepayHistoryMapper;
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void addDebt(InviteOrderSubsidyDebt debt) throws InviteOrderSubsidyDebtException {
|
if (debt == null || debt.getOriginMoney() == null || debt.getOriginMoney() == null || debt.getUid() == null) {
|
throw new InviteOrderSubsidyDebtException(1, "数据不完整");
|
}
|
if (debt.getCreateTime() == null)
|
debt.setCreateTime(new Date());
|
debt.setLeftMoney(debt.getOriginMoney());
|
inviteOrderSubsidyDebtMapper.insertSelective(debt);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void repayDebt(Long debtId, BigDecimal money) throws InviteOrderSubsidyDebtException {
|
InviteOrderSubsidyDebt debt = inviteOrderSubsidyDebtMapper.selectByPrimaryKeyForUpdate(debtId);
|
if (debt == null)
|
throw new InviteOrderSubsidyDebtException(1, "债务ID不存在");
|
if (money == null || money.compareTo(new BigDecimal(0)) <= 0)
|
throw new InviteOrderSubsidyDebtException(3, "还钱必须大于0");
|
if (debt.getLeftMoney().compareTo(money) < 0)
|
throw new InviteOrderSubsidyDebtException(2, "还钱过多");
|
// 还钱
|
InviteOrderSubsidyDebt update = new InviteOrderSubsidyDebt();
|
update.setId(debt.getId());
|
update.setLeftMoney(debt.getLeftMoney().subtract(money));
|
update.setUpdateTime(new Date());
|
inviteOrderSubsidyDebtMapper.updateByPrimaryKeySelective(update);
|
// 加入还钱记录
|
InviteOrderSubsidyDebtRepayHistory record = new InviteOrderSubsidyDebtRepayHistory();
|
record.setCreateTime(new Date());
|
record.setDebt(debt);
|
record.setMoney(money);
|
record.setUid(debt.getUid());
|
inviteOrderSubsidyDebtRepayHistoryMapper.insertSelective(record);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public BigDecimal repayDebtByUid(Long uid, Date maxEstimatePayTime, BigDecimal money)
|
throws InviteOrderSubsidyDebtException {
|
// 还钱
|
long count = countNeedRepayDebt(uid, maxEstimatePayTime);
|
int page = (int) (count % 200 == 0 ? count / 200 : count / 200 + 1);
|
List<InviteOrderSubsidyDebt> totalList = new ArrayList<>();
|
for (int i = 0; i < page; i++) {
|
List<InviteOrderSubsidyDebt> tempList = listNeedRepayDebt(uid, maxEstimatePayTime, i + 1, 200);
|
if (tempList != null && tempList.size() > 0) {
|
totalList.addAll(tempList);
|
}
|
}
|
|
// 剩余资金
|
BigDecimal leftMoney = new BigDecimal(money.toString());
|
|
for (InviteOrderSubsidyDebt 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 (InviteOrderSubsidyDebtException e) {
|
// 上笔还款未成功，继续下一笔还款
|
}
|
}
|
|
return leftMoney;// 返回剩余的资金
|
}
|
|
@Override
|
public List<InviteOrderSubsidyDebt> listNeedRepayDebt(Long uid, Date maxEstimatePayTime, int page, int count) {
|
return inviteOrderSubsidyDebtMapper.listByLeftMoneyAndUidAndMaxEstimatePayTime(new BigDecimal("0.01"), null,
|
uid, maxEstimatePayTime, (page - 1) * count, count);
|
}
|
|
@Override
|
public long countNeedRepayDebt(Long uid, Date maxEstimatePayTime) {
|
return inviteOrderSubsidyDebtMapper.countByLeftMoneyAndUidAndMaxEstimatePayTime(new BigDecimal("0.01"), null,
|
uid, maxEstimatePayTime);
|
}
|
|
@Override
|
public BigDecimal getTotalDebtMoney(Long uid, Date maxEstimatePayTime) {
|
BigDecimal money = inviteOrderSubsidyDebtMapper.sumLeftMoneyByUid(uid, maxEstimatePayTime);
|
if (money == null)
|
money = new BigDecimal(0);
|
return money;
|
}
|
|
|
@Override
|
public InviteOrderSubsidyDebt getBySourceId(Long sourceId) {
|
return inviteOrderSubsidyDebtMapper.getBySourceId(sourceId);
|
}
|
|
}
|
