skf振动数据接入

energy-manage-common/src/main/java/com/energy/manage/common/po/healthscores/HealthscoresPO.java

@@ -1,142 +0,0 @@
-package com.energy.manage.common.po.healthscores;
-
-import lombok.Data;
-import lombok.EqualsAndHashCode;
-import lombok.experimental.Accessors;
-
-import java.io.Serializable;
-import java.math.BigDecimal;
-import java.util.Date;
-
-@Data
-@EqualsAndHashCode(callSuper = false)
-@Accessors(chain = true)
-public class HealthscoresPO implements Serializable {
-
-    private static final long serialVersionUID = 1L;
-
-    /**
-     * 主键ID
-     * 对应数据库字段：id (INT, 自增主键)
-     */
-    private Integer id;
-
-    /**
-     * 风场ID（内部命名）
-     * 对应数据库字段：field_code (VARCHAR(32), 非空，默认空字符串)
-     */
-    private String fieldId;
-
-    /**
-     * 风机ID（内部命名）
-     * 对应数据库字段：engine_code (VARCHAR(32), 非空，默认空字符串)
-     */
-    private String engineId;
-
-    /**
-     * 机型型号
-     */
-    private String machineTypeCode;
-
-    /**
-     * 综合健康评分 (0-100)
-     * 对应数据库字段：overall_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal overallScore;
-
-    /**
-     * 综合健康等级 (优/良/中/差)
-     * 对应数据库字段：overall_level (VARCHAR(10), 可为空)
-     */
-    private String overallLevel;
-
-    /**
-     * 叶轮健康评分 (0-100)
-     * 对应数据库字段：rotor_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal rotorScore;
-
-    /**
-     * 塔筒健康评分 (0-100)
-     * 对应数据库字段：tower_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal towerScore;
-
-    /**
-     * 发电机健康评分 (0-100)
-     * 对应数据库字段：generator_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal generatorScore;
-
-    /**
-     * 齿轮箱健康评分 (0-100)
-     * 对应数据库字段：gearbox_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal gearboxScore;
-
-    /**
-     * 主轴健康评分 (0-100)
-     * 对应数据库字段：main_shaft_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal mainShaftScore;
-
-    /**
-     * 变流器健康评分 (0-100)
-     * 对应数据库字段：converter_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal converterScore;
-
-    /**
-     * 偏航系统健康评分 (0-100)
-     * 对应数据库字段：yaw_system_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal yawSystemScore;
-
-    /**
-     * 变桨系统健康评分 (0-100)
-     * 对应数据库字段：pitch_system_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal pitchSystemScore;
-
-    /**
-     * 液压系统健康评分 (0-100)
-     * 对应数据库字段：hydraulic_system_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal hydraulicSystemScore;
-
-    /**
-     * 主控系统健康评分 (0-100)
-     * 对应数据库字段：control_system_score (DECIMAL(5,2), 可为空)
-     */
-    private BigDecimal controlSystemScore;
-
-    /**
-     * 数据来源时间 (yyyy-mm-dd)
-     * 对应数据库字段：source_datetime (DATE, 非空)
-     */
-    private Date sourceDatetime;
-
-    /**
-     * 评估入库时间戳 (yyyy-mm-dd hh:mm:ss)
-     * 对应数据库字段：create_time (DATETIME, 非空，默认当前时间)
-     */
-    private Date createTime;
-
-    /**
-     * 结构健康评分
-     */
-    private BigDecimal structureScore;
-
-    /**
-     * 部件健康评分
-     */
-    private BigDecimal componentScore;
-
-    /**
-     * 系统健康评分
-     */
-    private BigDecimal systemScore;
-
-
-
-}

energy-manage-common/src/main/java/com/energy/manage/common/po/healthscores/HealthscoresWindPO.java

