提交

CODE/smart-community/app-api/src/main/java/com/community/huiju/common/fushi/Base64.java

@@ -0,0 +1,268 @@
+package com.community.huiju.common.fushi;
+
+public final class Base64 {
+
+	private static final int BASELENGTH = 128;
+	private static final int LOOKUPLENGTH = 64;
+	private static final int TWENTYFOURBITGROUP = 24;
+	private static final int EIGHTBIT = 8;
+	private static final int SIXTEENBIT = 16;
+	private static final int FOURBYTE = 4;
+	private static final int SIGN = -128;
+	private static char PAD = '=';
+	private static byte[] base64Alphabet = new byte[BASELENGTH];
+	private static char[] lookUpBase64Alphabet = new char[LOOKUPLENGTH];
+
+	static {
+		for (int i = 0; i < BASELENGTH; ++i) {
+			base64Alphabet[i] = -1;
+		}
+		for (int i = 'Z'; i >= 'A'; i--) {
+			base64Alphabet[i] = (byte) (i - 'A');
+		}
+		for (int i = 'z'; i >= 'a'; i--) {
+			base64Alphabet[i] = (byte) (i - 'a' + 26);
+		}
+
+		for (int i = '9'; i >= '0'; i--) {
+			base64Alphabet[i] = (byte) (i - '0' + 52);
+		}
+
+		base64Alphabet['+'] = 62;
+		base64Alphabet['/'] = 63;
+
+		for (int i = 0; i <= 25; i++) {
+			lookUpBase64Alphabet[i] = (char) ('A' + i);
+		}
+
+		for (int i = 26, j = 0; i <= 51; i++, j++) {
+			lookUpBase64Alphabet[i] = (char) ('a' + j);
+		}
+
+		for (int i = 52, j = 0; i <= 61; i++, j++) {
+			lookUpBase64Alphabet[i] = (char) ('0' + j);
+		}
+		lookUpBase64Alphabet[62] = (char) '+';
+		lookUpBase64Alphabet[63] = (char) '/';
+
+	}
+
+	private static boolean isWhiteSpace(char octect) {
+		return (octect == 0x20 || octect == 0xd || octect == 0xa || octect == 0x9);
+	}
+
+	private static boolean isPad(char octect) {
+		return (octect == PAD);
+	}
+
+	private static boolean isData(char octect) {
+		return (octect < BASELENGTH && base64Alphabet[octect] != -1);
+	}
+
+	/**
+	 * Encodes hex octects into Base64
+	 * 
+	 * @param binaryData
+	 *            Array containing binaryData
+	 * @return Encoded Base64 array
+	 */
+	public static String encode(byte[] binaryData) {
+
+		if (binaryData == null) {
+			return null;
+		}
+
+		int lengthDataBits = binaryData.length * EIGHTBIT;
+		if (lengthDataBits == 0) {
+			return "";
+		}
+
+		int fewerThan24bits = lengthDataBits % TWENTYFOURBITGROUP;
+		int numberTriplets = lengthDataBits / TWENTYFOURBITGROUP;
+		int numberQuartet = fewerThan24bits != 0 ? numberTriplets + 1
+				: numberTriplets;
+		char encodedData[] = null;
+
+		encodedData = new char[numberQuartet * 4];
+
+		byte k = 0, l = 0, b1 = 0, b2 = 0, b3 = 0;
+
+		int encodedIndex = 0;
+		int dataIndex = 0;
+
+		for (int i = 0; i < numberTriplets; i++) {
+			b1 = binaryData[dataIndex++];
+			b2 = binaryData[dataIndex++];
+			b3 = binaryData[dataIndex++];
+
+			l = (byte) (b2 & 0x0f);
+			k = (byte) (b1 & 0x03);
+
+			byte val1 = ((b1 & SIGN) == 0) ? (byte) (b1 >> 2)
+					: (byte) ((b1) >> 2 ^ 0xc0);
+			byte val2 = ((b2 & SIGN) == 0) ? (byte) (b2 >> 4)
+					: (byte) ((b2) >> 4 ^ 0xf0);
+			byte val3 = ((b3 & SIGN) == 0) ? (byte) (b3 >> 6)
+					: (byte) ((b3) >> 6 ^ 0xfc);
+
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val1];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val2 | (k << 4)];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[(l << 2) | val3];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[b3 & 0x3f];
+		}
+
+		// form integral number of 6-bit groups
+		if (fewerThan24bits == EIGHTBIT) {
+			b1 = binaryData[dataIndex];
+			k = (byte) (b1 & 0x03);
+			
+			byte val1 = ((b1 & SIGN) == 0) ? (byte) (b1 >> 2)
+					: (byte) ((b1) >> 2 ^ 0xc0);
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val1];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[k << 4];
+			encodedData[encodedIndex++] = PAD;
+			encodedData[encodedIndex++] = PAD;
+		} else if (fewerThan24bits == SIXTEENBIT) {
+			b1 = binaryData[dataIndex];
+			b2 = binaryData[dataIndex + 1];
+			l = (byte) (b2 & 0x0f);
+			k = (byte) (b1 & 0x03);
+
+			byte val1 = ((b1 & SIGN) == 0) ? (byte) (b1 >> 2)
+					: (byte) ((b1) >> 2 ^ 0xc0);
+			byte val2 = ((b2 & SIGN) == 0) ? (byte) (b2 >> 4)
+					: (byte) ((b2) >> 4 ^ 0xf0);
+
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val1];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val2 | (k << 4)];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[l << 2];
+			encodedData[encodedIndex++] = PAD;
+		}
+
+		return new String(encodedData);
+	}
+
+	/**
+	 * Decodes Base64 data into octects
+	 * 
+	 * @param encoded
+	 *            string containing Base64 data
+	 * @return Array containind decoded data.
+	 */
+	public static byte[] decode(String encoded) {
+
+		if (encoded == null) {
+			return null;
+		}
+
+		char[] base64Data = encoded.toCharArray();
+		// remove white spaces
+		int len = removeWhiteSpace(base64Data);
+
+		if (len % FOURBYTE != 0) {
+			return null;// should be divisible by four
+		}
+
+		int numberQuadruple = (len / FOURBYTE);
+
+		if (numberQuadruple == 0) {
+			return new byte[0];
+		}
+
+		byte decodedData[] = null;
+		byte b1 = 0, b2 = 0, b3 = 0, b4 = 0;
+		char d1 = 0, d2 = 0, d3 = 0, d4 = 0;
+
+		int i = 0;
+		int encodedIndex = 0;
+		int dataIndex = 0;
+		decodedData = new byte[(numberQuadruple) * 3];
+
+		for (; i < numberQuadruple - 1; i++) {
+
+			if (!isData((d1 = base64Data[dataIndex++]))
+					|| !isData((d2 = base64Data[dataIndex++]))
+					|| !isData((d3 = base64Data[dataIndex++]))
+					|| !isData((d4 = base64Data[dataIndex++]))) {
+				return null;
+			}// if found "no data" just return null
+
+			b1 = base64Alphabet[d1];
+			b2 = base64Alphabet[d2];
+			b3 = base64Alphabet[d3];
+			b4 = base64Alphabet[d4];
+
+			decodedData[encodedIndex++] = (byte) (b1 << 2 | b2 >> 4);
+			decodedData[encodedIndex++] = (byte) (((b2 & 0xf) << 4) | ((b3 >> 2) & 0xf));
+			decodedData[encodedIndex++] = (byte) (b3 << 6 | b4);
+		}
+
+		if (!isData((d1 = base64Data[dataIndex++]))
+				|| !isData((d2 = base64Data[dataIndex++]))) {
+			return null;// if found "no data" just return null
+		}
+
+		b1 = base64Alphabet[d1];
+		b2 = base64Alphabet[d2];
+
+		d3 = base64Data[dataIndex++];
+		d4 = base64Data[dataIndex++];
+		if (!isData((d3)) || !isData((d4))) {// Check if they are PAD characters
+			if (isPad(d3) && isPad(d4)) {
+				if ((b2 & 0xf) != 0)// last 4 bits should be zero
+				{
+					return null;
+				}
+				byte[] tmp = new byte[i * 3 + 1];
+				System.arraycopy(decodedData, 0, tmp, 0, i * 3);
+				tmp[encodedIndex] = (byte) (b1 << 2 | b2 >> 4);
+				return tmp;
+			} else if (!isPad(d3) && isPad(d4)) {
+				b3 = base64Alphabet[d3];
+				if ((b3 & 0x3) != 0)// last 2 bits should be zero
+				{
+					return null;
+				}
+				byte[] tmp = new byte[i * 3 + 2];
+				System.arraycopy(decodedData, 0, tmp, 0, i * 3);
+				tmp[encodedIndex++] = (byte) (b1 << 2 | b2 >> 4);
+				tmp[encodedIndex] = (byte) (((b2 & 0xf) << 4) | ((b3 >> 2) & 0xf));
+				return tmp;
+			} else {
+				return null;
+			}
+		} else { // No PAD e.g 3cQl
+			b3 = base64Alphabet[d3];
+			b4 = base64Alphabet[d4];
+			decodedData[encodedIndex++] = (byte) (b1 << 2 | b2 >> 4);
+			decodedData[encodedIndex++] = (byte) (((b2 & 0xf) << 4) | ((b3 >> 2) & 0xf));
+			decodedData[encodedIndex++] = (byte) (b3 << 6 | b4);
+
+		}
+
+		return decodedData;
+	}
+
+	/**
+	 * remove WhiteSpace from MIME containing encoded Base64 data.
+	 * 
+	 * @param data
+	 *            the byte array of base64 data (with WS)
+	 * @return the new length
+	 */
+	private static int removeWhiteSpace(char[] data) {
+		if (data == null) {
+			return 0;
+		}
+
+		// count characters that's not whitespace
+		int newSize = 0;
+		int len = data.length;
+		for (int i = 0; i < len; i++) {
+			if (!isWhiteSpace(data[i])) {
+				data[newSize++] = data[i];
+			}
+		}
+		return newSize;
+	}
+}

