java-insagent-pc/src/main/java/com/ydtech/modules/admin/service/impl/SysPartnerServiceImpl.java

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


import cn.dev33.satoken.session.SaSession;
import cn.dev33.satoken.stp.StpUtil;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSONObject;
import com.alipay.api.AlipayApiException;
import com.alipay.api.AlipayClient;
import com.alipay.api.AlipayConfig;
import com.alipay.api.DefaultAlipayClient;
import com.alipay.api.request.AlipaySystemOauthTokenRequest;
import com.alipay.api.response.AlipaySystemOauthTokenResponse;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
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.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ydtech.aop.exception.DescribeException;
import com.ydtech.constants.enums.WechatOpenSystem;
import com.ydtech.core.page.HttpResult;
import com.ydtech.exception.SystemException;
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.SysPartnerService;
import com.ydtech.modules.admin.service.SysPremiumDetailsService;
import com.ydtech.modules.admin.service.SysUserService;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.esm.dao.EsmUserReferrerMapper;
import com.ydtech.modules.esm.model.EsmUserReferrer;
import com.ydtech.modules.order.entity.BasePageResult;
import com.ydtech.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.bean.oauth2.WxOAuth2AccessToken;
import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.mp.api.WxMpService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 配置机构合伙人表(SysPartner)表服务实现类
 *
 * @author makejava
 * @since 2024-08-01 11:20:57
 */
