package com.nq.service.impl;

import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.dao.AgentAgencyFeeMapper;
import com.nq.dao.AgentUserMapper;
import com.nq.dao.UserMapper;
import com.nq.dao.UserPositionMapper;
import com.nq.pojo.*;
import com.nq.service.IAgentAgencyFeeService;
import com.nq.service.IAgentUserService;
import com.nq.utils.PropertiesUtil;
import com.nq.utils.redis.CookieUtils;
import com.nq.utils.redis.JsonUtil;
import com.nq.utils.redis.RedisShardedPoolUtils;
import com.nq.vo.agent.AgentAgencyFeeVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.util.List;

@Service("IAgentAgencyFeeService")
public class AgentAgencyFeeServiceImpl implements IAgentAgencyFeeService {
    @Resource
    private AgentAgencyFeeMapper agentAgencyFeeMapper;

    @Autowired
    IAgentUserService iAgentUserService;

    @Autowired
    AgentUserMapper agentUserMapper;

    @Autowired
    UserPositionMapper userPositionMapper;

    @Autowired
    UserMapper userMapper;

    @Override
    public int insert(AgentAgencyFee agentAgencyFee) {
        int ret = 0;
        // valid
        if (agentAgencyFee == null) {
            return 0;
        }

        ret = agentAgencyFeeMapper.insert(agentAgencyFee);
        return ret;
    }

    @Override
    public int update(AgentAgencyFee agentAgencyFee) {
        int ret = agentAgencyFeeMapper.update(agentAgencyFee);
        return ret>0 ? ret: 0;
    }

    /*获取收费比例
    * feeType：费用类型：1、入仓手续费，2、平仓手续费，3、延递费(留仓费)，4、分红
    * */
    private  BigDecimal getScale(AgentUser agentUser, int feeType){
        BigDecimal scale = new BigDecimal(0);//递延费比例
        if(feeType == 1 || feeType == 2){
            scale = agentUser.getPoundageScale();
        } else if(feeType == 3){
            scale = agentUser.getDeferredFeesScale();
        } else if(feeType == 4){
            scale = agentUser.getReceiveDividendsScale();
        }
        return scale;
    }

