package com.xzx.gc.pay.service;
|
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.core.util.StrUtil;
|
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 RestoreLimitService 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;
|
|
|
/**
|
* 打包站标识
|
*/
|
private static final String DBZ="1";
|
|
@Override
|
public Object account(AllAcountParamDto allAcountParamDto) {
|
//额度恢复 恢复入库员的固定额度 同时要减去合伙人的金额 打包员则 需要 减去 打包站的额度（按额度优先原则 ）
|
|
//打包站恢复额度则需要减去合伙人的环保币
|
|
String partnerId=null;
|
if(StrUtil.isBlank(allAcountParamDto.getUserRealType())) {
|
AccountInfo byUserId = accountService.findByUserId(allAcountParamDto.getUserId());
|
if (byUserId == null) {
|
throw new RestException(-1, "账户被禁用");
|
}
|
OtherUserInfo byId = otherUserService.findById(allAcountParamDto.getUserId());
|
partnerId = byId.getPartnerId();
|
allAcountParamDto.setFixedLimit(byUserId.getFixedLimit());
|
allAcountParamDto.setAccountId(byUserId.getAccountId());
|
allAcountParamDto.setOverdraftLimit(byUserId.getOverdraftLimit());
|
CityPartner byId1 = cityPartnerService.queryById(partnerId);
|
//1：合伙人。2：打包站
|
String partnerType = byId1.getPartnerType();
|
allAcountParamDto.setPartnerType(partnerType);
|
allAcountParamDto.setPartnerId(partnerId);
|
allAcountParamDto.setPartnerAccountId(byId1.getAccountNo());
|
|
}else if(DBZ.equals(allAcountParamDto.getUserRealType())){
|
String userId=allAcountParamDto.getUserId();
|
//根据主打包员查询所属的打包站ID
|
CityPartner byuserId = cityPartnerService.findByUserId(userId, OrderEnum.打包站.getValue());
|
if(byuserId==null){
|
throw new RestException("找不到对应的打包站");
|
}
|
partnerId=byuserId.getId()+"";
|
//查询打包站的账户
|
PartnerAccount accountInfo1 = partnerAccountService.findByPartnerId(partnerId);
|
allAcountParamDto.setFixedLimit(accountInfo1.getFixedLimit());
|
|
//打包站的账户
|
allAcountParamDto.setAccountId(accountInfo1.getAccount());
|
allAcountParamDto.setOverdraftLimit(accountInfo1.getOverdraftLimit());
|
|
CityPartner byId1 = cityPartnerService.queryById(byuserId.getPackingStation());
|
allAcountParamDto.setPartnerId(byId1.getId().toString());
|
//合伙人的账户
|
allAcountParamDto.setPartnerAccountId(byId1.getAccountNo());
|
}
|
|
|
log.debug("准备进行额度恢复操作:{}",JSONUtil.toJsonPrettyStr(allAcountParamDto));
|
//额度恢复 入库员加钱 合伙人扣钱
|
BigDecimal limit=Convert.toBigDecimal(allAcountParamDto.getOverdraftLimit(),Constants.MONEY_INIT);
|
//实际恢复的额度
|
BigDecimal realLimit=NumberUtil.sub(Convert.toBigDecimal(allAcountParamDto.getFixedLimit()),limit);
|
|
if(StrUtil.isBlank(allAcountParamDto.getUserRealType())) {
|
AccountInfo accountInfo = new AccountInfo();
|
accountInfo.setAccountId(allAcountParamDto.getAccountId());
|
accountInfo.setOverdraftLimit(allAcountParamDto.getFixedLimit());
|
accountInfo.setUpdateTime(DateUtil.now());
|
accountService.update(accountInfo);
|
|
AccountLog accountLog = new AccountLog();
|
accountLog.setAccountId(allAcountParamDto.getAccountId());
|
accountLog.setCreateUserId(allAcountParamDto.getUserId());
|
accountLog.setChannelType(Convert.toShort(CommonEnum.额度恢复.getValue()));
|
accountLog.setOrderId(allAcountParamDto.getFlowNo());
|
accountLog.setOldLimit(allAcountParamDto.getOverdraftLimit());
|
accountLog.setNewLimit(allAcountParamDto.getFixedLimit());
|
accountLog.setOldFixedLimit(accountLog.getNewLimit());
|
accountLog.setNewFixedLimit(accountLog.getNewLimit());
|
accountLogService.add(accountLog);
|
|
|
//合伙人
|
if("1".equals(allAcountParamDto.getPartnerType())){
|
PartnerAccountLog partnerAccountLog=new PartnerAccountLog();
|
partnerAccountLog.setPartnerId(allAcountParamDto.getPartnerId());
|
partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
|
partnerAccountLog.setType(OrderEnum.额度调整.getValue());
|
partnerAccountLog.setMoney("-"+realLimit.toString());
|
partnerAccountLogService.add(partnerAccountLog);
|
partnerAccountService.updateReduceMoneyByPartnerId(allAcountParamDto.getPartnerId(),realLimit);
|
}else if("2".equals(allAcountParamDto.getPartnerType())){
|
//打包站 先扣额度再扣钱
|
PartnerAccountLog partnerAccountLog1=partnerAccountService.updateAll(allAcountParamDto.getPartnerAccountId(), Convert.toBigDecimal("-"+realLimit.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);
|
}
|
|
|
}else if(DBZ.equals(allAcountParamDto.getUserRealType())){
|
|
//打包站可用额度恢复
|
PartnerAccountLog partnerAccountLog = new PartnerAccountLog();
|
partnerAccountLog.setAccountId(allAcountParamDto.getAccountId());
|
partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
|
partnerAccountLog.setType(OrderEnum.恢复额度.getValue());
|
partnerAccountLog.setManageLimit(realLimit.toString());
|
PartnerAccount partnerAccount=new PartnerAccount();
|
partnerAccount.setOverdraftLimit(allAcountParamDto.getOverdraftLimit());
|
partnerAccountLog.setPartnerAccount(partnerAccount);
|
partnerAccountLogService.add(partnerAccountLog);
|
|
PartnerAccount accountInfo = new PartnerAccount();
|
accountInfo.setAccount(allAcountParamDto.getAccountId());
|
accountInfo.setOverdraftLimit(allAcountParamDto.getFixedLimit());
|
accountInfo.setUpdateTime(DateUtil.now());
|
partnerAccountService.updateByAccount(accountInfo);
|
|
|
|
//合伙人扣除环保币
|
partnerAccountLog=new PartnerAccountLog();
|
partnerAccountLog.setPartnerId(allAcountParamDto.getPartnerId());
|
partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
|
partnerAccountLog.setType(OrderEnum.恢复额度.getValue());
|
partnerAccountLog.setMoney("-"+realLimit.toString());
|
partnerAccountLogService.add(partnerAccountLog);
|
partnerAccountService.updateReduceMoneyByPartnerId(allAcountParamDto.getPartnerId(),realLimit);
|
}
|
|
|
|
log.debug("额度恢复操作已完成");
|
return null;
|
}
|
}
|
