Merge remote-tracking branch 'origin/master'

video/pom.xml

@@ -47,6 +47,13 @@
             <version>5.6.6</version>
         </dependency>
 
+        <!-- 海康SDK -->
+        <dependency>
+            <groupId>com.hikvision.ga</groupId>
+            <artifactId>artemis-http-client</artifactId>
+            <version>1.1.3</version>
+        </dependency>
+
 
         <!-- Mysql驱动包 -->
         <dependency>
@@ -59,6 +66,12 @@
             <version>1.1.22</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis-typehandlers-jsr310</artifactId>
+            <version>1.0.1</version>
+        </dependency>
+
         <!-- mybatis-plus -->
         <dependency>
             <groupId>com.baomidou</groupId>

video/src/main/java/cn/com/taiji/video/config/HttpClientConfig.java

@@ -1,9 +1,26 @@
 package cn.com.taiji.video.config;
 
+import org.apache.http.config.Registry;
+import org.apache.http.config.RegistryBuilder;
+import org.apache.http.conn.socket.ConnectionSocketFactory;
+import org.apache.http.conn.socket.PlainConnectionSocketFactory;
+import org.apache.http.conn.ssl.NoopHostnameVerifier;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.conn.ssl.TrustStrategy;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.BasicHttpClientConnectionManager;
+import org.apache.http.ssl.SSLContexts;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
 import org.springframework.web.client.RestTemplate;
 
+import javax.net.ssl.SSLContext;
+import java.security.KeyManagementException;
+import java.security.KeyStoreException;
+import java.security.NoSuchAlgorithmException;
+
 /**
  * @Description
  *
@@ -18,4 +35,22 @@ public class HttpClientConfig {
         return new RestTemplate();
     }
 
+    // @Bean
+    // RestTemplate restTemplate() throws NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
+    //     TrustStrategy acceptingTrustStrategy = (cert, authType) -> true;
+    //     SSLContext sslContext = SSLContexts.custom().loadTrustMaterial(null, acceptingTrustStrategy).build();
+    //     SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, NoopHostnameVerifier.INSTANCE);
+    //
+    //     Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
+    //             .register("https", sslsf).register("http", new PlainConnectionSocketFactory()).build();
+    //     BasicHttpClientConnectionManager connectionManager = new BasicHttpClientConnectionManager(
+    //             socketFactoryRegistry);
+    //     CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(sslsf)
+    //             .setConnectionManager(connectionManager).build();
+    //     HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);
+    //     requestFactory.setConnectTimeout(10000);
+    //     requestFactory.setReadTimeout(10000);
+    //     return new RestTemplate(requestFactory);
+    // }
+
 }

video/src/main/java/cn/com/taiji/video/cotroller/VideoUrlController.java

@@ -1,6 +1,8 @@
 package cn.com.taiji.video.cotroller;
 
 
+import cn.com.taiji.video.model.VideoAnalysisLineDTO;
+import cn.com.taiji.video.model.VideoAnalysisPieDTO;
 import cn.com.taiji.video.model.VideoDTO;
 import cn.com.taiji.video.service.IVideoUrlService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -8,6 +10,7 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDate;
 import java.util.List;
 
 
@@ -27,4 +30,21 @@ public class VideoUrlController {
     public List<VideoDTO> queryVideoList() {
         return urlService.queryVideoList();
     }
+
+    @GetMapping("analysis/test")
+    public void queryTestPie(Integer type, String startTime, String endTime) {
+        LocalDate startDate = LocalDate.parse(startTime);
+        LocalDate endDate = LocalDate.parse(endTime);
+        urlService.queryTestPie(type, startDate, endDate);
+    }
+
+    @GetMapping("analysis/pie")
+    public VideoAnalysisPieDTO queryPieRecord(Integer type) {
+        return urlService.queryPieRecord(type);
+    }
+
+    @GetMapping("analysis/line")
+    public List<VideoAnalysisLineDTO> queryLineRecord(Integer type) {
+        return urlService.queryLineRecord(type);
+    }
 }

video/src/main/java/cn/com/taiji/video/mapper/HtDpVideoAnalysisMapper.java

@@ -0,0 +1,23 @@
+package cn.com.taiji.video.mapper;
+
+import cn.com.taiji.video.model.*;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * @Description
+ *
+ * @Author  yangyue
+ * @Date 2023/7/28
+ */
+@Mapper
+public interface HtDpVideoAnalysisMapper extends BaseMapper<HtDpVideoAnalysis> {
+
+    List<AnalysisDTO> selectFilter(@Param("year") String year, @Param("yearMonth") String yearMonth);
+
+    List<VideoAnalysisLineDTO> selecttotal(@Param("year") String year, @Param("yearMonth") String yearMonth);
+
+}

