bonus
/
bns-zhgd-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

有限空间气体

This commit is contained in:
马三炮 2025-04-18 14:59:06 +08:00
parent 5014975bb7
commit a2a202797d
9 changed files with 202 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/controller/ConfinedSpaceGasController.java Normal file
View File

@ -0,0 +1,54 @@
package com.bonus.base.screen.controller;
import com.bonus.base.screen.domain.CollectDeviceHisVo;
import com.bonus.base.screen.service.ConfinedSpaceGasService;
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;
import java.util.Map;
/**
* 有限空间气体
* @author 马三炮
* @date 2025/4/18
*/
@Slf4j
@RestController
@RequestMapping("/confinedSpaceGas")
public class ConfinedSpaceGasController extends BaseController {
@Resource
private ConfinedSpaceGasService confinedSpaceGasService;
@ApiOperation(value = "实时数据变化")
@PostMapping("/realData")
public AjaxResult realData(@RequestBody CollectDeviceHisVo collectDeviceHisVo) {
try {
Map<String,String> map = confinedSpaceGasService.realData(collectDeviceHisVo);
return success(map);
}catch (Exception e){
log.error("查询区域列表失败",e.getMessage());
return error("查询区域列表失败");
}
}
@ApiOperation(value = "获取曲线图")
@PostMapping("/getCurveGraph")
public AjaxResult getCurveGraph(@RequestBody CollectDeviceHisVo collectDeviceHisVo) {
try {
List<CollectDeviceHisVo> collectDeviceHisVoList = confinedSpaceGasService.getCurveGraph(collectDeviceHisVo);
return success(collectDeviceHisVoList);
}catch (Exception e){
log.error("查询区域列表失败",e.getMessage());
return error("查询区域列表失败");
}
}
}

1
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/controller/ExcavationDetectionController.java
View File

@ -2,7 +2,6 @@ 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.CollectDeviceHisVo;
import com.bonus.base.screen.domain.DeviceAlarmVo;
import com.bonus.base.screen.domain.ProjectOverviewVo;
import com.bonus.base.screen.service.ExcavationDetectionService;

14
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/mapper/ConfinedSpaceGasMapper.java Normal file
View File

@ -0,0 +1,14 @@
package com.bonus.base.screen.mapper;
import com.bonus.base.basic.domain.CollectDevAttrVo;
import com.bonus.base.screen.domain.CollectDeviceHisVo;
import java.util.List;
public interface ConfinedSpaceGasMapper {
List<CollectDevAttrVo> realData(CollectDeviceHisVo collectDeviceHisVo);
CollectDeviceHisVo getData(CollectDevAttrVo collectDevAttrVo);
List<CollectDeviceHisVo> getCurveGraph(CollectDeviceHisVo collectDeviceHisVo);
}

25
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/ConfinedSpaceGasService.java Normal file
View File

@ -0,0 +1,25 @@
package com.bonus.base.screen.service;
import com.bonus.base.screen.domain.CollectDeviceHisVo;
import java.util.List;
import java.util.Map;
public interface ConfinedSpaceGasService {
/**
* 实时数据变化
* @param collectDeviceHisVo
* @return
*/
Map<String, String> realData(CollectDeviceHisVo collectDeviceHisVo);
/**
* 获取曲线图
* @param collectDeviceHisVo
* @return
*/
List<CollectDeviceHisVo> getCurveGraph(CollectDeviceHisVo collectDeviceHisVo);
}

15
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/ExcavationDetectionService.java
View File

@ -9,10 +9,25 @@ import com.bonus.base.screen.domain.ProjectOverviewVo;
import java.util.List;
public interface ExcavationDetectionService {
/**
* 查询设备列表
* @param constInfoVo
* @return
*/
List<CollectDevVo> getCollectDeviceList(ConstInfoVo constInfoVo);
/**
* 设备统计
* @param constInfoVo
* @return
*/
ProjectOverviewVo getDevStatistics(ConstInfoVo constInfoVo);
/**
* 报警信息
* @param constInfoVo
* @return
*/
List<DeviceAlarmVo> concreteAlarmList(ConstInfoVo constInfoVo);
}

55
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/ConfinedSpaceGasServiceImpl.java Normal file
View File

