完成 人员添加,获取部们,开卡

CODE/smart-community/app-api/src/main/java/com/community/huiju/common/hk/HKConstant.java

      */
     public static final String ITF_ADD_USER = "/openapi/service/base/person/addPersonInfo";
 
+    /**
+     * 批量开卡
+     */
+    public static final String ITF_OPEN_CARD = "/openapi/service/base/person/batchOpenCards";
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/common/hk/HKOpenApi.java

 package com.community.huiju.common.hk;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.community.commom.hk.Digests;
 import com.community.commom.hk.HttpClientSSLUtils;
 import com.google.common.collect.Maps;
      *      比如 住户
      * @return
      */
-    public static String getAddUser(Map<String,Object> map){
+    public static String addUser(Map<String,Object> map){
         Map<String,Object> parMap = Maps.newHashMap();
-        String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.ITF_LIKE_DEPT_NAME;
+        String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.ITF_ADD_USER;
         //设置APPKEY
         parMap.put("appkey", HKConstant.APPKEY);
         //设置时间参数
         parMap.put("time", System.currentTimeMillis());
-        parMap.put("pageNo",map.get("pageNo"));
-        parMap.put("pageSize",map.get("pageSize"));
         parMap.put("opUserUuid",map.get("opUserUuid") == null?HKConstant.OP_USER_UUID:map.get("opUserUuid"));
         parMap.put("personNo",map.get("personNo"));
         parMap.put("personName",map.get("personName"));
+        parMap.put("phoneNo",map.get("phoneNo"));
+        parMap.put("deptUuid",map.get("deptUuid"));
+        // parMap.put("cardNo",map.get("cardNo"));
         String params =  JSON.toJSONString(parMap);
         log.info("添加人员 请求参数：{}", params);
         String data = null;
         return data;
     }
 
+    /**
+     * 批量开卡
+     *
+     * 其中参数 cardAndPerson 形式为“卡号，人员ID”，开卡数量不得超过50个，若没有该卡号，则添加一张新卡进行绑定 List<String>
+     * @return
+     */
+    public static String openCard(Map<String,Object> map){
+        Map<String,Object> parMap = Maps.newHashMap();
+        String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.ITF_OPEN_CARD;
+        //设置APPKEY
+        parMap.put("appkey", HKConstant.APPKEY);
+        //设置时间参数
+        parMap.put("time", System.currentTimeMillis());
+        parMap.put("opUserUuid",map.get("opUserUuid") == null?HKConstant.OP_USER_UUID:map.get("opUserUuid"));
+        parMap.put("cardAndPerson",map.get("cardAndPerson"));
+        parMap.put("startTime",map.get("startTime"));
+        parMap.put("endTime",map.get("endTime"));
+
+        String params =  JSON.toJSONString(parMap);
+        log.info("批量开卡 请求参数：{}", params);
+        String data = null;
+        try {
+            data = HttpClientSSLUtils.doPost(url + "?token=" + Digests.buildToken(url + "?" + params, params, HKConstant.SECRET), params);
+            log.info("批量开卡 请求返回结果：{}",data);
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("批量开卡失败!",e);
+        }
+
+        return data;
+    }
 
     public static void main(String[] args) {
         Map<String,Object> parMap = Maps.newHashMap();
         parMap.put("opUserUuid",HKConstant.OP_USER_UUID);
         parMap.put("deptName","住户");
         String result = HKOpenApi.getDeptName(parMap);
+        Map<String,Object> deptMap = JSONObject.parseObject(result, HashMap.class);
         System.out.println(result);
     }
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/common/hk/test/OpenapiTest.java

 package com.community.huiju.common.hk.test;
 
+import java.time.LocalDate;
 import java.util.HashMap;
 import java.util.Map;
 
 
 		/***http方式调用***/
 		//System.out.println(testGetDefaultUserUUID());
-		System.out.println(testGetCameras());
+		//System.out.println(testGetCameras());
 //		
 //		/***https方式调用***/
 //		System.out.println(testGetDefaultUserUUID_Https());
 //		System.out.println(testGetCameras_Https());
+
+		LocalDate today = LocalDate.now();
+		int year = today.getYear();
+		// 加上20, 表示加上20年,默认
+
+		int month = today.getMonthValue();
+		int day = today.getDayOfMonth();
+
 	}
 	
 	/**

CODE/smart-community/app-api/src/main/java/com/community/huiju/model/TaUser.java

 
     private Date updateDate;
 
+    // 海康UserId
+    private Integer hkUserId;
+
     public Integer getId() {
         return id;
     }
     public void setUpdateDate(Date updateDate) {
         this.updateDate = updateDate;
     }
+
+    public Integer getHkUserId() {
+        return hkUserId;
+    }
+
+    public void setHkUserId(Integer hkUserId) {
+        this.hkUserId = hkUserId;
+    }
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/impl/TaUserServiceImpl.java

 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.mode.ResponseBean;
 import com.community.commom.utils.AccountValidatorUtil;
 import com.community.commom.utils.MD5Utils;
 import com.community.huiju.common.code.cache.AppkeyCache;
+import com.community.huiju.common.hk.HKConstant;
+import com.community.huiju.common.hk.HKOpenApi;
 import com.community.huiju.dao.*;
 import com.community.huiju.model.*;
 import com.community.huiju.service.ITaUserService;
 import com.community.huiju.vo.TaUserVO;
+import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.sun.org.apache.bcel.internal.generic.IF_ACMPEQ;
 import lombok.extern.slf4j.Slf4j;
 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.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.logging.SimpleFormatter;
 
 /**
  * 用户业务 实现
     @Autowired
     private SysNationMapper sysNationMapper;
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public ResponseBean login(TaUser user) {
         ResponseBean response = new ResponseBean();
         return response;
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public ResponseBean register(TaUser user) {
 
         response.addSuccess(taUserVO);
         return response;
     }
-    @Transactional
+
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public ResponseBean upDateloginName(Integer id, String paramets) {
         ResponseBean response = new ResponseBean();
         return taUserMapper.selectUserListByParentId(parentId);
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public ResponseBean modifyUser(TaUser user) {
 
         return response;
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public ResponseBean startOrEndUsingUser(Integer currentUserId, Integer userId, Integer type) {
         ResponseBean response = null;
         return response;
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public ResponseBean addTenantsOrDependents(String userName, String phone, String gender, Integer currentUserId, Integer type) {
         ResponseBean response = new ResponseBean();
             return response;
         }
 
+        // 用户添加到本地库
         addUserRole(type,response,user);
 
+        // 推送海康
+        /**
+         * 1.获取部门(比如 住户)
+         * 2.根据部门编号推送 海康
+         */
+        addUserAndOpenCard(response,user);
+
+        return response;
+    }
+
+    /**
+     * 公共方法
+     *  添加人员, 开卡
+     * @param response
+     * @param user
+     */
+    private void addUserAndOpenCard(ResponseBean response,TaUser user){
+        Map<String,Object> parDept = Maps.newHashMap();
+        parDept.put("pageNo",1);
+        parDept.put("pageSize",100);
+        parDept.put("deptName",Constant.DEPT_RESIDENTS);
+        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");
+
+        // 添加人员
+        Map<String,Object> parUser = Maps.newHashMap();
+        parUser.put("personNo",user.getId());
+        parUser.put("personName",user.getUserName());
+        parUser.put("phoneNo",user.getLoginName());
+        parUser.put("deptUuid",deptUuid);
+        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");
+            // 海康人员ID
+            Integer personId = (Integer) resultDataMap.get("personId");
+            TaUser tempUser = taUserMapper.selectByPrimaryKey(user.getId());
+            tempUser.setHkUserId(personId);
+            // 存储海康人员ID
+            int row = taUserMapper.updateByPrimaryKeySelective(tempUser);
+            if (row > 0) {
+                response.addSuccess("操作成功!");
+            }else {
+                response.addError("操作失败");
+                throw new RuntimeException("数据库添加 家属/租客 人员失败!");
+            }
+
+            // 开卡
+            List<String> cardAndPersonList = Lists.newArrayList();
+            cardAndPersonList.add(System.currentTimeMillis() + "," + personId);
+            response = openCard(cardAndPersonList,null);
+        }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){
+        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);
+        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;
     }
 

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

     <result column="create_date" property="createDate" jdbcType="TIMESTAMP" />
     <result column="update_user" property="updateUser" jdbcType="INTEGER" />
     <result column="update_date" property="updateDate" jdbcType="TIMESTAMP" />
