package com.ydtech.modules.admin.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ydtech.aop.exception.DescribeException;
import com.ydtech.core.page.HttpResult;
import com.ydtech.modules.admin.dao.*;
import com.ydtech.modules.admin.model.*;
import com.ydtech.modules.admin.model.dto.*;
import com.ydtech.modules.admin.model.vo.*;
import com.ydtech.modules.admin.service.SysAgencyLeaderService;
import com.ydtech.modules.admin.service.SysDeptService;
import com.ydtech.modules.admin.service.SysPartnerService;
import com.ydtech.modules.admin.service.SysUserService;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.inv.utils.EasyExcelUtils;
import com.ydtech.modules.order.dao.InsAreaCompanyMapper;
import com.ydtech.modules.order.dao.InsOrdersMapper;
import com.ydtech.modules.order.entity.BasePageResult;
import com.ydtech.modules.order.entity.InsAreaCompany;
import com.ydtech.modules.order.entity.InsOrders;
import com.ydtech.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.io.IOException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@Service("sysAgencyLeaderService")
public class SysAgencyLeaderServiceImpl extends ServiceImpl<SysAgencyLeaderMapper, SysAgencyLeader> implements SysAgencyLeaderService {

    @Resource
    private SysAgencyLeaderMapper sysAgencyLeaderMapper;

    @Resource
    private SysDeptMapper sysDeptMapper;
    @Resource
    private SysDeptService sysDeptService;

    @Resource
    private SysUserMapper sysUserMapper;

    @Resource
    private SysUserService sysUserService;
    @Resource
    private InsOrdersMapper insOrdersMapper;

    @Resource
    private InsAreaCompanyMapper insAreaCompanyMapper;

    @Resource
    private SysAgencyFeeApprovalMapper sysAgencyFeeApprovalMapper;

    @Resource
    private SysRelationPersonMapper sysRelationPersonMapper;


    @Resource
    private SysPartnerService sysPartnerService;

    @Resource
    private SysPartnerMapper sysPartnerMapper;
    @Resource
    private SysPartnerTimeMapper sysPartnerTimeMapper;
    @Resource
    private SysPartnerAccountMapper sysPartnerAccountMapper;

    @Resource
    private SysPremiumDetailsMapper sysPremiumDetailsMapper;

    @Value("${upload.file.path}")
    private String uploadPath;


    @Value("${upload.file.url}")
    private String uploadUrl;


    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean insert(SysAgencyLeaderDto sysAgencyLeaderDto) {
        //校验一个用户只能是一个机构的负责人，每个机构只有一个负责人
        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new QueryWrapper<SysAgencyLeader>().lambda()
                .eq(SysAgencyLeader::getDelFlag, 1));
        if (sysAgencyLeaders.size() > 0) {
            //校验用户是否已经机构负责人
            List<String> userIdList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());
            if (userIdList.contains(sysAgencyLeaderDto.getUserId())) {
                throw new DescribeException(sysAgencyLeaderDto.getUserName() + "已是机构负责人，不可重复配置");
            }