@Slf4j
@Service("sysPartnerService")
public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPartner> implements SysPartnerService {
    @Resource
    private SysPartnerMapper sysPartnerMapper;
    @Resource
    private SysRelationPersonMapper sysRelationPersonMapper;

    @Resource
    private SysAgencyLeaderMapper sysAgencyLeaderMapper;

    @Resource
    private SysDeptMapper sysDeptMapper;

    @Resource
    private SysUserMapper sysUserMapper;

    @Resource
    private SysUserService sysUserService;

    @Resource
    private SysAgencyFeeApprovalMapper sysAgencyFeeApprovalMapper;
    @Resource
    private SysAgencyLeaderService sysAgencyLeaderService;

    @Resource
    private SysPartnerAccountMapper sysPartnerAccountMapper;

    @Resource
    private SysPremiumDetailsMapper sysPremiumDetailsMapper;

    @Resource
    private SysPremiumDetailsService sysPremiumDetailsService;
    @Resource
    private SysPartnerConfigMapper sysPartnerConfigMapper;

    @Resource
    private SysProportionConfigMapper sysProportionConfigMapper;
    @Resource
    private EsmUserReferrerMapper esmUserReferrerMapper;

    @Resource
    private Map<String, WxMpService> wxMpService;

    @Override
    public List<SysUser> queryRecommendAndPartner(String id,Integer level) {
        List<SysUser> sysPartnerList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                .ne(SysUser::getStatus, 0)
                .likeRight(SysUser::getId, id)
                .eq(SysUser::getType,1)
                .lt(SysUser::getLevel,level)
                .orderByDesc(SysUser::getId));

        return sysPartnerList;
    }


    @Override
    public BasePageResult<SysUserPartner> queryByPage(SysPartnerPageDto sysPartnerPageDto) {
        Page<SysPartner> page = new Page<>(sysPartnerPageDto.getPageNum(), sysPartnerPageDto.getPageSize());

        LambdaQueryWrapper<SysPartner> wrapper = new LambdaQueryWrapper<>();
        wrapper.like(StringUtils.isNotEmpty(sysPartnerPageDto.getUserId()), SysPartner::getUserId, sysPartnerPageDto.getUserId());
        wrapper.like(StringUtils.isNotEmpty(sysPartnerPageDto.getUserName()), SysPartner::getUserName, sysPartnerPageDto.getUserName());
        wrapper.likeRight(StringUtils.isNotEmpty(sysPartnerPageDto.getDeptId()), SysPartner::getUserId, sysPartnerPageDto.getDeptId());
        wrapper.eq(sysPartnerPageDto.getLevel() != null, SysPartner::getType, sysPartnerPageDto.getLevel());
        wrapper.orderByDesc(SysPartner::getId);


        Page<SysPartner> insOrdersPage = page(page, wrapper);
        List<SysPartner> records = insOrdersPage.getRecords();

        List<SysUserPartner> sysUserPartners = BeanUtil.copyToList(records, SysUserPartner.class);

        if (!sysUserPartners.isEmpty()) {
            for (SysUserPartner user : sysUserPartners) {
                SysUser sysUser1 = sysUserMapper.selectById(user.getUserId());
                if(!Objects.isNull(sysUser1)) {
                    user.setUserName(sysUser1.getName());
                    user.setDeptId(sysUser1.getDeptId());
                    SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>()
                            .eq(SysDept::getId, sysUser1.getDeptId()).eq(SysDept::getDelFlag, 0));
                    user.setParentId(sysDept.getParentId());
                    user.setDeptName(sysDept.getName());
                }
                SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                        .eq(SysPartner::getUserId, user.getUserId()));
                if (sysPartner != null) {
                    user.setType(sysPartner.getType());
                    String suggestId = sysPartner.getSuggestId();
                    if (suggestId != null) {
                        user.setSuggestId(sysPartner.getSuggestId());
                        SysUser sysUser = sysUserMapper.selectById(sysPartner.getSuggestId());
                        if (sysUser != null) {
                            user.setSuggestName(sysUser.getName());
                        }
                    }
                    //查看等级
                    int type = sysPartner.getType();
                    if (type == 1) {
                        SysProportionConfig sysProportionConfig = sysProportionConfigMapper.selectOne(new LambdaQueryWrapper<SysProportionConfig>()
                                .eq(SysProportionConfig::getUserId, sysPartner.getUserId()));
                        if (sysProportionConfig == null) continue;
                        user.setProportional(sysProportionConfig.getOneProportion());

                    } else {
                        SysRelationPerson sysRelationPeople = sysRelationPersonMapper.selectOne(new LambdaQueryWrapper<SysRelationPerson>()
                                .eq(SysRelationPerson::getAgencyLeaderId, user.getUserId())
                                .eq(SysRelationPerson::getType, 0)
                                .eq(SysRelationPerson::getSuggestLevel, 1));
                        if (sysRelationPeople == null) continue;
                        SysProportionConfig sysProportionConfig = sysProportionConfigMapper.selectOne(new LambdaQueryWrapper<SysProportionConfig>()
                                .eq(SysProportionConfig::getUserId, sysRelationPeople.getSuggestId()));
                        if (sysProportionConfig == null) continue;
                        if (type == 2) {
                            user.setProportional(sysProportionConfig.getTwoProportion());
                        } else if (type == 3) {
                            user.setProportional(sysProportionConfig.getThreeProportion());
                        } else if (type == 4) {
                            user.setProportional(sysProportionConfig.getFourProportion());
                        } else if (type == 5) {
                            user.setProportional(sysProportionConfig.getFiveProportion());
                        }
                    }
                }
            }

        }


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


    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean insert(SysPartnerDto sysPartnerDto) {

        SysPartner sysPartner = BeanUtil.copyProperties(sysPartnerDto, SysPartner.class);
        sysPartner.setCreateTime(new Date());
        sysPartner.setCreateBy(BaseController.getUser().getId());
        sysPartner.setType(sysPartnerDto.getLevel());
        boolean b = false;
        b = sysPartnerMapper.insert(sysPartner) > 0;
        //一级合伙人添加默认比例
        if (sysPartnerDto.getLevel() == 1) {
            SysProportionConfig sysProportionConfig = new SysProportionConfig(null, sysPartner.getUserId(), "0.5", "0.1", "0.1", "0.1", "0.1", "0.1");
            sysProportionConfigMapper.insert(sysProportionConfig);
        }
        if (sysPartnerDto.getSuggestId() != null) {
            SysPartner sysPartner1 = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                    .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, sysPartnerDto.getSuggestId()));
            //保存关系
            SysRelationPerson sysRelationPerson = new SysRelationPerson();
            sysRelationPerson.setAgencyLeaderId(sysPartnerDto.getUserId());
            sysRelationPerson.setSuggestId(sysPartnerDto.getSuggestId());
            sysRelationPerson.setSuggestLevel(sysPartner1.getType());
            //'推荐等级(0:直接推荐；1：间接推荐)
            sysRelationPerson.setSource(0);
            //推荐类型（0：合伙人  1：机构负责人）
            sysRelationPerson.setType(0);
            sysRelationPerson.setCreateBy(BaseController.getUser().getId());
            sysRelationPerson.setCreateTime(new Date());
            b = sysRelationPersonMapper.insert(sysRelationPerson) > 0;
            //查询合伙人的推荐人是否有上级
            List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getAgencyLeaderId, sysPartnerDto.getSuggestId())
                    .eq(SysRelationPerson::getType, 0));
            if (sysRelationPeople.size() > 0) {
                for (SysRelationPerson relationPerson : sysRelationPeople) {
                    SysRelationPerson sysRelationPerson1 = new SysRelationPerson();
                    SysPartner sysPartner2 = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                            .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, relationPerson.getSuggestId()));
                    sysRelationPerson1.setAgencyLeaderId(sysPartnerDto.getUserId());
                    sysRelationPerson1.setSuggestId(relationPerson.getSuggestId());
                    sysRelationPerson1.setSuggestLevel(sysPartner2.getType());
                    sysRelationPerson1.setSource(1);
                    //推荐类型（0：合伙人  1：机构负责人）
                    sysRelationPerson1.setType(0);
                    sysRelationPerson1.setCreateBy(BaseController.getUser().getId());
                    sysRelationPerson1.setCreateTime(new Date());
                    sysRelationPersonMapper.insert(sysRelationPerson1);
                }
            }
        }
        return b;
    }

    @Override
    public boolean checkPartner(String userId) {
        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());
            return userIdList.contains(userId);
        }
        return false;
    }

    @Override
    public boolean deleteById(String id) {
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, id));
        List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new UpdateWrapper<SysRelationPerson>().lambda()
                .eq(SysRelationPerson::getAgencyLeaderId, id)
                .eq(SysRelationPerson::getDelFlag, 1)
                .eq(SysRelationPerson::getType, 0));
        if (sysRelationPeople.size() > 0) {
            if (sysRelationPeople.get(0).getSuggestId() != null) {
                throw new DescribeException(sysPartner.getUserName() + "有推荐人，不允许删除");
            }
        }
        List<SysRelationPerson> sysRelationPeople1 = sysRelationPersonMapper.selectList(new UpdateWrapper<SysRelationPerson>().lambda()
                .eq(SysRelationPerson::getSuggestId, id)
                .eq(SysRelationPerson::getDelFlag, 1)
                .eq(SysRelationPerson::getType, 0));
        if (sysRelationPeople1.size() > 0) {
            if (sysRelationPeople1.get(0).getSuggestId() != null) {
                throw new DescribeException(sysPartner.getUserName() + "是推荐人，不允许删除");
            }
        }

        SysPartner partner = new SysPartner();
        partner.setId(sysPartner.getId());
        partner.setDelFlag(0);
        return sysPartnerMapper.updateById(partner) > 0;
    }

    @Override
    public BasePageResult<AgencyExtractFeeVo> queryPartnerByPages(SysPartnerPageDto sysPartnerPageDto) {
        List<AgencyExtractFeeVo> agencyExtractFeeList = new ArrayList<>();

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

        Page<SysPartner> insOrdersPage = page(page, wrapper);
        List<SysPartner> sysPartnerList = insOrdersPage.getRecords();
        if (sysPartnerList.size() > 0) {
            for (SysPartner sysPartner : sysPartnerList) {
                AgencyExtractFeeVo agencyExtractFee = new AgencyExtractFeeVo();
                //总保费
                BigDecimal bigDecimal = BigDecimal.ZERO;
                BigDecimal extractFee = BigDecimal.ZERO;
                //已提现抽成费用
                BigDecimal historyFee = BigDecimal.ZERO;
                //填充查询人的姓名和机构
                agencyExtractFee.setProportional(sysPartner.getProportional());
                agencyExtractFee.setUserId(sysPartner.getUserId());
                //SysUser sysUser = sysUserMapper.selectById(sysPartner.getUserId());
                SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                        .eq(SysUser::getId, sysPartner.getUserId())
                        .ne(SysUser::getStatus, 0));
                if (sysUser == null) {
                    continue;
                }
                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, sysPartner.getUserId()).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);
                            } else {
                                dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                            }
                            HashMap<String, BigDecimal> map = sysAgencyLeaderMapper.getBigDecimalNum(sysAgencyLeaders.getDeptId(), dateStr, null, null);
                            if (CollectionUtil.isNotEmpty(map)) {
                                bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : map.get("bigDecimal"));
                            }
                        }
                    }
                    // 填充 已提现抽成费用和可提现抽成费用
                    List<SysAgencyFeeApproval> sysAgencyFeeApprovals = sysAgencyFeeApprovalMapper.selectList(new LambdaQueryWrapper<SysAgencyFeeApproval>()
                            .eq(SysAgencyFeeApproval::getUserId, sysPartner.getUserId())
                            .eq(SysAgencyFeeApproval::getStatus, 1));
                    if (sysAgencyFeeApprovals.size() > 0) {
                        for (SysAgencyFeeApproval sysAgencyFeeApproval : sysAgencyFeeApprovals) {
                            historyFee = historyFee.add(sysAgencyFeeApproval.getHistoryFee());
                        }
                    }
                    agencyExtractFee.setSumpremium(bigDecimal);
                    if (!bigDecimal.equals(BigDecimal.ZERO)) {

                        BigDecimal multiply = bigDecimal.multiply(new BigDecimal(agencyExtractFee.getProportional())
                                .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                        agencyExtractFee.setExtractFee(multiply);
                        //已提现
                        agencyExtractFee.setHistoryFee(historyFee);
                        extractFee = agencyExtractFee.getExtractFee();
                        //可提现 = 总抽成-已提现
                        agencyExtractFee.setCashFee(extractFee.subtract(historyFee));
                    } else {
                        agencyExtractFee.setExtractFee(BigDecimal.ZERO);
                        agencyExtractFee.setHistoryFee(BigDecimal.ZERO);
                        agencyExtractFee.setCashFee(extractFee);
                    }

                } else {
                    agencyExtractFee.setSumpremium(BigDecimal.ZERO);
                    agencyExtractFee.setExtractFee(BigDecimal.ZERO);
                    agencyExtractFee.setHistoryFee(BigDecimal.ZERO);
                    agencyExtractFee.setCashFee(BigDecimal.ZERO);
                }
                agencyExtractFeeList.add(agencyExtractFee);

            }
        }

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

    }

    @Override
    public BasePageResult<AgencyExtractFeeVo> queryPartnerByPage(SysPartnerPageDto sysPartnerPageDto) {
        List<AgencyExtractFeeVo> agencyExtractFeeList = new ArrayList<>();

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

        Page<SysPartner> insOrdersPage = page(page, wrapper);
        List<SysPartner> sysPartnerList = insOrdersPage.getRecords();
        if (sysPartnerList.size() > 0) {
            for (SysPartner sysPartner : sysPartnerList) {
                String userId = sysPartner.getUserId();

                AgencyExtractFeeVo agencyExtractFee = new AgencyExtractFeeVo();
                //已提现抽成费用
                BigDecimal historyFee = BigDecimal.ZERO;
                SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                        .eq(SysUser::getId, userId)
                        .ne(SysUser::getStatus, 0));
                //填充查询人的姓名和机构
                agencyExtractFee.setUserId(userId);
                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());

                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, sysPartner.getUserId())
                            .eq(SysAgencyFeeApproval::getStatus, 1));
                    if (sysAgencyFeeApprovals.size() > 0) {
                        for (SysAgencyFeeApproval sysAgencyFeeApproval : sysAgencyFeeApprovals) {
                            historyFee = historyFee.add(sysAgencyFeeApproval.getHistoryFee());
                        }
                    }
                    agencyExtractFee.setHistoryFee(historyFee);
                    //可提现 = 总抽成-已提现
                    agencyExtractFee.setCashFee(extractFee.subtract(historyFee));

                } else {
                    agencyExtractFee.setSumpremium(BigDecimal.ZERO);
                    agencyExtractFee.setExtractFee(BigDecimal.ZERO);
                    agencyExtractFee.setHistoryFee(BigDecimal.ZERO);
                    agencyExtractFee.setCashFee(BigDecimal.ZERO);
                }

                agencyExtractFeeList.add(agencyExtractFee);

            }
        }

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

    }

    @Override
    public BasePageResult<SysPartnerAPPPageVo> SysPartnerAPPPage(SysPartnerAPPPageDto sysPartnerAPPPageDto) {
        List<SysPartnerAPPPageVo> sysPartnerAPPPageVoList = new ArrayList<>();
        String userId = BaseController.getUserId();
        int source = sysPartnerAPPPageDto.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, 0));

        } else {
            sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId)
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getSource, 1)
                    .eq(SysRelationPerson::getType, 0));

        }
        List<String> ids = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
        if (CollectionUtil.isNotEmpty(ids)) {
            //分页查询合伙人信息
            Page<SysPartner> page = new Page<>(sysPartnerAPPPageDto.getPageNum(), sysPartnerAPPPageDto.getPageSize());

            LambdaQueryWrapper<SysPartner> wrapper = new LambdaQueryWrapper<>();
            wrapper.like(StringUtils.isNotEmpty(sysPartnerAPPPageDto.getUserName()), SysPartner::getUserName, sysPartnerAPPPageDto.getUserName());
            wrapper.in(SysPartner::getUserId, ids);
            wrapper.eq(SysPartner::getDelFlag, 1);
            wrapper.orderByDesc(SysPartner::getId);

            Page<SysPartner> insOrdersPage = page(page, wrapper);
            List<SysPartner> sysPartnerList = insOrdersPage.getRecords();
            if (sysPartnerList.size() > 0) {
                for (SysPartner sysPartner : sysPartnerList) {
                    //总保费
                    BigDecimal bigDecimal = new BigDecimal("0.00");
                    SysPartnerAPPPageVo sysPartnerAPPPageVo = new SysPartnerAPPPageVo();
                    sysPartnerAPPPageVo.setUserId(sysPartner.getUserId());
                    //填充机构信息
                    SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                            .eq(SysUser::getId, sysPartner.getUserId())
                            .ne(SysUser::getStatus, 0));
                    sysPartnerAPPPageVo.setUserName(sysUser.getName());
                    SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>()
                            .eq(SysDept::getId, sysUser.getDeptId()).eq(SysDept::getDelFlag, 0));
                    sysPartnerAPPPageVo.setDeptId(sysDept.getId());
                    sysPartnerAPPPageVo.setDeptName(sysDept.getName());
                    sysPartnerAPPPageVo.setProportional(sysPartner.getProportional());

                    List<SysRelationPerson> relationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                            .eq(SysRelationPerson::getSuggestId, sysPartner.getUserId())
                            .eq(SysRelationPerson::getDelFlag, 1)
                            .eq(SysRelationPerson::getType, 1));
                    if (relationPersonList.size() > 0) {
                        List<String> agencyLeaderIds = relationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                        List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                                .eq(SysAgencyLeader::getDelFlag, 1).in(SysAgencyLeader::getUserId, agencyLeaderIds));
                        for (SysAgencyLeader sysAgencyLeader : leaderList) {
                            //获取机构下的团队
                            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()));
                            if (sysDeptList.size() > 0) {

                                for (SysDept sysDept1 : sysDeptList) {
                                    //筛选订单，选择时间
                                    Date updateTime = sysAgencyLeader.getUpdateTime();
                                    Date createTime = sysAgencyLeader.getCreateTime();
                                    String dateStr = "";
                                    if (updateTime != null) {
                                        dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(updateTime);
                                    } else {
                                        dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                                    }
                                    HashMap<String, BigDecimal> map = sysAgencyLeaderMapper.getBigDecimalNum(sysDept1.getId(), dateStr, null, null);
                                    if (CollectionUtil.isNotEmpty(map)) {
                                        bigDecimal = bigDecimal.add(map.get("bigDecimal") == null ? BigDecimal.ZERO : map.get("bigDecimal"));
                                    }
                                }
                            }
                        }
                    }
                    sysPartnerAPPPageVo.setSumpremium(bigDecimal);
                    if (!bigDecimal.equals(new BigDecimal("0.00"))) {
                        BigDecimal multiply = bigDecimal.multiply(new BigDecimal(sysPartner.getProportional())
                                .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                        sysPartnerAPPPageVo.setExtractFee(multiply);
                    } else {
                        sysPartnerAPPPageVo.setExtractFee(new BigDecimal("0.00"));
                    }

                    sysPartnerAPPPageVoList.add(sysPartnerAPPPageVo);

                }

            }

            return new BasePageResult<>(sysPartnerAPPPageDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
                    sysPartnerAPPPageVoList);
        }
        return new BasePageResult<>(sysPartnerAPPPageDto.getPageNum(), sysPartnerAPPPageDto.getPageSize(), 0L, 0L,
                sysPartnerAPPPageVoList);
    }

    @Override
    public boolean edit(SysPartnerDto sysPartnerDto) {
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, sysPartnerDto.getUserId()));
        if (sysPartner == null) throw new DescribeException("系统错误，请联系管理员！");
        SysPartner partner = new SysPartner();
        partner.setId(sysPartner.getId());
        partner.setUserName(sysPartnerDto.getUserName());

        return sysPartnerMapper.updateById(partner) > 0;
    }

    @Override
    public BasePageResult<AgencyExtractFeeVo> queryAgencyLeaderById(SysAgencyLeaderPageDto sysAgencyLeaderPageDto) {
        List<AgencyExtractFeeVo> agencyExtractFeeList = new ArrayList<>();
        List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getSuggestId, sysAgencyLeaderPageDto.getUserId()).eq(SysRelationPerson::getType, 1));

        if (CollectionUtil.isEmpty(sysRelationPeople)) return new BasePageResult<>(sysAgencyLeaderPageDto.getPageNum(),
                sysAgencyLeaderPageDto.getPageSize(), 0L, 0L, agencyExtractFeeList);
        //获取所有推荐的机构负责人id
        List<String> agencyLeaderIds = sysRelationPeople.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
        Page<SysAgencyLeader> page = new Page<>(sysAgencyLeaderPageDto.getPageNum(), sysAgencyLeaderPageDto.getPageSize());
        LambdaQueryWrapper<SysAgencyLeader> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(SysAgencyLeader::getUserId, agencyLeaderIds);
        wrapper.eq(SysAgencyLeader::getDelFlag, 1);
        wrapper.orderByDesc(SysAgencyLeader::getId);

        Page<SysAgencyLeader> insOrdersPage = sysAgencyLeaderService.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));
                    }
                }else {
                    agencyExtractFee.setSumpremium(BigDecimal.ZERO);
                }

                agencyExtractFeeList.add(agencyExtractFee);

            }

        }

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

    }

    @Override
    public APPPartnerInfoFreeVo getTeamInfo(PartnerGradeInfo partnerGradeInfo) {
        APPPartnerInfoFreeVo appPartnerInfoFreeVo = new APPPartnerInfoFreeVo();
        String loginId = BaseController.getUserId();
        List<APPPartnerInfo> appPartnerInfoList = new ArrayList<>();

        List<String> deptIds = partnerGradeInfo.getDeptIds();
        if (CollectionUtil.isEmpty(deptIds)) {
            return appPartnerInfoFreeVo;
        }
        List<SysDept> sysDeptList = sysDeptMapper.selectList(new LambdaQueryWrapper<SysDept>()
                .in(SysDept::getId, deptIds).eq(SysDept::getDelFlag, 0));
        if (sysDeptList.size() == 0) {
            return appPartnerInfoFreeVo;
        }
        for (SysDept sysDept : sysDeptList) {
            APPPartnerInfo appPartnerInfo = new APPPartnerInfo();
            appPartnerInfo.setDeptId(sysDept.getId());
            appPartnerInfo.setDeptName(sysDept.getName());
            String leaderId = sysDept.getLeaderId();
            if (StringUtils.isNotEmpty(leaderId)) {
                appPartnerInfo.setLeaderId(leaderId);
                SysUser sysUser = sysUserMapper.selectById(leaderId);
                appPartnerInfo.setLeaderName(sysUser.getName());
            }

            //获取机构下的团队
            List<SysDept> sysDepTeam = sysDeptMapper.selectList(new LambdaQueryWrapper<SysDept>()
                    .likeRight(SysDept::getId, sysDept.getId())
                    .isNull(SysDept::getComlevel).eq(SysDept::getDelFlag, 0)
                    .eq(SysDept::getManagementSource, sysDept.getManagementSource()));
            //机构下每个团队人数id集合
            List<String> userIdList = new ArrayList<>();
            int deptManNum = 0;
            if (sysDepTeam.size() > 0) {
                for (SysDept sysDept1 : sysDepTeam) {
                    List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                            .likeRight(SysUser::getId, sysDept1.getId()).ne(SysUser::getStatus, 0));
                    deptManNum = deptManNum + sysUsers.size();
                    if (sysUsers.size() > 0) {
                        List<String> collect = sysUsers.stream().map(SysUser::getId).collect(Collectors.toList());
                        userIdList.addAll(collect);
                    }

                }
            }
            appPartnerInfo.setTeamManNum(deptManNum);
            appPartnerInfo.setUserIds(userIdList);
            BigDecimal sumPremium = BigDecimal.ZERO;
            BigDecimal extractFee = BigDecimal.ZERO;
            if (CollectionUtil.isEmpty(userIdList)) continue;
            for (String userId : userIdList) {
                //查团队的保费
                List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                        .eq(SysPremiumDetails::getIssuerId, userId)
                        .eq(SysPremiumDetails::getUserId, loginId)
                        .between(StringUtils.isNotEmpty(partnerGradeInfo.getBeginTime()) && StringUtils.isNotEmpty(partnerGradeInfo.getEndTime()),
                                SysPremiumDetails::getCreateTime, partnerGradeInfo.getBeginTime(), partnerGradeInfo.getEndTime())
                        .eq(SysPremiumDetails::getStatus, 1)
                        .eq(partnerGradeInfo.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerGradeInfo.getIndustrySector()));
                if (sysPremiumDetails.size() > 0) {
                    Map<String, List<SysPremiumDetails>> map = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                            .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                    for (String s : map.keySet()) {
                        List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                        sumPremium = sumPremium.add(sysPremiumDetails1.get(0).getSumpremium());
                    }

                    BigDecimal reduce = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                    extractFee = extractFee.add(reduce);
                }

            }

            appPartnerInfo.setSumPremium(sumPremium);
            appPartnerInfo.setExtractFee(extractFee);
            appPartnerInfoList.add(appPartnerInfo);
        }
        List<String> ids = new ArrayList<>();
        List<List<String>> collect = appPartnerInfoList.stream().map(APPPartnerInfo::getUserIds).collect(Collectors.toList());
        if (collect.size() > 0) {
            for (List<String> list : collect) {
                ids.addAll(list);
            }
        }
        if (CollectionUtil.isEmpty(ids)) return appPartnerInfoFreeVo;
        BigDecimal sumPremium1 = BigDecimal.ZERO;
        BigDecimal extractFee1 = BigDecimal.ZERO;
        for (String id : ids) {

            List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                    .eq(SysPremiumDetails::getIssuerId, id)
                    .eq(SysPremiumDetails::getUserId, loginId)
                    .between(StringUtils.isNotEmpty(partnerGradeInfo.getBeginTime()) && StringUtils.isNotEmpty(partnerGradeInfo.getEndTime()),
                            SysPremiumDetails::getCreateTime, partnerGradeInfo.getBeginTime(), partnerGradeInfo.getEndTime())
                    .eq(SysPremiumDetails::getStatus, 1)
                    .eq(partnerGradeInfo.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerGradeInfo.getIndustrySector()));
            if (sysPremiumDetails.size() > 0) {
                Map<String, List<SysPremiumDetails>> map = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                        .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                for (String s : map.keySet()) {
                    List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                    sumPremium1 = sumPremium1.add(sysPremiumDetails1.get(0).getSumpremium());
                }
//                SysPremiumDetails sysPremiumDetails1 = sysPremiumDetails.get(0);
//                sumPremium1 = sumPremium1.add(sysPremiumDetails1.getSumpremium());
                BigDecimal reduce = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                extractFee1 = extractFee1.add(reduce);
            }

        }

        appPartnerInfoFreeVo.setSumPremium(sumPremium1);
        appPartnerInfoFreeVo.setExtractFee(extractFee1);

        int sum = appPartnerInfoList.stream().mapToInt(APPPartnerInfo::getTeamManNum).sum();
        appPartnerInfoFreeVo.setTeamManNum(sum);

        appPartnerInfoFreeVo.setAppPartnerInfos(appPartnerInfoList);

        return appPartnerInfoFreeVo;
    }

    @Override
    public AppPartnerNumVo getHomePage(Integer type) {
        AppPartnerNumVo appPartnerNumVo = new AppPartnerNumVo();
        //合伙人：1 ；工作室管理员：2
        String userId = BaseController.getUserId();
        SysPartnerAccount sysPartnerAccount = sysPartnerAccountMapper.selectOne(new LambdaQueryWrapper<SysPartnerAccount>()
                .eq(SysPartnerAccount::getUserId, userId));
        if (sysPartnerAccount != null) {
            appPartnerNumVo.setSumPremium(sysPartnerAccount.getSumPremium());
            appPartnerNumVo.setExtractFee(sysPartnerAccount.getExtractFee());
        }
        if (type == 1) {
            //下面合伙人（直接）数量
            List<SysRelationPerson> sysRelationPersonList1 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId)
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getSource, 0)
                    .eq(SysRelationPerson::getType, 0));

            appPartnerNumVo.setPartnerNum(sysRelationPersonList1.size());

            //直接工作室数量
            List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId)
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getSource, 0)
                    .eq(SysRelationPerson::getType, 1));
            appPartnerNumVo.setWorkroomNum(sysRelationPersonList.size());
            List<String> collect = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
            appPartnerNumVo.setLeaderIds(collect);
            //登录人下面的所有团队人数
            List<SysRelationPerson> sysRelationPersonList2 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, userId)
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getType, 1));
            if (sysRelationPersonList2.size() > 0) {
                List<String> ids = sysRelationPersonList2.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                        .in(CollectionUtil.isNotEmpty(ids), SysAgencyLeader::getUserId, ids).eq(SysAgencyLeader::getDelFlag, 1));
                int deptManNum = 0;
                if (leaderList.size() > 0) {
                    for (SysAgencyLeader sysAgencyLeader : leaderList) {
                        //获取机构下的团队
                        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()));
                        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();

                            }
                        }
                    }

                    appPartnerNumVo.setTeamManNum(deptManNum);
                }
            }
        } else {
            int deptManNum = 0;
            SysAgencyLeader sysAgencyLeader = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>()
                    .in(SysAgencyLeader::getUserId, userId).eq(SysAgencyLeader::getDelFlag, 1));
            //获取机构下的团队
            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()));
            appPartnerNumVo.setWorkroomTeamNum(sysDeptList.size());
            List<String> deptIds = new ArrayList<>();
            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();
                    deptIds.add(sysDept.getId());
                }
                appPartnerNumVo.setWorkroomManNum(deptManNum);
                appPartnerNumVo.setTeamManNum(deptManNum);
                appPartnerNumVo.setDeptIds(deptIds);
            }

        }

        return appPartnerNumVo;
    }

    @Override
    public AppUserInfoVo getUserInfo(Integer type) {
        String userId = BaseController.getUserId();
        AppUserInfoVo appUserInfoVo = sysUserMapper.queryByUserId(userId);
        if (type == 1) {
            SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                    .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, userId));
            SysPartnerConfig sysPartnerConfig = sysPartnerConfigMapper.selectOne(new LambdaQueryWrapper<SysPartnerConfig>()
                    .eq(SysPartnerConfig::getDelFlag, 1).eq(SysPartnerConfig::getLevel, sysPartner.getType()));

            appUserInfoVo.setSysPartnerConfig(sysPartnerConfig);
            appUserInfoVo.setLevel(sysPartner.getType());
        } else {
            SysPartnerConfig sysPartnerConfig = sysPartnerConfigMapper.selectOne(new LambdaQueryWrapper<SysPartnerConfig>()
                    .eq(SysPartnerConfig::getDelFlag, 1).eq(SysPartnerConfig::getLevel, 0));
            appUserInfoVo.setSysPartnerConfig(sysPartnerConfig);
        }

        // 获取当前日期
