业主绑定功能开发中

Api/src/main/java/com/java110/api/listener/owner/AppUserBindingOwnerListener.java

@@ -0,0 +1,269 @@
+package com.java110.api.listener.owner;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.listener.AbstractServiceApiDataFlowListener;
+import com.java110.api.listener.AbstractServiceApiListener;
+import com.java110.core.annotation.Java110Listener;
+import com.java110.core.context.DataFlowContext;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.core.smo.file.IFileInnerServiceSMO;
+import com.java110.dto.file.FileDto;
+import com.java110.entity.center.AppService;
+import com.java110.event.service.api.ServiceDataFlowEvent;
+import com.java110.utils.constant.*;
+import com.java110.utils.exception.ListenerExecuteException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.DateUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+
+/**
+ * @ClassName AppUserBindingOwnerListener
+ * @Description app用户绑定业主接口
+ * @Author wuxw
+ * @Date 2019/4/26 14:51
+ * @Version 1.0
+ * add by wuxw 2019/4/26
+ **/
+
+@Java110Listener("appUserBindingOwnerListener")
+public class AppUserBindingOwnerListener extends AbstractServiceApiListener {
+
+
+    private static final int DEFAULT_SEQ_COMMUNITY_MEMBER = 2;
+
+    @Autowired
+    private IFileInnerServiceSMO fileInnerServiceSMOImpl;
+
+    private static Logger logger = LoggerFactory.getLogger(AppUserBindingOwnerListener.class);
+
+    @Override
+    public String getServiceCode() {
+        return ServiceCodeConstant.SERVICE_CODE_APP_USER_BINDING_OWNER;
+    }
+
+    @Override
+    public HttpMethod getHttpMethod() {
+        return HttpMethod.POST;
+    }
+
+    @Override
+    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "communityName", "未包含小区名称");
+        Assert.hasKeyAndValue(reqJson, "areaCode", "未包含小区名称");
+        Assert.hasKeyAndValue(reqJson, "appUserName", "未包含用户名称");
+        Assert.hasKeyAndValue(reqJson, "idCard", "未包含身份证号");
+        Assert.hasKeyAndValue(reqJson, "link", "未包含联系电话");
+    }
+
+    @Override
+    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+
+        logger.debug("ServiceDataFlowEvent : {}", event);
+
+        //查询小区是否存在
+    }
+
+    /**
+     * 生成小区楼ID
+     *
+     * @param paramObj 请求入参数据
+     */
+    private void generateMemberId(JSONObject paramObj) {
+        String memberId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId);
+        paramObj.put("memberId", memberId);
+        if (!paramObj.containsKey("ownerId") || "1001".equals(paramObj.getString("ownerTypeCd"))) {
+            paramObj.put("ownerId", memberId);
+        }
+    }
+
+
+    /**
+     * 添加小区楼信息
+     * <p>
+     * * name:'',
+     * *                 age:'',
+     * *                 link:'',
+     * *                 sex:'',
+     * *                 remark:''
+     *
+     * @param paramInJson 接口调用放传入入参
+     * @return 订单服务能够接受的报文
+     */
+    private JSONObject addOwner(JSONObject paramInJson) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_OWNER_INFO);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject businessOwner = new JSONObject();
+        businessOwner.putAll(paramInJson);
+        businessOwner.put("state", "2000");
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessOwner", businessOwner);
+
+        return business;
+    }
+
+
+    /**
+     * 添加小区成员
+     *
+     * @param paramInJson 组装 楼小区关系
+     * @return 小区成员信息
+     */
+    private JSONObject addCommunityMember(JSONObject paramInJson) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_MEMBER_JOINED_COMMUNITY);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ_COMMUNITY_MEMBER);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject businessCommunityMember = new JSONObject();
+        businessCommunityMember.put("communityMemberId", "-1");
+        businessCommunityMember.put("communityId", paramInJson.getString("communityId"));
+        businessCommunityMember.put("memberId", paramInJson.getString("ownerId"));
+        businessCommunityMember.put("memberTypeCd", CommunityMemberTypeConstant.OWNER);
+        businessCommunityMember.put("auditStatusCd", StateConstant.AGREE_AUDIT);
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessCommunityMember", businessCommunityMember);
+
+        return business;
+    }
+
+
+    /**
+     * 售卖房屋信息
+     *
+     * @param paramInJson     接口调用放传入入参
+     * @param dataFlowContext 数据上下文
+     * @return 订单服务能够接受的报文
+     */
+    private JSONObject sellRoom(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_OWNER_ROOM_REL);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject businessUnit = new JSONObject();
+        businessUnit.putAll(paramInJson);
+        businessUnit.put("relId", "-1");
+        businessUnit.put("userId", dataFlowContext.getRequestCurrentHeaders().get(CommonConstant.HTTP_USER_ID));
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessOwnerRoomRel", businessUnit);
+
+        return business;
+    }
+
+    /**
+     * 添加物业费用
+     *
+     * @param paramInJson     接口调用放传入入参
+     * @param dataFlowContext 数据上下文
+     * @return 订单服务能够接受的报文
+     */
+    private JSONObject addPropertyFee(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_FEE_INFO);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ + 1);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject businessUnit = new JSONObject();
+        businessUnit.put("feeId", "-1");
+        businessUnit.put("feeTypeCd", FeeTypeConstant.FEE_TYPE_PROPERTY);
+        businessUnit.put("incomeObjId", paramInJson.getString("storeId"));
+        businessUnit.put("amount", "-1.00");
+        businessUnit.put("startTime", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        businessUnit.put("endTime", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        businessUnit.put("communityId", paramInJson.getString("communityId"));
+        businessUnit.put("payerObjId", paramInJson.getString("roomId"));
+        businessUnit.put("userId", dataFlowContext.getRequestCurrentHeaders().get(CommonConstant.HTTP_USER_ID));
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFee", businessUnit);
+
+        return business;
+    }
+
+    /**
+     * 添加物业费用
+     *
+     * @param paramInJson     接口调用放传入入参
+     * @param dataFlowContext 数据上下文
+     * @return 订单服务能够接受的报文
+     */
+    private JSONObject addOwnerPhoto(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_FILE_REL);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ + 2);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject businessUnit = new JSONObject();
+        businessUnit.put("fileRelId", "-1");
+        businessUnit.put("relTypeCd", "10000");
+        businessUnit.put("saveWay", "table");
+        businessUnit.put("objId", paramInJson.getString("memberId"));
+        businessUnit.put("fileRealName", paramInJson.getString("ownerPhotoId"));
+        businessUnit.put("fileSaveName", paramInJson.getString("ownerPhotoId"));
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFileRel", businessUnit);
+
+        return business;
+    }
+
+
+    /**
+     * 数据校验
+     * <p>
+     * name:'',
+     * age:'',
+     * link:'',
+     * sex:'',
+     * remark:''
+     *
+     * @param paramIn "communityId": "7020181217000001",
+     *                "memberId": "3456789",
+     *                "memberTypeCd": "390001200001"
+     */
+    private void validate(String paramIn) {
+        Assert.jsonObjectHaveKey(paramIn, "name", "请求报文中未包含name");
+        Assert.jsonObjectHaveKey(paramIn, "userId", "请求报文中未包含userId");
+        Assert.jsonObjectHaveKey(paramIn, "age", "请求报文中未包含age");
+        Assert.jsonObjectHaveKey(paramIn, "link", "请求报文中未包含link");
+        Assert.jsonObjectHaveKey(paramIn, "sex", "请求报文中未包含sex");
+        Assert.jsonObjectHaveKey(paramIn, "ownerTypeCd", "请求报文中未包含类型");
+        Assert.jsonObjectHaveKey(paramIn, "communityId", "请求报文中未包含communityId");
+        //Assert.jsonObjectHaveKey(paramIn, "idCard", "请求报文中未包含身份证号");
+
+        JSONObject paramObj = JSONObject.parseObject(paramIn);
+
+        if (paramObj.containsKey("roomId")) {
+
+            Assert.jsonObjectHaveKey(paramObj, "state", "请求报文中未包含state节点");
+            Assert.jsonObjectHaveKey(paramObj, "storeId", "请求报文中未包含storeId节点");
+
+            Assert.hasLength(paramObj.getString("roomId"), "roomId不能为空");
+            Assert.hasLength(paramObj.getString("state"), "state不能为空");
+            Assert.hasLength(paramObj.getString("storeId"), "storeId不能为空");
+        }
+    }
+
+
+    @Override
+    public int getOrder() {
+        return 0;
+    }
+
+
+    public IFileInnerServiceSMO getFileInnerServiceSMOImpl() {
+        return fileInnerServiceSMOImpl;
+    }
+
+    public void setFileInnerServiceSMOImpl(IFileInnerServiceSMO fileInnerServiceSMOImpl) {
+        this.fileInnerServiceSMOImpl = fileInnerServiceSMOImpl;
+    }
+}

