fea: 测试接口添加

Hugiee.Liu
1 parent 009374ed
Showing 35 changed files with 1429 additions and 180 deletions
pom.xml
src/main/java/com/objecteye/config/ApplicationConfigurationProperties.java → src/main/java/com/objecteye/config/Gat1400Properties.java
src/main/java/com/objecteye/config/ObjectMapperConfigure.java
src/main/java/com/objecteye/content/VIIDApi.java
src/main/java/com/objecteye/content/VIIDContent.java
src/main/java/com/objecteye/content/ViidCollectorRedisKey.java
src/main/java/com/objecteye/controller/SubscribeController.java
src/main/java/com/objecteye/controller/SystemController.java
src/main/java/com/objecteye/handle/StartUpAndShutdown.java
src/main/java/com/objecteye/handle/viid/CommonHandle.java
src/main/java/com/objecteye/handle/viid/SubscribeHandle.java
src/main/java/com/objecteye/handle/viid/VIIDCommonHandle.java
src/main/java/com/objecteye/pojo/platform/DeviceRequestParams.java → src/main/java/com/objecteye/pojo/DeviceIdParams.java
src/main/java/com/objecteye/pojo/Result.java
src/main/java/com/objecteye/pojo/viid/common/KeepaliveRequestObject.java
src/main/java/com/objecteye/pojo/viid/common/CommonDeviceIdRequestParams.java → src/main/java/com/objecteye/pojo/viid/common/RegisterObject.java
src/main/java/com/objecteye/pojo/viid/common/RegisterRequestObject.java
src/main/java/com/objecteye/pojo/viid/common/ResponseStatusResponse.java → src/main/java/com/objecteye/pojo/viid/common/ResponseStatus.java
src/main/java/com/objecteye/pojo/viid/common/ResponseStatusListObject.java
src/main/java/com/objecteye/pojo/viid/common/ResponseStatusObjectWrapper.java
@@ -6,7 +6,7 @@
     <groupId>com.objecteye</groupId>
     <artifactId>viid-collector</artifactId>
-    <version>1.0-SNAPSHOT</version>
+    <version>1.0</version>
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
@@ -49,14 +49,6 @@
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
         <dependency>
-            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
-        </dependency>
-        <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
@@ -72,5 +64,41 @@
             <groupId>org.apache.commons</groupId>
             <artifactId>commons-pool2</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>commons-codec</groupId>
+            <artifactId>commons-codec</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+        </dependency>
     </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <configuration>
+                    <finalName>viid-collector</finalName>
+                    <mainClass>com.objecteye.VIIDCollectorApplication</mainClass>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 </project>
 \ No newline at end of file
@@ -2,16 +2,22 @@ package com.objecteye.config;
 import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.stereotype.Component;
+import org.springframework.context.annotation.Configuration;
 /**
  * @author: liuhaoyu
- * @date: 2023/6/28
+ * @date: 2023/7/5
  */
 @Data
