package com.gear.customer.swx.biz.impl;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.gear.common.constant.SwxConstons;
import com.gear.common.core.redis.RedisCache;
import com.gear.common.exception.CustomerException;
import com.gear.common.utils.jwt.JWTTokenUtils;
import com.gear.common.utils.sign.Md5Utils;
import com.gear.customer.swx.biz.SwxBizUser;
import com.gear.customer.swx.vo.request.*;
import com.gear.customer.swx.vo.response.SwxUserInfoVo;
import com.gear.swx.domain.*;
import com.gear.swx.service.*;
import org.apache.logging.log4j.util.Strings;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;
import java.util.concurrent.TimeUnit;

@Component
public class SwxBizUserImpl implements SwxBizUser {

    @Autowired
    private ISwxIdentificationService swxIdentificationService;

    @Autowired
    private ISwxUserService swxUserService;

    @Autowired
    private RedisCache redisCache;

    @Autowired
    private ISwxSettingsService swxSettingsService;

    @Autowired
    private ISwxRechargeRecordService swxRechargeRecordService;

    @Autowired
    private ISwxWithdrawalRecordService swxWithdrawalRecordService;

    @Autowired
    private ISwxNftService swxNftService;

    @Autowired
    private ISwxMoneyLogService moneyLogService;

    @Autowired
    private ISwxLoanRecordService swxLoanRecordService;

    @Autowired
    private ISwxUserLevelService swxUserLevelService;
    @Override
    @Transactional
    public String identification(String userId,SwxUserIdentificationVo swxUserIdentificationVo) throws CustomerException {
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        if (swxUser.getIdefinderStatus() == SwxConstons.SWX_EXAMINE_STATUS_REVIEW||swxUser.getIdefinderStatus()  == SwxConstons.SWX_EXAMINE_STATUS_YES){
            throw new CustomerException("10019");
        }
        SwxIdentification swxIdentification = new SwxIdentification();
        BeanUtils.copyProperties(swxUserIdentificationVo,swxIdentification);
        swxIdentification.setUserId(swxUser.getId());
        swxIdentificationService.save(swxIdentification);
        swxUser.setIdefinderStatus(SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
        swxUserService.updateById(swxUser);
        return "20001";
    }

    @Override
    public SwxUserInfoVo getUserInfo(String userId) throws CustomerException{
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw  new CustomerException("10009");
        }
        SwxUserInfoVo info = new SwxUserInfoVo();
        BeanUtils.copyProperties(swxUser,info);
        if (!Strings.isEmpty(swxUser.getLevel())){
            SwxUserLevel userLevel = swxUserLevelService.getById(swxUser.getLevel());
            if (userLevel != null){
                info.setLevelLogo(userLevel.getLogo());
            }
        }
        SwxSettings swxSettings = swxSettingsService.getOne(new QueryWrapper<SwxSettings>().lambda().eq(SwxSettings::getParamKey,"virtual_account"));

        if(swxSettings != null && ((Integer.parseInt(swxSettings.getParamValue()))==SwxConstons.NOMARL_STATUS_YES)){
            long exprise = 7L;
           //判断当前系统中是否存在此虚拟账户
            if (redisCache.hasKey("SWX-CUSTOMER-VERTURAL-"+userId)){
                SwxUserInfoVo infoVo= redisCache.getCacheObject("SWX-CUSTOMER-VERTURAL-"+userId);
                info.setVirtuallyAmount(infoVo.getVirtuallyAmount() == null ? new BigDecimal(100000) : infoVo.getVirtuallyAmount());
                info.setVirtuallyBondAmount(infoVo.getVirtuallyBondAmount());
            }else{
                info.setVirtuallyAmount(new BigDecimal(1000000));
                info.setVirtuallyBondAmount(new BigDecimal(0));
                redisCache.setCacheObject("SWX-CUSTOMER-VERTURAL-"+swxUser.getId(),info,604800L, TimeUnit.SECONDS);
            }
            info.setVirtuallyStatus(SwxConstons.NOMARL_STATUS_YES);
        }
        info.setInviteNumber(String.valueOf(swxUser.getInviteNumber()));
        return info;
    }

