From b88a288f4f787b509463678e3cd9ccfa3f37014b Mon Sep 17 00:00:00 2001
From: chengf <cgf12138@163.com>
Date: 星期三, 11 三月 2026 12:01:05 +0800
Subject: [PATCH] 导入测试
---
service-job/src/main/java/com/java110/job/importData/adapt/ImportMeterWaterFeeV2QueueDataAdapt.java | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/importData/adapt/ImportMeterWaterFeeV2QueueDataAdapt.java b/service-job/src/main/java/com/java110/job/importData/adapt/ImportMeterWaterFeeV2QueueDataAdapt.java
index ea39bb6..255b85a 100644
--- a/service-job/src/main/java/com/java110/job/importData/adapt/ImportMeterWaterFeeV2QueueDataAdapt.java
+++ b/service-job/src/main/java/com/java110/job/importData/adapt/ImportMeterWaterFeeV2QueueDataAdapt.java
@@ -73,9 +73,17 @@
private void doImportData(AssetImportLogDetailDto assetImportLogDetailDto) {
JSONObject data = JSONObject.parseObject(assetImportLogDetailDto.getContent());
MeterWaterPo po = BeanConvertUtil.covertBean(data, MeterWaterPo.class);
+ if (po.getCommunityId() == null) {
+ throw new IllegalArgumentException("鏈煡璇㈠埌灏忓尯锛�" + po.getCommunityCode() + po.getCommunityName());
+ }
validateRoom(po, assetImportLogDetailDto);
addFee(po, data, assetImportLogDetailDto.getLogId(), assetImportLogDetailDto);
int i = 1;
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
}
private void addFee(MeterWaterPo po, JSONObject reqJson, String batchId, AssetImportLogDetailDto assetImportLogDetailDto) {
@@ -247,7 +255,10 @@
// }
// po.setObjId(importOwnerRoomDto.getRoomId());
} else if (roomDtos.size() > 1) {
- throw new IllegalArgumentException("瀛樺湪閲嶅鐨勬埧灞嬶細" + po.getObjName());
+ po.setObjId("1");
+ po.setRemark3("\n\n鎴垮眿锛�" +
+ roomDto.getCommunityId() + "-" + roomDto.getRoadName() + "-" + roomDto.getFloorNum() + "-" + roomDto.getUnitNum() + "-" +
+ roomDto.getRoomNum() + "瀛樺湪閲嶅鐨勬埧灞嬶紝璇ヨ垂鐢ㄥ瓨鍏ュ叕鍙歌处鎴�");
} else {
po.setObjId(roomDtos.get(0).getRoomId());
}
--
Gitblit v1.8.0