package com.nq.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.nq.common.ResponseCode;
import com.nq.common.ServerResponse;
import com.nq.dao.DkJGMapper;
import com.nq.dao.DkMapper;
import com.nq.dao.StockConfigMapper;
import com.nq.dao.UserMapper;
import com.nq.enums.EStockType;
import com.nq.enums.EUserAssets;
import com.nq.pojo.*;
import com.nq.service.IDkServices;
import com.nq.service.IUserAssetsServices;
import com.nq.service.IUserService;
import com.nq.utils.timeutil.DateTimeUtil;
import com.nq.vo.dk.DkModelVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;

@Service
public class DkServices implements IDkServices {

    private static final Logger log = LoggerFactory.getLogger(DkServices.class);
    private final ConcurrentHashMap<Long, Object> locks = new ConcurrentHashMap<>();

    @Autowired
    DkMapper dkMapper;
    @Autowired
    DkJGMapper mapper;
    @Autowired
    UserMapper userMapper;
    @Autowired
    StockConfigMapper stockConfigMapper;

    @Autowired
    IUserService iUserService;
    @Autowired
    IUserAssetsServices iUserAssetsServices;


    /**
     * 申请贷款
     * @param dkMoney
     * @param phone
     * @param dkjgId
     * @param request
     * @return
     */
    @Override
    public ServerResponse addDk(BigDecimal dkMoney, String phone, String dkjgId, HttpServletRequest request) {
        try {
            User user = this.iUserService.getCurrentRefreshUser(request);
            if (user == null) {
                return ServerResponse.createByErrorCodeMsg(ResponseCode.NEED_LOGIN.getCode(),"请先登录", request);
            }
            if (user.getLoanLimit() == null || user.getLoanLimit().compareTo(BigDecimal.ZERO) <= 0) {
                System.out.println(user.getLoanLimit());
                return ServerResponse.createByErrorMsg("无贷款额度",request);
            }
            if (user.getLoanLimit().compareTo(dkMoney) < 0) {
                return ServerResponse.createByErrorMsg("最大贷款额度为：" + user.getLoanLimit() ,request);
            }
            String userId = String.valueOf(user.getId());
            //查询是否有未还款记录
            if (dkMapper.countByUserIdAndRStatus(userId, 0) > 0 ) {
                return ServerResponse.createByErrorMsg("已申请贷款,请勿重复申请!", request);
            }
            DkModel dkModel = new DkModel();
            dkModel.setDkUserId(userId);
            dkModel.setCreateTime(new Date());
            dkModel.setDkMoney(String.valueOf(dkMoney));
            dkModel.setDkState("0");
            dkModel.setDkRefundState(0);
            dkModel.setDkJgId(dkjgId);
            dkModel.setDkPhone(phone);
            dkMapper.insert(dkModel);
            return ServerResponse.createBySuccess("贷款申请成功", request);
        } catch (Exception e) {
            log.error("IDkServices addDk error", e);
        }
        return ServerResponse.createByError();
    }

    @Override
    public ServerResponse queryDk(int pageNum, int pageSize) {
        try {
            PageHelper.startPage(pageNum,pageSize);
            List<DkModelVo> dkModelVoList = dkMapper.queryDk();
            PageInfo<DkModelVo> pageInfo = new PageInfo<>(dkModelVoList);
            return ServerResponse.createBySuccess(pageInfo);
        } catch (Exception e) {
            log.error("IDkServices queryDk error", e);
        }
        return ServerResponse.createByError();
    }

