From 9adbbca6d70de6f6a5095f1dad1c6dbb512b41f1 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期三, 04 七月 2018 01:13:24 +0800
Subject: [PATCH] 商户服务开发完成，待测试
---
UserService/src/main/java/com/java110/user/listener/SaveUserInfoListener.java | 181 ++++++++++++++++----------------------------
1 files changed, 67 insertions(+), 114 deletions(-)
diff --git a/UserService/src/main/java/com/java110/user/listener/SaveUserInfoListener.java b/UserService/src/main/java/com/java110/user/listener/SaveUserInfoListener.java
index dcc9025..c828899 100644
--- a/UserService/src/main/java/com/java110/user/listener/SaveUserInfoListener.java
+++ b/UserService/src/main/java/com/java110/user/listener/SaveUserInfoListener.java
@@ -8,15 +8,17 @@
import com.java110.common.log.LoggerEngine;
import com.java110.common.util.Assert;
import com.java110.core.annotation.Java110Listener;
-import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.context.DataFlowContext;
import com.java110.core.factory.DataTransactionFactory;
+import com.java110.core.factory.GenerateCodeFactory;
import com.java110.entity.center.Business;
+import com.java110.event.service.AbstractBusinessServiceDataFlowListener;
import com.java110.event.service.BusinessServiceDataFlowEvent;
import com.java110.event.service.BusinessServiceDataFlowListener;
import com.java110.user.dao.IUserServiceDao;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashMap;
@@ -29,7 +31,9 @@
*/
@Java110Listener("saveUserInfoListener")
@Transactional
-public class SaveUserInfoListener extends LoggerEngine implements BusinessServiceDataFlowListener{
+public class SaveUserInfoListener extends AbstractBusinessServiceDataFlowListener {
+
+ private final static Logger logger = LoggerFactory.getLogger(SaveUserInfoListener.class);
@Autowired
IUserServiceDao userServiceDaoImpl;
@@ -44,113 +48,14 @@
return ServiceCodeConstant.SERVICE_CODE_SAVE_USER_INFO;
}
+
+ /**
+ * 淇濆瓨鐢ㄦ埛淇℃伅鑷� business琛ㄤ腑
+ * @param dataFlowContext 鏁版嵁瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
+ */
@Override
- public void soService(BusinessServiceDataFlowEvent event) {
- //杩欓噷澶勭悊涓氬姟閫昏緫鏁版嵁
- DataFlowContext dataFlowContext = event.getDataFlowContext();
- doSaveUserInfo(dataFlowContext);
- }
-
- private void doSaveUserInfo(DataFlowContext dataFlowContext){
- String businessType = dataFlowContext.getOrder().getBusinessType();
- Business business = dataFlowContext.getCurrentBusiness();
- //Assert.hasLength(business.getbId(),"bId 涓嶈兘涓虹┖");
- // Instance 杩囩▼
- if(StatusConstant.REQUEST_BUSINESS_TYPE_INSTANCE.equals(businessType)){
- //doComplateUserInfo(business);
- doSaveInstanceUserInfo(dataFlowContext,business);
- }else if(StatusConstant.REQUEST_BUSINESS_TYPE_BUSINESS.equals(businessType)){ // Business杩囩▼
- doSaveBusinessUserInfo(dataFlowContext,business);
- }else if(StatusConstant.REQUEST_BUSINESS_TYPE_DELETE.equals(businessType)){ //鎾ゅ崟杩囩▼
- doDeleteInstanceUserInfo(dataFlowContext,business);
- }
-
- dataFlowContext.setResJson(DataTransactionFactory.createBusinessResponseJson(dataFlowContext,ResponseConstant.RESULT_CODE_SUCCESS,"鎴愬姛",
- dataFlowContext.getParamOut()));
- }
-
- /**
- * 鎾ゅ崟
- * @param business
- */
- private void doDeleteInstanceUserInfo(DataFlowContext dataFlowContext,Business business) {
-
- String bId = business.getbId();
- //Assert.hasLength(bId,"璇锋眰鎶ユ枃涓病鏈夊寘鍚� bId");
- Map info = new HashMap();
- info.put("bId",bId);
- Map userInfo = userServiceDaoImpl.queryUserInfo(info);
- if(userInfo != null && !userInfo.isEmpty()){
- info.put("bId",bId);
- info.put("userId",userInfo.get("user_id").toString());
- info.put("statusCd",StatusConstant.STATUS_CD_INVALID);
- userServiceDaoImpl.updateUserInfoInstance(userInfo);
- dataFlowContext.addParamOut("userId",userInfo.get("user_id"));
- }
-
- info.clear();
- info.put("bId",bId);
-
- List<Map> userAttrs = userServiceDaoImpl.queryUserInfoAttrs(info);
-
- if(userAttrs != null && userAttrs.size() >0){
- info.put("bId",bId);
- //info.put("userId",userInfo.get("user_id").toString());
- info.put("statusCd",StatusConstant.STATUS_CD_INVALID);
- userServiceDaoImpl.updateUserAttrInstance(info);
- }
-
-
- }
-
- /**
- * instance杩囩▼
- * @param business
- */
- private void doSaveInstanceUserInfo(DataFlowContext dataFlowContext,Business business) {
-
- JSONObject data = business.getDatas();
-
- //Assert.notEmpty(data,"娌℃湁datas 鑺傜偣锛屾垨娌℃湁瀛愯妭鐐归渶瑕佸鐞�");
-
- //Assert.jsonObjectHaveKey(data,"businessUser","datas 鑺傜偣涓嬫病鏈夊寘鍚� businessUser 鑺傜偣");
-
- //JSONObject businessUser = data.getJSONObject("businessUser");
- Map info = new HashMap();
- info.put("bId",business.getbId());
- info.put("operate",StatusConstant.OPERATE_ADD);
- Map businessUser = userServiceDaoImpl.queryBusinessUserInfo(info);
- if( businessUser != null && !businessUser.isEmpty()) {
- userServiceDaoImpl.saveUserInfoInstance(businessUser);
- dataFlowContext.addParamOut("userId",businessUser.get("user_id"));
- }
- List<Map> businessUserAttrs = userServiceDaoImpl.queryBusinessUserInfoAttrs(info);
- if(businessUserAttrs != null && businessUserAttrs.size() > 0) {
- userServiceDaoImpl.saveUserAttrInstance(businessUser);
- }
-
-
- }
-
- /**
- * 淇濆瓨鏁版嵁鑷硊_user 琛ㄤ腑
- * @param business
- */
- private void doComplateUserInfo(DataFlowContext dataFlowContext,Business business) {
- String bId = business.getbId();
- Map paramIn = new HashMap();
- paramIn.put("bId",bId);
- paramIn.put("statusCd",StatusConstant.STATUS_CD_VALID);
- userServiceDaoImpl.updateUserInfoInstance(paramIn);
- userServiceDaoImpl.updateUserAttrInstance(paramIn);
- }
-
- /**
- * 澶勭悊鐢ㄦ埛淇℃伅
- * @param business
- */
- private void doSaveBusinessUserInfo(DataFlowContext dataFlowContext,Business business) {
-
+ protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
JSONObject data = business.getDatas();
Assert.notEmpty(data,"娌℃湁datas 鑺傜偣锛屾垨娌℃湁瀛愯妭鐐归渶瑕佸鐞�");
@@ -175,11 +80,63 @@
if(businessUser.containsKey("businessUserAttr")){
doSaveUserAttrs(business);
}
+ }
- //userServiceDaoImpl.saveUserInfoInstance(businessUser);
+ /**
+ * 灏� business鐨勭敤鎴蜂俊鎭� 淇濆瓨鑷� instance琛ㄤ腑
+ * @param dataFlowContext 鏁版嵁瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
+ */
+ @Override
+ protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
+ JSONObject data = business.getDatas();
+ Map info = new HashMap();
+ info.put("bId",business.getbId());
+ info.put("operate",StatusConstant.OPERATE_ADD);
+ Map businessUser = userServiceDaoImpl.queryBusinessUserInfo(info);
+ if( businessUser != null && !businessUser.isEmpty()) {
+ userServiceDaoImpl.saveUserInfoInstance(businessUser);
+ dataFlowContext.addParamOut("userId",businessUser.get("user_id"));
+ }
+ List<Map> businessUserAttrs = userServiceDaoImpl.queryBusinessUserInfoAttrs(info);
+ if(businessUserAttrs != null && businessUserAttrs.size() > 0) {
+ userServiceDaoImpl.saveUserAttrInstance(businessUser);
+ }
+ }
+ /**
+ * 灏唅nstance 浣滃簾
+ * @param dataFlowContext 鏁版嵁瀵硅薄
+ * @param business 褰撳墠涓氬姟瀵硅薄
+ */
+ @Override
+ protected void doRecover(DataFlowContext dataFlowContext, Business business) {
+ String bId = business.getbId();
+ //Assert.hasLength(bId,"璇锋眰鎶ユ枃涓病鏈夊寘鍚� bId");
+ Map info = new HashMap();
+ info.put("bId",bId);
+ Map userInfo = userServiceDaoImpl.queryUserInfo(info);
+ if(userInfo != null && !userInfo.isEmpty()){
+ info.put("bId",bId);
+ info.put("userId",userInfo.get("user_id").toString());
+ info.put("statusCd",StatusConstant.STATUS_CD_INVALID);
+ userServiceDaoImpl.updateUserInfoInstance(info);
+ dataFlowContext.addParamOut("userId",userInfo.get("user_id"));
+ }
+
+ info.clear();
+ info.put("bId",bId);
+
+ List<Map> userAttrs = userServiceDaoImpl.queryUserInfoAttrs(info);
+
+ if(userAttrs != null && userAttrs.size() >0){
+ info.put("bId",bId);
+ //info.put("userId",userInfo.get("user_id").toString());
+ info.put("statusCd",StatusConstant.STATUS_CD_INVALID);
+ userServiceDaoImpl.updateUserAttrInstance(info);
+ }
}
private void doSaveUserAttrs(Business business){
@@ -201,10 +158,6 @@
userServiceDaoImpl.saveBusinessUserAttr(userAttr);
}
-
- /*JSONObject attrInstance = new JSONObject();
- attrInstance.put("bId",business.getbId());
- userServiceDaoImpl.saveUserAttrInstance(attrInstance);*/
}
public IUserServiceDao getUserServiceDaoImpl() {
--
Gitblit v1.8.0