//        LocalDate currentDate = LocalDate.now();
//        ZoneId zoneId = ZoneId.systemDefault();
//        Date entryTime = appUserInfoVo.getEntryTime();
//        if (entryTime != null) {
//            LocalDate localDate = entryTime.toInstant().atZone(zoneId).toLocalDate();
//            // 计算年数
//            long years = ChronoUnit.YEARS.between(localDate, currentDate);
//            appUserInfoVo.setYears(years);
//        }

        return appUserInfoVo;
    }

    @Override
    public SysPartnerAccount getFee() {
        String userId = BaseController.getUserId();

        return sysPartnerAccountMapper.selectOne(new LambdaQueryWrapper<SysPartnerAccount>().eq(SysPartnerAccount::getUserId, userId));
    }

    @Override
    public List<AppSysPartnerVo>  partnerInfo(PartnerInfoDto partnerInfoDto) {
        List<AppSysPartnerVo> appSysPartnerVos = new ArrayList<>();
        String userId = partnerInfoDto.getUserId();
        if (StringUtils.isEmpty(userId)) {
            userId = BaseController.getUserId();
        }
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
        //查询登陆人下所有直接合伙人
        List<SysPartner> sysPartnerList = sysPartnerMapper.queryByLoginId(userId);

        Map<Integer, List<SysPartner>> listMap = sysPartnerList.stream().sorted(Comparator.comparing(SysPartner::getId))
                .collect(Collectors.groupingBy(SysPartner::getType));
        //按等级查询
//        Integer partnerType = partnerInfoDto.getPartnerType();
//        if (partnerType != null) {
//            List<SysPartner> sysPartnerList1 = listMap.get(partnerType + sysPartner.getType());
//
//            if (sysPartnerList1 != null) {
//                AppSysPartnerVo appSysPartnerVo = new AppSysPartnerVo();
//                appSysPartnerVo.setPartnerType(partnerType + sysPartner.getType());
//                //下级合伙人数
//                appSysPartnerVo.setPartnerNumber(sysPartnerList1.size());
//                List<String> ids = sysPartnerList1.stream().map(SysPartner::getUserId).collect(Collectors.toList());
//                appSysPartnerVo.setPartnerIds(ids);
//                List<String> userIds = new ArrayList<>();
//                //二级以下团队的总人数
//                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
//                        .in(CollectionUtil.isNotEmpty(ids), SysRelationPerson::getSuggestId, ids)
//                        .eq(SysRelationPerson::getDelFlag, 1)
//                        .eq(SysRelationPerson::getType, 1));
//                int deptManNum = 0;
//                if (sysRelationPersonList.size() > 0) {
//                    List<String> idList = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
//                    List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
//                            .in(CollectionUtil.isNotEmpty(idList), SysAgencyLeader::getUserId, idList).eq(SysAgencyLeader::getDelFlag, 1));
//                    if (leaderList.size() > 0) {
//                        for (SysAgencyLeader sysAgencyLeader : leaderList) {
//                            //获取机构下的团队
//                            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()));
//                            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();
//                                    if (sysUsers.size() >0) {
//                                        userIds.addAll(sysUsers.stream().map(SysUser::getId).collect(Collectors.toList()));
//                                    }
//                                }
//                            }
//                        }
//                    }
//                }
//                appSysPartnerVo.setTeamManNum(deptManNum);
//                if (CollectionUtil.isNotEmpty(userIds)) {
//                    List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
//                            .eq(SysPremiumDetails::getUserId, userId)
//                            .in(SysPremiumDetails::getIssuerId,userIds)
//                            .between(StringUtils.isNotEmpty(partnerInfoDto.getBeginTime()) && StringUtils.isNotEmpty(partnerInfoDto.getEndTime()),
//                                    SysPremiumDetails::getCreateTime, partnerInfoDto.getBeginTime(), partnerInfoDto.getEndTime())
//                            .eq(partnerInfoDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerInfoDto.getIndustrySector())
//                            .eq(SysPremiumDetails::getStatus, 1));
//                    BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
//                    BigDecimal extractFee = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
//
//                    appSysPartnerVo.setSumPremium(sumPremium);
//                    appSysPartnerVo.setExtractFee(extractFee);
//                }else {
//                    appSysPartnerVo.setSumPremium(BigDecimal.ZERO);
//                    appSysPartnerVo.setExtractFee(BigDecimal.ZERO);
//                }
//
//                List<SysRelationPerson> sysRelationPersons = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
//                        .in(CollectionUtil.isNotEmpty(ids), SysRelationPerson::getSuggestId, ids)
//                        .eq(SysRelationPerson::getDelFlag, 1)
//                        .eq(SysRelationPerson::getSource, 0)
//                        .eq(SysRelationPerson::getType, 1));
//                appSysPartnerVo.setWorkNumber(sysRelationPersons.size());
//                if (sysRelationPersons.size() > 0) {
//                    List<String> list1 = sysRelationPersons.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
//                    appSysPartnerVo.setLeaderIds(list1);
//                }
//
//                //每一级存入map
//
//                appSysPartnerVos.add(appSysPartnerVo);
//            }
//
//            return appSysPartnerVos;
//
//        }
        int start = 0;
        int type = sysPartner.getType();
        if (type == 1) {
            start = start + 2;
        } else if (type == 2) {
            start = start + 3;
        } else if (type == 3) {
            start = start + 4;
        } else if (type == 4) {
            start = start + 5;
        }

        for (int i = start; i < 6; i++) {
            //二级
            List<SysPartner> sysPartnerList1 = listMap.get(i);
            if (CollectionUtil.isNotEmpty(sysPartnerList1)) {
                AppSysPartnerVo appSysPartnerVo = new AppSysPartnerVo();
                appSysPartnerVo.setPartnerType(i);
                //下级合伙人数
                appSysPartnerVo.setPartnerNumber(sysPartnerList1.size());
                List<String> ids = sysPartnerList1.stream().map(SysPartner::getUserId).collect(Collectors.toList());
                appSysPartnerVo.setPartnerIds(ids);

                //所有创造利益总人数
                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .in(CollectionUtil.isNotEmpty(ids), SysRelationPerson::getSuggestId, ids)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 1));
                int deptManNum = 0;
                if (sysRelationPersonList.size() > 0) {
                    List<String> idList = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                    List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                            .in(SysAgencyLeader::getUserId, idList).eq(SysAgencyLeader::getDelFlag, 1));
                    if (leaderList.size() > 0) {
                        for (SysAgencyLeader sysAgencyLeader : leaderList) {
                            //获取机构下的团队
                            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()));
                            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();
                                }
                            }
                        }
                    }

                }
                appSysPartnerVo.setTeamManNum(deptManNum);
                //直接工作室
                List<SysRelationPerson> sysRelationPersons = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .in(CollectionUtil.isNotEmpty(ids), SysRelationPerson::getSuggestId, ids)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getSource, 0)
                        .eq(SysRelationPerson::getType, 1));
                appSysPartnerVo.setWorkNumber(sysRelationPersons.size());
                if (sysRelationPersons.size() > 0) {
                    List<String> list1 = sysRelationPersons.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                    appSysPartnerVo.setLeaderIds(list1);
                }
                //所有工作室
                List<SysRelationPerson> sysRelationPersons1 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .in(CollectionUtil.isNotEmpty(ids), SysRelationPerson::getSuggestId, ids)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 1));

                //直接工作室下所有的人
                List<String> userIds = getUserIds(sysRelationPersons1);

                BigDecimal sumPremium = BigDecimal.ZERO;
                BigDecimal extractFee = BigDecimal.ZERO;
                if (CollectionUtil.isNotEmpty(userIds)) {
                    for (String id : userIds) {
                        List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                                .eq(SysPremiumDetails::getUserId, BaseController.getUserId())
                                .eq(SysPremiumDetails::getIssuerId,id)
                                .between(StringUtils.isNotEmpty(partnerInfoDto.getBeginTime()) && StringUtils.isNotEmpty(partnerInfoDto.getEndTime()),
                                        SysPremiumDetails::getCreateTime, partnerInfoDto.getBeginTime(), partnerInfoDto.getEndTime())
                                .eq(partnerInfoDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerInfoDto.getIndustrySector())
                                .eq(SysPremiumDetails::getStatus, 1));
                        if (CollectionUtil.isNotEmpty(sysPremiumDetails)) {
                            Map<String, List<SysPremiumDetails>> map = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                                    .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                            for (String s : map.keySet()) {
                                List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                                sumPremium = sumPremium.add(sysPremiumDetails1.get(0).getSumpremium());
                            }
                            BigDecimal reduce = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                            extractFee = extractFee.add(reduce);
                        }

                    }
                }
                appSysPartnerVo.setSumPremium(sumPremium);
                appSysPartnerVo.setExtractFee(extractFee);
                //每一级存入map
                appSysPartnerVos.add(appSysPartnerVo);
            }
        }
        return appSysPartnerVos;
    }

    private List<String> getUserIds(List<SysRelationPerson> sysRelationPersons) {
        List<String> userIds = new ArrayList<>();
        if (sysRelationPersons.size() > 0) {
            List<String> idList = sysRelationPersons.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
            List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                    .in(CollectionUtil.isNotEmpty(idList), SysAgencyLeader::getUserId, idList).eq(SysAgencyLeader::getDelFlag, 1));
            if (leaderList.size() > 0) {
                for (SysAgencyLeader sysAgencyLeader : leaderList) {
                    //获取机构下的团队
                    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()));
                    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));
                            if (sysUsers.size()>0) {
                                userIds.addAll(sysUsers.stream().map(SysUser::getId).collect(Collectors.toList()));
                            }
                        }
                    }
                }
            }

        }
        return userIds;
    }

    private List<String> getUserIdByLeader(List<SysAgencyLeader> leaderList) {
        List<String> userIds = new ArrayList<>();
        if (leaderList.size() > 0) {
            for (SysAgencyLeader sysAgencyLeader : leaderList) {
                //获取机构下的团队
                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()));
                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));
                        if (sysUsers.size()>0) {
                            userIds.addAll(sysUsers.stream().map(SysUser::getId).collect(Collectors.toList()));
                        }
                    }
                }
            }
        }
        return userIds;
    }

    @Override
    public PartnerInfoFreeVo queryPartnerInfo(PartnerGradeInfo partnerGradeInfo) {
        PartnerInfoFreeVo partnerInfoFreeVo = new PartnerInfoFreeVo();
        List<PartnerInfoVo> partnerInfoVoList = new ArrayList<>();
        String loginId = BaseController.getUserId();
        List<String> partnerIds = partnerGradeInfo.getPartnerIds();
        if (CollectionUtil.isEmpty(partnerIds)) {
            return partnerInfoFreeVo;
        }
        //关联工作室下所有的人
        List<SysRelationPerson> sysRelationPersons1 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .in(SysRelationPerson::getSuggestId, partnerIds)
                .eq(SysRelationPerson::getDelFlag, 1)
                .eq(SysRelationPerson::getType, 1));
        List<String> userIds = getUserIds(sysRelationPersons1);
        BigDecimal sumPremium = BigDecimal.ZERO;
        BigDecimal extractFee = BigDecimal.ZERO;
        if (CollectionUtil.isNotEmpty(userIds)) {
            for (String userId : userIds) {
                //费用
                List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                        .eq(SysPremiumDetails::getUserId, loginId)
                        .eq(SysPremiumDetails::getIssuerId,userId)
                        .between(StringUtils.isNotEmpty(partnerGradeInfo.getBeginTime()) && StringUtils.isNotEmpty(partnerGradeInfo.getEndTime()),
                                SysPremiumDetails::getCreateTime, partnerGradeInfo.getBeginTime(), partnerGradeInfo.getEndTime())
                        .eq(partnerGradeInfo.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerGradeInfo.getIndustrySector())
                        .eq(SysPremiumDetails::getStatus, 1));
                if (CollectionUtil.isNotEmpty(sysPremiumDetails)) {
                    Map<String, List<SysPremiumDetails>> map = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                            .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                    for (String s : map.keySet()) {
                        List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                        sumPremium = sumPremium.add(sysPremiumDetails1.get(0).getSumpremium());
                    }

//                        sumPremium = sumPremium.add(sysPremiumDetails.get(0).getSumpremium());
                    BigDecimal reduce = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                    extractFee = extractFee.add(reduce);
                }

            }
        }
        partnerInfoFreeVo.setSumPremium(sumPremium);
        partnerInfoFreeVo.setExtractFee(extractFee);

        //合伙人
        List<SysPartner> sysPartnerList = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>()
                .in(SysPartner::getUserId, partnerGradeInfo.getPartnerIds()).eq(SysPartner::getDelFlag, 1));
        if (sysPartnerList.size() > 0) {
            for (SysPartner sysPartner : sysPartnerList) {
                PartnerInfoVo partnerInfoVo = new PartnerInfoVo();
                partnerInfoVo.setLevel(sysPartner.getType());
                String userId = sysPartner.getUserId();
                partnerInfoVo.setUserId(userId);
                SysUser sysUser = sysUserMapper.selectById(userId);
                partnerInfoVo.setUserName(sysUser.getName());
                SysUser sysUser1 = sysUserMapper.selectById(sysPartner.getSuggestId());
                partnerInfoVo.setSuggestName(sysUser1.getName());
                //直接合伙人
                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, userId)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 0)
                        .eq(SysRelationPerson::getSource, 0));
                List<String> collect = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                partnerInfoVo.setPartnerIds(collect);
                partnerInfoVo.setPartnerNumber(collect.size());

                //直接管理员
                List<SysRelationPerson> sysRelationPersonList1 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, userId)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 1)
                        .eq(SysRelationPerson::getSource, 0));

                List<String> collects = sysRelationPersonList1.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                partnerInfoVo.setLeaderIds(collects);
                partnerInfoVo.setWorkNumber(collects.size());
                //所有贡献费用
                //合伙人下所有工作室数 核算总代理人数
                List<SysRelationPerson> sysRelationPersonList2 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, userId)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 1));

                List<String> userIds1 = getUserIds(sysRelationPersonList2);
                BigDecimal sumPremium1 = BigDecimal.ZERO;
                BigDecimal extractFee1 = BigDecimal.ZERO;
                if (CollectionUtil.isNotEmpty(userIds1)) {
                    for (String id : userIds1) {
                        //费用
                        List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                                .eq(SysPremiumDetails::getUserId, loginId)
                                .eq(SysPremiumDetails::getIssuerId,id)
                                .between(StringUtils.isNotEmpty(partnerGradeInfo.getBeginTime()) && StringUtils.isNotEmpty(partnerGradeInfo.getEndTime()),
                                        SysPremiumDetails::getCreateTime, partnerGradeInfo.getBeginTime(), partnerGradeInfo.getEndTime())
                                .eq(SysPremiumDetails::getStatus, 1)
                                .eq(partnerGradeInfo.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerGradeInfo.getIndustrySector()));

                        if (CollectionUtil.isNotEmpty(sysPremiumDetail)) {
                            Map<String, List<SysPremiumDetails>> map = sysPremiumDetail.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                                    .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                            for (String s : map.keySet()) {
                                List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                                sumPremium1 = sumPremium1.add(sysPremiumDetails1.get(0).getSumpremium());
                            }

//                                sumPremium1 = sumPremium1.add(sysPremiumDetail.get(0).getSumpremium());
                            BigDecimal reduce = sysPremiumDetail.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                            extractFee1 = extractFee1.add(reduce);
                        }
                    }
                }
                partnerInfoVo.setSumPremium(sumPremium1);
                partnerInfoVo.setExtractFee(extractFee1);

                int deptManNum = 0;
                if (sysRelationPersonList2.size() > 0) {
                    List<String> idList = sysRelationPersonList2.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                    List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                            .in(SysAgencyLeader::getUserId, idList).eq(SysAgencyLeader::getDelFlag, 1));
                    if (leaderList.size() > 0) {
                        for (SysAgencyLeader sysAgencyLeader : leaderList) {
                            //获取机构下的团队
                            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()));
                            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();

                                }
                            }
                        }
                    }
                }
                partnerInfoVo.setTeamManNum(deptManNum);

                partnerInfoVoList.add(partnerInfoVo);
            }
        }
        int sum = partnerInfoVoList.stream().mapToInt(PartnerInfoVo::getTeamManNum).sum();
        partnerInfoFreeVo.setTeamManNum(sum);
        partnerInfoFreeVo.setPartnerInfoVoList(partnerInfoVoList);

        return partnerInfoFreeVo;
    }

    @Override
    public BasePageResult<SysPremiumDetailsVo> getCommissionInfo(CommissionInfoDto commissionInfoDto) {
        List<SysPremiumDetailsVo> list = new ArrayList<>();
        String userId = BaseController.getUserId();
        int pageNum = commissionInfoDto.getPageNum();
        Page page = new Page(commissionInfoDto.getPageNum(), commissionInfoDto.getPageSize());
        commissionInfoDto.setUserId(userId);
        //int offset = (page - 1) * size;
        Page<Map<String, Object>> stringObjectList = sysPremiumDetailsMapper.queryInfoPages(page, commissionInfoDto);
        commissionInfoDto.setPageNum( (commissionInfoDto.getPageNum() -1) * commissionInfoDto.getPageSize());

        List<Map<String, Object>> stringObjectInfo = sysPremiumDetailsMapper.queryInfoPage(userId, commissionInfoDto);

        if (CollectionUtil.isEmpty(stringObjectInfo)) return new BasePageResult<>(pageNum, commissionInfoDto.getPageSize(), 0L, 0L,
                list);
        Map<String, List<SysPremiumDetails>> listMap = new HashMap<>();
        for (Map<String, Object> stringObjectMap : stringObjectInfo) {
            String companyId = (String) stringObjectMap.get("companyId");
            Object json = stringObjectMap.get("sysPremiumDetails");
            String s ="["+ json.toString()+"]";

            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
            List<SysPremiumDetails> sysPremiumDetails1 = null;
            try {
                sysPremiumDetails1 = objectMapper.readValue(s , new TypeReference<List<SysPremiumDetails>>() {});
            } catch (JsonProcessingException e) {
                throw new RuntimeException(e);
            }


            listMap.put(companyId,sysPremiumDetails1);

        }

//        Map<String, List<SysPremiumDetails>> listMap = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
//                .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
        for (String key : listMap.keySet()) {
            List<SysPremiumInfoVo> proportionList = new ArrayList<>();
            SysPremiumDetailsVo sysPremiumDetailsVo = new SysPremiumDetailsVo();
            sysPremiumDetailsVo.setCompanyId(key);
            List<SysPremiumDetails> detailsList = listMap.get(key);

            BigDecimal extractFee = detailsList.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
            sysPremiumDetailsVo.setExtractFee(extractFee);
            SysPremiumDetails sysPremiumDetails1 = detailsList.get(0);
            String issuerId = sysPremiumDetails1.getIssuerId();
            if (issuerId != null) {
                SysUser sysUser1 = sysUserMapper.selectById(issuerId);
                SysDept sysDept = sysDeptMapper.selectById(sysUser1.getDeptId());
                SysAgencyLeader sysAgencyLeader = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>()
                        .eq(SysAgencyLeader::getDelFlag, 1).eq(SysAgencyLeader::getDeptId, sysDept.getParentId()));
                SysRelationPerson sysRelationPerson = sysRelationPersonMapper.selectOne(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getAgencyLeaderId,sysAgencyLeader.getUserId())
                        .eq(SysRelationPerson::getSource,0).eq(SysRelationPerson::getType,1));

                SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                        .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, sysRelationPerson.getSuggestId()));
                sysPremiumDetailsVo.setProfferLevel(sysPartner.getType());
                SysUser sysUser = sysUserMapper.selectById(sysPartner.getUserId());
                sysPremiumDetailsVo.setProfferName(sysUser.getName());
                //直接工作室产生费用，显示工作室名称
                SysDept sysDept1 = sysDeptMapper.selectById(sysAgencyLeader.getDeptId());
                sysPremiumDetailsVo.setWorkName(sysDept1.getName());
            }
            sysPremiumDetailsVo.setSumpremium(sysPremiumDetails1.getSumpremium());
            SysUser sysUser = sysUserMapper.selectById(sysPremiumDetails1.getIssuerId());
            sysPremiumDetailsVo.setIssuerName(sysUser.getName());
            sysPremiumDetailsVo.setIssuerId(sysPremiumDetails1.getIssuerId());
            sysPremiumDetailsVo.setCreateTime(sysPremiumDetails1.getCreateTime());
            sysPremiumDetailsVo.setLicenseno(sysPremiumDetails1.getLicenseno());
            sysPremiumDetailsVo.setIndustrySector(sysPremiumDetails1.getIndustrySector());
            sysPremiumDetailsVo.setStatus(sysPremiumDetails1.getStatus());

            for (SysPremiumDetails premiumDetails : detailsList) {
                SysPremiumInfoVo sysPremiumInfoVo = new SysPremiumInfoVo();
                sysPremiumInfoVo.setSource(premiumDetails.getSource());
                sysPremiumInfoVo.setSumpremium(premiumDetails.getSumpremium());
                sysPremiumInfoVo.setProportional(premiumDetails.getProportional());
                sysPremiumInfoVo.setExtractFee(premiumDetails.getExtractFee());
                proportionList.add(sysPremiumInfoVo);
            }
            proportionList = proportionList.stream().sorted(Comparator.comparingInt(SysPremiumInfoVo::getSource)).collect(Collectors.toList());
            sysPremiumDetailsVo.setProfferList(proportionList);

            list.add(sysPremiumDetailsVo);
        }
        list =list.stream().sorted(Comparator.comparing(SysPremiumDetailsVo::getCreateTime).reversed()).collect(Collectors.toList());
