提交

CODE/foreign-service/src/main/java/com/community/huiju/dao/TaFaceMapper.java

@@ -0,0 +1,38 @@
+package com.community.huiju.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.community.huiju.model.TaFace;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * <p>
+ * 人脸检测图片 Mapper 接口
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-05-16
+ */
+public interface TaFaceMapper extends BaseMapper<TaFace> {
+
+
+    /**
+     * 查看当前用户信息
+     * @param userVerifyId
+     * @return
+     */
+    TaFace getByUserVerifyId(@Param("userVerifyId") Integer userVerifyId);
+
+    /**
+     * 查看当前信息
+     * @param id
+     * @return
+     */
+    TaFace getById(@Param("id")Integer id);
+
+    /**
+     * 根据审核ID删除人脸信息
+     * @param verifyId
+     */
+    void deleteFace(@Param("verifyId") Integer verifyId);
+
+}

CODE/foreign-service/src/main/java/com/community/huiju/dao/TaUserVerifyMapper.java

@@ -74,4 +74,24 @@ public interface TaUserVerifyMapper extends BaseMapper<TaUserVerify> {
             "where user_id = #{userId} " +
             "and id = #{userVerifyId} ")
     TaUserVerify selectByUserIdAndUserVerifyId(Integer userId, Integer userVerifyId);
+
+    /**
+     * 根据 用户id、小区id 、 期、栋、单元、楼层、户号、审核状态  进行条件查询
+     * @param communityId
+     * @param phaseId
+     * @param buildingId
+     * @param unitId
+     * @param levelId
+     * @param roomNoId
+     * @param verifyStatus
+     * @return
+     */
+    List<TaUserVerify> selectCommunityAndAddressAndVerifyStatus(@Param("userId") Integer userId,
+                                                                @Param("communityId") Integer communityId,
+                                                                @Param("phaseId") Integer phaseId,
+                                                                @Param("buildingId") Integer buildingId,
+                                                                @Param("unitId") Integer unitId,
+                                                                @Param("levelId") Integer levelId,
+                                                                @Param("roomNoId") Integer roomNoId,
+                                                                @Param("verifyStatus") Integer verifyStatus);
 }

CODE/foreign-service/src/main/java/com/community/huiju/dao/TpEquipmentMapper.java

@@ -8,6 +8,8 @@ import org.apache.ibatis.annotations.ResultMap;
 import org.apache.ibatis.annotations.ResultType;
 import org.apache.ibatis.annotations.Select;
 
+import java.util.List;
+
 /**
  * <p>
  * 设备表 Mapper 接口
@@ -34,4 +36,18 @@ public interface TpEquipmentMapper extends BaseMapper<TpEquipment> {
             "tp_equipment tm " +
             "where tm.community_id = #{communityId} and tm.equipment_type = 1")
     IPage<TpEquipment> selectMonitoringByCommunityId(IPage<TpEquipment> page, @Param("communityId") Integer communityId);
+
+    /**
+     * 根据小区 和 单元号 查询所有设备
+     * @param communityId
+     * @param unitId
+     * @return
+     */
+    @ResultType(TpEquipment.class)
+    @Select("select " +
+            "te.* " +
+            "from tp_unit_equipment trne left join tp_equipment te " +
+            "on trne.equipment_id = te.id " +
+            "where trne.community_id=#{communityId} and trne.unit_id=#{unitId} and te.equipment_type=#{equipmentType}")
+    List<TpEquipment> selectByCommunityIdAndUnitId(Integer communityId, Integer unitId, int i);
 }

CODE/foreign-service/src/main/java/com/community/huiju/dao/TpEquipmentTreeMapper.java

@@ -2,6 +2,9 @@ package com.community.huiju.dao;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.community.huiju.model.TpEquipmentTree;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.ResultType;
+import org.apache.ibatis.annotations.Select;
 
 /**
  * <p>
@@ -13,4 +16,12 @@ import com.community.huiju.model.TpEquipmentTree;
  */
 public interface TpEquipmentTreeMapper extends BaseMapper<TpEquipmentTree> {
 
+    /**
+     * 根据小区id 查询
+     * @param communityId
+     * @return
+     */
+    @ResultType(TpEquipmentTree.class)
+    @Select("select * from tp_equipment_tree where community_id = #{communityId}")
+    TpEquipmentTree selectByCommunityId(@Param("communityId") Integer communityId);
 }

CODE/foreign-service/src/main/java/com/community/huiju/enums/ResponseErrorsMessages.java

@@ -22,7 +22,9 @@ public enum ResponseErrorsMessages {
     NO_UNIT(1010, "单元不存在！"),
     NO_LEVEL(1011, "楼层不存在！"),
     NO_ROOM_NO(1012, "户号不存在！"),
-    NOT_USER_VERIFY(1013, "无房产关联关系！")
+    NOT_USER_VERIFY(1013, "无房产关联关系！"),
+    NOT_USER_FACE(1014, "未录入人脸信息！"),
+    NOT_PUSH_FACE(1015, "人脸推送失敗！")
     ;
 
 

CODE/foreign-service/src/main/java/com/community/huiju/model/TaFace.java

@@ -0,0 +1,69 @@
+package com.community.huiju.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.Date;
+
+/**
+ * <p>
+ * 人脸检测图片
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-05-16
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("ta_face")
+public class TaFace implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer faceId;
+
+    /**
+     * 小区id
+     */
+    private Integer communityId;
+
+    /**
+     * 用户审核表id
+     */
+    private Integer taUserVerifyId;
+
+    /**
+     * 上传的图片
+     */
+    private String faceImg;
+
+    /**
+     * 创建人
+     */
+    private Integer createUser;
+
+    /**
+     * 创建时间
+     */
+    private Date createDate;
+
+    /**
+     * 更新人
+     */
+    private Integer updateUser;
+
+    /**
+     * 更新时间
+     */
+    private Date updateDate;
+
+
+}

