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.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ydtech.aop.exception.DescribeException;
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.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.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
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;


    @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() + "机构已配置负责人，不可重复配置");
            }
        }

        List<SysPartner> sysPartners = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1));
        if (sysPartners.size() > 0) {
            List<String> userIdList = sysPartners.stream().map(SysPartner::getUserId).collect(Collectors.toList());
            if (userIdList.contains(sysAgencyLeaderDto.getUserId())) {
                throw new DescribeException(sysAgencyLeaderDto.getUserName() + "已是合伙人，不可设置为机构负责人");
            }
        }


        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.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(user.getId());
                    sysRelationPerson1.setCreateTime(new Date());
                    sysRelationPerson1.setSuggestId(sysRelation.getSuggestId());
                    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>()
                    .eq(SysUser::getStatus, 1)
                    .likeRight(SysUser::getId, sysDept.getParentId())
                    .notLike(SysUser::getId, "M")
                    .orderByDesc(SysUser::getCreateTime));

        } else {
            sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                    .eq(SysUser::getStatus, 1)
                    .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) {
        //不修改负责人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;
            }

        }

        return b;
    }

    @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.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());
                }
            }
        }

        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);

        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())
                    .eq(SysUser::getStatus, 1));
            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());
                        List<InsOrders> insOrderList;
                        //筛选订单，选择时间
                        Date updateTime = sysAgencyLeaders.getUpdateTime();
                        if (updateTime == null) {
                            //机构下所有订单
                            insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                                    .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                                    .ge(InsOrders::getCreatetime, sysAgencyLeaders.getCreateTime()));
                            agencyExtractFee.setStartTime(sysAgencyLeaders.getCreateTime());
                        } else {
                            insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                                    .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                                    .ge(InsOrders::getCreatetime, updateTime));
                            agencyExtractFee.setStartTime(updateTime);
                        }
                        if (insOrderList.size() > 0) {
                            List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                            //查询订单下的所有子订单
                            List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                                    .in(InsAreaCompany::getOrderno, collect)
                                    .eq(InsAreaCompany::getOrderstatus, 3));
                            if (insAreaCompanies.size() > 0) {
                                BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

                                bigDecimal = jqpremium.add(sypremium).add(jypremium);
//                                    for (InsAreaCompany insAreaCompany : insAreaCompanies) {
//                                        //累加每一个子订单的交强险费用+商业险费用+驾意险费用
//                                        bigDecimal = bigDecimal.add(insAreaCompany.getJqpremium()).add(insAreaCompany.getSypremium()).add(insAreaCompany.getJypremium());
//
//                                    }
                            }
                        }
                    }
                }
                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())
                        .eq(SysUser::getStatus, 1));
                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());
                List<InsOrders> insOrderList;
                //筛选订单，选择时间
                Date updateTime = sysAgencyLeaders.getUpdateTime();
                if (updateTime == null) {
                    //机构下所有订单
                    insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                            .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                            .ge(InsOrders::getCreatetime, sysAgencyLeaders.getCreateTime()));
                    agencyExtractFee.setStartTime(sysAgencyLeaders.getCreateTime());
                } else {
                    insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                            .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                            .ge(InsOrders::getCreatetime, updateTime));
                    agencyExtractFee.setStartTime(updateTime);
                }
                if (insOrderList.size() > 0) {
                    List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                    //查询订单下的所有子订单
                    List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                            .in(InsAreaCompany::getOrderno, collect)
                            .eq(InsAreaCompany::getOrderstatus, 3));
                    if (insAreaCompanies.size() > 0) {
                        BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                        BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                        BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

                        bigDecimal = jqpremium.add(sypremium).add(jypremium);
                    }
                }
                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> queryExtractFeeAll(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 = new BigDecimal("0.00");
                //已提现抽成费用
                BigDecimal historyFee = new BigDecimal("0.00");

                agencyExtractFee.setUserId(sysAgencyLeaders.getUserId());
                agencyExtractFee.setUserName(sysAgencyLeaders.getUserName());
                agencyExtractFee.setDeptId(sysAgencyLeaders.getDeptId());
                agencyExtractFee.setDeptName(sysAgencyLeaders.getDeptName());
                agencyExtractFee.setProportional(sysAgencyLeaders.getProportional());
                List<InsOrders> insOrderList;
                //筛选订单，选择时间
                Date updateTime = sysAgencyLeaders.getUpdateTime();
                if (updateTime == null) {
                    //机构下所有订单
                    insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                            .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                            .ge(InsOrders::getCreatetime, sysAgencyLeaders.getCreateTime()));
                    agencyExtractFee.setStartTime(sysAgencyLeaders.getCreateTime());
                } else {
                    insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                            .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                            .ge(InsOrders::getCreatetime, updateTime));
                    agencyExtractFee.setStartTime(updateTime);
                }
                if (insOrderList.size() > 0) {
                    List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                    //查询订单下的所有子订单
                    List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                            .in(InsAreaCompany::getOrderno, collect)
                            .eq(InsAreaCompany::getOrderstatus, 3));
                    if (insAreaCompanies.size() > 0) {
                        BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                        BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                        BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

                        bigDecimal = jqpremium.add(sypremium).add(jypremium);
                    }
                }
                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(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")));
                }
                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();
                teamInformation.setUserName(sysAgencyLeaders.getUserName());
                teamInformation.setDeptId(sysDept.getId());
                teamInformation.setDeptName(sysDept.getName());
                List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                        .likeRight(SysUser::getId, sysDept.getId()).eq(SysUser::getStatus, 1));
                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());
                        //查询订单下的所有子订单
                        List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                                .in(InsAreaCompany::getOrderno, collect)
                                .eq(InsAreaCompany::getOrderstatus, 3));
                        if (insAreaCompanies.size() > 0) {
                                //累加每一个子订单的交强险费用+商业险费用+驾意险费用
                                BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

                                bigDecimal = jqpremium.add(sypremium).add(jypremium);
                        }

                }
                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()).eq(SysUser::getStatus, 1));
                            deptManNum = deptManNum + sysUsers.size();
                            List<InsOrders> insOrderList;
                            //筛选订单，选择时间
                            Date updateTime = sysAgencyLeader.getUpdateTime();
                            if (updateTime == null) {
                                //机构下所有订单
                                insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                                        .likeRight(InsOrders::getDeptid, sysDept.getId())
                                        .ge(InsOrders::getCreatetime, sysAgencyLeader.getCreateTime()));
                                agencyTeamVo.setStartTime(sysAgencyLeader.getCreateTime());

                            } else {
                                insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                                        .likeRight(InsOrders::getDeptid, sysDept.getId())
                                        .ge(InsOrders::getCreatetime, updateTime));
                                agencyTeamVo.setStartTime(updateTime);
                            }

                            if (insOrderList.size() > 0) {
                                List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                                //查询订单下的所有子订单
                                List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                                        .in(InsAreaCompany::getOrderno, collect)
                                        .eq(InsAreaCompany::getOrderstatus, 3));
                                if (insAreaCompanies.size() > 0) {
                                    BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                    BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                    BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

                                    bigDecimal = jqpremium.add(sypremium).add(jypremium);

                                }
                            }

                        }

                    }
                    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 核保不通过)',
                List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                        .in(InsAreaCompany::getOrderno, orderNoList)
                        .eq(InsAreaCompany::getOrderstatus, 3));
                if (insAreaCompanies.size() > 0) {
                    //累加每一个子订单的交强险费用+商业险费用+驾意险费用
                    BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                    BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                    BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

                    bigDecimal = jqpremium.add(sypremium).add(jypremium);
                }
                //出单笔数
                teamUserInfoVo.setIssueNum(insAreaCompanies.size());
                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);
    }


}