视频人流量

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinCameraRecordService.java

+package com.liquidnet.service.kylin.service;
+
+import com.liquidnet.service.kylin.entity.KylinCameraRecord;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 人流量检测记录表 服务类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+public interface IKylinCameraRecordService extends IService<KylinCameraRecord> {
+
+}

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinCameraService.java

+package com.liquidnet.service.kylin.service;
+
+import com.liquidnet.service.kylin.entity.KylinCamera;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 人流量排队检测摄像头表 服务类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+public interface IKylinCameraService extends IService<KylinCamera> {
+
+}

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

+package com.liquidnet.service.kylin.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 人流量排队检测摄像头表
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinCamera implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * camera_id
+     */
+    private String cameraId;
+
+    /**
+     * 国标ID
+     */
+    private String cameraGbId;
+
+    /**
+     * 设备ID
+     */
+    private String cameraName;
+
+    /**
+     * 场地ID
+     */
+    private String fieldId;
+
+    /**
+     * 截图url
+     */
+    private String imgUrl;
+
+    /**
+     * 地点类型 1卫生间 2。。。
+     */
+    private Integer siteType;
+
+    private LocalDateTime createdAt;
+
+    private LocalDateTime updatedAt;
+
+
+}

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

+package com.liquidnet.service.kylin.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.apache.ibatis.javassist.SerialVersionUID;
+
+/**
+ * <p>
+ * 人流量检测记录表
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinCameraRecord implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * camera_record_id
+     */
+    private String cameraRecordId;
+
+    /**
+     * camera_id
+     */
+    private String cameraId;
+
+    /**
+     * 检测到的人数
+     */
+    private Integer personNum;
+
+    private LocalDateTime createdAt;
+
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinCameraMapper.java

+package com.liquidnet.service.kylin.mapper;
+
+import com.liquidnet.service.kylin.entity.KylinCamera;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 人流量排队检测摄像头表 Mapper 接口
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+public interface KylinCameraMapper extends BaseMapper<KylinCamera> {
+
+}

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinCameraRecordMapper.java

+package com.liquidnet.service.kylin.mapper;
+
+import com.liquidnet.service.kylin.entity.KylinCameraRecord;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 人流量检测记录表 Mapper 接口
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+public interface KylinCameraRecordMapper extends BaseMapper<KylinCameraRecord> {
+
+}

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinCameraMapper.xml

+<?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.liquidnet.service.kylin.mapper.KylinCameraMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinCameraRecordMapper.xml

+<?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.liquidnet.service.kylin.mapper.KylinCameraRecordMapper">
+
+</mapper>

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

+drop TABLE if exists `kylin_camera`;
+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',
+    `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。。。',
+    `created_at`   timestamp    NULL     DEFAULT NULL,
+    `updated_at`   timestamp    NULL     DEFAULT NULL,
+    KEY `idx_camera_id` (`camera_id`),
+    PRIMARY KEY (`mid`)
+) ENGINE = InnoDB
+  DEFAULT CHARSET utf8mb4
+  COLLATE utf8mb4_unicode_ci COMMENT '人流量排队检测摄像头表';
+
+drop TABLE if exists `kylin_camera_record`;
+CREATE TABLE `kylin_camera_record`
+(
+    `mid`              int unsigned NOT NULL AUTO_INCREMENT,
+    `camera_record_id` varchar(255) NOT NULL DEFAULT '' COMMENT 'camera_record_id',
+    `camera_id`        varchar(255) NOT NULL DEFAULT '' COMMENT 'camera_id',
+    `person_num`       int          NOT NULL DEFAULT 0 COMMENT '检测到的人数',
+    `created_at`       timestamp    NULL     DEFAULT NULL,
+    `updated_at`       timestamp    NULL     DEFAULT NULL,
+    KEY `idx_camera_record_id` (`camera_record_id`),
+    PRIMARY KEY (`mid`)
+) ENGINE = InnoDB
+  DEFAULT CHARSET utf8mb4
+  COLLATE utf8mb4_unicode_ci COMMENT '人流量检测记录表';

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

+package com.liquidnet.service.kylin.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 人流量排队检测摄像头表 前端控制器
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@RestController
+@RequestMapping("/camera")
+public class KylinCameraController {
+
+}

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

+package com.liquidnet.service.kylin.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 人流量检测记录表 前端控制器
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@RestController
+@RequestMapping("/cameraRecord")
+public class KylinCameraRecordController {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinCameraRecordServiceImpl.java

+package com.liquidnet.service.kylin.service.impl;
+
+import com.liquidnet.service.kylin.entity.KylinCameraRecord;
+import com.liquidnet.service.kylin.mapper.KylinCameraRecordMapper;
+import com.liquidnet.service.kylin.service.IKylinCameraRecordService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 人流量检测记录表 服务实现类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@Service
+public class KylinCameraRecordServiceImpl extends ServiceImpl<KylinCameraRecordMapper, KylinCameraRecord> implements IKylinCameraRecordService {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinCameraServiceImpl.java

+package com.liquidnet.service.kylin.service.impl;
+
+import com.liquidnet.service.kylin.entity.KylinCamera;
+import com.liquidnet.service.kylin.mapper.KylinCameraMapper;
+import com.liquidnet.service.kylin.service.IKylinCameraService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 人流量排队检测摄像头表 服务实现类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@Service
+public class KylinCameraServiceImpl extends ServiceImpl<KylinCameraMapper, KylinCamera> implements IKylinCameraService {
+
+}

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

+package com.liquidnet.service.platform.controller.kylin;
+
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * <p>
+ * 人流量排队检测摄像头表 前端控制器
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@Api(tags = "截图回调")
+@Slf4j
+@RestController
+@RequestMapping("/camera")
+public class KylinCameraCallBackController {
+
+    @PostMapping(value = "create", produces = "application/xml;charset=UTF-8")
+    @ApiOperation("截图回调")
+    public String record(
+            @RequestBody String requestBody,
+//            @RequestParam() String requestBody,
+            @RequestParam("Version") String Version,
+            @RequestParam("Signature") String Signature,
+            @RequestParam("SignatureMethod") String SignatureMethod,
+            @RequestParam("SignatureNonce") String SignatureNonce,
+            @RequestParam("SignatureVersion") String SignatureVersion,
+            @RequestParam("AccessKeyId") String AccessKeyId,
+            @RequestParam("Timestamp") String Timestamp
+    ) {
+        try {
+            log.info("\n接收截图回调请求：[Version=[{}], Signature=[{}], [SignatureMethod=[{}], SignatureNonce=[{}], SignatureVersion=[{}],"
+                            + " AccessKeyId=[{}], Timestamp=[{}], requestBody=[\n{}\n] ",
+                    Version, Signature, SignatureMethod, SignatureNonce, SignatureVersion, AccessKeyId, Timestamp, requestBody);
+            // TODO: 2022/1/10 jxltodo 验签
+            return "success";
+        } catch (Exception e) {
+            log.error("截图回调Exception：[msg={}, e={}]", e.getMessage(), e);
+            return "error";
+        }
+    }
+
+}