@@ -1,111 +0,0 @@
-package com.energy.manage.common.po.healthscores;
-
-
-import com.fasterxml.jackson.annotation.JsonFormat;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Data;
-import lombok.EqualsAndHashCode;
-import lombok.experimental.Accessors;
-
-import java.io.Serializable;
-import java.math.BigDecimal;
-import java.util.Date;
-
-@Data
-@EqualsAndHashCode(callSuper = false)
-@Accessors(chain = true)
-@ApiModel
-public class HealthscoresWindPO implements Serializable {
-
-    private static final long serialVersionUID = 1L;
-
-    /**
-     * 主键ID
-     * 对应数据库字段：id (INT, 自增主键)
-     */
-    @ApiModelProperty("主键ID")
-    private Integer id;
-
-    /**
-     * 风场ID（客户内部编号）
-     * 对应数据库字段：fieldId (VARCHAR(32), 非空，默认空字符串)
-     */
-    @ApiModelProperty("风场ID（客户内部编号）")
-    private String fieldId;
-
-    /**
-     * 风场内健康等级为优的风机个数
-     * 对应数据库字段：excellent_count (INT, 可为空)
-     */
-    @ApiModelProperty("风场内健康等级为优的风机个数")
-    private Integer excellentCount;
-
-    /**
-     * 风场内健康等级为良的风机个数
-     * 对应数据库字段：good_count (INT, 可为空)
-     */
-    @ApiModelProperty("风场内健康等级为良的风机个数")
-    private Integer goodCount;
-
-    /**
-     * 风场内健康等级为中的风机个数
-     * 对应数据库字段：fair_count (INT, 可为空)
-     */
-    @ApiModelProperty("风场内健康等级为中的风机个数")
-    private Integer fairCount;
-
-    /**
-     * 风场内健康等级为差的风机个数
-     * 对应数据库字段：poor_count (INT, 可为空)
-     */
-    @ApiModelProperty("风场内健康等级为差的风机个数")
-    private Integer poorCount;
-
-    /**
-     * 风场综合健康评分 (0-100)
-     * 对应数据库字段：overall_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("风场综合健康评分")
-    private BigDecimal overallScore;
-
-    /**
-     * 风场结构健康评分 (0-100)
-     * 对应数据库字段：structure_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("风场结构健康评分")
-    private BigDecimal structureScore;
-
-    /**
-     * 风场系统健康评分 (0-100)
-     * 对应数据库字段：system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("风场系统健康评分")
-    private BigDecimal systemScore;
-
-    /**
-     * 风场部件健康评分 (0-100)
-     * 对应数据库字段：component_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("风场部件健康评分")
-    private BigDecimal componentScore;
-
-    /**
-     * 数据来源时间 (yyyy-mm-dd)
-     * 对应数据库字段：source_datetime (DATE, 非空)
-     */
-    @ApiModelProperty("数据来源时间")
-    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
-    private Date sourceDatetime;
-
-    /**
-     * 评估入库时间戳 (yyyy-mm-dd hh:mm:ss)
-     * 对应数据库字段：create_time (DATETIME, 非空，默认当前时间)
-     */
-    @ApiModelProperty("评估入库时间戳")
-    @JsonFormat(pattern = "yyyy-MM-dd HH:mm",timezone = "GMT+8")
-    private Date createTime;
-
-
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/constant/client/skf/SkfClientConstants.java

@@ -6,7 +6,7 @@ package com.energy.manage.service.constant.client.skf;
 public interface SkfClientConstants {
 
 
-    String SKF_REQUEST_PATH = "http://106.120.102.238:13050";
+    String SKF_REQUEST_PATH = "http://192.168.50.242:13050";
 
     String SKF_TOKEN_GRANT_TYPE = "password";
 

energy-manage-service/src/main/java/com/energy/manage/service/controller/analysisresultreport/AnalysisResultReportController.java

@@ -25,6 +25,11 @@ public class AnalysisResultReportController extends BaseServiceController {
     @Autowired
     private AnalysisResultReportService analysisResultReportService;
 
+    /**
+     * 批量添加保存报告
+     * @param reportVoList
+     * @return
+     */
     @PostMapping("/saveReportBatch")
     public ResultResp saveReportBatch(@RequestBody List<AnalysisResultReportVo> reportVoList)
     {

energy-manage-service/src/main/java/com/energy/manage/service/controller/healthscores/HealthscoresController.java

@@ -1,81 +0,0 @@
-package com.energy.manage.service.controller.healthscores;
-
-import com.energy.manage.common.reponse.ResultResp;
-import com.energy.manage.service.config.annotations.UserLoginToken;
-import com.energy.manage.service.controller.base.BaseServiceController;
-import com.energy.manage.service.domain.vo.healthscores.HealthOverviewVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresTendencyVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresWindVO;
-import com.energy.manage.service.domain.vo.homepage.WaitTaskVo;
-import com.energy.manage.service.service.healthscores.HealthscoresService;
-import com.energy.manage.service.service.homepage.HomePageService;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiParam;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.List;
-
-/**
- * @author sy
- * @desc
- */
-@Api(value = "HealthscoresController",tags = "风机健康查询接口")
-@RestController
-@RequestMapping("/healthscores")
-public class HealthscoresController extends BaseServiceController {
-
-    @Autowired
-    private HealthscoresService healthscoresService;
-
-    @ApiOperation("首页风场健康台数统计数据")
-    @UserLoginToken
-    @PostMapping("/getHealthscoresWindList")
-    public ResultResp<List<HealthscoresWindVO>> getHealthscoresWindList(
-                                                                @ApiParam(value = "fieldCode参数为平台内部风场编号，当参数为空时，默认查全部风场", required = false)
-                                                                @RequestParam(value = "fieldCode",required = false) String fieldCode,
-                                                                @ApiParam(value = "datatime参数为查询日期，当参数为空时，默认查昨天日期的数据", required = false)
-                                                                @RequestParam(value = "datatime",required = false) String datatime){
-        List<HealthscoresWindVO> list = healthscoresService.getHealthscoresWind(fieldCode,datatime);
-        return success(list);
-    }
-
-
-
-    @ApiOperation("风场下所有风机健康查询概览页面")
-    @UserLoginToken
-    @PostMapping("/getHealthOverview")
-    public ResultResp<HealthOverviewVO> getHealthOverview(
-                                                        @ApiParam(value = "fieldCode参数为平台内部风场编号", required = true)
-                                                        @RequestParam(value = "fieldCode") String fieldCode,
-                                                        @ApiParam(value = "datatime参数为查询日期，当参数为空时，默认查昨天日期的数据", required = false)
-                                                        @RequestParam(value = "datatime",required = false) String datatime){
-        HealthOverviewVO healthOverviewVO = healthscoresService.getHealthOverview(fieldCode,datatime);
-        return success(healthOverviewVO);
-    }
-
-
-    @ApiOperation("风机按天数查询趋势图")
-    @UserLoginToken
-    @PostMapping("/getLastDaysTrend")
-    public ResultResp<HealthscoresTendencyVO> getLastDaysTrend(
-                                                               @ApiParam(value = "fieldId参数为客户内部风场ID，可通过风机概览页面获取", required = true)
-                                                               @RequestParam(value = "fieldId") String fieldId,
-                                                               @ApiParam(value = "engineId参数为客户内部风机ID，可通过风机概览页面获取", required = true)
-                                                               @RequestParam(value = "engineId") String engineId,
-                                                               @ApiParam(value = "day参数为查询多少天的趋势图数据，如7天，30天，365天", required = true)
-                                                               @RequestParam(value = "day") int day){
-        List<HealthscoresTendencyVO> list = healthscoresService.getLastDaysTrend(day,fieldId,engineId);
-        return success(list);
-    }
-
-
-
-
-
-
-
-
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/controller/system/SysTestController.java

@@ -78,7 +78,7 @@ public class SysTestController {
 
 //        vibrationService.extracTwindGeneratorSkfPointData(yesterdayDate);
 
-        vibrationService.extracTwindGeneratorSkfMachinePart(yesterdayDate);
+//        vibrationService.extracTwindGeneratorSkfMachinePart(yesterdayDate);
 
         vibrationService.extracTwindGeneratorSkfPointData(yesterdayDate);
 	}

energy-manage-service/src/main/java/com/energy/manage/service/domain/vo/healthscores/HealthOverviewListVO.java

@@ -1,166 +0,0 @@
-package com.energy.manage.service.domain.vo.healthscores;
-
-import com.fasterxml.jackson.annotation.JsonFormat;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Getter;
-import lombok.Setter;
-
-import java.math.BigDecimal;
-import java.util.Date;
-
-@Getter
-@Setter
-@ApiModel
-public class HealthOverviewListVO {
-
-    /**
-     * 编号
-     */
-    @ApiModelProperty("编号")
-    private Integer id;
-    /**
-     * 风场ID（内部命名）
-     * 对应数据库字段：field_code (VARCHAR(32), 非空，默认空字符串)
-     */
-    @ApiModelProperty("风场ID（客户内部命名）")
-    private String fieldId;
-
-
-    /**
-     * 风机ID（内部命名）
-     * 对应数据库字段：engine_code (VARCHAR(32), 非空，默认空字符串)
-     */
-    @ApiModelProperty("风机ID（客户内部命名）")
-    private String engineId;
-
-    /**
-     * 风机名称
-     */
-    @ApiModelProperty("风机名称")
-    private String engineName;
-
-    /**
-     * 机型型号
-     */
-    @ApiModelProperty("机型型号")
-    private String machineTypeCode;
-
-    /**
-     * 综合健康评分 (0-100)
-     * 对应数据库字段：overall_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("综合健康评分 (0-100)")
-    private BigDecimal overallScore;
-
-    /**
-     * 综合健康等级 (优/良/中/差)
-     * 对应数据库字段：overall_level (VARCHAR(10), 可为空)
-     */
-    @ApiModelProperty("综合健康等级 (优/良/中/差)")
-    private String overallLevel;
-
-    /**
-     * 叶轮健康评分 (0-100)
-     * 对应数据库字段：rotor_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("叶轮健康评分 (0-100)")
-    private BigDecimal rotorScore;
-
-    /**
-     * 塔筒健康评分 (0-100)
-     * 对应数据库字段：tower_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("塔筒健康评分 (0-100)")
-    private BigDecimal towerScore;
-
-    /**
-     * 发电机健康评分 (0-100)
-     * 对应数据库字段：generator_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("发电机健康评分 (0-100)")
-    private BigDecimal generatorScore;
-
-    /**
-     * 齿轮箱健康评分 (0-100)
-     * 对应数据库字段：gearbox_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("齿轮箱健康评分 (0-100)")
-    private BigDecimal gearboxScore;
-
-    /**
-     * 主轴健康评分 (0-100)
-     * 对应数据库字段：main_shaft_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("主轴健康评分 (0-100)")
-    private BigDecimal mainShaftScore;
-
-    /**
-     * 变流器健康评分 (0-100)
-     * 对应数据库字段：converter_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("变流器健康评分 (0-100)")
-    private BigDecimal converterScore;
-
-    /**
-     * 偏航系统健康评分 (0-100)
-     * 对应数据库字段：yaw_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("偏航系统健康评分 (0-100)")
-    private BigDecimal yawSystemScore;
-
-    /**
-     * 变桨系统健康评分 (0-100)
-     * 对应数据库字段：pitch_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("变桨系统健康评分 (0-100)")
-    private BigDecimal pitchSystemScore;
-
-    /**
-     * 液压系统健康评分 (0-100)
-     * 对应数据库字段：hydraulic_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("液压系统健康评分 (0-100)")
-    private BigDecimal hydraulicSystemScore;
-
-    /**
-     * 主控系统健康评分 (0-100)
-     * 对应数据库字段：control_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("主控系统健康评分 (0-100)")
-    private BigDecimal controlSystemScore;
-
-    /**
-     * 数据来源时间 (yyyy-mm-dd)
-     * 对应数据库字段：source_datetime (DATE, 非空)
-     */
-    @ApiModelProperty("数据来源时间 (yyyy-mm-dd)")
-    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
-    private Date sourceDatetime;
-
-    /**
-     * 评估入库时间戳 (yyyy-mm-dd hh:mm:ss)
-     * 对应数据库字段：create_time (DATETIME, 非空，默认当前时间)
-     */
-    @ApiModelProperty("评估入库时间戳 (yyyy-mm-dd hh:mm:ss)")
-    @JsonFormat(pattern = "yyyy-MM-dd HH:mm",timezone = "GMT+8")
-    private Date createTime;
-
-    /**
-     * 结构健康评分
-     */
-    @ApiModelProperty("结构健康评分")
-    private BigDecimal structureScore;
-
-    /**
-     * 部件健康评分
-     */
-    @ApiModelProperty("部件健康评分")
-    private BigDecimal componentScore;
-
-    /**
-     * 系统健康评分
-     */
-    @ApiModelProperty("系统健康评分")
-    private BigDecimal systemScore;
-}

energy-manage-service/src/main/java/com/energy/manage/service/domain/vo/healthscores/HealthOverviewVO.java

@@ -1,39 +0,0 @@
-package com.energy.manage.service.domain.vo.healthscores;
-
-import com.energy.manage.common.po.healthscores.HealthscoresWindPO;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Getter;
-import lombok.Setter;
-
-import java.math.BigDecimal;
-import java.util.Date;
-import java.util.List;
-
-@Getter
-@Setter
-@ApiModel
-public class HealthOverviewVO {
-
-    /**
-     * 风场健康信息
-     */
-    @ApiModelProperty("风场健康信息")
-    private HealthscoresWindVO healthscoresWindVO;
-
-
-    /**
-     * 健康概览风机集合
-     */
-    @ApiModelProperty("健康概览风机集合")
-    private List<HealthOverviewListVO>  healthOverviewListVOList;
-
-
-
-
-
-
-
-
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/domain/vo/healthscores/HealthscoresTendencyVO.java

@@ -1,119 +0,0 @@
-package com.energy.manage.service.domain.vo.healthscores;
-
-import com.fasterxml.jackson.annotation.JsonFormat;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Getter;
-import lombok.Setter;
-
-import java.math.BigDecimal;
-import java.time.LocalDate;
-import java.util.Date;
-
-@Getter
-@Setter
-@ApiModel
-public class HealthscoresTendencyVO {
-
-    // 空构造（MyBatis反射用）
-    public HealthscoresTendencyVO() {}
-
-    // 仅日期构造（补0时用）
-    public HealthscoresTendencyVO(LocalDate sourceDatetime) {
-        this.sourceDatetime = sourceDatetime;
-    }
-
-    /**
-     * 风场id
-     */
-    @ApiModelProperty("风场id,客户内部编号")
-    private String  fieldId;
-
-    /**
-     * 风机id
-     */
-    @ApiModelProperty("风机id，客户内部编号")
-    private String  engineId;
-
-    /**
-     * 坐标x
-     */
-    @ApiModelProperty("坐标x")
-    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
-    private LocalDate sourceDatetime;
-
-    /**
-     * 叶轮健康评分 (0-100)
-     * 对应数据库字段：rotor_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("叶轮健康评分")
-    private BigDecimal rotorScore;
-
-    /**
-     * 塔筒健康评分 (0-100)
-     * 对应数据库字段：tower_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("塔筒健康评分")
-    private BigDecimal towerScore;
-
-    /**
-     * 发电机健康评分 (0-100)
-     * 对应数据库字段：generator_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("发电机健康评分")
-    private BigDecimal generatorScore;
-
-    /**
-     * 齿轮箱健康评分 (0-100)
-     * 对应数据库字段：gearbox_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("齿轮箱健康评分")
-    private BigDecimal gearboxScore;
-
-    /**
-     * 主轴健康评分 (0-100)
-     * 对应数据库字段：main_shaft_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("主轴健康评分")
-    private BigDecimal mainShaftScore;
-
-    /**
-     * 变流器健康评分 (0-100)
-     * 对应数据库字段：converter_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("变流器健康评分")
-    private BigDecimal converterScore;
-
-    /**
-     * 偏航系统健康评分 (0-100)
-     * 对应数据库字段：yaw_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("偏航系统健康评分")
-    private BigDecimal yawSystemScore;
-
-    /**
-     * 变桨系统健康评分 (0-100)
-     * 对应数据库字段：pitch_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("变桨系统健康评分")
-    private BigDecimal pitchSystemScore;
-
-    /**
-     * 液压系统健康评分 (0-100)
-     * 对应数据库字段：hydraulic_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("液压系统健康评分")
-    private BigDecimal hydraulicSystemScore;
-
-    /**
-     * 主控系统健康评分 (0-100)
-     * 对应数据库字段：control_system_score (DECIMAL(5,2), 可为空)
-     */
-    @ApiModelProperty("主控系统健康评分")
-    private BigDecimal controlSystemScore;
-
-    @ApiModelProperty("综合健康评分 (0-100) ")
-    private BigDecimal overallScore;
-
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/domain/vo/healthscores/HealthscoresWindVO.java

@@ -1,16 +0,0 @@
-package com.energy.manage.service.domain.vo.healthscores;
-
-import com.energy.manage.common.po.healthscores.HealthscoresWindPO;
-import io.swagger.annotations.ApiModel;
-import lombok.Getter;
-import lombok.Setter;
-
-import java.util.List;
-
-@Getter
-@Setter
-@ApiModel
-public class HealthscoresWindVO extends HealthscoresWindPO {
-
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/mappers/healthscores/HealthscoresMapper.java

@@ -1,64 +0,0 @@
-package com.energy.manage.service.mappers.healthscores;
-
-import com.energy.manage.common.mapper.MyMapper;
-import com.energy.manage.common.po.healthscores.HealthscoresPO;
-import com.energy.manage.common.po.powerwordcontract.PowerWordContractPO;
-import com.energy.manage.service.domain.vo.healthscores.HealthOverviewListVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresTendencyVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresWindVO;
-import org.apache.ibatis.annotations.Param;
-import org.springframework.stereotype.Repository;
-
-import java.time.LocalDate;
-import java.util.List;
-import java.util.Set;
-
-@Repository
-public interface HealthscoresMapper extends MyMapper<HealthscoresPO> {
-
-    /**
-     * 查询整个风场健康情况统计信息集合
-     * @param fieldId
-     * @param beginTime
-     * @param endTime
-     * @return
-     */
-    List<HealthscoresWindVO> selectWindScoreList(@Param("fieldId")String fieldId,
-                                                 @Param("beginTime")String beginTime,
-                                                 @Param("endTime")String endTime);
-
-    /**
-     * 查询单个风场健康情况统计信息
-     * @param fieldId
-     * @param beginTime
-     * @param endTime
-     * @return
-     */
-    HealthscoresWindVO selectWindHealthscoresScore(@Param("fieldId")String fieldId,
-                                                   @Param("beginTime")String beginTime,
-                                                   @Param("endTime")String endTime);
-
-    /**
-     * 查询风场下所有风机健康情况信息
-     * @param fieldId
-     * @param beginTime
-     * @param endTime
-     * @return
-     */
-    List<HealthOverviewListVO> selectHealthOverviewList(@Param("year")String year,
-                                                        @Param("fieldId")String fieldId,
-                                                        @Param("beginTime")String beginTime,
-                                                        @Param("endTime")String endTime);
-
-
-    /**
-     * 跨年分表查询近365天数据
-     */
-    List<HealthscoresTendencyVO> listHscoresLastays( @Param("fieldId") String fieldId,
-                                                     @Param("engineId") String engineId,
-                                                     @Param("startDate") LocalDate startDate,
-                                                     @Param("endDate") LocalDate endDate,
-                                                     @Param("tableNames") List<String> tableNames);
-
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/service/anomaly/AnomalyService.java

@@ -0,0 +1,18 @@
+package com.energy.manage.service.service.anomaly;
+
+/**
+ * 异常检测接口
+ */
+public interface AnomalyService {
+
+
+
+
+
+
+
+
+
+
+
+}

energy-manage-service/src/main/java/com/energy/manage/service/service/healthscores/HealthscoresService.java

@@ -1,42 +0,0 @@
-package com.energy.manage.service.service.healthscores;
-
-import com.energy.manage.service.domain.vo.healthscores.HealthOverviewListVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthOverviewVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresTendencyVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresWindVO;
-
-import java.util.List;
-
-/**
- * 健康查询接口
- */
-public interface HealthscoresService {
-
-
-    /**
-     * 风场健康查询综合页面（包含首页）
-     * @param datatime
-     * @return
-     */
-    List<HealthscoresWindVO> getHealthscoresWind(String fieldCode,String datatime);
-
-
-    /**
-     * 风场下风机健康查询概览页面
-     * @param fieldCode
-     * @param datatime
-     * @return
-     */
-    HealthOverviewVO getHealthOverview(String fieldCode,String datatime);
-
-
-    /**
-     * 风机健康趋势图
-     * @param day
-     * @param fieldId
-     * @param engineId
-     * @return
-     */
-    List<HealthscoresTendencyVO> getLastDaysTrend(int day, String fieldId, String engineId);
-
-}

energy-manage-service/src/main/java/com/energy/manage/service/service/healthscores/impl/HealthscoresServiceImpl.java

@@ -1,252 +0,0 @@
-package com.energy.manage.service.service.healthscores.impl;
-
-import com.energy.manage.common.po.windfield.WindFieldPO;
-import com.energy.manage.service.domain.vo.healthscores.HealthOverviewListVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthOverviewVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresTendencyVO;
-import com.energy.manage.service.domain.vo.healthscores.HealthscoresWindVO;
-import com.energy.manage.service.mappers.healthscores.HealthscoresMapper;
-import com.energy.manage.service.mappers.windfield.WindFieldMapper;
-import com.energy.manage.service.service.healthscores.HealthscoresService;
-import groovy.util.logging.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
-import java.util.*;
-import java.util.stream.Collectors;
-import java.util.stream.Stream;
-
-@Service
-@Slf4j
-public class HealthscoresServiceImpl implements HealthscoresService {
-
-    @Autowired
-    private HealthscoresMapper healthscoresMapper;
-
-    @Autowired
-    private WindFieldMapper windFieldMapper;
-
-    // 通用日期格式化器（线程安全，可全局复用）
-    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-    private static final DateTimeFormatter DATETIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
-
-
-    @Override
-    public List<HealthscoresWindVO> getHealthscoresWind(String fieldCode, String datatime) {
-
-        String fieldId = null;
-        if (!StringUtils.isEmpty(fieldCode)) {
-            WindFieldPO po = new WindFieldPO();
-            po.setFieldCode(fieldCode);
-            WindFieldPO windFieldPO = windFieldMapper.selectOne(po);
-            fieldId = windFieldPO.getFieldId();
-        }
-
-        String beginTime = null;
-        String endTime = null;
-        if (!StringUtils.isEmpty(datatime)) {
-            beginTime = appendTimeToString(datatime, 00, 00, 00);
-            endTime = appendTimeToString(datatime, 23, 59, 59);
-        } else {
-            beginTime = getYesterdayStartStr();
-            endTime = getYesterdayEnd().format(DATETIME_FORMATTER);
-        }
-
-        List<HealthscoresWindVO> list = healthscoresMapper.selectWindScoreList(fieldId, beginTime, endTime);
-        return list;
-    }
-
-
-    @Override
-    public HealthOverviewVO getHealthOverview(String fieldCode, String datatime) {
-
-        String fieldId = null;
-        if (!StringUtils.isEmpty(fieldCode)) {
-            WindFieldPO po = new WindFieldPO();
-            po.setFieldCode(fieldCode);
-            WindFieldPO windFieldPO = windFieldMapper.selectOne(po);
-            fieldId = windFieldPO.getFieldId();
-        }
-
-        String beginTime = null;
-        String endTime = null;
-        if (!StringUtils.isEmpty(datatime)) {
-            beginTime = appendTimeToString(datatime, 00, 00, 00);
-            endTime = appendTimeToString(datatime, 23, 59, 59);
-        } else {
-            beginTime = getYesterdayStartStr();
-            endTime = getYesterdayEnd().format(DATETIME_FORMATTER);
-        }
-
-        HealthOverviewVO healthOverviewVO = new HealthOverviewVO();
-        HealthscoresWindVO healthscoresWind = healthscoresMapper.selectWindHealthscoresScore(fieldId, beginTime, endTime);
-
-        if (healthscoresWind != null) {
-            healthOverviewVO.setHealthscoresWindVO(healthscoresWind);
-        }
-        String year = String.valueOf(LocalDate.now().getYear());
-        List<HealthOverviewListVO> overviewListVOS = healthscoresMapper.selectHealthOverviewList(year, fieldId, beginTime, endTime);
-        healthOverviewVO.setHealthOverviewListVOList(overviewListVOS);
-
-        return healthOverviewVO;
-    }
-
-    @Override
-    public List<HealthscoresTendencyVO> getLastDaysTrend(int day, String fieldId, String engineId) {
-        // 1. 校验入参（非空）
-        if (Objects.isNull(fieldId) || fieldId.isEmpty() || Objects.isNull(engineId) || engineId.isEmpty()) {
-            throw new IllegalArgumentException("风场ID和风机ID不能为空");
-        }
-
-        // 1. 计算起止日期
-        LocalDate[] range = getLastNDaysRange(day);
-        LocalDate startDate = range[0];
-        LocalDate endDate = range[1];
-
-        // 3. 生成连续的365天日期序列（基础维度，确保每个日期都有记录）
-        List<LocalDate> allDates = generateContinuousDates(startDate, endDate);
-
-        // 4. 确定要查询的表名（按年份拆分，如healthscores_2025、healthscores_2026）
-        List<String> tableNames = getValidTableNames(startDate, endDate);
-
-        // 3. 跨表查询数据
-        List<HealthscoresTendencyVO> hscoresLastays = healthscoresMapper.listHscoresLastays(fieldId, engineId, startDate, endDate, tableNames);
-
-        // 6. 封装已有数据到Map（key=日期，value=评分数据，方便快速匹配）
-        Map<LocalDate, HealthscoresTendencyVO> existDataMap = hscoresLastays.stream()
-                .collect(Collectors.toMap(
-                        HealthscoresTendencyVO::getSourceDatetime,
-                        data -> data,
-                        (oldVal, newVal) -> oldVal
-                ));
-
-        // 7. 补0处理：遍历所有日期，缺失则新建（所有评分字段默认0）
-        List<HealthscoresTendencyVO> finalResult = new ArrayList<>();
-        for (LocalDate date : allDates) {
-            HealthscoresTendencyVO score = existDataMap.getOrDefault(date, new HealthscoresTendencyVO(date));
-            // 补全风场/风机ID（前端展示用）
-            score.setFieldId(fieldId);
-            score.setEngineId(engineId);
-            finalResult.add(score);
-        }
-
-        return finalResult;
-    }
-
-
-    /**
-     * ====================== 当前接口使用日期工具 ======================
-     */
-
-    /**
-     * 给String类型的年月日拼接时分秒
-     *
-     * @param dateStr 年月日字符串（如 "2026-03-02"）
-     * @param hour    小时
-     * @param minute  分钟
-     * @param second  秒
-     * @return 带时分秒的字符串（如 "2026-03-02 15:30:00"）
-     */
-    private String appendTimeToString(String dateStr, int hour, int minute, int second) {
-        // 1. 解析为LocalDate（校验日期合法性）
-        LocalDate localDate = LocalDate.parse(dateStr, DATE_FORMATTER);
-        // 2. 拼接时分秒为LocalDateTime
-        LocalDateTime localDateTime = localDate.atTime(hour, minute, second);
-        // 3. 格式化为字符串
-        return localDateTime.format(DATETIME_FORMATTER);
-    }
-
-    /**
-     * 重载：获取昨天开始/结束时间的字符串格式
-     */
-    private String getYesterdayStartStr() {
-        return getYesterdayStart().format(DATETIME_FORMATTER);
-    }
-
-    private String getYesterdayEndStr() {
-        // 严格格式化为 23:59:59（去掉纳秒）
-        return getYesterdayEnd().format(DATETIME_FORMATTER).substring(0, 19);
-    }
-
-    /**
-     * 获取昨天的开始时间（yyyy-MM-dd 00:00:00）
-     *
-     * @return LocalDateTime
-     */
-    private LocalDateTime getYesterdayStart() {
-        // 1. 获取昨天的日期
-        LocalDate yesterday = LocalDate.now().minusDays(1);
-        // 2. 拼接 00:00:00 等价于 yesterday.atTime(0, 0, 0)
-        return yesterday.atStartOfDay();
-    }
-
-    /**
-     * 获取昨天的结束时间（yyyy-MM-dd 23:59:59）
-     *
-     * @return LocalDateTime
-     */
-    private LocalDateTime getYesterdayEnd() {
-        LocalDate yesterday = LocalDate.now().minusDays(1);
-        // 拼接 23:59:59
-        return yesterday.atTime(23, 59, 59);
-        // 若需严格的23:59:59，用：yesterday.atTime(23, 59, 59)
-    }
-
-    /**
-     * 获取近 N 天的开始、结束日期
-     * 参数days 为需要查几天的数据
-     */
-    private LocalDate[] getLastNDaysRange(int days) {
-        LocalDate endDate = LocalDate.now().minusDays(1);
-        LocalDate startDate = endDate.minusDays(days-1);
-        return new LocalDate[]{startDate, endDate};
-    }
-
-    /**
-     * 获取日期范围内涉及的所有年份（最多2个）
-     */
-    private Set<Integer> getYearSet(LocalDate start, LocalDate end) {
-        return Stream.of(start.getYear(), end.getYear())
-                .collect(Collectors.toSet());
-    }
-
-    /**
-     * 生成连续的日期序列（Java8 Stream实现）
-     */
-    private List<LocalDate> generateContinuousDates(LocalDate start, LocalDate end) {
-        long days = java.time.temporal.ChronoUnit.DAYS.between(start, end);
-        return Stream.iterate(start, date -> date.plusDays(1))
-                .limit(days + 1) // +1 包含结束日期
-                .collect(Collectors.toList());
-    }
-
-
-    /**
-     * 获取合法的表名列表（防SQL注入，仅允许healthscores_+4位数字）
-     */
-    private List<String> getValidTableNames(LocalDate start, LocalDate end) {
-        Set<String> tableNames = new HashSet<>();
-        String tablePrefix = "healthscores_";
-
-        // 遍历日期范围的所有年份
-        int startYear = start.getYear();
-        int endYear = end.getYear();
-        for (int year = startYear; year <= endYear; year++) {
-            tableNames.add(tablePrefix + year);
-        }
-
-        // 严格校验表名格式（防SQL注入）
-        tableNames.forEach(name -> {
-            if (!name.matches("^healthscores_\\d{4}$")) {
-                throw new IllegalArgumentException("非法表名：" + name + "（仅允许healthscores_四位数字格式）");
-            }
-        });
-
-        return new ArrayList<>(tableNames);
-    }
-
-}

energy-manage-service/src/main/resources/application.properties

@@ -37,6 +37,3 @@ logging.level.com.energy.manage.service.mappers= debug
 #banner路径
 spring.banner.location=classpath:banner/banner.txt
 
-#=============================skf数据服务器地址配置=============================
-skf.data.path = /Users/shiyue/Downloads/skf_data
-skf.data.condition = 乾安风电场

energy-manage-service/src/main/resources/bootstrap.properties

@@ -13,7 +13,7 @@ spring.cloud.nacos.config.extension-configs[0].refresh=true
 mybatis.mapper-locations = classpath*:mybatis/**/*.xml
 mybatis.type-aliases-package = com.energy.manage.common.po
 mybatis.configuration.mapUnderscoreToCamelCase = true
-#sql打印
+#sql打印F
 mybatis.configuration.log-impl = org.apache.ibatis.logging.stdout.StdOutImpl
 #mappers 多个接口时逗号隔开
 mapper.mappers = com.energy.manage.common.mapper.MyMapper

energy-manage-service/src/main/resources/mybatis/healthscores/HealthscoresMapper.xml

@@ -1,183 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.energy.manage.service.mappers.healthscores.HealthscoresMapper">
-
-    <!-- 查询风场健康聚合台数 -->
-    <select id="selectHealthOverviewCount" resultType="com.energy.manage.service.domain.vo.healthscores.HealthOverviewVO">
-        select
-        field_code as fieldCode,
-        overall_level as overallLevel,
-        count(overall_level) as overallTotal
-        from
-        healthscores_#{YEAR}
-        where
-        <if test="fieldCode!=null">
-            and weg.field_code = #{fieldCode}
-        </if>
-        group by overall_level
-    </select>
-
-    <!-- 风场健康综合统计查询 -->
-    <select id="selectWindScoreList" resultType="com.energy.manage.service.domain.vo.healthscores.HealthscoresWindVO">
-        SELECT
-        id as id,
-        field_id as fieldId,
-        excellent_count as excellentCount,
-        good_count as goodCount,
-        fair_count as fairCount,
-        poor_count as poorCount,
-        overall_score as overallScore,
-        structure_score as structureScore,
-        system_score as systemScore,
-        component_score as componentScore,
-        source_datetime as sourceDatetime,
-        create_time as createTime
-        FROM healthscores_wind
-        WHERE 1=1
-        <if test="fieldId!=null">
-            and field_id = #{fieldId}
-        </if>
-        <if test="beginTime != null and beginTime != ''">
-            and create_time  <![CDATA[>= ]]> #{beginTime}
-        </if>
-        <if test="endTime != null and endTime != ''">
-            and create_time <![CDATA[<= ]]> #{endTime}
-        </if>
-        ORDER BY create_time DESC
-    </select>
-
-    <!-- 风场健康综合统计查询 -->
-    <select id="selectWindHealthscoresScore" resultType="com.energy.manage.service.domain.vo.healthscores.HealthscoresWindVO">
-        SELECT
-        id as id,
-        field_id as fieldId,
-        excellent_count as excellentCount,
-        good_count as goodCount,
-        fair_count as fairCount,
-        poor_count as poorCount,
-        overall_score as overallScore,
-        structure_score as structureScore,
-        system_score as systemScore,
-        component_score as componentScore,
-        source_datetime as sourceDatetime,
-        create_time as createTime
-        FROM healthscores_wind
-        WHERE 1=1
-        <if test="fieldId!=null">
-            and field_id = #{fieldId}
-        </if>
-        <if test="beginTime != null and beginTime != ''">
-            and create_time  <![CDATA[>= ]]>  #{beginTime}
-        </if>
-        <if test="endTime != null and endTime != ''">
-            and create_time <![CDATA[<= ]]> #{endTime}
-        </if>
-        ORDER BY create_time DESC
-    </select>
-
-    <!-- 查询每个风场风机健康状态 -->
-    <select id="selectHealthOverviewList" resultType="com.energy.manage.service.domain.vo.healthscores.HealthOverviewListVO">
-        select
-        hs.id as id,
-        weg.engine_id as engineId,
-        weg.engine_name as engineName,
-        hs.overall_score as overallScore,
-        hs.overall_level as overallLevel,
-        hs.source_datetime as sourceDateTime,
-        hs.create_time as createTime
-        from
-        wind_engine_group weg
-        left join
-        healthscores_${year} hs
-        on  weg.engine_id = hs.engine_id
-        where 1=1
-        <if test="fieldId!=null">
-            and hs.field_id = #{fieldId}
-        </if>
-        <if test="beginTime != null and beginTime != ''">
-            and hs.create_time  <![CDATA[>= ]]>  #{beginTime}
-        </if>
-        <if test="endTime != null and endTime != ''">
-            and hs.create_time <![CDATA[<= ]]> #{endTime}
-        </if>
-        order by hs.overall_score desc
-    </select>
-
-    <!-- 当年风机趋势图按周查询 -->
-    <select id="selectHealthscoresTendencyDay" resultType="com.energy.manage.service.domain.vo.healthscores.HealthscoresTendencyVO">
-    SELECT
-    ds.stat_date as xLabel,
-    rotor_score as rotorScore,
-    tower_score as towerScore,
-
-    generator_score as generatorScore,
-    gearbox_score as gearboxScore,
-    main_shaft_score as mainShaftScore,
-    converter_score as converterScore,
-
-    yaw_system_score as yawSystemScore,
-    pitch_system_score as pitchSystemScore,
-    hydraulic_system_score as hydraulicSystemScore,
-    control_system_score as controlSystemScore
-    FROM (
-        SELECT DATE_SUB(CURDATE(), INTERVAL 7 DAY) AS stat_date UNION ALL
-        SELECT DATE_SUB(CURDATE(), INTERVAL 6 DAY) UNION ALL
-        SELECT DATE_SUB(CURDATE(), INTERVAL 5 DAY) UNION ALL
-        SELECT DATE_SUB(CURDATE(), INTERVAL 4 DAY) UNION ALL
-        SELECT DATE_SUB(CURDATE(), INTERVAL 3 DAY) UNION ALL
-        SELECT DATE_SUB(CURDATE(), INTERVAL 2 DAY) UNION ALL
-        SELECT DATE_SUB(CURDATE(), INTERVAL 1 DAY)
-    ) ds
-    LEFT JOIN healthscores_#{year} h
-        ON h.source_datetime = ds.stat_date
-        AND h.engine_id = #{engineId}
-    GROUP BY ds.stat_date,rotor_score,tower_score,generator_score,gearbox_score,main_shaft_score,converter_score,yaw_system_score,pitch_system_score,hydraulic_system_score,control_system_score
-    ORDER BY ds.stat_date ASC
-    </select>
-
-
-    <resultMap id="BaseResultMap" type="com.energy.manage.service.domain.vo.healthscores.HealthscoresTendencyVO">
-        <result column="source_datetime" property="sourceDatetime" jdbcType="DATE"/>
-        <result column="rotor_score" property="rotorScore" jdbcType="DECIMAL"/>
-        <result column="tower_score" property="towerScore" jdbcType="DECIMAL"/>
-        <result column="generator_score" property="generatorScore" jdbcType="DECIMAL"/>
-        <result column="gearbox_score" property="gearboxScore" jdbcType="DECIMAL"/>
-        <result column="main_shaft_score" property="mainShaftScore" jdbcType="DECIMAL"/>
-        <result column="converter_score" property="converterScore" jdbcType="DECIMAL"/>
-        <result column="yaw_system_score" property="yawSystemScore" jdbcType="DECIMAL"/>
-        <result column="pitch_system_score" property="pitchSystemScore" jdbcType="DECIMAL"/>
-        <result column="hydraulic_system_score" property="hydraulicSystemScore" jdbcType="DECIMAL"/>
-        <result column="control_system_score" property="controlSystemScore" jdbcType="DECIMAL"/>
-        <result column="overall_score" property="overallScore" jdbcType="DECIMAL"/>
-    </resultMap>
-    <!-- 无定时天跨年分表查询 -->
-    <select id="listHscoresLastays" resultMap="BaseResultMap">
-        <foreach collection="tableNames" item="tableName" separator=" UNION ALL ">
-            SELECT
-            source_datetime,
-            rotor_score,
-            tower_score ,
-
-            generator_score,
-            gearbox_score,
-            main_shaft_score,
-            converter_score,
-
-            yaw_system_score,
-            pitch_system_score,
-            hydraulic_system_score,
-            control_system_score,
-            overall_score
-            FROM ${tableName}
-            WHERE  1=1
-            <if test="fieldId!=null">
-                and field_id = #{fieldId}
-            </if>
-            <if test="engineId!=null">
-                and engine_id = #{engineId}
-            </if>
-            and create_time BETWEEN #{startDate} AND #{endDate}
-        </foreach>
-    </select>
-
-</mapper>