From 4c3fa7b1828d5e9bbd586a42fa00924e9f5a7c25 Mon Sep 17 00:00:00 2001
From: chengf <cgf12138@163.com>
Date: 星期四, 12 三月 2026 11:41:30 +0800
Subject: [PATCH] 导入测试
---
service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomOwnerV2QueueDataAdapt.java | 34 ++++++++++++++++++----------------
1 files changed, 18 insertions(+), 16 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 78410f7..e0ab829 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
@@ -153,25 +153,27 @@
importOwnerRoomDto.setPersonRole(OwnerDto.PERSON_ROLE_OWNER);
importOwnerRoomDto.setMonthlyUnitPrice(objects.getString(23));
importOwnerRoomDto.setPropertyFeeMonth(objects.getString(24));
- //--------璁剧疆鐗╀笟绫诲瀷
- DictDto dictDto = new DictDto();
- dictDto.setTableName("building_room");
- dictDto.setTableColumns("room_sub_type");
- dictDto.setName(Vtil.defaultValue(objects.get(1)));
- List<DictDto> dictDtos = dictV1InnerServiceSMOImpl.queryDictAndSpecs(dictDto);
- if (dictDtos.isEmpty()) {
- DictPo dictPo = new DictPo();
- dictPo.setStatusCd(GenerateCodeFactory.getGeneratorId("2"));
- dictPo.setTableName("building_room");
- dictPo.setTableColumns("room_sub_type");
- dictPo.setName(Vtil.defaultValue(objects.get(1)));
- dictV1InnerServiceSMOImpl.saveDict(dictPo);
- dictDtos = dictV1InnerServiceSMOImpl.queryDictAndSpecs(dictDto);
+ if (!Vtil.defaultValue(objects.get(1)).isEmpty()) {
+ //--------璁剧疆鐗╀笟绫诲瀷
+ DictDto dictDto = new DictDto();
+ dictDto.setTableName("building_room");
+ dictDto.setTableColumns("room_sub_type");
+ dictDto.setName(Vtil.defaultValue(objects.get(1)));
+ List<DictDto> dictDtos = dictV1InnerServiceSMOImpl.queryDictAndSpecs(dictDto);
if (dictDtos.isEmpty()) {
- throw new IllegalArgumentException("瀵煎叆澶辫触:瀛楀吀涓笉瀛樺湪鐗╀笟绫诲瀷:" + Vtil.defaultValue(objects.get(1)));
+ DictPo dictPo = new DictPo();
+ dictPo.setStatusCd(GenerateCodeFactory.getGeneratorId("2"));
+ dictPo.setTableName("building_room");
+ dictPo.setTableColumns("room_sub_type");
+ dictPo.setName(Vtil.defaultValue(objects.get(1)));
+ dictV1InnerServiceSMOImpl.saveDict(dictPo);
+ dictDtos = dictV1InnerServiceSMOImpl.queryDictAndSpecs(dictDto);
+ if (dictDtos.isEmpty()) {
+ throw new IllegalArgumentException("瀵煎叆澶辫触:瀛楀吀涓笉瀛樺湪鐗╀笟绫诲瀷:" + Vtil.defaultValue(objects.get(1)));
+ }
}
+ importOwnerRoomDto.setRoomSubType(dictDtos.get(0).getStatusCd());
}
- importOwnerRoomDto.setRoomSubType(dictDtos.get(0).getStatusCd());
//----------
importOwnerRoomDto.setPropertyType(Vtil.defaultValue(objects.get(2)));//浣忓畢绫诲瀷
--
Gitblit v1.8.0