    /*
    * 代理费收入，考虑多级代理的问题
    * feeType：费用类型：1、入仓手续费，2、平仓手续费，3、延递费(留仓费)，4、分红
    * positionSn：入仓单号
    * 调用关键词：核算代理收入
    * */
    @Override
    public int AgencyFeeIncome(int feeType,String positionSn) {
        int ret = 0;
        int businessId = 0;
        int agentId = 0;
        int level = 0;//代理级别
        BigDecimal totalMoney = new BigDecimal(0);
        BigDecimal oneProfitMoney = new BigDecimal(0);//一级利润
        BigDecimal upProfitMoney = new BigDecimal(0);//上级利润
        BigDecimal selfProfitMoney = new BigDecimal(0);//上级利润
        BigDecimal downProfitMoney = new BigDecimal(0);//下级利润
        BigDecimal scale = new BigDecimal(0);//递延费比例
        String remarks = "";
        int downAgentId = 0;
        AgentUser agentUser = null;
        UserPosition userPosition = null;
        userPosition = userPositionMapper.findPositionBySn(positionSn);
        agentUser = agentUserMapper.findAgentByAgentId(userPosition.getAgentId());
        if(agentUser == null){
            return 0;
        }
        agentId = agentUser.getId();
        level = agentUser.getAgentLevel();
        businessId = userPosition.getId();
        if(feeType == 1){
            totalMoney = userPosition.getOrderFee();
            remarks = "【入仓收入】入仓手续费总额："+userPosition.getOrderFee()+"，单号："+userPosition.getPositionSn();
        } else if(feeType == 2){
            //平仓浮动总盈亏负数，代理利润增加，否则减少
            totalMoney = userPosition.getAllProfitAndLose().multiply(new BigDecimal(-1));
            remarks = "【平仓收入】平仓手续费总额："+userPosition.getOrderFee()+"，单号："+userPosition.getPositionSn();
        } else if(feeType == 3){
            totalMoney = userPosition.getOrderStayFee();
            remarks = "【递延费收入】递延费总额："+userPosition.getOrderFee()+"，单号："+userPosition.getPositionSn();
        }else if(feeType == 4){
            totalMoney = userPosition.getAllProfitAndLose().multiply(new BigDecimal(-1));
            remarks = "【分红收入】分红总额："+userPosition.getOrderFee()+"，单号："+userPosition.getPositionSn();
        }
        //金额为0不计算分红直接跳出
        if(totalMoney.compareTo(new BigDecimal(0))<=0){
            return -1;
        }
        //模拟用户下单不计算分红
        User user = userMapper.selectById(userPosition.getUserId());
        if(user.getAccountType() != 0 || user.getIsLock() != 0 || user.getIsActive() != 2){
            return -2;
        }
        List<AgentUser> agentlist = iAgentUserService.getAgentSuperiorList(agentUser.getId());
        if(agentlist != null && agentlist.size()>0){
            if(agentlist.size() == 1){//一级代理的会员
                //一级代理利润
                AgentAgencyFee agentAgencyFee = new AgentAgencyFee();
                scale = getScale(agentUser,feeType);
                selfProfitMoney = totalMoney.multiply(scale).setScale(4, 4);
                agentAgencyFee.setAgentId(agentUser.getId());
                agentAgencyFee.setStatus(1);
                agentAgencyFee.setAymentType(1);
                agentAgencyFee.setBusinessId(businessId);
                agentAgencyFee.setFeeType(feeType);
                agentAgencyFee.setTotalMoney(totalMoney);
                agentAgencyFee.setProfitMoney(selfProfitMoney);
                agentAgencyFee.setRemarks(remarks);
                saveAgencyFee(agentAgencyFee);
                //总代理利润
                agentUser = agentUserMapper.findAgentByAgentId(agentUser.getParentId());
                AgentAgencyFee totalAgent = new AgentAgencyFee();
                totalAgent.setAgentId(agentUser.getId());
                totalAgent.setStatus(1);
                totalAgent.setAymentType(1);
                totalAgent.setBusinessId(businessId);
                totalAgent.setFeeType(feeType);
                upProfitMoney = totalMoney.subtract(selfProfitMoney);
                totalAgent.setTotalMoney(totalMoney);
                totalAgent.setProfitMoney(upProfitMoney);
                totalAgent.setRemarks(remarks);
                saveAgencyFee(totalAgent);
            } else if(agentlist.size()>1) {//二级代理以上会员
                for (int i = 1; i < agentlist.size(); i++) {
                    AgentUser model = agentlist.get(i);
                    //一级代理，要把总代理的收入算出来
                    if (i == 1) {
                        //一级代理利润
                        AgentAgencyFee agentAgencyFee = new AgentAgencyFee();
                        if (agentlist.size() == 2) {
                            AgentUser selfAgentUser = agentUserMapper.findAgentByAgentId(agentId);
                            scale = getScale(model,feeType);
                            oneProfitMoney = totalMoney.multiply(scale).setScale(4, 4);
                            scale = getScale(selfAgentUser,feeType);
                            downProfitMoney = oneProfitMoney.multiply(scale).setScale(4, 4);
                            selfProfitMoney = oneProfitMoney.subtract(downProfitMoney);

                        } else {
                            AgentUser modeldown = agentlist.get(i + 1);
                            scale = getScale(model,feeType);
                            oneProfitMoney = totalMoney.multiply(scale).setScale(4, 4);
                            scale = getScale(modeldown,feeType);
                            downProfitMoney = oneProfitMoney.multiply(scale).setScale(4, 4);
                            selfProfitMoney = oneProfitMoney.subtract(downProfitMoney);
                        }
                        agentAgencyFee.setAgentId(model.getId());
                        agentAgencyFee.setStatus(1);
                        agentAgencyFee.setAymentType(1);
                        agentAgencyFee.setBusinessId(businessId);
                        agentAgencyFee.setFeeType(feeType);
                        agentAgencyFee.setTotalMoney(totalMoney);
                        agentAgencyFee.setProfitMoney(selfProfitMoney);
                        agentAgencyFee.setRemarks(remarks);
                        //增加一级代理利润
                        saveAgencyFee(agentAgencyFee);
                        //总代理利润
                        agentUser = agentUserMapper.findAgentByAgentId(model.getParentId());
                        AgentAgencyFee totalAgent = new AgentAgencyFee();
                        totalAgent.setAgentId(agentUser.getId());
                        totalAgent.setStatus(1);
                        totalAgent.setAymentType(1);
                        totalAgent.setBusinessId(businessId);
                        totalAgent.setFeeType(feeType);
                        upProfitMoney = totalMoney.subtract(oneProfitMoney);
                        totalAgent.setTotalMoney(totalMoney);
                        totalAgent.setProfitMoney(upProfitMoney);
                        totalAgent.setRemarks(remarks);
                        saveAgencyFee(totalAgent);
                        upProfitMoney = downProfitMoney;
                        ret = ret +1 ;
                    } else {
                        //二级以下代理利润
                        AgentAgencyFee agentAgencyFee = new AgentAgencyFee();
                        if (i == (level-1)) {//倒数第二级，自己就是下级
                            AgentUser selfAgentUser = agentUserMapper.findAgentByAgentId(agentId);
                            scale = getScale(selfAgentUser,feeType);
                            downProfitMoney = upProfitMoney.multiply(scale).setScale(4, 4);
                            selfProfitMoney = upProfitMoney.subtract(downProfitMoney);
                        } else {
                            AgentUser modeldown = agentlist.get(i + 1);
                            scale = getScale(modeldown,feeType);
                            downProfitMoney = upProfitMoney.multiply(scale).setScale(4, 4);
                            selfProfitMoney = upProfitMoney.subtract(downProfitMoney);
                        }
                        agentAgencyFee.setAgentId(model.getId());
                        agentAgencyFee.setStatus(1);
                        agentAgencyFee.setAymentType(1);
                        agentAgencyFee.setBusinessId(businessId);
                        agentAgencyFee.setFeeType(feeType);
                        agentAgencyFee.setTotalMoney(totalMoney);
                        agentAgencyFee.setProfitMoney(selfProfitMoney);
                        agentAgencyFee.setRemarks(remarks);
                        saveAgencyFee(agentAgencyFee);
                        upProfitMoney = downProfitMoney;
                        ret = ret +1 ;
                    }
                }
                //最后一级的利润
                AgentAgencyFee agentAgencyFee = new AgentAgencyFee();
                agentAgencyFee.setAgentId(agentId);
                agentAgencyFee.setStatus(1);
                agentAgencyFee.setAymentType(1);
                agentAgencyFee.setBusinessId(businessId);
                agentAgencyFee.setFeeType(feeType);
                agentAgencyFee.setTotalMoney(totalMoney);
                agentAgencyFee.setProfitMoney(downProfitMoney);
                agentAgencyFee.setRemarks(remarks);
                saveAgencyFee(agentAgencyFee);
            }
        }
        return ret;
    }

