java110 лет назад: 4
Родитель
Сommit
9903732d78

+ 1 - 0
service-api/src/main/java/com/java110/api/components/parkingSpace/ParkingAreaSelect2Component.java

@@ -17,6 +17,7 @@ public class ParkingAreaSelect2Component {
 
 
     public ResponseEntity<String> list(IPageData pd) {
+
         return listParkingAreasSMOImpl.listParkingAreas(pd);
     }
 

+ 0 - 118
service-api/src/main/java/com/java110/api/listener/UserRegisterServiceListener.java

@@ -1,118 +0,0 @@
-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.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-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.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 {
-
-    private final static Logger logger = LoggerFactory.getLogger(UserRegisterServiceListener.class);
-
-
-    @Autowired
-    private IUserBMO userBMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeConstant.SERVICE_CODE_USER_SERVICE_REGISTER;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return 0;
-    }
-
-
-    /**
-     * 请求参数格式:
-     * {
-     * "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
-    public void soService(ServiceDataFlowEvent event) {
-        //获取数据上下文对象
-        DataFlowContext dataFlowContext = event.getDataFlowContext();
-        AppService service = event.getAppService();
-        String paramIn = dataFlowContext.getReqData();
-        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);
-
-        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();
-        //将 rest header 信息传递到下层服务中去
-        userBMOImpl.freshHttpHeader(header, dataFlowContext.getRequestCurrentHeaders());
-        HttpEntity<String> httpEntity = new HttpEntity<String>(paramInObj, header);
-        //http://user-service/test/sayHello
-        super.doRequest(dataFlowContext, service, httpEntity);
-
-        super.doResponse(dataFlowContext);
-    }
-
-    /**
-     * 对请求报文处理
-     *
-     * @param paramIn
-     * @return
-     */
-    private JSONObject refreshParamIn(String paramIn) {
-        JSONObject paramObj = JSONObject.parseObject(paramIn);
-        paramObj.put("userId", "-1");
-        paramObj.put("levelCd", UserLevelConstant.USER_LEVEL_ADMIN);
-
-        return paramObj;
-    }
-
-
-}

+ 3 - 3
service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java

@@ -107,7 +107,9 @@ public class DefaultAbstractComponentSMO extends AbstractComponentSMO {
         headers.put(CommonConstant.HTTP_SERVICE, url);
         headers.put(CommonConstant.HTTP_METHOD, CommonConstant.getHttpMethodStr(httpMethod));
 
-        initUrlParam(JSONObject.parseObject(param), headers);
+        if (HttpMethod.GET == httpMethod) {
+            initUrlParam(JSONObject.parseObject(param), headers);
+        }
         if (HttpMethod.GET == httpMethod) {
             headers.put("REQUEST_URL", "http://127.0.0.1:8008/" + url + mapToUrlParam(JSONObject.parseObject(param)));
         }
@@ -359,8 +361,6 @@ public class DefaultAbstractComponentSMO extends AbstractComponentSMO {
     }
 
 
-
-
     private JSONObject getCurrentCommunity(JSONArray communitys, String communityId) {
         for (int communityIndex = 0; communityIndex < communitys.size(); communityIndex++) {
             if (communityId.equals(communitys.getJSONObject(communityIndex).getString("communityId"))) {