video/src/main/java/cn/com/taiji/video/model/AnalysisDTO.java

@@ -0,0 +1,16 @@
+package cn.com.taiji.video.model;
+
+import lombok.Data;
+
+/**
+ * @Description
+ * @Author yangyue
+ * @Date 2023/7/28
+ */
+@Data
+public class AnalysisDTO {
+
+    private Integer type;
+
+    private Integer count;
+}

video/src/main/java/cn/com/taiji/video/model/AnalysisLineDTO.java

@@ -0,0 +1,23 @@
+package cn.com.taiji.video.model;
+
+import lombok.Data;
+
+/**
+ * @Description
+ * @Author yangyue
+ * @Date 2023/7/28
+ */
+@Data
+public class AnalysisLineDTO {
+
+    private String time;
+
+    private Integer count;
+
+    private Integer face;
+
+    private Integer car;
+
+    private Integer body;
+
+}

video/src/main/java/cn/com/taiji/video/model/HtDpVideoAnalysis.java

@@ -0,0 +1,75 @@
+package cn.com.taiji.video.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.util.Date;
+
+/**
+ * @Description 视频解析统计表
+ *
+ * @Author  yangyue
+ * @Date 2023/7/28
+ */
+@Data
+@TableName("ht_dp_video_analysis")
+public class HtDpVideoAnalysis implements Serializable {
+
+    /** 主键 */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /** 年 */
+    @TableField("`year`")
+    private String year;
+
+    /** 年月 */
+    @TableField("`year_month`")
+    private String yearMonth;
+
+    /** 统计日期 */
+    @TableField("stat_date")
+    private LocalDate statDate;
+
+    /** 任务编号 */
+    @TableField("task_id")
+    private String taskId;
+
+    /** 任务分类（1-人。2-车） */
+    @TableField("type")
+    private Integer type;
+
+    /** 图片抓拍总数 */
+    @TableField("pic_analysis_total")
+    private Integer picAnalysisTotal;
+
+    /** 提交失败数量 */
+    @TableField("pic_analysis_fail_count")
+    private Integer picAnalysisFailCount;
+
+    /** 提交成功数量 */
+    @TableField("pic_analysis_success_count")
+    private Integer picAnalysisSuccessCount;
+
+    /** 过滤数量 */
+    @TableField("pic_capture_total")
+    private Integer picCaptureTotal;
+
+    /** 分析总数 */
+    @TableField("pic_filter_count")
+    private Integer picFilterCount;
+
+    /** 分析失败数量 */
+    @TableField("pic_submit_fail_count")
+    private Integer picSubmitFailCount;
+
+    /** 分析成功数量 */
+    @TableField("pic_submit_success_count")
+    private Integer picSubmitSuccessCount;
+
+}

video/src/main/java/cn/com/taiji/video/model/VideoAnalysisLineDTO.java

@@ -0,0 +1,23 @@
+package cn.com.taiji.video.model;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Description
+ * @Author yangyue
+ * @Date 2023/7/28
+ */
+@Data
+public class VideoAnalysisLineDTO {
+
+    private String time;
+
+    private Integer face;
+
+    private Integer car;
+
+    private Integer body;
+
+}

video/src/main/java/cn/com/taiji/video/model/VideoAnalysisPieDTO.java

@@ -0,0 +1,25 @@
+package cn.com.taiji.video.model;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Description
+ * @Author yangyue
+ * @Date 2023/7/28
+ */
+@Data
+public class VideoAnalysisPieDTO {
+
+    private Integer total;
+
+    private Integer face;
+
+    private Integer car;
+
+    private Integer body;
+
+    // private List<AnalysisDTO> analysis;
+
+}

video/src/main/java/cn/com/taiji/video/service/IHtDpVideoAnalysisService.java