    @Override
    public String recharge(String userId, SwxUserRechargeVo vo) throws CustomerException{
        if(vo.getAmount() == null || vo.getCurrency() == null || Strings.isEmpty(vo.getType())){
            throw new CustomerException("10018");
        }
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        SwxRechargeRecord swxRechargeRecord = new SwxUserRechargeVo();
        BeanUtils.copyProperties(vo,swxRechargeRecord);
        swxRechargeRecord.setUserId(swxUser.getId());
        swxRechargeRecord.setStatus(SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
        swxRechargeRecordService.save(swxRechargeRecord);
        return "20002";
    }

    @Override
    public String withdrawal(String userId, SwxUserWithdrawalVo vo)throws CustomerException {
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }

        SwxSettings swxSettings = swxSettingsService.getOne(new QueryWrapper<SwxSettings>().lambda().eq(SwxSettings::getParamKey,"withdrawal_fee"));
        BigDecimal fee = BigDecimal.ZERO;
        if(swxSettings != null && !Strings.isEmpty(swxSettings.getParamValue())){
            fee =  new BigDecimal(swxSettings.getParamValue());
        }

        SwxWithdrawalRecord swxWithdrawalRecord = new SwxWithdrawalRecord();
        BeanUtils.copyProperties(vo,swxWithdrawalRecord);
        swxWithdrawalRecord.setUserId(swxUser.getId());
        swxWithdrawalRecord.setStatus(SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
        BigDecimal withdrawalFee = swxWithdrawalRecord.getAmount().multiply(fee).divide(new BigDecimal(100));
        swxWithdrawalRecord.setWithdrawalFee(withdrawalFee);
        swxWithdrawalRecord.setTrueAmount(swxWithdrawalRecord.getAmount().subtract(withdrawalFee));
        swxWithdrawalRecordService.save(swxWithdrawalRecord);
        return "20003";
    }

    @Override
    public IPage<SwxWithdrawalRecord> listWithdrwal(String userId,Integer pageNo,Integer pageSize) throws CustomerException{
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        Page<SwxWithdrawalRecord> page = new Page<SwxWithdrawalRecord>(pageNo, pageSize);
        QueryWrapper<SwxWithdrawalRecord> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SwxWithdrawalRecord::getUserId,userId);
        queryWrapper.lambda().orderByDesc(SwxWithdrawalRecord::getCreateTime);
        IPage<SwxWithdrawalRecord> pageList = swxWithdrawalRecordService.page(page, queryWrapper);
        return pageList;
    }