CODE/foreign-service/src/main/java/com/community/huiju/service/FaceServiceI.java

@@ -0,0 +1,45 @@
+package com.community.huiju.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.community.commom.session.UserElement;
+import com.community.huiju.common.base.ResponseBean;
+import com.community.huiju.model.TaFace;
+import com.community.huiju.model.TaUser;
+import org.springframework.web.multipart.MultipartFile;
+
+public interface FaceServiceI extends IService<TaFace> {
+    /**
+     * 添加人脸
+     * @param userId 用户Id
+     *  @param  uploadFile
+     *  @param userVerifyId 审核id
+     * @return
+     */
+    ResponseBean addFace(Integer userId, Integer userVerifyId, MultipartFile uploadFile);
+
+    /**
+     * 更新当前人脸
+     *  @param userId 用户Id
+     *  @param  uploadFile
+     *  @param userVerifyId 审核id
+     * @return
+     */
+    ResponseBean updateFace(Integer userId, Integer userVerifyId, MultipartFile uploadFile);
+
+    /**
+     * 当前登入人是否有人脸信息
+     * @param userElement
+     * @param otherUserId
+     * @return
+     */
+    ResponseBean getTaFaceByUserId(UserElement userElement, Integer otherUserId);
+
+    /**
+     * 删除人脸
+     * @param userElement
+     * @param otherUserId
+     * @return
+     */
+    ResponseBean deleteFace(UserElement userElement, Integer otherUserId, Integer verifyId);
+}

CODE/foreign-service/src/main/java/com/community/huiju/service/IHKService.java

@@ -0,0 +1,32 @@
+package com.community.huiju.service;
+
+import com.community.commom.mode.ResponseBean;
+
+/**
+ * 海康 业务
+ * @author weiximei
+ */
+public interface IHKService {
+
+    /**
+     * 推送海康人员
+     * @param appUserId
+     * @return
+     */
+    ResponseBean pushPerson(String appUserId, Integer userVerifyId);
+
+    /**
+     * 下发门禁权限
+     * @return
+     */
+    ResponseBean downloadAuthorityByDeviceUuids();
+
+    /**
+     * 异步反控开门 (远程开门)
+     *
+     * @param userVerifyId 审核ID
+     * @return
+     */
+    ResponseBean syncControl(Integer userVerifyId);
+
+}

CODE/foreign-service/src/main/java/com/community/huiju/service/ImageServiceI.java

@@ -0,0 +1,15 @@
+package com.community.huiju.service;
+
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+
+/**
+ * @author admin
+ * @Title: ImageServiceI
+ * @Description: TODO
+ * @date 2018/11/5
+ */
+public interface ImageServiceI {
+    String getImageUrl(MultipartFile uploadFile) throws IOException;
+}

CODE/foreign-service/src/main/java/com/community/huiju/service/impl/FaceServicelimpl.java