+    <result column="hk_user_id" property="hkUserId" javaType="INTEGER" />
   </resultMap>
   <sql id="Base_Column_List" >
     id, community_id, building_owner_info_id, head_portrait, user_name, login_name, login_password, 
     email, gender, status, remark, parent_id, accept_agreement_status, verify_status,
-    create_user, create_date, update_user, update_date
+    create_user, create_date, update_user, update_date,hk_user_id
   </sql>
   <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
     select
       login_password, email, gender,
       status, remark, parent_id,
       accept_agreement_status, verify_status, create_user,
-      create_date, update_user, update_date
+      create_date, update_user, update_date, hk_user_id
       )
     values (#{id,jdbcType=INTEGER}, #{communityId,jdbcType=INTEGER}, #{buildingOwnerInfoId,jdbcType=INTEGER},
       #{headPortrait,jdbcType=VARCHAR}, #{userName,jdbcType=VARCHAR}, #{loginName,jdbcType=VARCHAR},
       #{loginPassword,jdbcType=VARCHAR}, #{email,jdbcType=VARCHAR}, #{gender,jdbcType=CHAR},
       #{status,jdbcType=CHAR}, #{remark,jdbcType=VARCHAR}, #{parentId,jdbcType=INTEGER},
       #{acceptAgreementStatus,jdbcType=CHAR}, #{verifyStatus,jdbcType=CHAR}, #{createUser,jdbcType=INTEGER},
-      #{createDate,jdbcType=TIMESTAMP}, #{updateUser,jdbcType=INTEGER}, #{updateDate,jdbcType=TIMESTAMP}
+      #{createDate,jdbcType=TIMESTAMP}, #{updateUser,jdbcType=INTEGER}, #{updateDate,jdbcType=TIMESTAMP},
+      #{hkUserId,jdbcType=INTEGER}
       )
   </insert>
   <insert id="insertSelective" useGeneratedKeys="true" keyProperty="id" parameterType="com.community.huiju.model.TaUser" >
       <if test="updateDate != null" >
         update_date,
       </if>
