From 352d2703b999530bc3bf3aba0cdef4534ae9d622 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期六, 21 九月 2019 00:20:51 +0800
Subject: [PATCH] 优化 小区入驻审核功能
---
CommunityService/src/main/java/com/java110/community/listener/communityMember/AuditCommunityMemberStateListener.java | 26 +++++++++++++++-----------
1 files changed, 15 insertions(+), 11 deletions(-)
diff --git a/CommunityService/src/main/java/com/java110/community/listener/MemberQuitCommunityListener.java b/CommunityService/src/main/java/com/java110/community/listener/communityMember/AuditCommunityMemberStateListener.java
similarity index 86%
copy from CommunityService/src/main/java/com/java110/community/listener/MemberQuitCommunityListener.java
copy to CommunityService/src/main/java/com/java110/community/listener/communityMember/AuditCommunityMemberStateListener.java
index af49c52..7273e7b 100644
--- a/CommunityService/src/main/java/com/java110/community/listener/MemberQuitCommunityListener.java
+++ b/CommunityService/src/main/java/com/java110/community/listener/communityMember/AuditCommunityMemberStateListener.java
@@ -1,4 +1,4 @@
-package com.java110.community.listener;
+package com.java110.community.listener.communityMember;
import com.alibaba.fastjson.JSONObject;
import com.java110.common.constant.BusinessTypeConstant;
@@ -7,6 +7,7 @@
import com.java110.common.exception.ListenerExecuteException;
import com.java110.common.util.Assert;
import com.java110.community.dao.ICommunityServiceDao;
+import com.java110.community.listener.AbstractCommunityBusinessServiceDataFlowListener;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.entity.center.Business;
@@ -26,11 +27,11 @@
* 鍗忚鍦板潃 锛歨ttps://github.com/java110/MicroCommunity/wiki/%E5%88%A0%E9%99%A4%E5%95%86%E6%88%B7%E4%BF%A1%E6%81%AF-%E5%8D%8F%E8%AE%AE
* Created by wuxw on 2018/5/18.
*/
-@Java110Listener("memberQuitCommunityListener")
+@Java110Listener("auditCommunityMemberStateListener")
@Transactional
-public class MemberQuitCommunityListener extends AbstractCommunityBusinessServiceDataFlowListener {
+public class AuditCommunityMemberStateListener extends AbstractCommunityBusinessServiceDataFlowListener {
- private final static Logger logger = LoggerFactory.getLogger(MemberQuitCommunityListener.class);
+ private final static Logger logger = LoggerFactory.getLogger(AuditCommunityMemberStateListener.class);
@Autowired
ICommunityServiceDao communityServiceDaoImpl;
@@ -41,7 +42,7 @@
@Override
public String getBusinessTypeCd() {
- return BusinessTypeConstant.BUSINESS_TYPE_MEMBER_QUIT_COMMUNITY;
+ return BusinessTypeConstant.BUSINESS_TYPE_AUDIT_COMMUNITY_MEMBER_STATE;
}
/**
@@ -79,12 +80,13 @@
//灏忓尯淇℃伅
Map info = new HashMap();
info.put("bId", business.getbId());
- info.put("operate", StatusConstant.OPERATE_DEL);
+ info.put("operate", StatusConstant.OPERATE_ADD);
+
//灏忓尯淇℃伅
Map businessCommunityMember = communityServiceDaoImpl.getBusinessCommunityMember(info);
if (businessCommunityMember != null && !businessCommunityMember.isEmpty()) {
- flushBusinessCommunityMember(businessCommunityMember, StatusConstant.STATUS_CD_INVALID);
+ flushBusinessCommunityMember(businessCommunityMember, StatusConstant.STATUS_CD_VALID);
communityServiceDaoImpl.updateCommunityMemberInstance(businessCommunityMember);
dataFlowContext.addParamOut("communityMemberId", businessCommunityMember.get("member_community_id"));
}
@@ -103,7 +105,7 @@
//Assert.hasLength(bId,"璇锋眰鎶ユ枃涓病鏈夊寘鍚� bId");
Map info = new HashMap();
info.put("bId", bId);
- info.put("statusCd", StatusConstant.STATUS_CD_INVALID);
+ info.put("statusCd", StatusConstant.STATUS_CD_VALID);
Map delInfo = new HashMap();
delInfo.put("bId", business.getbId());
@@ -136,11 +138,13 @@
Assert.jsonObjectHaveKey(businessCommunity, "communityMemberId", "doBusinessCommunityMember 鑺傜偣涓嬫病鏈夊寘鍚� communityMemberId 鑺傜偣");
- if (businessCommunity.getString("communityMemberId").startsWith("-")) {
- throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "communityMemberId 閿欒锛屼笉鑳借嚜鍔ㄧ敓鎴愶紙蹇呴』宸茬粡瀛樺湪鐨刢ommunityMemberId锛�" + businessCommunity);
- }
//鑷姩鎻掑叆DEL
autoSaveDelBusinessCommunityMember(business, businessCommunity);
+
+ businessCommunity.put("bId",business.getbId());
+ businessCommunity.put("operate", StatusConstant.OPERATE_ADD);
+ //淇濆瓨灏忓尯淇℃伅
+ communityServiceDaoImpl.saveBusinessCommunityMember(businessCommunity);
}
--
Gitblit v1.8.0