java110-db/db/UserService/create_owner_app.sql

@@ -1,17 +1,17 @@
 
 -- 单元信息 building 楼宇管理
 CREATE TABLE business_owner_app_user(
-  app_user_id varchar(30) not null comment 'app用户ID'
+  app_user_id VARCHAR(30) NOT NULL COMMENT 'app用户ID',
   member_id VARCHAR(30) NOT NULL COMMENT '业主成员ID',
   b_id VARCHAR(30) NOT NULL COMMENT '业务Id',
   community_id VARCHAR(30) NOT NULL COMMENT '小区Id',
   community_name VARCHAR(100) NOT NULL COMMENT '小区名称',
   app_user_name VARCHAR(100) NOT NULL COMMENT 'app用户名称',
-  id_card varchar(20) NOT NULL COMMENT '身份证号',
-  link varchar(11) NOT NULL COMMENT '联系人手机号',
+  id_card VARCHAR(20) NOT NULL COMMENT '身份证号',
+  link VARCHAR(11) NOT NULL COMMENT '联系人手机号',
   open_id VARCHAR(30) NOT NULL COMMENT 'app 开放ID',
-  app_type_cd varchar(12) not null comment '应用类型 10010 微信小程序',
-  state varchar(12) not null comment '状态类型，10000 审核中，12000 审核成功，13000 审核失败',
+  app_type_cd VARCHAR(12) NOT NULL COMMENT '应用类型 10010 微信小程序',
+  state VARCHAR(12) NOT NULL COMMENT '状态类型，10000 审核中，12000 审核成功，13000 审核失败',
   remark VARCHAR(200) NOT NULL COMMENT '备注',
   create_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
   operate VARCHAR(4) NOT NULL COMMENT '数据状态，添加ADD，修改MOD 删除DEL'
@@ -23,17 +23,17 @@ CREATE INDEX idx_b_owner_app_b_id ON business_owner_app_user(b_id);
 
 
 CREATE TABLE owner_app_user(
-  app_user_id varchar(30) not null comment 'app用户ID'
+  app_user_id VARCHAR(30) NOT NULL COMMENT 'app用户ID',
     member_id VARCHAR(30) NOT NULL COMMENT '业主成员ID',
     b_id VARCHAR(30) NOT NULL COMMENT '业务Id',
     community_id VARCHAR(30) NOT NULL COMMENT '小区Id',
     community_name VARCHAR(100) NOT NULL COMMENT '小区名称',
     app_user_name VARCHAR(100) NOT NULL COMMENT 'app用户名称',
-    id_card varchar(20) NOT NULL COMMENT '身份证号',
-    link varchar(11) NOT NULL COMMENT '联系人手机号',
+    id_card VARCHAR(20) NOT NULL COMMENT '身份证号',
+    link VARCHAR(11) NOT NULL COMMENT '联系人手机号',
     open_id VARCHAR(30) NOT NULL COMMENT 'app 开放ID',
-    app_type_cd varchar(12) not null comment '应用类型 10010 微信小程序',
-    state varchar(12) not null comment '状态类型，10000 审核中，12000 审核成功，13000 审核失败',
+    app_type_cd VARCHAR(12) NOT NULL COMMENT '应用类型 10010 微信小程序',
+    state VARCHAR(12) NOT NULL COMMENT '状态类型，10000 审核中，12000 审核成功，13000 审核失败',
     remark VARCHAR(200) NOT NULL COMMENT '备注',
   create_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
   status_cd VARCHAR(2) NOT NULL DEFAULT '0' COMMENT '数据状态，详细参考c_status表，0, 在用 1失效',

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

@@ -428,6 +428,9 @@ public class ServiceCodeConstant {
     // 保存业主信息
     public static final String SERVICE_CODE_SAVE_OWNER = "owner.saveOwner";
 
+    // App 用户绑定业主接口
+    public static final String SERVICE_CODE_APP_USER_BINDING_OWNER = "owner.appUserBindingOwner";
+
     public static final String SERVICE_CODE_APPLICATION_KEY = "owner.applicationKey";
 
     // 编辑业主信息