package com.xzx.gc.order.service;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.map.MapUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.PayEnum;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.utils.*;
|
import com.xzx.gc.entity.AccountInfo;
|
import com.xzx.gc.entity.AccountLog;
|
import com.xzx.gc.model.comon.account.AllAcountParamDto;
|
import com.xzx.gc.model.user.AccountVo;
|
import com.xzx.gc.order.mapper.AccountLogMapper;
|
import com.xzx.gc.order.mapper.AccountMapper;
|
import com.xzx.gc.order.mapper.PayInfoMapper;
|
import com.xzx.gc.service.AccountContext;
|
import com.xzx.gc.util.SessionUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import tk.mybatis.mapper.entity.Example;
|
|
import java.math.BigDecimal;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
@Transactional
|
public class AccountService {
|
|
@Autowired
|
private AccountMapper accountMapper;
|
|
@Autowired
|
private AccountLogMapper accountLogMapper;
|
|
|
|
@Autowired
|
private PayInfoMapper payInfoMapper;
|
|
|
@Autowired
|
private IdUtils idUtils;
|
|
|
|
|
|
public void updateMoneyByUserId(String userId,BigDecimal money){
|
Map<String,Object> map=MapUtil.newHashMap();
|
map.put("userId", userId);
|
map.put("money", money);
|
accountMapper.updateMyMoneyByOrder(map);
|
}
|
|
public void updateScoreByUserId(String userId,BigDecimal money){
|
Map<String,Object> map=MapUtil.newHashMap();
|
map.put("userId", userId);
|
map.put("money", money);
|
accountMapper.updateMyScoreByOrder(map);
|
}
|
|
|
|
public AccountInfo findByUserId(String userId){
|
AccountInfo accountInfo=new AccountInfo();
|
accountInfo.setDelFlag(Constants.DEL_NOT_FLAG);
|
accountInfo.setIsProhibit("0");
|
accountInfo.setUserId(userId);
|
AccountInfo accountInfo1 = accountMapper.selectOne(accountInfo);
|
return accountInfo1;
|
}
|
|
public AccountInfo findById(String id){
|
return accountMapper.selectByPrimaryKey(id);
|
}
|
|
|
|
|
|
/**
|
*
|
* @param receiverAccount 操作账户
|
* @param channelType 操作渠道1：充值 2：提现 3：回收 4入库 5红包 6分享返利 7重量达标返利
|
* @param channelId 操作ID 如充值 是充值流水号ID
|
* @param channelMoney 操作金额
|
*/
|
public void addAccount(AccountVo receiverAccount, String channelType, String channelId, String channelMoney){
|
String accountId = receiverAccount.getAccountId();
|
String now=DateUtil.now();
|
//回收员
|
Map payMap = new HashMap();
|
String payOrderId=idUtils.generate("ZF",0);
|
payMap.put("payOrderId",payOrderId);
|
payMap.put("orderId",channelId);
|
payMap.put("createUserId",receiverAccount.getUserId());
|
payMap.put("money",channelMoney);
|
payMap.put("accountId",accountId);
|
payMap.put("payType", PayEnum.环保金收入.getValue());
|
payMap.put("status",PayEnum.已支付.getValue());
|
payMap.put("createTime",now);
|
payInfoMapper.payInfoAdd(payMap);
|
|
|
//添加账户
|
AccountInfo accountInfo=new AccountInfo();
|
BeanUtil.copyProperties(receiverAccount,accountInfo);
|
addOtherUserAccount(accountInfo,channelType,payOrderId,channelMoney);
|
|
}
|
|
public void update(AccountInfo accountInfo){
|
accountMapper.updateByPrimaryKeySelective(accountInfo);
|
}
|
|
|
/**
|
* 回收员加钱
|
* @param accountInfo
|
* @param channelType
|
* @param payOrderId
|
* @param channelMoney
|
*/
|
public void addOtherUserAccount(AccountInfo accountInfo,String channelType,String payOrderId,String channelMoney) {
|
|
Map map = new HashMap();
|
map.put("userId", accountInfo.getUserId());
|
|
|
AccountLog accountLog2 = new AccountLog();
|
accountLog2.setCreateTime(DateUtil.now());
|
accountLog2.setCreateUserId(accountInfo.getUserId());
|
accountLog2.setChannelType(Convert.toShort(channelType));
|
accountLog2.setOrderId(payOrderId);
|
|
|
//额度用完还用了环保金的情况
|
BigDecimal limit = Convert.toBigDecimal(accountInfo.getFixedLimit(),Constants.MONEY_INIT);
|
String receiverLimit = accountInfo.getOverdraftLimit();
|
accountLog2.setAccountId(accountInfo.getAccountId());
|
String money = accountInfo.getMoney();
|
BigDecimal v = NumberUtil.add(Convert.toBigDecimal(channelMoney), Convert.toBigDecimal(receiverLimit,Constants.MONEY_INIT));
|
//查询账户信息
|
if (v.compareTo(limit) > 0) {
|
//将额度填充完 再补money
|
BigDecimal actualMoney = NumberUtil.sub(v, limit);
|
map.put("money", actualMoney);
|
map.put("limit", limit);
|
|
accountLog2.setOldMoney(money);
|
accountLog2.setNewMoney(Convert.toStr(NumberUtil.add(Convert.toBigDecimal(money), Convert.toBigDecimal(actualMoney))));
|
accountLog2.setOldLimit(receiverLimit);
|
accountLog2.setNewLimit(Convert.toStr(limit));
|
accountLogMapper.insertSelective(accountLog2);
|
accountMapper.updateMoneyAndLimit(map);
|
} else {
|
//直接补额度
|
map.put("money", Convert.toBigDecimal(channelMoney));
|
accountLog2.setOldLimit(receiverLimit);
|
accountLog2.setNewLimit(Convert.toStr(NumberUtil.add(Convert.toBigDecimal(receiverLimit), Convert.toBigDecimal(channelMoney))));
|
accountLogMapper.insertSelective(accountLog2);
|
accountMapper.updateLimitByOrder(map);
|
}
|
}
|
|
|
|
|
|
|
}
|
