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 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 queryRecommendAndPartner(String id) { return sysPartnerMapper.selectList(new LambdaQueryWrapper().eq(SysPartner::getDelFlag, 1).likeRight(SysPartner::getUserId,id)); } @Override public BasePageResult queryByPage(SysPartnerPageDto sysPartnerPageDto) { Page page = new Page<>(sysPartnerPageDto.getPageNum(), sysPartnerPageDto.getPageSize()); LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(SysUser::getStatus, 1); wrapper.likeRight(StringUtils.isNotEmpty(sysPartnerPageDto.getDeptId()),SysUser::getId, sysPartnerPageDto.getDeptId()); wrapper.notLike(SysUser::getId, "M"); Page insOrdersPage = sysUserService.page(page, wrapper); List records = insOrdersPage.getRecords(); List sysUserPartners = BeanUtil.copyToList(records, SysUserPartner.class); if (sysUserPartners.size()>0) { for (SysUserPartner user : sysUserPartners) { SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper().eq(SysDept::getId, user.getDeptId()).eq(SysDept::getDelFlag, 0)); user.setParentId(sysDept.getParentId()); user.setDeptName(sysDept.getName()); SysPartner sysPartner = sysPartnerMapper.selectOne(new LambdaQueryWrapper() .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 sysPartners = sysPartnerMapper.selectList(new LambdaQueryWrapper().eq(SysPartner::getDelFlag, 1)); if (sysPartners.size() > 0) { List userIdList = sysPartners.stream().map(SysPartner::getUserId).collect(Collectors.toList()); if (userIdList.contains(sysPartnerDto.getUserId())) { throw new DescribeException(sysPartnerDto.getUserName() + "已是合伙人，不可重复设置"); } } //机构负责人不能配置为合伙人 List sysAgencyLeaders = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper().eq(SysAgencyLeader::getDelFlag, 1)); if (sysAgencyLeaders.size() > 0) { //校验用户是否已经机构负责人 List 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 sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper() .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 sysPartners = sysPartnerMapper.selectList(new LambdaQueryWrapper().eq(SysPartner::getDelFlag, 1)); if (sysPartners.size() > 0) { List 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 queryPartnerByPage(SysPartnerPageDto sysPartnerPageDto) { List agencyExtractFeeList = new ArrayList<>(); Page page = new Page<>(sysPartnerPageDto.getPageNum(), sysPartnerPageDto.getPageSize()); LambdaQueryWrapper 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 insOrdersPage = page(page, wrapper); List 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() .eq(SysUser::getId, sysPartner.getUserId()) .eq(SysUser::getStatus, 1)); agencyExtractFee.setDeptId(sysUser.getDeptId()); SysDept sysDept = sysDeptMapper.selectOne(new LambdaQueryWrapper() .eq(SysDept::getId, sysUser.getDeptId()).eq(SysDept::getDelFlag, 0)); agencyExtractFee.setDeptName(sysDept.getName()); //查询所有推荐的机构负责人核算总保费 List sysRelationPeople = sysRelationPersonMapper.selectList(new LambdaQueryWrapper() .eq(SysRelationPerson::getSuggestId, sysPartner.getUserId()).eq(SysRelationPerson::getType,1)); if (sysRelationPeople.size() > 0) { List agencyLeaderIds = sysRelationPeople.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList()); for (String agencyLeaderId : agencyLeaderIds) { SysAgencyLeader sysAgencyLeaders = sysAgencyLeaderMapper.selectOne(new LambdaQueryWrapper() .eq(SysAgencyLeader::getUserId, agencyLeaderId) .eq(SysAgencyLeader::getDelFlag, 1)); if (sysAgencyLeaders != null) { agencyExtractFee.setProportional(sysPartner.getProportional()); List insOrderList; //筛选订单，选择时间 Date updateTime = sysAgencyLeaders.getUpdateTime(); if (updateTime == null) { //机构下所有订单 insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper() .likeRight(StringUtils.isNotEmpty(sysAgencyLeaders.getDeptId()), InsOrders::getDeptid, sysAgencyLeaders.getDeptId()) .ge(InsOrders::getCreatetime, sysAgencyLeaders.getCreateTime())); agencyExtractFee.setStartTime(sysAgencyLeaders.getCreateTime()); } else { insOrderList = insOrdersMapper.selectList(new LambdaQueryWrapper() .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 insAreaCompanies = insAreaCompanyMapper.selectList(new LambdaQueryWrapper() .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 sysAgencyFeeApprovals = sysAgencyFeeApprovalMapper.selectList(new LambdaQueryWrapper() .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); } }