暂存

CODE/smart-community/app-api/pom.xml

@@ -167,6 +167,19 @@
 			<version>3.1</version>
 		</dependency>
 
+		<!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
+		<dependency>
+			<groupId>commons-io</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>1.4</version>
+		</dependency>
+
+		<dependency>
+			<groupId>net.coobird</groupId>
+			<artifactId>thumbnailator</artifactId>
+			<version>0.4.2</version>
+		</dependency>
+
 
 	</dependencies>
 

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

@@ -37,7 +37,6 @@ public class HKConstant {
      * <p>操作用户UUID，即用户UUID，首次使用操作用户UUID可以通过接口 [获取默认用户UUID]来获取</p>
      * <p>也可以通过接口[分页获取用户]来获取</p>
      */
-    public static final String OP_USER_UUID = "5b2eb534696b11e89c2e438f92627767";
 
     /**
      * 获取默认用户UUID的接口地址，此地址可以从《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》中具体的接口说明上获取
@@ -57,8 +56,12 @@ public class HKConstant {
     /**--主要是推送图片到海康
      * 通过此接口将人员名单添加到指定的人员分组当中，此接口适合一次添加一个人员，如果需要批量添加可以使用平台上自带的图片压缩包的方式批量添加。
      */
-    public  static  final  String OP_IMG="openapi/service/fas/personInfo/addPersonInfoIntoGroup";
+    public  static  final  String OP_IMG="/openapi/service/fas/personInfo/addPersonInfoIntoGroup";
 
     public static final String ITF_MONITORY_POINT = "/openapi/service/vss/res/getCamerasEx";
 
+    /**--推送图片时需要获取人员分组下的，人员分组ID
+     * --personGroupId--
+     */
+    public static final  String OP_PERSON_ID="/openapi/service/fas/personGroup/getPersonGroup";
 }

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

@@ -1,18 +1,16 @@
 package com.community.huiju.common.hk;
 
 import com.alibaba.fastjson.JSON;
+import com.community.huiju.common.hk.test.PicUtils;
 import com.google.common.collect.Maps;
 import com.hikvision.cms.api.common.util.Digests;
 import com.hikvision.cms.api.common.util.HttpClientSSLUtils;
 import lombok.extern.slf4j.Slf4j;
