From b8bf2507bc7b23c90bc6dc71ea2460e277d3800a Mon Sep 17 00:00:00 2001
From: chengf <cgf12138@163.com>
Date: 星期五, 30 一月 2026 19:23:44 +0800
Subject: [PATCH] 导入测试
---
service-job/src/main/java/com/java110/job/importData/adapt/ImportElectricityFeeV2QueueDataAdapt.java | 98 ++++++++++++++++++++++++------------------------
1 files changed, 49 insertions(+), 49 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/importData/adapt/ImportElectricityFeeV2QueueDataAdapt.java b/service-job/src/main/java/com/java110/job/importData/adapt/ImportElectricityFeeV2QueueDataAdapt.java
index 8cbf512..57275d5 100644
--- a/service-job/src/main/java/com/java110/job/importData/adapt/ImportElectricityFeeV2QueueDataAdapt.java
+++ b/service-job/src/main/java/com/java110/job/importData/adapt/ImportElectricityFeeV2QueueDataAdapt.java
@@ -76,24 +76,25 @@
private void addFee(MeterWaterPo po, JSONObject reqJson, String batchId, AssetImportLogDetailDto assetImportLogDetailDto) {
PayFeePo payFeePo = BeanConvertUtil.covertBean(reqJson, PayFeePo.class);
- payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId));
- payFeePo.setIncomeObjId(reqJson.getString("storeId"));
payFeePo.setAmount(po.getUnitPrice());
if (payFeePo.getAmount().equals("")){
payFeePo.setAmount("-1");
}
-// payFeePo.setSecondaryFeeTypeCd("888800010190");
payFeePo.setFeeTypeCd(po.getFeeTypeCd());
payFeePo.setConfigId(po.getConfigId());
-// payFeePo.setPayerObjType("3333");
payFeePo.setPayerObjId(po.getObjId());
- payFeePo.setBatchId(batchId);
payFeePo.setStartTime(po.getCurReadingTime());
payFeePo.setEndTime(po.getPreReadingTime());
payFeePo.setPayerObjType(FeeDto.PAYER_OBJ_TYPE_ROOM);
- payFeePo.setbId("-1");
payFeePo.setFeeFlag(FeeDto.FEE_FLAG_ONCE);
- payFeePo.setState(FeeDto.STATE_DOING);
+ payFeePo.setState(FeeDto.STATE_FINISH);
+ int i = meterWaterInnerServiceSMOImpl.queryMeterWatersCount(BeanConvertUtil.covertBean(BeanConvertUtil.beanCovertMap(po), MeterWaterDto.class));
+ if (i > 0) {
+ throw new IllegalArgumentException("閲嶅鐨勭數璐瑰鍏�");
+ }
+ payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId));
+ payFeePo.setBatchId(batchId);
+ payFeePo.setbId("-1");
payFeePo.setIncomeObjId("102025062610470035");
payFeePo.setUserId("-1");
@@ -102,10 +103,6 @@
po.setWaterId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_waterId));
po.setFeeId(payFeePo.getFeeId());
meterWaterPos.add(po);
- int i = meterWaterInnerServiceSMOImpl.queryMeterWatersCount(BeanConvertUtil.covertBean(BeanConvertUtil.beanCovertMap(po), MeterWaterDto.class));
- if (i > 0) {
- throw new IllegalArgumentException("閲嶅鐨勭數璐瑰鍏�");
- }
meterWaterInnerServiceSMOImpl.saveMeterWaters(meterWaterPos);
int flag = payFeeV1InnerServiceSMOImpl.savePayFee(payFeePo);
@@ -179,47 +176,50 @@
private void validateRoom(MeterWaterPo po, AssetImportLogDetailDto assetImportLogDetailDto) {
RoomDto roomDto = new RoomDto();
roomDto.setRoadName(po.getRoadName());
- roomDto.setFloorNum(po.getFloorNum());
+ roomDto.setFloorNum(Vtil.defaultValueToNumber(po.getFloorNum()));
roomDto.setCommunityId(po.getCommunityId());
- roomDto.setUnitNum(po.getUnitNum());
- roomDto.setRoomNum(po.getRoomNum());
+ roomDto.setUnitNum(Vtil.defaultValueToNumber(po.getUnitNum()));
+ roomDto.setRoomNum(Vtil.defaultValueToNumber(po.getRoomNum()));
+ if (roomDto.getRoomNum().isEmpty()) {
+ roomDto.setRoomNumIsNull("yes");
+ }
List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
if (roomDtos.isEmpty()) {
-// throw new IllegalArgumentException("鏈煡璇㈠埌鎴垮眿锛�" + po.getObjName());
- ImportOwnerRoomDto importOwnerRoomDto = new ImportOwnerRoomDto();//鎴垮眿
- importOwnerRoomDto.setRoomId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId));
- importOwnerRoomDto.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId));
- importOwnerRoomDto.setUserId(po.getUserId());
- importOwnerRoomDto.setLayerCount("0");
- importOwnerRoomDto.setLayer("0");
- importOwnerRoomDto.setLift("鏈煡");
- importOwnerRoomDto.setSection("10102");
- importOwnerRoomDto.setOwnerTypeCd("1001");
- importOwnerRoomDto.setPersonType(OwnerDto.PERSON_TYPE_PERSON);
- importOwnerRoomDto.setPersonRole(OwnerDto.PERSON_ROLE_OWNER);
- importOwnerRoomDto.setRoomSubType(RoomDto.ROOM_SUB_TYPE_HOUSE);
- importOwnerRoomDto.setCommunityId(po.getCommunityId());//灏忓尯缂栧彿
- //---------
-
- importOwnerRoomDto.setRoadName(roomDto.getRoadName());//璺悕
- importOwnerRoomDto.setFloorNum(roomDto.getFloorNum());//寮�
- importOwnerRoomDto.setUnitNum(roomDto.getUnitNum());//闂�
- importOwnerRoomDto.setRoomNum(roomDto.getRoomNum());//瀹�
- importOwnerRoomDto.setDoorRoomNum(roomDto.getUnitNum() + "-" + roomDto.getRoomNum());//闂ㄥ競鍙�
- importOwnerRoomDto.setPropertyAddress(
- roomDto.getRoadName() + roomDto.getFloorNum() + roomDto.getUnitNum() + roomDto.getRoomNum()
- );//涓氫富鍦板潃
- importOwnerRoomDto.setBuiltUpArea("0");//闈㈢Н
- importOwnerRoomDto.setRoomArea("0");//闈㈢Н
- importOwnerRoomDto.setRoomRent("0");//闈㈢Н
- importOwnerRoomDto.setSellState(RoomDto.STATE_FREE);//鎴垮眿鐘舵��
- importOwnerRoomDto.setRoomState(Vtil.defaultValue(importOwnerRoomDto.getOwnerName()).equals("") ? "2004" : "2001");
- int i = importOwnerRoomInnerServiceSMOImpl.saveOwnerRoom(importOwnerRoomDto);
-
- if (i == 0) {
- throw new IllegalArgumentException("鎴垮眿娣诲姞閿欒");
- }
- po.setObjId(importOwnerRoomDto.getRoomId());
+ throw new IllegalArgumentException("鏈煡璇㈠埌鎴垮眿锛�" + po.getObjName());
+// ImportOwnerRoomDto importOwnerRoomDto = new ImportOwnerRoomDto();//鎴垮眿
+// importOwnerRoomDto.setRoomId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId));
+// importOwnerRoomDto.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId));
+// importOwnerRoomDto.setUserId(po.getUserId());
+// importOwnerRoomDto.setLayerCount("0");
+// importOwnerRoomDto.setLayer("0");
+// importOwnerRoomDto.setLift("鏈煡");
+// importOwnerRoomDto.setSection("10102");
+// importOwnerRoomDto.setOwnerTypeCd("1001");
+// importOwnerRoomDto.setPersonType(OwnerDto.PERSON_TYPE_PERSON);
+// importOwnerRoomDto.setPersonRole(OwnerDto.PERSON_ROLE_OWNER);
+// importOwnerRoomDto.setRoomSubType(RoomDto.ROOM_SUB_TYPE_HOUSE);
+// importOwnerRoomDto.setCommunityId(po.getCommunityId());//灏忓尯缂栧彿
+// //---------
+//
+// importOwnerRoomDto.setRoadName(roomDto.getRoadName());//璺悕
+// importOwnerRoomDto.setFloorNum(roomDto.getFloorNum());//寮�
+// importOwnerRoomDto.setUnitNum(roomDto.getUnitNum());//闂�
+// importOwnerRoomDto.setRoomNum(roomDto.getRoomNum());//瀹�
+// importOwnerRoomDto.setDoorRoomNum(roomDto.getUnitNum() + "-" + roomDto.getRoomNum());//闂ㄥ競鍙�
+// importOwnerRoomDto.setPropertyAddress(
+// roomDto.getRoadName() + roomDto.getFloorNum() + roomDto.getUnitNum() + roomDto.getRoomNum()
+// );//涓氫富鍦板潃
+// importOwnerRoomDto.setBuiltUpArea("0");//闈㈢Н
+// importOwnerRoomDto.setRoomArea("0");//闈㈢Н
+// importOwnerRoomDto.setRoomRent("0");//闈㈢Н
+// importOwnerRoomDto.setSellState(RoomDto.STATE_FREE);//鎴垮眿鐘舵��
+// importOwnerRoomDto.setRoomState(Vtil.defaultValue(importOwnerRoomDto.getOwnerName()).equals("") ? "2004" : "2001");
+// int i = importOwnerRoomInnerServiceSMOImpl.saveOwnerRoom(importOwnerRoomDto);
+//
+// if (i == 0) {
+// throw new IllegalArgumentException("鎴垮眿娣诲姞閿欒");
+// }
+// po.setObjId(importOwnerRoomDto.getRoomId());
} else if (roomDtos.size() > 1) {
throw new IllegalArgumentException("瀛樺湪閲嶅鐨勬埧灞嬶細" + po.getObjName());
} else {
--
Gitblit v1.8.0