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

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


import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ydtech.aop.exception.DescribeException;
import com.ydtech.exception.SystemException;
import com.ydtech.modules.admin.dao.*;
import com.ydtech.modules.admin.model.*;
import com.ydtech.modules.admin.model.dto.SysPartnerAPPPageDto;
import com.ydtech.modules.admin.model.dto.SysPartnerDto;
import com.ydtech.modules.admin.model.dto.SysPartnerPageDto;
import com.ydtech.modules.admin.model.vo.AgencyExtractFeeVo;
import com.ydtech.modules.admin.model.vo.SysAgencyLeaderVo;
import com.ydtech.modules.admin.model.vo.SysPartnerAPPPageVo;
import com.ydtech.modules.admin.model.vo.SysUserPartner;
import com.ydtech.modules.admin.service.SysPartnerService;
import com.ydtech.modules.admin.service.SysUserService;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.order.dao.InsAreaCompanyMapper;
import com.ydtech.modules.order.dao.InsOrdersMapper;
import com.ydtech.modules.order.entity.BasePageResult;
import com.ydtech.modules.order.entity.InsAreaCompany;
import com.ydtech.modules.order.entity.InsOrders;
import com.ydtech.utils.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * 配置机构合伙人表(SysPartner)表服务实现类
 *
 * @author makejava
 * @since 2024-08-01 11:20:57
 */