@@ -0,0 +1,21 @@
+package cn.com.taiji.video.service;
+
+
+import cn.com.taiji.video.model.*;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.List;
+
+/**
+ * @Description
+ *
+ * @Author  yangyue
+ * @Date 2023/7/28
+ */
+public interface IHtDpVideoAnalysisService extends IService<HtDpVideoAnalysis> {
+
+    List<AnalysisDTO> queryFilter(String year, String yearMonth);
+
+    List<VideoAnalysisLineDTO> querytotal(String year, String yearMonth);
+
+}

video/src/main/java/cn/com/taiji/video/service/IVideoUrlService.java

@@ -1,8 +1,11 @@
 package cn.com.taiji.video.service;
 
 
+import cn.com.taiji.video.model.VideoAnalysisLineDTO;
+import cn.com.taiji.video.model.VideoAnalysisPieDTO;
 import cn.com.taiji.video.model.VideoDTO;
 
+import java.time.LocalDate;
 import java.util.List;
 
 /**
@@ -25,4 +28,26 @@ public interface IVideoUrlService {
      */
     List<VideoDTO> queryVideoList();
 
+    /**
+     * 查询视频记录
+     * @param type 类型
+     * @param startDate 开始日期
+     * @param endDate 结束日期
+     */
+    void queryTestPie(Integer type, LocalDate startDate, LocalDate endDate);
+
+    /**
+     * 查询视频记录
+     * @param type 类型
+     * @return VideoAnalysisDTO
+     */
+    VideoAnalysisPieDTO queryPieRecord(Integer type);
+
+    /**
+     * 查询视频记录
+     * @param type 类型
+     * @return List<VideoAnalysisLineDTO>
+     */
+    List<VideoAnalysisLineDTO> queryLineRecord(Integer type);
+
 }

video/src/main/java/cn/com/taiji/video/service/impl/HtDpVideoAnalysisServiceImpl.java

@@ -0,0 +1,32 @@
+package cn.com.taiji.video.service.impl;
+
+import cn.com.taiji.video.mapper.HtDpVideoAnalysisMapper;
+import cn.com.taiji.video.model.*;
+import cn.com.taiji.video.service.IHtDpVideoAnalysisService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Description
+ * @Author yangyue
+ * @Date 2023/7/28
+ */
+@Service
+public class HtDpVideoAnalysisServiceImpl extends ServiceImpl<HtDpVideoAnalysisMapper, HtDpVideoAnalysis> implements IHtDpVideoAnalysisService {
+
+    @Autowired
+    private HtDpVideoAnalysisMapper videoAnalysisMapper;
+
+    @Override
+    public List<AnalysisDTO> queryFilter(String year, String yearMonth) {
+        return videoAnalysisMapper.selectFilter(year,yearMonth);
+    }
+
+    @Override
+    public List<VideoAnalysisLineDTO> querytotal(String year, String yearMonth) {
+        return videoAnalysisMapper.selecttotal(year,yearMonth);
+    }
+}

video/src/main/java/cn/com/taiji/video/service/impl/VideoUrlServiceImpl.java

@@ -2,20 +2,27 @@ package cn.com.taiji.video.service.impl;
 
 
 import cn.com.taiji.video.mapper.HtDpVideoMapper;
-import cn.com.taiji.video.model.HtDpVideo;
-import cn.com.taiji.video.model.VideoDTO;
+import cn.com.taiji.video.model.*;
+import cn.com.taiji.video.service.IHtDpVideoAnalysisService;
 import cn.com.taiji.video.service.IVideoUrlService;
-import com.alibaba.fastjson.JSON;
+import cn.com.taiji.video.utils.DataUtils;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.hikvision.artemis.sdk.ArtemisHttpUtil;
+import com.hikvision.artemis.sdk.config.ArtemisConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.*;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 import org.springframework.web.client.RestTemplate;
 