//        long l = (list.size()+pageNum-1)/commissionInfoDto.getPageSize();
        return new BasePageResult<>(pageNum, commissionInfoDto.getPageSize(), stringObjectList.getTotal(), page.getPages(),
                list);
    }

    @Override
    public List<SysPremiumDetailsVo> getCommissionInfos(CommissionInfoDto commissionInfoDto) {
        List<SysPremiumDetailsVo> list = new ArrayList<>();
        String userId = BaseController.getUserId();
        List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                .eq(SysPremiumDetails::getUserId, userId)
                .eq(commissionInfoDto.getIndustrySector() != 0, SysPremiumDetails::getIndustrySector, commissionInfoDto.getIndustrySector())
                .between(StringUtils.isNotEmpty(commissionInfoDto.getBeginTime()) && StringUtils.isNotEmpty(commissionInfoDto.getEndTime()),
                        SysPremiumDetails::getCreateTime, commissionInfoDto.getBeginTime(), commissionInfoDto.getEndTime())
                .orderByDesc(SysPremiumDetails::getId).eq(SysPremiumDetails::getStatus,1));
        if (CollectionUtil.isEmpty(sysPremiumDetails)) return list;

        Map<String, List<SysPremiumDetails>> listMap = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
        for (String key : listMap.keySet()) {
            List<SysPremiumInfoVo> proportionList = new ArrayList<>();
            SysPremiumDetailsVo sysPremiumDetailsVo = new SysPremiumDetailsVo();
            sysPremiumDetailsVo.setCompanyId(key);
            List<SysPremiumDetails> detailsList = listMap.get(key);

            BigDecimal extractFee = detailsList.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
            sysPremiumDetailsVo.setExtractFee(extractFee);
            SysPremiumDetails sysPremiumDetails1 = detailsList.get(0);
            String issuerId = sysPremiumDetails1.getIssuerId();
            if (issuerId != null) {
                SysUser sysUser1 = sysUserMapper.selectById(issuerId);
                SysDept sysDept = sysDeptMapper.selectById(sysUser1.getDeptId());
                SysAgencyLeader sysAgencyLeader = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>()
                        .eq(SysAgencyLeader::getDelFlag, 1).eq(SysAgencyLeader::getDeptId, sysDept.getParentId()));
                SysRelationPerson sysRelationPerson = sysRelationPersonMapper.selectOne(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getAgencyLeaderId,sysAgencyLeader.getUserId())
                        .eq(SysRelationPerson::getSource,0).eq(SysRelationPerson::getType,1));

                SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                        .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, sysRelationPerson.getSuggestId()));
                sysPremiumDetailsVo.setProfferLevel(sysPartner.getType());
                SysUser sysUser = sysUserMapper.selectById(sysPartner.getUserId());
                sysPremiumDetailsVo.setProfferName(sysUser.getName());
            }
            sysPremiumDetailsVo.setSumpremium(sysPremiumDetails1.getSumpremium());
            SysUser sysUser = sysUserMapper.selectById(sysPremiumDetails1.getIssuerId());
            sysPremiumDetailsVo.setIssuerName(sysUser.getName());
            sysPremiumDetailsVo.setIssuerId(sysPremiumDetails1.getIssuerId());
            sysPremiumDetailsVo.setCreateTime(sysPremiumDetails1.getCreateTime());
            sysPremiumDetailsVo.setLicenseno(sysPremiumDetails1.getLicenseno());
            sysPremiumDetailsVo.setIndustrySector(sysPremiumDetails1.getIndustrySector());
            sysPremiumDetailsVo.setStatus(sysPremiumDetails1.getStatus());

            for (SysPremiumDetails premiumDetails : detailsList) {
                SysPremiumInfoVo sysPremiumInfoVo = new SysPremiumInfoVo();
                sysPremiumInfoVo.setSource(premiumDetails.getSource());
                sysPremiumInfoVo.setSumpremium(premiumDetails.getSumpremium());
                sysPremiumInfoVo.setProportional(premiumDetails.getProportional());
                sysPremiumInfoVo.setExtractFee(premiumDetails.getExtractFee());
                proportionList.add(sysPremiumInfoVo);
            }
            proportionList = proportionList.stream().sorted(Comparator.comparingInt(SysPremiumInfoVo::getSource)).collect(Collectors.toList());
            sysPremiumDetailsVo.setProfferList(proportionList);

            list.add(sysPremiumDetailsVo);
        }