@@ -0,0 +1,441 @@
+package com.community.huiju.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.community.commom.ailiyun.AESDecode;
+import com.community.commom.constant.Constant;
+import com.community.commom.hk.HKOpenApi;
+import com.community.commom.session.UserElement;
+import com.community.huiju.common.base.ResponseBean;
+import com.community.huiju.dao.*;
+import com.community.huiju.enums.ResponseErrorsMessages;
+import com.community.huiju.exception.WisdomException;
+import com.community.huiju.model.*;
+import com.community.huiju.service.FaceServiceI;
+import com.community.huiju.service.IHKService;
+import com.community.huiju.service.ImageServiceI;
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Service("faceServicel")
+@Transactional
+@Slf4j
+public class FaceServicelimpl  extends ServiceImpl<TaFaceMapper, TaFace> implements FaceServiceI {
+
+
+    @Autowired
+    private TaFaceMapper taFaceMapper;
+
+    @Autowired
+    private TaUserMapper taUserMapper;
+
+    @Autowired
+    private TaSysRoleMapper taSysRoleMapper;
+
+    @Autowired
+    private ImageServiceI imageServiceI;
+
+    @Autowired
+    private TaUserVerifyMapper taUserVerifyMapper;
+
+    @Autowired
+    private IHKService ihkService;
+
+    @Autowired
+    private TpEquipmentMapper tpEquipmentMapper;
+
+    @Autowired
+    private TpConfigurationMapper tpConfigurationMapper;
+
+    @Autowired
+    private TpEquipmentTreeMapper tpEquipmentTreeMapper;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public ResponseBean addFace(Integer userId, Integer userVerifyId, MultipartFile uploadFile) {
+        ResponseBean responseBean = new ResponseBean();
+        // 判断房产是否存在关联关系
+        TaUserVerify userVerify = taUserVerifyMapper.selectByUserIdAndUserVerifyId(userId, userVerifyId);
+        if (null == userVerify) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER_VERIFY.getCode(), ResponseErrorsMessages.NOT_USER_VERIFY.getMsg());
+            return responseBean;
+        }
+
+        TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(userVerify.getCommunityId());
+
+        // 当前人脸图片url
+        String faceImg = img(uploadFile);
+
+        /**
+         * 删除的时候，将所有的海康设备的关联关系删除了，需要重新下发一次
+         */
+        // 下发门禁
+        ihkService.pushPerson(userId + "", userVerifyId);
+
+        TaUser user = taUserMapper.selectById(userId);
+        TaFace taFace = new TaFace();
+        taFace.setFaceImg(faceImg);
+        taFace.setCommunityId(user.getCommunityId());
+        taFace.setTaUserVerifyId(userVerifyId);
+        taFace.setCreateUser(userId);
+        taFace.setUpdateUser(userId);
+        taFace.setCreateDate(new Date());
+        taFace.setUpdateDate(new Date());
+
+        /*验证身份*/
+        responseBean = addVerify(userId, userVerifyId, uploadFile, faceImg, taFace, tpEquipmentTree);
+        return responseBean;
+    }
+
+    /**
+     * 修改人脸信息
+     *
+     * @param userElement 登入人ID
+     * @param uploadFile
+     * @param otherUserId 关联家属或者租客ID
+     * @return
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public ResponseBean updateFace(Integer userId, Integer userVerifyId, MultipartFile uploadFile) {
+        ResponseBean responseBean = new ResponseBean();
+        // 判断房产是否存在关联关系
+        TaUserVerify userVerify = taUserVerifyMapper.selectByUserIdAndUserVerifyId(userId, userVerifyId);
+        if (null == userVerify) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER_VERIFY.getCode(), ResponseErrorsMessages.NOT_USER_VERIFY.getMsg());
+            return responseBean;
+        }
+
+        TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(userVerify.getCommunityId());
+        // 人脸图片地址url
+        String faceImg = img(uploadFile);
+
+        /**
+         * 删除的时候，将所有的海康设备的关联关系删除了，需要重新下发一次
+         */
+        // 下发门禁
+        ihkService.pushPerson(userId + "", userVerifyId);
+
+        //当前修改的id否存在
+        TaFace face = taFaceMapper.getByUserVerifyId(userVerifyId);
+        if (null == face) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER_FACE.getCode(), ResponseErrorsMessages.NOT_USER_FACE.getMsg());
+            return responseBean;
+        }
+
+        face.setTaUserVerifyId(userVerifyId);
+        face.setFaceImg(faceImg);
+        face.setUpdateUser(userId);
+        face.setUpdateDate(new Date());
+        ResponseBean resps = checKout(faceImg, face, false, uploadFile, userId, userVerify.getCommunityId(), userVerify.getRoomNoId(), userVerify.getUnitId(), tpEquipmentTree.getAppkey(), tpEquipmentTree.getSecret(), tpEquipmentTree.getHttpServer());
+        if (resps.getCode().equals("0")) {
+            resps.addSuccess((Object) faceImg);
+        } else {
+            resps.addError(resps.getMessage());
+        }
+        return resps;
+    }
+
+    /**
+     * 验证图片是否为人脸，推送海康
+     * @param faceImg
+     * @param taFace
+     * @param isA
+     * @param uploadFile
+     * @param userId
+     * @param communityId
+     * @param roomNoId
+     * @param unitId
+     * @param appkey
+     * @param secret
+     * @param openapi_ip_port_http 海康服务器地址
+     * @return
+     */
+    public ResponseBean checKout(String faceImg, TaFace taFace, boolean isA, MultipartFile uploadFile, Integer userId, Integer communityId, Integer roomNoId, Integer unitId, String  appkey, String secret, String openapi_ip_port_http) {
+        ResponseBean responseBean = new ResponseBean();
+        TaUser user = taUserMapper.selectById(userId);
+        if (user.getHkUserId() == null) {
+            log.error("本地库人员ID：{}  的海康人员ID不存在", userId);
+            throw new WisdomException(ResponseErrorsMessages.NOT_PUSH_FACE.getCode(), ResponseErrorsMessages.NOT_PUSH_FACE.getMsg());
+            return responseBean;
+        }
+        AESDecode aesd = new AESDecode();
+        String body = "{\"type\": \"0\", \"image_url\":\"" + faceImg + "\"}";
+        try {
+            com.community.commom.mode.ResponseBean send = aesd.send(body);
+            JSONObject jsonObject = JSONObject.parseObject(send.getMessage());
+            Integer type = (Integer) jsonObject.get("errno");
+            Integer faceNum = (Integer) jsonObject.get("face_num");
+
+            /*推送海康*/
+            String data = HKOpenApi.HKpersonGroupId(uploadFile, user.getHkUserId(), user.getHkPersonNo(), user.getUserName(), user.getHkCardNo(), appkey, secret, openapi_ip_port_http);
+            /*boolean isA为true进行添加，为false进行修改*/
+            if (0 == type && 1 == faceNum) {
+                if (null == data) {
+                    log.error("未得到，海康数据反馈！");
+                    throw new WisdomException(ResponseErrorsMessages.NOT_PUSH_FACE.getCode(), ResponseErrorsMessages.NOT_PUSH_FACE.getMsg());
+                }
+                if (isA) {
+                    taFaceMapper.insert(taFace);
+                } else {
+                    taFaceMapper.updateById(taFace);
+                }
+                responseBean.addSuccess("操作成功");
+
+                // 设备树
+                TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(communityId);
+                // 所有设备
+                List<TpEquipment> tpEquipments = tpEquipmentMapper.selectByCommunityIdAndUnitId(communityId, unitId, 4);
+                List<Map<String, Object>> equipmentUUID = getEquipmentUUID(tpEquipments);
+                StringBuilder doorUuids = new StringBuilder();
+                StringBuilder deviceUuids = new StringBuilder();
+                equipmentUUID.forEach(e-> {
+                    doorUuids.append(e.get("doorUuid"));
+                    doorUuids.append(",");
+                    deviceUuids.append(e.get("deviceUuid"));
+                    deviceUuids.append(",");
+                });
+                Map<String,Object> map = Maps.newHashMap();
+                map.put("appkey", tpEquipmentTree.getAppkey());
+                map.put("opUserUuid", tpEquipmentTree.getOpUserUuid());
+                map.put("personIds", String.valueOf(user.getHkUserId()));
+                map.put("deviceUuids", deviceUuids.substring(0, deviceUuids.lastIndexOf(",")));
+                map.put("type", 1);
+                map.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+                HKOpenApi.downloadFaceAndFingerInfos(map);
+
+                //可视对讲时 指定人员人脸权限下载
+                List<Integer> userIdList = new ArrayList<>();
+                userIdList.add(user.getHkUserId());
+                //临时设备编号
+                // TODO 根据期楼栋号，来查询出门口机
+
+                // 单元门口机
+                List<TpEquipment> visualEquipments = tpEquipmentMapper.selectByCommunityIdAndUnitId(communityId, unitId, 3);
+                List<String> visualList = visualEquipments.stream()
+                        .map(e-> tpConfigurationMapper.selectById(e.getUuidId()).getConfigurationValue())
+                        .collect(Collectors.toList());
+//                List<String> visualList = new ArrayList<>();
+//                visualList.add("10010100000");
+                HKOpenApi.visualIntercom(tpEquipmentTree.getOpUserUuid(), 1, userIdList, visualList, tpEquipmentTree.getAppkey(), tpEquipmentTree.getSecret(), tpEquipmentTree.getHttpServer());
+            } else {
+                responseBean.addError("请录入正确图片");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("海康人脸推送失敗！ {}", e);
+            throw new RuntimeException("海康人脸推送失敗！");
+        }
+        return responseBean;
+    }
+
+    /**
+     * 获取设备UUID
+     * @param equipmentList
+     * @return
+     */
+    private List<Map<String,Object>> getEquipmentUUID(List<TpEquipment> equipmentList) {
+        return equipmentList.stream().map(equipment -> {
+            TpConfiguration tpConfiguration = tpConfigurationMapper.selectById(equipment.getUuidId());
+            Map<String,Object> map = Maps.newHashMap();
+            map.put("doorUuid", tpConfiguration.getDoorUuid());
+            map.put("deviceUuid", tpConfiguration.getDeviceUuid());
+            return map;
+        }).collect(Collectors.toList());
+    }
+
+    /**
+     * 当前登入人是否有人脸信息
+     */
+    @Override
+    public ResponseBean getTaFaceByUserId(UserElement userElement, Integer otherUserId) {
+        ResponseBean responseBean = new ResponseBean();
+        Integer userVerifyId = userElement.getUserVerifyId();
+
+        /**当otherUserId不为空时判断它是否是业主下的租客或者家属*/
+        if (null != otherUserId) {
+            TaUserVerify userVerify = getTaFaceParentId(userElement, otherUserId);
+            userVerifyId = userVerify.getUserVerifyId();
+        }
+        TaFace face = taFaceMapper.getByUserVerifyId(userVerifyId);
+        if (null != face) {
+            responseBean.addSuccess(face);
+            return responseBean;
+        }
+        responseBean.addError("当前用户暂无人脸图片");
+        return responseBean;
+
+    }
+
+    /**
+     * 判断当前用户下的人员关系（家属，租客）
+     */
+    public TaUserVerify getTaFaceParentId(UserElement userElement, Integer otherUserId) {
+        // 根据 家属/租客 的id， 和 当前的房产信息进行查询是否有值，有值就说明是 家属/租客
+        List<TaUserVerify> todUserVerify = taUserVerifyMapper.selectCommunityAndAddressAndVerifyStatus(otherUserId, userElement.getCommunityId(), userElement.getPhaseId(), userElement.getBuildingId(), userElement.getUnitId(), userElement.getLevelId(), userElement.getRoomNoId(), 1);
+        // 判断 家属或者租客 属不属于这个业主的下面
+        if (null == todUserVerify || todUserVerify.size() == 0) {
+            throw new WisdomException("您输入的家属或租户ID有误或审核未通过！");
+        }
+//        if (!Constant.VERIFY_STATUS.equals(todUserVerify.get(0).getVerifyStatus())) {
+//            throw new WisdomException("用户房产审核未通过！");
+//        }
+
+        return todUserVerify.get(0);
+    }
+
+    /**
+     * 得到当前图片
+     */
+    private String img(MultipartFile uploadFile) {
+        String faceImg = null;
+        try {
+            faceImg = imageServiceI.getImageUrl(uploadFile);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return faceImg;
+    }
+
+    /**
+     * 各种身份校验
+     */
+    public ResponseBean addVerify(Integer userid, Integer userVerifyId, MultipartFile uploadFile, String faceImg, TaFace taFace, TpEquipmentTree tpEquipmentTree) {
+        ResponseBean response = new ResponseBean();
+
+        TaUserVerify userVerify = taUserVerifyMapper.selectById(userVerifyId);
+        if (null == userVerify) {
+            response.addError("当前房产审核记录不存在！");
+            return response;
+        }
+        TaUser taUser = taUserMapper.selectById(userid);
+
+        //身份为家属租客，状态为已停用
+        if (null != taUser && !Constant.EFFECTIVE_STATUS.equals(taUser.getStatus())) {
+            response.addError("9996", "您的身份已停用，请联系物业");
+            return response;
+        }
+
+        //查询当前用户是否有人脸记录
+        TaFace face = taFaceMapper.getByUserVerifyId(userVerifyId);
+        if (null == face) {
+            boolean isA = true;
+            if (Constant.EFFECTIVE_STATUS.equals(taUser.getStatus())) {
+                ResponseBean responseBean = checKout(faceImg, taFace, isA, uploadFile, userid, userVerify.getCommunityId(), userVerify.getRoomNoId(), userVerify.getUnitId(),tpEquipmentTree.getAppkey(), tpEquipmentTree.getSecret(), tpEquipmentTree.getHttpServer());
+                if (responseBean.getCode().equals("0")) {
+                    responseBean.addSuccess("图片录入成功");
+                } else {
+                    responseBean.addError(responseBean.getMessage());
+                }
+                return responseBean;
+            }
+        }
+        response.addError("您的信息已存在");
+        return response;
+    }
+
+    @Override
+    public ResponseBean deleteFace(UserElement userElement, Integer otherUserId, Integer verifyId) {
+        ResponseBean responseBean= new ResponseBean();
+        TaUserVerify taUserVerify= infoExist(userElement.getUserVerifyId());
+        if (null ==taUserVerify) {
+            responseBean.addError("房产审核未通过");
+            return responseBean;
+        }
+            TaUser taUser = taUserMapper.selectById(taUserVerify.getUserId());
+
+        // 设备树
+        TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(taUserVerify.getCommunityId());
+        // 所有设备
+        List<TpEquipment> tpEquipments = tpEquipmentMapper.selectByCommunityIdAndUnitId(taUserVerify.getCommunityId(), taUserVerify.getUnitId(), 4);
+        List<Map<String, Object>> equipmentUUID = getEquipmentUUID(tpEquipments);
+        StringBuilder doorUuids = new StringBuilder();
+        StringBuilder deviceUuids = new StringBuilder();
+        equipmentUUID.forEach(e-> {
+            doorUuids.append(e.get("doorUuid"));
+            doorUuids.append(",");
+            deviceUuids.append(e.get("deviceUuid"));
+            deviceUuids.append(",");
+        });
+
+
+        // TODO 删除人脸，是否删除海康
+        // 修改人脸(图片为null时。海康删除人脸)
+//        HKOpenApi.HKpersonGroupId(null, taUser.getHkUserId(), taUser.getHkPersonNo(), taUser.getUserName(), taUser.getHkCardNo(), tpEquipmentTree.getAppkey(), tpEquipmentTree.getSecret());
+        // 删除 权限
+        Map<String,Object> selectUserFaceMap = Maps.newHashMap();
+        selectUserFaceMap.put("personIds", taUser.getHkUserId()+"");
+        selectUserFaceMap.put("opUserUuid", tpEquipmentTree.getOpUserUuid());
+        selectUserFaceMap.put("appkey", tpEquipmentTree.getAppkey());
+        selectUserFaceMap.put("secret", tpEquipmentTree.getSecret());
+        selectUserFaceMap.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        // 查询人脸信息
+        HKOpenApi.selectUserFace(selectUserFaceMap);
+
+        Map<String,Object> deleteUserMap = Maps.newHashMap();
+        deleteUserMap.put("personIds", taUser.getHkUserId()+"");
+        deleteUserMap.put("opUserUuid", tpEquipmentTree.getOpUserUuid());
+        deleteUserMap.put("doorUuids", doorUuids.substring(0, doorUuids.lastIndexOf(",")));
+        deleteUserMap.put("appkey", tpEquipmentTree.getAppkey());
+        deleteUserMap.put("secret", tpEquipmentTree.getSecret());
+        deleteUserMap.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        // 删除当前人脸设备信息
+        String data= HKOpenApi.deleteUser(deleteUserMap);
+        JSONObject object= JSONObject.parseObject(data);
+
+        if (object.get("errorCode").equals(1)){
+            String errorMessage=  object.getString("errorMessage");
+            responseBean.addError(errorMessage);
+            return responseBean;
+        }
+        Integer activeUser = otherUserId == null ? userElement.getUserVerifyId() : otherUserId;
+        taFaceMapper.deleteFace(activeUser);
+        // 异动同步到设备
+        Map<String,Object> appointJurisdictionMap = Maps.newHashMap();
+        appointJurisdictionMap.put("appkey", tpEquipmentTree.getAppkey());
+        appointJurisdictionMap.put("secret", tpEquipmentTree.getSecret());
+        appointJurisdictionMap.put("opUserUuid", tpEquipmentTree.getOpUserUuid());
+        appointJurisdictionMap.put("personIds", taUser.getHkUserId()+"" );
+        appointJurisdictionMap.put("doorUuids", doorUuids.substring(0, doorUuids.lastIndexOf(",")));
+        appointJurisdictionMap.put("operateType",3);
+        appointJurisdictionMap.put("includeFinger",0);
+        appointJurisdictionMap.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+
+         HKOpenApi.appointJurisdiction(appointJurisdictionMap);
+        // HKOpenApi.selectUserSynchronization();
+        // ihkService.downloadAuthorityByDeviceUuids();
+        return responseBean;
+
+    }
+
+    /*校验房产是否审核通过*/
+    public TaUserVerify infoExist(Integer verifyID){
+        /*查询当前的房产ID*/
+        TaUserVerify taUserVerify = null;
+      if (!"".equals(verifyID)) {
+        taUserVerify = taUserVerifyMapper.selectById(verifyID);
+      }
+      if (null!= taUserVerify && taUserVerify.getVerifyStatus().equals("1")) {
+          return taUserVerify;
+      }
+      return  null;
+    }
+}
+
+

CODE/foreign-service/src/main/java/com/community/huiju/service/impl/HKServiceImpl.java

@@ -0,0 +1,365 @@
+package com.community.huiju.service.impl;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.community.commom.constant.Constant;
+import com.community.commom.hk.HKOpenApi;
+import com.community.commom.mode.ResponseBean;
+import com.community.commom.uuid.IdGen;
+import com.community.huiju.dao.*;
+import com.community.huiju.exception.WisdomException;
+import com.community.huiju.model.*;
+import com.community.huiju.service.IHKService;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.time.LocalDate;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 海康 业务实现
+ * @author weiximei
+ */
+@Service
+@Slf4j
+public class HKServiceImpl implements IHKService {
+
+    @Autowired
+    private TaUserMapper taUserMapper;
+
+    private IdGen idGen = IdGen.get();
+
+    @Autowired
+    private TpEquipmentMapper tpEquipmentMapper;
+
+    @Autowired
+    private TpConfigurationMapper tpConfigurationMapper;
+
+    @Autowired
+    private TpEquipmentTreeMapper tpEquipmentTreeMapper;
+
+    @Autowired
+    private TaUserVerifyMapper taUserVerifyMapper;
+
+    /**
+     * 获取设备UUID
+     * @param equipmentList
+     * @return
+     */
+    private List<Map<String,Object>> getEquipmentUUID(List<TpEquipment> equipmentList) {
+        return equipmentList.stream().map(equipment -> {
+            TpConfiguration tpConfiguration = tpConfigurationMapper.selectById(equipment.getUuidId());
+            Map<String,Object> map = Maps.newHashMap();
+            map.put("doorUuid", tpConfiguration.getDoorUuid());
+            map.put("deviceUuid", tpConfiguration.getDeviceUuid());
+            return map;
+        }).collect(Collectors.toList());
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public ResponseBean pushPerson(String appUserId, Integer userVerifyId) {
+        ResponseBean responseBean = new ResponseBean();
+        TaUser user = taUserMapper.selectById(Integer.parseInt(appUserId));
+
+        TaUserVerify userVerify = taUserVerifyMapper.selectById(userVerifyId);
+        if (null == userVerify) {
+            throw new WisdomException("审核数据不存在！");
+        }
+        TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(userVerify.getCommunityId());
+
+        // 这两个值一般都是同时存在的
+        // 当这两个值不存在的时候，就添加海康人员
+        if (null == user.getHkUserId() && null == user.getHkPersonNo()) {
+            // 设置 海康id
+            user.setHkPersonNo(idGen.nextId());
+            /**
+             * 1.获取部门(比如 住户)
+             * 2.根据部门编号推送 海康
+             */
+            taUserMapper.updateById(user);
+            addUserAndOpenCard(responseBean, user, tpEquipmentTree);
+        }
+
+
+        // 推送海康
+
+        // 给用户添加 海康门禁权限
+
+        List<TpEquipment> tpEquipments = tpEquipmentMapper.selectByCommunityIdAndUnitId(userVerify.getCommunityId(), userVerify.getUnitId(), 4);
+        List<Map<String, Object>> equipmentUUID = getEquipmentUUID(tpEquipments);
+        StringBuilder doorUuids = new StringBuilder();
+        StringBuilder deviceUuids = new StringBuilder();
+        equipmentUUID.forEach(e-> {
+            doorUuids.append(e.get("doorUuid"));
+            doorUuids.append(",");
+            deviceUuids.append(e.get("deviceUuid"));
+            deviceUuids.append(",");
+        });
+
+        Map<String, Object> map = Maps.newHashMap();
+        map.put("personIds",String.valueOf(user.getHkUserId()));
+        map.put("doorUuids", doorUuids.substring(0, doorUuids.lastIndexOf(",")));
+        map.put("secret", tpEquipmentTree.getSecret());
+        map.put("appkey", tpEquipmentTree.getAppkey());
+        map.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        HKOpenApi.addAuthoritiesByPersonIds(map);
+
+        // 下发门禁权限
+        Map<String, Object> downloadAuthorityByPersonIdsMap = Maps.newHashMap();
+        downloadAuthorityByPersonIdsMap.put("personIds",String.valueOf(user.getHkUserId()));
+        downloadAuthorityByPersonIdsMap.put("doorUuids", doorUuids.substring(0, doorUuids.lastIndexOf(",")));
+        downloadAuthorityByPersonIdsMap.put("operateType",1);
+        downloadAuthorityByPersonIdsMap.put("includeFinger",1);
+        downloadAuthorityByPersonIdsMap.put("secret", tpEquipmentTree.getSecret());
+        downloadAuthorityByPersonIdsMap.put("appkey", tpEquipmentTree.getAppkey());
+        downloadAuthorityByPersonIdsMap.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        HKOpenApi.downloadAuthorityByPersonIds(downloadAuthorityByPersonIdsMap);
+
+        //--------- 可视对讲 ----------
+
+        Map<String,Object> addOutDoorAuthMap = Maps.newHashMap();
+        addOutDoorAuthMap.put("authName", "荟居");
+        addOutDoorAuthMap.put("personIds", Arrays.asList(user.getHkUserId()));
+        addOutDoorAuthMap.put("secret", tpEquipmentTree.getSecret());
+        addOutDoorAuthMap.put("appkey", tpEquipmentTree.getAppkey());
+
+        // 单元门口机
+        List<TpEquipment> visualEquipments = tpEquipmentMapper.selectByCommunityIdAndUnitId(userVerify.getCommunityId(), userVerify.getUnitId(), 3);
+        List<String> visualList = visualEquipments.stream()
+                .map(e-> tpConfigurationMapper.selectById(e.getUuidId()).getConfigurationValue())
+                .collect(Collectors.toList());
+//        List<String> visualList = new ArrayList<>();
+//        visualList.add("10010100000");
+        addOutDoorAuthMap.put("longNums", visualList);
+        // 可视对讲下发 权限
+        visualIntercomPermissions(addOutDoorAuthMap);
+        if ("0".equals(responseBean.getCode())) {
+            responseBean.addSuccess("操作成功！");
+            return responseBean;
+        }
+        throw new WisdomException("操作失败!");
+    }
+
+    @Override
+    @Deprecated
+    public ResponseBean downloadAuthorityByDeviceUuids() {
+        ResponseBean responseBean = new ResponseBean();
+        // 下发门禁权限
+        HKOpenApi.downloadAuthorityByDeviceUuids(Maps.newHashMap());
+        responseBean.addSuccess("操作成功！");
+        return responseBean;
+    }
+
+    /**
+     * 公共方法
+     * 添加人员, 开卡
+     *
+     * @param response
+     * @param user
+     */
+    private void addUserAndOpenCard(ResponseBean response, TaUser user, TpEquipmentTree tpEquipmentTree) {
+        Map<String, Object> parDept = Maps.newHashMap();
+        parDept.put("pageNo", 1);
+        parDept.put("pageSize", 100);
+        parDept.put("deptName", Constant.DEPT_RESIDENTS);
+        parDept.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        // 部门UUID
+        String deptUuid = getDeptUUID(parDept);
+
+        // 添加人员
+        Map<String, Object> parUser = Maps.newHashMap();
+        parUser.put("personNo", user.getHkPersonNo());
+        parUser.put("personName", user.getUserName());
+        parUser.put("phoneNo", user.getLoginName());
+        parUser.put("deptUuid", deptUuid);
+        parUser.put("secret", tpEquipmentTree.getSecret());
+        parUser.put("appkey", tpEquipmentTree.getAppkey());
+        parUser.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        Map<String, Object> resultMap = JSONObject.parseObject(HKOpenApi.addUser(parUser), HashMap.class);
+        int errorCode = (int) resultMap.get("errorCode");
+        if (errorCode == 0) {
+            Map<String, Object> resultDataMap = (Map<String, Object>) resultMap.get("data");
+            // 开卡 卡号
+            long cardNo = System.currentTimeMillis();
+            // 海康人员ID
+            Integer personId = (Integer) resultDataMap.get("personId");
+            TaUser tempUser = taUserMapper.selectById(user.getUserId());
+            tempUser.setHkUserId(personId);
+            tempUser.setHkCardNo(cardNo + "");
+
+            user.setHkUserId(personId);
+            // 存储海康人员ID
+            int row = taUserMapper.updateById(tempUser);
+            if (row > 0) {
+                response.addSuccess("操作成功!");
+            } else {
+                response.addError("操作失败");
+                throw new RuntimeException("数据库添加 家属/租客 人员失败!");
+            }
+
+            // 开卡
+            List<String> cardAndPersonList = Lists.newArrayList();
+            cardAndPersonList.add(cardNo + "," + personId);
+            response = openCard(cardAndPersonList, null, tpEquipmentTree);
+        } else {
+            String errorMessage = String.valueOf(resultMap.get("errorMessage"));
+            response.addError(errorMessage);
+            log.error("海康添加人员失败! {}", errorMessage);
+            throw new RuntimeException(errorMessage);
+        }
+    }
+
+    /**
+     * 批量开卡
+     *
+     * @param cardIdAndHKUserID list.add("卡号,人员ID")
+     * @param expirationTime    有效期为多少? 单位为 年
+     * @return
+     */
+    private ResponseBean openCard(List<String> cardIdAndHKUserID, Integer expirationTime, TpEquipmentTree tpEquipmentTree) {
+        ResponseBean response = new ResponseBean();
+
+        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
+        LocalDate today = LocalDate.now();
+        int year = today.getYear();
+        // 加上20, 表示加上20年,默认
+        if (null == expirationTime || expirationTime <= 0) {
+            year += 20;
+        } else {
+            year += expirationTime;
+        }
+        int month = today.getMonthValue();
+        int day = today.getDayOfMonth();
+
+        Long time = null;
+        try {
+            time = formatter.parse(year + "-" + month + "-" + day).getTime();
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+
+        // 开卡
+        Map<String, Object> parOpenCard = Maps.newHashMap();
+        parOpenCard.put("cardAndPerson", cardIdAndHKUserID);
+        parOpenCard.put("startTime", System.currentTimeMillis());
+        parOpenCard.put("endTime", time);
+        parOpenCard.put("secret", tpEquipmentTree.getSecret());
+        parOpenCard.put("appkey", tpEquipmentTree.getAppkey());
+        parOpenCard.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        JSONObject openCardJSON = JSONObject.parseObject(HKOpenApi.openCard(parOpenCard));
+        int code = (int) openCardJSON.get("errorCode");
+        if (code == 0) {
+            response.addSuccess("操作成功!");
+        } else {
+            String errorMessage = String.valueOf(openCardJSON.get("errorMessage"));
+            response.addError(errorMessage);
+            log.error("开卡失败! {}", errorMessage);
+            throw new RuntimeException(errorMessage);
+        }
+
+        return response;
+    }
+
+    /**
+     * 获取部门 uuid
+     * <p>
+     * 这里的部门相当于 小区
+     *
+     * @return
+     */
+    private String getDeptUUID(Map<String, Object> parDept) {
+        Map<String, Object> deptMap = JSONObject.parseObject(HKOpenApi.getDeptName(parDept), HashMap.class);
+        Map<String, Object> deptDataMap = (Map<String, Object>) deptMap.get("data");
+        JSONArray jsonArray = (JSONArray) deptDataMap.get("list");
+        Map<String, Object> deptListData = (Map<String, Object>) jsonArray.get(0);
+        // 部门UUID
+        String deptUuid = (String) deptListData.get("deptUuid");
+        return deptUuid;
+    }
+
+    /**
+     * 可视对讲下发 权限
+     *
+     * @param map
+     */
+    private void visualIntercomPermissions(Map<String,Object> map) {
+        // TODO 目前下发的 authName权限组是我们自定义的, 后面肯定是按照小区的 期楼栋号来设置的
+        // TODO longNums设备编号, 可视对讲的机器编号, 应该根据 期楼栋号 下面的机器编号来设置的
+
+        //--------- 可视对讲 ----------
+
+        // 可视对讲 根据人员 ID 集添加权限并下发
+        HKOpenApi.addOutDoorAuth(map);
+
+    }
+
+    /**
+     * 可视对讲 指定人员指纹权限下载
+     * @param map
+     */
+    private void visualIntercomFingerprint(Map<String,Object> map) {
+        // 可视对讲 指定人员指纹权限下载
+        Map<String, Object> downloadFingerMap = new HashMap<>();
+        // opType 操作类型 Integer 是 1 为下发权限；2 为删除权限
+        downloadFingerMap.put("opType", 1);
+        downloadFingerMap.put("personIds", map.get("personIds"));
+        downloadFingerMap.put("longNums", map.get("longNums"));
+        downloadFingerMap.put("openapi_ip_port_http", map.get("openapi_ip_port_http"));
+        // 可视对讲 指定人员指纹权限下载
+        HKOpenApi.downloadFinger(downloadFingerMap);
+    }
+
+    @Override
+    public ResponseBean syncControl(Integer userVerifyId) {
+        // TODO 暂时只支持开单元门
+
+        ResponseBean responseBean = new ResponseBean();
+
+        // 查询当前的房产
+        TaUserVerify userVerify = taUserVerifyMapper.selectById(userVerifyId);
+        TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(userVerify.getCommunityId());
+        // 单元门口机
+        List<TpEquipment> tpEquipments = tpEquipmentMapper.selectByCommunityIdAndUnitId(userVerify.getCommunityId(), userVerify.getUnitId(), 3);
+
+         if (CollectionUtils.isEmpty(tpEquipments)) {
+             responseBean.addError("无设备信息!");
+             return responseBean;
+         }
+
+         String str = "";
+         for (TpEquipment e : tpEquipments) {
+             TpConfiguration tpConfiguration = tpConfigurationMapper.selectById(e.getUuidId());
+             str += tpConfiguration.getConfigurationValue();
+             str += ",";
+         }
+
+        // 查询设备编号
+
+        Map<String,Object> parMap = com.beust.jcommander.internal.Maps.newHashMap();
+        parMap.put("longNums", str);
+        parMap.put("openapi_ip_port_http", tpEquipmentTree.getHttpServer());
+        parMap.put("secret", tpEquipmentTree.getSecret());
+        parMap.put("appkey", tpEquipmentTree.getAppkey());
+        String data = HKOpenApi.syncControl(parMap);
+        JSONObject jsonObject = JSONObject.parseObject(data);
+        int errorCode = jsonObject.getInteger("errorCode");
+        if (errorCode == 0) {
+            responseBean.addSuccess("操作成功!");
+            return responseBean;
+        }
+        responseBean.addError("操作失败!");
+        return responseBean;
+    }
+}

CODE/foreign-service/src/main/java/com/community/huiju/service/impl/ImageServiceimpl.java

@@ -0,0 +1,46 @@
+package com.community.huiju.service.impl;
+
+import com.aliyun.oss.OSSClient;
+import com.community.huiju.service.ImageServiceI;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.util.Date;
+
+/**
+ * @author weichaochao
+ * @Title: ImageServiceimpl
+ * @Description: 获取图片地址实现类
+ * @date 2018/11/5
+ */
+@Service("ImageService")
+public class ImageServiceimpl implements ImageServiceI {
+
+    private static String endpoint = "http://oss-cn-shanghai.aliyuncs.com";
+    private static String accessKeyId = "LTAIkc75dpkJw8Lb";
+    private static String accessKeySecret = "v4bvXCaix6vSDTCFfwSAdqV53iFEQw";
+    private static String bucketName = "jingcheng-h5temp";
+
+    @Override
+    public String getImageUrl(MultipartFile uploadFile) throws IOException {
+
+        String imgName = System.currentTimeMillis() + ".png";
+        // 创建OSSClient实例
+        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
+        // 上传
+        long time = System.currentTimeMillis();
+
+        ossClient.putObject(bucketName, imgName, new ByteArrayInputStream(uploadFile.getBytes()));
+
+        // 关闭client
+        ossClient.shutdown();
+        Date expiration = new Date(time + 3600 * 1000 * 24 * 365 * 10);
+        String url = ossClient.generatePresignedUrl(bucketName, imgName, expiration).toString();
+
+        // 截取掉签名
+        url = url.substring(0, url.lastIndexOf("&Signature"));
+        return url;
+    }
+}

CODE/foreign-service/src/main/resources/application.yml

@@ -18,6 +18,7 @@ mybatis-plus:
   mapper-locations: classpath:mapper/*.xml
   configuration:
     call-setters-on-nulls: true
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #打印sql语句,调试用
 
 # 打印sql
 logging:

CODE/foreign-service/src/main/resources/mapper/TaFaceMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.community.huiju.dao.TaFaceMapper">
+
+</mapper>

CODE/foreign-service/src/main/resources/mapper/TaSysRoleMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.community.huiju.dao.TaSysRoleMapper">
+
+</mapper>

CODE/foreign-service/src/main/resources/mapper/TaUserVerifyMapper.xml

@@ -2,4 +2,21 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.community.huiju.dao.TaUserVerifyMapper">
 
+    <select id="selectCommunityAndAddressAndVerifyStatus" resultType="com.community.huiju.model.TaUserVerify">
+        select
+        <include refid="Base_Column_List"/>
+        from ta_user_verify
+        where community_id = #{communityId,jdbcType=INTEGER}
+        and user_id = #{userId,jdbcType=INTEGER}
+        and phase_id = #{phaseId,jdbcType=INTEGER}
+        and building_id = #{buildingId,jdbcType=INTEGER}
+        and unit_id = #{unitId,jdbcType=INTEGER}
+        and level_id = #{levelId,jdbcType=INTEGER}
+        and room_no_id = #{roomNoId,jdbcType=INTEGER}
+        <if test="verifyStatus != null and verifyStatus != ''">
+            and verify_status = #{verifyStatus}
+        </if>
+    </select>
+
+
 </mapper>

CODE/foreign-service/src/main/resources/mapper/TpBuildingMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.community.huiju.dao.TpBuildingMapper">
+
+</mapper>

CODE/smart-community/app-api/src/main/resources/mapper/TpHotelMapper.xml

@@ -192,7 +192,7 @@
   </select>
   
   <select id="hotelSetting" resultType="string">
-    select id from tp_hotel_setting where  community_id = #{communityId};
+    select id from tp_hotel_setting where  community_id = #{communityId}
   </select>
 
 </mapper>