-import javax.annotation.Resource;
+import java.time.*;
+import java.time.format.DateTimeFormatter;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -35,6 +42,24 @@ public class VideoUrlServiceImpl implements IVideoUrlService {
     @Autowired
     private HtDpVideoMapper videoMapper;
 
+    @Autowired
+    private IHtDpVideoAnalysisService videoAnalysisService;
+
+    @Value("${taiji.faceTaskId}")
+    private String faceTaskId;
+
+    @Value("${taiji.carTaskId}")
+    private String carTaskId;
+
+    @Value("${taiji.url}")
+    private String analysisUrl;
+
+    @Value("${taiji.ak}")
+    private String ak;
+
+    @Value("${taiji.sk}")
+    private String sk;
+
     String url = "http://10.110.80.31:8888";
 
     @Override
@@ -84,4 +109,172 @@ public class VideoUrlServiceImpl implements IVideoUrlService {
     public List<VideoDTO> queryVideoList() {
         return videoMapper.selectVideoList();
     }
+
+    @Override
+    public void queryTestPie(Integer type, LocalDate startDate, LocalDate endDate) {
+        DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM");
+        ArtemisConfig.host=analysisUrl;
+        ArtemisConfig.appKey=ak;
+        ArtemisConfig.appSecret=sk;
+        final String artemispath = "/artemis";
+        List<LocalDate> localDates = DataUtils.getAllDatesInTheDateRange(startDate, endDate);
+        if (null != localDates && localDates.size() > 0) {
+            localDates.forEach(item -> {
+                long startTimestamp = LocalDateTime.of(item, LocalTime.MIN).toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
+                long endTimestamp = LocalDateTime.of(item, LocalTime.MAX).toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
+                log.info("开始时间：{} ；结束时间：{}",startTimestamp,endTimestamp);
+                HtDpVideoAnalysis videoAnalysis = new HtDpVideoAnalysis();
+                videoAnalysis.setYear(String.valueOf(item.getYear()));
+                videoAnalysis.setYearMonth(item.format(fmt));
+                videoAnalysis.setStatDate(item);
+                videoAnalysis.setType(type);
+                String taskId = carTaskId;
+                if (1 == type) {
+                    taskId = faceTaskId;
+                }
+                videoAnalysis.setTaskId(taskId);
+                String previewurlsapi = artemispath + "/api/v2/tasks/picture/statistics/"+taskId+"/"+ startTimestamp +"/"+endTimestamp;
+                log.info(previewurlsapi);
+
+                Map<String, String> path = new HashMap<String, String>(2) {
+                    {
+                        put("https://", previewurlsapi);//根据现场环境部署确认是http还是https
+                    }
+                };
+                String contentType = "application/json";
+                // post请求application/json类型参数
+                String result = ArtemisHttpUtil.doGetArtemis(path, null, null, contentType, null);
+                log.info(result);
+                JSONObject jsonObject = JSONObject.parseObject(result).getJSONObject("data");
+                videoAnalysis.setPicAnalysisTotal(jsonObject.getInteger("picAnalysisTotal"));
+                videoAnalysis.setPicAnalysisFailCount(jsonObject.getInteger("picAnalysisFailCount"));
+                videoAnalysis.setPicAnalysisSuccessCount(jsonObject.getInteger("picAnalysisSuccessCount"));
+                videoAnalysis.setPicCaptureTotal(jsonObject.getInteger("picCaptureTotal"));
+                videoAnalysis.setPicFilterCount(jsonObject.getInteger("picFilterCount"));
+                videoAnalysis.setPicSubmitFailCount(jsonObject.getInteger("picSubmitFailCount"));
+                videoAnalysis.setPicSubmitSuccessCount(jsonObject.getInteger("picSubmitSuccessCount"));
+                videoAnalysisService.saveOrUpdate(
+                        videoAnalysis,
+                        Wrappers.<HtDpVideoAnalysis>lambdaUpdate()
+                                .eq(HtDpVideoAnalysis::getType,type)
+                                .eq(HtDpVideoAnalysis::getStatDate,item));
+
+            });
+        }
+    }
+
+    @Scheduled(cron = "0 0 5 * * ?")
+    public void scheduleOne() {
+        log.info("===========定时开始===========");
+        LocalDate localDate = LocalDate.now().plusDays(-1);
+        log.info("统计日期：{}",localDate);
+        log.info("获取视频解析人员");
+        this.querytime(1,localDate);
+        log.info("获取视频解析车辆");
+        this.querytime(2,localDate);
+        log.info("===========定时结束===========");
+    }
+
+    public void querytime(Integer type, LocalDate localDate) {
+        DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM");
+        ArtemisConfig.host=analysisUrl;
+        ArtemisConfig.appKey=ak;
+        ArtemisConfig.appSecret=sk;
+        final String artemispath = "/artemis";
+        long startTimestamp = LocalDateTime.of(localDate, LocalTime.MIN).toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
+        long endTimestamp = LocalDateTime.of(localDate, LocalTime.MAX).toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
+        log.info("开始时间：{} ；结束时间：{}",startTimestamp,endTimestamp);
+        HtDpVideoAnalysis videoAnalysis = new HtDpVideoAnalysis();
+        videoAnalysis.setYear(String.valueOf(localDate.getYear()));
+        videoAnalysis.setYearMonth(localDate.format(fmt));
+        videoAnalysis.setStatDate(localDate);
+        videoAnalysis.setType(type);
+        String taskId = carTaskId;
+        if (1 == type) {
+            taskId = faceTaskId;
+        }
+        videoAnalysis.setTaskId(taskId);
+        String previewurlsapi = artemispath + "/api/v2/tasks/picture/statistics/"+taskId+"/"+ startTimestamp +"/"+endTimestamp;
+        log.info(previewurlsapi);
+
+        Map<String, String> path = new HashMap<String, String>(2) {
+            {
+                put("https://", previewurlsapi);//根据现场环境部署确认是http还是https
+            }
+        };
+        String contentType = "application/json";
+        // post请求application/json类型参数
+        String result = ArtemisHttpUtil.doGetArtemis(path, null, null, contentType, null);
+        log.info(result);
+        JSONObject jsonObject = JSONObject.parseObject(result).getJSONObject("data");
+        videoAnalysis.setPicAnalysisTotal(jsonObject.getInteger("picAnalysisTotal"));
+        videoAnalysis.setPicAnalysisFailCount(jsonObject.getInteger("picAnalysisFailCount"));
+        videoAnalysis.setPicAnalysisSuccessCount(jsonObject.getInteger("picAnalysisSuccessCount"));
+        videoAnalysis.setPicCaptureTotal(jsonObject.getInteger("picCaptureTotal"));
+        videoAnalysis.setPicFilterCount(jsonObject.getInteger("picFilterCount"));
+        videoAnalysis.setPicSubmitFailCount(jsonObject.getInteger("picSubmitFailCount"));
+        videoAnalysis.setPicSubmitSuccessCount(jsonObject.getInteger("picSubmitSuccessCount"));
+        videoAnalysisService.saveOrUpdate(
+                videoAnalysis,
+                Wrappers.<HtDpVideoAnalysis>lambdaUpdate()
+                        .eq(HtDpVideoAnalysis::getType,type)
+                        .eq(HtDpVideoAnalysis::getStatDate,localDate));
+    }
+
+    @Override
+    public VideoAnalysisPieDTO queryPieRecord(Integer type) {
+        LocalDate localDate = LocalDate.now();
+        String year = String.valueOf(localDate.getYear());
+        DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM");
+        String yearMonth = localDate.format(fmt);
+        List<AnalysisDTO> analysisDTO;
+        if (1 == type) {
+            analysisDTO = videoAnalysisService.queryFilter(year, null);
+        } else {
+            analysisDTO = videoAnalysisService.queryFilter(null,yearMonth);
+        }
+        VideoAnalysisPieDTO videoAnalysisPieDTO = new VideoAnalysisPieDTO();
+        // videoAnalysisPieDTO.setAnalysis(analysisDTO);
+        Integer total = 0;
+        Integer face = 0;
+        Integer car = 0;
+        Integer body = 0;
+        if (null != analysisDTO && analysisDTO.size() > 0) {
+            for (AnalysisDTO dto: analysisDTO) {
+                total += dto.getCount();
+                if (dto.getType() == 1) {
+                    face = dto.getCount();
+                }
+                if (dto.getType() == 2) {
+                    car = dto.getCount();
+                }
+                if (dto.getType() == 3) {
+                    body = dto.getCount();
+                }
+            }
+        }
+        videoAnalysisPieDTO.setTotal(total);
+        videoAnalysisPieDTO.setFace(face);
+        videoAnalysisPieDTO.setCar(car);
+        videoAnalysisPieDTO.setBody(body);
+
+        return videoAnalysisPieDTO;
+    }
+
+    @Override
+    public List<VideoAnalysisLineDTO> queryLineRecord(Integer type) {
+
+        LocalDate localDate = LocalDate.now();
+        String year = String.valueOf(localDate.getYear());
+        DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM");
+        String yearMonth = localDate.format(fmt);
+        List<VideoAnalysisLineDTO> analysisLineDTO;
+        if (1 == type) {
+            analysisLineDTO = videoAnalysisService.querytotal(year, null);
+        } else {
+            analysisLineDTO = videoAnalysisService.querytotal(null,yearMonth);
+        }
+
+        return analysisLineDTO;
+    }
 }

video/src/main/java/cn/com/taiji/video/utils/DataUtils.java

@@ -0,0 +1,34 @@
+package cn.com.taiji.video.utils;
+
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Description
+ * @Author yangyue
+ * @Date 2023/7/28
+ */
+public class DataUtils {
+
+    /**
+     * 根据传入的日期,获取时间区间中所有的日期
+     *
+     * @param startDate 开始日期
+     * @param endDate 结束日期
+     * @return java.util.List<java.time.LocalDate>
+     */
+    public static List<LocalDate> getAllDatesInTheDateRange(LocalDate startDate, LocalDate endDate) {
+        List<LocalDate> localDateList = new ArrayList<>();
+        // 开始时间必须小于结束时间
+        if (startDate.isAfter(endDate)) {
+            return null;
+        }
+        while (startDate.isBefore(endDate)) {
+            localDateList.add(startDate);
+            startDate = startDate.plusDays(1);
+        }
+        localDateList.add(endDate);
+        return localDateList;
+    }
+}

video/src/main/resources/application.yml

@@ -56,4 +56,10 @@ mybatis-plus:
       logic-not-delete-value: 0
       id-type: assign_id
       update-strategy: not_empty
-    banner: false   # 不打印banner
+    banner: false   # 不打印banner
+taiji:
+  url: 10.110.33.6:443
+  ak: 27335616
+  sk: KZTwnMbtnKHCyNju0eur
+  faceTaskId: 0db384d3bbdd432aba457d64e347d369
+  carTaskId: 4ef6713e9b894c35b572800f30fd8eba

video/src/main/resources/mapper/HtDpVideoAnalysisMapper.xml

@@ -0,0 +1,49 @@
+<?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="cn.com.taiji.video.mapper.HtDpVideoAnalysisMapper">
+
+    <select id="selectFilter" resultType="AnalysisDTO">
+        SELECT type,sum(pic_filter_count) AS count FROM `ht_dp_video_analysis`
+        <where>
+        <if test="year != null and year != ''">
+            and `year` = #{year}
+        </if>
+        <if test="yearMonth != null and yearMonth != ''">
+            and `year_month` = #{yearMonth}
+        </if>
+        </where>
+        GROUP BY type
+    </select>
+    <select id="selecttotal" resultType="cn.com.taiji.video.model.VideoAnalysisLineDTO">
+        SELECT
+        <if test="year != null and year != ''">
+            t.`year_month` as time,
+            (select sum(pic_filter_count) from `ht_dp_video_analysis` t1 where t1.`year_month` = t.`year_month` and t1.type = 1) as face,
+            (select sum(pic_filter_count) from `ht_dp_video_analysis` t1 where t1.`year_month` = t.`year_month` and t1.type = 2) as car,
+            (select sum(pic_filter_count) from `ht_dp_video_analysis` t1 where t1.`year_month` = t.`year_month` and t1.type = 3) as body
+        </if>
+        <if test="yearMonth != null and yearMonth != ''">
+            t.stat_date as time,
+            (select sum(pic_filter_count) from `ht_dp_video_analysis` t1 where t1.stat_date = t.stat_date and t1.type = 1) as face,
+            (select sum(pic_filter_count) from `ht_dp_video_analysis` t1 where t1.stat_date = t.stat_date and t1.type = 2) as car,
+            (select sum(pic_filter_count) from `ht_dp_video_analysis` t1 where t1.stat_date = t.stat_date and t1.type = 3) as body
+        </if>
+        FROM `ht_dp_video_analysis` t
+        where
+        <if test="year != null and year != ''">
+            t.`year` = #{year}
+        </if>
+        <if test="yearMonth != null and yearMonth != ''">
+            t.`year_month` = #{yearMonth}
+        </if>
+        GROUP BY
+        <if test="year != null and year != ''">
+            t.`year_month`
+        </if>
+        <if test="yearMonth != null and yearMonth != ''">
+            t.stat_date
+        </if>
+    </select>
+</mapper>