优化代码

service-user/src/main/java/com/java110/user/cmd/owner/QueryOwnerAndMembersCmd.java

@@ -0,0 +1,268 @@
+package com.java110.user.cmd.owner;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.CmdContextUtils;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.doc.annotation.*;
+import com.java110.dto.file.FileRelDto;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.dto.privilege.BasePrivilegeDto;
+import com.java110.dto.room.RoomDto;
+import com.java110.intf.common.IFileRelInnerServiceSMO;
+import com.java110.intf.community.IMenuInnerServiceSMO;
+import com.java110.intf.community.IRoomInnerServiceSMO;
+import com.java110.intf.user.IOwnerInnerServiceSMO;
+import com.java110.user.bmo.owner.IQueryOwnerStatisticsBMO;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.StringUtil;
+import com.java110.vo.ResultVo;
+import com.java110.vo.api.ApiOwnerDataVo;
+import com.java110.vo.api.ApiOwnerVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@Java110CmdDoc(title = "查询业主和成员",
+        description = "第三方系统，比如招商系统查询业主和成员信息",
+        httpMethod = "get",
+        url = "http://{ip}:{port}/app/owner.queryOwnerAndMembers",
+        resource = "userDoc",
+        author = "吴学文",
+        serviceCode = "owner.queryOwnerAndMembers",
+        seq = 12
+)
+
+@Java110ParamsDoc(params = {
+        @Java110ParamDoc(name = "page", type = "int", length = 11, remark = "页数"),
+        @Java110ParamDoc(name = "row", type = "int", length = 11, remark = "行数"),
+        @Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"),
+        @Java110ParamDoc(name = "name", length = 64, remark = "业主名称"),
+        @Java110ParamDoc(name = "link", length = 11, remark = "业主手机号"),
+        @Java110ParamDoc(name = "roomName", length = 30, remark = "房屋编号 例如 1-1-1001"),
+})
+
+@Java110ResponseDoc(
+        params = {
+                @Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"),
+                @Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"),
+                @Java110ParamDoc(name = "owners", type = "Array", length = -1, defaultValue = "成功", remark = "数据"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "communityId", length = 30, remark = "小区ID"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "name", length = 64, remark = "业主名称"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "link", length = 11, remark = "业主手机号"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "idCard", length = 30, remark = "业主身份证号"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "address", length = 512, remark = "地址"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "sex", length = 12, remark = "性别 男 1 女 0"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "ownerTypeCd", length = 12, remark = "业主类型 1001 业主 2002 家庭成员 家庭成员 需要传业主的ownerId"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "remark", length = 512, remark = "备注"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "memberId", length = 30, remark = "业主ID"),
+                @Java110ParamDoc(parentNodeName = "owners", name = "ownerPhoto", length = -1, remark = "业主人脸 用于同步门禁 人脸开门"),
+        }
+)
+
+@Java110ExampleDoc(
+        reqBody = "http://ip:port/app/owner.queryOwnerAndMembers?page=1&row=10&communityId=2022121921870161",
+        resBody = "{\n" +
+                "\t\"owners\": [{\n" +
+                "\t\t\"address\": \"张三\",\n" +
+                "\t\t\"idCard\": \"\",\n" +
+                "\t\t\"link\": \"18909718888\",\n" +
+                "\t\t\"memberId\": \"772023012589770046\",\n" +
+                "\t\t\"name\": \"王王\",\n" +
+                "\t\t\"ownerId\": \"772023012589770046\",\n" +
+                "\t\t\"ownerTypeCd\": \"1001\",\n" +
+                "\t\t\"remark\": \"\",\n" +
+                "\t\t\"sex\": \"0\",\n" +
+                "\t\t\"userName\": \"人和物业\"\n" +
+                "\t}],\n" +
+                "\t\"page\": 0,\n" +
+                "\t\"records\": 1,\n" +
+                "\t\"rows\": 0,\n" +
+                "\t\"total\": 1\n" +
+                "}"
+)
+@Java110Cmd(serviceCode = "owner.queryOwnerAndMembers")
+public class QueryOwnerAndMembersCmd extends Cmd {
+
+    @Autowired
+    private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
+
+    @Autowired
+    private IMenuInnerServiceSMO menuInnerServiceSMOImpl;
+
+    @Autowired
+    private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
+
+    @Autowired
+    private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
+
+    @Autowired
+    private IQueryOwnerStatisticsBMO queryOwnerStatisticsBMOImpl;
+
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+        Assert.hasKeyAndValue(reqJson, "page", "请求中未包含page信息");
+        Assert.hasKeyAndValue(reqJson, "row", "请求中未包含row信息");
+        Assert.hasKeyAndValue(reqJson, "communityId", "请求中未包含communityId信息");
+
+
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+
+        String userId = CmdContextUtils.getUserId(cmdDataFlowContext);
+
+        //todo 根据房屋查询时 先用 房屋信息查询 业主ID
+        freshRoomId(reqJson);
+
+        OwnerDto ownerDto = BeanConvertUtil.covertBean(reqJson, OwnerDto.class);
+
+        int row = reqJson.getInteger("row");
+        //todo 查询总记录数
+        int total = ownerInnerServiceSMOImpl.queryOwnersMemberCount(ownerDto);
+        List<OwnerDto> ownerDtos = null;
+        if (total > 0) {
+            ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto);
+        } else {
+            ownerDtos = new ArrayList<>();
+        }
+
+        // todo 清洗数据
+        cleanOwnerData(ownerDtos, userId);
+
+        // todo 刷入房号
+        freshRoomName(ownerDtos);
+
+
+        ResponseEntity<String> responseEntity = ResultVo.createResponseEntity((int) Math.ceil((double) total / (double) row), total, ownerDtos);
+        cmdDataFlowContext.setResponseEntity(responseEntity);
+    }
+
+    /**
+     * 刷入业主房屋
+     *
+     * @param ownerDtos
+     */
+    private void freshRoomName(List<OwnerDto> ownerDtos) {
+
+        if (ownerDtos == null || ownerDtos.size() < 1 || ownerDtos.size() > 10) {
+            return;
+        }
+        RoomDto roomDto = null;
+        List<RoomDto> roomDtos = null;
+        String roomName = "";
+        for (OwnerDto tmpOwnerDto : ownerDtos) {
+
+            roomDto = new RoomDto();
+            roomDto.setOwnerId(tmpOwnerDto.getOwnerId());
+            roomDto.setStatusCd("0");
+
+            roomDtos = roomInnerServiceSMOImpl.queryRoomsByOwner(roomDto);
+
+            if (roomDtos == null || roomDtos.size() < 1) {
+                continue;
+            }
+            roomName = "";
+            for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) {
+                if (roomIndex > 2) {
+                    break;
+                }
+                RoomDto tmpRoomDto = roomDtos.get(roomIndex);
+                roomName += (tmpRoomDto.getFloorNum() + "-" + tmpRoomDto.getUnitNum() + "-" + tmpRoomDto.getRoomNum());
+            }
+
+            tmpOwnerDto.setRoomName(roomName);
+        }
+    }
+
+    /**
+     * 清洗数据
+     *
+     * @param ownerDtos
+     * @param userId
+     */
+    private void cleanOwnerData(List<OwnerDto> ownerDtos, String userId) {
+
+        //todo 查询脱敏权限
+        List<Map> mark = getPrivilegeOwnerList("/roomCreateFee", userId);
+
+        for (OwnerDto tmpOwnerDto : ownerDtos) {
+            String idCard = tmpOwnerDto.getIdCard();
+            if (mark.size() == 0 && idCard != null && !idCard.equals("") && idCard.length() > 16) {
+                idCard = idCard.substring(0, 6) + "**********" + idCard.substring(16);
+                tmpOwnerDto.setIdCard(idCard);
+            }
+            //对业主手机号隐藏处理
+            String link = tmpOwnerDto.getLink();
+            if (mark.size() == 0 && link != null && !link.equals("") && link.length() == 11) {
+                link = link.substring(0, 3) + "****" + link.substring(7);
+                tmpOwnerDto.setLink(link);
+            }
+        }
+        for (OwnerDto tmpOwnerDto : ownerDtos) {
+            //查询照片
+            FileRelDto fileRelDto = new FileRelDto();
+            fileRelDto.setObjId(tmpOwnerDto.getMemberId());
+            fileRelDto.setRelTypeCd("10000"); //业主照片
+            List<FileRelDto> fileRelDtos = fileRelInnerServiceSMOImpl.queryFileRels(fileRelDto);
+            if (fileRelDtos == null || fileRelDtos.size() < 1) {
+                continue;
+            }
+            List<String> urls = new ArrayList<>();
+            for (FileRelDto fileRel : fileRelDtos) {
+                urls.add(fileRel.getFileRealName());
+            }
+            tmpOwnerDto.setUrls(urls);
+        }
+    }
+
+
+    private void freshRoomId(JSONObject reqJson) {
+        if (!reqJson.containsKey("roomName")) {
+            return;
+        }
+        String roomName = reqJson.getString("roomName");
+        if (StringUtil.isEmpty(roomName)) {
+            return;
+        }
+        if (!roomName.contains("-")) {
+            throw new IllegalArgumentException("房屋格式错误,请写入如 楼栋-单元-房屋 格式");
+        }
+        String[] params = roomName.split("-", 3);
+        if (params.length != 3) {
+            throw new IllegalArgumentException("房屋格式错误,请写入如 楼栋-单元-房屋 格式");
+        }
+        RoomDto roomDto = new RoomDto();
+        roomDto.setFloorNum(params[0]);
+        roomDto.setUnitNum(params[1]);
+        roomDto.setRoomNum(params[2]);
+        roomDto.setCommunityId(reqJson.getString("communityId"));
+        List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
+        Assert.listOnlyOne(roomDtos, "未查询到房屋下业主信息");
+        reqJson.put("roomId", roomDtos.get(0).getRoomId());
+    }
+
+
+    /**
+     * 脱敏处理
+     *
+     * @return
+     */
+    public List<Map> getPrivilegeOwnerList(String resource, String userId) {
+        BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto();
+        basePrivilegeDto.setResource(resource);
+        basePrivilegeDto.setUserId(userId);
+        List<Map> privileges = menuInnerServiceSMOImpl.checkUserHasResource(basePrivilegeDto);
+        return privileges;
+    }
+}