diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/DataInterfaceApplication.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/DataInterfaceApplication.java index 161e9ed..865f263 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/DataInterfaceApplication.java +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/DataInterfaceApplication.java @@ -16,7 +16,7 @@ import org.springframework.context.annotation.ComponentScan; */ @SpringBootApplication @EnableFeignClients -@MapperScan(basePackages = {"com.cqu.dataInterface"}) +@ComponentScan(basePackages = {"com.cqu"}) public class DataInterfaceApplication { public static void main(String[] args) { diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/GasController.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/GasController.java new file mode 100644 index 0000000..e37a987 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/GasController.java @@ -0,0 +1,42 @@ +package com.cqu.dataInterface.controller; + +import com.cqu.dataInterface.entity.GasTypeState; +import com.cqu.dataInterface.service.GasService; +import com.cqu.dataInterface.utils.TimeUtils; +import com.cqu.utils.Result; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.dataInterface.controller + *@Author: markilue + *@CreateTime: 2023-05-28 15:51 + *@Description: TODO 燃机Controller层 + *@Version: 1.0 + */ +@RestController +@RequestMapping("/api/dataInterface/gas") +public class GasController { + + @Autowired + private GasService gasService; + + @GetMapping("/gasTypeState/{date}/{limit}") + public Result getGasTypeStateByTm(@PathVariable(required = false) String date, @PathVariable(required = false) Integer limit) { + if ("".equals(date)) { + date = TimeUtils.getCurrentDate(); + } + + List gasTypeStateList = gasService.getGasTypeStateByTm(date, limit); + + return Result.ok().data("data", gasTypeStateList); + + + } +} diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/WindSCADAController.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/WindSCADAController.java index 81538f0..78b57a1 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/WindSCADAController.java +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/controller/WindSCADAController.java @@ -1,14 +1,15 @@ package com.cqu.dataInterface.controller; import com.cqu.dataInterface.entity.WindSCADALocationState; +import com.cqu.dataInterface.entity.WindSCADATypeState; import com.cqu.dataInterface.service.WindSCADAService; +import com.cqu.dataInterface.utils.TimeUtils; import com.cqu.utils.Result; import org.apache.commons.lang3.time.DateFormatUtils; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; +import java.sql.Time; import java.util.Date; import java.util.List; @@ -28,20 +29,28 @@ public class WindSCADAController { @Autowired private WindSCADAService windSCADAService; - @RequestMapping("/windSCADALocationState") - public Result getWindSCADALocationState(@RequestParam(value = "date", defaultValue = "0") String date, @RequestParam(value = "limit", defaultValue = "5") Integer limit) { - if ("0".equals(date)) { - date = getCurrentDate(); + @GetMapping("/windSCADALocationState/{date}/{limit}") + public Result getWindSCADALocationState(@PathVariable(required = false) String date, @PathVariable(required = false) Integer limit) { + if ("".equals(date)) { + date = TimeUtils.getCurrentDate(); } List locationStateList = windSCADAService.getWindSCADALocationStateByTm(date, limit); return Result.ok().data("data", locationStateList); } + @GetMapping("/windSCADATypeState/{date}/{limit}") + public Result getWindSCADATypeState(@PathVariable(required = false) String date, @PathVariable(required = false) Integer limit) { + if ("".equals(date)) { + date = TimeUtils.getCurrentDate(); + } + List locationStateList = windSCADAService.getWindSCADATypeStateByTm(date, limit); - public String getCurrentDate() { - return DateFormatUtils.format(new Date(), "yyyyMMdd"); + return Result.ok().data("data", locationStateList); } + + + } diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/GasTypeState.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/GasTypeState.java new file mode 100644 index 0000000..a9d5cf1 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/GasTypeState.java @@ -0,0 +1,41 @@ +package com.cqu.dataInterface.entity; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.dataInterface.entity + *@Author: markilue + *@CreateTime: 2023-05-28 15:45 + *@Description: TODO 燃机聚合数据实体类 + *@Version: 1.0 + */ +@Data +@NoArgsConstructor +@AllArgsConstructor +public class GasTypeState { + + String stt; + String edt; + String type_id; + Long rated_temp; + Long rated_press; + Long rated_flow_rate; + Long rated_speed; + Long rated_power; + Long rated_load; + Long rated_duration; + Double avg_LubeReturnT2; + Double avg_T5TC1; + Double avg_GFFlow; + Double avg_LFFlow; + Double avg_NHP_1; + Double avg_AirInletDP_1; + Double avg_T1_1; + Double avg_LubeHaderP; + Double avg_LubeFilterDP; + Double avg_TankT; + Double avg_GrBxAccel; +} diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADALocationState.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADALocationState.java index b08df3e..b50c33a 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADALocationState.java +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADALocationState.java @@ -1,9 +1,13 @@ package com.cqu.dataInterface.entity; import lombok.AllArgsConstructor; + +import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; +import java.math.BigDecimal; + /** *@BelongsProject: phm_parent *@BelongsPackage: com.cqu.dataInterface.entity @@ -13,6 +17,7 @@ import lombok.NoArgsConstructor; *@Version: 1.0 */ @Data +@Builder @AllArgsConstructor @NoArgsConstructor public class WindSCADALocationState { @@ -25,25 +30,44 @@ public class WindSCADALocationState { private String location; private String longitude; private String latitude; - private Double production; - private Double avg_torque; - private Double avg_sumptemp; - private Double avg_inletoiltemp; - private Double avg_winddirection; - private Double avg_envtemp; - private Double avg_gen_speed; - private Double avg_pumpoutletpress; - private Double avg_engineroom_temp; - private Double avg_rotorspeed; - private Double avg_activepower; - private Double avg_engineroom_vibration_x; - private Double avg_engineroom_vibration_y; - private Double avg_highspeedshaft_front_temp; - private Double avg_max_windingtemp; - private Double avg_highspeedshaft_rear_temp; - private Double avg_windspeed; - private Double avg_coolingwatertemp; - private Double avg_inletpress; + private BigDecimal production; + @Builder.Default + private BigDecimal avg_torque = BigDecimal.ZERO; + @Builder.Default + + private BigDecimal avg_sumptemp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_inletoiltemp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_winddirection = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_envtemp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_gen_speed = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_pumpoutletpress = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_engineroom_temp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_rotorspeed = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_activepower = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_engineroom_vibration_x = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_engineroom_vibration_y = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_highspeedshaft_front_temp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_max_windingtemp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_highspeedshaft_rear_temp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_windspeed = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_coolingwatertemp = BigDecimal.ZERO; + @Builder.Default + private BigDecimal avg_inletpress = BigDecimal.ZERO; private Long ts; } diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADATypeState.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADATypeState.java new file mode 100644 index 0000000..4f91906 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/entity/WindSCADATypeState.java @@ -0,0 +1,50 @@ +package com.cqu.dataInterface.entity; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.math.BigDecimal; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.warehouse.realtime.entity + *@Author: markilue + *@CreateTime: 2023-05-25 21:39 + *@Description: TODO 风电SCADA数据按照地区聚合后的对象 + *@Version: 1.0 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class WindSCADATypeState { + + //TODO 注意:这些属性名和类型必须和建表的时候完全对应上,ts字段为Long类型；BigInt ->Long + private String stt; + private String edt; + private String type_id; + private Long rated_efficiency; + private Long rated_load; + private Long rated_power; + private Long rated_speed; + private Long rated_air_volume; + private BigDecimal avg_torque; + private BigDecimal avg_sumptemp; + private BigDecimal avg_inletoiltemp; + private BigDecimal avg_winddirection; + private BigDecimal avg_envtemp; + private BigDecimal avg_gen_speed; + private BigDecimal avg_pumpoutletpress; + private BigDecimal avg_engineroom_temp; + private BigDecimal avg_rotorspeed; + private BigDecimal avg_activepower; + private BigDecimal avg_engineroom_vibration_x; + private BigDecimal avg_engineroom_vibration_y; + private BigDecimal avg_highspeedshaft_front_temp; + private BigDecimal avg_max_windingtemp; + private BigDecimal avg_highspeedshaft_rear_temp; + private BigDecimal avg_windspeed; + private BigDecimal avg_coolingwatertemp; + private BigDecimal avg_inletpress; + private Long ts; +} diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/GasMapper.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/GasMapper.java new file mode 100644 index 0000000..4536cea --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/GasMapper.java @@ -0,0 +1,31 @@ +package com.cqu.dataInterface.mapper; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.cqu.dataInterface.entity.GasTypeState; +import io.swagger.models.auth.In; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; + +import java.util.List; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.dataInterface.mapper + *@Author: markilue + *@CreateTime: 2023-05-28 15:46 + *@Description: TODO 燃机Mapper + *@Version: 1.0 + */ +@Mapper +@DS("clickhouse") +public interface GasMapper { + + @Select("select * " + + "from gas_type_state " + + "where " + + " toYYYYMMDD(stt) =#{tm} " + + "limit #{limit}") + @DS("clickhouse") + List selectGasTypeStateByTm(@Param("tm") String tm, @Param("limit") Integer limit); +} diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/WindSCADAMapper.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/WindSCADAMapper.java index 2bfc94c..1d1b473 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/WindSCADAMapper.java +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/WindSCADAMapper.java @@ -2,6 +2,8 @@ package com.cqu.dataInterface.mapper; import com.baomidou.dynamic.datasource.annotation.DS; import com.cqu.dataInterface.entity.WindSCADALocationState; +import com.cqu.dataInterface.entity.WindSCADATypeState; +import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; @@ -16,14 +18,45 @@ import java.util.List; *@Version: 1.0 */ @DS("clickhouse") //本个mapper默认的数据源 +@Mapper public interface WindSCADAMapper { - @Select("select * " + - " " + - "from wind_SCADA_type_state " + - "where " + - " toYYYYMMDD(ts) = ${tm} " + - "and limit ${limit}") + @Select("select stt, " + + " edt, " + + " windfarm, " + + " location, " + + " longitude, " + + " latitude, " + + " production, " + + " avg_torque, " + + " avg_sumptemp, " + + " avg_inletoiltemp, " + + " avg_winddirection, " + + " avg_envtemp, " + + " avg_gen_speed, " + + " avg_pumpoutletpress, " + + " avg_engineroom_temp, " + + " avg_rotorspeed, " + + " avg_activepower, " + + " avg_engineroom_vibration_x, " + + " avg_engineroom_vibration_y, " + + " avg_highspeedshaft_front_temp, " + + " avg_max_windingtemp, " + + " avg_highspeedshaft_rear_temp, " + + " avg_windspeed, " + + " avg_coolingwatertemp, " + + " avg_inletpress, " + + " ts " + + "from wind_SCADA_location_state " + + "where toYYYYMMDD(stt) = #{tm} limit #{limit}") @DS("clickhouse") - List selectWindSCADALocationStateByTm(@Param("tm") String tm,@Param("limit") Integer limit);//通过tm查询风电SCADA数据根据地区聚合之后的数据 + List selectWindSCADALocationStateByTm(@Param("tm") String tm, @Param("limit") Integer limit);//通过tm查询风电SCADA数据根据地区聚合之后的数据 + + @Select("select * " + + "from wind_SCADA_type_state " + + "where " + + " toYYYYMMDD(stt) = #{tm} " + + "limit #{limit}") + List selectWindSCADATypeStateByTm(@Param("tm") String tm, @Param("limit") Integer limit);//通过tm查询风电SCADA数据根据地区聚合之后的数据 + } diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/selectTable.sql b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/selectTable.sql index 3655ce7..c39791d 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/selectTable.sql +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/selectTable.sql @@ -1,7 +1,36 @@ - -- 按照tm查询风电SCADA数据按照地区聚合之后的结果 +-- 注意:需要把所有名称都写出来,按顺序 否则映射不上,需要注意Mybatis-plus的是否转驼峰的配置 +select stt, + edt, + windfarm, + location, + longitude, + latitude, + production, + avg_torque, + avg_sumptemp, + avg_inletoiltemp, + avg_winddirection, + avg_envtemp, + avg_gen_speed, + avg_pumpoutletpress, + avg_engineroom_temp, + avg_rotorspeed, + avg_activepower, + avg_engineroom_vibration_x, + avg_engineroom_vibration_y, + avg_highspeedshaft_front_temp, + avg_max_windingtemp, + avg_highspeedshaft_rear_temp, + avg_windspeed, + avg_coolingwatertemp, + avg_inletpress, + ts +from wind_SCADA_location_state +where toYYYYMMDD(stt) = 20180730 limit 5 + select * from wind_SCADA_type_state where - toYYYYMMDD(ts) =tm -and limit 5 \ No newline at end of file + toYYYYMMDD(stt) =20180730 +limit 5 \ No newline at end of file diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/xml/GasMapper.xml b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/xml/GasMapper.xml new file mode 100644 index 0000000..6853b24 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/xml/GasMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/xml/WindSCADAMapper.xml b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/xml/WindSCADAMapper.xml new file mode 100644 index 0000000..d52e2b4 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/mapper/xml/WindSCADAMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/GasService.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/GasService.java new file mode 100644 index 0000000..d938d70 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/GasService.java @@ -0,0 +1,19 @@ +package com.cqu.dataInterface.service; + +import com.cqu.dataInterface.entity.GasTypeState; + +import java.util.List; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.dataInterface.service + *@Author: markilue + *@CreateTime: 2023-05-28 15:48 + *@Description: TODO 燃机service类 + *@Version: 1.0 + */ +public interface GasService { + + + List getGasTypeStateByTm(String date, Integer limit); +} diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/WindSCADAService.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/WindSCADAService.java index 84d4577..660924b 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/WindSCADAService.java +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/WindSCADAService.java @@ -1,6 +1,7 @@ package com.cqu.dataInterface.service; import com.cqu.dataInterface.entity.WindSCADALocationState; +import com.cqu.dataInterface.entity.WindSCADATypeState; import org.springframework.stereotype.Service; import java.util.List; @@ -17,4 +18,6 @@ public interface WindSCADAService { List getWindSCADALocationStateByTm(String tm,Integer limit); + + List getWindSCADATypeStateByTm(String tm, Integer limit); } diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/GasServiceImpl.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/GasServiceImpl.java new file mode 100644 index 0000000..94aed81 --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/GasServiceImpl.java @@ -0,0 +1,29 @@ +package com.cqu.dataInterface.service.impl; + +import com.cqu.dataInterface.entity.GasTypeState; +import com.cqu.dataInterface.mapper.GasMapper; +import com.cqu.dataInterface.service.GasService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.dataInterface.service.impl + *@Author: markilue + *@CreateTime: 2023-05-28 15:50 + *@Description: TODO 燃机服务实现类 + *@Version: 1.0 + */ +@Service +public class GasServiceImpl implements GasService { + + @Autowired + private GasMapper gasMapper; + + @Override + public List getGasTypeStateByTm(String date, Integer limit) { + return gasMapper.selectGasTypeStateByTm(date, limit); + } +} diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/WindSCADAServiceImpl.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/WindSCADAServiceImpl.java index e2b24ef..88ffac5 100644 --- a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/WindSCADAServiceImpl.java +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/service/impl/WindSCADAServiceImpl.java @@ -1,6 +1,7 @@ package com.cqu.dataInterface.service.impl; import com.cqu.dataInterface.entity.WindSCADALocationState; +import com.cqu.dataInterface.entity.WindSCADATypeState; import com.cqu.dataInterface.mapper.WindSCADAMapper; import com.cqu.dataInterface.service.WindSCADAService; import org.springframework.beans.factory.annotation.Autowired; @@ -27,4 +28,9 @@ public class WindSCADAServiceImpl implements WindSCADAService { public List getWindSCADALocationStateByTm(String tm, Integer limit) { return windSCADAMapper.selectWindSCADALocationStateByTm(tm, limit); } + + @Override + public List getWindSCADATypeStateByTm(String tm, Integer limit) { + return windSCADAMapper.selectWindSCADATypeStateByTm(tm, limit); + } } diff --git a/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/utils/TimeUtils.java b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/utils/TimeUtils.java new file mode 100644 index 0000000..d7c0c9a --- /dev/null +++ b/phm_rotate/backend/phm_backend/service/service_data_interface/src/main/java/com/cqu/dataInterface/utils/TimeUtils.java @@ -0,0 +1,20 @@ +package com.cqu.dataInterface.utils; + +import org.apache.commons.lang3.time.DateFormatUtils; + +import java.util.Date; + +/** + *@BelongsProject: phm_parent + *@BelongsPackage: com.cqu.dataInterface.utils + *@Author: markilue + *@CreateTime: 2023-05-28 15:56 + *@Description: TODO 时间工具类 + *@Version: 1.0 + */ +public class TimeUtils { + + public static String getCurrentDate() { + return DateFormatUtils.format(new Date(), "yyyyMMdd"); + } +}