    /**
     * 贷款审核
     * @param spMoney
     * @param message
     * @param state
     * @param dkId
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public ServerResponse dkSp(BigDecimal spMoney, String message, Integer state, Integer dkId) {
        try {
            DkModel dkModel = dkMapper.selectById(dkId);
            if (dkModel == null) {
                return ServerResponse.createByErrorMsg("无贷款记录");
            }
            String userId = String.valueOf(dkModel.getDkUserId());
            Object lock = locks.computeIfAbsent(Long.valueOf(userId), k -> new Object());
            synchronized (lock){
                User user = userMapper.selectById(Integer.valueOf(userId));
                if (user == null) {
                    return ServerResponse.createByErrorMsg("无用户信息");
                }
                if (state == 1) { //通过
                    if (user.getLoanLimit() == null || user.getLoanLimit().compareTo(BigDecimal.ZERO) <= 0) {
                        return ServerResponse.createByErrorMsg("无贷款额度");
                    }
                    if (user.getLoanLimit().compareTo(spMoney) < 0) {
                        return ServerResponse.createByErrorMsg("审核金额超出贷款额度：" + user.getLoanLimit());
                    }
                    dkModel.setSpMoney(String.valueOf(spMoney));
                    dkModel.setLoanTime(new Date());
                    //扣除用户贷款
                    user.setLoanLimit(user.getLoanLimit().subtract(spMoney));
                    //发放贷款金额 墨西哥账户
                    iUserAssetsServices.aiAvailableBalanceChange(EStockType.MX.getCode(), user.getId(), EUserAssets.DK, spMoney);
                    userMapper.updateById(user);
                } else if (state == 2) { //拒绝
                    dkModel.setDkMessage(message);
                }
                dkModel.setDkState(String.valueOf(state));
                dkMapper.updateById(dkModel);
                return ServerResponse.createBySuccess("贷款审核成功");
            }
        } catch (Exception e) {
            log.error("IDkServices dksp error", e);
        }
        return ServerResponse.createByError();
    }

    /**
     * 还款
     * @param id
     * @param request
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public ServerResponse rtDk(Integer id, HttpServletRequest request) {
        try {
            DkModel dkModel = dkMapper.selectById(id);
            if (dkModel == null) {
                return ServerResponse.createByErrorMsg("无贷款记录", request);
            }
            if (!dkModel.getDkState().equals("1")) {
                return ServerResponse.createByErrorMsg("未审核通过记录不能还款", request);
            }
            String userId = String.valueOf(dkModel.getDkUserId());
            Object lock = locks.computeIfAbsent(Long.valueOf(userId), k -> new Object());
            synchronized (lock){
                User user = userMapper.selectById(Integer.valueOf(userId));
                if (user == null) {
                    return ServerResponse.createByErrorMsg("无用户信息", request);
                }
                UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId(EStockType.MX.getCode(), user.getId());
                //应该还款金额
                BigDecimal amount = new BigDecimal(dkModel.getSpMoney());
                if(userAssets.getAvailableBalance().compareTo(amount) < 0){
                    return ServerResponse.createByErrorMsg("可用余额不足:" +  userAssets.getAvailableBalance(), request);
                }
                dkModel.setDkRefundState(1);
                //查看贷款利息
                StockConfig stockConfig = stockConfigMapper.selectOne(new QueryWrapper<StockConfig>().eq("c_key", "loan_interest"));
                if (stockConfig != null) {
                    long day = DateTimeUtil.getDaysRoundedUp(dkModel.getLoanTime());
                    //利息 利率*贷款金额*借款天数
                    BigDecimal intAmount = new BigDecimal(stockConfig.getCValue()).multiply(amount).multiply(BigDecimal.valueOf(day));
                    iUserAssetsServices.aiAvailableBalanceChange(EStockType.MX.getCode(), user.getId(), EUserAssets.RT_DK_INT, intAmount);
                }
                //还款
                iUserAssetsServices.aiAvailableBalanceChange(EStockType.MX.getCode(), user.getId(), EUserAssets.RT_DK, amount);
                dkMapper.updateById(dkModel);
                return ServerResponse.createBySuccess("贷款审核成功", request);
            }
        } catch (Exception e) {
            log.error("IDkServices rtDk error", e);
        }
        return ServerResponse.createByError();
    }

    @Override
    public List<DkJgBean> queryAll() {
        return mapper.queryAll();
    }

    /**
     * 贷款记录
     * @param pageNum
     * @param pageSize
     * @param httpServletRequest
     * @return
     */
    @Override
    public ServerResponse queryByShUserId(int pageNum, int pageSize, Integer state, HttpServletRequest httpServletRequest) {
        try {
            User user = this.iUserService.getCurrentRefreshUser(httpServletRequest);
            if (user == null) {
                return ServerResponse.createByErrorCodeMsg(ResponseCode.NEED_LOGIN.getCode(),"请先登录", httpServletRequest);
            }
            PageHelper.startPage(pageNum,pageSize);
            List<DkModel> dkModelList = dkMapper.selectList(new QueryWrapper<DkModel>()
                    .eq("dk_user_id", String.valueOf(user.getId()))
                    .eq(state != null,"dk_state", state)
                    .orderByDesc("create_time")
            );
            PageInfo<DkModel> pageInfo = new PageInfo<>(dkModelList);
            return ServerResponse.createBySuccess(pageInfo);
        } catch (Exception e) {
            log.error("IDkServices queryByShUserId error", e);
        }
        return ServerResponse.createByError();
    }

    @Override
    public int  inserDkJG(String dkjgName) {
        DkJgBean dkJgBean = new DkJgBean();
        dkJgBean.setDkJg(dkjgName);
        return mapper.insert(dkJgBean);
    }



    @Override
    public int update(DkJgBean dkJgBean) {
        return mapper.updateById(dkJgBean);
    }

    @Override
    public List<DkJgBean> queryDkJg() {
        return mapper.queryAll();
    }

    @Override
    public int deleteByDkjg(int id) {
       return mapper.deleteById(id);
    }
}