    /*增加代理利润*/
    public int saveAgencyFee(AgentAgencyFee model){
        int k = 0;
        //添加利润明细
        k = insert(model);
        //修改代理账户余额
        AgentUser user = new AgentUser();
        user.setId(model.getAgentId());
        user.setTotalMoney(model.getProfitMoney());
        k = agentUserMapper.updateTotalMoney(user);
        return k;
    }

    /*查询代理利润明细列表
    * */
    public ServerResponse<PageInfo> getAgentAgencyFeeList(int pageNum, int pageSize, HttpServletRequest request) {
        Page<AgentAgencyFeeVO> page = PageHelper.startPage(pageNum, pageSize);
        AgentUser agentUser = getCurrentAgent(request);
        List<AgentAgencyFee> agentAgencyFees = this.agentAgencyFeeMapper.getAgentAgencyFeeList(agentUser.getId());
        PageInfo pageInfo = new PageInfo(page);
        pageInfo.setList(agentAgencyFees);
        return ServerResponse.createBySuccess(pageInfo);
    }

    public AgentUser getCurrentAgent(HttpServletRequest request) {
        String loginToken = CookieUtils.readLoginToken(request, PropertiesUtil.getProperty("agent.cookie.name"));
        String agentJson = RedisShardedPoolUtils.get(loginToken);
        AgentUser agentUser = (AgentUser) JsonUtil.string2Obj(agentJson, AgentUser.class);
       if (agentUser==null){
           return null;
       }
        return this.agentUserMapper.selectByPrimaryKey(agentUser.getId());
    }
}