//        if (commissionInfoDto.getType() != 0) {
//            return list.stream().filter(SysPremiumDetailsVo-> SysPremiumDetailsVo.getProfferLevel() == commissionInfoDto.getType()).collect(Collectors.toList());
//        }

        return list;
    }

    @Override
    public TeamUserInfosFreeVo getTeamUserInfo(TeamUserInfosDto teamUserInfosDto) {
        TeamUserInfosFreeVo teamUserInfosFreeVo = new TeamUserInfosFreeVo();
        String loginId = BaseController.getUserId();
        List<TeamUserInfosVo> userInfosVoList = new ArrayList<>();
        List<String> userIds = teamUserInfosDto.getUserIds();
        if (CollectionUtil.isEmpty(userIds)) {
            return teamUserInfosFreeVo;
        }
        BigDecimal sumPremium = BigDecimal.ZERO;
        BigDecimal extractFee = BigDecimal.ZERO;
        for (String userId : userIds) {
            //费用
            List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                    .eq(SysPremiumDetails::getUserId, loginId)
                    .eq(SysPremiumDetails::getIssuerId, userId)
                    .between(StringUtils.isNotEmpty(teamUserInfosDto.getBeginTime()) && StringUtils.isNotEmpty(teamUserInfosDto.getEndTime()),
                            SysPremiumDetails::getCreateTime, teamUserInfosDto.getBeginTime(), teamUserInfosDto.getEndTime())
                    .eq(SysPremiumDetails::getStatus, 1)
                    .eq(teamUserInfosDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, teamUserInfosDto.getIndustrySector()));
            if (sysPremiumDetails.size()>0) {
                Map<String, List<SysPremiumDetails>> map = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                        .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                for (String s : map.keySet()) {
                    List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                    sumPremium = sumPremium.add(sysPremiumDetails1.get(0).getSumpremium());
                }
//                SysPremiumDetails sysPremiumDetails1 = sysPremiumDetails.get(0);
//                sumPremium = sumPremium.add(sysPremiumDetails1.getSumpremium());
                BigDecimal reduce = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                extractFee = extractFee.add(reduce);
            }

        }
        teamUserInfosFreeVo.setSumPremium(sumPremium);
        teamUserInfosFreeVo.setExtractFee(extractFee);

        List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                .ne(SysUser::getStatus, 0).in(SysUser::getId, teamUserInfosDto.getUserIds()));
        for (SysUser sysUser : sysUsers) {
            TeamUserInfosVo teamUserInfosVo = new TeamUserInfosVo();
            teamUserInfosVo.setUserId(sysUser.getId());
            teamUserInfosVo.setUserName(sysUser.getName());
            EsmUserReferrer esmUserReferrer = esmUserReferrerMapper.selectById(sysUser.getId());
            if (esmUserReferrer != null) {
                teamUserInfosVo.setLeaderId(esmUserReferrer.getReferrerId());
                SysUser sysUser1 = sysUserMapper.selectById(esmUserReferrer.getReferrerId());
                teamUserInfosVo.setLeaderName(sysUser1.getName());
            }
            BigDecimal sumPremium1 =BigDecimal.ZERO;
            BigDecimal extractFee1 =BigDecimal.ZERO;
            //费用
            List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                    .eq(SysPremiumDetails::getIssuerId, sysUser.getId())
                    .eq(SysPremiumDetails::getUserId, loginId)
                    .between(StringUtils.isNotEmpty(teamUserInfosDto.getBeginTime()) && StringUtils.isNotEmpty(teamUserInfosDto.getEndTime()),
                            SysPremiumDetails::getCreateTime, teamUserInfosDto.getBeginTime(), teamUserInfosDto.getEndTime())
                    .eq(SysPremiumDetails::getStatus, 1)
                    .eq(teamUserInfosDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, teamUserInfosDto.getIndustrySector()));
            if (sysPremiumDetail.size()>0) {
                Map<String, List<SysPremiumDetails>> map = sysPremiumDetail.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                        .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                for (String s : map.keySet()) {
                    List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                    sumPremium1 = sumPremium1.add(sysPremiumDetails1.get(0).getSumpremium());
                }
                extractFee1 =extractFee1.add(sysPremiumDetail.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add)) ;
            }

            teamUserInfosVo.setSumPremium(sumPremium1);
            teamUserInfosVo.setExtractFee(extractFee1);
            userInfosVoList.add(teamUserInfosVo);
        }
        teamUserInfosFreeVo.setTeamManNum(userIds.size());
        teamUserInfosFreeVo.setTeamUserInfosVoList(userInfosVoList);

        return teamUserInfosFreeVo;
    }

    @Override
    public FilterPartnerInfoVo queryFilterPartnerInfo(FilterPartnerInfoDto filterPartnerInfoDto) {
        FilterPartnerInfoVo filterPartnerInfoVo = new FilterPartnerInfoVo();

        String userId = BaseController.getUserId();
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
        //查询登陆人下所有合伙人
        List<SysPartner> sysPartnerList = sysPartnerMapper.queryByLoginId(userId);

        Map<Integer, List<SysPartner>> listMap = sysPartnerList.stream().sorted(Comparator.comparing(SysPartner::getId))
                .collect(Collectors.groupingBy(SysPartner::getType));
        Integer partnerType = filterPartnerInfoDto.getPartnerType();

        List<SysPartner> sysPartnerList1 = listMap.get(sysPartner.getType() + partnerType);
        List<String> collect1 = sysPartnerList1.stream().map(SysPartner::getUserId).collect(Collectors.toList());
        if (collect1.size() == 0) {
            return filterPartnerInfoVo;
        }
        //费用
        List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                .in(CollectionUtil.isNotEmpty(collect1), SysPremiumDetails::getUserId, collect1)
                .between(StringUtils.isNotEmpty(filterPartnerInfoDto.getBeginTime()) && StringUtils.isNotEmpty(filterPartnerInfoDto.getEndTime()),
                        SysPremiumDetails::getCreateTime, filterPartnerInfoDto.getBeginTime(), filterPartnerInfoDto.getEndTime())
                .eq(SysPremiumDetails::getStatus, 1)
                .eq(filterPartnerInfoDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, filterPartnerInfoDto.getIndustrySector()));
        BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
        BigDecimal extractFee = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
        filterPartnerInfoVo.setSumPremium(sumPremium);
        filterPartnerInfoVo.setExtractFee(extractFee);

        if (sysPartnerList1.size() > 0) {

            List<PartnerInfoVo> partnerInfoVoList = new ArrayList<>();
            for (SysPartner partner : sysPartnerList1) {

                PartnerInfoVo partnerInfoVo = new PartnerInfoVo();

                String id = partner.getUserId();
                partnerInfoVo.setUserId(id);
                SysUser sysUser = sysUserMapper.selectById(id);
                partnerInfoVo.setUserName(sysUser.getName());
                SysUser sysUser1 = sysUserMapper.selectById(partner.getSuggestId());
                partnerInfoVo.setSuggestName(sysUser1.getName());
                //费用
                List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                        .eq(SysPremiumDetails::getUserId, id)
                        .between(StringUtils.isNotEmpty(filterPartnerInfoDto.getBeginTime()) && StringUtils.isNotEmpty(filterPartnerInfoDto.getEndTime()),
                                SysPremiumDetails::getCreateTime, filterPartnerInfoDto.getBeginTime(), filterPartnerInfoDto.getEndTime())
                        .eq(SysPremiumDetails::getStatus, 1)
                        .eq(filterPartnerInfoDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, filterPartnerInfoDto.getIndustrySector()));
                BigDecimal sumPremium1 = sysPremiumDetail.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                BigDecimal extractFee1 = sysPremiumDetail.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
                partnerInfoVo.setSumPremium(sumPremium1);
                partnerInfoVo.setExtractFee(extractFee1);
                //直接合伙人
                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, id)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 0)
                        .eq(SysRelationPerson::getSource, 0));
                List<String> collect = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                partnerInfoVo.setPartnerIds(collect);

                //直接管理员
                List<SysRelationPerson> sysRelationPersonList1 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, id)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 1)
                        .eq(SysRelationPerson::getSource, 0));

                List<String> collects = sysRelationPersonList1.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                partnerInfoVo.setLeaderIds(collects);

                partnerInfoVo.setPartnerNumber(collects.size() + collect.size());

                //工作室数
                List<SysRelationPerson> sysRelationPersonList2 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, id)
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getType, 1));

                int deptManNum = 0;
                if (sysRelationPersonList2.size() > 0) {
                    List<String> idList = sysRelationPersonList2.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                    List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                            .in(SysAgencyLeader::getUserId, idList).eq(SysAgencyLeader::getDelFlag, 1));
                    if (leaderList.size() > 0) {
                        for (SysAgencyLeader sysAgencyLeader : leaderList) {
                            //获取机构下的团队
                            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()));
                            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();

                                }
                            }
                        }
                    }
                    partnerInfoVo.setTeamManNum(deptManNum);
                }

                partnerInfoVoList.add(partnerInfoVo);

            }
            int sum = partnerInfoVoList.stream().mapToInt(PartnerInfoVo::getTeamManNum).sum();
            filterPartnerInfoVo.setPartnerInfoVoList(partnerInfoVoList);
            filterPartnerInfoVo.setTeamManNum(sum);

        }

        return filterPartnerInfoVo;
    }

    @Override
    public PartnerLeaderInfoVo partnerLeaderInfo(PartnerGradeInfo partnerGradeInfo) {
        PartnerLeaderInfoVo partnerLeaderInfoVo = new PartnerLeaderInfoVo();

        List<PartnerInfoVo> partnerInfoVoList = new ArrayList<>();
        //工作室
        List<String> leaderIds = partnerGradeInfo.getLeaderIds();
        if (CollectionUtil.isEmpty(leaderIds)) {
            return partnerLeaderInfoVo;
        }
        List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                .in(SysAgencyLeader::getUserId, leaderIds).eq(SysAgencyLeader::getDelFlag, 1));


        List<String> userIdByLeader = getUserIdByLeader(leaderList);
        for (SysAgencyLeader sysAgencyLeader : leaderList) {
            BigDecimal sumPremium1 = BigDecimal.ZERO;
            BigDecimal extractFee1 = BigDecimal.ZERO;
            PartnerInfoVo partnerInfoVo = new PartnerInfoVo();

            String userId = sysAgencyLeader.getUserId();
            partnerInfoVo.setUserId(userId);
            SysUser sysUser = sysUserMapper.selectById(userId);
            partnerInfoVo.setUserName(sysUser.getName());
            SysUser sysUser1 = sysUserMapper.selectById(sysAgencyLeader.getSuggestId());
            partnerInfoVo.setSuggestName(sysUser1.getName());
            partnerInfoVo.setDeptId(sysAgencyLeader.getDeptId());
            SysDept sysDept1 = sysDeptMapper.selectById(sysAgencyLeader.getDeptId());
            partnerInfoVo.setDeptName(sysDept1.getName());
            //团队总人数
            int deptManNum = 0;
            //获取机构下的团队
            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()));

            partnerInfoVo.setDeptNum(sysDeptList.size());
            List<String> collect = sysDeptList.stream().map(SysDept::getId).collect(Collectors.toList());

            partnerInfoVo.setDeptIds(collect);
            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();
                    if (CollectionUtil.isNotEmpty(sysUsers)) {
                        for (SysUser user : sysUsers) {
                            //费用
                            List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                                    .eq(SysPremiumDetails::getUserId, BaseController.getUserId())
                                    .eq(SysPremiumDetails::getIssuerId, user.getId())
                                    .between(StringUtils.isNotEmpty(partnerGradeInfo.getBeginTime()) && StringUtils.isNotEmpty(partnerGradeInfo.getEndTime()),
                                            SysPremiumDetails::getCreateTime, partnerGradeInfo.getBeginTime(), partnerGradeInfo.getEndTime())
                                    .eq(SysPremiumDetails::getStatus, 1)
                                    .eq(partnerGradeInfo.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerGradeInfo.getIndustrySector()));
                            if (sysPremiumDetail.size() >0) {
                                Map<String, List<SysPremiumDetails>> map = sysPremiumDetail.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                                        .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                                for (String s : map.keySet()) {
                                    List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                                    sumPremium1= sumPremium1.add(sysPremiumDetails1.get(0).getSumpremium());
                                }
//                                SysPremiumDetails sysPremiumDetails = sysPremiumDetail.get(0);
//                                sumPremium1= sumPremium1.add(sysPremiumDetail.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add));

                                extractFee1 = extractFee1.add(sysPremiumDetail.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add));
                            }
                        }
                    }
                }
            }
            partnerInfoVo.setSumPremium(sumPremium1);
            partnerInfoVo.setExtractFee(extractFee1);
            partnerInfoVo.setTeamManNum(deptManNum);
            partnerInfoVo.setLevel(partnerGradeInfo.getLevel());

            partnerInfoVoList.add(partnerInfoVo);
        }
        //top总费用
        BigDecimal sumPremium = BigDecimal.ZERO;
        BigDecimal extractFee = BigDecimal.ZERO;
        if (userIdByLeader.size()>0) {
            for (String id : userIdByLeader) {
                //总费用
                List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
                        .eq(SysPremiumDetails::getUserId, BaseController.getUserId())
                        .eq(SysPremiumDetails::getIssuerId, id)
                        .between(StringUtils.isNotEmpty(partnerGradeInfo.getBeginTime()) && StringUtils.isNotEmpty(partnerGradeInfo.getEndTime()),
                                SysPremiumDetails::getCreateTime, partnerGradeInfo.getBeginTime(), partnerGradeInfo.getEndTime())
                        .eq(SysPremiumDetails::getStatus, 1)
                        .eq(partnerGradeInfo.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, partnerGradeInfo.getIndustrySector()));

                if (sysPremiumDetails.size() >0) {
                    Map<String, List<SysPremiumDetails>> map = sysPremiumDetails.stream().sorted(Comparator.comparing(SysPremiumDetails::getId))
                            .collect(Collectors.groupingBy(SysPremiumDetails::getCompanyId));
                    for (String s : map.keySet()) {
                        List<SysPremiumDetails> sysPremiumDetails1 = map.get(s);
                        sumPremium= sumPremium.add(sysPremiumDetails1.get(0).getSumpremium());
                    }
//                    SysPremiumDetails sysPremiumDetails1 = sysPremiumDetails.get(0);
//                    sumPremium= sumPremium.add(sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add));

                    extractFee = extractFee.add(sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add));
                }

            }
        }
        partnerLeaderInfoVo.setSumPremium(sumPremium);
        partnerLeaderInfoVo.setExtractFee(extractFee);

        int sum = partnerInfoVoList.stream().mapToInt(PartnerInfoVo::getTeamManNum).sum();
        partnerLeaderInfoVo.setUserIds(userIdByLeader);
        partnerLeaderInfoVo.setTeamManNum(sum);
        partnerLeaderInfoVo.setPartnerInfoVoList(partnerInfoVoList);


        return partnerLeaderInfoVo;
    }

    @Override
    public List<SysPartnerVo> getRelationInfo(String userId) {
        List<SysPartnerVo> sysPartners = new ArrayList<>();
        //登陆人的上下级合伙人信息
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
        SysPartnerVo sysPartnerVo = BeanUtil.copyProperties(sysPartner, SysPartnerVo.class);
        sysPartners.add(sysPartnerVo);
        List<String> ids = new ArrayList<>();
        List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getAgencyLeaderId, userId).eq(SysRelationPerson::getType, 0).orderByDesc(SysRelationPerson::getId));
        if (sysRelationPersonList.size() > 0) {
            List<String> collect = sysRelationPersonList.stream().map(SysRelationPerson::getSuggestId).collect(Collectors.toList());

            if (collect.size()>0) {
                ids.addAll(collect);
            }

        }

        List<SysRelationPerson> sysRelationList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getSuggestId, userId).eq(SysRelationPerson::getType, 0));
        if (sysRelationList.size() > 0) {

            List<String> collect1 = sysRelationList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
            if (collect1.size() >0) {
                ids.addAll(collect1);
            }
        }
        if (CollectionUtil.isNotEmpty(ids)) {
            List<SysPartner> sysPartnerList = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>()
                    .in(SysPartner::getUserId, ids).eq(SysPartner::getDelFlag, 1));
            List<SysPartnerVo> sysPartnerVos = BeanUtil.copyToList(sysPartnerList, SysPartnerVo.class);
            sysPartners.addAll(sysPartnerVos);
        }
        List<SysPartnerVo> sysPartnerVoList = sysPartners.stream().sorted(Comparator.comparing(SysPartner::getId)).collect(Collectors.toList());
        if (sysPartnerVoList.size() > 0) {
            for (SysPartnerVo partner : sysPartnerVoList) {
                SysUser sysUser1 = sysUserMapper.selectById(partner.getUserId());
                partner.setMobile(sysUser1.getMobile());
                partner.setUserName(sysUser1.getName());
                SysDept sysDept = sysDeptMapper.selectById(sysUser1.getDeptId());
                partner.setDeptName(sysDept.getName());
                SysDept sysDept1 = sysDeptMapper.selectById(sysDept.getParentId());
                partner.setAgencyName(sysDept1.getName());

                String suggestId = partner.getSuggestId();
                if (StringUtils.isNotEmpty(suggestId)) {
                    SysUser sysUser = sysUserMapper.selectById(partner.getSuggestId());
                    partner.setSuggestName(sysUser.getName());

                }
            }
        }

        return sysPartnerVoList;
    }

    @Override
    public CountUserVo getCountUser(CountUserDto countUserDto) {
        CountUserVo countUserVo = new CountUserVo();
        String userId = BaseController.getUserId();
        //原始参数
        String startTime1 = countUserDto.getBeginTime();
        String endTime1 = countUserDto.getEndTime();

        int deptSum = 0;
        int deptManSum = 0;
        List<String> deptIds = new ArrayList<>();
        //查工作室下的团队
        SysAgencyLeader sysAgencyLeader = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper<SysAgencyLeader>()
                .eq(SysAgencyLeader::getDelFlag, 1).in(SysAgencyLeader::getUserId, userId));
        List<SysUser> userList = new ArrayList<>();
        //根据机构id查下面团队
        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()));
        deptSum = deptSum + sysDeptList.size();
        if (sysDeptList.size() > 0) {
            for (SysDept sysDept : sysDeptList) {
                deptIds.add(sysDept.getId());
                //团队下的人数
                List<SysUser> sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                        .likeRight(SysUser::getId, sysDept.getId())
                        .ne(SysUser::getStatus, 0));
                userList.addAll(sysUserList);
                deptManSum = deptManSum + sysUserList.size();
            }

            countUserVo.setDeptSum(deptSum);
            countUserVo.setDeptManSum(deptManSum);
            List<SysUser> collect;
            if (CollectionUtil.isNotEmpty(userList)) {
                try {
                    if (StringUtils.isNotEmpty(startTime1)) {
                        SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

                        Date parse = simpleDateFormat1.parse(startTime1);
                        Date parse1 = simpleDateFormat1.parse(endTime1);

                        collect = userList.stream().filter(SysUser -> SysUser.getCreateTime().after(parse)
                                && SysUser.getCreateTime().before(parse1)).collect(Collectors.toList());

                    } else {
                        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
                        Date date = new Date();
                        String format = simpleDateFormat.format(date);
                        String start = format + " 00:00:01";
                        String end = format + " 23:59:59";
                        SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

                        Date parse = simpleDateFormat1.parse(start);
                        Date parse1 = simpleDateFormat1.parse(end);

                        collect = userList.stream().filter(SysUser -> SysUser.getCreateTime().after(parse)
                                && SysUser.getCreateTime().before(parse1)).collect(Collectors.toList());
                    }

                    countUserVo.setCountSum(collect.size());

                } catch (Exception e) {
                    throw new SystemException("系统繁忙,请联系管理员");
                }
            } else {
                countUserVo.setCountSum(0);
            }

            //曲线图
            List<CountUserNumVo> countUserNumVoList = null;
            int type = countUserDto.getType();

            //类型：1：团队 2：代理人
            if (type == 1) {
                if (StringUtils.isNotEmpty(startTime1)) {
                    String s = startTime1.split(" ")[0];
                    String s1 = endTime1.split(" ")[0];
                    if (s.equals(s1)) {
                        //查一天的数据
                        countUserNumVoList = sysPartnerMapper.queryDeptByTimes(deptIds, countUserDto);
                    } else {
                        countUserNumVoList = sysPartnerMapper.queryDeptByTime(deptIds, countUserDto);
                    }
                } else {
                    countUserNumVoList = sysPartnerMapper.queryDeptByTime(deptIds, countUserDto);
                }

            } else {
                if (StringUtils.isNotEmpty(startTime1)) {
                    String s = startTime1.split(" ")[0];
                    String s1 = endTime1.split(" ")[0];
                    if (s.equals(s1)) {
                        countUserNumVoList = sysPartnerMapper.queryUserByTimes(deptIds, countUserDto);
                    } else {
                        countUserNumVoList = sysPartnerMapper.queryUserByTime(deptIds, countUserDto);
                    }
                } else {
                    countUserNumVoList = sysPartnerMapper.queryUserByTime(deptIds, countUserDto);
                }

            }
            countUserVo.setCountUserNumVoList(countUserNumVoList);
        }


        return countUserVo;
    }

    @Override
    public PartnerCountVo getPartnerCount(PartnerCountDto partnerCountDto) {
        PartnerCountVo partnerCountVo = new PartnerCountVo();
        String userId = BaseController.getUserId();
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
        int type = sysPartner.getType();
        partnerCountDto.setType(type + partnerCountDto.getType());
        //查询登陆人下所有合伙人
        List<SysPartner> sysPartnerList = sysPartnerMapper.queryPartnerById(userId, partnerCountDto);
        if (CollectionUtil.isNotEmpty(sysPartnerList)){
            //统计每一个等级的合伙人数
            if (type == 1) {
                //1
                List<SysPartner> onePartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 1).collect(Collectors.toList());
                partnerCountVo.setOnePartnerNum(onePartners.size());
                //2
                List<SysPartner> twoPartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 2).collect(Collectors.toList());
                partnerCountVo.setTwoPartnerNum(twoPartners.size());
                //3
                List<SysPartner> threePartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 3).collect(Collectors.toList());
                partnerCountVo.setThreePartnerNum(threePartners.size());
                //4
                List<SysPartner> fourPartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 4).collect(Collectors.toList());
                partnerCountVo.setFourPartnerNum(fourPartners.size());

            } else if (type == 2) {
                //1
                List<SysPartner> onePartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 1).collect(Collectors.toList());
                partnerCountVo.setOnePartnerNum(onePartners.size());
                //2
                List<SysPartner> twoPartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 2).collect(Collectors.toList());
                partnerCountVo.setTwoPartnerNum(twoPartners.size());
                //3
                List<SysPartner> threePartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 3).collect(Collectors.toList());
                partnerCountVo.setThreePartnerNum(threePartners.size());

            } else if (type == 3) {
                //1
                List<SysPartner> onePartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 1).collect(Collectors.toList());
                partnerCountVo.setOnePartnerNum(onePartners.size());
                //2
                List<SysPartner> twoPartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 2).collect(Collectors.toList());
                partnerCountVo.setTwoPartnerNum(twoPartners.size());

            } else if (type == 4) {
                //1
                List<SysPartner> onePartners = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == type + 1).collect(Collectors.toList());
                partnerCountVo.setOnePartnerNum(onePartners.size());
            }
        }


        //工作室
        List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getSuggestId, userId)
                .eq(SysRelationPerson::getDelFlag, 1)
                .eq(SysRelationPerson::getSource, 0)
                .eq(SysRelationPerson::getType, 1));
        partnerCountVo.setWorkSum(sysRelationPersonList.size());
        if (CollectionUtil.isNotEmpty(sysRelationPersonList)) {
            List<String> collect = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
            //查工作室下的团队
            List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                    .eq(SysAgencyLeader::getDelFlag, 1).in(SysAgencyLeader::getUserId, collect));
            int deptSum = 0;
            int deptManSum = 0;

            for (SysAgencyLeader sysAgencyLeader : leaderList) {
                //根据机构id查下面团队
                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()));
                deptSum = deptSum + sysDeptList.size();
                if (sysDeptList.size() > 0) {
                    for (SysDept sysDept : sysDeptList) {
                        //团队下的人数
                        List<SysUser> sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                                .likeRight(SysUser::getId, sysDept.getId())
                                .in(SysUser::getStatus, Arrays.asList(1, 4, 5, 6, 7)));
                        deptManSum = deptManSum + sysUserList.size();
                    }
                }
            }

            partnerCountVo.setDeptSum(deptSum);
            partnerCountVo.setDeptManSum(deptManSum);

        }
        //曲线图
        List<CountUserNumVo> countUserNumVoList;
        String beginTime = partnerCountDto.getBeginTime();
        String s = "";
        String s1 = "";
        if (StringUtils.isNotEmpty(beginTime)) {
            s = partnerCountDto.getBeginTime().split(" ")[0];
            s1 = partnerCountDto.getEndTime().split(" ")[0];
        }

        if (StringUtils.isNotEmpty(s)) {
            if (s.equals(s1)) {
                //查一天的数据
                countUserNumVoList = sysPartnerMapper.queryPartnerByTimes(userId, partnerCountDto);
            } else {
                countUserNumVoList = sysPartnerMapper.queryPartnerByTime(userId, partnerCountDto);
            }

        } else {
            countUserNumVoList = sysPartnerMapper.queryPartnerByTime(userId, partnerCountDto);
        }

        partnerCountVo.setCountUserNumVoList(countUserNumVoList);

        return partnerCountVo;
    }


    @Override
    public PartnerCountVo getFivePartnerCount(PartnerCountDto partnerCountDto) {
        PartnerCountVo partnerCountVo = new PartnerCountVo();
        String userId = BaseController.getUserId();
        //原始参数
        String startTime1 = partnerCountDto.getBeginTime();
        String endTime1 = partnerCountDto.getEndTime();
        List<String> deptIds = new ArrayList<>();
        //工作室
        List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getSuggestId, userId)
                .eq(SysRelationPerson::getDelFlag, 1)
                .eq(SysRelationPerson::getSource, 0)
                .eq(SysRelationPerson::getType, 1));
        partnerCountVo.setWorkSum(sysRelationPersonList.size());
        if (CollectionUtil.isNotEmpty(sysRelationPersonList)) {
            List<String> workIds = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
            //查工作室下的团队
            List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
                    .eq(SysAgencyLeader::getDelFlag, 1).in(SysAgencyLeader::getUserId, workIds));
            int deptSum = 0;
            int deptManSum = 0;

            for (SysAgencyLeader sysAgencyLeader : leaderList) {
                //根据机构id查下面团队
                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()));
                deptSum = deptSum + sysDeptList.size();
                if (sysDeptList.size() > 0) {
                    for (SysDept sysDept : sysDeptList) {
                        deptIds.add(sysDept.getId());
                        //团队下的人数
                        List<SysUser> sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
                                .likeRight(SysUser::getId, sysDept.getId())
                                .ne(SysUser::getStatus, 0));
                        deptManSum = deptManSum + sysUserList.size();
                    }
                }
            }

            partnerCountVo.setDeptSum(deptSum);
            partnerCountVo.setDeptManSum(deptManSum);

            //曲线图
            List<CountUserNumVo> countUserNumVoList = null;

            int type = partnerCountDto.getNumber();

            //类型：1：工作室，2：团队 3：代理人
            if (type == 1) {
                if (StringUtils.isNotEmpty(startTime1)) {
                    String s = startTime1.split(" ")[0];
                    String s1 = endTime1.split(" ")[0];
                    if (s.equals(s1)) {
                        //查一天的数据
                        countUserNumVoList = sysAgencyLeaderMapper.queryWorkByFive(workIds,partnerCountDto);
                    } else {
                        //查日期范围数据
                        countUserNumVoList = sysAgencyLeaderMapper.queryWorkByFiveTime(workIds,partnerCountDto);
                    }
                } else {
                    countUserNumVoList = sysAgencyLeaderMapper.queryWorkByFiveTime(workIds,partnerCountDto);
                }


            }else if (type == 2) {
                if (StringUtils.isNotEmpty(startTime1)) {
                    String s = startTime1.split(" ")[0];
                    String s1 = endTime1.split(" ")[0];
                    if (s.equals(s1)) {
                        //查一天的数据
                        countUserNumVoList = sysPartnerMapper.queryDeptByFiveTime(deptIds, partnerCountDto);
                    } else {
                        countUserNumVoList = sysPartnerMapper.queryDeptByFive(deptIds, partnerCountDto);
                    }
                } else {
                    countUserNumVoList = sysPartnerMapper.queryDeptByFive(deptIds, partnerCountDto);
                }

            } else if (type == 3){
                if (StringUtils.isNotEmpty(startTime1)) {
                    String s = startTime1.split(" ")[0];
                    String s1 = endTime1.split(" ")[0];
                    if (s.equals(s1)) {
                        countUserNumVoList = sysPartnerMapper.queryUserByFive(deptIds, partnerCountDto);
                    } else {
                        countUserNumVoList = sysPartnerMapper.queryUserByFiveTime(deptIds, partnerCountDto);
                    }
                } else {
                    countUserNumVoList = sysPartnerMapper.queryUserByFiveTime(deptIds, partnerCountDto);
                }

            }

            partnerCountVo.setCountUserNumVoList(countUserNumVoList);
        }


        return partnerCountVo;
    }

    @Override
    public PartnerProportionVo getPartnerProportion(PartnerCountDto partnerCountDto) {
        PartnerProportionVo partnerProportionVo = new PartnerProportionVo();
        String userId = BaseController.getUserId();
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
        int level = sysPartner.getType() + partnerCountDto.getType();
        List<SysPartner> sysPartnerList = sysPartnerMapper.queryByLoginId(userId);
        List<SysPartner> collectNum;
        List<SysPartner> collectSum;
        try {
            if (StringUtils.isNotEmpty(partnerCountDto.getBeginTime())) {
                SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

                Date parse = simpleDateFormat1.parse(partnerCountDto.getBeginTime());
                Date parse1 = simpleDateFormat1.parse(partnerCountDto.getEndTime());
                collectNum = sysPartnerList.stream().filter(SysPartner -> SysPartner.getCreateTime().after(parse)
                                && SysPartner.getCreateTime().before(parse1) && SysPartner.getType() == level)
                        .collect(Collectors.toList());

                collectSum = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == level)
                        .collect(Collectors.toList());
            } else {
                SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
                Date date = new Date();
                String format = simpleDateFormat.format(date);
                String start = format + " 00:00:01";
                String end = format + " 23:59:59";
                SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

                Date parse = simpleDateFormat1.parse(start);
                Date parse1 = simpleDateFormat1.parse(end);
                collectNum = sysPartnerList.stream().filter(SysPartner -> SysPartner.getCreateTime().after(parse)
                                && SysPartner.getCreateTime().before(parse1) && SysPartner.getType() == level)
                        .collect(Collectors.toList());

                collectSum = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == level)
                        .collect(Collectors.toList());

            }
        } catch (Exception e) {
            throw new SystemException("系统繁忙,请联系管理员");
        }

        partnerProportionVo.setNewNum(Optional.ofNullable(collectNum.size()).orElse(0));
        partnerProportionVo.setNumber(Optional.ofNullable(collectSum.size()).orElse(0));
        if (CollectionUtil.isNotEmpty(collectSum)) {
            int i = collectSum.size() - collectNum.size();
            partnerProportionVo.setOldNum(i);
        }
        if (CollectionUtil.isNotEmpty(collectNum)) {
            double v = (float) collectNum.size() / (float) collectSum.size() * 100;
            String format = String.format("%.2f", v);
            Double aDouble = Double.valueOf(format);
            partnerProportionVo.setNewProportion(aDouble);
        }
        int oldNum = partnerProportionVo.getOldNum();
        if (oldNum != 0) {
            double v = (float) oldNum / (float) collectSum.size() * 100;
            String format = String.format("%.2f", v);
            Double aDouble = Double.valueOf(format);
            partnerProportionVo.setOldProportion(aDouble);
        }

        return partnerProportionVo;
    }

    @Override
    public List<LevelPartnerVo> getLevelPartner(Integer type) {
        List<LevelPartnerVo> partnerVoList = new ArrayList<>();
        String userId = BaseController.getUserId();
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getUserId, userId).eq(SysPartner::getDelFlag, 1));
        int level = sysPartner.getType() + type;

        List<SysPartner> sysPartnerList = sysPartnerMapper.queryByLoginId(userId);

        List<SysPartner> collect = sysPartnerList.stream().filter(SysPartner -> SysPartner.getType() == level)
                .collect(Collectors.toList());
        if (CollectionUtil.isEmpty(collect)) return partnerVoList;

        for (SysPartner partner : collect) {
            LevelPartnerVo levelPartnerVo = new LevelPartnerVo();

            levelPartnerVo.setId(partner.getId());
            SysUser sysUser = sysUserMapper.selectById(partner.getUserId());
            levelPartnerVo.setUserName(sysUser.getName());
            //查合伙人下的工作室下团队的所有人
            List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                    .eq(SysRelationPerson::getSuggestId, partner.getUserId())
                    .eq(SysRelationPerson::getDelFlag, 1)
                    .eq(SysRelationPerson::getSource,0)
                    .eq(SysRelationPerson::getType, 0));
            levelPartnerVo.setDeptManNum(sysRelationPersonList.size());
            if (CollectionUtil.isNotEmpty(sysRelationPersonList)) {
                List<String> strings = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
                levelPartnerVo.setPartnerIds(strings);
            }

            partnerVoList.add(levelPartnerVo);
        }


        return partnerVoList.stream().sorted(Comparator.comparingInt(LevelPartnerVo::getDeptManNum).reversed()).collect(Collectors.toList());
    }

    @Override
    public HttpResult<AAPLoginVo> loginAlipay(AlipayBindVo alipayBindVo) throws AlipayApiException {
        AAPLoginVo aapLoginVo = new AAPLoginVo();
        AlipayClient alipayClient = new DefaultAlipayClient(getAlipayConfig());

        // 构造请求参数以调用接口
        AlipaySystemOauthTokenRequest request = new AlipaySystemOauthTokenRequest();

        // 设置授权码
        request.setCode(alipayBindVo.getCode());

        // 设置授权方式
        request.setGrantType("authorization_code");

        AlipaySystemOauthTokenResponse response = alipayClient.execute(request);
        String aliPayId = response.getUserId();
        SysUser sysUser = sysUserService.lambdaQuery()
                .eq(SysUser::getAlipay, aliPayId)
                .one();

        // 没有绑定支付宝
        if (sysUser == null) {
            throw new SystemException("您还未绑定工号");
        }
        //校验登录用户是否为合伙人或者是机构负责人
        boolean a = this.checkPartner(sysUser.getId());
        boolean b = sysAgencyLeaderService.checkUserId(sysUser.getId());
        if (a) {
            SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getUserId, sysUser.getId()));
            //类型：1.合伙人;2机构负责人
            aapLoginVo.setType(1);
            aapLoginVo.setLevel(sysPartner.getType());
        } else if (b) {
            aapLoginVo.setType(2);
        } else {
            throw new SystemException("该用户无权限登录AAP,只能合伙人或者工作室管理员才能登录!");

        }
        SysUser.verifyUser(sysUser);//验证用户状态

        String token = StpUtil.createLoginSession(sysUser.getId());
