haozq
/
jjsp_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

监控覆盖

This commit is contained in:
cwchen 2024-12-11 15:03:06 +08:00
parent 1af5d4eb73
commit b81e376eda
9 changed files with 545 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/controller/MonitoringCoverageController.java Normal file
View File

@ -0,0 +1,80 @@
package com.sercurityControl.proteam.supplement.controller;
import com.securityControl.common.core.web.domain.AjaxResult;
import com.securityControl.common.log.annotation.SysLog;
import com.securityControl.common.log.enums.OperaType;
import com.sercurityControl.proteam.supplement.domain.dto.ParamsDto;
import com.sercurityControl.proteam.supplement.service.MonitoringCoverageService;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
/**
* @className:MonitoringCoverageController
* @author:cwchen
* @date:2024-12-11-9:17
* @version:1.0
* @description:监控覆盖-controller
*/
@RestController
@RequestMapping("/pot/monitoringCoverage/")
@Slf4j
public class MonitoringCoverageController {
@Resource(name = "MonitoringCoverageService")
private MonitoringCoverageService service;
@ApiOperation(value = "监控活跃度分析")
@SysLog(title = "监控覆盖", model = "安全风险->监控覆盖", operaType = OperaType.QUERY, details = "监控覆盖",logType = 1)
@GetMapping("getHyd")
public AjaxResult getHyd(ParamsDto dto){
AjaxResult res = service.getHyd(dto);
return res;
}
@ApiOperation(value = "监控覆盖度分析")
@GetMapping("getFgd")
public AjaxResult getFgd(ParamsDto dto){
AjaxResult res = service.getFgd(dto);
return res;
}
@ApiOperation(value = "地图球机")
@GetMapping("getMap")
public AjaxResult getMap(ParamsDto dto){
AjaxResult res = service.getMap(dto);
return res;
}
@ApiOperation(value = "球机异常数量")
@GetMapping("getErrorNum")
public AjaxResult getErrorNum(ParamsDto dto){
AjaxResult res = service.getErrorNum(dto);
return res;
}
@ApiOperation(value = "下行观看分析")
@GetMapping("getWatchNum")
public AjaxResult getWatchNum(ParamsDto dto){
AjaxResult res = service.getWatchNum(dto);
return res;
}
@ApiOperation(value = "风险球机覆盖度")
@GetMapping("getCoverRate")
public AjaxResult getCoverRate(ParamsDto dto){
AjaxResult res = service.getCoverRate(dto);
return res;
}
@ApiOperation(value = "球机速率正常/异常数量")
@GetMapping("getSpeedNum")
public AjaxResult getSpeedNum(ParamsDto dto){
AjaxResult res = service.getSpeedNum(dto);
return res;
}
}

60
securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/domain/vo/MonitoringCoverageVo.java Normal file
View File

@ -0,0 +1,60 @@
package com.sercurityControl.proteam.supplement.domain.vo;
import lombok.Data;
/**
* @className:MonitoringCoverageVo
* @author:cwchen
* @date:2024-12-11-10:11
* @version:1.0
* @description:监控覆盖
*/
@Data
public class MonitoringCoverageVo {
private int num;
private String id;
private String name;
private String runTime;
private String time;
private long timeValue;
/**观看次数*/
private int watchTime;
/**风险等级*/
private String riskLevel;
/**站班会地址*/
private String address;
/**经度*/
private String lon;
/**纬度*/
private String lat;
/**二级风险数量*/
private int twoRiskNum;
/**三级风险数量*/
private int threeRiskNum;
/**四级风险数量*/
private int fourRiskNum;
/**五级风险数量*/
private int fiveRiskNum;
private int totalRiskNum;
private double twoRate;
private double threeRate;
private double fourRate;
private double fiveRate;
/**视频设备视频速率正常数量*/
private int errorNum;
/**视频设备视频速率异常数量*/
private int normalNum;
}

80
securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/mapper/MonitoringCoverageMapper.java Normal file
View File

