From 2f28b85bf6cee44d72ab0d06fed0fc12fa6a8efc Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 01 六月 2020 13:06:43 +0800
Subject: [PATCH] 用户注册
---
Api/src/main/java/com/java110/api/listener/UserRegisterServiceListener.java | 77 +++++++++++++++++++++-----------------
1 files changed, 42 insertions(+), 35 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/listener/UserRegisterServiceListener.java b/Api/src/main/java/com/java110/api/listener/UserRegisterServiceListener.java
index a1d18e8..90c0bc1 100644
--- a/Api/src/main/java/com/java110/api/listener/UserRegisterServiceListener.java
+++ b/Api/src/main/java/com/java110/api/listener/UserRegisterServiceListener.java
@@ -1,25 +1,31 @@
package com.java110.api.listener;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.user.IUserBMO;
-import com.java110.po.user.UserPo;
-import com.java110.utils.constant.*;
-import com.java110.utils.util.Assert;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.AppService;
import com.java110.core.event.service.api.ServiceDataFlowEvent;
+import com.java110.entity.center.AppService;
+import com.java110.po.user.UserPo;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.constant.ServiceCodeConstant;
+import com.java110.utils.constant.UserLevelConstant;
+import com.java110.utils.util.Assert;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.*;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
/**
* 鐢ㄦ埛娉ㄥ唽 渚﹀惉
* Created by wuxw on 2018/5/18.
*/
@Java110Listener("userRegisterServiceListener")
-public class UserRegisterServiceListener extends AbstractServiceApiDataFlowListener{
+public class UserRegisterServiceListener extends AbstractServiceApiDataFlowListener {
private final static Logger logger = LoggerFactory.getLogger(UserRegisterServiceListener.class);
@@ -47,22 +53,23 @@
/**
* 璇锋眰鍙傛暟鏍煎紡锛�
* {
- "userId": "-1",
- "name": "寮犱笁",
- "email": "928255095@qq.com",
- "address": "闈掓捣鐪佽タ瀹佸競鍩庝腑鍖�129鍙�",
- "password": "ERCBHDUYFJDNDHDJDNDJDHDUDHDJDDKDK",
- "locationCd": "001",
- "age": 19,
- "sex": "0",
- "tel": "17797173943",
- "level_cd": "1",
- "businessUserAttr": [{
- "attrId":"-1",
- "specCd":"1001",
- "value":"01"
- }]
- }
+ * "userId": "-1",
+ * "name": "寮犱笁",
+ * "email": "928255095@qq.com",
+ * "address": "闈掓捣鐪佽タ瀹佸競鍩庝腑鍖�129鍙�",
+ * "password": "ERCBHDUYFJDNDHDJDNDJDHDUDHDJDDKDK",
+ * "locationCd": "001",
+ * "age": 19,
+ * "sex": "0",
+ * "tel": "17797173943",
+ * "level_cd": "1",
+ * "businessUserAttr": [{
+ * "attrId":"-1",
+ * "specCd":"1001",
+ * "value":"01"
+ * }]
+ * }
+ *
* @param event
*/
@Override
@@ -71,19 +78,21 @@
DataFlowContext dataFlowContext = event.getDataFlowContext();
AppService service = event.getAppService();
String paramIn = dataFlowContext.getReqData();
- Assert.isJsonObject(paramIn,"鐢ㄦ埛娉ㄥ唽璇锋眰鍙傛暟鏈夎锛屼笉鏄湁鏁堢殑json鏍煎紡 "+paramIn);
+ Assert.isJsonObject(paramIn, "鐢ㄦ埛娉ㄥ唽璇锋眰鍙傛暟鏈夎锛屼笉鏄湁鏁堢殑json鏍煎紡 " + paramIn);
JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_USER_INFO);
- business.put(CommonConstant.HTTP_SEQ,1);
- business.put(CommonConstant.HTTP_INVOKE_MODEL,CommonConstant.HTTP_INVOKE_MODEL_S);
+ business.put(CommonConstant.HTTP_SEQ, 1);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
- business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put(UserPo.class.getSimpleName(),refreshParamIn(paramIn));
+ JSONArray userPos = new JSONArray();
+ userPos.add(refreshParamIn(paramIn));
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put(UserPo.class.getSimpleName(), userPos);
HttpHeaders header = new HttpHeaders();
- dataFlowContext.getRequestCurrentHeaders().put(CommonConstant.HTTP_USER_ID,"-1");
- dataFlowContext.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD,"D");
- String paramInObj = userBMOImpl.restToCenterProtocol(business,dataFlowContext.getRequestCurrentHeaders()).toJSONString();
+ dataFlowContext.getRequestCurrentHeaders().put(CommonConstant.HTTP_USER_ID, "-1");
+ dataFlowContext.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD, "D");
+ String paramInObj = userBMOImpl.restToCenterProtocol(business, dataFlowContext.getRequestCurrentHeaders()).toJSONString();
//灏� rest header 淇℃伅浼犻�掑埌涓嬪眰鏈嶅姟涓幓
- userBMOImpl.freshHttpHeader(header,dataFlowContext.getRequestCurrentHeaders());
+ userBMOImpl.freshHttpHeader(header, dataFlowContext.getRequestCurrentHeaders());
HttpEntity<String> httpEntity = new HttpEntity<String>(paramInObj, header);
//http://user-service/test/sayHello
super.doRequest(dataFlowContext, service, httpEntity);
@@ -93,19 +102,17 @@
/**
* 瀵硅姹傛姤鏂囧鐞�
+ *
* @param paramIn
* @return
*/
- private JSONObject refreshParamIn(String paramIn){
+ private JSONObject refreshParamIn(String paramIn) {
JSONObject paramObj = JSONObject.parseObject(paramIn);
- paramObj.put("userId","-1");
+ paramObj.put("userId", "-1");
paramObj.put("levelCd", UserLevelConstant.USER_LEVEL_ADMIN);
return paramObj;
}
-
-
-
}
--
Gitblit v1.8.0