From a0dd79aa4924e9e2e3280b66c6477153f818d5a9 Mon Sep 17 00:00:00 2001 From: fl <3098731433@qq.com> Date: Fri, 18 Apr 2025 17:15:10 +0800 Subject: [PATCH] =?UTF-8?q?=E7=8E=AF=E5=A2=83=E7=9B=91=E6=B5=8B=E9=A1=B5?= =?UTF-8?q?=E9=9D=A2=E9=83=A8=E5=88=86=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../base/common/utils/AttrCodeUtils.java | 6 ++ .../base/common/utils/TypeCodeUtils.java | 6 ++ .../EnvironmentDetectionController.java | 81 +++++++++++++++++ .../mapper/EnvironmentDetectionMapper.java | 41 +++++++++ .../service/EnvironmentDetectionService.java | 40 +++++++++ .../impl/EnvironmentDetectionServiceImpl.java | 86 +++++++++++++++++++ .../impl/TowerCraneDetectionServiceImpl.java | 2 + .../EnvironmentDetectionMapper.xml | 44 ++++++++++ .../TowerCraneDetectionMapper.xml | 1 + 9 files changed, 307 insertions(+) create mode 100644 bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/controller/EnvironmentDetectionController.java create mode 100644 bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/mapper/EnvironmentDetectionMapper.java create mode 100644 bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/EnvironmentDetectionService.java create mode 100644 bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/EnvironmentDetectionServiceImpl.java create mode 100644 bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/EnvironmentDetectionMapper.xml diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/AttrCodeUtils.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/AttrCodeUtils.java index cadd442..8cb31d4 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/AttrCodeUtils.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/AttrCodeUtils.java @@ -21,5 +21,11 @@ public class AttrCodeUtils { */ public final static String GZM_ZL="重量"; + /** + * 环境 PM2.5 + */ + public final static String HJ_PM25="PM2.5"; + + public final static int LIMIT=20; } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/TypeCodeUtils.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/TypeCodeUtils.java index 15ea08e..10d1753 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/TypeCodeUtils.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/common/utils/TypeCodeUtils.java @@ -33,4 +33,10 @@ public class TypeCodeUtils { public final static String BALL_CODE="ball_0"; + /** + * 环境监测设备类型id + */ + public final static String ENVIRONMENT_CODE="174435992023806894663"; + + } diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/controller/EnvironmentDetectionController.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/controller/EnvironmentDetectionController.java new file mode 100644 index 0000000..c3a3f6c --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/controller/EnvironmentDetectionController.java @@ -0,0 +1,81 @@ +package com.bonus.base.screen.controller; + +import com.bonus.base.basic.domain.CollectDevVo; +import com.bonus.base.basic.domain.ConstInfoVo; +import com.bonus.base.screen.domain.DeviceAlarmVo; +import com.bonus.base.screen.service.EnvironmentDetectionService; +import com.bonus.common.core.web.controller.BaseController; +import com.bonus.common.core.web.domain.AjaxResult; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; +import java.util.List; + +/** + * 环境监测 + * @author fl + * @date 2025/4/18 + */ +@Slf4j +@RestController +@RequestMapping("/videoDetection") +public class EnvironmentDetectionController extends BaseController { + + @Resource + private EnvironmentDetectionService service; + + @ApiOperation(value = "环境监测设备列表") + @PostMapping("/getCollectDeviceList") + public AjaxResult getCollectDeviceList(@RequestBody CollectDevVo bean) { + try { + List collectDevVoList = service.getCollectDeviceList(bean); + return success(collectDevVoList); + }catch (Exception e){ + log.error("查询环境监测设备失败",e.getMessage()); + return error("查询环境监测设备失败"); + } + } + + + @ApiOperation(value = "近7天空气质量详情") + @PostMapping("/getSevenDayAirList") + public AjaxResult getSevenDayAirList(@RequestBody CollectDevVo bean) { + try { + return service.getSevenDayAirList(bean); + }catch (Exception e){ + log.error("查询近7天空气质量详情失败",e.getMessage()); + return error("查询近7天空气质量详情失败"); + } + } + + + @ApiOperation(value = "实时环境信息") + @PostMapping("/getEnvironmentMsg") + public AjaxResult getEnvironmentMsg(@RequestBody CollectDevVo bean) { + try { + return service.getEnvironmentMsg(bean); + }catch (Exception e){ + log.error("查询实时环境信息失败",e.getMessage()); + return error("查询实时环境信息失败"); + } + } + + @ApiOperation(value = "环境报警信息") + @PostMapping("/getEnvironmentAlarmList") + public AjaxResult getEnvironmentAlarmList(@RequestBody CollectDevVo constInfoVo) { + try { + List deviceAlarmVoList = service.getEnvironmentAlarmList(constInfoVo); + return success(deviceAlarmVoList); + }catch (Exception e){ + log.error("查询塔吊报警信息失败",e.getMessage()); + return error("查询塔吊报警信息失败"); + } + } + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/mapper/EnvironmentDetectionMapper.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/mapper/EnvironmentDetectionMapper.java new file mode 100644 index 0000000..8abbb51 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/mapper/EnvironmentDetectionMapper.java @@ -0,0 +1,41 @@ +package com.bonus.base.screen.mapper; + +import com.bonus.base.basic.domain.CollectDevVo; +import com.bonus.base.basic.domain.ConstInfoVo; +import com.bonus.base.screen.domain.BallInfoVo; +import com.bonus.base.screen.domain.DeviceAlarmVo; +import com.bonus.base.screen.domain.MapValueVo; + +import java.util.List; + +public interface EnvironmentDetectionMapper { + + + /** + * 查询环境设备列表 + * @param bean + * @return + */ + List getCollectDeviceList(CollectDevVo bean); + + /** + * 近7天空气质量详情 + * @param bean + * @return + */ + List getAttrListByTypeId(CollectDevVo bean); + + /** + * 实时环境信息 + * @param bean + * @return + */ + List getEnvironmentMsg(CollectDevVo bean); + + /** + * 环境报警信息 + * @param bean + * @return + */ + List getEnvironmentAlarmList(CollectDevVo bean); +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/EnvironmentDetectionService.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/EnvironmentDetectionService.java new file mode 100644 index 0000000..2f68f97 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/EnvironmentDetectionService.java @@ -0,0 +1,40 @@ +package com.bonus.base.screen.service; + +import com.bonus.base.basic.domain.CollectDevVo; +import com.bonus.base.basic.domain.ConstInfoVo; +import com.bonus.base.screen.domain.BallInfoVo; +import com.bonus.base.screen.domain.DeviceAlarmVo; +import com.bonus.common.core.web.domain.AjaxResult; + +import java.util.List; + +public interface EnvironmentDetectionService { + + /** + * 查询环境设备列表 + * @param bean + * @return + */ + List getCollectDeviceList(CollectDevVo bean); + + /** + * 近7天空气质量详情 + * @param bean + * @return + */ + AjaxResult getSevenDayAirList(CollectDevVo bean); + + /** + * 实时环境信息 + * @param bean + * @return + */ + AjaxResult getEnvironmentMsg(CollectDevVo bean); + + /** + * 环境报警信息 + * @param bean + * @return + */ + List getEnvironmentAlarmList(CollectDevVo bean); +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/EnvironmentDetectionServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/EnvironmentDetectionServiceImpl.java new file mode 100644 index 0000000..da94999 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/EnvironmentDetectionServiceImpl.java @@ -0,0 +1,86 @@ +package com.bonus.base.screen.service.impl; + +import com.bonus.base.basic.domain.CollectDevVo; +import com.bonus.base.basic.domain.ConstInfoVo; +import com.bonus.base.common.utils.TypeCodeUtils; +import com.bonus.base.screen.domain.BallInfoVo; +import com.bonus.base.screen.domain.DeviceAlarmVo; +import com.bonus.base.screen.domain.MapValueVo; +import com.bonus.base.screen.mapper.EnvironmentDetectionMapper; +import com.bonus.base.screen.mapper.VideoDetectionMapper; +import com.bonus.base.screen.service.EnvironmentDetectionService; +import com.bonus.base.screen.service.VideoDetectionService; +import com.bonus.common.core.web.domain.AjaxResult; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.time.LocalTime; +import java.time.format.DateTimeFormatter; +import java.util.List; + +/** + * @author fl + * @date 2025/4/18 + */ +@Slf4j +@Service +public class EnvironmentDetectionServiceImpl implements EnvironmentDetectionService { + + @Resource + private EnvironmentDetectionMapper mapper; + + + /** + * 查询环境设备列表 + * @param bean + * @return + */ + @Override + public List getCollectDeviceList(CollectDevVo bean) { + //设置查询类型 + bean.setDevType(TypeCodeUtils.ENVIRONMENT_CODE); + return mapper.getCollectDeviceList(bean); + } + + /** + * 近7天空气质量详情 + * @param bean + * @return + */ + @Override + public AjaxResult getSevenDayAirList(CollectDevVo bean) { + // 获取当前日期 + LocalDate now = LocalDate.now(); + // 计算七天前的日期 + LocalDate sevenDaysAgo = now.minusDays(7); + // 格式化日期 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + System.out.println("七天前的起始日期: " + sevenDaysAgo.format(formatter)); + System.out.println("今天的日期: " + now.format(formatter)); + //TODO sql没写 + List list = mapper.getAttrListByTypeId(bean); + return AjaxResult.success(list); + } + + @Override + public AjaxResult getEnvironmentMsg(CollectDevVo bean) { + bean.setDevType(TypeCodeUtils.ENVIRONMENT_CODE); + List list = mapper.getEnvironmentMsg(bean); + return AjaxResult.success(list); + } + + /** + * 环境报警信息 + * @param bean + * @return + */ + @Override + public List getEnvironmentAlarmList(CollectDevVo bean) { + bean.setDevType(TypeCodeUtils.ENVIRONMENT_CODE); + return mapper.getEnvironmentAlarmList(bean); + } +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/TowerCraneDetectionServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/TowerCraneDetectionServiceImpl.java index 263d67c..1a5c525 100644 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/TowerCraneDetectionServiceImpl.java +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/TowerCraneDetectionServiceImpl.java @@ -53,6 +53,8 @@ public class TowerCraneDetectionServiceImpl implements TowerCraneDetectionServic */ @Override public List getTowerCraneAlarmList(ConstInfoVo constInfoVo) { + //设置查询类型 + constInfoVo.setTypeCode(TypeCodeUtils.TC_CODE); return mapper.getTowerCraneAlarmList(constInfoVo); } diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/EnvironmentDetectionMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/EnvironmentDetectionMapper.xml new file mode 100644 index 0000000..cf8e03e --- /dev/null +++ b/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/EnvironmentDetectionMapper.xml @@ -0,0 +1,44 @@ + + + + + + + + + + diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/TowerCraneDetectionMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/TowerCraneDetectionMapper.xml index 640386e..a642c10 100644 --- a/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/TowerCraneDetectionMapper.xml +++ b/bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/TowerCraneDetectionMapper.xml @@ -50,5 +50,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" LEFT JOIN tb_collect_device_his tcdh ON tcdh.dev_id = tcd.id WHERE tci.type_code = #{typeCode} + and tcdh.is_warn = 1