@ -0,0 +1,80 @@
package com.sercurityControl.proteam.supplement.mapper;
import com.sercurityControl.proteam.supplement.domain.dto.ParamsDto;
import com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @className:MonitoringCoverageMapper
* @author:cwchen
* @date:2024-12-11-9:18
* @version:1.0
* @description:监控覆盖-mapper
*/
@Repository("MonitoringCoverageMapper")
public interface MonitoringCoverageMapper {
/**
* 监控覆盖-活跃度分析
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 10:23
*/
List<MonitoringCoverageVo> getHyd(ParamsDto dto);
/**
* 监控覆盖-覆盖度分析
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 13:10
*/
List<MonitoringCoverageVo> getFgd(ParamsDto dto);
/**
* 地图球机
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 13:26
*/
List<MonitoringCoverageVo> getMap(ParamsDto dto);
/**
* 球机异常数量
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 14:11
*/
List<MonitoringCoverageVo> getErrorNum(ParamsDto dto);
/**
* 下行观看分析
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 14:23
*/
List<MonitoringCoverageVo> getWatchNum(ParamsDto dto);
/**
* 风险球机覆盖度
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 14:33
*/
List<MonitoringCoverageVo> getCoverRate(ParamsDto dto);
/**
* 球机速率正常/异常数量
* @param dto
* @return List<MonitoringCoverageVo>
* @author cwchen
* @date 2024/12/11 14:53
*/
List<MonitoringCoverageVo> getSpeedNum(ParamsDto dto);
}

76
securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/service/MonitoringCoverageService.java Normal file
View File

@ -0,0 +1,76 @@
package com.sercurityControl.proteam.supplement.service;
import com.securityControl.common.core.web.domain.AjaxResult;
import com.sercurityControl.proteam.supplement.domain.dto.ParamsDto;
/**
* @className:MonitoringCoverageService
* @author:cwchen
* @date:2024-12-11-9:17
* @version:1.0
* @description:监控覆盖-service
*/
public interface MonitoringCoverageService {
/**
* 监控覆盖-活跃度分析
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 10:21
*/
AjaxResult getHyd(ParamsDto dto);
/**
* 监控覆盖-覆盖度分析
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 13:08
*/
AjaxResult getFgd(ParamsDto dto);
/**
* 地图球机
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 13:26
*/
AjaxResult getMap(ParamsDto dto);
/**
* 球机异常数量
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 14:10
*/
AjaxResult getErrorNum(ParamsDto dto);
/**
* 下行观看分析
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 14:22
*/
AjaxResult getWatchNum(ParamsDto dto);
/**
* 风险球机覆盖度
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 14:32
*/
AjaxResult getCoverRate(ParamsDto dto);
/**
* 球机速率正常/异常数量
* @param dto
* @return AjaxResult
* @author cwchen
* @date 2024/12/11 14:53
*/
AjaxResult getSpeedNum(ParamsDto dto);
}

136
securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/service/impl/MonitoringCoverageServiceImpl.java Normal file
View File

