视频人流量 完善url 人体检测入库

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

@@ -2,11 +2,11 @@ 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;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
 
 /**
  * <p>
@@ -18,7 +18,7 @@ import org.apache.ibatis.javassist.SerialVersionUID;
  */
 @Data
 @EqualsAndHashCode(callSuper = false)
-public class KylinCameraRecord implements Serializable {
+public class KylinCameraRecord implements Serializable, Cloneable {
 
     private static final long serialVersionUID = 1L;
 
@@ -44,5 +44,14 @@ public class KylinCameraRecord implements Serializable {
 
     private LocalDateTime updatedAt;
 
+    private static final KylinCameraRecord obj = new KylinCameraRecord();
+    public static KylinCameraRecord getNew() {
+        try {
+            return (KylinCameraRecord) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinCameraRecord();
+        }
+    }
+
 
 }

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

@@ -22,7 +22,9 @@ import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.dto.vo.KylinCameraDevicesVo;
 import com.liquidnet.service.kylin.entity.KylinCamera;
+import com.liquidnet.service.kylin.entity.KylinCameraRecord;
 import com.liquidnet.service.kylin.mapper.KylinCameraMapper;
+import com.liquidnet.service.kylin.mapper.KylinCameraRecordMapper;
 import com.liquidnet.service.platform.utils.ViapiFileUtilAdvance;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -36,6 +38,7 @@ import org.springframework.web.bind.annotation.*;
 import java.io.InputStream;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Optional;
 
 /**
  * <p>
@@ -58,6 +61,8 @@ public class KylinCameraController {
 
     @Autowired
     private KylinCameraMapper cameraMapper;
+    @Autowired
+    private KylinCameraRecordMapper recordMapper;
 
     @PostMapping(value = "callBack", produces = "application/xml;charset=UTF-8")
     @ApiOperation("截图回调")
@@ -162,10 +167,12 @@ public class KylinCameraController {
                     DetectPedestrianResponse response = client.getAcsResponse(request);
                     List<DetectPedestrianResponse.Data.Element> elementList = response.getData().getElements();
                     if (!CollectionUtils.isEmpty(elementList)) {
-                        for (DetectPedestrianResponse.Data.Element element : elementList) {
-                            System.out.println(element.getType());
-                            System.out.println(element.getScore());
-                        }
+                        long count = elementList.stream().filter(r -> r.getScore() > 0.5).count();
+                        KylinCameraRecord cameraRecord = KylinCameraRecord.getNew();
+                        cameraRecord.setCameraRecordId(IDGenerator.nextSnowId());
+                        cameraRecord.setCameraId(kylinCamera.getCameraId());
+                        cameraRecord.setPersonNum((int) count);
+                        recordMapper.insert(cameraRecord);
                     }
                 } catch (Exception e) {
                     log.error("获取设备列表Exception：[msg={}, e={}]", e.getMessage(), e);