From 88a5b794fb322728045ada65dd64c99fafd2304e Mon Sep 17 00:00:00 2001 From: yangzhe123 <2824096059@qq.com> Date: Mon, 12 Jan 2026 16:37:23 +0800 Subject: [PATCH] =?UTF-8?q?1=EF=BC=9A=E6=8A=A5=E8=A1=A8=E7=AE=A1=E7=90=86-?= =?UTF-8?q?=E9=80=BB=E8=BE=91=E4=BF=AE=E6=94=B9=202=EF=BC=9A=E5=B0=86?= =?UTF-8?q?=E7=AB=99=E7=82=B9=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3=E7=BB=9F?= =?UTF-8?q?=E4=B8=80=E8=B5=B7=E6=9D=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docker-compose.yml | 26 +- .../ss/common/mapper/StStbprpBMapper.java | 16 + .../controller/OsmoticPressRController.java | 178 ------- .../controller/OsmoticShiftRController.java | 116 ----- .../ss/controller/StationController.java | 75 +++ .../ss/controller/StatisticsController.java | 20 +- .../project/ss/entity/dto/ReportTmSo.java | 15 + .../ss/entity/so/StatisticsQuerySo.java | 2 + .../gunshi/project/ss/entity/vo/SdJyRbVo.java | 5 + .../gunshi/project/ss/entity/vo/SdSwRbVo.java | 13 + .../project/ss/mapper/StPptnRHMapper.java | 14 +- .../project/ss/mapper/StbprpBVoMapper.java | 16 - .../ss/service/OsmoticPressRService.java | 485 ------------------ .../ss/service/OsmoticShiftRService.java | 333 ------------ .../project/ss/service/StStbprpBService.java | 7 + .../project/ss/service/StatisticsService.java | 89 ++-- src/main/resources/mapper/StPptnRHMapper.xml | 20 +- 17 files changed, 235 insertions(+), 1195 deletions(-) delete mode 100644 src/main/java/com/gunshi/project/ss/controller/OsmoticPressRController.java delete mode 100644 src/main/java/com/gunshi/project/ss/controller/OsmoticShiftRController.java create mode 100644 src/main/java/com/gunshi/project/ss/controller/StationController.java create mode 100644 src/main/java/com/gunshi/project/ss/entity/dto/ReportTmSo.java delete mode 100644 src/main/java/com/gunshi/project/ss/service/OsmoticPressRService.java delete mode 100644 src/main/java/com/gunshi/project/ss/service/OsmoticShiftRService.java diff --git a/docker-compose.yml b/docker-compose.yml index a9cc411..2918b66 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -4,8 +4,8 @@ networks: external: true driver: bridge services: - hsz-redis: - container_name: hsz-redis + ss-redis: + container_name: ss-redis image: redis:latest privileged: true environment: @@ -15,36 +15,36 @@ services: networks: - tsg_tsg-bridge volumes: - - /opt/hsz/redis/conf/redis.conf:/usr/local/etc/redis/conf/redis.conf - - /opt/hsz/redis/data:/data + - /opt/ss/redis/conf/redis.conf:/usr/local/etc/redis/conf/redis.conf + - /opt/ss/redis/data:/data command: redis-server /usr/local/etc/redis/conf/redis.conf - hsz-proj: - container_name: hsz-proj + ss-proj: + container_name: ss-proj image: openjdk:21 working_dir: /app networks: - tsg_tsg-bridge volumes: - - /opt/hsz/java:/app + - /opt/ss/java:/app ports: - "24305:24305" environment: - SPRING_PROFILES_ACTIVE=prod - TZ=Asia/Shanghai depends_on: - - hsz-redis - entrypoint: java -cp "gunshi-project-hsz-1.0-SNAPSHOT.jar:./lib/*" com.gunshi.project.hsz.Main + - ss-redis + entrypoint: java -cp "gunshi-project-ss-1.0-SNAPSHOT.jar:./lib/*" com.gunshi.project.ss.Main - hsz-datasync: - container_name: hsz-datasync + ss-datasync: + container_name: ss-datasync image: openjdk:21 working_dir: /app networks: - tsg_tsg-bridge volumes: - - /opt/hsz/datasync:/app + - /opt/ss/datasync:/app environment: - SPRING_PROFILES_ACTIVE=prod - TZ=Asia/Shanghai - entrypoint: java -cp "gunshi-project-hsz-datasync-1.0-SNAPSHOT.jar:./lib/*" com.gunshi.project.hsz.datasync.Main \ No newline at end of file + entrypoint: java -cp "gunshi-project-ss-datasync-1.0-SNAPSHOT.jar:./lib/*" com.gunshi.project.ss.datasync.Main \ No newline at end of file diff --git a/module-common/src/main/java/com/gunshi/project/ss/common/mapper/StStbprpBMapper.java b/module-common/src/main/java/com/gunshi/project/ss/common/mapper/StStbprpBMapper.java index 84ed64a..1aa438c 100644 --- a/module-common/src/main/java/com/gunshi/project/ss/common/mapper/StStbprpBMapper.java +++ b/module-common/src/main/java/com/gunshi/project/ss/common/mapper/StStbprpBMapper.java @@ -32,4 +32,20 @@ public interface StStbprpBMapper extends BaseMapper { """) List getRsvrStations(); + @Select(""" + select * from public.st_stbprp_b b + join public.st_stbprp_b_elem e + on b.stcd =e.stcd + where e.elem = 'z' +""") + List getRiverStations(); + + @Select(""" + select * from public.st_stbprp_b b + join public.st_stbprp_b_elem e + on b.stcd =e.stcd + where e.elem = 'flow' +""") + List getFlowStations(); + } \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/controller/OsmoticPressRController.java b/src/main/java/com/gunshi/project/ss/controller/OsmoticPressRController.java deleted file mode 100644 index f64c30d..0000000 --- a/src/main/java/com/gunshi/project/ss/controller/OsmoticPressRController.java +++ /dev/null @@ -1,178 +0,0 @@ -//package com.gunshi.project.hsz.controller; -// -//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -//import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; -//import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -//import com.gunshi.core.result.R; -//import com.gunshi.project.hsz.common.model.so.OsmoticDetailQuerySo; -//import com.gunshi.project.hsz.common.model.so.OsmoticQueryPageSo; -//import com.gunshi.project.hsz.common.model.so.OsmoticQuerySo; -//import com.gunshi.project.hsz.entity.vo.OsmoticChartVo; -//import com.gunshi.project.hsz.common.model.vo.OsmoticPressDetailVo; -//import com.gunshi.project.hsz.entity.vo.OsmoticPressVo; -//import com.gunshi.project.hsz.entity.vo.OsmoticStationVo; -//import com.gunshi.project.hsz.model.OsmoticPressDevice; -//import com.gunshi.project.hsz.model.OsmoticPressR; -//import com.gunshi.project.hsz.service.OsmoticPressDeviceService; -//import com.gunshi.project.hsz.service.OsmoticPressRService; -//import com.gunshi.project.hsz.common.validate.markers.Insert; -//import com.gunshi.project.hsz.common.validate.markers.Update; -//import io.swagger.v3.oas.annotations.Operation; -//import io.swagger.v3.oas.annotations.media.Schema; -//import io.swagger.v3.oas.annotations.tags.Tag; -//import jakarta.servlet.http.HttpServletResponse; -//import org.apache.commons.collections4.CollectionUtils; -//import org.springframework.beans.factory.annotation.Autowired; -//import org.springframework.validation.annotation.Validated; -//import org.springframework.web.bind.annotation.*; -// -//import java.io.Serializable; -//import java.util.List; -//import java.util.Map; -//import java.util.Objects; -//import java.util.stream.Collectors; -// -///** -// * 描述: 渗压监测记录表 -// * author: xusan -// * date: 2024-07-08 17:40:37 -// */ -////@Tag(name = "渗压监测记录表") -////@RestController -////@RequestMapping(value="/osmoticPressR") -//public class OsmoticPressRController { -// -// @Autowired -// private OsmoticPressRService service; -// -// @Autowired -// private OsmoticPressDeviceService osmoticPressDeviceService; -// -// -// @Operation(summary = "新增") -// @PostMapping("/insert") -// public R insert(@Validated(Insert.class) @RequestBody OsmoticPressR dto) { -//// // 通过时间戳去除毫秒 -//// long currentTime = System.currentTimeMillis(); -//// long seconds = currentTime / 1000; // 去掉毫秒部分 -//// Date dateWithoutMillis = new Date(seconds * 1000); // 转回毫秒时间戳 -//// dto.setTm(dateWithoutMillis); -// boolean result = service.save(dto); -// return R.ok(result ? dto : null); -// } -// -// @Operation(summary = "修改") -// @PostMapping("/update") -// public R update(@Validated(Update.class) @RequestBody OsmoticPressR dto) { -// LambdaUpdateWrapper wrapper = new LambdaUpdateWrapper<>(); -// wrapper.eq(OsmoticPressR::getTm, dto.getTm()) -// .eq(OsmoticPressR::getStationCode, dto.getStationCode()) -// .set(OsmoticPressR::getPress, dto.getPress()) -// .set(OsmoticPressR::getVib, dto.getVib()) -// .set(OsmoticPressR::getTemp, dto.getTemp()) -// .set(OsmoticPressR::getValue, dto.getValue()) -// .set(OsmoticPressR::getChan, dto.getChan()); -// boolean update = service.update(null, wrapper); -// return R.ok(update ? dto : null); -// } -// -// @Operation(summary = "删除") -// @GetMapping("/del/{id}/{tm}") -// public R del(@Schema(name = "id") @PathVariable("id") Serializable id,@Schema(name = "tm") @PathVariable("tm") Serializable tm) { -// if(Objects.isNull(id) || Objects.isNull(tm)){ -// return R.ok(false); -// } -// QueryWrapper wrapper = new QueryWrapper<>(); -// wrapper.eq("station_code", id).eq("tm", tm); -// return R.ok(service.remove(wrapper)); -// } -// -// @Operation(summary = "列表") -// @PostMapping("/list") -// public R> list() { -// return R.ok(service.lambdaQuery().list()); -// } -// -// @Operation(summary = "分页") -// @PostMapping("/page") -// public R> page(@RequestBody OsmoticQueryPageSo osmoticQueryPageSo) { -// Page osmoticPressRPage = service.queryPage(osmoticQueryPageSo); -// List records = osmoticPressRPage.getRecords(); -// if(CollectionUtils.isEmpty(records)){ -// return R.ok(osmoticPressRPage); -// } -// List collect = records.stream().peek(e -> { -// LambdaQueryWrapper wq = new LambdaQueryWrapper(); -// wq.eq(OsmoticPressDevice::getStationCode, e.getStationCode()); -// List list = osmoticPressDeviceService.list(wq); -// if (CollectionUtils.isNotEmpty(list)) { -// OsmoticPressDevice osmoticPressDevice = list.stream().findFirst().orElse(null); -// e.setProfileCode(osmoticPressDevice.getProfileCode()); -// } -// }).collect(Collectors.toList()); -// osmoticPressRPage.setRecords(collect); -// return R.ok(osmoticPressRPage); -// } -// -// @Operation(summary = "大屏-大坝安全监测统计") -// @GetMapping("/stat") -// public R> stat() { -// return R.ok(service.stat()); -// } -// -// @Operation(summary = "布置图-渗压/渗流监测") -// @GetMapping("/list/value") -// public R> listValue(@Schema(name = "type",description = "类型(1渗压 2渗流)") @RequestParam("type") Integer type) { -// return R.ok(service.listValue(type)); -// } -// -// @Operation(summary = "布置图-按测站查询渗压/渗流监测数据") -// @PostMapping("/detail/value") -// public R> detailValue(@RequestBody @Validated OsmoticDetailQuerySo so) { -// return R.ok(service.detailValue(so)); -// } -// -// @Operation(summary = "测值查询(数据表)") -// @PostMapping("/query/value") -// public R> queryValue(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.queryValue(osmoticQuerySo,null)); -// } -// -// @Operation(summary = "测值查询(多图单表)") -// @PostMapping("/query/chart") -// public R> queryChart(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.queryChart(osmoticQuerySo,null)); -// } -// -// @Operation(summary = "浸润线查询") -// @PostMapping("/infiltra/line") -// public R> infiltraLine(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.infiltraLine(osmoticQuerySo)); -// } -// -// @Operation(summary = "浸润线导出") -// @PostMapping( "/export") -// public void export(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo, HttpServletResponse response) { -// service.export(osmoticQuerySo,response); -// } -// -// @Operation(summary = "年度渗压/渗流统计(表格)") -// @PostMapping("/year/stat") -// public R> yearStat(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.yearStat(osmoticQuerySo)); -// } -// -// @Operation(summary = "年度渗压/渗流统计(全年度特征值统计)") -// @PostMapping("/year/stat/value") -// public R> yearStatValue(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.yearStatValue(osmoticQuerySo)); -// } -// -// @Operation(summary = "年度渗压/渗流统计导出") -// @PostMapping( "/year/stat/export") -// public void yearStatExport(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo, HttpServletResponse response) { -// service.yearStatExport(osmoticQuerySo,response); -// } -// -//} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/controller/OsmoticShiftRController.java b/src/main/java/com/gunshi/project/ss/controller/OsmoticShiftRController.java deleted file mode 100644 index 65d4636..0000000 --- a/src/main/java/com/gunshi/project/ss/controller/OsmoticShiftRController.java +++ /dev/null @@ -1,116 +0,0 @@ -//package com.gunshi.project.hsz.controller; -// -//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -//import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; -//import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -//import com.gunshi.core.result.R; -//import com.gunshi.project.hsz.common.model.so.OsmoticDetailQuerySo; -//import com.gunshi.project.hsz.common.model.so.OsmoticQueryPageSo; -//import com.gunshi.project.hsz.common.model.so.OsmoticQuerySo; -//import com.gunshi.project.hsz.entity.vo.*; -//import com.gunshi.project.hsz.model.OsmoticShiftR; -//import com.gunshi.project.hsz.service.OsmoticShiftRService; -//import com.gunshi.project.hsz.common.validate.markers.Insert; -//import com.gunshi.project.hsz.common.validate.markers.Update; -//import io.swagger.v3.oas.annotations.Operation; -//import io.swagger.v3.oas.annotations.media.Schema; -//import io.swagger.v3.oas.annotations.tags.Tag; -//import jakarta.servlet.http.HttpServletResponse; -//import org.springframework.beans.factory.annotation.Autowired; -//import org.springframework.validation.annotation.Validated; -//import org.springframework.web.bind.annotation.*; -// -//import java.io.Serializable; -//import java.util.List; -//import java.util.Objects; -// -///** -// * 描述: 位移监测记录表 -// * author: xusan -// * date: 2024-07-08 17:40:37 -// */ -////@Tag(name = "位移监测记录表") -////@RestController -////@RequestMapping(value="/osmoticShiftR") -//public class OsmoticShiftRController { -// -// @Autowired -// private OsmoticShiftRService service; -// -// -// @Operation(summary = "新增") -// @PostMapping("/insert") -// public R insert(@Validated(Insert.class) @RequestBody OsmoticShiftR dto) { -// // dto.setTm(new Date()); -// boolean result = service.save(dto); -// return R.ok(result ? dto : null); -// } -// -// @Operation(summary = "修改") -// @PostMapping("/update") -// public R update(@Validated(Update.class) @RequestBody OsmoticShiftR dto) { -// LambdaUpdateWrapper wrapper = new LambdaUpdateWrapper<>(); -// wrapper.eq(OsmoticShiftR::getStationCode, dto.getStationCode()) -// .eq(OsmoticShiftR::getTm, dto.getTm()) -// .set(OsmoticShiftR::getX, dto.getX()) -// .set(OsmoticShiftR::getY, dto.getY()) -// .set(OsmoticShiftR::getH, dto.getH()); -// boolean update = service.update(null, wrapper); -// return R.ok(update ? dto : null); -// } -// -// @Operation(summary = "删除") -// @GetMapping("/del/{id}/{tm}") -// public R del(@Schema(name = "id") @PathVariable("id") Serializable id,@Schema(name = "tm") @PathVariable("tm") Serializable tm) { -// -// if(Objects.isNull(id) || Objects.isNull(tm)){ -// return R.ok(false); -// } -// QueryWrapper wrapper = new QueryWrapper<>(); -// wrapper.eq("station_code", id).eq("tm", tm); -// return R.ok(service.remove(wrapper)); -// } -// -// @Operation(summary = "列表") -// @PostMapping("/list") -// public R> list() { -// return R.ok(service.lambdaQuery().list()); -// } -// -// @Operation(summary = "分页") -// @PostMapping("/page") -// public R> page(@RequestBody OsmoticQueryPageSo osmoticQueryPageSo) { -// return R.ok(service.queryPage(osmoticQueryPageSo)); -// } -// -// @Operation(summary = "年度位移统计(表格)") -// @PostMapping("/year/stat") -// public R> yearStat(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.yearStat(osmoticQuerySo)); -// } -// -// @Operation(summary = "年度位移统计(全年度特征值统计)") -// @PostMapping("/year/stat/value") -// public R> yearStatValue(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo) { -// return R.ok(service.yearStatValue(osmoticQuerySo)); -// } -// -// @Operation(summary = "年度位移统计导出") -// @PostMapping( "/year/stat/export") -// public void yearStatExport(@RequestBody @Validated OsmoticQuerySo osmoticQuerySo, HttpServletResponse response) { -// service.yearStatExport(osmoticQuerySo,response); -// } -// -// @Operation(summary = "布置图-位移监测") -// @GetMapping("/list/value") -// public R> listValue() { -// return R.ok(service.listValue()); -// } -// -// @Operation(summary = "布置图-按测站查询位移监测数据") -// @PostMapping("/detail/value") -// public R> detailValue(@RequestBody @Validated OsmoticDetailQuerySo so) { -// return R.ok(service.detailValue(so)); -// } -// -//} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/controller/StationController.java b/src/main/java/com/gunshi/project/ss/controller/StationController.java new file mode 100644 index 0000000..ef1ba76 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/controller/StationController.java @@ -0,0 +1,75 @@ +package com.gunshi.project.ss.controller; + + +import com.gunshi.core.result.R; +import com.gunshi.project.ss.common.model.StStbprpB; +import com.gunshi.project.ss.entity.vo.ProfilePressTreeVo; +import com.gunshi.project.ss.model.AttCctvBase; +import com.gunshi.project.ss.service.AttCctvBaseService; +import com.gunshi.project.ss.service.AttDamProfileService; +import com.gunshi.project.ss.service.StStbprpBService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +@RestController +@RequestMapping("/station") +public class StationController { + + + @Autowired + private StStbprpBService stStbprpBService;//基本站点信息 雨量,水位,流量,水库 + + @Autowired + private AttCctvBaseService attCctvBaseService;//视频点 + + @Autowired + private AttDamProfileService attDamProfileService;//渗压断面 + + + //获取雨量站信息 + @GetMapping("/rainList") + public R> rainList(){ + List stStbprpBList = stStbprpBService.getPptnStations(); + return R.ok(stStbprpBList); + } + + //获取水库水位站信息 + @GetMapping("/rzList") + public R> rzList(){ + List stStbprpBList = stStbprpBService.getRsvrStations(); + return R.ok(stStbprpBList); + } + +// //获取河道水位站信息 +// @GetMapping("/riverList") +// public R> riverList(){ +// List stStbprpBList = stStbprpBService.getRiverStations(); +// return R.ok(stStbprpBList); +// } + + //获取流量站信息 + @GetMapping("/flowList") + public R> flowList(){ + List stStbprpBList = stStbprpBService.getFlowStations(); + return R.ok(stStbprpBList); + } + + //获取视频站信息 + @GetMapping("/cctvList") + public R> cctvList(){ + List cctvBases = attCctvBaseService.queryList(); + return R.ok(cctvBases); + } + + //获取渗压监测断面与对应测点 + @GetMapping("/syDmList") + public R> syDmList(){ + List tree = attDamProfileService.tree(); + return R.ok(tree); + } + +} diff --git a/src/main/java/com/gunshi/project/ss/controller/StatisticsController.java b/src/main/java/com/gunshi/project/ss/controller/StatisticsController.java index 95ffda7..fedddbf 100644 --- a/src/main/java/com/gunshi/project/ss/controller/StatisticsController.java +++ b/src/main/java/com/gunshi/project/ss/controller/StatisticsController.java @@ -2,6 +2,7 @@ package com.gunshi.project.ss.controller; import com.gunshi.core.result.R; import com.gunshi.db.dto.DateRangeSo; +import com.gunshi.project.ss.entity.dto.ReportTmSo; import com.gunshi.project.ss.entity.so.StatisticsQuerySo; import com.gunshi.project.ss.entity.vo.*; import com.gunshi.project.ss.service.StatisticsService; @@ -15,6 +16,9 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.util.Date; import java.util.List; /** @@ -32,26 +36,26 @@ public class StatisticsController{ @Operation(summary = "时段降雨日报表") @PostMapping("/sdJyRb") - public R> sdJyRb(@Validated @RequestBody DateRangeSo dateRangeSo) { - return R.ok(service.sdJyRb(dateRangeSo)); + public R> sdJyRb(@Validated @RequestBody ReportTmSo reportTmSo) { + return R.ok(service.getDailyRain(reportTmSo)); } @Operation(summary = "时段降雨日报表导出") @PostMapping( "/sdJyRb/export") - public void export(@RequestBody @Validated DateRangeSo dateRangeSo, HttpServletResponse response) { - service.sdJyRbExport(dateRangeSo,response); + public void export(@RequestBody @Validated ReportTmSo reportTmSo, HttpServletResponse response) { + service.sdJyRbExport(reportTmSo,response); } @Operation(summary = "时段水位日报表") @PostMapping("/sdSwRb") - public R> sdSwRb(@Validated @RequestBody DateRangeSo dateRangeSo) { - return R.ok(service.sdSwRb(dateRangeSo)); + public R> sdSwRb(@Validated @RequestBody ReportTmSo reportTmSo) { + return R.ok(service.sdSwRb(reportTmSo)); } @Operation(summary = "时段水位日报表导出") @PostMapping("/sdSwRb/export") - public void sdSwRbExport(@Validated @RequestBody DateRangeSo dateRangeSo, HttpServletResponse response) { - service.sdSwRbExport(dateRangeSo,response); + public void sdSwRbExport(@Validated @RequestBody ReportTmSo reportTmSo, HttpServletResponse response) { + service.sdSwRbExport(reportTmSo,response); } @Operation(summary = "日降雨年报表(上方表格)") diff --git a/src/main/java/com/gunshi/project/ss/entity/dto/ReportTmSo.java b/src/main/java/com/gunshi/project/ss/entity/dto/ReportTmSo.java new file mode 100644 index 0000000..95b8bf8 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/entity/dto/ReportTmSo.java @@ -0,0 +1,15 @@ +package com.gunshi.project.ss.entity.dto; + + +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; + +import java.util.Date; + +@Data +public class ReportTmSo { + + + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private Date date; +} diff --git a/src/main/java/com/gunshi/project/ss/entity/so/StatisticsQuerySo.java b/src/main/java/com/gunshi/project/ss/entity/so/StatisticsQuerySo.java index 413a100..0823659 100644 --- a/src/main/java/com/gunshi/project/ss/entity/so/StatisticsQuerySo.java +++ b/src/main/java/com/gunshi/project/ss/entity/so/StatisticsQuerySo.java @@ -17,4 +17,6 @@ public class StatisticsQuerySo { @Schema(description="年份") private Integer year; + @Schema(description = "站点编码") + private String stcd; } diff --git a/src/main/java/com/gunshi/project/ss/entity/vo/SdJyRbVo.java b/src/main/java/com/gunshi/project/ss/entity/vo/SdJyRbVo.java index 531c160..405a3ca 100644 --- a/src/main/java/com/gunshi/project/ss/entity/vo/SdJyRbVo.java +++ b/src/main/java/com/gunshi/project/ss/entity/vo/SdJyRbVo.java @@ -12,6 +12,11 @@ import java.math.BigDecimal; public class SdJyRbVo { + @ExcelProperty({"${title}","站点名称"}) + private String stnm; + + private String stcd; + /** * 日期 */ diff --git a/src/main/java/com/gunshi/project/ss/entity/vo/SdSwRbVo.java b/src/main/java/com/gunshi/project/ss/entity/vo/SdSwRbVo.java index f0d69f6..3e0da51 100644 --- a/src/main/java/com/gunshi/project/ss/entity/vo/SdSwRbVo.java +++ b/src/main/java/com/gunshi/project/ss/entity/vo/SdSwRbVo.java @@ -12,6 +12,19 @@ import java.math.BigDecimal; public class SdSwRbVo { + /** + * 站点编码 + */ + @ExcelProperty({"${title}","站点编码"}) + private String stcd; + + + /** + * 日期 + */ + @ExcelProperty({"${title}","站点名称"}) + private String stnm; + /** * 日期 */ diff --git a/src/main/java/com/gunshi/project/ss/mapper/StPptnRHMapper.java b/src/main/java/com/gunshi/project/ss/mapper/StPptnRHMapper.java index 5b56dab..7ca2e0a 100644 --- a/src/main/java/com/gunshi/project/ss/mapper/StPptnRHMapper.java +++ b/src/main/java/com/gunshi/project/ss/mapper/StPptnRHMapper.java @@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.gunshi.project.ss.common.model.vo.StRzVo; import com.gunshi.project.ss.model.StPptnRD; import com.gunshi.project.ss.model.StPptnRH; +import jakarta.validation.constraints.NotBlank; +import jakarta.validation.constraints.Size; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -17,15 +19,19 @@ import java.util.List; @Mapper public interface StPptnRHMapper extends BaseMapper { - List queryList(@Param("start") String start,@Param("end") String end); - List queryRzList(@Param("start") String start,@Param("end") String end); + List queryRzListByStcd(@Param("start") String start,@Param("end") String end,@Param("stcd") String stcd); - List queryDayDrp(@Param("year") Integer year); + List queryDayDrpByStcd(@Param("year")Integer year,@Param("stcd") String stcd); List reorganizePptnRHData(@Param("stcd") String stcd, @Param("maxData") StPptnRH maxData); StPptnRH getMaxData(String stcd); - List queryDayRz(@Param("year") String year); + + List queryDayRzByStcd(@Param("year") String year,@Param("stcd") String stcd); + + List queryListByStcd(@Param("start") String start, @Param("end") String end, @Param("stcd") String stcd); + + } diff --git a/src/main/java/com/gunshi/project/ss/mapper/StbprpBVoMapper.java b/src/main/java/com/gunshi/project/ss/mapper/StbprpBVoMapper.java index 5f27866..fe4552e 100644 --- a/src/main/java/com/gunshi/project/ss/mapper/StbprpBVoMapper.java +++ b/src/main/java/com/gunshi/project/ss/mapper/StbprpBVoMapper.java @@ -82,22 +82,6 @@ public interface StbprpBVoMapper { """) List rainList(); - // @Select("") @Select("""