From d0b19298e28a9b8b50c778704b77160f17e73950 Mon Sep 17 00:00:00 2001
From: jialh <1972868360@qq.com>
Date: 星期五, 17 四月 2026 18:20:38 +0800
Subject: [PATCH] 水电话费
---
service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomOwnerV2QueueDataAdapt.java | 56 +++++++++++++++++++++++++++++---------------------------
1 files changed, 29 insertions(+), 27 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomOwnerV2QueueDataAdapt.java b/service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomOwnerV2QueueDataAdapt.java
index d19e21b..cceda2d 100644
--- a/service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomOwnerV2QueueDataAdapt.java
+++ b/service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomOwnerV2QueueDataAdapt.java
@@ -562,33 +562,35 @@
ownerV1InnerServiceSMOImpl.saveOwner(ownerPoTo3);
}
}
- for (int i = 0 ; i < feeDtos.size(); i++) {
- FeeConfigDto feeDto = feeDtos.get(i);
- PayFeePo payFeePo = new PayFeePo();
- payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId));
- payFeePo.setbId("-1");
- payFeePo.setFeeTypeCd(feeDto.getFeeTypeCd());
- payFeePo.setSecondaryFeeTypeCd(feeDto.getSecondaryFeeTypeCd());
- payFeePo.setCommunityId(importOwnerRoomDto.getCommunityId());
- payFeePo.setPayerObjId(importOwnerRoomDto.getRoomId());
- payFeePo.setIncomeObjId("102025062610470035");
- payFeePo.setStartTime(feeDto.getStartTime());
- payFeePo.setEndTime(feeDto.getStartTime());
- payFeePo.setUserId(importOwnerRoomDto.getUserId());
- payFeePo.setStatusCd("0");
- payFeePo.setFeeFlag(feeDto.getFeeFlag());
- payFeePo.setConfigId(feeDto.getConfigId());
- payFeePo.setState("2008001");
- payFeePo.setPayerObjType("3333");
- payFeePo.setBatchId(assetImportLogDetailDto.getLogId());
- payFeeV1InnerServiceSMO.savePayFee(payFeePo);
- List<FeeAttrPo> feeAttrPos = new ArrayList<>();
- feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390007" , importOwnerRoomDto.getOwnerId()));
- feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390010" , feeDto.getEndTime().split(" ")[0] + " 23:59:59"));
- feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390009" , importOwnerRoomDto.getTel()));
- feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390008" , importOwnerRoomDto.getOwnerName()));
- feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390012" , importOwnerRoomDto.getDoorRoomNum()));
- int i1 = feeAttrInnerServiceSMO.saveFeeAttrs(feeAttrPos);
+ if (feeDtos != null) {
+ for (int i = 0 ; i < feeDtos.size(); i++) {
+ FeeConfigDto feeDto = feeDtos.get(i);
+ PayFeePo payFeePo = new PayFeePo();
+ payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId));
+ payFeePo.setbId("-1");
+ payFeePo.setFeeTypeCd(feeDto.getFeeTypeCd());
+ payFeePo.setSecondaryFeeTypeCd(feeDto.getSecondaryFeeTypeCd());
+ payFeePo.setCommunityId(importOwnerRoomDto.getCommunityId());
+ payFeePo.setPayerObjId(importOwnerRoomDto.getRoomId());
+ payFeePo.setIncomeObjId("102025062610470035");
+ payFeePo.setStartTime(feeDto.getStartTime());
+ payFeePo.setEndTime(feeDto.getStartTime());
+ payFeePo.setUserId(importOwnerRoomDto.getUserId());
+ payFeePo.setStatusCd("0");
+ payFeePo.setFeeFlag(feeDto.getFeeFlag());
+ payFeePo.setConfigId(feeDto.getConfigId());
+ payFeePo.setState("2008001");
+ payFeePo.setPayerObjType("3333");
+ payFeePo.setBatchId(assetImportLogDetailDto.getLogId());
+ payFeeV1InnerServiceSMO.savePayFee(payFeePo);
+ List<FeeAttrPo> feeAttrPos = new ArrayList<>();
+ feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390007" , importOwnerRoomDto.getOwnerId()));
+ feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390010" , feeDto.getEndTime().split(" ")[0] + " 23:59:59"));
+ feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390009" , importOwnerRoomDto.getTel()));
+ feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390008" , importOwnerRoomDto.getOwnerName()));
+ feeAttrPos.add(new FeeAttrPo(payFeePo.getFeeId(), payFeePo.getCommunityId(), GenerateCodeFactory.getGeneratorId("11"), "390012" , importOwnerRoomDto.getDoorRoomNum()));
+ int i1 = feeAttrInnerServiceSMO.saveFeeAttrs(feeAttrPos);
+ }
}
}
}
--
Gitblit v1.8.0