package project.loan.internal;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.util.UUIDGenerator;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.Page;
|
import project.Constants;
|
import project.data.DataService;
|
import project.data.model.Realtime;
|
import project.loan.LoanConstants;
|
import project.loan.LoanOrder;
|
import project.loan.LoanOrderService;
|
import project.loan.LoanRelationOrder;
|
import project.loan.LoanRelationOrderService;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletExtend;
|
import project.wallet.WalletService;
|
|
public class LoanRelationOrderServiceImpl implements LoanRelationOrderService {
|
|
private DataService dataService;
|
|
private JdbcTemplate jdbcTemplate;
|
|
private WalletService walletService;
|
|
private MoneyLogService moneyLogService;
|
|
private LoanOrderService loanOrderService;
|
|
/**
|
* 新增质押借币关联订单
|
*/
|
public void saveLoanRelationOrder(LoanRelationOrder relationOrder) {
|
relationOrder.setId(UUIDGenerator.getUUID());
|
relationOrder.setPledgeType(LoanConstants.PLEDGE_TYPE);
|
relationOrder.setOrderType(LoanConstants.PLEDGE_ORDER_TYPE_LOAN);
|
relationOrder.setLoanCurrency("usdt");
|
relationOrder.setCreateTime(new Date());
|
this.insertLoanRelationOrder(relationOrder);
|
}
|
|
/**
|
* 质押记录
|
*/
|
public List<Map<String, Object>> pagedQueryPledge(int pageNo, int pageSize, String loanRelationOrderId) {
|
if (pageNo <= 0) pageNo = 1;
|
Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
|
|
List<LoanRelationOrder> orders = ApplicationUtil.executeSelect(LoanRelationOrder.class,"WHERE LOAN_RELATION_ORDER_ID=? ORDER BY CREATE_TIME DESC LIMIT ?,?",new Object[] {loanRelationOrderId,page.getFirstElementNumber(),pageSize});
|
List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
|
for (LoanRelationOrder order : orders) {
|
Map<String, Object> map = new HashMap<>();
|
// 借款
|
if (LoanConstants.PLEDGE_ORDER_TYPE_LOAN == order.getOrderType()) {
|
map.put("orderType", order.getOrderType());
|
map.put("loanAmount", order.getLoanAmount());
|
map.put("pledgeType", order.getPledgeType());
|
map.put("pledgeAmount", order.getPledgeAmount());
|
map.put("pledgeCurrency", order.getPledgeCurrency());
|
map.put("createTime", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
|
}
|
// 续借、强平、还款
|
if (LoanConstants.PLEDGE_ORDER_TYPE_REFURBISH == order.getOrderType()
|
|| LoanConstants.PLEDGE_ORDER_TYPE_CLOSEOUT == order.getOrderType()
|
|| LoanConstants.PLEDGE_ORDER_TYPE_REPAY == order.getOrderType()) {
|
map.put("orderType", order.getOrderType());
|
map.put("loanAmount", order.getLoanAmount());
|
map.put("createTime", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
|
}
|
// 补增质押
|
if (LoanConstants.PLEDGE_ORDER_TYPE_REPLENISH == order.getOrderType()) {
|
map.put("orderType", order.getOrderType());
|
map.put("pledgeType", order.getPledgeType());
|
map.put("pledgeAmount", order.getPledgeAmount());
|
map.put("pledgeCurrency", order.getPledgeCurrency());
|
map.put("createTime", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
|
}
|
if(ObjectUtils.isNotEmpty(map)) {
|
list.add(map);
|
}
|
}
|
return list;
|
}
|
|
/**
|
* 补增质押
|
*/
|
public void saveReplenishOrder(String id, double pledgeAmount, String partyId) {
|
LoanOrder order = loanOrderService.getLoanOrderParam(id);
|
if (null == order) {
|
throw new BusinessException(1, "order is unknown");
|
}
|
|
if (LoanConstants.PLEDGE_ORDER_STATE_CALCULATE != order.getState()) {
|
throw new BusinessException(1, "order state error");
|
}
|
|
WalletExtend walletExtend = walletService.saveExtendByPara(partyId, order.getPledgeCurrency());
|
if (walletExtend.getAmount() < pledgeAmount) {
|
throw new BusinessException(1, "Insufficient balance");
|
}
|
|
double amountBeforeExtend = walletExtend.getAmount();
|
// 修改拓展钱包 余额 及冻结余额
|
walletService.updateExtend(partyId, walletExtend.getWallettype(), Arith.sub(0, pledgeAmount), pledgeAmount);
|
|
// 保存资金日志
|
MoneyLog logExtend = new MoneyLog();
|
logExtend.setCategory(Constants.MONEYLOG_CATEGORY_LOAN);
|
logExtend.setAmount_before(amountBeforeExtend);
|
logExtend.setAmount(pledgeAmount);
|
logExtend.setAmount_after(Arith.add(amountBeforeExtend, Arith.sub(0, pledgeAmount)));
|
logExtend.setLog("补增质押，订单号[" + order.getOrderNo() + "]，" + "冻结：" + pledgeAmount);
|
logExtend.setPartyId(partyId);
|
logExtend.setWallettype(order.getPledgeCurrency());
|
logExtend.setContent_type(Constants.MONEYLOG_CONTENT_LOAN_FROZEN);
|
logExtend.setCreateTime(new Date());
|
moneyLogService.save(logExtend);
|
|
// 保存质押记录
|
LoanRelationOrder replenish = new LoanRelationOrder();
|
replenish.setId(UUIDGenerator.getUUID());
|
replenish.setLoanRelationOrderId(id);
|
replenish.setPartyId(partyId);
|
replenish.setOrderType(LoanConstants.PLEDGE_ORDER_TYPE_REPLENISH);
|
replenish.setPledgeType(LoanConstants.PLEDGE_TYPE);
|
replenish.setPledgeCurrency(order.getPledgeCurrency());
|
replenish.setPledgeAmount(pledgeAmount);
|
replenish.setCreateTime(new Date());
|
this.insertLoanRelationOrder(replenish);
|
}
|
|
/**
|
* 续借
|
*/
|
public void saveRefurbishOrder(String id, double loanAmountRq, String partyId) {
|
LoanOrder order = loanOrderService.getLoanOrderParam(id);
|
if (null == order) {
|
throw new BusinessException(1, "order is unknown");
|
}
|
|
if (LoanConstants.PLEDGE_ORDER_STATE_CALCULATE != order.getState()) {
|
throw new BusinessException(1, "order state error");
|
}
|
|
double pledgeAmount = order.getPledgeAmount();
|
String pledgeCurrency = order.getPledgeCurrency();
|
int loanCycle = order.getLoanCycle();
|
|
// 质押率 = (借款金额 + (借款金额 * 时利率 * 24 * 借款周期)) / 质押币的价格 / 质押数量
|
List<Realtime> realtimes = dataService.realtime(pledgeCurrency);
|
double debtAmount = Arith.mul(realtimes.get(0).getClose(), pledgeAmount) * LoanConstants.PLEDGE_RATE_INITIAL;
|
double rate = Arith.add(Arith.mul(order.getHourlyRate() * 24, loanCycle), 1);
|
double loanAmountMax = Arith.div(debtAmount, rate, 2);
|
double loanAmountSub = Arith.sub(loanAmountMax, order.getLoanAmount());
|
if (loanAmountSub < loanAmountRq) {
|
throw new BusinessException(1, "Maximum Borrow: " + new BigDecimal(loanAmountSub).setScale(2, RoundingMode.DOWN));
|
}
|
|
Wallet wallet = walletService.saveWalletByPartyId(partyId);
|
double amountBefore = wallet.getMoney();
|
// 修改主钱包余额
|
walletService.update(partyId, loanAmountRq);
|
|
// 保存资金日志
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_CATEGORY_LOAN);
|
moneylog.setAmount_before(amountBefore);
|
moneylog.setAmount(loanAmountRq);
|
moneylog.setAmount_after(Arith.add(amountBefore, loanAmountRq));
|
moneylog.setLog("质押借币，订单号[" + order.getOrderNo() + "]，" + "借款：" + loanAmountRq);
|
moneylog.setPartyId(partyId);
|
moneylog.setWallettype(Constants.WALLET);
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_LOAN_ADD);
|
moneylog.setCreateTime(new Date());
|
moneyLogService.save(moneylog);
|
|
LoanRelationOrder refurbish = new LoanRelationOrder();
|
refurbish.setId(UUIDGenerator.getUUID());
|
refurbish.setLoanRelationOrderId(id);
|
refurbish.setPartyId(partyId);
|
refurbish.setOrderType(LoanConstants.PLEDGE_ORDER_TYPE_REFURBISH);
|
refurbish.setLoanAmount(loanAmountRq);
|
refurbish.setCreateTime(new Date());
|
this.insertLoanRelationOrder(refurbish);
|
|
// 修改质押借币单
|
order.setDebtAmount(Arith.add(order.getDebtAmount(), loanAmountRq));
|
order.setLoanAmount(Arith.add(order.getLoanAmount(), loanAmountRq));
|
loanOrderService.updateLoanOrder(order);
|
|
// 更新缓存
|
loanOrderService.addCacheOrder(order);
|
}
|
|
/**
|
* 还款
|
*/
|
public void saveRepayOrder(String id, double repayAmount, String partyId) {
|
LoanOrder order = loanOrderService.getLoanOrderParam(id);
|
if (null == order) {
|
throw new BusinessException(1, "order is unknown");
|
}
|
|
if (LoanConstants.PLEDGE_ORDER_STATE_SETTLE == order.getState()
|
|| LoanConstants.PLEDGE_ORDER_STATE_CLOSEOUT == order.getState()) {
|
throw new BusinessException(1, "order state error");
|
}
|
|
if (repayAmount > order.getDebtAmount()) {
|
throw new BusinessException(1, "wrong repayment amount");
|
}
|
|
// 解冻
|
if (repayAmount >= order.getDebtAmount()) {
|
WalletExtend walletExtend = walletService.saveExtendByPara(order.getPartyId(), order.getPledgeCurrency());
|
|
List<LoanRelationOrder> list = queryOrders(id, LoanConstants.PLEDGE_ORDER_TYPE_REPLENISH);
|
double pledgeAmount = order.getPledgeAmount();
|
for (LoanRelationOrder relationOrder : list) {
|
pledgeAmount = Arith.add(pledgeAmount, relationOrder.getPledgeAmount());
|
}
|
|
double amountBeforeExtend = walletExtend.getAmount();
|
// 修改拓展钱包 余额 及冻结余额
|
walletService.updateExtend(partyId, walletExtend.getWallettype(), pledgeAmount, Arith.sub(0, pledgeAmount));
|
|
// 保存资金日志
|
MoneyLog logExtend = new MoneyLog();
|
logExtend.setCategory(Constants.MONEYLOG_CATEGORY_LOAN);
|
logExtend.setAmount_before(amountBeforeExtend);
|
logExtend.setAmount(pledgeAmount);
|
logExtend.setAmount_after(Arith.add(amountBeforeExtend, pledgeAmount));
|
logExtend.setLog("质押借币，订单号[" + order.getOrderNo() + "]，" + "解冻：" + pledgeAmount);
|
logExtend.setPartyId(partyId);
|
logExtend.setWallettype(order.getPledgeCurrency());
|
logExtend.setContent_type(Constants.MONEYLOG_CONTENT_LOAN_THAW);
|
logExtend.setCreateTime(new Date());
|
moneyLogService.save(logExtend);
|
|
// 主动结清
|
order.setState(LoanConstants.PLEDGE_ORDER_STATE_SETTLE);
|
|
}
|
|
Wallet wallet = walletService.saveWalletByPartyId(partyId);
|
double amountBefore = wallet.getMoney();
|
// 修改主钱包余额
|
walletService.update(partyId, Arith.sub(0, repayAmount));
|
|
// 保存资金日志
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_CATEGORY_LOAN);
|
moneylog.setAmount_before(amountBefore);
|
moneylog.setAmount(repayAmount);
|
moneylog.setAmount_after(Arith.sub(amountBefore, repayAmount));
|
moneylog.setLog("借币还款，订单号[" + order.getOrderNo() + "]，" + "还款：" + repayAmount);
|
moneylog.setPartyId(partyId);
|
moneylog.setWallettype(Constants.WALLET);
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_LOAN_REPAY);
|
moneylog.setCreateTime(new Date());
|
moneyLogService.save(moneylog);
|
|
LoanRelationOrder repay = new LoanRelationOrder();
|
repay.setId(UUIDGenerator.getUUID());
|
repay.setLoanRelationOrderId(id);
|
repay.setPartyId(partyId);
|
repay.setOrderType(LoanConstants.PLEDGE_ORDER_TYPE_REPAY);
|
repay.setLoanAmount(repayAmount);
|
repay.setCreateTime(new Date());
|
this.insertLoanRelationOrder(repay);
|
|
// 修改质押借币单
|
order.setDebtAmount(Arith.sub(order.getDebtAmount(), repayAmount));
|
// order.setLoanAmount(Arith.sub(order.getLoanAmount(), repayAmount));
|
loanOrderService.updateLoanOrder(order);
|
|
// 更新缓存
|
if (LoanConstants.PLEDGE_ORDER_STATE_SETTLE == order.getState()) {
|
// 主动结清
|
loanOrderService.removeCacheOrder(order.getId());
|
} else {
|
loanOrderService.addCacheOrder(order);
|
}
|
}
|
|
/**
|
* 后台质押记录
|
*/
|
public List<Map<String,Object>> queryLoanRelation(String loanRelationOrderId) {
|
List<Map<String,Object>> result = new ArrayList<Map<String,Object>>();
|
List<LoanRelationOrder> list = jdbcTemplate.query("SELECT * FROM T_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID=? ORDER BY CREATE_TIME DESC",
|
RecordObjectMapper.newInstance(LoanRelationOrder.class), loanRelationOrderId);
|
for (LoanRelationOrder order : list) {
|
Map<String,Object> data = new HashMap<String, Object>();
|
data.put("orderType", order.getOrderType());
|
data.put("loanAmount", order.getLoanAmount());
|
data.put("pledgeType", order.getPledgeType());
|
data.put("pledgeAmount", order.getPledgeAmount());
|
data.put("pledgeCurrency", order.getPledgeCurrency());
|
data.put("createTime", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
|
result.add(data);
|
}
|
return result;
|
}
|
|
/**
|
* 根据订单关联ID获取订单列表
|
*/
|
public List<LoanRelationOrder> queryOrders(String loanRelationOrderId, int orderType) {
|
List<LoanRelationOrder> list = jdbcTemplate.query("SELECT * FROM T_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID=? AND ORDER_TYPE=?",
|
RecordObjectMapper.newInstance(LoanRelationOrder.class), loanRelationOrderId, orderType);
|
return list;
|
}
|
|
public void insertLoanRelationOrder(LoanRelationOrder order) {
|
String insertSql = "INSERT INTO T_LOAN_RELATION_ORDER(UUID,LOAN_RELATION_ORDER_ID,PARTY_ID,ORDER_TYPE,LOAN_AMOUNT,LOAN_CURRENCY,"
|
+ "PLEDGE_AMOUNT,PLEDGE_CURRENCY,PLEDGE_TYPE,CREATE_TIME) VALUES (?,?,?,?,?,?,?,?,?,?)";
|
jdbcTemplate.update(insertSql,order.getId(),order.getLoanRelationOrderId(),order.getPartyId(),order.getOrderType(),
|
order.getLoanAmount(),order.getLoanCurrency(),order.getPledgeAmount(),order.getPledgeCurrency(),
|
order.getPledgeType(),order.getCreateTime());
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setMoneyLogService(MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setDataService(DataService dataService) {
|
this.dataService = dataService;
|
}
|
|
public void setLoanOrderService(LoanOrderService loanOrderService) {
|
this.loanOrderService = loanOrderService;
|
}
|
|
}
|