-
-import javax.imageio.ImageIO;
-import java.awt.image.BufferedImage;
-import java.io.ByteArrayOutputStream;
-import java.io.File;
-import java.io.IOException;
-import java.net.MalformedURLException;
-import java.util.Base64;
+import net.coobird.thumbnailator.Thumbnails;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.multipart.MultipartFile;
+import java.io.*;
 import java.util.Map;
 
 /**
@@ -21,6 +19,7 @@ import java.util.Map;
  */
 @Slf4j
 public class HKOpenApi {
+    private static Logger logger = LoggerFactory.getLogger(PicUtils.class);
 
     public static String getMonitoryPoint(){
         Map<String,Object> parMap = Maps.newHashMap();
@@ -53,7 +52,7 @@ public class HKOpenApi {
      * @param imageFile
      * @return 加密之后的字符串
      */
-    public static String encodeImgageToBase64(String imageFile) {// 将图片文件转化为字节数组字符串，并对其进行Base64编码处理
+    /*public static String encodeImgageToBase64(String imageFile) {// 将图片文件转化为字节数组字符串，并对其进行Base64编码处理
         String img=getPicSuffix(String.valueOf(imageFile));
         ByteArrayOutputStream outputStream = null;
         try {
@@ -69,7 +68,7 @@ public class HKOpenApi {
         Base64.Encoder encoder = Base64.getEncoder();
 
         return encoder.encodeToString(outputStream.toByteArray());// 返回Base64编码过的字节数组字符串
-    }
+    }*/
 
     /**
      *
@@ -83,4 +82,99 @@ public class HKOpenApi {
         return img_path.substring(img_path.lastIndexOf(".") + 1).
                 trim().toLowerCase();
     }
+
+/*    //将本地图片进行Base64位编码
+    public static String getImgStr(String imgFile){
+        //将图片文件转化为字节数组字符串，并对其进行Base64编码处理
+        InputStream in = null;
+        byte[] data = null;
+        //读取图片字节数组
+        try
+        {
+            in = new FileInputStream(imgFile);
+            data = new byte[in.available()];
+            in.read(data);
+            in.close();
+        }
+        catch (IOException e)
+        {
+            e.printStackTrace();
+        }
+        return new String(org.apache.commons.codec.binary.Base64.encodeBase64(data));
+    }*/
+
+    //将本地图片进行Base64位编码
+    public static String getImgStr(MultipartFile imgFile){
+        //将图片文件转化为字节数组字符串，并对其进行Base64编码处理
+        byte[] data = null;
+        //读取图片字节数组
+        try
+        {
+            data = imgFile.getBytes();
+        }
+        catch (IOException e)
+        {
+            e.printStackTrace();
+        }
+        return new String(org.apache.commons.codec.binary.Base64.encodeBase64(data));
+    }
+
+    //将本地图片进行Base64位编码
+    public static String getImgStr(byte [] fileBytes){
+        return new String(org.apache.commons.codec.binary.Base64.encodeBase64(fileBytes));
+    }
+
+
+    /**
+     * 根据指定大小压缩图片
+     *
+     * @param imageBytes  源图片字节数组
+     * @param desFileSize 指定图片大小，单位kb
+     * @param imageId     影像编号
+     * @return 压缩质量后的图片字节数组
+     */
+    public static byte[] compressPicForScale(byte[] imageBytes, long desFileSize, String imageId) {
+        if (imageBytes == null || imageBytes.length <= 0 || imageBytes.length < desFileSize * 1024) {
+            return imageBytes;
+        }
+        long srcSize = imageBytes.length;
+        double accuracy = getAccuracy(srcSize / 1024);
+        try {
+            while (imageBytes.length > desFileSize * 1024) {
+                ByteArrayInputStream inputStream = new ByteArrayInputStream(imageBytes);
+                ByteArrayOutputStream outputStream = new ByteArrayOutputStream(imageBytes.length);
+                Thumbnails.of(inputStream)
+                        .scale(accuracy)
+                        .outputQuality(accuracy)
+                        .toOutputStream(outputStream);
+                imageBytes = outputStream.toByteArray();
+            }
+            logger.info("【图片压缩】imageId={} | 图片原大小={}kb | 压缩后大小={}kb",
+                    imageId, srcSize / 1024, imageBytes.length / 1024);
+        } catch (Exception e) {
+            logger.error("【图片压缩】msg=图片压缩失败!", e);
+        }
+        return imageBytes;
+    }
+
+    /**
+     * 自动调节精度(经验数值)
+     *
+     * @param size 源图片大小
+     * @return 图片压缩质量比
+     */
+    private static double getAccuracy(long size) {
+        double accuracy;
+        if (size < 900) {
+            accuracy = 0.85;
+        } else if (size < 2047) {
+            accuracy = 0.6;
+        } else if (size < 3275) {
+            accuracy = 0.44;
+        } else {
+            accuracy = 0.4;
+        }
+        return accuracy;
+    }
+
 }

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

@@ -45,8 +45,7 @@ public class OpenapiUtil {
 	
 	/** 
      * 将本地图片进行Base64位编码 
-     *  
-     * @param imgUrl 
+     *
      *            图片的url路径，如http://.....xx.jpg 
      * @param extensioName 图片的扩展名
      * @return 加密之后的字符串

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

@@ -0,0 +1,84 @@
+package com.community.huiju.common.hk.test;
+
+import net.coobird.thumbnailator.Thumbnails;
+import org.apache.commons.io.FileUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.IOException;
+
+/**
+ * 图片压缩Utils
+ *
+ * @author worstEzreal
+ * @version V1.1.0
+ * @date 2018/3/12
+ */
+public class PicUtils {
+
+    private static Logger logger = LoggerFactory.getLogger(PicUtils.class);
+
+   public static void main(String[] args) throws IOException {
+        byte[] bytes = FileUtils.readFileToByteArray(new File("C:\\Users\\DELL\\Pictures\\timg.jpg"));
+      long l = System.currentTimeMillis();
+       bytes = PicUtils.compressPicForScale(bytes, 20, "x");// 图片小于300kb
+        System.out.println(System.currentTimeMillis() - l);
+        FileUtils.writeByteArrayToFile(new File("C:\\Users\\DELL\\Pictures\\timg.jpg"), bytes);
+   }
+
+    /**
+     * 根据指定大小压缩图片
+     *
+     * @param imageBytes  源图片字节数组
+     * @param desFileSize 指定图片大小，单位kb
+     * @param imageId     影像编号
+     * @return 压缩质量后的图片字节数组
+     */
+    public static byte[] compressPicForScale(byte[] imageBytes, long desFileSize, String imageId) {
+        if (imageBytes == null || imageBytes.length <= 0 || imageBytes.length < desFileSize * 1024) {
+            return imageBytes;
+        }
+        long srcSize = imageBytes.length;
+        double accuracy = getAccuracy(srcSize / 1024);
+        try {
+            while (imageBytes.length > desFileSize * 1024) {
+                ByteArrayInputStream inputStream = new ByteArrayInputStream(imageBytes);
+                ByteArrayOutputStream outputStream = new ByteArrayOutputStream(imageBytes.length);
+                Thumbnails.of(inputStream)
+                        .scale(accuracy)
+                        .outputQuality(accuracy)
+                        .toOutputStream(outputStream);
+                imageBytes = outputStream.toByteArray();
+            }
+            logger.info("【图片压缩】imageId={} | 图片原大小={}kb | 压缩后大小={}kb",
+                    imageId, srcSize / 1024, imageBytes.length / 1024);
+        } catch (Exception e) {
+            logger.error("【图片压缩】msg=图片压缩失败!", e);
+        }
+        return imageBytes;
+    }
+
+    /**
+     * 自动调节精度(经验数值)
+     *
+     * @param size 源图片大小
+     * @return 图片压缩质量比
+     */
+    private static double getAccuracy(long size) {
+        double accuracy;
+        if (size < 900) {
+            accuracy = 0.85;
+        } else if (size < 2047) {
+            accuracy = 0.6;
+        } else if (size < 3275) {
+            accuracy = 0.44;
+        } else {
+            accuracy = 0.4;
+        }
+        return accuracy;
+    }
+
+}

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

@@ -0,0 +1,49 @@
+package com.community.huiju.common.hk.test;
+
+import org.apache.commons.codec.binary.Base64;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * version V1.0
+ * class_name: $METHOD_NAME$
+ * param: $METHOD_PARAM$
+ * describe: TODO
+ * creat_user:fannaixi
+ * creat_time: 2018/11/6
+ **/
+public class img{
+    public static void main(String[] args) {
+        String imgFile = "E:\\1.jpg";//待处理的图片
+        String imgbese=getImgStr(imgFile);
+        System.out.println(imgbese.length());
+        System.out.println(imgbese);
+
+    }
+
+    /**
+     * 将图片转换成Base64编码
+     * @param imgFile 待处理图片
+     * @return
+     */
+    public static String getImgStr(String imgFile){
+        //将图片文件转化为字节数组字符串，并对其进行Base64编码处理
+        InputStream in = null;
+        byte[] data = null;
+        //读取图片字节数组
+        try
+        {
+            in = new FileInputStream(imgFile);
+            data = new byte[in.available()];
+            in.read(data);
+            in.close();
+        }
+        catch (IOException e)
+        {
+            e.printStackTrace();
+        }
+        return new String(Base64.encodeBase64(data));
+    }
+}

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

@@ -7,6 +7,7 @@ import com.community.commom.constant.Constant;
 import com.community.commom.mode.ResponseBean;
 import com.community.huiju.common.hk.HKConstant;
 import com.community.huiju.common.hk.HKOpenApi;
+import com.community.huiju.common.hk.test.PicUtils;
 import com.community.huiju.controller.ImageController;
 import com.community.huiju.dao.TaFaceMapper;
 import com.community.huiju.dao.TaSysRoleMapper;
@@ -18,11 +19,16 @@ import com.community.huiju.service.ImageServiceI;
 import com.community.huiju.service.FaceServicel;
 import com.hikvision.cms.api.common.util.Digests;
 import com.hikvision.cms.api.common.util.HttpClientSSLUtils;
+import org.apache.commons.io.FileUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
+import java.io.FileInputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
@@ -44,6 +50,7 @@ public class FaceServicelimpl implements FaceServicel {
     private ImageServiceI imageServiceI;
 
     @Override
+    @Transactional
     public ResponseBean addFace(Integer userid,MultipartFile uploadFile) {
         String faceImg = null;
         try {
@@ -87,35 +94,41 @@ public class FaceServicelimpl implements FaceServicel {
             boolean isA=true;
             if (Constant.OWNER.equals(sysRole.getRoleName()) && "1".equals(taUser.getVerifyStatus())) {
                 ResponseBean responseBean = new ResponseBean();
-                boolean resps=checKout(faceImg,taFace,isA,null);
-                if (resps==true) {
-                    //校验通过后
-                    imgPush(user.getUserName(),faceImg);
+                Object resps=checKout(faceImg,taFace,isA,null,user.getUserName(),uploadFile);
+                if (null!=resps && "true".equals(resps)) {
                     responseBean.addSuccess("图片录入成功");
                 }else {
-                    responseBean.addError("7771","请录入正确的图片");
+                    if ("1".equals(resps)) {
+                        responseBean.addError("7772", "推送海康服务器失败");
+                    }else {
+                        responseBean.addError("7771","请录入正确的图片");
+                    }
                 }
                 return responseBean;
             }
-            //家属或者租客
+            //家属或者租客，已认证
             if (Constant.RELATION.equals(sysRole.getRoleName()) || Constant.TENANT.equals(sysRole.getDescription()) && "1".equals(taUser.getVerifyStatus())) {
                 ResponseBean responseBeans = new ResponseBean();
-                boolean resps=checKout(faceImg,taFace,isA,null);
-                if (resps==true) {
-                    imgPush(user.getUserName(),faceImg);
+                Object resps=checKout(faceImg,taFace,isA,null,user.getUserName(),uploadFile);
+                if (null!=resps && "true".equals(resps)) {
+                    imgPush(user.getUserName(), uploadFile);
                     responseBeans.addSuccess("图片录入成功");
                 }else {
-                    responseBeans.addError("7771","请录入正确的图片");
+                        if ("1".equals(resps)) {
+                            responseBeans.addError("7772", "推送海康服务器失败");
+                        }else {
+                            responseBeans.addError("7771","请录入正确的图片");
+                        }
                 }
                 return responseBeans;
             }
         } else {
-            //为业主，已认证
+            //为业主，未认证情况下
             if (Constant.OWNER.equals(sysRole.getRoleName()) && "1".equals(taUser.getVerifyStatus())) {
                 response.addError("8885", "您的信息已存在");
                 return response;
             }
-            //家属或者租客
+            //家属或者租客，未认证情况下
             if (Constant.RELATION.equals(sysRole.getRoleName()) || Constant.TENANT.equals(sysRole.getDescription()) && "1".equals(taUser.getVerifyStatus())) {
                 response.addError("8885", "您的信息已存在");
                 return response;
@@ -123,11 +136,10 @@ public class FaceServicelimpl implements FaceServicel {
         }
         response.addError("9995", "无法确认您的身份，请联系物业");
         return response;
-
-
     }
 
     @Override
+    @Transactional
     public ResponseBean upDateFace(Integer userId,MultipartFile uploadFile) {
         boolean isA=false;
         String faceImg = null;
@@ -143,8 +155,8 @@ public class FaceServicelimpl implements FaceServicel {
         taFace.setTaUserId(userId);
         taFace.setUpdateUser(userId);
         taFace.setUpdateDate(new Date());
-        boolean ck=checKout(faceImg,taFace,isA,userId);
-        if (ck == true) {
+        Object resps=checKout(faceImg,taFace,isA,userId,user.getUserName(),uploadFile);
+        if (null!=resps && "true".equals(resps)) {
             responseBean.addSuccess("修改成功");
         }else {
             responseBean.addError("7771","请录入正确图片");
@@ -153,7 +165,8 @@ public class FaceServicelimpl implements FaceServicel {
     }
 
     //人脸录入验证
-    public boolean checKout(String faceImg, TaFace taFace, boolean isA,Integer user) {
+    @Transactional
+    public Object checKout(String faceImg, TaFace taFace, boolean isA,Integer user,String name,MultipartFile uploadFile) {
         AESDecode aesd = new AESDecode();
                 String body = "{\"type\": \"0\", \"image_url\":\"" + faceImg + "\"}";
         try {
@@ -162,9 +175,18 @@ public class FaceServicelimpl implements FaceServicel {
             Integer type = (Integer) jsonObject.get("errno");
             Integer faceNum= (Integer) jsonObject.get("face_num");
             if (0==type && null!=faceNum && 1==faceNum && isA==true) {
-                taFace.setFaceImg(faceImg);
-                taFaceMapper.insertSelective(taFace);
-                return true;
+                //校验通过后
+                String errorCode= (String) imgPush(name, uploadFile);
+                JSONObject Code = JSONObject.parseObject(errorCode);
+                Integer personGroupId = (Integer) Code.get("personGroupId");
+                if (null!=personGroupId && personGroupId == 1) {
+                    taFace.setFaceImg(faceImg);
+                    taFaceMapper.insertSelective(taFace);
+                    return true;
+                }else{
+                    String code="1";
+                    return code;
+                }
             }else if (0==type && null!=faceNum && 1==faceNum && isA==false){
                 taFace.setFaceImg(faceImg);
                 taFaceMapper.updateByPrimaryKeySelective(taFace);
@@ -177,16 +199,35 @@ public class FaceServicelimpl implements FaceServicel {
         return false;
     }
     //在图片验证通过的情况下，推送到海康
-    public Object imgPush(String name,String img){
+    public Object imgPush(String name,MultipartFile uploadFile){
         HKOpenApi hkOpenApi=new HKOpenApi();
-        name = hkOpenApi.encodeImgageToBase64(img);
+        //把图片压缩成100K以下
+        // 压缩后的图片字节数组
+        byte [] picByte = null;
+        try {
+            long l = System.currentTimeMillis();
+            byte[] bytes  = uploadFile.getBytes();
+            // 拿到转换后的图片字节
+            picByte= PicUtils.compressPicForScale(bytes,99L,"x");
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        // String imgs = hkOpenApi.getImgStr(uploadFile);
+        String imgs = hkOpenApi.getImgStr(picByte);
+        String pgId= (String) HKpersonGroupId();
+        JSONObject jsonObject = JSONObject.parseObject(pgId);
+        Integer personGroupId = (Integer) jsonObject.get("personGroupId");
+        System.out.println(personGroupId);
         String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.OP_IMG;
         Map<String, Object> map = new HashMap<String, Object>();
         map.put("appkey", HKConstant.APPKEY);//设置APPKEY
         map.put("time", System.currentTimeMillis());//设置时间参数
-        map.put("facePhotos", System.currentTimeMillis());//设置时间参数 //bs64转码
+        map.put("token", HKConstant.SECRET);//认证token
+        map.put("opUserUuid",HKConstant.OP_USER_UUID);//操作用户UUID
+        map.put("facePhotos", imgs); //bs64转码
         map.put("personName",name);//名字
-        map.put("personName",System.currentTimeMillis());//时间取毫秒
+        map.put("personGroupId",personGroupId);//分组用户ID
+        map.put("birthday",System.currentTimeMillis());//时间取毫秒
         String params =  JSON.toJSONString(map);
         System.out.println(" ====== testGetDefaultUserUUID 请求参数：【" + params + "】");
         String data = null;
@@ -199,5 +240,27 @@ public class FaceServicelimpl implements FaceServicel {
         return data;
     }
 
+    //把图片推送海康，需要获得海康人员分组下的
+    // **personGroupId**
+    @Transactional
+    public Object HKpersonGroupId(){
+        String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.OP_PERSON_ID;
+        Map<String, Object> map = new HashMap<String, Object>();
+        map.put("appkey", HKConstant.APPKEY);//设置APPKEY
+        map.put("time", System.currentTimeMillis());//设置时间参数
+        map.put("token", HKConstant.SECRET);//认证token
+        map.put("opUserUuid",HKConstant.OP_USER_UUID);//操作用户UUID
+        map.put("pageNo",1);//当前页码
+        map.put("pageSize",100);//每页数据记录数
+        map.put("birthday",System.currentTimeMillis());//时间取毫秒
+        String params =  JSON.toJSONString(map);
+        String data = null;
+        try {
+            data = HttpClientSSLUtils.doPost(url + "?token=" + Digests.buildToken(url + "?" + params, params, HKConstant.SECRET), params);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return data;
+    }
 
 }

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

@@ -3,6 +3,7 @@ package com.community.huiju.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.community.commom.mode.ResponseBean;
 import com.community.huiju.common.hk.HKConstant;
+import com.community.huiju.common.hk.HKOpenApi;
 import com.community.huiju.service.IMonitoringService;
 import com.google.common.collect.Maps;
 import com.hikvision.cms.api.common.util.Digests;
@@ -24,30 +25,16 @@ public class MonitoringServiceImpl implements IMonitoringService {
     @Override
     public ResponseBean getByCommunityId(Integer communityId) {
 
-        // TODO 数据是假数据, 后期在更改
+        // TODO 数据是假数据, 后期在更改. 需要根据小区查询 组织中心编号
 
         ResponseBean response = new ResponseBean();
         Map<String,Object> parMap = Maps.newHashMap();
-        String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.ITF_ADDRESS_GET_CAMERAS;
-        //设置APPKEY
-        parMap.put("appkey", HKConstant.APPKEY);
-        //设置时间参数
-        parMap.put("time", System.currentTimeMillis());
-        parMap.put("pageNo","");
-        parMap.put("pageSize","");
+        parMap.put("pageNo",1);
+        parMap.put("pageSize",100);
         parMap.put("opUserUuid",HKConstant.OP_USER_UUID);
-        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);
-        }
-
-
+        parMap.put("unitUuids","1048576");
+/*        String result = HKOpenApi.getMonitoryPoint(parMap);
+        response.addSuccess(result);*/
         return response;
     }
 }