@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 SysUserService sysUserService;

    @Resource
    private SysUserMapper sysUserMapper;

    @Resource
    private InsOrdersMapper insOrdersMapper;

    @Resource
    private InsAreaCompanyMapper insAreaCompanyMapper;

    @Resource
    private SysAgencyFeeApprovalMapper sysAgencyFeeApprovalMapper;


    @Override
    public List<SysPartner> queryRecommendAndPartner(String id) {
        return sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1)
                .likeRight(SysPartner::getUserId, id).orderByDesc(SysPartner::getId));
    }

    @Override
    public BasePageResult<SysUserPartner> queryByPage(SysPartnerPageDto sysPartnerPageDto) {
        Page<SysUser> page = new Page<>(sysPartnerPageDto.getPageNum(), sysPartnerPageDto.getPageSize());
        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>().eq(SysAgencyLeader::getDelFlag, 1));
        List<String> stringList = null;
        if (sysAgencyLeaders.size() > 0) {
            stringList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());

        }
        List<String> idList = null;
        List<SysDept> sysDeptLists = sysDeptMapper.selectList(new LambdaQueryWrapper<SysDept>().eq(SysDept::getComlevel, 4).eq(SysDept::getDelFlag, 0));
        if (sysDeptLists.size() > 0) {
            List<String> collect = sysDeptLists.stream().map(SysDept::getId).collect(Collectors.toList());

            List<SysDept> sysDeptList = sysDeptMapper.selectList(new LambdaQueryWrapper<SysDept>()
                    .in(SysDept::getParentId, collect)
                    .eq(SysDept::getDelFlag, 0).isNull(SysDept::getComlevel).eq(SysDept::getDeptType, "D"));
            if (sysDeptList.size() > 0) {
                idList = sysDeptList.stream().map(SysDept::getId).collect(Collectors.toList());
            }
        }
        LambdaQueryWrapper<SysUser> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(SysUser::getStatus, 1);
        wrapper.likeRight(StringUtils.isNotEmpty(sysPartnerPageDto.getDeptId()), SysUser::getId, sysPartnerPageDto.getDeptId());
        wrapper.notLike(SysUser::getId, "M");
        wrapper.notIn(CollectionUtil.isNotEmpty(stringList), SysUser::getId, stringList);
        wrapper.in(CollectionUtil.isNotEmpty(idList), SysUser::getDeptId, idList);
        wrapper.orderByDesc(SysUser::getCreateTime);

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

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

        if (sysUserPartners.size() > 0) {
            for (SysUserPartner user : sysUserPartners) {
                SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>().eq(SysDept::getId, user.getDeptId()).eq(SysDept::getDelFlag, 0));
                user.setParentId(sysDept.getParentId());
                user.setDeptName(sysDept.getName());
                SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                        .eq(SysPartner::getUserId, user.getId()).eq(SysPartner::getDelFlag, 1));
                if (sysPartner != null) {
                    user.setType("1");
                    user.setSuggestId(sysPartner.getSuggestId());
                    user.setSuggestName(sysPartner.getSuggestName());
                    user.setProportional(sysPartner.getProportional());
                }
            }

        }


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

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean insert(SysPartnerDto sysPartnerDto) {
        List<SysPartner> sysPartners = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>().eq(SysPartner::getDelFlag, 1));
        if (sysPartners.size() > 0) {
            List<String> userIdList = sysPartners.stream().map(SysPartner::getUserId).collect(Collectors.toList());
            if (userIdList.contains(sysPartnerDto.getUserId())) {
                throw new DescribeException(sysPartnerDto.getUserName() + "已是合伙人，不可重复设置");
            }

        }
        //机构负责人不能配置为合伙人
        List<SysAgencyLeader> sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>().eq(SysAgencyLeader::getDelFlag, 1));
        if (sysAgencyLeaders.size() > 0) {
            //校验用户是否已经机构负责人
            List<String> userIdList = sysAgencyLeaders.stream().map(SysAgencyLeader::getUserId).collect(Collectors.toList());
            if (userIdList.contains(sysPartnerDto.getUserId())) {
                throw new DescribeException(sysPartnerDto.getUserName() + "已是机构负责人，不可配置为合伙人");
            }

        }
        SysPartner sysPartner = BeanUtil.copyProperties(sysPartnerDto, SysPartner.class);
        sysPartner.setCreateTime(new Date());
        sysPartner.setCreateBy(BaseController.getUser().getId());
        boolean b = false;
        if (sysPartnerDto.getSuggestId() != null) {
            SysPartner sysPartnerSuggest = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                    .eq(SysPartner::getUserId, sysPartnerDto.getSuggestId())
                    .eq(SysPartner::getDelFlag, 1));
            if (sysPartnerSuggest == null) throw new SystemException("推荐人不存在");
            sysPartner.setType(sysPartnerSuggest.getType() + 1);
            b = sysPartnerMapper.insert(sysPartner) > 0;
            //保存关系
            SysRelationPerson sysRelationPerson = new SysRelationPerson();
            sysRelationPerson.setAgencyLeaderId(sysPartnerDto.getUserId());
            sysRelationPerson.setSuggestId(sysPartnerDto.getSuggestId());
            //'推荐等级(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();
                    sysRelationPerson1.setAgencyLeaderId(sysPartnerDto.getUserId());
                    sysRelationPerson1.setSuggestId(relationPerson.getSuggestId());
                    sysRelationPerson1.setSource(1);
                    //推荐类型（0：合伙人  1：机构负责人）
                    sysRelationPerson1.setType(0);
                    sysRelationPerson1.setCreateBy(BaseController.getUser().getId());
                    sysRelationPerson1.setCreateTime(new Date());
                    sysRelationPersonMapper.insert(sysRelationPerson1);
                }
            }
        } else {
            //无推荐人，等级为一级
            sysPartner.setType(1);
            b = sysPartnerMapper.insert(sysPartner) > 0;
        }

        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> 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) {
                AgencyExtractFeeVo agencyExtractFee = new AgencyExtractFeeVo();
                //总保费
                BigDecimal bigDecimal = new BigDecimal("0.00");
                //已提现抽成费用
                BigDecimal historyFee = new BigDecimal("0.00");
                //填充查询人的姓名和机构
                agencyExtractFee.setProportional(sysPartner.getProportional());
                agencyExtractFee.setUserId(sysPartner.getUserId());
                agencyExtractFee.setUserName(sysPartner.getUserName());
                SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                        .eq(SysUser::getId, sysPartner.getUserId())
                        .eq(SysUser::getStatus, 1));
                agencyExtractFee.setDeptId(sysUser.getDeptId());
                SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>()
                        .eq(SysDept::getId, sysUser.getDeptId()).eq(SysDept::getDelFlag, 0));
                agencyExtractFee.setDeptName(sysDept.getName());
                //查询所有推荐的机构负责人核算总保费
                List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, 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());
                            List<InsOrders> insOrderList;
                            //筛选订单，选择时间
                            Date updateTime = sysAgencyLeaders.getUpdateTime();
                            if (updateTime == null) {
                                //机构下所有订单
                                insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                                        .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                                        .ge(InsOrders::getCreatetime, sysAgencyLeaders.getCreateTime()));
                                agencyExtractFee.setStartTime(sysAgencyLeaders.getCreateTime());
                            } else {
                                insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
                                        .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId())
                                        .ge(InsOrders::getCreatetime, updateTime));
                                agencyExtractFee.setStartTime(updateTime);
                            }
                            if (insOrderList.size() > 0) {
                                List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
                                //查询订单下的所有子订单
                                List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                                        .in(InsAreaCompany::getOrderno, collect)
                                        .eq(InsAreaCompany::getOrderstatus, 3));
                                if (insAreaCompanies.size() > 0) {
                                    //累加每一个子订单的交强险费用+商业险费用+驾意险费用
                                    BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                    BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
                                    BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);

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

                            }
                        }
                    }
                    agencyExtractFee.setSumpremium(bigDecimal);
                    if (!bigDecimal.equals(new BigDecimal("0.00"))) {

                        BigDecimal multiply = bigDecimal.multiply(new BigDecimal(agencyExtractFee.getProportional())
                                .divide(new BigDecimal("100"))).setScale(2, RoundingMode.DOWN);
                        agencyExtractFee.setExtractFee(multiply);
                    } else {
                        agencyExtractFee.setExtractFee(new BigDecimal("0.00"));
                    }
                    // 填充 已提现抽成费用和可提现抽成费用
                    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());
                        }
                    }
                    BigDecimal extractFee = agencyExtractFee.getExtractFee();
                    if (!extractFee.equals(new BigDecimal("0.00"))) {
                        //已提现
                        agencyExtractFee.setHistoryFee(historyFee);
                        //可提现 = 总抽成-已提现
                        agencyExtractFee.setCashFee(extractFee.subtract(historyFee));
                    } else {
                        agencyExtractFee.setHistoryFee(new BigDecimal("0.00"));
                        agencyExtractFee.setCashFee(extractFee.subtract(new BigDecimal("0.00")));
                    }

                } 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> 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());
                agencyExtractFee.setUserName(sysPartner.getUserName());
                SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                        .eq(SysUser::getId, sysPartner.getUserId())
                        .eq(SysUser::getStatus, 1));
                agencyExtractFee.setDeptId(sysUser.getDeptId());
                SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper<SysDept>()
                        .eq(SysDept::getId, sysUser.getDeptId()).eq(SysDept::getDelFlag, 0));
                agencyExtractFee.setDeptName(sysDept.getName());
                //查询所有推荐的机构负责人核算总保费
                List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                        .eq(SysRelationPerson::getSuggestId, 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);
                                agencyExtractFee.setStartTime(updateTime);
                            } else {
                                dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                                agencyExtractFee.setStartTime(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<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());
                    sysPartnerAPPPageVo.setUserName(sysPartner.getUserName());
                    //填充机构信息
                    SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>()
                            .eq(SysUser::getId, sysPartner.getUserId())
                            .eq(SysUser::getStatus, 1));
                    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) {

//                                    List<InsOrders> insOrderList;
//                                    //筛选订单，选择时间
//                                    Date updateTime = sysAgencyLeader.getUpdateTime();
//                                    if (updateTime == null) {
//                                        //机构下所有订单
//                                        insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
//                                                .likeRight(InsOrders::getDeptid, sysDept1.getId())
//                                                .ge(InsOrders::getCreatetime, sysAgencyLeader.getCreateTime()));
//                                        sysPartnerAPPPageVo.setStartTime(sysAgencyLeader.getCreateTime());
//
//                                    } else {
//                                        insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper<InsOrders>()
//                                                .likeRight(InsOrders::getDeptid, sysDept1.getId())
//                                                .ge(InsOrders::getCreatetime, updateTime));
//                                        sysPartnerAPPPageVo.setStartTime(updateTime);
//                                    }
//
//                                    if (insOrderList.size() > 0) {
//                                        List<String> collect = insOrderList.stream().map(InsOrders::getOrderno).collect(Collectors.toList());
//                                        //查询订单下的所有子订单
//                                        List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
//                                                .in(InsAreaCompany::getOrderno, collect)
//                                                .eq(InsAreaCompany::getOrderstatus, 3));
//                                        if (insAreaCompanies.size() > 0) {
//                                            BigDecimal jqpremium = insAreaCompanies.stream().map(InsAreaCompany::getJqpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
//                                            BigDecimal sypremium = insAreaCompanies.stream().map(InsAreaCompany::getSypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
//                                            BigDecimal jypremium = insAreaCompanies.stream().map(InsAreaCompany::getJypremium).reduce(BigDecimal.ZERO, BigDecimal::add);
//
//                                            bigDecimal = jqpremium.add(sypremium).add(jypremium);
//                                        }
//                                    }
                                    //筛选订单，选择时间
                                    Date updateTime = sysAgencyLeader.getUpdateTime();
                                    Date createTime = sysAgencyLeader.getCreateTime();
                                    String dateStr = "";
                                    if (updateTime != null) {
                                        dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(updateTime);
                                        sysPartnerAPPPageVo.setStartTime(updateTime);
                                    } else {
                                        dateStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(createTime);
                                        sysPartnerAPPPageVo.setStartTime(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
    @Transactional(rollbackFor = Exception.class)
    public boolean edit(SysPartnerDto sysPartnerDto) {
        boolean b;
        SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper<SysPartner>()
                .eq(SysPartner::getDelFlag, 1).eq(SysPartner::getUserId, sysPartnerDto.getUserId()));
        if (sysPartner == null) throw new DescribeException("系统错误，请联系管理员！");

        if (StringUtils.isNullOrEmpty(sysPartner.getSuggestId()) && StringUtils.isNotEmpty(sysPartnerDto.getSuggestId())) {
            SysPartner partner = new SysPartner();
            partner.setId(sysPartner.getId());
            partner.setProportional(sysPartnerDto.getProportional());
            partner.setSuggestId(sysPartnerDto.getSuggestId());
            partner.setSuggestName(sysPartnerDto.getSuggestName());
            b = sysPartnerMapper.updateById(partner) > 0;

            SysRelationPerson sysRelationPerson = new SysRelationPerson();
            sysRelationPerson.setAgencyLeaderId(sysPartnerDto.getUserId());
            sysRelationPerson.setSuggestId(sysPartnerDto.getSuggestId());
            //'推荐等级(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();
                    sysRelationPerson1.setAgencyLeaderId(sysPartnerDto.getUserId());
                    sysRelationPerson1.setSuggestId(relationPerson.getSuggestId());
                    sysRelationPerson1.setSource(1);
                    //推荐类型（0：合伙人  1：机构负责人）
                    sysRelationPerson1.setType(0);
                    sysRelationPerson1.setCreateBy(BaseController.getUser().getId());
                    sysRelationPerson1.setCreateTime(new Date());
                    sysRelationPersonMapper.insert(sysRelationPerson1);
                }
            }
        } else {
            SysPartner partner = new SysPartner();
            partner.setId(sysPartner.getId());
            partner.setProportional(sysPartnerDto.getProportional());
            b = sysPartnerMapper.updateById(partner) > 0;
        }


        return b;
    }

    @Override
    public List<SysAgencyLeader> queryAgencyLeaderById(String userId) {
        List<SysRelationPerson> sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
                .eq(SysRelationPerson::getSuggestId, userId).eq(SysRelationPerson::getType, 1));

            //获取所有推荐的机构负责人id
            List<String> agencyLeaderIds = sysRelationPeople.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());

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

            return sysAgencyLeaders;

    }


}