+      <if test="hkUserId != null">
+        hk_user_id,
+      </if>
     </trim>
     <trim prefix="values (" suffix=")" suffixOverrides="," >
       <if test="id != null" >
       <if test="updateDate != null" >
         #{updateDate,jdbcType=TIMESTAMP},
       </if>
+      <if test="hkUserId != null">
+        #{hkUserId,jdbcType=INTEGER},
+      </if>
     </trim>
   </insert>
   <update id="updateByPrimaryKeySelective" parameterType="com.community.huiju.model.TaUser" >
       <if test="updateDate != null" >
         update_date = #{updateDate,jdbcType=TIMESTAMP},
       </if>
+      <if test="hkUserId != null">
+        hk_user_id = #{hkUserId,jdbcType=INTEGER},
+      </if>
     </set>
     where id = #{id,jdbcType=INTEGER}
   </update>
       create_user = #{createUser,jdbcType=INTEGER},
       create_date = #{createDate,jdbcType=TIMESTAMP},
       update_user = #{updateUser,jdbcType=INTEGER},
-      update_date = #{updateDate,jdbcType=TIMESTAMP}
+      update_date = #{updateDate,jdbcType=TIMESTAMP},
+      hk_user_id = #{hkUserId,jdbcType=INTEGER}
     where id = #{id,jdbcType=INTEGER}
   </update>
 

CODE/smart-community/community-common/src/main/java/com/community/commom/constant/Constant.java

 
     /**图片服务类型**/
     public static final String SERVICE = "service";
+
+    /** 添加用户所对应的部门 住户 **/
+    public static final String DEPT_RESIDENTS = "测试";
 }