From 9592a96bc773354e93b048df7183cc6accfe5229 Mon Sep 17 00:00:00 2001
From: 吴学文 <wuxuewen@wuxuewendeMacBook-Pro.local>
Date: 星期四, 16 五月 2019 00:27:21 +0800
Subject: [PATCH] 数据库分片未开发完成
---
CommunityService/src/main/java/com/java110/community/listener/SaveCommunityInfoListener.java | 25 ++++++++++++++++++++++++-
1 files changed, 24 insertions(+), 1 deletions(-)
diff --git a/CommunityService/src/main/java/com/java110/community/listener/SaveCommunityInfoListener.java b/CommunityService/src/main/java/com/java110/community/listener/SaveCommunityInfoListener.java
index b64767b..f15bd35 100644
--- a/CommunityService/src/main/java/com/java110/community/listener/SaveCommunityInfoListener.java
+++ b/CommunityService/src/main/java/com/java110/community/listener/SaveCommunityInfoListener.java
@@ -89,24 +89,47 @@
//灏忓尯淇℃伅
Map businessCommunityInfo = communityServiceDaoImpl.getBusinessCommunityInfo(info);
+
if (businessCommunityInfo != null && !businessCommunityInfo.isEmpty()) {
- communityServiceDaoImpl.saveCommunityInfoInstance(info);
+ reFresh(info, businessCommunityInfo);
+ communityServiceDaoImpl.saveCommunityInfoInstance(businessCommunityInfo);
dataFlowContext.addParamOut("communityId", businessCommunityInfo.get("community_id"));
}
//灏忓尯灞炴��
List<Map> businessCommunityAttrs = communityServiceDaoImpl.getBusinessCommunityAttrs(info);
if (businessCommunityAttrs != null && businessCommunityAttrs.size() > 0) {
+ reFresh(info, businessCommunityAttrs.get(0));
communityServiceDaoImpl.saveCommunityAttrsInstance(info);
}
//灏忓尯鐓х墖
List<Map> businessCommunityPhotos = communityServiceDaoImpl.getBusinessCommunityPhoto(info);
if (businessCommunityPhotos != null && businessCommunityPhotos.size() > 0) {
+ reFresh(info, businessCommunityPhotos.get(0));
communityServiceDaoImpl.saveCommunityPhotoInstance(info);
}
}
/**
+ * 鍒� communityId
+ *
+ * @param info 鏌ヨ瀵硅薄
+ * @param businessInfo 灏忓尯ID
+ */
+ private void reFresh(Map info, Map businessInfo) {
+
+ if (info.containsKey("communityId")) {
+ return;
+ }
+
+ if (!businessInfo.containsKey("community_id")) {
+ return;
+ }
+
+ info.put("communityId", businessInfo.get("community_id"));
+ }
+
+ /**
* 鎾ゅ崟
*
* @param dataFlowContext 鏁版嵁瀵硅薄
--
Gitblit v1.8.0