|
|
@@ -954,6 +954,7 @@ public class ReceivableServiceImpl extends ServiceImpl<ReceivableMapper, InsPlyI
|
|
|
|
|
|
// 按companyName分组,组内year+month升序,最后打平
|
|
|
resultList = resultList.stream()
|
|
|
+ .filter(x -> StrUtil.isNotBlank(x.getYear()) && StrUtil.isNotBlank(x.getMonth()))
|
|
|
// 按公司名称分组
|
|
|
.collect(Collectors.groupingBy(FollowCompanyFeeVO::getCompanyName))
|
|
|
// 获取分组后的value集合
|
|
|
@@ -1380,27 +1381,27 @@ public class ReceivableServiceImpl extends ServiceImpl<ReceivableMapper, InsPlyI
|
|
|
}
|
|
|
|
|
|
// 第一步:批量查询 ptl_agreement 表,补全 partner_company_id
|
|
|
- Set<String> agreementIds = records.stream()
|
|
|
- .filter(r -> StrUtil.isNotBlank(r.getAgreementId()))
|
|
|
- .map(InsPlyIncome::getAgreementId)
|
|
|
- .collect(Collectors.toSet());
|
|
|
-
|
|
|
- Map<String, String> agreementPartnerCompanyMap = new HashMap<>();
|
|
|
- if (CollUtil.isNotEmpty(agreementIds)) {
|
|
|
- LambdaQueryWrapper<PtlAgreement> agreementWrapper = new LambdaQueryWrapper<>();
|
|
|
- agreementWrapper.in(PtlAgreement::getId, agreementIds);
|
|
|
- List<PtlAgreement> agreements = ptlAgreementMapper.selectList(agreementWrapper);
|
|
|
- for (PtlAgreement agreement : agreements) {
|
|
|
- agreementPartnerCompanyMap.put(agreement.getId(), agreement.getPartnerCompanyId());
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // 将 partner_company_id 设置到对应的 ins_ply_income 对象中
|
|
|
- for (InsPlyIncome record : records) {
|
|
|
- if (StrUtil.isNotBlank(record.getAgreementId())) {
|
|
|
- record.setPartnerCompanyId(agreementPartnerCompanyMap.get(record.getAgreementId()));
|
|
|
- }
|
|
|
- }
|
|
|
+// Set<String> agreementIds = records.stream()
|
|
|
+// .filter(r -> StrUtil.isNotBlank(r.getAgreementId()))
|
|
|
+// .map(InsPlyIncome::getAgreementId)
|
|
|
+// .collect(Collectors.toSet());
|
|
|
+//
|
|
|
+// Map<String, String> agreementPartnerCompanyMap = new HashMap<>();
|
|
|
+// if (CollUtil.isNotEmpty(agreementIds)) {
|
|
|
+// LambdaQueryWrapper<PtlAgreement> agreementWrapper = new LambdaQueryWrapper<>();
|
|
|
+// agreementWrapper.in(PtlAgreement::getId, agreementIds);
|
|
|
+// List<PtlAgreement> agreements = ptlAgreementMapper.selectList(agreementWrapper);
|
|
|
+// for (PtlAgreement agreement : agreements) {
|
|
|
+// agreementPartnerCompanyMap.put(agreement.getId(), agreement.getPartnerCompanyId());
|
|
|
+// }
|
|
|
+// }
|
|
|
+//
|
|
|
+// // 将 partner_company_id 设置到对应的 ins_ply_income 对象中
|
|
|
+// for (InsPlyIncome record : records) {
|
|
|
+// if (StrUtil.isNotBlank(record.getAgreementId())) {
|
|
|
+// record.setPartnerCompanyId(agreementPartnerCompanyMap.get(record.getAgreementId()));
|
|
|
+// }
|
|
|
+// }
|
|
|
|
|
|
// 第二步:构建查询条件的唯一标识:year_month_companyId_partnerCompanyId
|
|
|
Map<String, InsPlyIncome> keyMap = new HashMap<>();
|