    @Override
    public IPage<SwxRechargeRecord> listRecharge(String userId,Integer pageNo,Integer pageSize) throws CustomerException{
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        QueryWrapper<SwxRechargeRecord> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SwxRechargeRecord::getUserId,userId);
        queryWrapper.lambda().orderByDesc(SwxRechargeRecord::getCreateTime);
        Page<SwxRechargeRecord> page = new Page<SwxRechargeRecord>(pageNo, pageSize);
        IPage<SwxRechargeRecord> pageList = swxRechargeRecordService.page(page, queryWrapper);
        return pageList;
    }

    @Override
    public List<SwxNft> listNft(String userId) throws CustomerException{
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        QueryWrapper<SwxNft> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SwxNft::getUserId,userId);
        queryWrapper.lambda().orderByDesc(SwxNft::getCreateTime);
        return swxNftService.list(queryWrapper);
    }

    @Override
    @Transactional
    public String buyNft(String userId, SwxUserBuyNftVo swxUserBuyNftVo) throws CustomerException {
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        SwxNft swxNft = swxNftService.getById(swxUserBuyNftVo.getId());
        if (swxNft == null || swxNft.getStatus() != SwxConstons.NOMARL_STATUS_YES){
            throw new CustomerException("10020");
        }
        if(Strings.isEmpty(swxUserBuyNftVo.getAddress())){
            throw new CustomerException("10021");
        }
        //判断用户余额是否足够
        if(swxUser.getAmount().compareTo(swxNft.getCurrentPrice()) < 0){
            throw new CustomerException("10011");
        }
        //插入资金日志
        SwxMoneyLog moneyLog = new SwxMoneyLog();
        moneyLog.setInfo("购买nft:"+swxNft.getName());
        moneyLog.setStatus(SwxConstons.NOMARL_STATUS_YES);
        moneyLog.setType(SwxConstons.SWX_MONEY_LOG_TYPE_BUYNFT);
        moneyLog.setSymbol(SwxConstons.SWX_MONEY_TYPE_PAY);
        moneyLog.setTitle("nft公益");
        moneyLog.setOldAmount(swxUser.getAmount());
        //修改用户余额
        swxUser.setAmount(swxUser.getAmount().subtract(swxNft.getCurrentPrice()));
        swxUserService.updateById(swxUser);
        moneyLog.setNowAmount(swxUser.getAmount());
        moneyLog.setUserId(swxUser.getId());
        moneyLog.setBusiId(swxNft.getId());
        moneyLog.setMoney(swxNft.getCurrentPrice());
        moneyLogService.save(moneyLog);
        //修改nft状态
        swxNft.setUserId(userId);
        swxNft.setStatus(SwxConstons.NOMARL_STATUS_NO);
        swxNft.setAddress(swxUserBuyNftVo.getAddress());
        swxNftService.updateById(swxNft);
        return "20004";
    }

    @Override
    public String loan(String userId, SwxUserLoanVo swxUserLoanVo) throws CustomerException{
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        //判断用户是否实名认证
        if (swxUser.getIdefinderStatus() != SwxConstons.SWX_EXAMINE_STATUS_YES){
            throw new CustomerException("10022");
        }

        //获取借款期限和利率
        if(swxUserLoanVo.getAmount() == null || swxUserLoanVo.getTerm() == null){
            throw new CustomerException("10023");
        }

        //获取利率
        SwxSettings rateSettings = swxSettingsService.getOne(new QueryWrapper<SwxSettings>().lambda().eq(SwxSettings::getParamKey,"loan_rate"));
        if(rateSettings == null){
            throw new CustomerException("10018");
        }

        String rateStr = rateSettings.getParamValue();

        JSONArray jsonArray = JSONArray.parseArray(rateStr);

        BigDecimal rate = null;

        for(int i = 0; i < jsonArray.size(); i++){
            JSONObject object = jsonArray.getJSONObject(i);
            Integer term = object.getInteger("days");
            if (term == swxUserLoanVo.getTerm()){
                rate = new BigDecimal(object.getString("rate"));
                break;
            }
        }
        if (rate == null){
            throw new CustomerException("10018");
        }

        SwxLoanRecord swxLoanRecord = new SwxLoanRecord();

        BeanUtils.copyProperties(swxUserLoanVo,swxLoanRecord);
        swxLoanRecord.setUserId(userId);
        //审核中
        swxLoanRecord.setStatus(SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
        swxLoanRecord.setRete(rate);
        swxLoanRecordService.save(swxLoanRecord);


        return "20001";
    }

    @Override
    public IPage<SwxLoanRecord> listLoanRecord(String userId,Integer pageNo,Integer pageSize)throws CustomerException {
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        QueryWrapper<SwxLoanRecord> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(SwxLoanRecord::getUserId,userId);
        queryWrapper.lambda().orderByDesc(SwxLoanRecord::getCreateTime);
        Page<SwxLoanRecord> page = new Page<SwxLoanRecord>(pageNo, pageSize);
        IPage<SwxLoanRecord> pageList = swxLoanRecordService.page(page, queryWrapper);
        return pageList;
    }

    @Override
    public String repassword(String userId,SwxUserRegisterVo vo) {
        if (Strings.isEmpty(vo.getPassword()) || Strings.isEmpty(vo.getRePaossword()) || !vo.getPassword().equals(vo.getRePaossword())){
            throw new CustomerException("10004");
        }
        SwxUser swxUser = swxUserService.getById(userId);
        if (swxUser == null){
            throw new CustomerException("10009");
        }
        String newPass = Md5Utils.hash(vo.getPassword());
        swxUser.setPassword(newPass);
        swxUserService.updateById(swxUser);
        return "20005";
    }
}