diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java index d6d9743..afc800b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java @@ -20,9 +20,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.CompletableFuture; /** *

@@ -39,8 +37,6 @@ public class BusLedgerController extends ExportController { private final IBusLedgerService iBusLedgerService; - private final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 6, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(10)); - @ApiOperation("添加临时井") @PostMapping("/add") @@ -109,8 +105,7 @@ @ResponseBody public ReturnDTO synAllDept() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllDept(); } ); @@ -129,8 +124,7 @@ @ResponseBody public ReturnDTO synAllLedger() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllLedger(); } ); diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java index d6d9743..afc800b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java @@ -20,9 +20,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.CompletableFuture; /** *

@@ -39,8 +37,6 @@ public class BusLedgerController extends ExportController { private final IBusLedgerService iBusLedgerService; - private final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 6, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(10)); - @ApiOperation("添加临时井") @PostMapping("/add") @@ -109,8 +105,7 @@ @ResponseBody public ReturnDTO synAllDept() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllDept(); } ); @@ -129,8 +124,7 @@ @ResponseBody public ReturnDTO synAllLedger() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllLedger(); } ); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java index 4123002..f8b6309 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java @@ -42,4 +42,7 @@ @Select("SELECT id,DEVICE_TYPE as deviceType ,PRODUCT_CODE as productCode FROM `base_product` WHERE PRODUCT_CODE =#{productCode} limit 1") BaseProduct getBaseProductByCode( @Param("productCode") String productCode); + @Select("SELECT DEVCODE FROM bus_device where valid>0 and PRODUCT_ID = ${productId}") + List getDevCodesByProductId( @Param("productId") Long productId); + } diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java index d6d9743..afc800b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java @@ -20,9 +20,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.CompletableFuture; /** *

@@ -39,8 +37,6 @@ public class BusLedgerController extends ExportController { private final IBusLedgerService iBusLedgerService; - private final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 6, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(10)); - @ApiOperation("添加临时井") @PostMapping("/add") @@ -109,8 +105,7 @@ @ResponseBody public ReturnDTO synAllDept() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllDept(); } ); @@ -129,8 +124,7 @@ @ResponseBody public ReturnDTO synAllLedger() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllLedger(); } ); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java index 4123002..f8b6309 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java @@ -42,4 +42,7 @@ @Select("SELECT id,DEVICE_TYPE as deviceType ,PRODUCT_CODE as productCode FROM `base_product` WHERE PRODUCT_CODE =#{productCode} limit 1") BaseProduct getBaseProductByCode( @Param("productCode") String productCode); + @Select("SELECT DEVCODE FROM bus_device where valid>0 and PRODUCT_ID = ${productId}") + List getDevCodesByProductId( @Param("productId") Long productId); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java index 5226b76..640d020 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java @@ -28,6 +28,12 @@ @Param("request") BusLedgerPipeMonitorRequestDTO request, @Param("deptStrs") String deptStrs); + + Page monitorHazardPageList(Page page, + @Param("request") BusLedgerPipeMonitorRequestDTO request, + @Param("deptStrs") String deptStrs); + + BusLedgerPipeResponseDTO detail(@Param("id") Long id, @Param("devcode") String devcode); @@ -38,5 +44,7 @@ List> deviceList( @Param("deptids") String deptids); + List> deviceHazardList( @Param("deptids") String deptids); + } diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java index d6d9743..afc800b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java @@ -20,9 +20,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.CompletableFuture; /** *

@@ -39,8 +37,6 @@ public class BusLedgerController extends ExportController { private final IBusLedgerService iBusLedgerService; - private final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 6, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(10)); - @ApiOperation("添加临时井") @PostMapping("/add") @@ -109,8 +105,7 @@ @ResponseBody public ReturnDTO synAllDept() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllDept(); } ); @@ -129,8 +124,7 @@ @ResponseBody public ReturnDTO synAllLedger() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllLedger(); } ); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java index 4123002..f8b6309 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java @@ -42,4 +42,7 @@ @Select("SELECT id,DEVICE_TYPE as deviceType ,PRODUCT_CODE as productCode FROM `base_product` WHERE PRODUCT_CODE =#{productCode} limit 1") BaseProduct getBaseProductByCode( @Param("productCode") String productCode); + @Select("SELECT DEVCODE FROM bus_device where valid>0 and PRODUCT_ID = ${productId}") + List getDevCodesByProductId( @Param("productId") Long productId); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java index 5226b76..640d020 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java @@ -28,6 +28,12 @@ @Param("request") BusLedgerPipeMonitorRequestDTO request, @Param("deptStrs") String deptStrs); + + Page monitorHazardPageList(Page page, + @Param("request") BusLedgerPipeMonitorRequestDTO request, + @Param("deptStrs") String deptStrs); + + BusLedgerPipeResponseDTO detail(@Param("id") Long id, @Param("devcode") String devcode); @@ -38,5 +44,7 @@ List> deviceList( @Param("deptids") String deptids); + List> deviceHazardList( @Param("deptids") String deptids); + } 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 dd0d56b..691c57b 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 @@ -38,17 +38,19 @@ bp.PRESS_TYPE, bm.NAME AS manufactureName FROM - `bus_ledger_pipe` blp - LEFT JOIN bus_pipeline bp ON blp.PIPE_CODE = bp.PIPE_CODE - JOIN bus_device_ledger bdl ON bdl.LEDGER_ID = blp.ID - - AND bdl.VALID = 1 - JOIN bus_device bd ON bd.ID = bdl.DEVICE_ID - AND bd.VALID = 1 + bus_device bd + JOIN bus_device_ledger bl ON bl.DEVICE_ID = bd.id + AND bl.VALID = 1 + JOIN bus_ledger_pipe blp ON blp.id = bl.LEDGER_ID + AND bl.type = blp.type JOIN base_device_type bt ON bt.ID = bd.DEVICE_TYPE - left JOIN base_product bpt on bpt.ID = bd.PRODUCT_ID - LEFT JOIN bus_manufacturer bm on bm.ID = bpt.MANUFACTURER_ID - + LEFT JOIN base_product bpt ON bpt.ID = bd.PRODUCT_ID + LEFT JOIN bus_manufacturer bm ON bm.ID = bpt.MANUFACTURER_ID + LEFT JOIN bus_pipeline bp ON blp.PIPE_CODE = bp.PIPE_CODE + WHERE + blp.LOCATION_CATEGORY = 1 + AND bd.VALID >0 + and bd.DEVCODE like concat('%', #{request.devCode}, '%') @@ -80,7 +82,69 @@ and bt.ID =#{request.devTypeId} - + + ORDER BY blp.TS DESC + + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java index d6d9743..afc800b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java @@ -20,9 +20,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.CompletableFuture; /** *

@@ -39,8 +37,6 @@ public class BusLedgerController extends ExportController { private final IBusLedgerService iBusLedgerService; - private final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 6, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(10)); - @ApiOperation("添加临时井") @PostMapping("/add") @@ -109,8 +105,7 @@ @ResponseBody public ReturnDTO synAllDept() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllDept(); } ); @@ -129,8 +124,7 @@ @ResponseBody public ReturnDTO synAllLedger() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllLedger(); } ); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java index 4123002..f8b6309 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java @@ -42,4 +42,7 @@ @Select("SELECT id,DEVICE_TYPE as deviceType ,PRODUCT_CODE as productCode FROM `base_product` WHERE PRODUCT_CODE =#{productCode} limit 1") BaseProduct getBaseProductByCode( @Param("productCode") String productCode); + @Select("SELECT DEVCODE FROM bus_device where valid>0 and PRODUCT_ID = ${productId}") + List getDevCodesByProductId( @Param("productId") Long productId); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java index 5226b76..640d020 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java @@ -28,6 +28,12 @@ @Param("request") BusLedgerPipeMonitorRequestDTO request, @Param("deptStrs") String deptStrs); + + Page monitorHazardPageList(Page page, + @Param("request") BusLedgerPipeMonitorRequestDTO request, + @Param("deptStrs") String deptStrs); + + BusLedgerPipeResponseDTO detail(@Param("id") Long id, @Param("devcode") String devcode); @@ -38,5 +44,7 @@ List> deviceList( @Param("deptids") String deptids); + List> deviceHazardList( @Param("deptids") String deptids); + } 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 dd0d56b..691c57b 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 @@ -38,17 +38,19 @@ bp.PRESS_TYPE, bm.NAME AS manufactureName FROM - `bus_ledger_pipe` blp - LEFT JOIN bus_pipeline bp ON blp.PIPE_CODE = bp.PIPE_CODE - JOIN bus_device_ledger bdl ON bdl.LEDGER_ID = blp.ID - - AND bdl.VALID = 1 - JOIN bus_device bd ON bd.ID = bdl.DEVICE_ID - AND bd.VALID = 1 + bus_device bd + JOIN bus_device_ledger bl ON bl.DEVICE_ID = bd.id + AND bl.VALID = 1 + JOIN bus_ledger_pipe blp ON blp.id = bl.LEDGER_ID + AND bl.type = blp.type JOIN base_device_type bt ON bt.ID = bd.DEVICE_TYPE - left JOIN base_product bpt on bpt.ID = bd.PRODUCT_ID - LEFT JOIN bus_manufacturer bm on bm.ID = bpt.MANUFACTURER_ID - + LEFT JOIN base_product bpt ON bpt.ID = bd.PRODUCT_ID + LEFT JOIN bus_manufacturer bm ON bm.ID = bpt.MANUFACTURER_ID + LEFT JOIN bus_pipeline bp ON blp.PIPE_CODE = bp.PIPE_CODE + WHERE + blp.LOCATION_CATEGORY = 1 + AND bd.VALID >0 + and bd.DEVCODE like concat('%', #{request.devCode}, '%') @@ -80,7 +82,69 @@ and bt.ID =#{request.devTypeId} - + + ORDER BY blp.TS DESC + + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java index c2d9c30..a6701f9 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasServiceImpl.java @@ -143,6 +143,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java index d58fdf1..f2ed864 100644 --- a/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java +++ b/casic-data/src/main/java/com/casic/missiles/modular/data/service/impl/DataGasliquidGasServiceImpl.java @@ -163,6 +163,9 @@ for (int i = 0; i < jsonArray.size(); i++) { try { String gas = ((JSONObject) jsonArray.get(i)).getString("gas"); + if("40".equals(gas)||"60".equals(gas)||"40.0".equals(gas)||"60.0".equals(gas)){ + gas="0"; + } String upTime = ((JSONObject) jsonArray.get(i)).getString("uptime"); gas = String.format("%.2f", Double.valueOf(gas)); //1.存数据 diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java index a992bc0..42d752d 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BaseProductController.java @@ -65,7 +65,7 @@ Assert.isFalse(Objects.isNull(baseProduct.getId()), () -> { throw new BusinessException(BusinessExceptionEnum.ID_NULL); }); - return ReturnUtil.success(iBaseProductService.updateById(baseProduct)); + return ReturnUtil.success(iBaseProductService.updateBaseProductById(baseProduct)); } @ApiOperation("批量删除") diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java new file mode 100644 index 0000000..0be41f3 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusHazardMonitorController.java @@ -0,0 +1,96 @@ +package com.casic.missiles.modular.device.controller; + +import cn.hutool.core.lang.Assert; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.casic.missiles.core.base.controller.ExportController; +import com.casic.missiles.core.page.PageFactory; +import com.casic.missiles.dto.ReturnDTO; +import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.exception.BusinessException; +import com.casic.missiles.modular.device.dto.BusLedgerPipeDetailRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeMonitorRequestDTO; +import com.casic.missiles.modular.device.dto.BusLedgerPipeResponseDTO; +import com.casic.missiles.modular.device.dto.MonitorDataRequestDTO; +import com.casic.missiles.modular.device.entity.BusLedgerPipe; +import com.casic.missiles.modular.device.service.IBusLedgerPipeService; +import com.casic.missiles.util.ReturnUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; + +import java.util.Objects; + +@Api(tags = "隐患监测模块") +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitor/hazard") +public class BusHazardMonitorController extends ExportController { + + private final IBusLedgerPipeService iBusLedgerPipeService; + + + @ApiOperation("查询分页接口,列表用") + @PostMapping("/listPage") + @ResponseBody + public ReturnDTO listPage(@RequestBody BusLedgerPipeMonitorRequestDTO request) { + Page page = PageFactory.defaultPage(); + return ReturnUtil.success(super.packForBT(iBusLedgerPipeService.monitorHazardPageList(page, request))); + } + + @ApiOperation("管线列表,地图用") + @PostMapping("/pipeList") + @ResponseBody + public ReturnDTO pipeList() { + return ReturnUtil.success(iBusLedgerPipeService.pipeList()); + } + + @ApiOperation("设备列表,地图用") + @PostMapping("/deviceList") + @ResponseBody + public ReturnDTO deviceList() { + return ReturnUtil.success(iBusLedgerPipeService.deviceHazardList()); + } + + + @ApiOperation("详情") + @PostMapping("/detail") + @ResponseBody + public ReturnDTO detail(@RequestBody BusLedgerPipeDetailRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getId()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.detail(requestDTO.getId(), requestDTO.getDevcode())); + } + + // @ApiOperation("查询接口,地图用") +// @PostMapping("/list") +// @ResponseBody +// public ReturnDTO list(@RequestBody BusLedgerDTO request) { +// DataScope dataScope = iCommonPermissionService.getAuthService().getLoginUserDataScope(); +// return ReturnUtil.success(wellMonitorService.list(request, dataScope)); +// } +// + @ApiOperation("查看监测数据") + @PostMapping("/watchDataByPipe") + @ResponseBody + public ReturnDTO watchDataByWell(@RequestBody MonitorDataRequestDTO requestDTO) { + Assert.isFalse(Objects.isNull(requestDTO.getDevcode()), () -> { + throw new BusinessException(BusinessExceptionEnum.ID_NULL); + }); + return ReturnUtil.success(iBusLedgerPipeService.watchDataByPipe(requestDTO)); + } + + @ApiOperation("监控设备维护记录(待开发)") + @PostMapping("/repairLog") + @ResponseBody + public ReturnDTO repairLog(@RequestBody MonitorDataRequestDTO requestDTO) { +// Assert.isFalse(Objects.isNull(requestDTO.getWellId()), () -> { +// throw new BusinessException(BusinessExceptionEnum.ID_NULL); +// }); +// return ReturnUtil.success(wellMonitorService.repairLog(requestDTO)); + return ReturnUtil.success(); + } + + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java index d6d9743..afc800b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/controller/BusLedgerController.java @@ -20,9 +20,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.CompletableFuture; /** *

@@ -39,8 +37,6 @@ public class BusLedgerController extends ExportController { private final IBusLedgerService iBusLedgerService; - private final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 6, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(10)); - @ApiOperation("添加临时井") @PostMapping("/add") @@ -109,8 +105,7 @@ @ResponseBody public ReturnDTO synAllDept() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllDept(); } ); @@ -129,8 +124,7 @@ @ResponseBody public ReturnDTO synAllLedger() { - threadPoolExecutor.execute( - () -> { + CompletableFuture.runAsync(() -> { iBusLedgerService.synAllLedger(); } ); diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java index 4123002..f8b6309 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BaseProductMapper.java @@ -42,4 +42,7 @@ @Select("SELECT id,DEVICE_TYPE as deviceType ,PRODUCT_CODE as productCode FROM `base_product` WHERE PRODUCT_CODE =#{productCode} limit 1") BaseProduct getBaseProductByCode( @Param("productCode") String productCode); + @Select("SELECT DEVCODE FROM bus_device where valid>0 and PRODUCT_ID = ${productId}") + List getDevCodesByProductId( @Param("productId") Long productId); + } diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java index 5226b76..640d020 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/BusLedgerPipeMapper.java @@ -28,6 +28,12 @@ @Param("request") BusLedgerPipeMonitorRequestDTO request, @Param("deptStrs") String deptStrs); + + Page monitorHazardPageList(Page page, + @Param("request") BusLedgerPipeMonitorRequestDTO request, + @Param("deptStrs") String deptStrs); + + BusLedgerPipeResponseDTO detail(@Param("id") Long id, @Param("devcode") String devcode); @@ -38,5 +44,7 @@ List> deviceList( @Param("deptids") String deptids); + List> deviceHazardList( @Param("deptids") String deptids); + } 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 dd0d56b..691c57b 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 @@ -38,17 +38,19 @@ bp.PRESS_TYPE, bm.NAME AS manufactureName FROM - `bus_ledger_pipe` blp - LEFT JOIN bus_pipeline bp ON blp.PIPE_CODE = bp.PIPE_CODE - JOIN bus_device_ledger bdl ON bdl.LEDGER_ID = blp.ID - - AND bdl.VALID = 1 - JOIN bus_device bd ON bd.ID = bdl.DEVICE_ID - AND bd.VALID = 1 + bus_device bd + JOIN bus_device_ledger bl ON bl.DEVICE_ID = bd.id + AND bl.VALID = 1 + JOIN bus_ledger_pipe blp ON blp.id = bl.LEDGER_ID + AND bl.type = blp.type JOIN base_device_type bt ON bt.ID = bd.DEVICE_TYPE - left JOIN base_product bpt on bpt.ID = bd.PRODUCT_ID - LEFT JOIN bus_manufacturer bm on bm.ID = bpt.MANUFACTURER_ID - + LEFT JOIN base_product bpt ON bpt.ID = bd.PRODUCT_ID + LEFT JOIN bus_manufacturer bm ON bm.ID = bpt.MANUFACTURER_ID + LEFT JOIN bus_pipeline bp ON blp.PIPE_CODE = bp.PIPE_CODE + WHERE + blp.LOCATION_CATEGORY = 1 + AND bd.VALID >0 + and bd.DEVCODE like concat('%', #{request.devCode}, '%') @@ -80,7 +82,69 @@ and bt.ID =#{request.devTypeId} - + + ORDER BY blp.TS DESC + + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@ + + + @@ -88,6 +152,7 @@ SELECT blp.*, bd.DEVCODE, + bd.INSTALL_DATE, bt.TYPE_NAME, bp.CONSTRUCT_ERA, bp.MATERIAL, @@ -131,20 +196,56 @@ bp.LNG_GAODE, bp.LAT_GAODE, bp.ID AS LEDGER_ID, - dt.ONLINE_STATE + dt.ONLINE_STATE, + bt.ID AS DEVICE_TYPE_ID, + bp.DEPTID, + bp.POSITION, + bp.MONITOR_STATE, + bp.ON_STATE FROM device_temp dt LEFT JOIN base_device_type bt ON bt.id = dt.DEVICE_TYPE - JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id - - AND bl.VALID = 1 + JOIN bus_device_ledger bl ON bl.DEVICE_ID = dt.id AND bl.VALID = 1 JOIN bus_ledger_pipe bp ON bp.id = bl.LEDGER_ID and bl.type=bp.type - - + where bp.LOCATION_CATEGORY=1 + and bp.DEPTID in (${deptids}) - + + + + diff --git a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml index 93d1973..fb9924b 100644 --- a/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml +++ b/casic-device/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusStationMonitorMapper.xml @@ -58,7 +58,7 @@ and bl.DEPTID in (${deptIds}) - ORDER BY bl.TS DESC + order by bl.MONITOR_STATE desc ,bl.TS DESC WITH station_temp as(SELECT bl.ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID FROM `bus_ledger` bl where bl.VALID=1 and bl.TYPE =2) select bl.ID as LEDGER_ID,bl.LEDGER_CODE,bl.TAG_NUMBER,bl.LEDGER_NAME,bl.DEPTID,bd.ID as DEVICE_ID,bd.DEVICE_NAME,bd.DEVCODE from station_temp bl - left join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 left join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 - + join bus_device_ledger bdl on bdl.LEDGER_ID = bl.ID and bdl.TYPE =2 and bdl.valid=1 + join bus_device bd on bd.id= bdl.DEVICE_ID and bd.VALID=1 order by bl.ID 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 b3aff86..b73ef63 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 @@ -107,7 +107,7 @@