视频人流量 streamName

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinCamera.java

@@ -30,14 +30,9 @@ public class KylinCamera implements Serializable {
     private String cameraId;
 
     /**
-     * 国标ID
+     * 设备用户名/国标ID
      */
-    private String cameraGbId;
-
-    /**
-     * 设备ID
-     */
-    private String cameraName;
+    private String streamName;
 
     /**
      * 场地ID

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/docu/db_0110_camera.sql

@@ -3,8 +3,7 @@ CREATE TABLE `kylin_camera`
 (
     `mid`          int unsigned NOT NULL AUTO_INCREMENT,
     `camera_id`    varchar(255) NOT NULL DEFAULT '' COMMENT 'camera_id',
-    `camera_gb_id` varchar(255) NOT NULL DEFAULT '' COMMENT '国标ID',
-    `camera_name`  varchar(255) NOT NULL DEFAULT '' COMMENT '设备ID',
+    `stream_name` varchar(255) NOT NULL DEFAULT '' COMMENT '设备用户名/国标ID',
     `field_id`     varchar(64)  NOT NULL DEFAULT '' COMMENT '场地ID',
     `img_url`      varchar(500) NOT NULL DEFAULT '' COMMENT '截图url',
     `site_type`    tinyint      NOT NULL DEFAULT 0 COMMENT '地点类型 1卫生间 2。。。',

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/KylinCameraCallBackController.java

@@ -24,19 +24,12 @@ public class KylinCameraCallBackController {
     @ApiOperation("截图回调")
     public String record(
             @RequestBody String requestBody,
-//            @RequestParam() String requestBody,
-            @RequestParam(value = "Version", defaultValue = "") String Version,
-            @RequestParam(value = "Signature", defaultValue = "") String Signature,
-            @RequestParam(value = "SignatureMethod", defaultValue = "") String SignatureMethod,
-            @RequestParam(value = "SignatureNonce", defaultValue = "") String SignatureNonce,
-            @RequestParam(value = "SignatureVersion", defaultValue = "") String SignatureVersion,
-            @RequestParam(value = "AccessKeyId", defaultValue = "") String AccessKeyId,
-            @RequestParam(value = "Timestamp", defaultValue = "") String Timestamp
+            @RequestParam(value = "siteType") Integer siteType,
+            @RequestParam(value = "fieldId") String fieldId
     ) {
         try {
-            log.info("\n接收截图回调请求：[Version=[{}], Signature=[{}], [SignatureMethod=[{}], SignatureNonce=[{}], SignatureVersion=[{}],"
-                            + " AccessKeyId=[{}], Timestamp=[{}], requestBody=[\n{}\n] ",
-                    Version, Signature, SignatureMethod, SignatureNonce, SignatureVersion, AccessKeyId, Timestamp, requestBody);
+            log.info("接收截图回调请求：[siteType=[{}], fieldId=[{}], requestBody=[{}]",
+                    siteType, fieldId, requestBody);
             // TODO: 2022/1/10 jxltodo 验签
             return "success";
         } catch (Exception e) {