package com.xzx.gc.pay.service;

import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.NumberUtil;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.exception.RestException;
import com.xzx.gc.entity.PartnerAccount;
import com.xzx.gc.entity.PartnerAccountLog;
import com.xzx.gc.pay.mapper.PartnerAccountMapper;
import lombok.extern.slf4j.Slf4j;
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;

@Service
@Transactional
@Slf4j
public class PartnerAccountService {

    @Autowired
    private PartnerAccountMapper partnerAccountMapper;


    public PartnerAccount findByPartnerId(String partnerId){
        PartnerAccount partnerAccount=new PartnerAccount();
        partnerAccount.setPartnerId(partnerId);
        partnerAccount.setDelFlag(Constants.DEL_NOT_FLAG);
        PartnerAccount partnerAccount1 = partnerAccountMapper.selectOne(partnerAccount);
        return partnerAccount1;
    }



    public PartnerAccount findByAccount(String accountId){
        PartnerAccount partnerAccount=new PartnerAccount();
        partnerAccount.setAccount(accountId);
        partnerAccount.setDelFlag(0);
        return partnerAccountMapper.selectOne(partnerAccount);
    }


    /**
     * 根据money变化自动判断增长 及优先额度再是环保币的规则
     */
    public PartnerAccountLog updateAll(String accountId, BigDecimal money){
        PartnerAccountLog partnerAccountLog=new PartnerAccountLog();
        PartnerAccount byAccount = findByAccount(accountId);
        String hbb = byAccount.getHbb();
        String fixed=byAccount.getFixedLimit();
        String over=byAccount.getOverdraftLimit();
        if(money.compareTo(BigDecimal.ZERO)>0){
            money=money.abs();
            //增长
            BigDecimal limit = Convert.toBigDecimal(fixed);
            BigDecimal v = NumberUtil.add(money, Convert.toBigDecimal(over));
            //查询账户信息
            if (v.compareTo(limit) > 0) {
                //将额度填充完   再补money
                BigDecimal actualMoney = NumberUtil.sub(v, limit);
                updateAddMoneyResetFixLimitByAccountId(accountId,actualMoney,limit);
                partnerAccountLog.setAccountMoney(hbb);
                partnerAccountLog.setMoney(actualMoney.toString());
                partnerAccountLog.setOldLimit(over);
                partnerAccountLog.setManageLimit(NumberUtil.sub(limit,Convert.toBigDecimal(over)).toString());
            } else {
                //直接补额度
                updateAddMoneyLimitByAccountId(accountId,null,money);
                partnerAccountLog.setOldLimit(over);
                partnerAccountLog.setManageLimit(money.toString());
            }

        } else if(money.compareTo(BigDecimal.ZERO)<0){
            money=money.abs();
            if(NumberUtil.add(Convert.toBigDecimal(hbb,Constants.MONEY_INIT),Convert.toBigDecimal(over,Constants.MONEY_INIT)).compareTo(money)<0){
                throw new RestException(-1,"打包站账户余额不足");
            }
            //判断要操作金额是否是在可用额度 和 环保币的和之内
            if (NumberUtil.isLessOrEqual(money, Convert.toBigDecimal(over))) {//支付金额小于等于支付额度  优先扣除支付额度
                partnerAccountMapper.updateReduceMoneyLimitByAccountId(accountId,null,money);
                partnerAccountLog.setOldLimit(over);
                partnerAccountLog.setManageLimit("-"+money.toString());
            } else if (NumberUtil.isGreater(money, Convert.toBigDecimal(over))) {   //支付金额大于支付额度 也是优先扣除额度变为0  剩下的用余额扣除
                BigDecimal actualMoney = NumberUtil.sub(money, Convert.toBigDecimal(over));
                partnerAccountMapper.updateReduceMoneyResetLimitByAccountId(accountId,Convert.toBigDecimal(actualMoney));
                partnerAccountLog.setAccountMoney(hbb);
                partnerAccountLog.setMoney("-"+actualMoney);
                partnerAccountLog.setOldLimit(over);
                partnerAccountLog.setManageLimit("-"+over);
            }
        }
        return partnerAccountLog;

    }


    public void updateAddMoneyLimitByAccountId(String accountId,BigDecimal money,BigDecimal over){
        partnerAccountMapper.updateAddMoneyLimitByAccountId(accountId,money,over);
    }

    public void updateAddMoneyResetFixLimitByAccountId(String accountId,BigDecimal money,BigDecimal over){
        partnerAccountMapper.updateAddMoneyResetFixLimitByAccountId(accountId,money,over);
    }


    public void updateReduceMoneyByPartnerId(String partnerId,BigDecimal money){
        //判断合伙人账户的钱是否足够
        PartnerAccount byPartnerId = findByPartnerId(partnerId);
        BigDecimal bigDecimal = Convert.toBigDecimal(byPartnerId.getHbb(),Constants.MONEY_INIT);
        if(bigDecimal.compareTo(money)<0){
            throw new RestException(-1,"合伙人账户余额不足");
        }
        partnerAccountMapper.updateReduceMoneyByPartnerId(partnerId,money);
    }



    public void updateByAccount(PartnerAccount partnerAccount){
        Example example=new Example(PartnerAccount.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("account",partnerAccount.getAccount());
        criteria.andEqualTo("delFlag","0");
        partnerAccountMapper.updateByExampleSelective(partnerAccount,example);
    }
}