|
|
@@ -88,9 +88,6 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
|
|
|
@Resource
|
|
|
private SysPremiumDetailsService sysPremiumDetailsService;
|
|
|
-
|
|
|
- @Resource
|
|
|
- private SysUserAccountHistoryMapper sysUserAccountHistoryMapper;
|
|
|
@Resource
|
|
|
private SysPartnerConfigMapper sysPartnerConfigMapper;
|
|
|
|
|
|
@@ -659,7 +656,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
@Override
|
|
|
public APPPartnerInfoFreeVo getTeamInfo(PartnerGradeInfo partnerGradeInfo) {
|
|
|
APPPartnerInfoFreeVo appPartnerInfoFreeVo = new APPPartnerInfoFreeVo();
|
|
|
-
|
|
|
+ String loginId = BaseController.getUserId();
|
|
|
List<APPPartnerInfo> appPartnerInfoList = new ArrayList<>();
|
|
|
|
|
|
List<String> deptIds = partnerGradeInfo.getDeptIds();
|
|
|
@@ -704,26 +701,29 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
}
|
|
|
appPartnerInfo.setTeamManNum(deptManNum);
|
|
|
appPartnerInfo.setUserIds(userIdList);
|
|
|
+ BigDecimal sumPremium = BigDecimal.ZERO;
|
|
|
+ BigDecimal extractFee = BigDecimal.ZERO;
|
|
|
if (CollectionUtil.isEmpty(userIdList)) continue;
|
|
|
- //查团队的保费
|
|
|
- List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .in(SysPremiumDetails::getUserId, userIdList)
|
|
|
- .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()));
|
|
|
- BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- appPartnerInfo.setSumPremium(sumPremium);
|
|
|
+ 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) {
|
|
|
+ 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);
|
|
|
+ }
|
|
|
|
|
|
- List<SysUserAccountHistory> sysUserAccountHistories = sysUserAccountHistoryMapper.selectList(new LambdaQueryWrapper<SysUserAccountHistory>()
|
|
|
- .in(SysUserAccountHistory::getUserId, userIdList).eq(SysUserAccountHistory::getProperty, 3));
|
|
|
- if (CollectionUtil.isNotEmpty(sysUserAccountHistories)) {
|
|
|
- BigDecimal extractFee = sysUserAccountHistories.stream().map(SysUserAccountHistory::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- appPartnerInfo.setExtractFee(extractFee);
|
|
|
- } else {
|
|
|
- appPartnerInfo.setExtractFee(BigDecimal.ZERO);
|
|
|
}
|
|
|
|
|
|
+ appPartnerInfo.setSumPremium(sumPremium);
|
|
|
+ appPartnerInfo.setExtractFee(extractFee);
|
|
|
appPartnerInfoList.add(appPartnerInfo);
|
|
|
}
|
|
|
List<String> ids = new ArrayList<>();
|
|
|
@@ -734,25 +734,29 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
}
|
|
|
}
|
|
|
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>()
|
|
|
- .in(SysPremiumDetails::getUserId, ids)
|
|
|
- .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()));
|
|
|
- BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- appPartnerInfoFreeVo.setSumPremium(sumPremium);
|
|
|
+ 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) {
|
|
|
+ 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);
|
|
|
+ }
|
|
|
|
|
|
- List<SysUserAccountHistory> sysUserAccountHistories = sysUserAccountHistoryMapper.selectList(new LambdaQueryWrapper<SysUserAccountHistory>()
|
|
|
- .in(SysUserAccountHistory::getUserId, ids).eq(SysUserAccountHistory::getProperty, 3));
|
|
|
- if (CollectionUtil.isNotEmpty(sysUserAccountHistories)) {
|
|
|
- BigDecimal extractFee = sysUserAccountHistories.stream().map(SysUserAccountHistory::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- appPartnerInfoFreeVo.setExtractFee(extractFee);
|
|
|
- } else {
|
|
|
- appPartnerInfoFreeVo.setExtractFee(BigDecimal.ZERO);
|
|
|
}
|
|
|
|
|
|
+ appPartnerInfoFreeVo.setSumPremium(sumPremium1);
|
|
|
+ appPartnerInfoFreeVo.setExtractFee(extractFee1);
|
|
|
+
|
|
|
int sum = appPartnerInfoList.stream().mapToInt(APPPartnerInfo::getTeamManNum).sum();
|
|
|
appPartnerInfoFreeVo.setTeamManNum(sum);
|
|
|
|
|
|
@@ -773,10 +777,11 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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());
|
|
|
@@ -888,87 +893,100 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<AppSysPartnerVo> partnerInfo(PartnerInfoDto partnerInfoDto) {
|
|
|
+ public List<AppSysPartnerVo> partnerInfo(PartnerInfoDto partnerInfoDto) {
|
|
|
List<AppSysPartnerVo> appSysPartnerVos = new ArrayList<>();
|
|
|
- String userId = BaseController.getUserId();
|
|
|
+ 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<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .in(CollectionUtil.isNotEmpty(ids), SysPremiumDetails::getUserId, ids)
|
|
|
- .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);
|
|
|
- //二级以下团队的总人数
|
|
|
- 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();
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- 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);
|
|
|
- }
|
|
|
-
|
|
|
- //每一级存入map
|
|
|
-
|
|
|
- appSysPartnerVos.add(appSysPartnerVo);
|
|
|
- }
|
|
|
-
|
|
|
- return appSysPartnerVos;
|
|
|
-
|
|
|
- }
|
|
|
+// 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) {
|
|
|
@@ -991,17 +1009,8 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
appSysPartnerVo.setPartnerNumber(sysPartnerList1.size());
|
|
|
List<String> ids = sysPartnerList1.stream().map(SysPartner::getUserId).collect(Collectors.toList());
|
|
|
appSysPartnerVo.setPartnerIds(ids);
|
|
|
- List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .in(CollectionUtil.isNotEmpty(ids), SysPremiumDetails::getUserId, ids)
|
|
|
- .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);
|
|
|
- //同等级合伙人团队的总人数:
|
|
|
+
|
|
|
+ //所有创造利益总人数
|
|
|
List<SysRelationPerson> sysRelationPersonList = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
|
|
|
.in(CollectionUtil.isNotEmpty(ids), SysRelationPerson::getSuggestId, ids)
|
|
|
.eq(SysRelationPerson::getDelFlag, 1)
|
|
|
@@ -1010,7 +1019,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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));
|
|
|
+ .in(SysAgencyLeader::getUserId, idList).eq(SysAgencyLeader::getDelFlag, 1));
|
|
|
if (leaderList.size() > 0) {
|
|
|
for (SysAgencyLeader sysAgencyLeader : leaderList) {
|
|
|
//获取机构下的团队
|
|
|
@@ -1023,14 +1032,14 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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)
|
|
|
@@ -1041,6 +1050,26 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
List<String> list1 = sysRelationPersons.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
|
|
|
appSysPartnerVo.setLeaderIds(list1);
|
|
|
}
|
|
|
+ //直接工作室下所有的人
|
|
|
+ List<String> userIds = getUserIds(sysRelationPersons);
|
|
|
+
|
|
|
+ if (CollectionUtil.isNotEmpty(userIds)) {
|
|
|
+ List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
+ .eq(SysPremiumDetails::getUserId, BaseController.getUserId())
|
|
|
+ .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);
|
|
|
+ }
|
|
|
//每一级存入map
|
|
|
appSysPartnerVos.add(appSysPartnerVo);
|
|
|
}
|
|
|
@@ -1048,10 +1077,63 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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();
|
|
|
//合伙人:1;工作室:2
|
|
|
Integer type = partnerGradeInfo.getType();
|
|
|
if (type == 1) {
|
|
|
@@ -1059,17 +1141,32 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
if (CollectionUtil.isEmpty(partnerIds)) {
|
|
|
return partnerInfoFreeVo;
|
|
|
}
|
|
|
- //费用
|
|
|
- List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .in(SysPremiumDetails::getUserId, partnerIds)
|
|
|
- .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));
|
|
|
- BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- BigDecimal extractFee = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- partnerInfoFreeVo.setSumPremium(sumPremium);
|
|
|
- partnerInfoFreeVo.setExtractFee(extractFee);
|
|
|
+ //合伙人的直接工作室贡献的费用
|
|
|
+ List<SysRelationPerson> sysRelationPersons = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
|
|
|
+ .in(SysRelationPerson::getSuggestId, partnerIds)
|
|
|
+ .eq(SysRelationPerson::getDelFlag, 1)
|
|
|
+ .eq(SysRelationPerson::getSource, 0)
|
|
|
+ .eq(SysRelationPerson::getType, 1));
|
|
|
+ //直接工作室下所有的人
|
|
|
+ List<String> userIds = getUserIds(sysRelationPersons);
|
|
|
+
|
|
|
+ if (CollectionUtil.isNotEmpty(userIds)) {
|
|
|
+ //费用
|
|
|
+ List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
+ .eq(SysPremiumDetails::getUserId, loginId)
|
|
|
+ .in(SysPremiumDetails::getIssuerId,userIds)
|
|
|
+ .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));
|
|
|
+ BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
+ BigDecimal extractFee = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
+ partnerInfoFreeVo.setSumPremium(sumPremium);
|
|
|
+ partnerInfoFreeVo.setExtractFee(extractFee);
|
|
|
+ }else {
|
|
|
+ partnerInfoFreeVo.setSumPremium(BigDecimal.ZERO);
|
|
|
+ partnerInfoFreeVo.setExtractFee(BigDecimal.ZERO);
|
|
|
+ }
|
|
|
|
|
|
//合伙人
|
|
|
List<SysPartner> sysPartnerList = sysPartnerMapper.selectList(new LambdaQueryWrapper<SysPartner>()
|
|
|
@@ -1077,24 +1174,13 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
if (sysPartnerList.size() > 0) {
|
|
|
for (SysPartner sysPartner : sysPartnerList) {
|
|
|
PartnerInfoVo partnerInfoVo = new PartnerInfoVo();
|
|
|
- partnerInfoVo.setLevel(partnerGradeInfo.getLevel());
|
|
|
+ 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<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .eq(SysPremiumDetails::getUserId, userId)
|
|
|
- .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()));
|
|
|
- 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, userId)
|
|
|
@@ -1116,6 +1202,26 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
partnerInfoVo.setLeaderIds(collects);
|
|
|
partnerInfoVo.setWorkNumber(collects.size());
|
|
|
|
|
|
+ List<String> userIds1 = getUserIds(sysRelationPersonList1);
|
|
|
+ if (CollectionUtil.isNotEmpty(userIds1)) {
|
|
|
+ //费用
|
|
|
+ List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
+ .eq(SysPremiumDetails::getUserId, loginId)
|
|
|
+ .in(SysPremiumDetails::getIssuerId,userIds1)
|
|
|
+ .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()));
|
|
|
+ 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);
|
|
|
+ }else {
|
|
|
+ partnerInfoVo.setSumPremium(BigDecimal.ZERO);
|
|
|
+ partnerInfoVo.setExtractFee(BigDecimal.ZERO);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
//合伙人下所有工作室数 核算总代理人数
|
|
|
List<SysRelationPerson> sysRelationPersonList2 = sysRelationPersonMapper.selectList(new LambdaQueryWrapper<SysRelationPerson>()
|
|
|
.eq(SysRelationPerson::getSuggestId, userId)
|
|
|
@@ -1228,23 +1334,74 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public BasePageResult<SysPremiumDetails> getCommissionInfo(CommissionInfoDto commissionInfoDto) {
|
|
|
+ public BasePageResult<SysPremiumDetailsVo> getCommissionInfo(CommissionInfoDto commissionInfoDto) {
|
|
|
+ List<SysPremiumDetailsVo> list = new ArrayList<>();
|
|
|
String userId = BaseController.getUserId();
|
|
|
|
|
|
Page<SysPremiumDetails> page = new Page<>(commissionInfoDto.getPageNum(), commissionInfoDto.getPageSize());
|
|
|
|
|
|
- LambdaQueryWrapper<SysPremiumDetails> wrapper = new LambdaQueryWrapper<>();
|
|
|
- wrapper.eq(SysPremiumDetails::getUserId, userId);
|
|
|
- wrapper.eq(commissionInfoDto.getIndustrySector() != null, SysPremiumDetails::getIndustrySector, commissionInfoDto.getIndustrySector());
|
|
|
- wrapper.between(StringUtils.isNotEmpty(commissionInfoDto.getBeginTime()) && StringUtils.isNotEmpty(commissionInfoDto.getEndTime()),
|
|
|
- SysPremiumDetails::getCreateTime, commissionInfoDto.getBeginTime(), commissionInfoDto.getEndTime());
|
|
|
- wrapper.orderByDesc(SysPremiumDetails::getId);
|
|
|
+ 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 new BasePageResult<>(commissionInfoDto.getPageNum(), page.getSize(), 0L, 0L,
|
|
|
+ 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);
|
|
|
|
|
|
- Page<SysPremiumDetails> insOrdersPage = sysPremiumDetailsService.page(page, wrapper);
|
|
|
+ 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);
|
|
|
|
|
|
- return new BasePageResult<>(commissionInfoDto.getPageNum(), page.getSize(), insOrdersPage.getTotal(), page.getPages(),
|
|
|
- insOrdersPage.getRecords());
|
|
|
+ list.add(sysPremiumDetailsVo);
|
|
|
+ }
|
|
|
+
|
|
|
+ List<SysPremiumDetailsVo> collect = list.stream().limit(page.getSize()).collect(Collectors.toList());
|
|
|
+ long l = list.size() / page.getSize();
|
|
|
+ return new BasePageResult<>(commissionInfoDto.getPageNum(), page.getSize(), list.size(), l,
|
|
|
+ collect);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -1318,30 +1475,33 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
@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;
|
|
|
}
|
|
|
- //费用
|
|
|
- List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .in(SysPremiumDetails::getUserId, userIds)
|
|
|
- .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()));
|
|
|
- BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- teamUserInfosFreeVo.setSumPremium(sumPremium);
|
|
|
- List<SysUserAccountHistory> sysUserAccountHistories = sysUserAccountHistoryMapper.selectList(new LambdaQueryWrapper<SysUserAccountHistory>()
|
|
|
- .in(SysUserAccountHistory::getUserId, userIds).eq(SysUserAccountHistory::getProperty, 3)
|
|
|
- .eq(teamUserInfosDto.getIndustrySector() != null, SysUserAccountHistory::getBusinessSegmentsType, teamUserInfosDto.getIndustrySector()));
|
|
|
- if (CollectionUtil.isNotEmpty(sysUserAccountHistories)) {
|
|
|
- BigDecimal extractFee = sysUserAccountHistories.stream().map(SysUserAccountHistory::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- teamUserInfosFreeVo.setExtractFee(extractFee);
|
|
|
- } else {
|
|
|
- teamUserInfosFreeVo.setExtractFee(BigDecimal.ZERO);
|
|
|
+ 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) {
|
|
|
+ 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()));
|
|
|
@@ -1358,23 +1518,20 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
|
|
|
//费用
|
|
|
List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .eq(SysPremiumDetails::getUserId, sysUser.getId())
|
|
|
+ .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()));
|
|
|
- BigDecimal sumPremium1 = sysPremiumDetail.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- teamUserInfosVo.setSumPremium(sumPremium1);
|
|
|
- List<SysUserAccountHistory> sysUserAccountHistorie = sysUserAccountHistoryMapper.selectList(new LambdaQueryWrapper<SysUserAccountHistory>()
|
|
|
- .in(SysUserAccountHistory::getUserId, sysUser.getId()).eq(SysUserAccountHistory::getProperty, 3)
|
|
|
- .eq(teamUserInfosDto.getIndustrySector() != null, SysUserAccountHistory::getBusinessSegmentsType, teamUserInfosDto.getIndustrySector()));
|
|
|
- if (CollectionUtil.isNotEmpty(sysUserAccountHistorie)) {
|
|
|
- BigDecimal extractFee1 = sysUserAccountHistorie.stream().map(SysUserAccountHistory::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
+ if (sysPremiumDetail.size()>0) {
|
|
|
+ teamUserInfosVo.setSumPremium(sysPremiumDetail.get(0).getSumpremium());
|
|
|
+ BigDecimal extractFee1 = sysPremiumDetail.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
teamUserInfosVo.setExtractFee(extractFee1);
|
|
|
- } else {
|
|
|
+ }else {
|
|
|
+ teamUserInfosVo.setSumPremium(BigDecimal.ZERO);
|
|
|
teamUserInfosVo.setExtractFee(BigDecimal.ZERO);
|
|
|
}
|
|
|
-
|
|
|
userInfosVoList.add(teamUserInfosVo);
|
|
|
}
|
|
|
teamUserInfosFreeVo.setTeamManNum(userIds.size());
|
|
|
@@ -1512,23 +1669,14 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
if (CollectionUtil.isEmpty(leaderIds)) {
|
|
|
return partnerLeaderInfoVo;
|
|
|
}
|
|
|
- //费用
|
|
|
- List<SysPremiumDetails> sysPremiumDetails = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .in(SysPremiumDetails::getUserId, leaderIds)
|
|
|
- .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()));
|
|
|
- BigDecimal sumPremium = sysPremiumDetails.stream().map(SysPremiumDetails::getSumpremium).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- BigDecimal extractFee = sysPremiumDetails.stream().map(SysPremiumDetails::getExtractFee).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- partnerLeaderInfoVo.setSumPremium(sumPremium);
|
|
|
- partnerLeaderInfoVo.setExtractFee(extractFee);
|
|
|
-
|
|
|
List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
|
|
|
.in(SysAgencyLeader::getUserId, leaderIds).eq(SysAgencyLeader::getDelFlag, 1));
|
|
|
- List<String> userIds = new ArrayList<>();
|
|
|
|
|
|
+
|
|
|
+ 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();
|
|
|
@@ -1540,18 +1688,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
partnerInfoVo.setDeptId(sysAgencyLeader.getDeptId());
|
|
|
SysDept sysDept1 = sysDeptMapper.selectById(sysAgencyLeader.getDeptId());
|
|
|
partnerInfoVo.setDeptName(sysDept1.getName());
|
|
|
- //费用
|
|
|
- List<SysPremiumDetails> sysPremiumDetail = sysPremiumDetailsMapper.selectList(new LambdaQueryWrapper<SysPremiumDetails>()
|
|
|
- .eq(SysPremiumDetails::getUserId, userId)
|
|
|
- .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()));
|
|
|
- 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);
|
|
|
-
|
|
|
+ //团队总人数
|
|
|
int deptManNum = 0;
|
|
|
//获取机构下的团队
|
|
|
List<SysDept> sysDeptList = sysDeptMapper.selectList(new LambdaQueryWrapper<SysDept>()
|
|
|
@@ -1563,27 +1700,66 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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 (sysUsers.size() > 0) {
|
|
|
-
|
|
|
- List<String> collect1 = sysUsers.stream().map(SysUser::getId).collect(Collectors.toList());
|
|
|
- userIds.addAll(collect1);
|
|
|
+ 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) {
|
|
|
+ SysPremiumDetails sysPremiumDetails = sysPremiumDetail.get(0);
|
|
|
+ sumPremium1= sumPremium1.add(sysPremiumDetails.getSumpremium());
|
|
|
+
|
|
|
+ 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) {
|
|
|
+ SysPremiumDetails sysPremiumDetails1 = sysPremiumDetails.get(0);
|
|
|
+ sumPremium= sumPremium.add(sysPremiumDetails1.getSumpremium());
|
|
|
+
|
|
|
+ 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(userIds);
|
|
|
+ partnerLeaderInfoVo.setUserIds(userIdByLeader);
|
|
|
partnerLeaderInfoVo.setTeamManNum(sum);
|
|
|
partnerLeaderInfoVo.setPartnerInfoVoList(partnerInfoVoList);
|
|
|
|
|
|
@@ -1605,13 +1781,6 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
if (sysRelationPersonList.size() > 0) {
|
|
|
List<String> collect = sysRelationPersonList.stream().map(SysRelationPerson::getSuggestId).collect(Collectors.toList());
|
|
|
|
|
|
-// if (collect.size() > 4) {
|
|
|
-// List<String> collect1 = collect.stream().limit(4).collect(Collectors.toList());
|
|
|
-// ids.addAll(collect1);
|
|
|
-// } else {
|
|
|
-// ids.addAll(collect);
|
|
|
-//
|
|
|
-// }
|
|
|
if (collect.size()>0) {
|
|
|
ids.addAll(collect);
|
|
|
}
|
|
|
@@ -1623,13 +1792,6 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
if (sysRelationList.size() > 0) {
|
|
|
|
|
|
List<String> collect1 = sysRelationList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
|
|
|
-// if (collect1.size() > 4) {
|
|
|
-// List<String> collect2 = collect1.stream().limit(4).collect(Collectors.toList());
|
|
|
-// ids.addAll(collect2);
|
|
|
-// } else {
|
|
|
-// ids.addAll(collect1);
|
|
|
-//
|
|
|
-// }
|
|
|
if (collect1.size() >0) {
|
|
|
ids.addAll(collect1);
|
|
|
}
|
|
|
@@ -1690,7 +1852,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
//团队下的人数
|
|
|
List<SysUser> sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
|
|
|
.likeRight(SysUser::getId, sysDept.getId())
|
|
|
- .in(SysUser::getStatus, Arrays.asList(1, 4, 5, 6, 7)));
|
|
|
+ .ne(SysUser::getStatus, 0));
|
|
|
userList.addAll(sysUserList);
|
|
|
deptManSum = deptManSum + sysUserList.size();
|
|
|
}
|
|
|
@@ -1830,6 +1992,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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)) {
|
|
|
@@ -1902,6 +2065,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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)) {
|
|
|
@@ -1925,7 +2089,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
//团队下的人数
|
|
|
List<SysUser> sysUserList = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>()
|
|
|
.likeRight(SysUser::getId, sysDept.getId())
|
|
|
- .in(SysUser::getStatus, Arrays.asList(1, 4, 5, 6, 7)));
|
|
|
+ .ne(SysUser::getStatus, 0));
|
|
|
deptManSum = deptManSum + sysUserList.size();
|
|
|
}
|
|
|
}
|
|
|
@@ -2083,6 +2247,7 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
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)) {
|
|
|
@@ -2090,37 +2255,6 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
levelPartnerVo.setPartnerIds(strings);
|
|
|
}
|
|
|
|
|
|
-// if (CollectionUtil.isNotEmpty(sysRelationPersonList)) {
|
|
|
-// List<String> collects = sysRelationPersonList.stream().map(SysRelationPerson::getAgencyLeaderId).collect(Collectors.toList());
|
|
|
-// //查工作室下的团队
|
|
|
-// List<SysAgencyLeader> leaderList = sysAgencyLeaderMapper.selectList(new LambdaQueryWrapper<SysAgencyLeader>()
|
|
|
-// .eq(SysAgencyLeader::getDelFlag, 1).in(SysAgencyLeader::getUserId, collects));
|
|
|
-// 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();
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-//
|
|
|
-// levelPartnerVo.setDeptManNum(deptManSum);
|
|
|
-//
|
|
|
-// } else {
|
|
|
-// levelPartnerVo.setDeptManNum(0);
|
|
|
-// }
|
|
|
-
|
|
|
partnerVoList.add(levelPartnerVo);
|
|
|
}
|
|
|
|
|
|
@@ -2305,16 +2439,30 @@ public class SysPartnerServiceImpl extends ServiceImpl<SysPartnerMapper, SysPart
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public PartnerInfoFreeVo getLevelPartnerInfo(List<String> partnerIds) {
|
|
|
- PartnerInfoFreeVo partnerInfoFreeVo = new PartnerInfoFreeVo();
|
|
|
- List<PartnerInfoVo> partnerInfoVoList = new ArrayList<>();
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+ public List<LevelPartnerInfoVo> getLevelPartnerInfo(List<String> partnerIds) {
|
|
|
+ List<LevelPartnerInfoVo> partnerInfoVoList = new ArrayList<>();
|
|
|
+ if (CollectionUtil.isEmpty(partnerIds)) return partnerInfoVoList;
|
|
|
|
|
|
-
|
|
|
- return partnerInfoFreeVo;
|
|
|
+ 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;
|
|
|
}
|
|
|
|
|
|
|