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 com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ydtech.aop.exception.DescribeException;
import com.ydtech.modules.admin.dao.*;
import com.ydtech.modules.admin.model.*;
import com.ydtech.modules.admin.model.dto.SysPartnerDto;
import com.ydtech.modules.admin.model.dto.SysPartnerPageDto;
import com.ydtech.modules.admin.model.vo.AgencyExtractFeeVo;
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.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 配置机构合伙人表(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));
    }

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

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

        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 = sysPartnerMapper.insert(sysPartner)>0;
        if (sysPartnerDto.getSuggestId()!=null) {
            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);
                }
            }
        }

        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(Integer id) {
        SysPartner partner = new SysPartner();
        partner.setId(id);
        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.orderByAsc(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.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) {
                                for (InsOrders insOrders : insOrderList) {
                                    //查询订单下的所有子订单
                                    List<InsAreaCompany> insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper<InsAreaCompany>()
                                            .eq(InsAreaCompany::getOrderno, insOrders.getOrderno())
                                            .eq(InsAreaCompany::getOrderstatus, 3));
                                    if (insAreaCompanies.size() > 0) {
                                        for (InsAreaCompany insAreaCompany : insAreaCompanies) {
                                            //累加每一个子订单的交强险费用+商业险费用+驾意险费用
                                            bigDecimal = bigDecimal.add(insAreaCompany.getJqpremium()).add(insAreaCompany.getSypremium()).add(insAreaCompany.getJypremium());

                                        }
                                    }
                                }
                            }
                        }
                    }
                    agencyExtractFee.setSumpremium(bigDecimal);
                    BigDecimal multiply = bigDecimal.multiply(new BigDecimal(agencyExtractFee.getProportional()).divide(new BigDecimal("100"))).setScale(2, RoundingMode.HALF_UP);
                    agencyExtractFee.setExtractFee(multiply);
                    // 填充 已提现抽成费用和可提现抽成费用
                    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());
                        }
                    }

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

                }
                agencyExtractFeeList.add(agencyExtractFee);

            }
        }

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

    }







}