diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java index 994a319..24ca9ee 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/controller/OverViewController.java @@ -61,7 +61,6 @@ @ResponseBody public ReturnDTO note() { Page page = PageFactory.defaultPage(); - Page messageLogPage = iMessageLogService.notePage(page); return ReturnUtil.success(super.packForBT(messageLogPage)); } diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml index 6e25903..5b0032f 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/AlarmStaticsMapper.xml @@ -81,6 +81,7 @@ GROUP BY ledgerCode) SELECT ap.alarmSum,bv.type,tagNumber,bv.ledgerName,bv.place,bv.deptid, bv.marker FROM alarm_position_group ap left join bus_ledger_all_view bv on ap.ledgerCode=bv.ledgerCode + order by ap.alarmSum desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + + diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml index c7b3033..ce3a490 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dao/mapping/MessageLogMapper.xml @@ -31,5 +31,6 @@ WHERE bv.DEPTID IN (${deptIds})) + order by TS desc diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java index 821069a..05d57e5 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/dto/AlarmPositionResponseDTO.java @@ -2,10 +2,12 @@ import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.alibaba.excel.annotation.write.style.ColumnWidth; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data +@ColumnWidth(30) @ExcelIgnoreUnannotated public class AlarmPositionResponseDTO { diff --git a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java index d96cfb8..ab6ad49 100644 --- a/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java +++ b/casic-alarm/src/main/java/com/casic/missiles/modular/alarm/service/impl/AlarmStaticsServiceImpl.java @@ -42,7 +42,10 @@ @Override public List alarmPosition(String alarmType, AlarmPositionRequestDTO request) { - //Todo:加入报警类型 + if (ObjectUtil.isNotEmpty(request.getBegTime()) || ObjectUtil.isNotEmpty(request.getEndTime())) { + request.setEndTime(request.getEndTime().replace("00:00:00", "23:59:59")); + request.setTimeType(""); + } List alarmPositionResponseDTOList = this.baseMapper.alarmPosition(alarmType, commonServer.getDeptScopeIds(null), request); alarmPositionResponseDTOList.forEach(alarmPositionResponseDTO -> { alarmPositionResponseDTO.setType("1".equals(alarmPositionResponseDTO.getType()) ? "闸井" : ("2".equals(alarmPositionResponseDTO.getType()) ? "场站" : "管线")); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java index 065319e..5131216 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusDeviceController.java @@ -107,6 +107,14 @@ return ReturnUtil.success(iBusDeviceService.monitorData(requestDTO)); } + @ApiOperation("数据查询导出") + @RequestMapping(value = "/dataExport", method = RequestMethod.GET) + public void dataExport(MonitorDataRequestDTO requestDTO, HttpServletResponse response) { + + iBusDeviceService.exportExcel(requestDTO, response); + + } + @ApiOperation("报警记录") @PostMapping("/alarmRecords") @ResponseBody @@ -180,7 +188,7 @@ @ApiOperation("导出列表") @RequestMapping(value = "/batchExport", method = RequestMethod.GET) - public void batchExport(BusDeviceDTO request, HttpServletResponse response) throws IOException { + public void batchExport(BusDeviceDTO request, HttpServletResponse response) { Page page = PageFactory.defaultPage(); page.setSize(Integer.MAX_VALUE); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java index d9744be..265d030 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusWellMonitorController.java @@ -2,10 +2,8 @@ import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.base.controller.ExportController; import com.casic.missiles.core.base.service.IBaseExportService; -import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.core.page.PageFactory; import com.casic.missiles.dto.ReturnDTO; import com.casic.missiles.enums.BusinessExceptionEnum; @@ -14,6 +12,7 @@ import com.casic.missiles.modular.device.dto.BusLedgerDTO; import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.WellMapDTO; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import com.casic.missiles.modular.device.service.IBusWellMonitorService; @@ -33,7 +32,6 @@ public class BusWellMonitorController extends ExportController { private final IBusWellMonitorService wellMonitorService; - private final AbstractPermissionContext iCommonPermissionService; private final IBaseExportService iBaseExportService; @ApiOperation("查询分页接口,列表用") @@ -47,10 +45,8 @@ @ApiOperation("查询接口,地图用") @PostMapping("/list") @ResponseBody - public ReturnDTO list(@RequestBody BusLedgerDTO request) { - //TOdO:需要优化,看实际用到字段返回 - DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); - return ReturnUtil.success(wellMonitorService.list(request, dataScope)); + public ReturnDTO list(@RequestBody BusLedgerDTO request) { + return ReturnUtil.success(wellMonitorService.list(request)); } @ApiOperation("查看闸井监控数据") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java index 2c80c6f..0fe29b6 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusWellMonitorMapper.java @@ -2,11 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.casic.missiles.core.datascope.DataScope; -import com.casic.missiles.modular.device.dto.BusLedgerDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorDTO; -import com.casic.missiles.modular.device.dto.DeviceMonitorRequestDTO; -import com.casic.missiles.modular.device.dto.LifeCycleRecordDTO; +import com.casic.missiles.modular.device.dto.*; import com.casic.missiles.modular.device.entity.BusDeviceLog; import com.casic.missiles.modular.device.entity.BusLedger; import org.apache.ibatis.annotations.Mapper; @@ -30,8 +26,8 @@ Page page, @Param("request") BusLedgerDTO request); - List list(@Param("deptIds") String deptIds, - @Param("request") BusLedgerDTO request); + List list(@Param("deptIds") String deptIds, + @Param("request") BusLedgerDTO request); @Select("WITH device_tmp as (SELECT bd.devcode,bd.DEVICE_TYPE FROM bus_device bd where " + " EXISTS (SELECT 1 from bus_device_ledger bl where bl.DEVICE_ID= bd.id and bl.LEDGER_ID=${ledgerId} and TYPE<3 and bl.VALID=1)) " + @@ -53,5 +49,15 @@ @Select("SELECT at.ID,at.ALARM_TYPE FROM `alarm_type` at ") List> alarmType(); + List> monitorData(@Param("tableName") String tableName, + @Param("tableColumns") String tableColumns, + @Param("devcode") String devcode, + @Param("uptime") String uptime, + @Param("logtime") String logtime, + @Param("wellCode") String wellCode, + @Param("orderColumn") String orderColumn, + @Param("request") DeviceMonitorRequestDTO request, + @Param("wellNumber") String wellNumber); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml index 436db91..3011a5c 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusLedgerPipeMapper.xml @@ -68,11 +68,11 @@ - and rd.PROCESS_STATUS =#{request.onState} + and blp.ON_STATE =#{request.onState} - and blp.ON_STATE =#{request.monitorState} + and blp.MONITOR_STATE =#{request.monitorState} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml index baff88f..8d9c731 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusWellMonitorMapper.xml @@ -6,7 +6,7 @@ - + @@ -34,7 +34,7 @@ - ID, LEDGER_CODE, LEDGERL_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE + ID, LEDGER_CODE, LEDGER_NAME, TAG_NUMBER, COORDINATE_X, COORDINATE_Y, LNG_BAIDU, LAT_BAIDU, LNG_GAODE, LAT_GAODE, POSITION, DEPTID, RESPONSIBLE_DEPT, MANAGE_TYPE, ON_STATE, LOCATION_STATE, WELL_TYPE, TS, VALID, BFZT, `TYPE`, TARGET_ID, MARKER, SFQ, PROPERTY_OWNER, MONITOR_STATE - SELECT - bl.* + ID,LNG_GAODE, LAT_GAODE,MONITOR_STATE,LEDGER_CODE, LEDGER_NAME, TAG_NUMBER FROM bus_ledger bl WHERE VALID = '1' AND TYPE = '1' @@ -165,6 +165,36 @@ ORDER BY ${orderColumn} DESC + +