视频mongo重构

xiangpei

2024-09-03 d03ef8779645bdcc106d99d34b2720bd0e59ddd6

视频mongo重构

 ycl-server/src/main/java/com/ycl/platform/controller/DataCenterController.java

@@ -122,8 +122,7 @@
    @PostMapping("/videoMinistryVideoAvailable")
    public Result videoMinistryVideoAvailable(@RequestBody DataCenterQuery query) {
        query.setTime();
        // TODO 做部级数据区分
        return dataCenterService.videoLabelingAccuracy(query);
        return dataCenterService.deptVideoAvailabilityRate(query);
    }

    /**

 ycl-server/src/main/java/com/ycl/platform/service/DataCenterService.java

@@ -67,6 +67,14 @@
    Result videoAvailabilityRate(DataCenterQuery query);

    /**
     * 视频：部级点位录像可用率
     *
     * @param query
     * @return
     */
    Result deptVideoAvailabilityRate(DataCenterQuery query);

    /**
     * 视频：重点点位录像可用率
     *
     * @param query

 ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java

@@ -51,7 +51,6 @@
     */
    @Override
    public Result videoPointOnlineRate(DataCenterQuery params) {
        params.setTime();
        // 生成查询
        Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, null);

@@ -74,7 +73,6 @@
     */
    @Override
    public Result deptVideoPointOnlineRate(DataCenterQuery params) {
        params.setTime();
        // 先查出部级点位的国标
        List<String> deptGBList = pointMapper.getDeptPointGB(0);

@@ -100,7 +98,6 @@
     */
    @Override
    public Result videoImportantPointOnlineRate(DataCenterQuery params) {
        params.setTime();
        // 先查出重点点位的国标
        List<String> deptGBList = pointMapper.getDeptPointGB(1);

@@ -129,7 +126,6 @@
     */
    @Override
    public Result videoImportantPointImageOnlineRate(DataCenterQuery params) {
        params.setTime();
        // 先查出重点指挥图像点位的国标
        List<String> deptGBList = pointMapper.getDeptPointGB(2);

@@ -159,16 +155,17 @@
    @Override
    public Result videoOneMachineDocumentRegister(DataCenterQuery params) {

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());
        Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null);

        long total = mongoTemplate.count(query, OneMachineFileResult.class);
        List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class);
        long total = mongoTemplate.count(query, MonitorQualifyResult.class);
        MongoUtil.setPage(query, params, TIME_FIELD);
        List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class);
        // 统计数
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OneMachineFileResult.class);
        long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OneMachineFileResult.class);
        long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OneMachineFileResult.class);
        long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OneMachineFileResult.class);
        long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OneMachineFileResult.class);
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), MonitorQualifyResult.class);
        long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), MonitorQualifyResult.class);
        long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), MonitorQualifyResult.class);
        long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), MonitorQualifyResult.class);
        long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), MonitorQualifyResult.class);
        HashMap<String, Object> map = new HashMap<>();
        map.put("count", Arrays.asList(nonNetwork, network, video, car, face));
        map.put("list", resultList);
@@ -184,9 +181,10 @@
    @Override
    public Result videoOneMachineDocumentQualified(DataCenterQuery params) {

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());
        Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null);

        long total = mongoTemplate.count(query, MonitorQualifyResult.class);
        MongoUtil.setPage(query, params, TIME_FIELD);
        List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class);
        // 统计数
        HashMap<String, Object> map = new HashMap<>();
@@ -203,17 +201,18 @@
     */
    @Override
    public Result videoAssessmentFileRatio(DataCenterQuery params) {
        // TODO 新增一张表记录每次的档案考核
        Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null);

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());

        long total = mongoTemplate.count(query, OneMachineFileResult.class);
        List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class);
        long total = mongoTemplate.count(query, MonitorQualifyResult.class);
        MongoUtil.setPage(query, params, TIME_FIELD);
        List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class);
        // 统计数
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OneMachineFileResult.class);
        long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OneMachineFileResult.class);
        long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OneMachineFileResult.class);
        long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OneMachineFileResult.class);
        long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OneMachineFileResult.class);
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), MonitorQualifyResult.class);
        long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), MonitorQualifyResult.class);
        long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), MonitorQualifyResult.class);
        long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), MonitorQualifyResult.class);
        long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), MonitorQualifyResult.class);
        HashMap<String, Object> map = new HashMap<>();
        map.put("count", Arrays.asList(nonNetwork, network, video, car, face));
        map.put("list", resultList);