-@Component
-@ConfigurationProperties(prefix = "config.application")
-public class ApplicationConfigurationProperties {
+@Configuration
+@ConfigurationProperties(prefix = "gat1400")
+public class Gat1400Properties {
-    private String platformCode;
+    private String serverAddress;
+
+    private Integer port;
+
+    private String accessKey;
+
+    private String securityKey;
 }
-package com.objecteye.config;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import lombok.Data;
-import org.springframework.context.annotation.Bean;
-
-/**
- * @author: liuhaoyu
- * @date: 2023/6/28
- */
-@Data
-public class ObjectMapperConfigure {
-
-    @Bean
-    public ObjectMapper objectMapper() {
-        return new ObjectMapper();
-    }
-}
@@ -6,7 +6,8 @@ package com.objecteye.content;
  */
 public class VIIDApi {
-    public static final String SYSTEM_PREFIX = "/VIID/System";
+    private static final String VIID = "/VIID";
+    public static final String SYSTEM_PREFIX = VIID + "/System";
     /**
      * 注册
      */
@@ -19,6 +20,12 @@ public class VIIDApi {
      * 保活
      */
     public static final String KEEPALIVE = SYSTEM_PREFIX + "/Keepalive";
+    /**
+     * 校时
+     */
+    public static final String TIME = SYSTEM_PREFIX + "/Time";
+
+    public static final String SUBSCRIBES = VIID + "/Subscribes";
     private VIIDApi() {
     }
+package com.objecteye.content;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+public class VIIDContent {
+
+    public static final String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
+
+    private VIIDContent() {
+    }
+}
@@ -6,7 +6,7 @@ package com.objecteye.content;
  */
 public class ViidCollectorRedisKey {
     /**
-     * 设备连接信息缓存
+     * 设备订阅信息
      */
     public static final String DEVICE_CACHE = "vc:dc";
+package com.objecteye.controller;
+
+import com.objecteye.handle.viid.SubscribeHandle;
+import com.objecteye.pojo.DeviceIdParams;
+import com.objecteye.pojo.Result;
+import com.objecteye.pojo.viid.subscribe.SubscribeNotificationRequestObject;
+import com.objecteye.utils.JSONUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Slf4j
+@RestController
+@RequiredArgsConstructor
+public class SubscribeController {
+    private final SubscribeHandle subscribeHandle;
+
+    @PostMapping("subscribe")
+    public Result<Boolean> subscribe(@RequestBody @Validated DeviceIdParams params) {
+        return Result.success(subscribeHandle.subscribe(params.getDeviceId()));
+    }
+
+    @PostMapping("receiver")
+    public Result receiver(@RequestBody SubscribeNotificationRequestObject subscribeNotificationRequestObject) {
+        log.info("notification: \n{}", JSONUtils.toPrettyJsonString(subscribeNotificationRequestObject));
+        return Result.success();
+    }
+}
+package com.objecteye.controller;
+
+import com.objecteye.handle.viid.CommonHandle;
+import com.objecteye.pojo.DeviceIdParams;
+import com.objecteye.pojo.Result;
+import lombok.RequiredArgsConstructor;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@RestController
+@RequestMapping("system")
+@RequiredArgsConstructor
+public class SystemController {
+
+    private final CommonHandle commonHandle;
+
+    @PostMapping("register")
+    public Result<Boolean> register(@RequestBody @Validated DeviceIdParams params) {
+        return Result.success(commonHandle.register(params.getDeviceId()));
+    }
+
+    @PostMapping("unregister")
+    public Result<Boolean> unregister(@RequestBody @Validated DeviceIdParams params) {
+        return Result.success(commonHandle.unregister(params.getDeviceId()));
+    }
+
+    @PostMapping("keepalive")
+    public Result<Boolean> keepalive(@RequestBody @Validated DeviceIdParams params) {
+        return Result.success(commonHandle.keepalive(params.getDeviceId()));
+    }
+}
 package com.objecteye.handle;
-import com.alibaba.nacos.common.utils.ExceptionUtil;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.objecteye.content.ViidCollectorRedisKey;
-import com.objecteye.handle.viid.VIIDCommonHandle;
-import com.objecteye.pojo.platform.DeviceRequestParams;
+import com.objecteye.handle.viid.CommonHandle;
 import lombok.RequiredArgsConstructor;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
@@ -26,32 +21,25 @@ import java.util.function.Consumer;
 @Component
 @RequiredArgsConstructor
 public class StartUpAndShutdown implements DisposableBean, ApplicationRunner {
-    private final VIIDCommonHandle viidCommonHandle;
+    private final CommonHandle commonHandle;
     private final StringRedisTemplate stringRedisTemplate;
-    private final ObjectMapper objectMapper;
-
-    private final Logger logger = LoggerFactory.getLogger(StartUpAndShutdown.class);
     @Override
     public void destroy() throws Exception {
-        allCacheHandle(viidCommonHandle::unregister);
+        allCacheHandle(commonHandle::unregister);
     }
     @Override
     public void run(ApplicationArguments args) throws Exception {
-        allCacheHandle(viidCommonHandle::register);
+        allCacheHandle(commonHandle::register);
     }
-    private void allCacheHandle(Consumer<DeviceRequestParams> func) {
+    private void allCacheHandle(Consumer<String> func) {
         try (Cursor<Map.Entry<Object, Object>> cursor = stringRedisTemplate.boundHashOps(ViidCollectorRedisKey.DEVICE_CACHE)
                 .scan(ScanOptions.scanOptions().build())) {
             while (cursor.hasNext()) {
                 Map.Entry<Object, Object> entry = cursor.next();
-                try {
-                    func.accept(objectMapper.readValue(entry.getValue().toString(), DeviceRequestParams.class));
-                } catch (Exception e) {
-                    logger.error(ExceptionUtil.getAllExceptionMsg(e));
-                }
+                func.accept(entry.getKey().toString());
             }
         }
     }
+package com.objecteye.handle.viid;
+
+import com.objecteye.config.Gat1400Properties;
+import com.objecteye.content.VIIDApi;
+import com.objecteye.pojo.viid.common.KeepaliveRequestObject;
+import com.objecteye.pojo.viid.common.RegisterObject;
+import com.objecteye.pojo.viid.common.RegisterRequestObject;
+import com.objecteye.pojo.viid.common.UnRegisterRequestObject;
+import com.objecteye.utils.DigestUtils;
+import com.objecteye.utils.JSONUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/6/28
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class CommonHandle {
+    private final RestTemplate restTemplate;
+    private final Gat1400Properties gat1400Properties;
+    private static final String HTTP = "http://";
+
+    /**
+     * 注册
+     *
+     * @param deviceId 注册目标设备
+     * @return 注册结果
+     */
+    public boolean register(String deviceId) {
+        // 请求参数设置
+        RegisterRequestObject registerRequestObject = new RegisterRequestObject();
+        RegisterObject registerObject = new RegisterObject();
+        registerObject.setDeviceId(deviceId);
+        registerRequestObject.setRegisterObject(registerObject);
+        return twoStepCheck(VIIDApi.REGISTER, deviceId, JSONUtils.toJsonString(registerRequestObject));
+    }
+
+    /**
+     * 保活
+     *
+     * @param deviceId 心跳目标设备
+     * @return 发送结果
+     */
+    public boolean keepalive(String deviceId) {
+        String keepaliveUrl = getAddress() + VIIDApi.KEEPALIVE;
+        // 请求参数设置
+        KeepaliveRequestObject keepaliveRequestObject = new KeepaliveRequestObject();
+        RegisterObject keepaliveObject = new RegisterObject();
+        keepaliveObject.setDeviceId(deviceId);
+        keepaliveRequestObject.setKeepaliveObject(keepaliveObject);
+        if (log.isDebugEnabled()) {
+            log.debug("保活请求 url:{} ,参数：{}", keepaliveUrl, keepaliveRequestObject);
+        }
+
+        HttpEntity<String> httpEntity = new HttpEntity<>(JSONUtils.toJsonString(keepaliveRequestObject),
+                buildRequestHttpHeader(deviceId));
+        // 请求执行
+        ResponseEntity<String> responseEntity = postForEntity(keepaliveUrl, httpEntity);
+        return org.apache.http.HttpStatus.SC_OK == responseEntity.getStatusCode().value();
+    }
+
+    /**
+     * 注销
+     *
+     * @param deviceId 注销目标设备
+     * @return 注销结果
+     */
+    public boolean unregister(String deviceId) {
+        // 请求参数设置
+        UnRegisterRequestObject unRegisterRequestObject = new UnRegisterRequestObject();
+        RegisterObject unRegisterObject = new RegisterObject();
+        unRegisterObject.setDeviceId(deviceId);
+        unRegisterRequestObject.setUnRegisterObject(unRegisterObject);
+        return twoStepCheck(VIIDApi.UNREGISTER, deviceId, JSONUtils.toJsonString(unRegisterRequestObject));
+    }
+
+    private String getAddress() {
+        return HTTP + gat1400Properties.getServerAddress() + ":" + gat1400Properties.getPort();
+    }
+
+    private HttpHeaders buildRequestHttpHeader(String deviceId) {
+        // 请求头设置
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json;charset=UTF-8");
+        headers.set("User-Identify", deviceId);
+        headers.setConnection("keepalive");
+        return headers;
+    }
+
+    private ResponseEntity<String> postForEntity(String url, HttpEntity<String> httpEntity) {
+        return restTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+    }
+
+    private boolean twoStepCheck(String uri, String deviceId, String requestJson) {
+        String url = getAddress() + uri;
+        // 请求头设置
+        HttpHeaders headers = buildRequestHttpHeader(deviceId);
+        // 第一次请求
+        ResponseEntity<String> responseEntity = postForEntity(url, new HttpEntity<>(requestJson, headers));
+        if (org.apache.http.HttpStatus.SC_UNAUTHORIZED == responseEntity.getStatusCode().value()) {
+            headers.set("Authorization", getAuthorization(responseEntity, url));
+            // 第二次请求
+            responseEntity = postForEntity(url, new HttpEntity<>(requestJson, headers));
+            return org.apache.http.HttpStatus.SC_OK == responseEntity.getStatusCode().value();
+        }
+        return false;
+    }
+
+    private String getAuthorization(ResponseEntity<String> responseEntity, String url) {
+        HttpHeaders responseEntityHeaders = responseEntity.getHeaders();
+        String authenticate = responseEntityHeaders.get("WWW-Authenticate").get(0);
+        String[] children = authenticate.split(",");
+        String realm = null, qop = null, nonce = null, opaque = null, method = "POST";
+        for (String item : children) {
+            String[] itemEntry = item.split("=");
+            if ("Digest realm".equals(itemEntry[0])) {
+                realm = itemEntry[1].replaceAll("\"", "");
+            } else if ("qop".equals(itemEntry[0])) {
+                qop = itemEntry[1].replaceAll("\"", "");
+            } else if ("nonce".equals(itemEntry[0])) {
+                nonce = itemEntry[1].replaceAll("\"", "");
+            }
+        }
+        String nc = "00000001";
+        String cnonce = DigestUtils.generateSalt2(8);
+        String response = DigestUtils.getResponse(gat1400Properties.getAccessKey(), realm, gat1400Properties.getSecurityKey(),
+                nonce, nc, cnonce, qop, method, url);
+        return DigestUtils.getAuthorization(gat1400Properties.getAccessKey(), realm, nonce,
+                url, qop, nc, cnonce, response, opaque);
+    }
+}
+package com.objecteye.handle.viid;
+
+import com.objecteye.config.Gat1400Properties;
+import com.objecteye.content.VIIDApi;
+import com.objecteye.content.ViidCollectorRedisKey;
+import com.objecteye.pojo.viid.subscribe.Subscribe;
+import com.objecteye.pojo.viid.subscribe.SubscribeRequestObject;
+import com.objecteye.utils.JSONUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class SubscribeHandle {
+    private final StringRedisTemplate stringRedisTemplate;
+    private final Gat1400Properties gat1400Properties;
+    private final RestTemplate restTemplate;
+    @Value("${receiver}")
+    private String receiver;
+
+    public boolean subscribe(String deviceId) {
+        // 订阅统一标识码 = 公安机关机构代码 + 子类型编码（03-订阅）+ 时间编码（YYYYMMDDhhmmss） + 流水序号（00001）
+        String time = DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS").format(LocalDateTime.now());
+        String toSecond = time.substring(0, 14);
+        String toMill = time.substring(14);
+        String subscribeId = "123456789012" + "03" + toSecond + StringUtils.leftPad(toMill, 5, "0");
+        String title = "订阅人脸识别、车牌识别消息";
+        // 订阅类别: 12-人脸信息 13-车辆信息
+        String subscribeDetail = "12,13";
+
+        String beginTime = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(LocalDateTime.now());
+
+        String endTime = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(LocalDateTime.now().plusMinutes(10L));
+
+        Integer operateType = 0;
+
+        SubscribeRequestObject subscribeRequestObject = new SubscribeRequestObject();
+        SubscribeRequestObject.SubscribeListObject subscribeListObject = new SubscribeRequestObject.SubscribeListObject();
+        subscribeRequestObject.setSubscribeListObject(subscribeListObject);
+
+        List<Subscribe> subscribeList = new ArrayList<>();
+
+        Subscribe subscribe = new Subscribe();
+        subscribe.setSubscribeId(subscribeId);
+        subscribe.setTitle(title);
+        subscribe.setSubscribeDetail(subscribeDetail);
+        subscribe.setResourceUri(deviceId);
+        subscribe.setBeginTime(beginTime);
+        subscribe.setEndTime(endTime);
+        subscribe.setReceiveAddr(receiver);
+        subscribe.setOperateType(operateType);
+        subscribeList.add(subscribe);
+        subscribeListObject.setSubscribeObject(subscribeList);
+
+        HttpEntity<String> httpEntity = new HttpEntity<>(JSONUtils.toJsonString(subscribeRequestObject),
+                buildHttpHeaders(deviceId));
+        if (log.isDebugEnabled()) {
+            log.debug("上传人脸消息体：{}", JSONUtils.toJsonString(subscribeRequestObject));
+        }
+        // 请求执行
+        ResponseEntity<String> responseEntity = restTemplate.exchange(getUrl(VIIDApi.SUBSCRIBES), HttpMethod.POST,
+                httpEntity, String.class);
+        if (org.apache.http.HttpStatus.SC_OK == responseEntity.getStatusCode().value()) {
+            stringRedisTemplate.opsForHash().put(ViidCollectorRedisKey.DEVICE_CACHE, deviceId, subscribeId);
+            return true;
+        }
+        return false;
+    }
+
+    public boolean unsubscribe(String deviceId) {
+        Object subscribeIdObj = stringRedisTemplate.opsForHash().get(ViidCollectorRedisKey.DEVICE_CACHE, deviceId);
+        if (null == subscribeIdObj) {
+            return false;
+        }
+        SubscribeRequestObject subscribeRequestObject = new SubscribeRequestObject();
+        SubscribeRequestObject.SubscribeListObject subscribeListObject = new SubscribeRequestObject.SubscribeListObject();
+        subscribeRequestObject.setSubscribeListObject(subscribeListObject);
+
+        List<Subscribe> subscribeList = new ArrayList<>();
+
+        Subscribe subscribe = new Subscribe();
+        subscribe.setSubscribeId(subscribeIdObj.toString());
+        subscribe.setOperateType(1);
+        subscribeList.add(subscribe);
+        subscribeListObject.setSubscribeObject(subscribeList);
+
+        HttpEntity<String> httpEntity = new HttpEntity<>(JSONUtils.toJsonString(subscribeRequestObject),
+                buildHttpHeaders(deviceId));
+        ResponseEntity<String> responseEntity = restTemplate.exchange(getUrl(VIIDApi.SUBSCRIBES),
+                HttpMethod.POST, httpEntity, String.class);
+        if (org.apache.http.HttpStatus.SC_OK == responseEntity.getStatusCode().value()) {
+            stringRedisTemplate.opsForHash().delete(ViidCollectorRedisKey.DEVICE_CACHE, deviceId);
+            return true;
+        }
+        return false;
+    }
+
+    private String getUrl(String uri) {
+        return "http://" + gat1400Properties.getServerAddress() + ":" + gat1400Properties.getPort() + uri;
+    }
+
+    private HttpHeaders buildHttpHeaders(String deviceId) {
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json;charset=utf-8");
+        headers.set("User-Identify", deviceId);
+        return headers;
+    }
+}
-package com.objecteye.handle.viid;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.objecteye.config.ApplicationConfigurationProperties;
-import com.objecteye.content.VIIDApi;
-import com.objecteye.content.enums.VIIDConfirmStatusTypeEnum;
-import com.objecteye.pojo.platform.DeviceRequestParams;
-import com.objecteye.pojo.viid.common.CommonDeviceIdRequestParams;
-import com.objecteye.pojo.viid.common.ResponseStatusResponse;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.http.HttpEntity;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Component;
-import org.springframework.util.StringUtils;
-import org.springframework.web.client.RestTemplate;
-
-/**
- * @author: liuhaoyu
- * @date: 2023/6/28
- */
-@Slf4j
-@Component
-@RequiredArgsConstructor
-public class VIIDCommonHandle {
-    private final ObjectMapper objectMapper;
-    private final RestTemplate restTemplate;
-    private final ApplicationConfigurationProperties applicationConfigurationProperties;
-    private static final String CONTENT_TYPE = "application/*+JSON";
-    private static final String HTTP = "http://";
-
-    /**
-     * 注册
-     *
-     * @param deviceRequestParams 注册目标设备
-     * @return 注册结果
-     */
-    public boolean register(DeviceRequestParams deviceRequestParams) {
-        return commonDeviceIdPost(deviceRequestParams, VIIDApi.REGISTER);
-    }
-
-    /**
-     * 保活
-     *
-     * @param deviceRequestParams 心跳目标设备
-     * @return 发送结果
-     */
-    public boolean keepalive(DeviceRequestParams deviceRequestParams) {
-        return commonDeviceIdPost(deviceRequestParams, VIIDApi.KEEPALIVE);
-    }
-
-    /**
-     * 注销
-     *
-     * @param deviceRequestParams 注销目标设备
-     * @return 注销结果
-     */
-    public boolean unregister(DeviceRequestParams deviceRequestParams) {
-        return commonDeviceIdPost(deviceRequestParams, VIIDApi.UNREGISTER);
-    }
-
-    private boolean commonDeviceIdPost(DeviceRequestParams deviceRequestParams, String uri) {
-        return checkResponse(restTemplate.postForEntity(getAddress(deviceRequestParams) + uri,
-                buildHttpEntity(buildCommonDeviceIdRequestParam(deviceRequestParams)), String.class));
-    }
-
-    private CommonDeviceIdRequestParams buildCommonDeviceIdRequestParam(DeviceRequestParams deviceRequestParams) {
-        CommonDeviceIdRequestParams commonDeviceIdRequestParams = new CommonDeviceIdRequestParams();
-        commonDeviceIdRequestParams.setDeviceId(applicationConfigurationProperties.getPlatformCode());
-        return commonDeviceIdRequestParams;
-    }
-
-    private String getAddress(DeviceRequestParams deviceRequestParams) {
-        return HTTP + deviceRequestParams.getHost() + ":" + deviceRequestParams.getPort();
-    }
-
-    private boolean checkResponse(ResponseEntity<String> responseEntity) {
-        String body = responseEntity.getBody();
-        if (StringUtils.hasText(body)) {
-            try {
-                ResponseStatusResponse responseStatusResponse = objectMapper.readValue(body, ResponseStatusResponse.class);
-                if (null == responseStatusResponse || null == responseStatusResponse.getStatusCode() ||
-                        !responseStatusResponse.getStatusCode().equals(VIIDConfirmStatusTypeEnum.OK.ordinal())) {
-                    if (log.isDebugEnabled()) {
-                        log.debug("register failed, {}", body);
-                    }
-                    return false;
-                }
-                return true;
-            } catch (JsonProcessingException e) {
-                if (log.isDebugEnabled()) {
-                    log.debug("convert failed, {}", body);
-                }
-                return false;
-            }
-        }
-        return false;
-    }
-
-    private <T> HttpEntity<T> buildHttpEntity(T t) {
-        HttpHeaders httpHeaders = new HttpHeaders();
-        httpHeaders.add(HttpHeaders.CONTENT_TYPE, CONTENT_TYPE);
-
-        return new HttpEntity<>(t, httpHeaders);
-    }
-}
-package com.objecteye.pojo.platform;
+package com.objecteye.pojo;
 import lombok.Data;
+import javax.validation.constraints.NotEmpty;
 import java.io.Serializable;
 /**
  * @author: liuhaoyu
- * @date: 2023/6/28
+ * @date: 2023/7/6
  */
 @Data
-public class DeviceRequestParams implements Serializable {
-    private static final long serialVersionUID = -7801549061937667804L;
+public class DeviceIdParams implements Serializable {
+    private static final long serialVersionUID = 2371999237808825162L;
+    @NotEmpty(message = "设备信息为空")
     private String deviceId;
-
-    private String host;
-
-    private String port;
-
-    private String accessKey;
-
-    private String securityKey;
-
 }
+package com.objecteye.pojo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class Result<T> implements Serializable {
+
+    private static final long serialVersionUID = -3498710365399499894L;
+
+    private Integer code;
+
+    private String message;
+
+    private T data;
+
+    public static <T> Result<T> success(T t) {
+        Result<T> result = new Result<>();
+        result.setCode(200);
+        result.setMessage("Success");
+        result.setData(t);
+        return result;
+    }
+
+    public static <T> Result<T> success() {
+        return success(null);
+    }
+
+    public static <T> Result<T> failed(String message) {
+        return failed(message, null);
+    }
+
+    public static <T> Result<T> failed(String message, T t) {
+        Result<T> result = new Result<>();
+        result.setCode(201);
+        result.setMessage(message);
+        result.setData(t);
+        return result;
+    }
+}
+package com.objecteye.pojo.viid.common;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class KeepaliveRequestObject {
+
+    @JsonProperty("KeepaliveObject")
+    private RegisterObject keepaliveObject;
+}
@@ -3,15 +3,12 @@ package com.objecteye.pojo.viid.common;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Data;
-import java.io.Serializable;
-
 /**
  * @author: liuhaoyu
- * @date: 2023/6/28
+ * @date: 2023/7/5
  */
 @Data
-public class CommonDeviceIdRequestParams implements Serializable {
-    private static final long serialVersionUID = 1L;
+public class RegisterObject {
     @JsonProperty("DeviceID")
     private String deviceId;
+package com.objecteye.pojo.viid.common;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class RegisterRequestObject {
+
+    @JsonProperty("RegisterObject")
+    private RegisterObject registerObject;
+}
@@ -10,7 +10,7 @@ import java.io.Serializable;
  * @date: 2023/6/28
  */
 @Data
-public class ResponseStatusResponse implements Serializable {
+public class ResponseStatus implements Serializable {
     private static final long serialVersionUID = 1L;
+package com.objecteye.pojo.viid.common;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class ResponseStatusListObject {
+
+    @JsonProperty("ResponseStatusList")
+    private ResponseStatusList responseStatusList;
+
+    @Data
+    public static class ResponseStatusList{
+        @JsonProperty("ResponseStatusObject")
+        private List<ResponseStatus> responseStatusObject;
+    }
+}
+package com.objecteye.pojo.viid.common;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class ResponseStatusObjectWrapper {
+
+    @JsonProperty("ResponseStatusObject")
+    private ResponseStatus responseStatusObject;
+}
+package com.objecteye.pojo.viid.common;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class SystemTimeObject {
+
+    @JsonProperty("SystemTime")
+    private SystemTime systemTime;
+
+    @Data
+    public static class SystemTime {
+        @JsonProperty("VIIDServerID")
+        private String serverId;
+        @JsonProperty("TimeMode")
+        private String timeMode;
+        @JsonProperty("LocalTime")
+        private String localTime;
+        @JsonProperty("TimeZone")
+        private String timeZone;
+    }
+}
+package com.objecteye.pojo.viid.common;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class UnRegisterRequestObject {
+
+    @JsonProperty("UnRegisterObject")
+    private RegisterObject unRegisterObject;
+}
+package com.objecteye.pojo.viid.detail;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class Face {
+
+    @JsonProperty("FaceID")
+    private String faceId;
+    @JsonProperty("InfoKind")
+    private Integer infoKind;
+    @JsonProperty("SourceID")
+    private String sourceId;
+    @JsonProperty("DeviceID")
+    private String deviceId;
+    @JsonProperty("LeftTopX")
+    private Integer leftTopX;
+    @JsonProperty("LeftTopY")
+    private Integer leftTopY;
+    @JsonProperty("RightBtmX")
+    private Integer rightBtmX;
+    @JsonProperty("RightBtmY")
+    private Integer rightBtmY;
+    @JsonProperty("IsDriver")
+    private Integer isDriver;
+    @JsonProperty("IsForeigner")
+    private Integer isForeigner;
+    @JsonProperty("IsSuspectedTerrorist")
+    private Integer isSuspectedTerrorist;
+    @JsonProperty("IsCriminalInvolved")
+    private Integer isCriminalInvolved;
+    @JsonProperty("IsDetainees")
+    private Integer isDetainees;
+    @JsonProperty("IsVictim")
+    private Integer isVictim;
+    @JsonProperty("IsSuspiciousPerson")
+    private Integer isSuspiciousPerson;
+    @JsonProperty("SubImageList")
+    private SubImageList subImageList;
+
+}
+package com.objecteye.pojo.viid.detail;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class FaceRequestObject {
+
+    @JsonProperty("FaceListObject")
+    private FaceListObject faceListObject;
+
+    @Data
+    public static class FaceListObject {
+        @JsonProperty("FaceObject")
+        private List<Face> faceObject;
+    }
+
+}
+package com.objecteye.pojo.viid.detail;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class MotorVehicle {
+
+    @JsonProperty("MotorVehicleID")
+    private String motorVehicleId;
+    @JsonProperty("InfoKind")
+    private Integer infoKind;
+    @JsonProperty("SourceID")
+    private String sourceId;
+    @JsonProperty("DeviceID")
+    private String deviceId;
+    @JsonProperty("StorageUrl1")
+    private String storageUrl1;
+    @JsonProperty("LeftTopX")
+    private Integer leftTopX;
+    @JsonProperty("LeftTopY")
+    private Integer leftTopY;
+    @JsonProperty("RightBtmX")
+    private Integer rightBtmX;
+    @JsonProperty("RightBtmY")
+    private Integer rightBtmY;
+    @JsonProperty("HasPlate")
+    private Boolean hasPlate;
+    @JsonProperty("PlateClass")
+    private String plateClass;
+    @JsonProperty("PlateColor")
+    private String plateColor;
+    @JsonProperty("PlateNo")
+    private String plateNo;
+    @JsonProperty("VehicleColor")
+    private String vehicleColor;
+    @JsonProperty("SubImageList")
+    private SubImageList subImageList;
+}
+package com.objecteye.pojo.viid.detail;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class MotorVehicleRequestObject {
+
+    @JsonProperty("MotorVehicleListObject")
+    private MotorVehicleListObject motorVehicleListObject;
+
+    @Data
+    public static class MotorVehicleListObject {
+
+        @JsonProperty("MotorVehicleObject")
+        private List<MotorVehicle> motorVehicleObject;
+    }
+}
+package com.objecteye.pojo.viid.detail;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class SubImageInfo {
+    /**
+     * 图片ID【String(41)】
+     */
+    @JsonProperty("ImageID")
+    private String imageId;
+    /**
+     * 视频图像分析处理事件类型
+     */
+    @JsonProperty("EventSort")
+    private Integer eventSort;
+    /**
+     * 设备编码【String(20)】
+     */
+    @JsonProperty("DeviceID")
+    private String deviceId;
+    /**
+     * 存储路径
+     */
+    @JsonProperty("StoragePath")
+    private String storagePath;
+    /**
+     * 图像类型
+     */
+    @JsonProperty("ImageType")
+    private String imageType;
+    /**
+     * 图片格式
+     */
+    @JsonProperty("FileFormat")
+    private String fileFormat;
+    /**
+     * 拍摄时间【格式(yyyyMMddHHmmss)】
+     */
+    @JsonProperty("ShotTime")
+    private String shotTime;
+    /**
+     * 水平像素值
+     */
+    @JsonProperty("Width")
+    private Integer width;
+    /**
+     * 垂直像素值
+     */
+    @JsonProperty("Height")
+    private Integer height;
+    /**
+     * 图片（base64）
+     */
+    @JsonProperty("Data")
+    private String data;
+    /**
+     * 图像类型（02-车牌彩色小图，11-人脸图）
+     */
+    @JsonProperty("Type")
+    private String type;
+}
+package com.objecteye.pojo.viid.detail;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class SubImageList {
+
+    @JsonProperty("SubImageInfoObject")
+    private List<SubImageInfo> subImageInfoObject;
+}
@@ -95,4 +95,29 @@ public class Subscribe implements Serializable {
      */
     @JsonProperty("SubscribeStatus")
     private Integer subscribeStatus;
+    /**
+     * 订阅原因
+     */
+    @JsonProperty("Reason")
+    private String reason;
+    /**
+     * 取消订阅机构
+     */
+    @JsonProperty("SubscribeCancelOrg")
+    private String subscribeCancelOrg;
+    /**
+     * 取消订阅人员
+     */
+    @JsonProperty("SubscribeCancelPerson")
+    private String subscribeCancelPerson;
+    /**
+     * 取消时间
+     */
+    @JsonProperty("CancelTime")
+    private String cancelTime;
+    /**
+     * 取消原因
+     */
+    @JsonProperty("CancelReason")
+    private String cancelReason;
 }
+package com.objecteye.pojo.viid.subscribe;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.objecteye.pojo.viid.detail.FaceRequestObject;
+import com.objecteye.pojo.viid.detail.MotorVehicleRequestObject;
+import lombok.Data;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class SubscribeNotification {
+
+    @JsonProperty("NotificationID")
+    private String notificationId;
+    @JsonProperty("SubscribeID")
+    private String subscribeId;
+    @JsonProperty("Title")
+    private String title;
+    @JsonProperty("TriggerTime")
+    private String triggerTime;
+    @JsonProperty("InfoIDs")
+    private String infoIds;
+    @JsonProperty("FaceListObject")
+    private FaceRequestObject.FaceListObject faceListObject;
+    @JsonProperty("MotorVehicleListObject")
+    private MotorVehicleRequestObject.MotorVehicleListObject motorVehicleListObject;
+}
+package com.objecteye.pojo.viid.subscribe;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/6
+ */
+@Data
+public class SubscribeNotificationRequestObject {
+
+    @JsonProperty("SubscribeNotificationListObject")
+    private SubscribeNotificationListObject subscribeNotificationListObject;
+
+    @Data
+    public static class SubscribeNotificationListObject {
+        @JsonProperty("SubscribeNotificationObject")
+        private List<SubscribeNotification> subscribeNotificationObject;
+    }
+}
+package com.objecteye.pojo.viid.subscribe;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author: liuhaoyu
+ * @date: 2023/7/5
+ */
+@Data
+public class SubscribeRequestObject {
+
+    @JsonProperty("SubscribeListObject")
+    private SubscribeListObject subscribeListObject;
+
+    @Data
+    public static class SubscribeListObject {
+        @JsonProperty("SubscribeObject")
+        private List<Subscribe> subscribeObject;
+    }
+}
+package com.objecteye.utils;
+
+import org.apache.commons.codec.binary.Hex;
+
+import java.security.GeneralSecurityException;
+import java.security.MessageDigest;
+import java.util.Random;
+
+public class DigestUtils {
+
+
+    /**
+     * 加密遵循RFC2671规范 将相关参数加密生成一个MD5字符串,并返回
+     */
+    public static String getResponse(
+            String username,
+            String realm,
+            String password,
+            String nonce,
+            String nc,
+            String cnonce,
+            String qop,
+            String method,
+            String uri
+    ) {
+        String A1 = username + ":" + realm + ":" + password;
+        byte[] md5ByteA1 = md5(A1.getBytes());
+        String HA1 = new String(Hex.encodeHex(md5ByteA1));
+
+        String A2 = method + ":" + uri;
+        byte[] md5ByteA2 = md5(A2.getBytes());
+        String HA2 = new String(Hex.encodeHex(md5ByteA2));
+
+
+        String original = HA1 + ":" + (nonce + ":" + nc + ":" + cnonce + ":" + qop) + ":" + HA2;
+        byte[] md5ByteOriginal = md5(original.getBytes());
+        return new String(Hex.encodeHex(md5ByteOriginal));
+    }
+
+    public static String getAuthorization(String username, String realm, String nonce, String uri, String qop, String nc, String cnonce, String response, String opaque) {
+        return "Digest username=\"" + username + "\"" +
+                ",realm=\"" + realm + "\"" +
+                ",nonce=\"" + nonce + "\"" +
+                ",uri=\"" + uri + "\"" +
+                ",qop=\"" + qop + "\"" +
+                ",nc=\"" + nc + "\"" +
+                ",cnonce=\"" + cnonce + "\"" +
+                ",response=\"" + response + "\"" +
+                ",opaque=\"" + opaque;
+    }
+
+
+    /**
+     * 对输入字符串进行md5散列.
+     */
+    public static byte[] md5(byte[] input) {
+        return digest(input, "MD5", null, 1);
+    }
+
+    /**
+     * 对字符串进行散列, 支持md5与sha1算法.
+     */
+    private static byte[] digest(byte[] input, String algorithm, byte[] salt, int iterations) {
+        try {
+            MessageDigest digest = MessageDigest.getInstance(algorithm);
+
+            if (salt != null) {
+                digest.update(salt);
+            }
+
+            byte[] result = digest.digest(input);
+
+            for (int i = 1; i < iterations; i++) {
+                digest.reset();
+                result = digest.digest(result);
+            }
+            return result;
+        } catch (GeneralSecurityException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public static String generateSalt2(int length) {
+        StringBuilder val = new StringBuilder();
+        Random random = new Random();
+        //参数length，表示生成几位随机数
+        for (int i = 0; i < length; i++) {
+            //输出字母还是数字
+            if (random.nextInt(2) % 2 == 0) {
+                //输出是大写字母还是小写字母
+                val.append((char) (random.nextInt(26) + random.nextInt(2) % 2 == 0 ? 65 : 97));
+            } else {
+                val.append(random.nextInt(10));
+            }
+        }
+        return val.toString().toLowerCase();
+    }
+
+
+}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.objecteye.utils;
+
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.*;
+import com.fasterxml.jackson.databind.json.JsonMapper;
+import com.fasterxml.jackson.databind.module.SimpleModule;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.fasterxml.jackson.databind.node.TextNode;
+import com.fasterxml.jackson.databind.type.CollectionType;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.lang.Nullable;
+
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+
+import static com.fasterxml.jackson.databind.DeserializationFeature.*;
+import static com.fasterxml.jackson.databind.MapperFeature.REQUIRE_SETTERS_FOR_GETTERS;
+import static com.objecteye.content.VIIDContent.YYYY_MM_DD_HH_MM_SS;
+import static java.nio.charset.StandardCharsets.UTF_8;
+
+/**
+ * json utils
+ */
+@Slf4j
+public class JSONUtils {
+
+    static {
+        log.info("init timezone: {}", TimeZone.getDefault());
+    }
+
+    private static final ObjectMapper objectMapper = JsonMapper.builder()
+            .configure(FAIL_ON_UNKNOWN_PROPERTIES, false)
+            .configure(ACCEPT_EMPTY_ARRAY_AS_NULL_OBJECT, true)
+            .configure(READ_UNKNOWN_ENUM_VALUES_AS_NULL, true)
+            .configure(REQUIRE_SETTERS_FOR_GETTERS, true)
+            .addModule(new SimpleModule()
+                    .addSerializer(LocalDateTime.class, new LocalDateTimeSerializer())
+                    .addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer()))
+            .defaultTimeZone(TimeZone.getDefault())
+            .defaultDateFormat(new SimpleDateFormat(YYYY_MM_DD_HH_MM_SS))
+            .build();
+
+    private JSONUtils() {
+        throw new UnsupportedOperationException("Construct JSONUtils");
+    }
+
+    public static synchronized void setTimeZone(TimeZone timeZone) {
+        objectMapper.setTimeZone(timeZone);
+    }
+
+    public static ArrayNode createArrayNode() {
+        return objectMapper.createArrayNode();
+    }
+
+    public static ObjectNode createObjectNode() {
+        return objectMapper.createObjectNode();
+    }
+
+    public static JsonNode toJsonNode(Object obj) {
+        return objectMapper.valueToTree(obj);
+    }
+
+    /**
+     * json representation of object
+     *
+     * @param object object
+     * @param feature feature
+     * @return object to json string
+     */
+    public static String toJsonString(Object object, SerializationFeature feature) {
+        try {
+            ObjectWriter writer = objectMapper.writer(feature);
+            return writer.writeValueAsString(object);
+        } catch (Exception e) {
+            log.error("object to json exception!", e);
+        }
+
+        return null;
+    }
+
+    /**
+     * This method deserializes the specified Json into an object of the specified class. It is not
+     * suitable to use if the specified class is a generic type since it will not have the generic
+     * type information because of the Type Erasure feature of Java. Therefore, this method should not
+     * be used if the desired type is a generic type. Note that this method works fine if the any of
+     * the fields of the specified object are generics, just the object itself should not be a
+     * generic type.
+     *
+     * @param json the string from which the object is to be deserialized
+     * @param clazz the class of T
+     * @param <T> T
+     * @return an object of type T from the string
+     * classOfT
+     */
+    public static @Nullable <T> T parseObject(String json, Class<T> clazz) {
+        if (StringUtils.isBlank(json)) {
+            return null;
+        }
+
+        try {
+            return objectMapper.readValue(json, clazz);
+        } catch (Exception e) {
+            log.error("Parse object exception, jsonStr: {}, class: {}", json, clazz, e);
+        }
+        return null;
+    }
+
+    /**
+     *  deserialize
+     *
+     * @param src byte array
+     * @param clazz class
+     * @param <T> deserialize type
+     * @return deserialize type
+     */
+    public static <T> T parseObject(byte[] src, Class<T> clazz) {
+        if (src == null) {
+            return null;
+        }
+        String json = new String(src, UTF_8);
+        return parseObject(json, clazz);
+    }
+
+    /**
+     * json to list
+     *
+     * @param json json string
+     * @param clazz class
+     * @param <T> T
+     * @return list
+     */
+    public static <T> List<T> toList(String json, Class<T> clazz) {
+        if (StringUtils.isBlank(json)) {
+            return Collections.emptyList();
+        }
+
+        try {
+            CollectionType listType = objectMapper.getTypeFactory().constructCollectionType(ArrayList.class, clazz);
+            return objectMapper.readValue(json, listType);
+        } catch (Exception e) {
+            log.error("parse list exception!", e);
+        }
+
+        return Collections.emptyList();
+    }
+
+    /**
+     * check json object valid
+     *
+     * @param json json
+     * @return true if valid
+     */
+    public static boolean checkJsonValid(String json) {
+
+        if (StringUtils.isBlank(json)) {
+            return false;
+        }
+
+        try {
+            objectMapper.readTree(json);
+            return true;
+        } catch (IOException e) {
+            log.error("check json object valid exception!", e);
+        }
+
+        return false;
+    }
+
+    /**
+     * Method for finding a JSON Object field with specified name in this
+     * node or its child nodes, and returning value it has.
+     * If no matching field is found in this node or its descendants, returns null.
+     *
+     * @param jsonNode json node
+     * @param fieldName Name of field to look for
+     * @return Value of first matching node found, if any; null if none
+     */
+    public static String findValue(JsonNode jsonNode, String fieldName) {
+        JsonNode node = jsonNode.findValue(fieldName);
+
+        if (node == null) {
+            return null;
+        }
+
+        return node.asText();
+    }
+
+    /**
+     * json to map
+     * {@link #toMap(String, Class, Class)}
+     *
+     * @param json json
+     * @return json to map
+     */
+    public static Map<String, String> toMap(String json) {
+        return parseObject(json, new TypeReference<Map<String, String>>() {
+        });
+    }
+
+    /**
+     * json to map
+     *
+     * @param json json
+     * @param classK classK
+     * @param classV classV
+     * @param <K> K
+     * @param <V> V
+     * @return to map
+     */
+    public static <K, V> Map<K, V> toMap(String json, Class<K> classK, Class<V> classV) {
+        if (StringUtils.isBlank(json)) {
+            return Collections.emptyMap();
+        }
+
+        try {
+            return objectMapper.readValue(json, new TypeReference<Map<K, V>>() {
+            });
+        } catch (Exception e) {
+            log.error("json to map exception!", e);
+        }
+
+        return Collections.emptyMap();
+    }
+
+    /**
+     * from the key-value generated json  to get the str value no matter the real type of value
+     * @param json the json str
+     * @param nodeName key
+     * @return the str value of key
+     */
+    public static String getNodeString(String json, String nodeName) {
+        try {
+            JsonNode rootNode = objectMapper.readTree(json);
+            JsonNode jsonNode = rootNode.findValue(nodeName);
+            if (Objects.isNull(jsonNode)) {
+                return "";
+            }
+            return jsonNode.isTextual() ? jsonNode.asText() : jsonNode.toString();
+        } catch (JsonProcessingException e) {
+            return "";
+        }
+    }
+
+    /**
+     * json to object
+     *
+     * @param json json string
+     * @param type type reference
+     * @param <T>
+     * @return return parse object
+     */
+    public static <T> T parseObject(String json, TypeReference<T> type) {
+        if (StringUtils.isBlank(json)) {
+            return null;
+        }
+
+        try {
+            return objectMapper.readValue(json, type);
+        } catch (Exception e) {
+            log.error("json to map exception!", e);
+        }
+
+        return null;
+    }
+
+    /**
+     * object to json string
+     *
+     * @param object object
+     * @return json string
+     */
+    public static String toJsonString(Object object) {
+        try {
+            return objectMapper.writeValueAsString(object);
+        } catch (Exception e) {
+            throw new RuntimeException("Object json deserialization exception.", e);
+        }
+    }
+
+    public static String toPrettyJsonString(Object object) {
+        try {
+            return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(object);
+        } catch (Exception e) {
+            throw new RuntimeException("Object json deserialization exception.", e);
+        }
+    }
+
+    /**
+     * serialize to json byte
+     *
+     * @param obj object
+     * @param <T> object type
+     * @return byte array
+     */
+    public static <T> byte[] toJsonByteArray(T obj) {
+        if (obj == null) {
+            return null;
+        }
+        String json = "";
+        try {
+            json = toJsonString(obj);
+        } catch (Exception e) {
+            log.error("json serialize exception.", e);
+        }
+
+        return json.getBytes(UTF_8);
+    }
+
+    public static ObjectNode parseObject(String text) {
+        try {
+            if (StringUtils.isEmpty(text)) {
+                return parseObject(text, ObjectNode.class);
+            } else {
+                return (ObjectNode) objectMapper.readTree(text);
+            }
+        } catch (Exception e) {
+            throw new RuntimeException("String json deserialization exception.", e);
+        }
+    }
+
+    public static ArrayNode parseArray(String text) {
+        try {
+            return (ArrayNode) objectMapper.readTree(text);
+        } catch (Exception e) {
+            throw new RuntimeException("Json deserialization exception.", e);
+        }
+    }
+
+    /**
+     * json serializer
+     */
+    public static class JsonDataSerializer extends JsonSerializer<String> {
+
+        @Override
+        public void serialize(String value, JsonGenerator gen, SerializerProvider provider) throws IOException {
+            gen.writeRawValue(value);
+        }
+
+    }
+
+    /**
+     * json data deserializer
+     */
+    public static class JsonDataDeserializer extends JsonDeserializer<String> {
+
+        @Override
+        public String deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
+            JsonNode node = p.getCodec().readTree(p);
+            if (node instanceof TextNode) {
+                return node.asText();
+            } else {
+                return node.toString();
+            }
+        }
+
+    }
+
+    public static class LocalDateTimeSerializer extends JsonSerializer<LocalDateTime> {
+
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern(YYYY_MM_DD_HH_MM_SS);
+
+        @Override
+        public void serialize(LocalDateTime value,
+                              JsonGenerator gen,
+                              SerializerProvider serializers) throws IOException {
+            gen.writeString(value.format(formatter));
+        }
+    }
+
+    public static class LocalDateTimeDeserializer extends JsonDeserializer<LocalDateTime> {
+
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern(YYYY_MM_DD_HH_MM_SS);
+
+        @Override
+        public LocalDateTime deserialize(JsonParser p, DeserializationContext context) throws IOException {
+            return LocalDateTime.parse(p.getValueAsString(), formatter);
+        }
+    }
+}
+gat1400:
+  server-address: 127.0.0.1
+  port: 9000
+  access-key: admin
+  security-key: 123456
+receiver: http://localhost:8888/receiver
+spring:
+  application:
+    name: viid-collector
+  redis:
+    host: 192.168.60.126
+    port: 6379
+    timeout: 10000ms
+    lettuce:
+      pool:
+        max-active: 8
+        max-wait: -1ms
+        min-idle: 0
+        max-idle: 8
+logging:
+  level:
+    root: error
+    com.objecteye: debug
 \ No newline at end of file