@ -0,0 +1,136 @@
package com.sercurityControl.proteam.supplement.service.impl;
import com.securityControl.common.core.web.domain.AjaxResult;
import com.sercurityControl.proteam.supplement.domain.dto.ParamsDto;
import com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo;
import com.sercurityControl.proteam.supplement.mapper.MonitoringCoverageMapper;
import com.sercurityControl.proteam.supplement.service.MonitoringCoverageService;
import com.sercurityControl.proteam.util.DateTimeHelper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
/**
* @className:MonitoringCoverageServiceImpl
* @author:cwchen
* @date:2024-12-11-9:18
* @version:1.0
* @description:监控覆盖-impl
*/
@Service("MonitoringCoverageService")
@Slf4j
public class MonitoringCoverageServiceImpl implements MonitoringCoverageService {
@Resource(name = "MonitoringCoverageMapper")
private MonitoringCoverageMapper mapper;
@Override
public AjaxResult getHyd(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getHyd(dto);
int num = 0;
Date endDate = new Date();
for (MonitoringCoverageVo vo : list) {
num ++;
vo.setNum(num);
Date runTime = DateTimeHelper.parse(vo.getRunTime(), "yyyy-MM-dd HH:mm:ss");
String gapTime = DateTimeHelper.getGapTime(endDate, runTime);
long timeValue = DateTimeHelper.getGapTime2(endDate, runTime);
vo.setTime(gapTime);
vo.setTimeValue(timeValue);
}
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
@Override
public AjaxResult getFgd(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getFgd(dto);
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
@Override
public AjaxResult getMap(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getMap(dto);
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
@Override
public AjaxResult getErrorNum(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getErrorNum(dto);
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
@Override
public AjaxResult getWatchNum(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getWatchNum(dto);
int num = 0;
for (MonitoringCoverageVo vo : list) {
num ++;
vo.setNum(num);
}
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
@Override
public AjaxResult getCoverRate(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getCoverRate(dto);
for (MonitoringCoverageVo vo : list) {
vo.setTwoRate(handleRate(vo.getTwoRiskNum(), vo.getTotalRiskNum()));
vo.setThreeRate(handleRate(vo.getThreeRiskNum(), vo.getTotalRiskNum()));
vo.setFourRate(handleRate(vo.getFourRiskNum(), vo.getTotalRiskNum()));
vo.setFiveRate(handleRate(vo.getFiveRiskNum(), vo.getTotalRiskNum()));
}
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
public static double handleRate(int a, int b) {
if (a == 0 || b == 0) {
return 0.0;
}
double ratio = (double) (a * 100) / b;
return Double.valueOf(String.format("%.2f", ratio));
}
@Override
public AjaxResult getSpeedNum(ParamsDto dto) {
List<MonitoringCoverageVo> list = null;
try {
list = mapper.getSpeedNum(dto);
} catch (Exception e) {
log.error(e.toString(),e);
}
return AjaxResult.success(list);
}
}

39
securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/util/DateTimeHelper.java
View File

@ -242,7 +242,6 @@ public class DateTimeHelper {
}
/**
* @return
*/
@ -646,4 +645,42 @@ public class DateTimeHelper {
String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
return time;
}
public static String getGapTime(Date date1, Date date2) {
// 相差的毫秒值
Long milliseconds = date1.getTime() - date2.getTime();
long nd = 1000 * 24 * 60 * 60;// 一天的毫秒数
long nh = 1000 * 60 * 60;// 一小时的毫秒数
long nm = 1000 * 60;// 一分钟的毫秒数
long ns = 1000;// 一秒钟的毫秒数
long day = milliseconds / nd; // 计算相差多少天
long hour = milliseconds % nd / nh; // 计算相差剩余多少小时
long min = milliseconds % nd % nh / nm; // 计算相差剩余多少分钟
long sec = milliseconds % nd % nh % nm / ns; // 计算相差剩余多少秒
// System.out.println("时间相差：" + day + "天" + hour + "小时" + min + "分钟" + sec + "秒");
long hourAll = milliseconds / nh; // 计算相差多少小时
// System.out.println("时间相差：" + hourAll + "小时" + min + "分钟" + sec + "秒");
long min2 = milliseconds / nm; // 计算相差多少分钟
// System.out.println("时间相差：" + min2 + "分钟" + sec + "秒");
String overTime = hourAll + "小时" + min + "分" + sec + "秒";
return overTime;
}
public static long getGapTime2(Date date1, Date date2) {
// 相差的毫秒值
Long milliseconds = date1.getTime() - date2.getTime();
long nd = 1000 * 24 * 60 * 60;// 一天的毫秒数
long nh = 1000 * 60 * 60;// 一小时的毫秒数
long nm = 1000 * 60;// 一分钟的毫秒数
long ns = 1000;// 一秒钟的毫秒数
long sec = milliseconds / ns; // 计算相差剩余多少秒
return sec;
}
}

73
securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/MonitoringCoverageMapper.xml Normal file
View File

@ -0,0 +1,73 @@
<?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.sercurityControl.proteam.supplement.mapper.MonitoringCoverageMapper">
<!--监控覆盖-活跃度分析-->
<select id="getHyd" resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT td.mac_id AS name,
DATE_FORMAT(jjmc.run_time,'%Y-%m-%d %H:%i:%s') AS runTime
FROM jj_monitoring_coverage jjmc
LEFT JOIN t_device td ON jjmc.camera_no = td.t_code
ORDER BY jjmc.run_time
</select>
<!--监控覆盖-覆盖度分析-->
<select id="getFgd" resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT so.city_name AS name,
a.num
FROM sys_org so
LEFT JOIN (
SELECT jjcm.build_unit_code AS org,
COUNT(jjcm.build_unit_code) AS num
FROM jj_monitoring_coverage jjmc
LEFT JOIN jj_class_meetting jjcm ON jjmc.class_id = jjcm.id
GROUP BY jjcm.build_unit_code
) a ON so.org_id = a.org
ORDER BY IFNULL(a.num,0) DESC
</select>
<!--地图球机-->
<select id="getMap" resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT jjcm.re_assessment_risk_level AS riskLevel,
jjcm.tool_box_talk_address AS address,
td.mac_id AS name,
jjcm.tool_box_talk_longitude AS lon,
jjcm.tool_box_talk_Latitude AS lat
FROM jj_monitoring_coverage jjmc
LEFT JOIN jj_class_meetting jjcm ON jjmc.class_id = jjcm.id
LEFT JOIN t_device td ON jjmc.camera_no = td.t_code
</select>
<!--球机异常数量-->
<select id="getErrorNum"
resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT jjmc.error_type AS name,COUNT(jjmc.error_type) AS num
FROM jj_monitoring_coverage jjmc
WHERE jjmc.error_type IN ('1','2','3','4','5','6')
GROUP BY jjmc.error_type
</select>
<!--下行观看分析-->
<select id="getWatchNum"
resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT td.mac_id AS name,
jjmc.watch_time AS watchTime
FROM jj_monitoring_coverage jjmc
LEFT JOIN t_device td ON jjmc.camera_no = td.t_code
ORDER BY jjmc.watch_time DESC
</select>
<!--风险球机覆盖度-->
<select id="getCoverRate"
resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT COUNT(IF(jjcm.re_assessment_risk_level = '2',1,null)) AS twoRiskNum,
COUNT(IF(jjcm.re_assessment_risk_level = '3',1,null)) AS threeRiskNum,
COUNT(IF(jjcm.re_assessment_risk_level = '4',1,null)) AS fourRiskNum,
COUNT(IF(jjcm.re_assessment_risk_level = '5',1,null)) AS fiveRiskNum,
COUNT(jjcm.re_assessment_risk_level) AS totalRiskNum
FROM jj_monitoring_coverage jjmc
LEFT JOIN jj_class_meetting jjcm ON jjcm.id = jjmc.class_id
</select>
<!--球机速率正常/异常数量-->
<select id="getSpeedNum"
resultType="com.sercurityControl.proteam.supplement.domain.vo.MonitoringCoverageVo">
SELECT COUNT(IF(jjmc.error_type = '7',1,null)) AS errorNum,
COUNT(IF(jjmc.error_type != '7',1,null)) AS normalNum
FROM jj_monitoring_coverage jjmc
</select>
</mapper>

2
securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/RiskCostMapper.xml
View File

@ -27,7 +27,7 @@
<if test="startDay!=null and startDay!='' and endDay!=null and endDay!=''">
AND jjcm.current_constr_date BETWEEN #{startDay} AND #{endDay}
</if>
AND jjcm.delete_flag = '0'
AND jjcm.delete_flag = 0
</where>
ORDER BY jjcm.create_time DESC
</select>

2
securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/RiskTimeMapper.xml
View File

@ -27,7 +27,7 @@
<if test="startDay!=null and startDay!='' and endDay!=null and endDay!=''">
AND jjcm.current_constr_date BETWEEN #{startDay} AND #{endDay}
</if>
AND jjcm.delete_flag = '0'
AND jjcm.delete_flag = 0
</where>
ORDER BY jjcm.create_time DESC
</select>