//        AlipayVo alipayVo = new AlipayVo(token, sysUser.getId());
        StpUtil.getSessionByLoginId(sysUser.getId()).set(SaSession.USER, sysUser);
        aapLoginVo.setUserId(sysUser.getId());
        aapLoginVo.setToken(token);
        log.info("支付宝登录返参：{}",aapLoginVo);
        return HttpResult.ok("", aapLoginVo);
    }

    @Override
    public String checkBindAlipay() {
        SysUser sysUser = sysUserMapper.selectById(BaseController.getUserId());
        return sysUser.getAlipay();
    }

    @Override
    public HttpResult<Object> bindAlipay(AlipayBindVo alipayBindVo, String userId) throws AlipayApiException {
        log.info("userId:{}",userId);
        AlipayClient alipayClient = new DefaultAlipayClient(getAlipayConfig());

        // 构造请求参数以调用接口
        AlipaySystemOauthTokenRequest request = new AlipaySystemOauthTokenRequest();

        // 设置授权码
        request.setCode(alipayBindVo.getCode());

        // 设置授权方式
        request.setGrantType("authorization_code");
        log.info("-----------------获取支付宝ID-------------");
        AlipaySystemOauthTokenResponse response = alipayClient.execute(request);
        log.info("授权返回值：{}", JSONObject.toJSON(response));
        String aliPayId = response.getUserId();
        log.info("支付宝的aliPayId={}",aliPayId);
        SysUser sysUser = sysUserService.lambdaQuery().eq(SysUser::getAlipay, aliPayId).one();
        if (sysUser != null) {
            throw new SystemException("同一支付宝不能重复绑定");
        }

        SysUser user = sysUserService.lambdaQuery().eq(SysUser::getId, userId).one();
        if (ObjectUtils.isEmpty(user)) {
            throw new SystemException("你输入的工号不存在");
        }

        user.setAlipay(aliPayId);
        boolean update = sysUserService.updateById(user);

        if (update) {
            log.info("支付宝绑定成功");
            return HttpResult.ok("绑定成功");
        }
        throw new SystemException("绑定失败");
    }

    //获取支付宝账户信息
    private static AlipayConfig getAlipayConfig() {
        String privateKey = "MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQCHXiWh2HopAtG69Wju2OIjB0F82AsLoP4TjUEsMWybWw97UhtpofF6qIOZ2hyu1RsM032VWYgvQrxHxXBL4mu+KH3jKK9cBB/FyH/J3RMSJeDHVRbHCbH5GB38L0f0Bg0DSzdlr7/oaFd2jm95NY8T2y+4WDI+6+vKPtcrEgbV79t8B6R20G7DuefNXoELE7H8fuz7hb3e+dApQ0Zp+VxpGIZPItVeddib+d+fQ9ha5ypAuP0mflXoOXW5ZY8jXDTKwVESpJ94y08yKuW4JsN32Se87d0Md2baJiVODwbzxxGNTRQavaQRR1Ve+CKKpqENz7N/w/mLJG7IxJjCzWN3AgMBAAECggEAEFDFomMwHh9L3gfUNO2JHAW02/JCKo2l8f9VepkeaP8pt4hm621saIdFDVcfm+btkrcu7MBUzLVzcgcXCN5qdAn3Wli+Ag4xMip/VHpD4S0VkZDs5OKDQ+2nN40PVBcinGIFdEkhjUZ+PDjgsLBG5XLGpqZir/jJe5/lWTicAE7ytr4zDVdrLWC45LMsEs49B2Ngwr+pLaYdzKK5oCEaVQCOAWyg77HEpnd+4sJeQUzpnfteN60IFp810Ec7a31b6E0rfq19Owqe6H/jp/fjiTouJSwfxjn3WMaAwZdA3D9SS9ukc9r878j92fdkeDQUpO41AGY3P3sWdexUjHz5cQKBgQC+9eauh65cPb1jzSQ149x+qyxBy6axpUUFbA08taYJIJdA6wSjXX8eCz3muMSjY616pA4c1gB3q3fEKBWD8NpaWJJvwae22mlhb27WlAiH7ND01hfcMHWefREcCFBHJnFRWScAvPRJtffU+csq1mYB62N2PgGPKgSAV5Zb+hD/DwKBgQC1eQnLdehVttSL3NWz7sf6Qdm+yloj38LgGtL8rj3Kankzb+Ty9RySTjnWidSzqfTaAa/1P9NGHrQh6hRz/DJXO3lUohOANijTT5dmOqg/M5nuR7K+cRCsHHaSEYicfgYalkkh3plDtcRQ4n52Z5ZAZvDLg3Id9+noQGlebkPVGQKBgQCMh1/kzprE7PaEDIJ6Wh545TUjkmAw2UQK8nJnW/I9Q0usDYgTRQn4LSO3t/+VkhQnbbWpCN+9MWVo6Gq09zlpRUc2kRgAW4kzmBLEPJpulRtNIoTamJrmMHm33HJfee3ohKhMRcGswQoKJG2cL71P6k7+xDDXj39Sh6JyO3vohwKBgGHbXxjEAAEYkgzJjMN2Y4fjspNbcrgdlWxbiqKPIurf93NxRzhsTHfoju/Na1FmuI5GkqfhPwB01hXjsBvLRyoa/BZTP8jHa8RnCvEpeEh8fukq6IwhVCg7QQULR2t72bbEi7Mj4enNPouPVzpqKW+ZEwfrXcIjSZLgCPHO6+0hAoGARv/95Q6wdP9NUoAQJqkETze/hEF8Ny51oephrOPsVfB7rAU1NQjp+k+/Q9UG1xz22lSkWd9kWcMTGjiAZzOy+AJF7tlnJV+5V79/OM1BBsB69oU3AF0Xqzwl/7gKzLsNQ7ZJflNPILIQlVw9IqfFlbHIBqY6fw7nhlmNp9tzabA=";
        String alipayPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEArP+St5P9dLhPmm/ggf3jPDc2552wu/+91QSAzlEqRSrdWAIwrHcntM0VY/4/+39Z8h44/0TBNTb0j1gdWrCyb+1ENxwwgCqs7f8C/5gClTQCcoNys4MtGAAM7BbNp/LzmswOuPTOMtjlUBArWFvJDgDoSQJ8vGwGHgRcLsSLPwlhwVdnqVbq60CI185U/yZgNITTCGpDXv5bnQQ26GrUbH+5Qm4fYmT2B/2ijAVJUYq+EaBMOyv+AD8C1+CtXcgH86+g13MdD1T8cw5nkV9/4fcPIWD8R1aj20C1+kCMujaydB4yDpHiqQcQEtJoVbZJk5MYp8JcctqDT01brVct5wIDAQAB";
        AlipayConfig alipayConfig = new AlipayConfig();
        alipayConfig.setServerUrl("https://openapi.alipay.com/gateway.do");
        alipayConfig.setAppId("2021004193614682");
        alipayConfig.setPrivateKey(privateKey);
        alipayConfig.setFormat("json");
        alipayConfig.setAlipayPublicKey(alipayPublicKey);
        alipayConfig.setCharset("UTF-8");
        alipayConfig.setSignType("RSA2");
        return alipayConfig;
    }

    @Override
    public HttpResult<AAPLoginVo> loginWechat(WechatLoginVo wechatLoginVo) throws WxErrorException {
        AAPLoginVo aapLoginVo = new AAPLoginVo();
        WxOAuth2AccessToken accessToken = wxMpService.get(WechatOpenSystem.HHR.getCode()).getOAuth2Service().getAccessToken(wechatLoginVo.getCode());
        String openId = accessToken.getOpenId();
        log.info("微信登录openId：{}",openId);
        SysUser sysUser = sysUserService.lambdaQuery()
                .eq(SysUser::getOpenid, openId)
                .one();
        // 没有绑定微信
        if (sysUser == null) {
            throw new SystemException("您还未绑定工号。");
        }
        //校验登录用户是否为合伙人或者是机构负责人
        boolean a = this.checkPartner(sysUser.getId());
        boolean b = sysAgencyLeaderService.checkUserId(sysUser.getId());
        if (a) {
            SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getUserId, sysUser.getId()));
            //类型：1.合伙人;2机构负责人
            aapLoginVo.setType(1);
            aapLoginVo.setLevel(sysPartner.getType());
        } else if (b) {
            aapLoginVo.setType(2);
        } else {
            throw new SystemException("该用户无权限登录AAP,只能合伙人或者工作室管理员才能登录!");

        }
        SysUser.verifyUser(sysUser);

        String token = StpUtil.createLoginSession(sysUser.getId());
        StpUtil.getSessionByLoginId(sysUser.getId()).set(SaSession.USER, sysUser);
        aapLoginVo.setUserId(sysUser.getId());
        aapLoginVo.setToken(token);
        log.info("微信登录返参：{}",aapLoginVo);
        return HttpResult.ok("", aapLoginVo);
    }

    @Override
    public HttpResult<Object> bindWechat(WechatBindVo wechatBindVo, String userId) throws WxErrorException {
        WxOAuth2AccessToken accessToken = wxMpService.get(WechatOpenSystem.HHR.getCode()).getOAuth2Service().getAccessToken(wechatBindVo.getCode());
        String openId = accessToken.getOpenId();
        log.info("微信绑定时的openID;{}",openId);
        SysUser sysUser = sysUserService.lambdaQuery().eq(SysUser::getOpenid, openId).one();
        if (sysUser != null) {
            throw new SystemException("同一微信不能重复绑定");
        }

        SysUser user = sysUserService.lambdaQuery().eq(SysUser::getId, userId).one();
        if (ObjectUtils.isEmpty(user)) {
            throw new SystemException("你输入的工号不存在");
        }

        user.setOpenid(openId);
        boolean update = sysUserService.updateById(user);

        if (update) {
            log.info("微信绑定成功");
            return HttpResult.ok("绑定成功");
        }
        throw new SystemException("绑定失败");
    }

    @Override
    public String checkBindWechat() {
        SysUser sysUser = sysUserMapper.selectById(BaseController.getUserId());
        return sysUser.getOpenid();
    }

    @Override
    public List<LevelPartnerInfoVo> getLevelPartnerInfo(List<String> partnerIds) {
        List<LevelPartnerInfoVo> partnerInfoVoList = new ArrayList<>();
        if (CollectionUtil.isEmpty(partnerIds)) return partnerInfoVoList;

        List<SysPartner> sysPartnerList = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getDelFlag,1).in(SysPartner::getUserId,partnerIds));
        if (sysPartnerList.size() >0 ) {
            for (SysPartner sysPartner : sysPartnerList) {
                LevelPartnerInfoVo levelPartnerInfoVo = new LevelPartnerInfoVo();
                levelPartnerInfoVo.setUserId(sysPartner.getUserId());
                levelPartnerInfoVo.setLevel(sysPartner.getType());
                List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, sysPartner.getUserId())
                        .eq(SysRelationPerson::getDelFlag, 1)
                        .eq(SysRelationPerson::getSource, 0)
                        .eq(SysRelationPerson::getType, 0));
                levelPartnerInfoVo.setDeptManNum(sysRelationPersonList.size());
                SysUser sysUser = sysUserMapper.selectById(sysPartner.getUserId());
                if (sysUser == null) continue;
                levelPartnerInfoVo.setUserName(sysUser.getName());
                partnerInfoVoList.add(levelPartnerInfoVo);
            }
        }
        return partnerInfoVoList;
    }


}