diff --git a/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/Main.java b/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/Main.java index d4b8792..81eb042 100644 --- a/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/Main.java +++ b/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/Main.java @@ -11,12 +11,12 @@ import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication @EnableScheduling @MapperScan({ - "com.gunshi.project.tsg.datasync.mapper", - "com.gunshi.project.tsg.datasync.mapper.jcsk", - "com.gunshi.project.tsg.datasync.rsvrWaterLevel", - "com.gunshi.project.tsg.datasync.rainfall", - "com.gunshi.project.tsg.datasync.gate", - "com.gunshi.project.tsg.datasync.riverWaterLevel", + "com.gunshi.project.hsz.datasync.mapper", + "com.gunshi.project.hsz.datasync.mapper.jcsk", + "com.gunshi.project.hsz.datasync.rsvrWaterLevel", + "com.gunshi.project.hsz.datasync.rainfall", + "com.gunshi.project.hsz.datasync.gate", + "com.gunshi.project.hsz.datasync.riverWaterLevel", }) public class Main { diff --git a/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/riverWaterLevel/RiverWaterLevelService.java b/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/riverWaterLevel/RiverWaterLevelService.java index 65416cd..7324f40 100644 --- a/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/riverWaterLevel/RiverWaterLevelService.java +++ b/service-datasync/src/main/java/com/gunshi/project/hsz/datasync/riverWaterLevel/RiverWaterLevelService.java @@ -37,14 +37,14 @@ public class RiverWaterLevelService implements SyncTableRService stbprps = stbprpMapper.selectByElem("z"); int cnt = 0; for (StStbprpBElem StStbprpBElem : stbprps) { RiverWaterLevel targetParams = new RiverWaterLevel(); targetParams.setStcd(StStbprpBElem.getStcd()); - + //获取该站点在水库表中最新的那一条数据 RiverWaterLevel latestTarget = getLatestTargetEntity(targetParams); List sourceEntityList = getSourceEntityListByLatestTargetEntity(latestTarget); cnt += saveToTarget(sourceEntityList); @@ -75,6 +75,7 @@ public class RiverWaterLevelService implements SyncTableRService getSourceEntityListByLatestTargetEntity(@NonNull RiverWaterLevel targetEntity) { + //去荆楚水库中查询出,时间大于水库中最新那一条时间的记录 String stcd = targetEntity.getStcd(); LocalDateTime tm = targetEntity.getTm(); return sourceMapper.selectList( @@ -86,6 +87,7 @@ public class RiverWaterLevelService implements SyncTableRService sourceEntityList) { + //将查询出的数据保存至目标水库表中 int count = 0; for (JcskStRsvrR sourceEntity : sourceEntityList) { String stcd = sourceEntity.getStcd(); diff --git a/src/main/java/com/gunshi/project/hsz/controller/WaterAlarmController.java b/src/main/java/com/gunshi/project/hsz/controller/WaterAlarmController.java index aa4e50e..4a05581 100644 --- a/src/main/java/com/gunshi/project/hsz/controller/WaterAlarmController.java +++ b/src/main/java/com/gunshi/project/hsz/controller/WaterAlarmController.java @@ -66,16 +66,16 @@ public class WaterAlarmController { @Operation(summary = "根据年份进行统计柱形图") @GetMapping("/count12") - public List count12(@RequestParam(value = "year") Integer year){ + public R> count12(@RequestParam(value = "year") Integer year){ List counts = service.count12(year); - return counts; + return R.ok(counts); } @Operation(summary = "根据年份进行统计圆饼图") @GetMapping("/countTypeByYear") - public List countTypeByYear(@RequestParam(value = "year") Integer year){ + public R> countTypeByYear(@RequestParam(value = "year") Integer year){ List res = service.countTypeByYear(year); - return res; + return R.ok(res); } } diff --git a/src/main/java/com/gunshi/project/hsz/service/WaterAlarmService.java b/src/main/java/com/gunshi/project/hsz/service/WaterAlarmService.java index 46e8295..b881c8a 100644 --- a/src/main/java/com/gunshi/project/hsz/service/WaterAlarmService.java +++ b/src/main/java/com/gunshi/project/hsz/service/WaterAlarmService.java @@ -42,6 +42,7 @@ public class WaterAlarmService extends ServiceImpl if(pageSo.getTimeRangeSo() != null){ queryWrapper.between(WaterAlarm::getAlarmTime,pageSo.getTimeRangeSo().getStart(),pageSo.getTimeRangeSo().getEnd()); } + queryWrapper.orderByDesc(WaterAlarm::getAlarmTime); Page waterAlarmPage = this.baseMapper.selectPage(pageSo.getPageSo().toPage(), queryWrapper); return waterAlarmPage; } diff --git a/src/main/java/com/gunshi/project/hsz/timetask/AlarmTask.java b/src/main/java/com/gunshi/project/hsz/timetask/AlarmTask.java index 5b188bb..507ce57 100644 --- a/src/main/java/com/gunshi/project/hsz/timetask/AlarmTask.java +++ b/src/main/java/com/gunshi/project/hsz/timetask/AlarmTask.java @@ -128,7 +128,9 @@ public class AlarmTask { if(stRiverRReal != null){ + //该站点,真实河道水位的最新数据的时间 Instant newDateInstant = stRiverRReal.getTm().toInstant(); + //告警表中,该站点的最新数据的时间 Instant curDateInstant = waterAlarmNew.getAlarmTime().toInstant(); if(newDateInstant.compareTo(curDateInstant) <= 0){ //如果要插入数据的时间与当前告警表中数据相同,则直接跳过本条数据