数据数据模型

Api/src/main/java/com/java110/api/listener/property/CheckStaffHasPropertyListener.java

@@ -0,0 +1,68 @@
+package com.java110.api.listener.property;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.listener.AbstractServiceApiDataFlowListener;
+import com.java110.common.constant.ServiceCodeConstant;
+import com.java110.common.util.Assert;
+import com.java110.core.annotation.Java110Listener;
+import com.java110.core.context.DataFlowContext;
+import com.java110.core.factory.AuthenticationFactory;
+import com.java110.entity.center.AppService;
+import com.java110.event.service.api.ServiceDataFlowEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.*;
+
+import javax.naming.AuthenticationException;
+import java.util.Map;
+
+/**
+ * @author wux
+ * @create 2019-02-10 下午11:11
+ * @desc 检查员工是否有物业信息
+ **/
+
+@Java110Listener("checkStaffHasPropertyListener")
+public class CheckStaffHasPropertyListener extends AbstractServiceApiDataFlowListener {
+
+    private final static Logger logger = LoggerFactory.getLogger(CheckStaffHasPropertyListener.class);
+
+    @Override
+    public String getServiceCode() {
+        return ServiceCodeConstant.SERVICE_CODE_CHECK_PROPERTY_STAFFHASPROPERTY;
+    }
+
+    @Override
+    public HttpMethod getHttpMethod() {
+        return HttpMethod.GET;
+    }
+
+    @Override
+    public void soService(ServiceDataFlowEvent event) {
+        DataFlowContext dataFlowContext = event.getDataFlowContext();
+        AppService service = event.getAppService();
+        String paramIn = dataFlowContext.getReqData();
+        Assert.isJsonObject(paramIn,"用户注册请求参数有误，不是有效的json格式 "+paramIn);
+        Assert.jsonObjectHaveKey(paramIn,"userId","请求报文中未包含userId 节点请检查");
+        JSONObject paramObj = JSONObject.parseObject(paramIn);
+        ResponseEntity responseEntity= null;
+        try {
+            HttpHeaders header = new HttpHeaders();
+            for(String key : dataFlowContext.getRequestCurrentHeaders().keySet()){
+                header.add(key,dataFlowContext.getRequestCurrentHeaders().get(key));
+            }
+            HttpEntity<String> httpEntity = new HttpEntity<String>(paramIn, header);
+            super.doRequest(dataFlowContext, service, httpEntity);
+            responseEntity = new ResponseEntity<String>("成功", HttpStatus.OK);
+        } catch (Exception e) {
+            //Invalid signature/claims
+            responseEntity = new ResponseEntity<String>("认证失败，不是有效的token", HttpStatus.UNAUTHORIZED);
+        }
+        dataFlowContext.setResponseEntity(responseEntity);
+    }
+
+    @Override
+    public int getOrder() {
+        return 0;
+    }
+}

Readme.md

@@ -50,6 +50,9 @@ Java + spring cloud + mybatis + mysql + kafka + redis
 
 3.统一接口地址：http://ip:8001/httpApi/service
 
+4.数据模型图
+![image](dataModel.png)
+
 加入微小区交流群随时了解项目进度，和java110开发者零距离沟通 qq群号 827669685，邮箱：928255095@qq.com
 
 ![image](MicroCommunity_qq.png)

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

@@ -267,6 +267,10 @@ public class ServiceCodeConstant {
     public static final String SERVICE_CODE_DELETE_PROPERTY_CERDENTIALS = "delete.property.cerdentials";
     public static final String SERVICE_CODE_DELETE_PROPERTY_USER = "delete.property.user";
     public static final String SERVICE_CODE_DELETE_PROPERTY_HOUSE = "delete.property.house";
+    /**
+     * 用工是否有物业信息
+     */
+    public static final String SERVICE_CODE_CHECK_PROPERTY_STAFFHASPROPERTY = "check.property.staffHasProperty";
 
 
     public static final String SERVICE_CODE_SAVE_AGENT_INFO = "save.agent.info";
@@ -281,4 +285,6 @@ public class ServiceCodeConstant {
     public static final String SERVICE_CODE_DELETE_AGENT_CERDENTIALS = "delete.agent.cerdentials";
     public static final String SERVICE_CODE_DELETE_AGENT_USER = "delete.agent.user";
 
+
+
 }

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

@@ -14,13 +14,13 @@ public class UserLevelConstant {
     public static final String USER_LEVEL_ADMIN = "00";
 
     /**
-     * 员工
+     * 普通员工
      */
     public static final String USER_LEVEL_STAFF = "01";
 
 
     /**
-     * 普通员工
+     * 普通用户
      */
     public static final String USER_LEVEL_ORDINARY = "02";
 }