@@ -229,9 +228,36 @@
    @Override
    public Result videoAvailabilityRate(DataCenterQuery params) {

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());
        Query query = MongoUtil.getQuery(params, "deviceId", "createTime", null);

        long total = mongoTemplate.count(query, RecordMetaDSumResult.class);
        MongoUtil.setPage(query, params, "createTime");
        List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class);
        // 统计数
        long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("1")), RecordMetaDSumResult.class);
        long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("2")), RecordMetaDSumResult.class);
        long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("-1")), RecordMetaDSumResult.class);
        HashMap<String, Object> map = new HashMap<>();
        map.put("count", Arrays.asList(one, two, three));
        map.put("list", resultList);
        return Result.ok().data(map).total(total);
    }

    /**
     * 视频：部级录像可用率
     *
     * @param params
     * @return
     */
    @Override
    public Result deptVideoAvailabilityRate(DataCenterQuery params) {

        List<String> deptGBList = pointMapper.getDeptPointGB(0);

        Query query = MongoUtil.getQuery(params, "deviceId", "createTime", deptGBList);

        long total = mongoTemplate.count(query, RecordMetaDSumResult.class);
        MongoUtil.setPage(query, params, "createTime");
        List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class);
        // 统计数
        long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("1")), RecordMetaDSumResult.class);
@@ -252,9 +278,12 @@
    @Override
    public Result videoImportantPointAvailabilityRate(DataCenterQuery params) {

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());
        List<String> deptGBList = pointMapper.getDeptPointGB(1);

        Query query = MongoUtil.getQuery(params, "deviceId", "createTime", deptGBList);

        long total = mongoTemplate.count(query, RecordMetaDSumResult.class);
        MongoUtil.setPage(query, params, "createTime");
        List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class);
        // 统计数
        long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("1")), OneMachineFileResult.class);
@@ -300,9 +329,11 @@
    @Override
    public Result videoImportantPointLabelingAccuracy(DataCenterQuery params) {

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());
        List<String> deptGBList = pointMapper.getDeptPointGB(1);
        Query query = MongoUtil.getQuery(params, "deviceNo", "checkTime", deptGBList);

        long total = mongoTemplate.count(query, OsdCheckResult.class);
        MongoUtil.setPage(query, params, "checkTime");
        List<OsdCheckResult> resultList = mongoTemplate.find(query, OsdCheckResult.class);
        // 统计数
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OsdCheckResult.class);
@@ -350,16 +381,19 @@
    @Override
    public Result videoImportantPointCheckTimeAccuracy(DataCenterQuery params) {

        Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>());
        List<String> deptGBList = pointMapper.getDeptPointGB(1);

        long total = mongoTemplate.count(query, OneMachineFileResult.class);
        List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class);
        Query query = MongoUtil.getQuery(params, "deviceId", "checkTime", deptGBList);

        long total = mongoTemplate.count(query, OsdCheckResult.class);
        MongoUtil.setPage(query, params, "checkTime");
        List<OsdCheckResult> resultList = mongoTemplate.find(query, OsdCheckResult.class);
        // 统计数
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OneMachineFileResult.class);
        long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OneMachineFileResult.class);
        long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OneMachineFileResult.class);
        long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OneMachineFileResult.class);
        long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OneMachineFileResult.class);
        long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OsdCheckResult.class);
        long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OsdCheckResult.class);
        long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OsdCheckResult.class);
        long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OsdCheckResult.class);
        long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OsdCheckResult.class);
        HashMap<String, Object> map = new HashMap<>();
        map.put("count", Arrays.asList(nonNetwork, network, video, car, face));
        map.put("list", resultList);

 ycl-server/src/main/java/com/ycl/task/MonitorTask.java

@@ -64,7 +64,7 @@
        Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday)));
        List<MonitorQualifyResult> oneMachineFileResults = mongoTemplate.find(query, MonitorQualifyResult.class);
        //mongo品牌数据
        Query OSDQuery = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday))));
        Query OSDQuery = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday)));
        Map<String, OsdCheckResult> osdMap = mongoTemplate.find(query, OsdCheckResult.class).stream().collect(Collectors.toMap(OsdCheckResult::getDeviceNo, Function.identity()));
        //数据库monitor表数据
        Map<String, TMonitorVO> monitorVOMap = monitorMapper.selectMonitorVOList().stream().collect(Collectors.toMap(TMonitorVO::getSerialNumber, Function.identity()));