加入员工查询接口

Api/src/main/java/com/java110/api/listener/users/QueryStaffServiceListener.java

@@ -0,0 +1,123 @@
+package com.java110.api.listener.users;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.listener.AbstractServiceApiDataFlowListener;
+import com.java110.common.constant.CommonConstant;
+import com.java110.common.constant.ServiceCodeConstant;
+import com.java110.common.exception.ListenerExecuteException;
+import com.java110.common.util.Assert;
+import com.java110.core.annotation.Java110Listener;
+import com.java110.core.context.DataFlowContext;
+import com.java110.core.factory.DataFlowFactory;
+import com.java110.entity.center.AppService;
+import com.java110.event.service.api.ServiceDataFlowEvent;
+import org.springframework.http.*;
+
+import java.util.Map;
+
+/**
+ * 查询员工信息
+ * Created by Administrator on 2019/4/2.
+ */
+@Java110Listener("queryStaffServiceListener")
+public class QueryStaffServiceListener extends AbstractServiceApiDataFlowListener {
+    @Override
+    public int getOrder() {
+        return 0;
+    }
+
+    @Override
+    public String getServiceCode() {
+        return ServiceCodeConstant.SERVICE_CODE_QUERY_STAFF_INFOS;
+    }
+
+    @Override
+    public HttpMethod getHttpMethod() {
+        return HttpMethod.GET;
+    }
+
+    /**
+     *
+     * @param event
+     */
+    @Override
+    public void soService(ServiceDataFlowEvent event) {
+
+
+        DataFlowContext dataFlowContext = event.getDataFlowContext();
+        AppService service = event.getAppService();
+        Map<String,String> headers = dataFlowContext.getRequestHeaders();
+
+        Assert.hasKeyAndValue(headers,"page","请求报文中未包含page节点");
+        Assert.hasKeyAndValue(headers,"rows","请求报文中未包含rows节点");
+        Assert.hasKeyAndValue(headers,"storeId","请求报文中未包含storeId节点");
+
+        ResponseEntity responseEntity= null;
+        AppService appService = DataFlowFactory.getService(dataFlowContext.getAppId(), ServiceCodeConstant.SERVICE_CODE_QUERY_STORE_USERS);
+        if(appService == null){
+            responseEntity = new ResponseEntity<String>("当前没有权限访问"+ServiceCodeConstant.SERVICE_CODE_QUERY_STORE_USERS, HttpStatus.UNAUTHORIZED);
+            dataFlowContext.setResponseEntity(responseEntity);
+            return ;
+        }
+        String requestUrl = appService.getUrl();
+        HttpHeaders header = new HttpHeaders();
+        header.add(CommonConstant.HTTP_SERVICE.toLowerCase(),ServiceCodeConstant.SERVICE_CODE_QUERY_STORE_USERS);
+
+        //先查询商户服务查询员工userId
+        requestUrl = requestUrl + "?page="+headers.get("page")+"&rows="+headers.get("rows")+"&storeId="+headers.get("storeId");
+        dataFlowContext.getRequestHeaders().put("REQUEST_URL",requestUrl);
+        HttpEntity<String> httpEntity = new HttpEntity<String>("", header);
+        doRequest(dataFlowContext,appService,httpEntity);
+        responseEntity = dataFlowContext.getResponseEntity();
+
+        if(responseEntity.getStatusCode() != HttpStatus.OK){
+            return ;
+        }
+
+        //然后根据userId 在用户服务查询用户信息
+        JSONObject staffs = JSONObject.parseObject(responseEntity.getBody().toString());
+
+        JSONArray rows = staffs.getJSONArray("rows");
+
+        appService = DataFlowFactory.getService(dataFlowContext.getAppId(), ServiceCodeConstant.SERVICE_CODE_QUERY_USER_USERINFO);
+        if(appService == null){
+            responseEntity = new ResponseEntity<String>("当前没有权限访问"+ServiceCodeConstant.SERVICE_CODE_QUERY_USER_USERINFO, HttpStatus.UNAUTHORIZED);
+            dataFlowContext.setResponseEntity(responseEntity);
+            return ;
+        }
+
+        for(int rowIndex = 0 ;rowIndex < rows.size();rowIndex ++){
+            JSONObject tmpObj = rows.getJSONObject(rowIndex);
+            queryUserInfoByUserId(dataFlowContext,tmpObj,appService);
+        }
+
+    }
+
+    /**
+     * 查询用户信息
+     * @param tmpObj
+     */
+    private void queryUserInfoByUserId( DataFlowContext dataFlowContext,JSONObject tmpObj,AppService appService){
+
+        String userId = tmpObj.getString("userId");
+
+        ResponseEntity responseEntity= null;
+
+        String requestUrl = appService.getUrl();
+        HttpHeaders header = new HttpHeaders();
+        header.add(CommonConstant.HTTP_SERVICE.toLowerCase(),ServiceCodeConstant.SERVICE_CODE_QUERY_USER_USERINFO);
+
+        //先查询商户服务查询员工userId
+        requestUrl = requestUrl + "?userId="+userId;
+        dataFlowContext.getRequestHeaders().put("REQUEST_URL",requestUrl);
+        HttpEntity<String> httpEntity = new HttpEntity<String>("", header);
+        doRequest(dataFlowContext,appService,httpEntity);
+        responseEntity = dataFlowContext.getResponseEntity();
+
+        if(responseEntity.getStatusCode() != HttpStatus.OK){
+            throw new ListenerExecuteException(1999,"查询用户信息异常 "+responseEntity.getBody());
+        }
+        tmpObj.putAll(JSONObject.parseObject(responseEntity.getBody().toString()));
+    }
+}

WebService/src/main/java/com/java110/web/smo/impl/StaffServiceSMOImpl.java

@@ -49,6 +49,7 @@ public class StaffServiceSMOImpl extends BaseComponentSMO implements IStaffServi
         String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
         String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
         JSONObject reqJson = JSONObject.parseObject(pd.getReqData());
+        reqJson.put("name",reqJson.getString("username"));
         reqJson.put("storeId",storeId);
         reqJson.put("storeTypeCd",storeTypeCd);
         responseEntity = this.callCenterService(restTemplate,pd,reqJson.toJSONString(), ServiceConstant.SERVICE_API_URL+"/api/user.staff.add", HttpMethod.POST);

java110-common/src/main/java/com/java110/common/constant/ServiceCodeConstant.java

@@ -105,6 +105,12 @@ public class ServiceCodeConstant {
      */
     public static final String SERVICE_CODE_SAVE_USER_DEFAULT_PRIVILEGE = "save.user.defaultPrivilege";
 
+
+    /**
+     * 保存用户默认权限
+     */
+    public static final String SERVICE_CODE_QUERY_USER_USERINFO = "query.user.userInfo";
+
     /**
      * 保存商户信息
      */
@@ -136,7 +142,10 @@ public class ServiceCodeConstant {
      */
     public static final String SERVICE_CODE_QUERY_STORE_BYUSER = "query.store.byuser";
 
-
+    /**
+     * 根据商户用户信息
+     */
+    public static final String SERVICE_CODE_QUERY_STORE_USERS = "query.store.users";
     /**
      * 商户成员加入信息
      */
@@ -244,6 +253,12 @@ public class ServiceCodeConstant {
     public static final String SERVICE_CODE_USER_STAFF_ENABLE = "user.staff.enable";
 
 
+    /**
+     * 查询 员工
+     */
+    public static final String SERVICE_CODE_QUERY_STAFF_INFOS = "query.staff.infos";
+
+
 
     /**
      * 保存商户信息