diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/app/AlarmDataApiController.java b/ruoyi-api/src/main/java/com/ruoyi/api/app/AlarmDataApiController.java new file mode 100644 index 0000000..aac1339 --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/app/AlarmDataApiController.java @@ -0,0 +1,43 @@ +package com.ruoyi.api.app; + +import com.ruoyi.api.controller.AbstractApiController; +import com.ruoyi.api.params.AlarmDataParams; +import com.ruoyi.api.params.WaterDataParams; +import com.ruoyi.api.service.AlarmDataApiService; +import com.ruoyi.api.service.WaterDataApiService; +import com.ruoyi.code.warning.service.IWaAlarmService; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.validator.ValidatorUtils; +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; + + +/** + * 系统对外接口-检测信息 + */ +@RestController +@RequestMapping("/api") +@Slf4j +public class AlarmDataApiController extends AbstractApiController { + + @Resource + private AlarmDataApiService alarmDataApiService; + /** + * 预警数据查询 + * + * @param params + * @return + */ + @PostMapping("v1/alarm_data/query") + public R query(@RequestBody AlarmDataParams params) { + log.info("[预警数据查询接口查询参数为{}]", params); + ValidatorUtils.validateV2(params); + return alarmDataApiService.query(params); + } + +} diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/app/StationDataApiController.java b/ruoyi-api/src/main/java/com/ruoyi/api/app/StationDataApiController.java index 188d2c9..6230e8f 100644 --- a/ruoyi-api/src/main/java/com/ruoyi/api/app/StationDataApiController.java +++ b/ruoyi-api/src/main/java/com/ruoyi/api/app/StationDataApiController.java @@ -32,7 +32,7 @@ public class StationDataApiController extends AbstractApiController { public R query(@RequestBody StationDataParams params) { log.info("[测站数据查询接口查询参数为{}]", params); ValidatorUtils.validateV2(params); - return stationDataApiService.query(params,getMarketAuthDto()); + return stationDataApiService.query(params); } } diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/app/WaterDataApiController.java b/ruoyi-api/src/main/java/com/ruoyi/api/app/WaterDataApiController.java index fe1b911..0a965c0 100644 --- a/ruoyi-api/src/main/java/com/ruoyi/api/app/WaterDataApiController.java +++ b/ruoyi-api/src/main/java/com/ruoyi/api/app/WaterDataApiController.java @@ -34,7 +34,7 @@ public class WaterDataApiController extends AbstractApiController { public R query(@RequestBody WaterDataParams params) { log.info("[水位数据查询接口查询参数为{}]", params); ValidatorUtils.validateV2(params); - return waterDataApiService.query(params,getMarketAuthDto()); + return waterDataApiService.query(params); } } diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/controller/AbstractApiController.java b/ruoyi-api/src/main/java/com/ruoyi/api/controller/AbstractApiController.java index b72de75..1bbc610 100644 --- a/ruoyi-api/src/main/java/com/ruoyi/api/controller/AbstractApiController.java +++ b/ruoyi-api/src/main/java/com/ruoyi/api/controller/AbstractApiController.java @@ -33,11 +33,12 @@ public abstract class AbstractApiController { ValidatorUtils.validateV2(signParams); YhAppInfoEntity appInfo = commonService.checkDigest(signParams); HttpServletUtil.setAppInfo(appInfo); + //验证接口权限 commonService.authPermission(appInfo); } - protected MarketAuthDto getMarketAuthDto() { - return commonService.getMarketAuthDto(HttpServletUtil.getAppInfo()); - } +// protected MarketAuthDto getMarketAuthDto() { +// return commonService.getMarketAuthDto(HttpServletUtil.getAppInfo()); +// } } diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/params/AlarmDataParams.java b/ruoyi-api/src/main/java/com/ruoyi/api/params/AlarmDataParams.java new file mode 100644 index 0000000..7f6eead --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/params/AlarmDataParams.java @@ -0,0 +1,16 @@ +package com.ruoyi.api.params; + +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; + +@Data +public class AlarmDataParams { + + private Long stnmId; + + private String startTime; + + private String endTime; +} diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/AlarmDataApiService.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/AlarmDataApiService.java new file mode 100644 index 0000000..55326d6 --- /dev/null +++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/AlarmDataApiService.java @@ -0,0 +1,31 @@ +package com.ruoyi.api.service; + +import com.ruoyi.api.params.AlarmDataParams; +import com.ruoyi.api.params.WaterDataParams; +import com.ruoyi.code.warning.domain.WaAlarm; +import com.ruoyi.code.warning.service.IWaAlarmService; +import com.ruoyi.common.core.page.R; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Service +public class AlarmDataApiService { + + @Resource + private IWaAlarmService waAlarmService; + + public R query(AlarmDataParams params) { + Map map = new HashMap<>(); + map.put("stnmId",params.getStnmId()); + map.put("startTime",params.getStartTime()); + map.put("endTime",params.getEndTime()); + + List list = waAlarmService.queryAlarm(map); + return R.ok().put("data", list); + } + +} diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/StationDataApiService.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/StationDataApiService.java index 86f658b..7311931 100644 --- a/ruoyi-api/src/main/java/com/ruoyi/api/service/StationDataApiService.java +++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/StationDataApiService.java @@ -21,13 +21,14 @@ public class StationDataApiService { @Resource private IScStationInfoService scStationInfoService; - public R query(StationDataParams params, MarketAuthDto marketAuthDto) { +// public R query(StationDataParams params, MarketAuthDto marketAuthDto) { + public R query(StationDataParams params) { Long id = params.getId(); String stnm = params.getStnm(); List list = scStationInfoService.list( new QueryWrapper() - .in("id", marketAuthDto.getQueryList()) +// .in("id", marketAuthDto.getQueryList()) .eq(id != null, "id", id) .like(StringUtils.isNotBlank(stnm),"stnm", stnm) ); diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/WaterDataApiService.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/WaterDataApiService.java index 2878eb5..6f2111d 100644 --- a/ruoyi-api/src/main/java/com/ruoyi/api/service/WaterDataApiService.java +++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/WaterDataApiService.java @@ -1,7 +1,6 @@ package com.ruoyi.api.service; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.ruoyi.api.dto.MarketAuthDto; import com.ruoyi.api.dto.StationData; import com.ruoyi.api.params.StationDataParams; import com.ruoyi.api.params.WaterDataParams; @@ -27,15 +26,14 @@ public class WaterDataApiService { @Resource private IScWaterDataService scWaterDataService; - public R query(WaterDataParams params, MarketAuthDto marketAuthDto) { + public R query(WaterDataParams params) { Long stnmId = params.getStnmId(); String startTime = params.getStartTime(); String endTime = params.getEndTime(); List list = scWaterDataService.list( new QueryWrapper() - .in("stnm_id", marketAuthDto.getQueryList()) - .eq("stnm_id", stnmId) + .eq(stnmId != null,"stnm_id", stnmId) .between("tm",startTime,endTime) ); diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/scwaterdata/domain/ScWaterData.java b/ruoyi-code/src/main/java/com/ruoyi/code/scwaterdata/domain/ScWaterData.java index cce20e7..46908a1 100644 --- a/ruoyi-code/src/main/java/com/ruoyi/code/scwaterdata/domain/ScWaterData.java +++ b/ruoyi-code/src/main/java/com/ruoyi/code/scwaterdata/domain/ScWaterData.java @@ -8,7 +8,10 @@ import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableId; import java.io.Serializable; + +import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; +import org.springframework.format.annotation.DateTimeFormat; /** @@ -31,6 +34,8 @@ public class ScWaterData implements Serializable private Long stnmId; /** 时间 */ + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") private Date tm; /** 水位值 */ diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java index 13b8da7..d72cb08 100644 --- a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java @@ -1,9 +1,12 @@ package com.ruoyi.code.warning.domain; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; +import org.springframework.format.annotation.DateTimeFormat; import java.io.Serializable; import java.util.Date; @@ -32,10 +35,15 @@ public class WaAlarm implements Serializable private String alarmContent; /** 预警时间 */ + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") private Date alarmTime; /** 0 未删除 1 删除 */ // @TableLogic private Long deleted; + + @TableField(exist = false) + private String stnm; } diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java index 65e8d6a..8bb3ac8 100644 --- a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java @@ -1,8 +1,12 @@ package com.ruoyi.code.warning.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import org.apache.ibatis.annotations.Mapper; import com.ruoyi.code.warning.domain.WaAlarm; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; /** * Mapper接口 @@ -14,4 +18,5 @@ import com.ruoyi.code.warning.domain.WaAlarm; public interface WaAlarmMapper extends BaseMapper { + List queryAlarm(@Param("params") Map params); } diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java index 78e747f..b1c6eca 100644 --- a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.extension.service.IService; import com.ruoyi.code.warning.domain.WaAlarm; import com.ruoyi.common.core.page.R; +import java.util.List; import java.util.Map; /** @@ -19,4 +20,5 @@ public interface IWaAlarmService extends IService */ R queryPage(Map params); + List queryAlarm(Map params); } diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java index fa2f686..3f9b4d2 100644 --- a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java @@ -11,6 +11,7 @@ import com.ruoyi.common.utils.Query; import com.ruoyi.common.utils.StringUtils; import org.springframework.stereotype.Service; +import java.util.List; import java.util.Map; /** @@ -36,4 +37,8 @@ public class WaAlarmServiceImpl extends ServiceImpl impl return R.ok().put("count", page.getTotal()).put("data", page.getRecords()); } + @Override + public List queryAlarm(Map params){ + return baseMapper.queryAlarm(params); + } } diff --git a/ruoyi-code/src/main/resources/mapper/warning/WaAlarmMapper.xml b/ruoyi-code/src/main/resources/mapper/warning/WaAlarmMapper.xml new file mode 100644 index 0000000..3fc74d1 --- /dev/null +++ b/ruoyi-code/src/main/resources/mapper/warning/WaAlarmMapper.xml @@ -0,0 +1,20 @@ + + + + + +