@ -0,0 +1,55 @@
package com.bonus.base.screen.service.impl;
import com.bonus.base.basic.domain.CollectDevAttrVo;
import com.bonus.base.screen.domain.CollectDeviceHisVo;
import com.bonus.base.screen.mapper.ConfinedSpaceGasMapper;
import com.bonus.base.screen.service.ConfinedSpaceGasService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author 马三炮
* @date 2025/4/18
*/
@Slf4j
@Service
public class ConfinedSpaceGasServiceImpl implements ConfinedSpaceGasService {
@Resource
private ConfinedSpaceGasMapper confinedSpaceGasMapper;
/**
* 实时数据变化
* @param collectDeviceHisVo
* @return
*/
@Override
public Map<String, String> realData(CollectDeviceHisVo collectDeviceHisVo) {
Map<String, String> map = new HashMap<>();
//获取设备所有的属性
List<CollectDevAttrVo> collectDevAttrVoList = confinedSpaceGasMapper.realData(collectDeviceHisVo);
for (CollectDevAttrVo collectDevAttrVo : collectDevAttrVoList) {
//获取每种属性的最新数据
CollectDeviceHisVo collectDeviceHis = confinedSpaceGasMapper.getData(collectDevAttrVo);
map.put(collectDevAttrVo.getAttrName(),collectDeviceHis.getAttrVal());
}
return map;
}
/**
* 获取曲线图
* @param collectDeviceHisVo
* @return
*/
@Override
public List<CollectDeviceHisVo> getCurveGraph(CollectDeviceHisVo collectDeviceHisVo) {
List<CollectDeviceHisVo> collectDeviceHisVoList = confinedSpaceGasMapper.getCurveGraph(collectDeviceHisVo);
return collectDeviceHisVoList;
}
}

15
bonus-modules/bonus-base/src/main/java/com/bonus/base/screen/service/impl/ExcavationDetectionServiceImpl.java
View File

@ -24,6 +24,11 @@ public class ExcavationDetectionServiceImpl implements ExcavationDetectionServic
@Resource
private ExcavationDetectionMapper excavationDetectionMapper;
/**
* 查询设备列表
* @param constInfoVo
* @return
*/
@Override
public List<CollectDevVo> getCollectDeviceList(ConstInfoVo constInfoVo) {
@ -31,6 +36,11 @@ public class ExcavationDetectionServiceImpl implements ExcavationDetectionServic
return collectDevVoList;
}
/**
* 设备统计
* @param constInfoVo
* @return
*/
@Override
public ProjectOverviewVo getDevStatistics(ConstInfoVo constInfoVo) {
//获取在线和离线的信息
@ -47,6 +57,11 @@ public class ExcavationDetectionServiceImpl implements ExcavationDetectionServic
return projectOverviewVo;
}
/**
* 报警信息
* @param constInfoVo
* @return
*/
@Override
public List<DeviceAlarmVo> concreteAlarmList(ConstInfoVo constInfoVo) {
List<DeviceAlarmVo> deviceAlarmVoList = excavationDetectionMapper.concreteAlarmList(constInfoVo);

23
bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/ConfinedSpaceGasMapper.xml Normal file
View File

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bonus.base.screen.mapper.ConfinedSpaceGasMapper">
<select id="realData" resultType="com.bonus.base.basic.domain.CollectDevAttrVo">
select attr_name,dev_id
from tb_collect_device_attr where dev_id = #{devId}
</select>
<select id="getData" resultType="com.bonus.base.screen.domain.CollectDeviceHisVo">
select create_time,remark,attr_val
from tb_collect_device_his
ORDER BY create_time desc limit 1
</select>
<select id="getCurveGraph" resultType="com.bonus.base.screen.domain.CollectDeviceHisVo">
select tcdh.create_time as createTime,tcdh.remark as remark,tcdh.attr_val as attrVal
from tb_collect_device_his tcdh
where tcdh.attr_name = #{attrName} and tcdh.dev_id = #{devId}
limit 20
</select>
</mapper>

2
bonus-modules/bonus-base/src/main/resources/mapper/screen.basic/ExcavationDetectionMapper.xml
View File

@ -6,7 +6,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<select id="getCollectDeviceList" resultType="com.bonus.base.basic.domain.CollectDevVo">
select tcd.id, tcd.dev_name,tcd.is_online,tcd.dev_location
select tcd.id, tcd.dev_name,tcd.is_online,tcd.dev_location,tcd.dev_code
from tb_collect_device tcd
where tcd.del_flag =0 and tcd.dev_type_id = #{typeId}
</select>