            List<String> deptIdList = sysAgencyLeaders.stream().map(SysAgencyLeader::getDeptId).collect(Collectors.toList());
            if (deptIdList.contains(sysAgencyLeaderDto.getDeptId())) {
                throw new DescribeException(sysAgencyLeaderDto.getDeptName() + "机构已配置负责人，不可重复配置");
            }
        }


        SysAgencyLeader sysAgencyLeader = BeanUtil.copyProperties(sysAgencyLeaderDto, SysAgencyLeader.class);
        sysAgencyLeader.setCreateTime(new Date());
        SysUser user = BaseController.getUser();
        sysAgencyLeader.setCreateBy(user.getId());
        boolean b = sysAgencyLeaderMapper.insert(sysAgencyLeader) > 0;
        if (!StringUtils.isNullOrEmpty(sysAgencyLeaderDto.getSuggestId())) {
            //sysRelationPerson1为空是无上级
            SysRelationPerson sysRelationPerson = new SysRelationPerson();
            sysRelationPerson.setAgencyLeaderId(sysAgencyLeader.getUserId());
            sysRelationPerson.setCreateBy(user.getId());
            sysRelationPerson.setCreateTime(new Date());
            sysRelationPerson.setSuggestLevel(sysAgencyLeaderDto.getSuggestLevel());
            sysRelationPerson.setSuggestId(sysAgencyLeaderDto.getSuggestId());
            sysRelationPerson.setSource(0);
            sysRelationPerson.setType(1);
            b = sysRelationPersonMapper.insert(sysRelationPerson) > 0;
            //查询推荐人是否有上级 ：满足合伙人有多层关系
            List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getAgencyLeaderId, sysAgencyLeaderDto.getSuggestId())
                    .eq(SysRelationPerson::getType, 0));

            if (sysRelationPersonList.size() > 0) {
                for (SysRelationPerson sysRelation : sysRelationPersonList) {
                    SysRelationPerson sysRelationPerson1 = new SysRelationPerson();
                    SysPartner sysPartner2 = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                            .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, sysRelation.getSuggestId()));
                    sysRelationPerson1.setAgencyLeaderId(sysAgencyLeader.getUserId());
                    sysRelationPerson1.setCreateBy(user.getId());
                    sysRelationPerson1.setCreateTime(new Date());
                    sysRelationPerson1.setSuggestId(sysRelation.getSuggestId());
                    sysRelationPerson1.setSuggestLevel(sysPartner2.getType());
                    sysRelationPerson1.setSource(1);
                    sysRelationPerson1.setType(1);
                    b = sysRelationPersonMapper.insert(sysRelationPerson1) > 0;
                }

            }
        }
        return b;
    }


    @Override
    public List<SysUser> getLevelUser(String id) {
        SysDept sysDept = sysDeptMapper.selectById(id);
        List<SysUser> sysUserList = null;
        if (sysDept.getComlevel().equals("5")) {
            sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                    .ne(SysUser::getStatus, 0)
                    .likeRight(SysUser::getId, sysDept.getParentId())
                    .notLike(SysUser::getId, "M")
                    .orderByDesc(SysUser::getCreateTime));

        } else {
            sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                    .ne(SysUser::getStatus, 0)
                    .likeRight(SysUser::getId, id)
                    .notLike(SysUser::getId, "M")
                    .orderByDesc(SysUser::getCreateTime));


        }

        //工作室管理员： 已是管理员不能再成为管理员，已是合伙人的也不能设置为管理员
        List<SysPartner> sysPartnerList = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1));
        if (sysPartnerList.size() > 0) {
            List<String> stringList = sysPartnerList.stream().map(SysPartner::getUserId).collect(Collectors.toList());
            sysUserList = sysUserList.stream().filter(SysUser -> !stringList.contains(SysUser.getId())).collect(Collectors.toList());
        }
        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>().eq(SysAgencyLeader::getDelFlag, 1));
        if (sysAgencyLeaders.size() > 0) {
            List<String> stringList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());
            sysUserList = sysUserList.stream().filter(SysUser -> !stringList.contains(SysUser.getId())).collect(Collectors.toList());
        }

        return sysUserList;
    }

    @Override
    public List<SysAgencyLeader> getByUserIdList(List<String> collect) {
        return baseMapper.getByUserIdList(collect);
    }


    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean edit(SysAgencyLeaderDto sysAgencyLeaderDto) {
        //判断本月是否已修改比例
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        String format = simpleDateFormat.format(new Date());
        List<SysPartnerTime> sysPartnerTimes = sysPartnerTimeMapper.selectList(new LambdaQueryWrapper<SysPartnerTime>()
                .eq(SysPartnerTime::getCreateTime,format).eq(SysPartnerTime::getUserId,sysAgencyLeaderDto.getUserId()));
        if (sysPartnerTimes.size() > 0) {
            throw new DescribeException(format+"已设置过抽成比例,每月只能修改一次");
        }
        //不修改负责人userId传null
        String userId = sysAgencyLeaderDto.getUserId();
        String loginId = BaseController.getUserId();
        boolean b = false;
        SysAgencyLeader sysAgencyLeader1 = sysAgencyLeaderMapper.selectById(sysAgencyLeaderDto.getId());
        if (!sysAgencyLeader1.getUserId().equals(userId)) {
            //修改管理员
            List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new QueryWrapper<SysAgencyLeader>().lambda().eq(SysAgencyLeader::getDelFlag, 1));
            List<String> userIdList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());
            if (userIdList.contains(sysAgencyLeaderDto.getUserId())) {
                throw new DescribeException(sysAgencyLeaderDto.getUserName() + "已是机构负责人，不可重复配置");
            }
            List<SysPartner> sysPartners = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1));
            if (sysPartners.size() > 0) {
                List<String> list = sysPartners.stream().map(SysPartner::getUserId).collect(Collectors.toList());
                if (list.contains(sysAgencyLeaderDto.getUserId())) {
                    throw new DescribeException(sysAgencyLeaderDto.getUserName() + "已是合伙人，不可设置为机构负责人");
                }
            }

            //修改负责人时解除合伙人或者推荐人与机构负责人的关系
            List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getAgencyLeaderId, sysAgencyLeader1.getUserId())
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getType, 1));
            if (sysRelationPeople.size() > 0) {
                throw new DescribeException(sysAgencyLeader1.getUserName() + "有推荐关系，不允许修改");
            }

            SysAgencyLeader sysAgencyLeader = BeanUtil.copyProperties(sysAgencyLeaderDto, SysAgencyLeader.class);
            sysAgencyLeader.setUpdateTime(new Date());
            sysAgencyLeader.setUpdateBy(loginId);
            sysAgencyLeaderMapper.updateById(sysAgencyLeader);
            if (!sysAgencyLeaderDto.getSuggestId().isEmpty()) {
                //sysRelationPerson1为空是无上级
                SysRelationPerson sysRelationPerson = new SysRelationPerson();
                sysRelationPerson.setAgencyLeaderId(sysAgencyLeader.getUserId());
                sysRelationPerson.setCreateBy(loginId);
                sysRelationPerson.setCreateTime(new Date());
                sysRelationPerson.setSuggestId(sysAgencyLeaderDto.getSuggestId());
                sysRelationPerson.setSource(0);
                sysRelationPerson.setType(1);
                b = sysRelationPersonMapper.insert(sysRelationPerson) > 0;
                //查询推荐人是否有上级 ：满足合伙人有多层关系
                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getAgencyLeaderId, sysAgencyLeaderDto.getSuggestId())
                        .eq(SysRelationPerson::getType, 0));

                if (sysRelationPersonList.size() > 0) {
                    for (SysRelationPerson sysRelation : sysRelationPersonList) {
                        SysRelationPerson sysRelationPerson1 = new SysRelationPerson();
                        sysRelationPerson1.setAgencyLeaderId(sysAgencyLeader.getUserId());
                        sysRelationPerson1.setCreateBy(loginId);
                        sysRelationPerson1.setCreateTime(new Date());
                        sysRelationPerson1.setSuggestId(sysRelation.getSuggestId());
                        sysRelationPerson1.setSource(1);
                        sysRelationPerson1.setType(1);
                        b = sysRelationPersonMapper.insert(sysRelationPerson1) > 0;
                    }

                }
            }


        } else {
            if (StringUtils.isNullOrEmpty(sysAgencyLeader1.getSuggestId()) && !sysAgencyLeaderDto.getSuggestId().isEmpty()) {
                //之前推荐人为空。可以修改
                SysAgencyLeader sysAgencyLeader = BeanUtil.copyProperties(sysAgencyLeaderDto, SysAgencyLeader.class);
                sysAgencyLeader.setUpdateBy(loginId);
                b = sysAgencyLeaderMapper.updateById(sysAgencyLeader) > 0;

                //sysRelationPerson1为空是无上级
                SysRelationPerson sysRelationPerson = new SysRelationPerson();
                sysRelationPerson.setAgencyLeaderId(sysAgencyLeader.getUserId());
                sysRelationPerson.setCreateBy(loginId);
                sysRelationPerson.setCreateTime(new Date());
                sysRelationPerson.setSuggestId(sysAgencyLeaderDto.getSuggestId());
                sysRelationPerson.setSource(0);
                sysRelationPerson.setType(1);
                b = sysRelationPersonMapper.insert(sysRelationPerson) > 0;
                //查询推荐人是否有上级 ：满足合伙人有多层关系
                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getAgencyLeaderId, sysAgencyLeaderDto.getSuggestId())
                        .eq(SysRelationPerson::getType, 0));

                if (sysRelationPersonList.size() > 0) {
                    for (SysRelationPerson sysRelation : sysRelationPersonList) {
                        SysRelationPerson sysRelationPerson1 = new SysRelationPerson();
                        sysRelationPerson1.setAgencyLeaderId(sysAgencyLeader.getUserId());
                        sysRelationPerson1.setCreateBy(loginId);
                        sysRelationPerson1.setCreateTime(new Date());
                        sysRelationPerson1.setSuggestId(sysRelation.getSuggestId());
                        sysRelationPerson1.setSource(1);
                        sysRelationPerson1.setType(1);
                        b = sysRelationPersonMapper.insert(sysRelationPerson1) > 0;
                    }

                }

            } else {

                SysAgencyLeader sysAgencyLeader = new SysAgencyLeader();
                sysAgencyLeader.setId(sysAgencyLeaderDto.getId());
                sysAgencyLeader.setProportional(sysAgencyLeaderDto.getProportional());
                sysAgencyLeader.setUpdateBy(loginId);
                b = sysAgencyLeaderMapper.updateById(sysAgencyLeader) > 0;
            }

        }

        //修改抽成比例记录改变过程
        SysPartnerTime sysPartnerTime = new SysPartnerTime();
        sysPartnerTime.setType(2);
        sysPartnerTime.setCreateTime(format);
        sysPartnerTime.setUserId(sysAgencyLeaderDto.getUserId());
        sysPartnerTime.setUserName(sysAgencyLeaderDto.getUserName());
        sysPartnerTime.setNewProportional(sysAgencyLeaderDto.getProportional());
        sysPartnerTime.setOldProportional(sysAgencyLeader1.getProportional());

        sysPartnerTimeMapper.insert(sysPartnerTime);

        return b;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void editInfo(SysAgencyLeaderDeptDto sysAgencyLeaderDeptDto) {
        SysDept sysDept = sysAgencyLeaderDeptDto.getSysDept();
        SysDept byId = sysDeptService.getById(sysDept.getId());
        if (sysDept.getManagementSource() != null){
            if (!sysDept.getManagementSource().equals(byId.getManagementSource())) {
                throw new DescribeException("机构已被设置来源无法修改");
            }
        }
        sysDeptService.updateDept(sysDept);

        //不修改负责人userId传null
//        String userId = sysAgencyLeaderDeptDto.getSysAgencyLeader().getUserId();
//        String loginId = BaseController.getUserId();
//        SysAgencyLeader sysAgencyLeader1 = sysAgencyLeaderMapper.selectById(sysAgencyLeaderDeptDto.getSysAgencyLeader().getId());
//        //修改管理员
//        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new QueryWrapper<SysAgencyLeader>().lambda().eq(SysAgencyLeader::getDelFlag, 1));
//        List<String> userIdList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());
//        if (userIdList.contains(userId)) {
//            throw new DescribeException(sysAgencyLeaderDeptDto.getSysAgencyLeader().getUserName() + "已是工作室管理员，不可重复配置");
//        }
//        List<SysPartner> sysPartners = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1));
//        if (sysPartners.size() > 0) {
//            List<String> list = sysPartners.stream().map(SysPartner::getUserId).collect(Collectors.toList());
//            if (list.contains(sysAgencyLeaderDeptDto.getSysAgencyLeader().getUserId())) {
//                throw new DescribeException(sysAgencyLeaderDeptDto.getSysAgencyLeader().getUserName() + "已是合伙人，不可设置为机构负责人");
//            }
//        }
//
//        //修改负责人时解除合伙人或者推荐人与机构负责人的关系
//        List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
//                .eq(SysRelationPerson::getAgencyLeaderId, sysAgencyLeader1.getUserId())
//                .eq(SysRelationPerson::getDelFlag, 1)
//                .eq(SysRelationPerson::getType, 1));
//        if (sysRelationPeople.size() > 0) {
//            throw new DescribeException(sysAgencyLeader1.getUserName() + "有推荐关系，不允许修改");
//        }
//
//        SysAgencyLeader sysAgencyLeader = BeanUtil.copyProperties(sysAgencyLeaderDeptDto.getSysAgencyLeader(), SysAgencyLeader.class);
//        sysAgencyLeader.setUpdateTime(new Date());
//        sysAgencyLeader.setUpdateBy(loginId);
//        sysAgencyLeaderMapper.updateById(sysAgencyLeader);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean delById(Integer id) {
        SysAgencyLeader sysAgencyLeader1 = sysAgencyLeaderMapper.selectById(id);
        List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new UpdateWrapper<SysRelationPerson>().lambda()
                .eq(SysRelationPerson::getAgencyLeaderId, sysAgencyLeader1.getUserId())
                .eq(SysRelationPerson::getDelFlag, 1)
                .eq(SysRelationPerson::getType, 1));
        if (sysRelationPeople.size() > 0) {
            if (sysRelationPeople.get(0).getSuggestId() != null) {
                throw new DescribeException(sysAgencyLeader1.getUserName() + "有推荐人，不允许删除");
            }
        }
        SysAgencyLeader sysAgencyLeader = new SysAgencyLeader();
        sysAgencyLeader.setId(id);
        sysAgencyLeader.setDelFlag(0);

        return sysAgencyLeaderMapper.updateById(sysAgencyLeader) > 0;
    }

    @Override
    public List<SysAgencyLeaderVo> queryInfo(String id) {
        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                .eq(SysAgencyLeader::getDelFlag, 1).likeRight(StringUtils.isNotEmpty(id), SysAgencyLeader::getDeptId, id));

        return BeanUtil.copyToList(sysAgencyLeaders, SysAgencyLeaderVo.class);
    }

    @Override
    public BasePageResult<SysAgencyLeaderVo> queryPage(SysAgencyLeaderPageDto sysAgencyLeaderPageDto) {
        Page<SysAgencyLeader> page = new Page<>(sysAgencyLeaderPageDto.getPageNum(), sysAgencyLeaderPageDto.getPageSize());
        LambdaQueryWrapper<SysAgencyLeader> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(SysAgencyLeader::getDelFlag, 1);
        wrapper.like(StringUtils.isNotEmpty(sysAgencyLeaderPageDto.getUserId()),SysAgencyLeader::getUserId,sysAgencyLeaderPageDto.getUserId());
        wrapper.like(StringUtils.isNotEmpty(sysAgencyLeaderPageDto.getUserName()),SysAgencyLeader::getUserName,sysAgencyLeaderPageDto.getUserName());
        wrapper.likeRight(!StringUtils.isNullOrEmpty(sysAgencyLeaderPageDto.getDeptId()), SysAgencyLeader::getDeptId, sysAgencyLeaderPageDto.getDeptId());
        wrapper.orderByDesc(SysAgencyLeader::getId);

        Page<SysAgencyLeader> insOrdersPage = page(page, wrapper);
        List<SysAgencyLeader> records = insOrdersPage.getRecords();
        List<SysAgencyLeaderVo> sysAgencyLeaderVos = BeanUtil.copyToList(records, SysAgencyLeaderVo.class);
        if (sysAgencyLeaderVos.size() > 0) {
            for (SysAgencyLeaderVo sysAgencyLeaderVo : sysAgencyLeaderVos) {
                SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>().eq(SysDept::getId, sysAgencyLeaderVo.getDeptId()).eq(SysDept::getDelFlag, 0));
                if (sysDept != null) {
                    sysAgencyLeaderVo.setParentId(sysDept.getParentId());
                    sysAgencyLeaderVo.setDeptName(sysDept.getName());
                }
                SysUser sysUser = sysUserMapper.selectById(sysAgencyLeaderVo.getUserId());
                sysAgencyLeaderVo.setUserName(sysUser.getName());
            }
        }

        return new BasePageResult<>(sysAgencyLeaderPageDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                sysAgencyLeaderVos);
    }

    @Override
    public SysAgencyLeaderVo queryById(Integer id) {
        SysAgencyLeader sysAgencyLeader = new SysAgencyLeader();
        sysAgencyLeader.setId(id);
        SysAgencyLeader sysAgencyLeader1 = sysAgencyLeaderMapper.selectById(sysAgencyLeader);
        SysAgencyLeaderVo sysAgencyLeaderVo = BeanUtil.copyProperties(sysAgencyLeader1, SysAgencyLeaderVo.class);
        SysUser sysUser = sysUserMapper.selectById(sysAgencyLeaderVo.getUserId());
        sysAgencyLeaderVo.setUserName(sysUser.getName());
        SysUser sysUser1 = sysUserMapper.selectById(sysAgencyLeaderVo.getSuggestId());
        if (sysUser1 != null) {
            sysAgencyLeaderVo.setSuggestName(sysUser1.getName());
        }
        return sysAgencyLeaderVo;
    }

    @Override
    public boolean checkUserId(String userId) {
        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new QueryWrapper<SysAgencyLeader>().lambda().eq(SysAgencyLeader::getDelFlag, 1));
        if (sysAgencyLeaders.size() > 0) {
            //校验用户是否已经配置机构负责人
            List<String> userIdList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());
            return userIdList.contains(userId);

        }
        return false;
    }

    @Override
    public AgencyExtractFee queryExtractFee(String userId) {
        AgencyExtractFee agencyExtractFee = new AgencyExtractFee();
        //判断当前登录用户是合伙人还是机构负责人
        boolean b1 = sysPartnerService.checkPartner(userId);
        if (b1) {
            //总保费
            BigDecimal bigDecimal = new BigDecimal("0.00");
            //已提现抽成费用
            BigDecimal historyFee = new BigDecimal("0.00");
            //合伙人信息
            SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                    .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
            //填充查询人的姓名和机构
            agencyExtractFee.setUserId(sysPartner.getUserId());
            agencyExtractFee.setUserName(sysPartner.getUserName());
            SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                    .eq(SysUser::getId, sysPartner.getUserId())
                    .ne(SysUser::getStatus, 0));
            agencyExtractFee.setUserName(sysUser.getName());
            agencyExtractFee.setDeptId(sysUser.getDeptId());
            SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>()
                    .eq(SysDept::getId, sysUser.getDeptId()).eq(SysDept::getDelFlag, 0));
            agencyExtractFee.setDeptName(sysDept.getName());
            //查询所有推荐的机构负责人核算总保费
            List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId).eq(SysRelationPerson::getType, 1));
            if (sysRelationPeople.size() > 0) {
                List<String> agencyLeaderIds = sysRelationPeople.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                for (String agencyLeaderId : agencyLeaderIds) {

                    SysAgencyLeader sysAgencyLeaders = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>().eq(SysAgencyLeader::getUserId, agencyLeaderId)
                            .eq(SysAgencyLeader::getDelFlag, 1));
                    if (sysAgencyLeaders != null) {
                        agencyExtractFee.setProportional(sysPartner.getProportional());
                        //筛选订单，选择时间
                        Date updateTime = sysAgencyLeaders.getUpdateTime();
                        Date createTime = sysAgencyLeaders.getCreateTime();
                        String dateStr = "";
                        if (updateTime != null) {
                            dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(updateTime);
                            agencyExtractFee.setStartTime(updateTime);
                        } else {
                            dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                            agencyExtractFee.setStartTime(createTime);
                        }
                        HashMap<String, BigDecimal> map = baseMapper.getBigDecimalNum(sysAgencyLeaders.getDeptId(), dateStr,null,null);
                        if (CollectionUtil.isNotEmpty(map)) {
                            bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : map.get("bigDecimal"));
                        }
                    }
                }
                agencyExtractFee.setSumpremium(bigDecimal);
                //总保费*比例/100  保留两位小数
                BigDecimal multiply = bigDecimal.multiply(new BigDecimal(agencyExtractFee.getProportional())
                        .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                agencyExtractFee.setExtractFee(multiply);
                // 填充 已提现抽成费用和可提现抽成费用
                List<SysAgencyFeeApproval> sysAgencyFeeApprovals = sysAgencyFeeApprovalMapper.selectList(new LambdaQueryWrapper<SysAgencyFeeApproval>()
                        .eq(SysAgencyFeeApproval::getUserId, userId)
                        .eq(SysAgencyFeeApproval::getStatus, 1));
                if (sysAgencyFeeApprovals.size() > 0) {
                    for (SysAgencyFeeApproval sysAgencyFeeApproval : sysAgencyFeeApprovals) {
                        historyFee = historyFee.add(sysAgencyFeeApproval.getHistoryFee());
                    }
                }
                if (!bigDecimal.equals(new BigDecimal("0.00"))) {
                    //已提现
                    agencyExtractFee.setHistoryFee(historyFee);
                    //可提现 = 总抽成-已提现
                    agencyExtractFee.setCashFee(multiply.subtract(historyFee));
                } else {
                    agencyExtractFee.setHistoryFee(new BigDecimal("0.00"));
                    agencyExtractFee.setCashFee(multiply.subtract(new BigDecimal("0.00")));
                }

            }
            return agencyExtractFee;
        }
        //校验是否为机构负责人
        boolean b = this.checkUserId(userId);
        if (b) {
            SysAgencyLeader sysAgencyLeaders = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>()
                    .eq(SysAgencyLeader::getUserId, userId).eq(SysAgencyLeader::getDelFlag, 1));
            if (sysAgencyLeaders != null) {
                //填充查询人的姓名和机构
                agencyExtractFee.setUserId(sysAgencyLeaders.getUserId());
                agencyExtractFee.setUserName(sysAgencyLeaders.getUserName());
                SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                        .eq(SysUser::getId, sysAgencyLeaders.getUserId())
                        .ne(SysUser::getStatus, 0));
                agencyExtractFee.setUserName(sysUser.getName());
                agencyExtractFee.setDeptId(sysUser.getDeptId());
                SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>()
                        .eq(SysDept::getId, sysUser.getDeptId()).eq(SysDept::getDelFlag, 0));
                agencyExtractFee.setDeptName(sysDept.getName());
                //总保费
                BigDecimal bigDecimal = new BigDecimal("0.00");
                //已提现抽成费用
                BigDecimal historyFee = new BigDecimal("0.00");

                agencyExtractFee.setProportional(sysAgencyLeaders.getProportional());

                //筛选订单，选择时间
                Date updateTime = sysAgencyLeaders.getUpdateTime();
                Date createTime = sysAgencyLeaders.getCreateTime();
                String dateStr = "";
                if (updateTime != null) {
                    dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(updateTime);
                    agencyExtractFee.setStartTime(updateTime);
                } else {
                    dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                    agencyExtractFee.setStartTime(createTime);
                }
                HashMap<String, BigDecimal> map = baseMapper.getBigDecimalNum(sysAgencyLeaders.getDeptId(), dateStr,null,null);
                if (CollectionUtil.isNotEmpty(map)) {
                    bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : map.get("bigDecimal"));
                }
                agencyExtractFee.setSumpremium(bigDecimal);
                BigDecimal multiply = bigDecimal.multiply(new BigDecimal(agencyExtractFee.getProportional())
                        .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                agencyExtractFee.setExtractFee(multiply);
                // 填充 已提现抽成费用和可提现抽成费用
                List<SysAgencyFeeApproval> sysAgencyFeeApprovals = sysAgencyFeeApprovalMapper.selectList(new LambdaQueryWrapper<SysAgencyFeeApproval>()
                        .eq(SysAgencyFeeApproval::getUserId, userId)
                        .eq(SysAgencyFeeApproval::getStatus, 1));
                if (sysAgencyFeeApprovals.size() > 0) {
                    for (SysAgencyFeeApproval sysAgencyFeeApproval : sysAgencyFeeApprovals) {
                        historyFee = historyFee.add(sysAgencyFeeApproval.getHistoryFee());
                    }
                }
                if (!bigDecimal.equals(new BigDecimal("0.00"))) {
                    //已提现
                    agencyExtractFee.setHistoryFee(historyFee);
                    //可提现 = 总抽成-已提现
                    agencyExtractFee.setCashFee(multiply.subtract(historyFee));
                } else {
                    agencyExtractFee.setHistoryFee(new BigDecimal("0.00"));
                    agencyExtractFee.setCashFee(multiply.subtract(new BigDecimal("0.00")));
                }

            }
            return agencyExtractFee;
        }


        return agencyExtractFee;
    }

    @Override
    public BasePageResult<AgencyExtractFeeVo> queryExtractFeeList(SysAgencyLeaderPageDto sysAgencyLeaderPageDto) {
        List<AgencyExtractFeeVo> agencyExtractFeeList = new ArrayList<>();

        Page<SysAgencyLeader> page = new Page<>(sysAgencyLeaderPageDto.getPageNum(), sysAgencyLeaderPageDto.getPageSize());
        LambdaQueryWrapper<SysAgencyLeader> wrapper = new LambdaQueryWrapper<>();
        wrapper.like(StringUtils.isNotEmpty(sysAgencyLeaderPageDto.getUserId()), SysAgencyLeader::getUserId, sysAgencyLeaderPageDto.getUserId());
        wrapper.like(StringUtils.isNotEmpty(sysAgencyLeaderPageDto.getUserName()), SysAgencyLeader::getUserName, sysAgencyLeaderPageDto.getUserName());
        wrapper.eq(SysAgencyLeader::getDelFlag, 1);
        wrapper.orderByDesc(SysAgencyLeader::getId);

        Page<SysAgencyLeader> insOrdersPage = page(page, wrapper);
        List<SysAgencyLeader> records = insOrdersPage.getRecords();
        if (records.size() > 0) {
            for (SysAgencyLeader sysAgencyLeaders : records) {
                AgencyExtractFeeVo agencyExtractFee = new AgencyExtractFeeVo();
                //总保费
                BigDecimal bigDecimal = BigDecimal.ZERO;
                //已提现抽成费用
                BigDecimal historyFee = BigDecimal.ZERO;
                SysUser sysUser = sysUserMapper.selectById(sysAgencyLeaders.getUserId());
                SysDept sysDept = sysDeptMapper.selectById(sysAgencyLeaders.getDeptId());
                agencyExtractFee.setUserId(sysAgencyLeaders.getUserId());
                agencyExtractFee.setUserName(sysUser.getName());
                agencyExtractFee.setDeptId(sysAgencyLeaders.getDeptId());
                agencyExtractFee.setDeptName(sysDept.getName());
                agencyExtractFee.setProportional(sysAgencyLeaders.getProportional());
                //筛选订单，选择时间
                Date updateTime = sysAgencyLeaders.getUpdateTime();
                Date createTime = sysAgencyLeaders.getCreateTime();
                String dateStr = "";
                if (updateTime != null) {
                    dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(updateTime);
                    agencyExtractFee.setStartTime(updateTime);
                } else {
                    dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                    agencyExtractFee.setStartTime(createTime);
                }
                HashMap<String, BigDecimal> map = baseMapper.getBigDecimalNum(sysAgencyLeaders.getDeptId(), dateStr,null,null);
                if (CollectionUtil.isNotEmpty(map)) {

                    bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : map.get("bigDecimal"));
                }
                agencyExtractFee.setSumpremium(bigDecimal);
                BigDecimal multiply = bigDecimal.multiply(new BigDecimal(agencyExtractFee.getProportional())
                        .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                agencyExtractFee.setExtractFee(multiply);
                // 填充 已提现抽成费用和可提现抽成费用
                List<SysAgencyFeeApproval> sysAgencyFeeApprovals = sysAgencyFeeApprovalMapper.selectList(new LambdaQueryWrapper<SysAgencyFeeApproval>()
                        .eq(SysAgencyFeeApproval::getUserId, sysAgencyLeaders.getUserId())
                        .eq(SysAgencyFeeApproval::getStatus, 1));
                if (sysAgencyFeeApprovals.size() > 0) {
                    for (SysAgencyFeeApproval sysAgencyFeeApproval : sysAgencyFeeApprovals) {
                        historyFee = historyFee.add(sysAgencyFeeApproval.getHistoryFee());
                    }
                }

                if (!bigDecimal.equals(BigDecimal.ZERO)) {
                    //已提现
                    agencyExtractFee.setHistoryFee(historyFee);
                    //可提现 = 总抽成-已提现
                    agencyExtractFee.setCashFee(multiply.subtract(historyFee));
                } else {
                    agencyExtractFee.setHistoryFee(BigDecimal.ZERO);
                    agencyExtractFee.setCashFee(multiply.subtract(BigDecimal.ZERO));
                }
                agencyExtractFeeList.add(agencyExtractFee);

            }

        }

        return new BasePageResult<>(sysAgencyLeaderPageDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                agencyExtractFeeList);
    }


    @Override
    public BasePageResult<AgencyExtractFeeVo> queryExtractFeeAlls(SysAgencyLeaderPageDto sysAgencyLeaderPageDto) {
        List<AgencyExtractFeeVo> agencyExtractFeeList = new ArrayList<>();

        Page<SysAgencyLeader> page = new Page<>(sysAgencyLeaderPageDto.getPageNum(), sysAgencyLeaderPageDto.getPageSize());
        LambdaQueryWrapper<SysAgencyLeader> wrapper = new LambdaQueryWrapper<>();
        wrapper.like(StringUtils.isNotEmpty(sysAgencyLeaderPageDto.getUserId()), SysAgencyLeader::getUserId, sysAgencyLeaderPageDto.getUserId());
        wrapper.like(StringUtils.isNotEmpty(sysAgencyLeaderPageDto.getUserName()), SysAgencyLeader::getUserName, sysAgencyLeaderPageDto.getUserName());
        wrapper.eq(SysAgencyLeader::getDelFlag, 1);
        wrapper.orderByDesc(SysAgencyLeader::getId);

        Page<SysAgencyLeader> insOrdersPage = page(page, wrapper);
        List<SysAgencyLeader> records = insOrdersPage.getRecords();
        if (records.size() > 0) {
            for (SysAgencyLeader sysAgencyLeaders : records) {
                AgencyExtractFeeVo agencyExtractFee = new AgencyExtractFeeVo();
                String userId = sysAgencyLeaders.getUserId();
                //已提现抽成费用
                BigDecimal historyFee = BigDecimal.ZERO;
                SysUser sysUser = sysUserMapper.selectById(userId);
                SysDept sysDept = sysDeptMapper.selectById(sysAgencyLeaders.getDeptId());
                agencyExtractFee.setUserId(userId);
                agencyExtractFee.setUserName(sysUser.getName());
                agencyExtractFee.setDeptId(sysAgencyLeaders.getDeptId());
                agencyExtractFee.setDeptName(sysDept.getName());

                SysPartnerAccount sysPartnerAccount = sysPartnerAccountMapper.selectOne(new LambdaQueryWrapper<SysPartnerAccount>().eq(SysPartnerAccount::getUserId, userId));
                if (sysPartnerAccount != null) {
                    BigDecimal sumPremium = sysPartnerAccount.getSumPremium();
                    BigDecimal extractFee = sysPartnerAccount.getExtractFee();
                    agencyExtractFee.setSumpremium(sumPremium);
                    agencyExtractFee.setExtractFee(extractFee);

                    // 填充 已提现抽成费用和可提现抽成费用
                    List<SysAgencyFeeApproval> sysAgencyFeeApprovals = sysAgencyFeeApprovalMapper.selectList(new LambdaQueryWrapper<SysAgencyFeeApproval>()
                            .eq(SysAgencyFeeApproval::getUserId, sysAgencyLeaders.getUserId())
                            .eq(SysAgencyFeeApproval::getStatus, 1));
                    if (sysAgencyFeeApprovals.size() > 0) {
                        for (SysAgencyFeeApproval sysAgencyFeeApproval : sysAgencyFeeApprovals) {
                            historyFee = historyFee.add(sysAgencyFeeApproval.getHistoryFee());
                        }
                    }

                    if (!extractFee.equals(BigDecimal.ZERO)) {
                        //已提现
                        agencyExtractFee.setHistoryFee(historyFee);
                        //可提现 = 总抽成-已提现
                        agencyExtractFee.setCashFee(extractFee.subtract(historyFee));
                    } else {
                        agencyExtractFee.setHistoryFee(BigDecimal.ZERO);
                        agencyExtractFee.setCashFee(extractFee.subtract(BigDecimal.ZERO));
                    }
                }
                agencyExtractFeeList.add(agencyExtractFee);

            }

        }

        return new BasePageResult<>(sysAgencyLeaderPageDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                agencyExtractFeeList);
    }


    @Override
    public BasePageResult<TeamInformation> queryTeamInfoPage(TeamInformationDto teamInformationDto) {
        String userId = BaseController.getUserId();
        List<TeamInformation> informationList = new ArrayList<>();
        //机构负责人查询机构下的团队
        SysAgencyLeader sysAgencyLeaders = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>().eq(SysAgencyLeader::getUserId, userId)
                .eq(SysAgencyLeader::getDelFlag, 1));
        if (sysAgencyLeaders == null) return null;

        Page<SysDept> page = new Page<>(teamInformationDto.getPageNum(), teamInformationDto.getPageSize());

        LambdaQueryWrapper<SysDept> wrapper = new LambdaQueryWrapper<>();
        wrapper.likeRight(SysDept::getId, sysAgencyLeaders.getDeptId())
                .isNull(SysDept::getComlevel).eq(SysDept::getDelFlag, 0)
                .eq(SysDept::getManagementSource, sysAgencyLeaders.getSource())
                .like(StringUtils.isNotEmpty(teamInformationDto.getDeptName()), SysDept::getName, teamInformationDto.getDeptName())
                .orderByDesc(SysDept::getCreateTime);

        Page<SysDept> insOrdersPage = sysDeptService.page(page, wrapper);
        List<SysDept> sysDeptList = insOrdersPage.getRecords();

        if (sysDeptList.size() > 0) {
            //总保费
            BigDecimal bigDecimal = new BigDecimal("0.00");
            for (SysDept sysDept : sysDeptList) {
                TeamInformation teamInformation = new TeamInformation();
                SysUser sysUser = sysUserMapper.selectById(sysAgencyLeaders.getUserId());
                teamInformation.setUserName(sysUser.getName());
                teamInformation.setDeptId(sysDept.getId());
                teamInformation.setDeptName(sysDept.getName());
                List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                        .likeRight(SysUser::getId, sysDept.getId()).ne(SysUser::getStatus, 0));
                teamInformation.setDeptManNum(sysUsers.size());
                List<InsOrders> insOrderList;
                //筛选订单，选择时间
                Date updateTime = sysAgencyLeaders.getUpdateTime();
                if (updateTime == null) {
                    //机构下所有订单
                    insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                            .likeRight(InsOrders::getDeptid, sysDept.getId())
                            .ge(InsOrders::getCreatetime, sysAgencyLeaders.getCreateTime())
                            .ge(StringUtils.isNotEmpty(teamInformationDto.getBeginTime()), InsOrders::getCreatetime, teamInformationDto.getBeginTime())
                            .le(StringUtils.isNotEmpty(teamInformationDto.getEndTime()), InsOrders::getCreatetime, teamInformationDto.getEndTime()));
                    teamInformation.setStartTime(sysAgencyLeaders.getCreateTime());

                } else {
                    insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                            .likeRight(InsOrders::getDeptid, sysDept.getId())
                            .ge(InsOrders::getCreatetime, updateTime)
                            .ge(StringUtils.isNotEmpty(teamInformationDto.getBeginTime()), InsOrders::getCreatetime, teamInformationDto.getBeginTime())
                            .le(StringUtils.isNotEmpty(teamInformationDto.getEndTime()), InsOrders::getCreatetime, teamInformationDto.getEndTime()));
                    teamInformation.setStartTime(updateTime);
                }

                if (insOrderList.size() > 0) {
                    List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                    //查询订单下的所有子订单 保费和
                    HashMap<String, Object> map = sysAgencyLeaderMapper.getAreaCompanyByUserId(collect);
                    if (CollectionUtil.isNotEmpty(map)) {
                        bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : (BigDecimal)map.get("bigDecimal"));
                    }

                }
                teamInformation.setSumpremium(bigDecimal);
                int num = 0;
                // 查团队有几人出单 :订单表中userid相等同时在 子订单表中状态为3已承保才为出单
                List<String> userIdList = sysUsers.stream().map(SysUser::getId).collect(Collectors.toList());
                for (String s : userIdList) {
                    List<InsOrders> collect = insOrderList.stream().filter(InsOrders -> InsOrders.getUserid().equals(s)).collect(Collectors.toList());
                    if (collect.size() > 0) {
                        List<String> insOrders = collect.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                        List<InsAreaCompany> insAreaCompanies1 = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                                .in(InsAreaCompany::getOrderno, insOrders)
                                .eq(InsAreaCompany::getOrderstatus, 3));
                        if (insAreaCompanies1.size() > 0) {
                            num++;
                        }

                    }
                }
                teamInformation.setOrderManNum(num);
                informationList.add(teamInformation);

            }

        }
        return new BasePageResult<>(teamInformationDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                informationList);
    }

    @Override
    public BasePageResult<AgencyTeamVo> queryWorkroomPage(AgencyTeamDto agencyTeamDto) {
        List<AgencyTeamVo> agencyTeamVoList = new ArrayList<>();
        String userId = BaseController.getUserId();
        int source = agencyTeamDto.getSource();
        List<SysRelationPerson> sysRelationPersonList = null;
        //判断是0:直接推荐；1：间接推荐
        if (source == 0) {
            sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId)
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getSource, 0)
                    .eq(SysRelationPerson::getType, 1));
        } else {
            sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId)
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getSource, 1)
                    .eq(SysRelationPerson::getType, 1));

        }
        List<String> ids = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
        if (CollectionUtil.isNotEmpty(ids)) {
            //分页查询推荐的机构信息
            Page<SysAgencyLeader> page = new Page<>(agencyTeamDto.getPageNum(), agencyTeamDto.getPageSize());

            LambdaQueryWrapper<SysAgencyLeader> wrapper = new LambdaQueryWrapper<>();
            wrapper.like(StringUtils.isNotEmpty(agencyTeamDto.getDeptName()), SysAgencyLeader::getDeptName, agencyTeamDto.getDeptName());
            wrapper.in(SysAgencyLeader::getUserId, ids);
            wrapper.eq(SysAgencyLeader::getDelFlag, 1);
            wrapper.orderByDesc(SysAgencyLeader::getId);

            Page<SysAgencyLeader> insOrdersPage = page(page, wrapper);
            List<SysAgencyLeader> leaderList = insOrdersPage.getRecords();
            if (leaderList.size() > 0) {
                for (SysAgencyLeader sysAgencyLeader : leaderList) {
                    //总保费
                    BigDecimal bigDecimal = new BigDecimal("0.00");
                    int deptManNum = 0;
                    AgencyTeamVo agencyTeamVo = new AgencyTeamVo();
                    agencyTeamVo.setDeptId(sysAgencyLeader.getDeptId());
                    agencyTeamVo.setDeptName(sysAgencyLeader.getDeptName());
                    //获取机构下的团队
                    List<SysDept> sysDeptList = sysDeptMapper.selectList(new LambdaQueryWrapper<SysDept>()
                            .likeRight(SysDept::getId, sysAgencyLeader.getDeptId())
                            .isNull(SysDept::getComlevel).eq(SysDept::getDelFlag, 0)
                            .eq(SysDept::getManagementSource, sysAgencyLeader.getSource()));

                    agencyTeamVo.setDeptNum(sysDeptList.size());
                    if (sysDeptList.size() > 0) {
                        for (SysDept sysDept : sysDeptList) {

                            List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                                    .likeRight(SysUser::getId, sysDept.getId()).ne(SysUser::getStatus, 0));
                            deptManNum = deptManNum + sysUsers.size();

                            Date updateTime = sysAgencyLeader.getUpdateTime();
                            Date createTime = sysAgencyLeader.getCreateTime();

                            String dateStr = "";
                            if (updateTime != null) {
                                dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(updateTime);
                                agencyTeamVo.setStartTime(updateTime);
                            } else {
                                dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                                agencyTeamVo.setStartTime(createTime);
                            }
                            HashMap<String, BigDecimal> map = baseMapper.getBigDecimalNum(sysDept.getId(), dateStr,null,null);
                            if (CollectionUtil.isNotEmpty(map)) {

                                bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : map.get("bigDecimal"));
                            }

                        }

                    }
                    agencyTeamVo.setDeptManNum(deptManNum);
                    agencyTeamVo.setSumpremium(bigDecimal);
                    if (!bigDecimal.equals(new BigDecimal("0.00"))) {

                        BigDecimal multiply = bigDecimal.multiply(new BigDecimal(sysAgencyLeader.getProportional())
                                .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                        agencyTeamVo.setExtractFee(multiply);
                    } else {
                        agencyTeamVo.setExtractFee(new BigDecimal("0.00"));
                    }
                    agencyTeamVoList.add(agencyTeamVo);

                }

            }

            return new BasePageResult<>(agencyTeamDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                    agencyTeamVoList);
        }

        return new BasePageResult<>(agencyTeamDto.getPageNum(), agencyTeamDto.getPageSize(), 0L, 0L,
                agencyTeamVoList);
    }

    @Override
    public List<SysAgencyLeaderVo> queryAgencyLeader(String userId) {
        List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getSuggestId, userId).eq(SysRelationPerson::getType, 1));
        if (sysRelationPeople.size() > 0) {
            //获取所有推荐的机构负责人id
            List<String> agencyLeaderIds = sysRelationPeople.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());

            //获取机构负责人信息
            List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                    .in(SysAgencyLeader::getUserId, agencyLeaderIds)
                    .eq(SysAgencyLeader::getDelFlag, 1)
                    .orderByDesc(SysAgencyLeader::getId));

            return BeanUtil.copyToList(sysAgencyLeaders, SysAgencyLeaderVo.class);
        }

        return null;
    }


    @Override
    public BasePageResult<TeamUserInfoVo> queryTeamUser(TeamUserInfoDto teamUserInfoDto) {
        List<TeamUserInfoVo> teamUserInfoVoList = new ArrayList<>();
        Page<SysUser> page = new Page<>(teamUserInfoDto.getPageNum(), teamUserInfoDto.getPageSize());
        LambdaQueryWrapper<SysUser> wrapper = new LambdaQueryWrapper<>();
        wrapper.likeRight(SysUser::getId, teamUserInfoDto.getDeptId());
        wrapper.eq(SysUser::getStatus, 1);
        wrapper.orderByDesc(SysUser::getCreateTime);

        Page<SysUser> insOrdersPage = sysUserService.page(page, wrapper);
        List<SysUser> sysUsers = insOrdersPage.getRecords();

        //总保费
        for (SysUser sysUser : sysUsers) {
            List<InsOrders> insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                    .ge(InsOrders::getCreatetime, teamUserInfoDto.getStartTime())
                    .ge(StringUtils.isNotEmpty(teamUserInfoDto.getBeginTime()), InsOrders::getCreatetime, teamUserInfoDto.getBeginTime())
                    .le(StringUtils.isNotEmpty(teamUserInfoDto.getEndTime()), InsOrders::getCreatetime, teamUserInfoDto.getEndTime())
                    .eq(InsOrders::getUserid, sysUser.getId()));
            //总保费
            BigDecimal bigDecimal = new BigDecimal("0.00");
            TeamUserInfoVo teamUserInfoVo = new TeamUserInfoVo();
            teamUserInfoVo.setUserId(sysUser.getId());
            teamUserInfoVo.setUserName(sysUser.getName());
            if (insOrderList.size() > 0) {
                List<String> orderNoList = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                //单个人员查询订单下的所有子订单总保费  '订单状态(0 报价 1 待核保 2 已核保待缴费 3 核保退回 4 核保不通过)',
                HashMap<String, Object> map = sysAgencyLeaderMapper.getAreaCompanyByUserId(orderNoList);
                if (CollectionUtil.isNotEmpty(map)) {
                    bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : (BigDecimal)map.get("bigDecimal"));
                    Long issueNum = (Long)map.get("issueNum");
                    teamUserInfoVo.setIssueNum(issueNum.intValue());
                }
//                //出单笔数
                teamUserInfoVo.setSumpremium(bigDecimal);
                //报价笔数
                Long quoteNum = insAreaCompanyMapper.selectCount(new LambdaQueryWrapper<InsAreaCompany>()
                        .in(InsAreaCompany::getOrderno, orderNoList));
                teamUserInfoVo.setQuoteNum(quoteNum);
                //核保笔数  订单状态(0 报价中 1 待核保 2 已核保待缴费 3已承保 4 核保退回)
                List<Integer> integers = Arrays.asList(2, 3, 4);
                Long underwriteNum = insAreaCompanyMapper.selectCount(new LambdaQueryWrapper<InsAreaCompany>()
                        .in(InsAreaCompany::getOrderno, orderNoList)
                        .in(InsAreaCompany::getOrderstatus, integers));

                teamUserInfoVo.setUnderwriteNum(underwriteNum);
                teamUserInfoVoList.add(teamUserInfoVo);
            } else {
                teamUserInfoVo.setIssueNum(0);
                teamUserInfoVo.setSumpremium(bigDecimal);
                teamUserInfoVo.setQuoteNum(Long.valueOf("0"));
                teamUserInfoVo.setUnderwriteNum(Long.valueOf("0"));
                teamUserInfoVoList.add(teamUserInfoVo);
            }
        }

        return new BasePageResult<>(teamUserInfoDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                teamUserInfoVoList);
    }

    @Override
    public List<SysUser> queryAgencyUser(String deptId) {

        return sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                .ne(SysUser::getStatus, 0)
                .likeRight(StringUtils.isNotEmpty(deptId), SysUser::getId, deptId));
    }

    @Override
    public IPage<AgencyUserInsAreaVo> queryAgencyUserInsAreaPage(AgencyUserInsAreaDto agencyUserInsAreaDto) {
        Page page = new Page(agencyUserInsAreaDto.getPageNum(), agencyUserInsAreaDto.getPageSize());

        IPage<AgencyUserInsAreaVo> agencyUserInsAreaVoIPage = insAreaCompanyMapper.queryAgencyUserInsAreaPage(page, agencyUserInsAreaDto);
        List<AgencyUserInsAreaVo> records = agencyUserInsAreaVoIPage.getRecords();
        if (records.size() > 0) {
            for (AgencyUserInsAreaVo record : records) {
                record.setSumpremium(record.getJqpremium().add(record.getJypremium()).add(record.getSypremium()));
            }
        }

        return agencyUserInsAreaVoIPage;
    }

    @Override
    public IPage<AgencyUserInsAreaVo> queryInsAreaPageById(AgencyUserInsAreaDto agencyUserInsAreaDto) {
        Page page = new Page(agencyUserInsAreaDto.getPageNum(), agencyUserInsAreaDto.getPageSize());

        IPage<AgencyUserInsAreaVo> agencyUserInsAreaVoIPage = sysPremiumDetailsMapper.queryInsAreaPageById(page, agencyUserInsAreaDto);
        return agencyUserInsAreaVoIPage;
    }

    @Override
    public HttpResult queryUserInsAreaExcel(AgencyUserInsAreaDto agencyUserInsAreaDto) {


        List<AgencyUserInsAreaVo> agencyUserInsAreaVos = baseMapper.queryUserInsAreaExcel(agencyUserInsAreaDto);
        if (agencyUserInsAreaVos.size()>0) {
            for (AgencyUserInsAreaVo agencyUserInsAreaVo : agencyUserInsAreaVos) {
                agencyUserInsAreaVo.setSumpremium(agencyUserInsAreaVo.getJqpremium().add(agencyUserInsAreaVo.getJypremium())
                        .add(agencyUserInsAreaVo.getSypremium()));
                agencyUserInsAreaVo.setOrderstatus("已承保");
            }
        }
        String uploadPath = this.uploadPath + "/excel/";
        Path path = Paths.get(uploadPath);
        if (!Files.exists(path)) {
            try {
                Files.createDirectories(path);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        String fileName = EasyExcelUtils.downExcel(uploadPath, "人员保费明细导出", AgencyUserInsAreaVo.class, agencyUserInsAreaVos);
        return HttpResult.ok("导出成功", uploadUrl + "excel/" + fileName);

    }

    @Override
    public boolean editAll(SysAgencyLeaderListDto sysAgencyLeaderDto) {
        String loginId = BaseController.getUserId();
        if (sysAgencyLeaderDto ==null) {
            throw new DescribeException( "批量修改参数不能为空");
        }


        return sysAgencyLeaderMapper.updateByIds(sysAgencyLeaderDto)>0;
    }

    @Override
    public SysAgencyLeaderDeptVo queryInfoById(Integer id) {
        SysAgencyLeaderDeptVo sysAgencyLeaderDeptVo = new SysAgencyLeaderDeptVo();
        SysAgencyLeader sysAgencyLeader = baseMapper.selectById(id);
        SysUser sysUser = sysUserMapper.selectById(sysAgencyLeader.getSuggestId());
        sysAgencyLeader.setSuggestName(sysUser.getName());
        sysAgencyLeaderDeptVo.setSysAgencyLeader(sysAgencyLeader);

        SysDept sysDept = sysDeptMapper.selectById(sysAgencyLeader.getDeptId());
        sysAgencyLeaderDeptVo.setSysDept(sysDept);

        return sysAgencyLeaderDeptVo;
    }


}