package com.xzx.gc.order.service;
|
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.OrderEnum;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.comon.account.AllAcountParamDto;
|
import com.xzx.gc.pay.service.*;
|
import com.xzx.gc.service.BaseAccountService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
|
@Service
|
@Transactional
|
@Slf4j
|
public class LimitApplyService extends BaseAccountService {
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
|
|
@Autowired
|
private OtherUserService otherUserService;
|
|
|
@Autowired
|
private AccountService accountService;
|
|
|
@Autowired
|
private PartnerAccountService partnerAccountService;
|
|
|
@Autowired
|
private PartnerAccountLogService partnerAccountLogService;
|
|
|
@Autowired
|
private AccountLogService accountLogService;
|
|
|
|
@Override
|
public Object account(AllAcountParamDto allAcountParamDto) {
|
AccountInfo byUserId = accountService.findByUserIdForbidden(allAcountParamDto.getUserId());
|
if("1".equals(byUserId.getIsProhibit())){
|
throw new RestException(-1,"账户被禁用");
|
}
|
String partnerId = otherUserService.findById(allAcountParamDto.getUserId()).getPartnerId();
|
CityPartner byId1 = cityPartnerService.queryById(partnerId);
|
//1：合伙人。2：打包站
|
String partnerType = byId1.getPartnerType();
|
String accountId = byUserId.getAccountId();
|
allAcountParamDto.setAccountId(accountId);
|
allAcountParamDto.setOverdraftLimit(byUserId.getOverdraftLimit());
|
allAcountParamDto.setFixedLimit(byUserId.getFixedLimit());
|
allAcountParamDto.setPartnerId(partnerId);
|
allAcountParamDto.setPartnerType(partnerType);
|
allAcountParamDto.setPartnerAccountId(byId1.getAccountNo());
|
|
log.debug("准备进行额度申请操作:{}",JSONUtil.toJsonPrettyStr(allAcountParamDto));
|
//合伙人扣钱或打包站先扣额度再扣钱 平台用户加钱
|
accountId = allAcountParamDto.getAccountId();
|
BigDecimal overdraftLimit = Convert.toBigDecimal(allAcountParamDto.getOverdraftLimit(),Constants.MONEY_INIT);
|
BigDecimal fixLimit = Convert.toBigDecimal(allAcountParamDto.getFixedLimit(),Constants.MONEY_INIT);
|
AccountInfo accountInfo=new AccountInfo();
|
accountInfo.setAccountId(accountId);
|
accountInfo.setOverdraftLimit(Convert.toStr(NumberUtil.add(overdraftLimit,allAcountParamDto.getMoney())));
|
accountInfo.setFixedLimit(Convert.toStr(NumberUtil.add(fixLimit,allAcountParamDto.getMoney())));
|
accountInfo.setUpdateTime(DateUtil.now());
|
accountService.update(accountInfo);
|
|
AccountLog accountLog=new AccountLog();
|
accountLog.setAccountId(accountId);
|
accountLog.setCreateUserId(allAcountParamDto.getUserId());
|
accountLog.setChannelType(Convert.toShort(CommonEnum.额度申请.getValue()));
|
accountLog.setOrderId(allAcountParamDto.getFlowNo());
|
accountLog.setOldLimit(Convert.toStr(overdraftLimit));
|
accountLog.setOldFixedLimit(Convert.toStr(fixLimit));
|
accountLog.setNewLimit(Convert.toStr(NumberUtil.add(overdraftLimit,allAcountParamDto.getMoney())));
|
accountLog.setNewFixedLimit(Convert.toStr(NumberUtil.add(fixLimit,allAcountParamDto.getMoney())));
|
accountLogService.add(accountLog);
|
|
//平台操作
|
partnerType = allAcountParamDto.getPartnerType();
|
//合伙人
|
if("1".equals(partnerType)){
|
PartnerAccountLog partnerAccountLog=new PartnerAccountLog();
|
partnerAccountLog.setPartnerId(allAcountParamDto.getPartnerId());
|
partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
|
partnerAccountLog.setType(OrderEnum.额度调整.getValue());
|
partnerAccountLog.setMoney("-"+allAcountParamDto.getMoney().toString());
|
partnerAccountLogService.add(partnerAccountLog);
|
partnerAccountService.updateReduceMoneyByPartnerId(allAcountParamDto.getPartnerId(),allAcountParamDto.getMoney());
|
}else if("2".equals(partnerType)){
|
//打包站 先扣额度再扣钱
|
PartnerAccountLog partnerAccountLog1=partnerAccountService.updateAll(allAcountParamDto.getPartnerAccountId(), Convert.toBigDecimal("-"+allAcountParamDto.getMoney().toString()));
|
PartnerAccountLog partnerAccountLog = new PartnerAccountLog();
|
partnerAccountLog.setAccountId(allAcountParamDto.getPartnerAccountId());
|
partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
|
partnerAccountLog.setType(OrderEnum.额度调整.getValue());
|
partnerAccountLog.setMoney(partnerAccountLog1.getMoney());
|
partnerAccountLog.setManageLimit(partnerAccountLog1.getManageLimit());
|
partnerAccountLog.setManageLimitFix(partnerAccountLog1.getManageLimitFix());
|
PartnerAccount partnerAccount=new PartnerAccount();
|
partnerAccount.setHbb(partnerAccountLog1.getAccountMoney());
|
partnerAccount.setOverdraftLimit(partnerAccountLog1.getOldLimit());
|
partnerAccount.setFixedLimit(partnerAccountLog1.getOldLimitFix());
|
partnerAccountLog.setPartnerAccount(partnerAccount);
|
partnerAccountLogService.add(partnerAccountLog);
|
}
|
log.debug("额度申请操作已完成：用户：{},额度：{}",allAcountParamDto.getUserId(),allAcountParamDto.getMoney().toString());
|
return null;
|
}
|
}
|