CODE/smart-community/app-api/src/main/java/com/community/huiju/common/fushi/FSApi.java

@@ -0,0 +1,166 @@
+package com.community.huiju.common.fushi;
+
+import com.alibaba.fastjson.JSONObject;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.security.KeyFactory;
+import java.security.PrivateKey;
+import java.security.spec.PKCS8EncodedKeySpec;
+import java.util.Map;
+import java.util.SortedMap;
+import java.util.TreeMap;
+
+public class FSApi {
+
+    //	private static String url = "http://mops-test.fujica.com.cn:8021/Api/Park/GetParkInfoByCarNo";
+    private static String url = "http://api.mops.fujica.com.cn/v2/Api/Park/GetParkInfoByCarNo";
+    private static String appid = "fujica_89aa0f62d7ec77fc";
+    private static String appSecret = "cef36935e0954f40afc519a43a0c857c";
+    private static String privateKey = "MIICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGBALATu5WNNx+XcrAS\n" +
+            "NJieGRsY7VryQjcs+pABXGh4BOCqAW3FgAAc21aIG0uxvYHdQUw1I7J80RiQJ506\n" +
+            "aIktGTmZKJTjez7JNF7GO4ieGmLMI3ds8iXyJrfUMp/1U3Cq6vja8vuRIKYVQCxZ\n" +
+            "e8un98Nr03F7oMlKpBydJQKVdlAHAgMBAAECgYBPcqfqhAyCWbCrF5vZ3URQwL+g\n" +
+            "kL0l7kqknaiXjsgMo0j/weTOqDaj5cgDMJDkvvPOsg+IYt9qKOlm/Urb0piVb9v9\n" +
+            "iAnp6gIppcyHrPUesgYRSbqR/HhdGtnzn/4f45YpkXA6URMfc04xBrIUCw5Dmnqo\n" +
+            "nJZJkjd6jjXiL65rYQJBAN8eg99yFH45D2cdlPBTN0LVWXgqy3N22byYh0j6kgo2\n" +
+            "5WOPMcuIZPM/XdSoTfhYeHixvEwrmCAkCmSkf524prECQQDKBnzZRj3eCij1z2SZ\n" +
+            "JCRZhRQUhFmK0AYYTXw9R0DfEaZNrEAe8PEypS94lYROvNV3TnSnK2FHKeH8YhHX\n" +
+            "EoA3AkBRHzMrRrsUuYJUJ3lDd74b2p5RBp46OPgpjfuCGTiH5jW44RNlwQ2TM3LW\n" +
+            "IutWZDRJDbY8q40AApqUxQpxOfXBAkA8bB5RGZoNW7qOcj3jM5UPlSbBUCg7xSXd\n" +
+            "hOdAqJv1W6ECoB75YhSxkggVp5pPtlid+0AWc3n/v74QLwCo86aXAkEAlxY3hoxQ\n" +
+            "jJiCjD2PbL0GLkMKNBqJgLcDWqeoHcal+iY2Fpr3U/iCJZNoBuovC2Qvc5J1y61P\n" +
+            "ojrvFNyFMEkWTQ==";
+    private static String sign = "";
+    private static String time;
+
+    public static void main(String[] args) {
+        time = getTimestamp();
+        String jsonString = "{'ParkingCode':'19000100250504','CarNo':'苏A8M6B2'}";
+
+        TreeMap<String, String> map = new TreeMap();
+        map.put("param", jsonString);
+        map.put("secret", appSecret);
+        map.put("timestamp", time);
+        sign = signWithoutMD5(map);
+        sign = sign(sign, privateKey);
+
+        doJsonPost(url, jsonString);
+    }
+
+    public static String doJsonPost(String urlPath, String Json) {
+        String result = "";
+        BufferedReader reader = null;
+        try {
+            URL url = new URL(urlPath);
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("POST");
+            conn.setDoOutput(true);
+            conn.setDoInput(true);
+            conn.setUseCaches(false);
+            conn.setRequestProperty("Connection", "Keep-Alive");
+            conn.setRequestProperty("Charset", "UTF-8");
+            conn.setRequestProperty("appid", appid);
+            conn.setRequestProperty("appSecret", appSecret);
+            conn.setRequestProperty("sign", sign);
+            conn.setRequestProperty("timestamp", time);
+            // 设置文件类型:
+            conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
+            // 设置接收类型否则返回415错误
+            conn.setRequestProperty("accept", "*/*");// 此处为暴力方法设置接受所有类型，以此来防范返回415;
+            conn.setRequestProperty("accept", "application/json");
+            // 往服务器里面发送数据
+            if (Json != null && !("").equals(Json)) {
+                byte[] writebytes = Json.getBytes();
+                // 设置文件长度
+                conn.setRequestProperty("Content-Length", String.valueOf(writebytes.length));
+                OutputStream outwritestream = (OutputStream) conn.getOutputStream();
+                outwritestream.write(Json.getBytes());
+                outwritestream.flush();
+                outwritestream.close();
+
+            }
+            if (conn.getResponseCode() == 200) {
+                reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+                result = reader.readLine();
+                System.out.println(result);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            if (reader != null) {
+                try {
+                    reader.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return result;
+    }
+
+    public static String getTimestamp() {
+        String time = "";
+        long timestamp = System.currentTimeMillis();
+        time = String.valueOf(timestamp);
+        time = time.substring(0, 10);
+        return time;
+    }
+
+    public static String signWithoutMD5(SortedMap<String, String> params) {
+        String restul = "";
+        if (params == null) {
+            return restul;
+        }
+
+        StringBuilder sb = new StringBuilder();
+        for (Map.Entry<String, String> me : params.entrySet()) {
+
+            sb.append(me.getKey());
+            sb.append('=');
+            sb.append(me.getValue());
+            sb.append('&');
+
+        }
+        int lastIndexOf = sb.lastIndexOf("&");
+        if (lastIndexOf != -1) {
+            sb.deleteCharAt(lastIndexOf);
+        }
+        restul = new String(sb);
+
+        return restul;
+    }
+
+    private static final String ALGORITHM = "RSA";
+    private static final String SIGN_ALGORITHMS = "SHA1WithRSA";
+
+    private static final String DEFAULT_CHARSET = "UTF-8";
+
+    public static String sign(String content, String privateKey) {
+        try {
+            PKCS8EncodedKeySpec priPKCS8 = new PKCS8EncodedKeySpec(Base64.decode(privateKey));
+            KeyFactory keyf = KeyFactory.getInstance(ALGORITHM);
+
+            PrivateKey priKey = keyf.generatePrivate(priPKCS8);
+
+            java.security.Signature signature = java.security.Signature.getInstance(SIGN_ALGORITHMS);
+
+            signature.initSign(priKey);
+            signature.update(content.getBytes(DEFAULT_CHARSET));
+
+            byte[] signed = signature.sign();
+
+            return Base64.encode(signed);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return null;
+    }
+
+
+}

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

@@ -53,7 +53,7 @@ public class HKConstant {
     public static final String ITF_ADDRESS_GET_CAMERAS = "/openapi/service/vss/res/getCameras";
 
     /**
-     * 查询监控点地址
+     * 操作用户的UUID
      */
     public static final String OP_USER_UUID = "5b2eb534696b11e89c2e438f92627767";
 

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

@@ -98,7 +98,7 @@ public class HKOpenApi {
     public static String addUser(Map<String,Object> map){
         Map<String,Object> parMap = Maps.newHashMap();
         String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.ITF_ADD_USER;
-        //设置APPKEY
+        //设置APPKEY获取中心信息
         parMap.put("appkey", HKConstant.APPKEY);
         //设置时间参数
         parMap.put("time", System.currentTimeMillis());
@@ -953,7 +953,28 @@ public class HKOpenApi {
 
     public static void main(String[] args) {
         // getDefaultUserUuid();
-        downloadFaceAndFingerInfos("2227");
+        Map<String,Object> parMap = Maps.newHashMap();
+        String url = "http://pingtai.vipgz1.idcfengye.com" + HKConstant.ITF_MONITORY_POINT;
+        //设置APPKEY
+        parMap.put("appkey", "d30396a0");
+        //设置时间参数
+        parMap.put("time", System.currentTimeMillis());
+        parMap.put("pageNo","1");
+        parMap.put("pageSize","100");
+        parMap.put("opUserUuid","5b2eb534696b11e89c2e438f92627767");
+        parMap.put("unitUuids","1048576");
+        String params =  JSON.toJSONString(parMap);
+        log.info("获取 监控列表 请求参数：{}", params);
+        String data = null;
+        try {
+            data = HttpClientSSLUtils.doPost(url + "?token=" + Digests.buildToken(url + "?" + params, params, "6a939cf0b2914004a2755e70c6c96e02"), params);
+            log.info("获取 监控列表 请求返回结果：{}",data);
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("获取监控列表失败!",e);
+            throw new RuntimeException("获取监控列表失败!");
+        }
+
     }
 
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/dao/TpEquipmentMapper.java

@@ -1,10 +1,7 @@
 package com.community.huiju.dao;
 
 import com.community.huiju.model.TpEquipment;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
-import org.apache.ibatis.annotations.ResultType;
-import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.*;
 
 import java.util.List;
 
@@ -27,9 +24,9 @@ public interface TpEquipmentMapper {
      * @param communityId
      * @return
      */
-    @ResultType(TpEquipment.class)
+    @ResultMap("BaseResultMap")
     @Select("select " +
-            "tm.id as id, " +
+            "tm.*, " +
             "(select configuration_value FROM tp_configuration WHERE id = tm.url_id) as monitoringUrl, " +
             "(select configuration_value FROM tp_configuration WHERE id = tm.security_guard_tel_id) as securityGuardTel, " +
             "(select configuration_value FROM tp_configuration WHERE id = tm.security_room_tel_id) as securityRoomTel, " +

CODE/smart-community/app-api/src/main/java/com/community/huiju/dao/TpEquipmentTreeMapper.java

@@ -0,0 +1,30 @@
+package com.community.huiju.dao;
+
+import com.community.huiju.model.TpEquipmentTree;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.ResultMap;
+import org.apache.ibatis.annotations.Select;
+
+@Mapper
+public interface TpEquipmentTreeMapper {
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(TpEquipmentTree record);
+
+    int insertSelective(TpEquipmentTree record);
+
+    TpEquipmentTree selectByPrimaryKey(Integer id);
+
+    int updateByPrimaryKeySelective(TpEquipmentTree record);
+
+    int updateByPrimaryKey(TpEquipmentTree record);
+
+    /**
+     * 根据小区查询
+     * @param communityId
+     * @return
+     */
+    @ResultMap("BaseResultMap")
+    @Select("select * from tp_equipment_tree where community_id = #{communityId}")
+    TpEquipmentTree selectByCommunityId(Integer communityId);
+}

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

@@ -1,5 +1,7 @@
 package com.community.huiju.model;
 
+import com.alibaba.fastjson.annotation.JSONField;
+
 import java.util.Date;
 
 public class TpEquipment {
@@ -28,6 +30,36 @@ public class TpEquipment {
     private String equipmentType;
 
     private Integer equipmentTreeId;
+
+    /**
+     * 这个值不返回给客户端
+     */
+    @JSONField(serialize = false)
+    private String appkey;
+
+    /**
+     * 这个值不返回给客户端
+     */
+    @JSONField(serialize = false)
+    private String secret;
+
+    /**
+     * 这个值不返回给客户端
+     */
+    @JSONField(serialize = false)
+    private String opUserUuid;
+
+    /**
+     * 这个值不返回给客户端
+     */
+    @JSONField(serialize = false)
+    private String httpServer;
+
+    /**
+     * 这个值不返回给客户端
+     */
+    @JSONField(serialize = false)
+    private String unitUuids;
     // ====================================
 
     /**
@@ -185,4 +217,44 @@ public class TpEquipment {
     public void setMonitoringAddress(String monitoringAddress) {
         this.monitoringAddress = monitoringAddress;
     }
+
+    public String getAppkey() {
+        return appkey;
+    }
+
+    public void setAppkey(String appkey) {
+        this.appkey = appkey;
+    }
+
+    public String getSecret() {
+        return secret;
+    }
+
+    public void setSecret(String secret) {
+        this.secret = secret;
+    }
+
+    public String getOpUserUuid() {
+        return opUserUuid;
+    }
+
+    public void setOpUserUuid(String opUserUuid) {
+        this.opUserUuid = opUserUuid;
+    }
+
+    public String getHttpServer() {
+        return httpServer;
+    }
+
+    public void setHttpServer(String httpServer) {
+        this.httpServer = httpServer;
+    }
+
+    public String getUnitUuids() {
+        return unitUuids;
+    }
+
+    public void setUnitUuids(String unitUuids) {
+        this.unitUuids = unitUuids;
+    }
 }

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

@@ -0,0 +1,145 @@
+package com.community.huiju.model;
+
+import java.util.Date;
+
+public class TpEquipmentTree {
+    private Integer id;
+
+    private Integer communityId;
+
+    private String equipmentName;
+
+    private Integer pid;
+
+    private Integer sort;
+
+    private Date createTime;
+
+    private Integer createUser;
+
+    private Date updateTime;
+
+    private Integer updateUser;
+
+    private String appkey;
+
+    private String secret;
+
+    private String opUserUuid;
+
+    private String httpServer;
+
+    private String unitUuids;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getCommunityId() {
+        return communityId;
+    }
+
+    public void setCommunityId(Integer communityId) {
+        this.communityId = communityId;
+    }
+
+    public String getEquipmentName() {
+        return equipmentName;
+    }
+
+    public void setEquipmentName(String equipmentName) {
+        this.equipmentName = equipmentName == null ? null : equipmentName.trim();
+    }
+
+    public Integer getPid() {
+        return pid;
+    }
+
+    public void setPid(Integer pid) {
+        this.pid = pid;
+    }
+
+    public Integer getSort() {
+        return sort;
+    }
+
+    public void setSort(Integer sort) {
+        this.sort = sort;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Integer getCreateUser() {
+        return createUser;
+    }
+
+    public void setCreateUser(Integer createUser) {
+        this.createUser = createUser;
+    }
+
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    public Integer getUpdateUser() {
+        return updateUser;
+    }
+
+    public void setUpdateUser(Integer updateUser) {
+        this.updateUser = updateUser;
+    }
+
+    public String getAppkey() {
+        return appkey;
+    }
+
+    public void setAppkey(String appkey) {
+        this.appkey = appkey == null ? null : appkey.trim();
+    }
+
+    public String getSecret() {
+        return secret;
+    }
+
+    public void setSecret(String secret) {
+        this.secret = secret == null ? null : secret.trim();
+    }
+
+    public String getOpUserUuid() {
+        return opUserUuid;
+    }
+
+    public void setOpUserUuid(String opUserUuid) {
+        this.opUserUuid = opUserUuid == null ? null : opUserUuid.trim();
+    }
+
+    public String getHttpServer() {
+        return httpServer;
+    }
+
+    public void setHttpServer(String httpServer) {
+        this.httpServer = httpServer == null ? null : httpServer.trim();
+    }
+
+    public String getUnitUuids() {
+        return unitUuids;
+    }
+
+    public void setUnitUuids(String unitUuids) {
+        this.unitUuids = unitUuids;
+    }
+}

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

@@ -1,15 +1,20 @@
 package com.community.huiju.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.community.commom.hk.Digests;
+import com.community.commom.hk.HttpClientSSLUtils;
 import com.community.commom.mode.ResponseBean;
 import com.community.huiju.common.hk.HKConstant;
+import com.community.huiju.common.hk.HKOpenApi;
 import com.community.huiju.dao.TpEquipmentMapper;
+import com.community.huiju.dao.TpEquipmentTreeMapper;
 import com.community.huiju.model.TpEquipment;
+import com.community.huiju.model.TpEquipmentTree;
 import com.community.huiju.service.IMonitoringService;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
 import com.google.common.collect.Maps;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -27,6 +32,9 @@ public class MonitoringServiceImpl implements IMonitoringService {
     @Autowired
     private TpEquipmentMapper tpEquipmentMapper;
 
+    @Autowired
+    private TpEquipmentTreeMapper tpEquipmentTreeMapper;
+
     @Override
     public ResponseBean getByCommunityId(Integer communityId,Integer pageNo, Integer pageSize) {
 
@@ -68,23 +76,57 @@ public class MonitoringServiceImpl implements IMonitoringService {
     @Override
     public ResponseBean getMonitoringToken(Integer communityId, Integer pageNo, Integer pageSize) {
 
-        // TODO 数据是假数据, 后期在更改. 需要根据小区查询 组织中心编号
+        String appkey = "";
+        String op_user_uuid = "";
+        String secret = "";
+        String openapi_ip_port_http = "";
+        String unitUuids = "";
+
+        /**
+         * 先检测设备 的appkey，op_user_uuid， secret 是否有值
+         * 如果有值，则使用 设备里面的参数
+         */
+
+        Page<TpEquipment> page = PageHelper.startPage(pageNo, pageSize);
+        List<TpEquipment> tpEquipments = tpEquipmentMapper.selectByCommunityId(communityId);
+        if (!tpEquipments.isEmpty()) {
+            TpEquipment equipment = tpEquipments.get(0);
+            if (StringUtils.isNotBlank(equipment.getAppkey()) && StringUtils.isNotBlank(equipment.getOpUserUuid()) && StringUtils.isNotBlank(equipment.getSecret())) {
+                appkey = equipment.getAppkey();
+                op_user_uuid = equipment.getOpUserUuid();
+                secret = equipment.getSecret();
+                openapi_ip_port_http = equipment.getHttpServer();
+                unitUuids = equipment.getUnitUuids();
+            }
+        }
+
+        TpEquipmentTree tpEquipmentTree = tpEquipmentTreeMapper.selectByCommunityId(communityId);
+        // 如果设备里面没有值
+        if (StringUtils.isBlank(appkey) && StringUtils.isBlank(op_user_uuid) && StringUtils.isBlank(secret)) {
+            appkey = tpEquipmentTree.getAppkey();
+            op_user_uuid = tpEquipmentTree.getOpUserUuid();
+            secret = tpEquipmentTree.getSecret();
+            openapi_ip_port_http = tpEquipmentTree.getHttpServer();
+            unitUuids = tpEquipmentTree.getUnitUuids();
+        }
+
 
         ResponseBean response = new ResponseBean();
         Map<String,Object> parMap = Maps.newHashMap();
-        String url = HKConstant.OPENAPI_IP_PORT_HTTP + HKConstant.ITF_MONITORY_POINT;
+        String url = openapi_ip_port_http + HKConstant.ITF_MONITORY_POINT;
         //设置APPKEY
-        parMap.put("appkey", HKConstant.APPKEY);
+        parMap.put("appkey", appkey);
         //设置时间参数
         parMap.put("time", System.currentTimeMillis());
         parMap.put("pageNo",pageNo);
         parMap.put("pageSize",pageSize);
         // 这里可以设置其他操作用户 parMap.put("opUserUuid",map.get("opUserUuid") == null?HKConstant.OP_USER_UUID:map.get("opUserUuid"));
-        parMap.put("opUserUuid",HKConstant.OP_USER_UUID);
+        parMap.put("opUserUuid",op_user_uuid);
         // 组织中心编号
-        parMap.put("unitUuids","1048576");
+        // parMap.put("unitUuids","1048576");
+        parMap.put("unitUuids",unitUuids);
         String params =  JSON.toJSONString(parMap);
-        String token = Digests.buildToken(url + "?" + params, params, HKConstant.SECRET);
+        String token = Digests.buildToken(url + "?" + params, params, secret);
 
         Map<String, Object> map = Maps.newHashMap();
         map.put("token",token);

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

@@ -15,10 +15,20 @@
     <result column="uuid_id" property="uuidId" jdbcType="INTEGER" />
     <result column="equipment_type" property="equipmentType" jdbcType="VARCHAR" />
     <result column="equipment_tree_id" property="equipmentTreeId" jdbcType="INTEGER" />
+    <result column="appkey" property="appkey" jdbcType="VARCHAR" />
+    <result column="secret" property="secret" jdbcType="VARCHAR" />
+    <result column="op_user_uuid" property="opUserUuid" jdbcType="VARCHAR" />
+    <result column="http_server" property="httpServer" jdbcType="VARCHAR" />
+    <result column="unit_uuids" property="unitUuids" jdbcType="VARCHAR" />
+    <result column="monitoringUrl" property="monitoringUrl" />
+    <result column="securityGuardTel" property="securityGuardTel" />
+    <result column="securityRoomTel" property="securityRoomTel" />
+    <result column="monitoringAddress" property="monitoringAddress" />
   </resultMap>
   <sql id="Base_Column_List" >
     id, url_id, community_id, security_guard_tel_id, security_room_tel_id, address_id,
-    create_time, create_user, update_time, update_user, uuid_id, equipment_type, equipment_tree_id
+    create_time, create_user, update_time, update_user, uuid_id, equipment_type, equipment_tree_id,
+    appkey, secret, op_user_uuid, http_server, unit_uuids
   </sql>
   <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
     select
@@ -35,12 +45,16 @@
       security_guard_tel_id, security_room_tel_id,
       address_id, create_time, create_user,
       update_time, update_user, uuid_id,
-      equipment_type, equipment_tree_id)
+      equipment_type, equipment_tree_id, appkey,
+      secret, op_user_uuid, http_server,
+      unit_uuids)
     values (#{id,jdbcType=INTEGER}, #{urlId,jdbcType=INTEGER}, #{communityId,jdbcType=INTEGER},
       #{securityGuardTelId,jdbcType=INTEGER}, #{securityRoomTelId,jdbcType=INTEGER},
       #{addressId,jdbcType=INTEGER}, #{createTime,jdbcType=TIMESTAMP}, #{createUser,jdbcType=INTEGER},
       #{updateTime,jdbcType=TIMESTAMP}, #{updateUser,jdbcType=INTEGER}, #{uuidId,jdbcType=INTEGER},
-      #{equipmentType,jdbcType=VARCHAR}, #{equipmentTreeId,jdbcType=INTEGER})
+      #{equipmentType,jdbcType=VARCHAR}, #{equipmentTreeId,jdbcType=INTEGER}, #{appkey,jdbcType=VARCHAR},
+      #{secret,jdbcType=VARCHAR}, #{opUserUuid,jdbcType=VARCHAR}, #{httpServer,jdbcType=VARCHAR},
+      #{unitUuids,jdbcType=VARCHAR})
   </insert>
   <insert id="insertSelective" parameterType="com.community.huiju.model.TpEquipment" >
     insert into tp_equipment
@@ -84,6 +98,21 @@
       <if test="equipmentTreeId != null" >
         equipment_tree_id,
       </if>
+      <if test="appkey != null" >
+        appkey,
+      </if>
+      <if test="secret != null" >
+        secret,
+      </if>
+      <if test="opUserUuid != null" >
+        op_user_uuid,
+      </if>
+      <if test="httpServer != null" >
+        http_server,
+      </if>
+      <if test="unitUuids != null" >
+        unit_uuids,
+      </if>
     </trim>
     <trim prefix="values (" suffix=")" suffixOverrides="," >
       <if test="id != null" >
@@ -125,6 +154,21 @@
       <if test="equipmentTreeId != null" >
         #{equipmentTreeId,jdbcType=INTEGER},
       </if>
+      <if test="appkey != null" >
+        #{appkey,jdbcType=VARCHAR},
+      </if>
+      <if test="secret != null" >
+        #{secret,jdbcType=VARCHAR},
+      </if>
+      <if test="opUserUuid != null" >
+        #{opUserUuid,jdbcType=VARCHAR},
+      </if>
+      <if test="httpServer != null" >
+        #{httpServer,jdbcType=VARCHAR},
+      </if>
+      <if test="unitUuids != null" >
+        #{unitUuids,jdbcType=VARCHAR},
+      </if>
     </trim>
   </insert>
   <update id="updateByPrimaryKeySelective" parameterType="com.community.huiju.model.TpEquipment" >
@@ -166,6 +210,21 @@
       <if test="equipmentTreeId != null" >
         equipment_tree_id = #{equipmentTreeId,jdbcType=INTEGER},
       </if>
+      <if test="appkey != null" >
+        appkey = #{appkey,jdbcType=VARCHAR},
+      </if>
+      <if test="secret != null" >
+        secret = #{secret,jdbcType=VARCHAR},
+      </if>
+      <if test="opUserUuid != null" >
+        op_user_uuid = #{opUserUuid,jdbcType=VARCHAR},
+      </if>
+      <if test="httpServer != null" >
+        http_server = #{httpServer,jdbcType=VARCHAR},
+      </if>
+      <if test="unitUuids != null" >
+        unit_uuids = #{unitUuids,jdbcType=VARCHAR},
+      </if>
     </set>
     where id = #{id,jdbcType=INTEGER}
   </update>
@@ -182,7 +241,12 @@
       update_user = #{updateUser,jdbcType=INTEGER},
       uuid_id = #{uuidId,jdbcType=INTEGER},
       equipment_type = #{equipmentType,jdbcType=VARCHAR},
-      equipment_tree_id = #{equipmentTreeId,jdbcType=INTEGER}
+      equipment_tree_id = #{equipmentTreeId,jdbcType=INTEGER},
+      appkey = #{appkey,jdbcType=VARCHAR},
+      secret = #{secret,jdbcType=VARCHAR},
+      op_user_uuid = #{opUserUuid,jdbcType=VARCHAR},
+      http_server = #{httpServer,jdbcType=VARCHAR},
+      unit_uuids = #{unitUuids,jdbcType=VARCHAR}
     where id = #{id,jdbcType=INTEGER}
   </update>
 </mapper>

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

@@ -0,0 +1,199 @@
+<?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.TpEquipmentTreeMapper" >
+  <resultMap id="BaseResultMap" type="com.community.huiju.model.TpEquipmentTree" >
+    <id column="id" property="id" jdbcType="INTEGER" />
+    <result column="community_id" property="communityId" jdbcType="INTEGER" />
+    <result column="equipment_name" property="equipmentName" jdbcType="VARCHAR" />
+    <result column="pid" property="pid" jdbcType="INTEGER" />
+    <result column="sort" property="sort" jdbcType="INTEGER" />
+    <result column="create_time" property="createTime" jdbcType="TIMESTAMP" />
+    <result column="create_user" property="createUser" jdbcType="INTEGER" />
+    <result column="update_time" property="updateTime" jdbcType="TIMESTAMP" />
+    <result column="update_user" property="updateUser" jdbcType="INTEGER" />
+    <result column="appkey" property="appkey" jdbcType="VARCHAR" />
+    <result column="secret" property="secret" jdbcType="VARCHAR" />
+    <result column="op_user_uuid" property="opUserUuid" jdbcType="VARCHAR" />
+    <result column="http_server" property="httpServer" jdbcType="VARCHAR" />
+    <result column="unit_uuids" property="unitUuids" jdbcType="VARCHAR" />
+  </resultMap>
+  <sql id="Base_Column_List" >
+    id, community_id, equipment_name, pid, sort, create_time, create_user, update_time,
+    update_user, appkey, secret, op_user_uuid, http_server, unit_uuids
+  </sql>
+  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
+    select
+    <include refid="Base_Column_List" />
+    from tp_equipment_tree
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
+    delete from tp_equipment_tree
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.community.huiju.model.TpEquipmentTree" >
+    insert into tp_equipment_tree (id, community_id, equipment_name,
+      pid, sort, create_time,
+      create_user, update_time, update_user,
+      appkey, secret, op_user_uuid,
+      http_server, unit_uuids)
+    values (#{id,jdbcType=INTEGER}, #{communityId,jdbcType=INTEGER}, #{equipmentName,jdbcType=VARCHAR},
+      #{pid,jdbcType=INTEGER}, #{sort,jdbcType=INTEGER}, #{createTime,jdbcType=TIMESTAMP},
+      #{createUser,jdbcType=INTEGER}, #{updateTime,jdbcType=TIMESTAMP}, #{updateUser,jdbcType=INTEGER},
+      #{appkey,jdbcType=VARCHAR}, #{secret,jdbcType=VARCHAR}, #{opUserUuid,jdbcType=VARCHAR},
+      #{httpServer,jdbcType=VARCHAR}, #{unitUuids,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.community.huiju.model.TpEquipmentTree" >
+    insert into tp_equipment_tree
+    <trim prefix="(" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        id,
+      </if>
+      <if test="communityId != null" >
+        community_id,
+      </if>
+      <if test="equipmentName != null" >
+        equipment_name,
+      </if>
+      <if test="pid != null" >
+        pid,
+      </if>
+      <if test="sort != null" >
+        sort,
+      </if>
+      <if test="createTime != null" >
+        create_time,
+      </if>
+      <if test="createUser != null" >
+        create_user,
+      </if>
+      <if test="updateTime != null" >
+        update_time,
+      </if>
+      <if test="updateUser != null" >
+        update_user,
+      </if>
+      <if test="appkey != null" >
+        appkey,
+      </if>
+      <if test="secret != null" >
+        secret,
+      </if>
+      <if test="opUserUuid != null" >
+        op_user_uuid,
+      </if>
+      <if test="httpServer != null" >
+        http_server,
+      </if>
+      <if test="unitUuids != null" >
+        unit_uuids,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="communityId != null" >
+        #{communityId,jdbcType=INTEGER},
+      </if>
+      <if test="equipmentName != null" >
+        #{equipmentName,jdbcType=VARCHAR},
+      </if>
+      <if test="pid != null" >
+        #{pid,jdbcType=INTEGER},
+      </if>
+      <if test="sort != null" >
+        #{sort,jdbcType=INTEGER},
+      </if>
+      <if test="createTime != null" >
+        #{createTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="createUser != null" >
+        #{createUser,jdbcType=INTEGER},
+      </if>
+      <if test="updateTime != null" >
+        #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateUser != null" >
+        #{updateUser,jdbcType=INTEGER},
+      </if>
+      <if test="appkey != null" >
+        #{appkey,jdbcType=VARCHAR},
+      </if>
+      <if test="secret != null" >
+        #{secret,jdbcType=VARCHAR},
+      </if>
+      <if test="opUserUuid != null" >
+        #{opUserUuid,jdbcType=VARCHAR},
+      </if>
+      <if test="httpServer != null" >
+        #{httpServer,jdbcType=VARCHAR},
+      </if>
+      <if test="unitUuids != null" >
+        #{unitUuids,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.community.huiju.model.TpEquipmentTree" >
+    update tp_equipment_tree
+    <set >
+      <if test="communityId != null" >
+        community_id = #{communityId,jdbcType=INTEGER},
+      </if>
+      <if test="equipmentName != null" >
+        equipment_name = #{equipmentName,jdbcType=VARCHAR},
+      </if>
+      <if test="pid != null" >
+        pid = #{pid,jdbcType=INTEGER},
+      </if>
+      <if test="sort != null" >
+        sort = #{sort,jdbcType=INTEGER},
+      </if>
+      <if test="createTime != null" >
+        create_time = #{createTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="createUser != null" >
+        create_user = #{createUser,jdbcType=INTEGER},
+      </if>
+      <if test="updateTime != null" >
+        update_time = #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateUser != null" >
+        update_user = #{updateUser,jdbcType=INTEGER},
+      </if>
+      <if test="appkey != null" >
+        appkey = #{appkey,jdbcType=VARCHAR},
+      </if>
+      <if test="secret != null" >
+        secret = #{secret,jdbcType=VARCHAR},
+      </if>
+      <if test="opUserUuid != null" >
+        op_user_uuid = #{opUserUuid,jdbcType=VARCHAR},
+      </if>
+      <if test="httpServer != null" >
+        http_server = #{httpServer,jdbcType=VARCHAR},
+      </if>
+      <if test="unitUuids != null" >
+        unit_uuids = #{unitUuids,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.community.huiju.model.TpEquipmentTree" >
+    update tp_equipment_tree
+    set community_id = #{communityId,jdbcType=INTEGER},
+      equipment_name = #{equipmentName,jdbcType=VARCHAR},
+      pid = #{pid,jdbcType=INTEGER},
+      sort = #{sort,jdbcType=INTEGER},
+      create_time = #{createTime,jdbcType=TIMESTAMP},
+      create_user = #{createUser,jdbcType=INTEGER},
+      update_time = #{updateTime,jdbcType=TIMESTAMP},
+      update_user = #{updateUser,jdbcType=INTEGER},
+      appkey = #{appkey,jdbcType=VARCHAR},
+      secret = #{secret,jdbcType=VARCHAR},
+      op_user_uuid = #{opUserUuid,jdbcType=VARCHAR},
+      http_server = #{httpServer,jdbcType=VARCHAR},
+      unit_uuids = #{unitUuids,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+</mapper>