From dbf1793b62b69f824a401242cfd5430dd4992fa8 Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期一, 18 十一月 2024 12:01:14 +0800
Subject: [PATCH] 运行监控导出
---
ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java | 2
ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java | 3
ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java | 66 ++++++++++++++++
ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java | 14 ++
ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml | 26 ++++++
ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java | 88 +++++++++++++++++-----
6 files changed, 176 insertions(+), 23 deletions(-)
diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java
new file mode 100644
index 0000000..a5edb27
--- /dev/null
+++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java
@@ -0,0 +1,66 @@
+package com.ycl.platform.domain.excel;
+
+import annotation.Excel;
+import com.ycl.platform.domain.vo.DynamicColumnVO;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class TMonitorExp {
+ /**
+ * 璁惧缂栫爜
+ */
+ @Excel(name = "璁惧缂栫爜")
+ private String serialNumber;
+
+ /**
+ * 璁惧鍚嶇О
+ */
+ @Excel(name = "璁惧鍚嶇О")
+ private String name;
+
+ /**
+ * 鎽勫儚鏈篒PV4鎴朓PV6鍦板潃
+ */
+ @Excel(name = "IP")
+ private String ip;
+
+ /**
+ * 鎽勫儚鏈哄姛鑳界被鍨媅1.瑙嗛鐩戞帶;2.杞﹁締璇嗗埆;3.浜哄憳璇嗗埆;] 鏁版嵁鏍煎紡[濉叆澶氫釜鍊煎苟浠�/闅斿紑銆備緥濡� 1/2]
+ */
+ @Excel(name = "鎽勫儚鏈哄姛鑳界被鍨�")
+ private String cameraFunType;
+
+ /**
+ * 璁惧鐘舵��
+ */
+ @Excel(name = "鐘舵��", readConverterExp = "-1=绂荤嚎,1=鍦ㄧ嚎,0=鏈煡")
+ private Integer onState;
+ /**
+ * 琛屾斂鍖哄煙
+ */
+ @Excel(name = "琛屾斂鍖哄煙")
+ private String deptName;
+
+ /**
+ * 绠＄悊鍗曚綅
+ */
+ @Excel(name = "绠＄悊鍗曚綅")
+ private String managementUnit;
+ /**
+ * 鏍囩
+ */
+ @Excel(name = "鏍囩")
+ private String tag;
+ private Boolean provinceTag;
+ private Boolean deptTag;
+ private Boolean importantTag;
+ private Boolean importantCommandImageTag;
+
+ private Integer pointId;
+ /**
+ * 鍔ㄦ�佸垪
+ */
+ private List<DynamicColumnVO> dynamicColumnList;
+}
diff --git a/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java b/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java
index 32d1f22..48f4102 100644
--- a/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java
+++ b/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java
@@ -83,7 +83,7 @@
/**
* 鑾峰彇璁惧璧勪骇璇︾粏淇℃伅
*/
- @PreAuthorize("@ss.hasPermi('system:monitor:query')")
+ @PreAuthorize("@ss.hasPermi('system:monitor:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -93,7 +93,7 @@
/**
* 鏂板璁惧璧勪骇
*/
- @PreAuthorize("@ss.hasPermi('system:monitor:add')")
+ @PreAuthorize("@ss.hasPermi('system:monitor:add')")
@Log(title = "璁惧璧勪骇", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody TMonitor tMonitor)
@@ -142,6 +142,14 @@
{
return success(tMonitorService.recoveryException(monitor));
}
-
+ /**
+ * 瀵煎嚭
+ */
+ @PreAuthorize("@ss.hasPermi('system:monitor:export')")
+ @Log(title = "瀵煎嚭", businessType = BusinessType.EXPORT)
+ @PostMapping("/export")
+ public void export(HttpServletResponse response,TMonitorVO tMonitor) throws IOException, NoSuchFieldException, IllegalAccessException {
+ tMonitorService.export(response,tMonitor);
+ }
}
diff --git a/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java b/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java
index 893cac3..ecfd274 100644
--- a/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java
+++ b/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java
@@ -3,6 +3,7 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.ycl.platform.domain.entity.TMonitor;
+import com.ycl.platform.domain.excel.TMonitorExp;
import com.ycl.platform.domain.form.VideoExportForm;
import com.ycl.platform.domain.query.DashboardQuery;
import com.ycl.platform.domain.query.DataCenterQuery;
@@ -180,4 +181,6 @@
void batchUpdateOnline(@Param("ipList")List<String> ipList,@Param("date") Date date,@Param("online")Integer online);
List<TMonitor> selectCarOrFace();
+
+ List<TMonitorExp> exportTMonitorList(TMonitorVO tMonitor);
}
diff --git a/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java b/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java
index 7862bc6..3b8a84b 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java
@@ -128,4 +128,6 @@
Map<String, Object> carHome(HomeQuery monitorQuery) throws ParseException, InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException;
Map<String, Object> videoHome(HomeQuery monitorQuery) throws ParseException, InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException;
+
+ void export(HttpServletResponse response, TMonitorVO tMonitor);
}
diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java
index 32b9f2c..6fc3f24 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java
@@ -7,6 +7,7 @@
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.ycl.platform.domain.entity.TMonitor;
+import com.ycl.platform.domain.excel.TMonitorExp;
import com.ycl.platform.domain.excel.VideoDailyExp;
import com.ycl.platform.domain.excel.VideoTotalExp;
import com.ycl.platform.domain.form.VideoExportForm;
@@ -40,6 +41,7 @@
import com.ycl.system.service.ISysConfigService;
import com.ycl.utils.DateUtils;
import com.ycl.utils.StringUtils;
+import com.ycl.utils.poi.ExcelUtil;
import constant.ApiConstants;
import constant.CheckConstants;
import enumeration.general.AreaDeptEnum;
@@ -134,7 +136,7 @@
for (TMonitorVO monitor : monitors) {
if (!CollectionUtils.isEmpty(voList)) {
for (WorkOrderVO workOrderVO : voList) {
- if (monitor.getWorkOrderNo()!=null && monitor.getWorkOrderNo().equals(workOrderVO.getWorkOrderNo())) {
+ if (monitor.getWorkOrderNo() != null && monitor.getWorkOrderNo().equals(workOrderVO.getWorkOrderNo())) {
monitor.setUnitContact(workOrderVO.getUnitContact());
monitor.setUnitContactPhone(workOrderVO.getUnitContactPhone());
monitor.setYwPeopleName(workOrderVO.getYwPeopleName());
@@ -416,7 +418,7 @@
@Override
public void exportVideoTotal(HttpServletResponse response, VideoExportForm exportForm) throws IOException {
//榛樿鏌ユ墍鏈夐儴闂�
- if(CollectionUtils.isEmpty(exportForm.getDeptIds())){
+ if (CollectionUtils.isEmpty(exportForm.getDeptIds())) {
List<Integer> deptIds = new ArrayList<>();
for (AreaDeptEnum value : AreaDeptEnum.values()) {
deptIds.add(value.getDeptId());
@@ -464,7 +466,7 @@
long count = onlines.stream()
.filter(item -> ApiConstants.UY_OnlineSite_Online.equals(item.getOnline()))
.count();
- videoExp.setOnline(Integer.valueOf(count+""));
+ videoExp.setOnline(Integer.valueOf(count + ""));
videoExp.setOffline(videoExp.getTotal() - videoExp.getOnline());
}
//璁剧疆瀛樺偍鎯呭喌
@@ -509,7 +511,7 @@
@Override
public void exportVideoOnline(HttpServletResponse response, VideoExportForm exportForm) throws IOException, NoSuchFieldException, IllegalAccessException {
//榛樿鏌ユ墍鏈夐儴闂�
- if(CollectionUtils.isEmpty(exportForm.getDeptIds())){
+ if (CollectionUtils.isEmpty(exportForm.getDeptIds())) {
List<Integer> deptIds = new ArrayList<>();
for (AreaDeptEnum value : AreaDeptEnum.values()) {
deptIds.add(value.getDeptId());
@@ -524,7 +526,7 @@
List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList());
List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
//琛ュ厖鍔ㄦ�佸垪鏁版嵁
- if(!CollectionUtils.isEmpty(dynamics)) {
+ if (!CollectionUtils.isEmpty(dynamics)) {
Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId));
for (TMonitorResult tMonitorResult : tMonitorResults) {
Integer pointId = tMonitorResult.getPointId();
@@ -553,7 +555,7 @@
videoDailyExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName());
StringBuilder tag = new StringBuilder("" + (result.getProvinceTag() ? "鐪佸巺銆�" : "") + (result.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (result.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (result.getDeptTag() ? "閮ㄧ骇銆�" : ""));
//鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲�
- if(!CollectionUtils.isEmpty(result.getDynamicColumnList())){
+ if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) {
List<DynamicColumnVO> dynamicColumnList = result.getDynamicColumnList();
for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) {
tag.append(dynamicColumnVO.getColumnValue()).append("銆�");
@@ -585,7 +587,7 @@
@Override
public void exportVideoRecord(HttpServletResponse response, VideoExportForm exportForm) throws IOException, NoSuchFieldException, IllegalAccessException {
//榛樿鏌ユ墍鏈夐儴闂�
- if(CollectionUtils.isEmpty(exportForm.getDeptIds())){
+ if (CollectionUtils.isEmpty(exportForm.getDeptIds())) {
List<Integer> deptIds = new ArrayList<>();
for (AreaDeptEnum value : AreaDeptEnum.values()) {
deptIds.add(value.getDeptId());
@@ -600,7 +602,7 @@
List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList());
List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
//琛ュ厖鍔ㄦ�佸垪鏁版嵁
- if(!CollectionUtils.isEmpty(dynamics)) {
+ if (!CollectionUtils.isEmpty(dynamics)) {
Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId));
for (TMonitorResult tMonitorResult : tMonitorResults) {
Integer pointId = tMonitorResult.getPointId();
@@ -629,7 +631,7 @@
videoDailyExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName());
StringBuilder tag = new StringBuilder("" + (result.getProvinceTag() ? "鐪佸巺銆�" : "") + (result.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (result.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (result.getDeptTag() ? "閮ㄧ骇銆�" : ""));
//鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲�
- if(!CollectionUtils.isEmpty(result.getDynamicColumnList())){
+ if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) {
List<DynamicColumnVO> dynamicColumnList = result.getDynamicColumnList();
for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) {
tag.append(dynamicColumnVO.getColumnValue()).append("銆�");
@@ -661,7 +663,7 @@
@Override
public void exportVideoLoseTime(HttpServletResponse response, VideoExportForm exportForm) throws NoSuchFieldException, IllegalAccessException, IOException {
//榛樿鏌ユ墍鏈夐儴闂�
- if(CollectionUtils.isEmpty(exportForm.getDeptIds())){
+ if (CollectionUtils.isEmpty(exportForm.getDeptIds())) {
List<Integer> deptIds = new ArrayList<>();
for (AreaDeptEnum value : AreaDeptEnum.values()) {
deptIds.add(value.getDeptId());
@@ -676,7 +678,7 @@
List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList());
List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
//琛ュ厖鍔ㄦ�佸垪鏁版嵁
- if(!CollectionUtils.isEmpty(dynamics)) {
+ if (!CollectionUtils.isEmpty(dynamics)) {
Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId));
for (TMonitorResult tMonitorResult : tMonitorResults) {
Integer pointId = tMonitorResult.getPointId();
@@ -705,7 +707,7 @@
videoDailyExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName());
StringBuilder tag = new StringBuilder("" + (result.getProvinceTag() ? "鐪佸巺銆�" : "") + (result.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (result.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (result.getDeptTag() ? "閮ㄧ骇銆�" : ""));
//鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲�
- if(!CollectionUtils.isEmpty(result.getDynamicColumnList())){
+ if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) {
List<DynamicColumnVO> dynamicColumnList = result.getDynamicColumnList();
for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) {
tag.append(dynamicColumnVO.getColumnValue()).append("銆�");
@@ -815,7 +817,7 @@
new Document("$group", new Document("_id", "$mongoCreateTime")
.append("onlineCount", new Document("$sum",
new Document("$cond", Arrays.asList(
- new Document("$eq", Arrays.asList("$online",ApiConstants.UY_OnlineSite_Online)),
+ new Document("$eq", Arrays.asList("$online", ApiConstants.UY_OnlineSite_Online)),
1,
0
))
@@ -847,6 +849,52 @@
resultMap.put("baseLine", Integer.valueOf(sysDictData.getDictValue()));
}
return resultMap;
+ }
+
+ /**
+ * 鍒楄〃瀵煎嚭
+ *
+ * @param response
+ * @param tMonitor
+ */
+ @Override
+ public void export(HttpServletResponse response, TMonitorVO tMonitor) {
+ List<TMonitorExp> monitors = tMonitorMapper.exportTMonitorList(tMonitor);
+ //鑾峰彇鍔ㄦ�佸垪鏁版嵁
+ List<Integer> pointIds = monitors.stream().map(TMonitorExp::getPointId).collect(Collectors.toList());
+ List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
+ //琛ュ厖鍔ㄦ�佸垪鏁版嵁
+ if (!CollectionUtils.isEmpty(dynamics)) {
+ Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId));
+ for (TMonitorExp tMonitorResult : monitors) {
+ Integer pointId = tMonitorResult.getPointId();
+ tMonitorResult.setDynamicColumnList(map.get(pointId));
+ }
+ }
+ monitors.forEach(monitor -> {
+ String cameraFunType = monitor.getCameraFunType();
+ if (!StringUtils.isEmpty(cameraFunType)) {
+ String video = cameraFunType.replaceAll("1", "瑙嗛");
+ String car = video.replaceAll("2", "杞﹁締");
+ String type = car.replaceAll("3", "浜鸿劯");
+ monitor.setCameraFunType(type);
+ }
+ StringBuilder tag = new StringBuilder("" + (monitor.getProvinceTag() ? "鐪佸巺銆�" : "") + (monitor.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (monitor.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (monitor.getDeptTag() ? "閮ㄧ骇銆�" : ""));
+ //鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲�
+ if (!CollectionUtils.isEmpty(monitor.getDynamicColumnList())) {
+ List<DynamicColumnVO> dynamicColumnList = monitor.getDynamicColumnList();
+ for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) {
+ tag.append(dynamicColumnVO.getColumnValue()).append("銆�");
+ }
+ }
+ // 鍒犻櫎瀛楃涓叉湯灏剧殑鈥溿�佲��
+ if (tag.toString().endsWith("銆�")) {
+ tag = new StringBuilder(tag.substring(0, tag.length() - 1));
+ }
+ monitor.setTag(tag.toString());
+ });
+ ExcelUtil<TMonitorExp> util = new ExcelUtil<>(TMonitorExp.class);
+ util.exportExcel(response, monitors, "2".equals(tMonitor.getCameraFunType()) ? "杞﹁締" : "浜鸿劯");
}
@@ -917,7 +965,7 @@
new Document("$group", new Document("_id", "$mongoCreateTime")
.append("onlineCount", new Document("$sum",
new Document("$cond", Arrays.asList(
- new Document("$eq", Arrays.asList("$online",ApiConstants.UY_OnlineSite_Online)),
+ new Document("$eq", Arrays.asList("$online", ApiConstants.UY_OnlineSite_Online)),
1,
0
))
@@ -1105,12 +1153,12 @@
for (TMonitorResult monitorResult : onlineResult) {
int dayOfMonth = monitorResult.getMongoCreateTime().getDayOfMonth();
String online = "";
- if(ApiConstants.UY_OnlineSite_Online.equals(monitorResult.getOnline())){
- online +="鍦ㄧ嚎";
- }else if(ApiConstants.UY_OnlineSite_Offline.equals(monitorResult.getOnline())){
- online +="绂荤嚎";
- }else {
- online +="鏈煡";
+ if (ApiConstants.UY_OnlineSite_Online.equals(monitorResult.getOnline())) {
+ online += "鍦ㄧ嚎";
+ } else if (ApiConstants.UY_OnlineSite_Offline.equals(monitorResult.getOnline())) {
+ online += "绂荤嚎";
+ } else {
+ online += "鏈煡";
}
//鍙嶅皠璧嬪�硷紝瀛楁缁熶竴瀹氫箟涓篸ay+1锛�2锛�3...
Field field = videoDailyExp.getClass().getDeclaredField("day" + dayOfMonth);
diff --git a/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml b/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml
index 4d17f84..475d5b3 100644
--- a/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml
+++ b/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml
@@ -181,6 +181,32 @@
</where>
</select>
+ <select id="exportTMonitorList" resultType="com.ycl.platform.domain.excel.TMonitorExp">
+ select m.id, m.serial_number, name, ip, camera_fun_type,p.online as onState,
+ d.dept_name, p.id as pointId,p.province_tag,p.dept_tag,p.important_tag,p.important_command_image_tag,u.unit_name as managementUnit
+ from t_monitor m
+ left join t_yw_point p on m.serial_number = p.serial_number and p.deleted = 0
+ left join sys_dept d on p.dept_id = d.dept_id and d.del_flag = 0
+ left join t_yw_unit u on p.unit_id = u.id and u.deleted = 0
+ <where>
+ p.examine_status = 1
+ <if test="serialNumber != null and serialNumber != ''">and m.serial_number = #{serialNumber}</if>
+ <if test="name != null and name != ''">
+ and (name like concat('%', #{name}, '%')
+ or m.ip like concat('%', #{name}, '%')
+ or m.serial_number like concat('%', #{name}, '%')
+ or u.unit_name like concat('%', #{name}, '%'))
+ </if>
+ <if test="provinceTag != null ">and p.province_tag = #{provinceTag}</if>
+ <if test="deptTag != null ">and p.dept_tag = #{deptTag}</if>
+ <if test="cameraFunType != null and cameraFunType != ''">and camera_fun_type like concat('%',
+ #{cameraFunType}, '%')
+ </if>
+ <if test="onState != null ">and p.online = #{onState}</if>
+ <if test="civilCode != null and civilCode != ''">and civil_code = #{civilCode}</if>
+ </where>
+ </select>
+
<select id="selectMonitorVOList" resultType="com.ycl.platform.domain.vo.TMonitorVO">
select m.id, m.serial_number, name, site_type, mac_addr, ip, camera_fun_type, longitude, latitude,
camera_capture_area, on_state, civil_code, integrated_device, camera_brand, address, net_working,
--
Gitblit v1.8.0