From a3e29d0fbf4d24f7ea7bc5cb18416180954dd668 Mon Sep 17 00:00:00 2001 From: blank <2649084208@qq.com> Date: Wed, 27 Jul 2022 17:11:23 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=A7=E5=B1=8F=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ruoyi/api/app/DapingController.java | 44 ++++++++++++ .../com/ruoyi/api/mapper/DapingMapper.java | 51 +++++++++++++ .../com/ruoyi/api/service/DapingService.java | 32 +++++++++ .../api/service/impl/DapingServiceImpl.java | 71 +++++++++++++++++++ .../resources/mapper/api/DapingMapper.xml | 54 ++++++++++++++ .../code/camera/domain/WaterPhotoInfo.java | 9 +++ 6 files changed, 261 insertions(+) create mode 100644 ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java create mode 100644 ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java create mode 100644 ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java create mode 100644 ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java create mode 100644 ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java b/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java new file mode 100644 index 0000000..1f17c64 --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java @@ -0,0 +1,44 @@ +package com.ruoyi.api.app; + +import com.ruoyi.api.service.DapingService; +import com.ruoyi.code.camera.domain.WaterPhotoInfo; +import com.ruoyi.common.core.page.R; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * 大屏的接口 + */ +@RestController +@RequestMapping("/daping") +@Slf4j +public class DapingController { + + @Autowired + private DapingService dapingService; + + @RequestMapping("/station/info") + public List getStationInfo(){ + return dapingService.getStationInfo(); + } + + @RequestMapping("/station/waterLevel") + public List getStationWaterLevel(){ + return dapingService.getStationWaterLevel(); + } + + @RequestMapping("/station/waterLevelTrend") + public R getWaterLevelTrend(){ + return dapingService.getWaterLevelTrend(); + } + + @RequestMapping("/station/status") + public R getStationByStatus(){ + return dapingService.getStationByStatus(); + } + +} diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java b/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java new file mode 100644 index 0000000..b6103ed --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java @@ -0,0 +1,51 @@ +package com.ruoyi.api.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ruoyi.code.camera.domain.WaterPhotoInfo; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +/** + * 大屏的接口 + */ +@Mapper +public interface DapingMapper extends BaseMapper { + /** + * 大屏查询查询站点信息 + * @return + */ + List selectStationInfo(); + + /** + * 实时水位 + * @return + */ + List selectWaterLevel(); + + /** + * 水位趋势 + * @return + */ + List selectWaterLevelTrend(@Param("id") Integer id); + + /** + * 查询id + * @return + */ + List selectStationInfoId(); + + /** + * 在线 + * @return + */ + Map selectStationByOnlineStatus(); + + /** + * 不在线 + * @return + */ + Map selectStationByOfflineStatus(); +} diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java new file mode 100644 index 0000000..5011d01 --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java @@ -0,0 +1,32 @@ +package com.ruoyi.api.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.code.camera.domain.WaterPhotoInfo; +import com.ruoyi.common.core.page.R; + +import java.util.List; + +public interface DapingService extends IService { + /** + * 大屏查询查询站点信息 + * @return + */ + List getStationInfo(); + + /** + * 实时水位 + * @return + */ + List getStationWaterLevel(); + /** + * 水位趋势 + * @return + */ + R getWaterLevelTrend(); + + /** + * 查询状态 + * @return + */ + R getStationByStatus(); +} diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java new file mode 100644 index 0000000..73f7d46 --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java @@ -0,0 +1,71 @@ +package com.ruoyi.api.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.api.mapper.DapingMapper; +import com.ruoyi.api.service.DapingService; +import com.ruoyi.code.camera.domain.WaterPhotoInfo; +import com.ruoyi.common.core.page.R; +import org.springframework.stereotype.Service; + +import java.util.*; + +@Service +public class DapingServiceImpl extends ServiceImpl implements DapingService{ + /** + * 大屏查询查询站点信息 + * @return + */ + @Override + public List getStationInfo() { + return baseMapper.selectStationInfo(); + } + + /** + * 实时水位 + * @return + */ + @Override + public List getStationWaterLevel() { + return baseMapper.selectWaterLevel(); + } + /** + * 水位趋势 + * @return + */ + @Override + public R getWaterLevelTrend() { + Map map = new HashMap<>(); + Map valMap = new HashMap<>(); + List valueList; + Set tmList = new HashSet<>(); + Set stnmList = new HashSet<>(); + List idList = baseMapper.selectStationInfoId(); + for (Integer id : idList) { + List waterPhotoInfos = baseMapper.selectWaterLevelTrend(id); + valueList = new ArrayList<>(); + String stnm = ""; + for (WaterPhotoInfo waterPhotoInfo : waterPhotoInfos) { + valueList.add(waterPhotoInfo.getValue()); + stnmList.add(waterPhotoInfo.getStnm()); + stnm = waterPhotoInfo.getStnm(); + tmList.add(waterPhotoInfo.getTm()); + } + valMap.put(stnm,valueList); + } + map.put("values",valMap); + map.put("tms",tmList); + map.put("stnms",stnmList); + return R.ok().put("map",map); + } + + @Override + public R getStationByStatus() { + Map map1 = baseMapper.selectStationByOnlineStatus(); + Map map2 = baseMapper.selectStationByOfflineStatus(); + List> resultList = new ArrayList<>(); + resultList.add(map1); + resultList.add(map2); + return R.ok().put("data",resultList); + } + +} diff --git a/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml b/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml new file mode 100644 index 0000000..cd909ea --- /dev/null +++ b/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml @@ -0,0 +1,54 @@ + + + + + + + + + + + + diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/camera/domain/WaterPhotoInfo.java b/ruoyi-code/src/main/java/com/ruoyi/code/camera/domain/WaterPhotoInfo.java index 101e99f..558909d 100644 --- a/ruoyi-code/src/main/java/com/ruoyi/code/camera/domain/WaterPhotoInfo.java +++ b/ruoyi-code/src/main/java/com/ruoyi/code/camera/domain/WaterPhotoInfo.java @@ -50,4 +50,13 @@ public class WaterPhotoInfo implements Serializable private String endTime; + /** 经度 */ + private String longitude; + + /** 纬度 */ + private String latitude; + + /** 摄像头编号 */ + private String cameraSn; + }