diff --git a/src/main/java/com/xydl/cac/entity/Warning.java b/src/main/java/com/xydl/cac/entity/Warning.java index 527f49b..9c86477 100644 --- a/src/main/java/com/xydl/cac/entity/Warning.java +++ b/src/main/java/com/xydl/cac/entity/Warning.java @@ -27,20 +27,28 @@ public class Warning { private Integer id; @ApiModelProperty("装置ID") - @Column(name = "eqmid") - private Integer eqmid; + @Column(name = "sensor_id") + private Integer sensorId; + + @ApiModelProperty("规则ID") + @Column(name = "rule_id") + private Integer ruleId; + + @ApiModelProperty("数据采集时间") + @Column(name = "d_time") + private Date dTime; @ApiModelProperty("告警时间") @Column(name = "warn_time") private Date warnTime; @ApiModelProperty("告警值") - @Column(name = "warning_value") - private String warningValue; + @Column(name = "warn_value") + private String warnValue; @ApiModelProperty("阈值") - @Column(name = "threadval") - private String threadval; + @Column(name = "threshold") + private String threshold; @ApiModelProperty("告警信息") @Column(name = "warn_desc") diff --git a/src/main/java/com/xydl/cac/task/RuleCheckTask.java b/src/main/java/com/xydl/cac/task/RuleCheckTask.java index e0b861d..e56a7c4 100644 --- a/src/main/java/com/xydl/cac/task/RuleCheckTask.java +++ b/src/main/java/com/xydl/cac/task/RuleCheckTask.java @@ -69,13 +69,16 @@ public class RuleCheckTask { NSensor sensor = rule.getNSensor(); ModevTypePoint typePoint = rule.getTypePoint(); Warning warning = Warning.builder() - .eqmid(sensor.getDevId()) - .threadval(rule.getThreshold()) - .warningValue((String) value) + .sensorId(sensor.getId()) + .ruleId(rule.getId()) + .dTime(date) + .threshold(rule.getThreshold()) + .warnValue((String) value) .warnLevel(rule.getLevel()) .state("1") .warnDesc(sensor.getName() + " " + typePoint.getFieldDesc() + " 告警") - .processTime(date) + .warnTime(new Date()) + .processTime(new Date()) .build(); warningRepository.save(warning); }