Browse Source

Merge pull request 'fix:修改数据库某些字段,对应修改实体类' (#45) from dev-xjf into master

Reviewed-on: http://120.26.116.243:3000/root/alert-backend/pulls/45
pull/46/head
xiaojinfei 1 month ago
parent
commit
6eb07ec855
  1. 6
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/instant/vo/pointInfo.java
  2. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/model/vo/ModelRespVO.java
  3. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/model/vo/ModelVersionRespVO.java
  4. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/warn/vo/WarnRespVO.java
  5. 3
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/warn/vo/WarnSaveReqVO.java
  6. 3
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/model/ModelDO.java
  7. 4
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/model/ModelVersionDO.java
  8. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/report/Report.java
  9. 4
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/warn/WarnDO.java
  10. 5
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/warn/WarnTableDO.java
  11. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/model/ModelMapper.java
  12. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/model/VersionMapper.java
  13. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/warn/WarnMapper.java
  14. 18
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/instant/InstantServiceImpl.java
  15. 6
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/warn/WarnServiceImpl.java

6
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/instant/vo/pointInfo.java

@ -6,15 +6,15 @@ import lombok.Data;
@Data @Data
public class pointInfo { public class pointInfo {
@JsonProperty(value="pointId") @JsonProperty(value="PointId")
@Schema(description = "点号", example = "id") @Schema(description = "点号", example = "id")
private String pointId; private String pointId;
@JsonProperty(value="description") @JsonProperty(value="Description")
@Schema(description = "描述", example = "yudao") @Schema(description = "描述", example = "yudao")
private String description; private String description;
@JsonProperty(value="unit") @JsonProperty(value="Unit")
@Schema(description = "单位", example = "yudao") @Schema(description = "单位", example = "yudao")
private String unit; private String unit;

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/model/vo/ModelRespVO.java

@ -14,7 +14,7 @@ import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_
@ExcelIgnoreUnannotated @ExcelIgnoreUnannotated
public class ModelRespVO { public class ModelRespVO {
@Schema(description = "模型id", example = "id") @Schema(description = "模型id", example = "id")
private String id; private String modelId;
@Schema(description = "模型名称", example = "yudao") @Schema(description = "模型名称", example = "yudao")

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/model/vo/ModelVersionRespVO.java

@ -11,7 +11,7 @@ import java.time.LocalDateTime;
@ExcelIgnoreUnannotated @ExcelIgnoreUnannotated
public class ModelVersionRespVO { public class ModelVersionRespVO {
@Schema(description = "版本id", example = "id") @Schema(description = "版本id", example = "id")
private Long id; private Long versionId;
@Schema(description = "所属模型id", example = "id") @Schema(description = "所属模型id", example = "id")

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/warn/vo/WarnRespVO.java

@ -14,7 +14,7 @@ import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_
@ExcelIgnoreUnannotated @ExcelIgnoreUnannotated
public class WarnRespVO { public class WarnRespVO {
@Schema(description = "预警id", example = "id") @Schema(description = "预警id", example = "id")
private Long id; private Long warnId;
@Schema(description = "实例id", example = "id") @Schema(description = "实例id", example = "id")

3
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/warn/vo/WarnSaveReqVO.java

@ -15,7 +15,7 @@ import java.util.List;
public class WarnSaveReqVO { public class WarnSaveReqVO {
@Schema(description = "预警编号", example = "1") @Schema(description = "预警编号", example = "1")
@NotNull(message = "预警编号不能为空") @NotNull(message = "预警编号不能为空")
private Long id; private Long warnId;
@Schema(description = "实例编号", example = "1") @Schema(description = "实例编号", example = "1")
// @NotNull(message = "实例编号不能为空") // @NotNull(message = "实例编号不能为空")
@ -60,7 +60,6 @@ public class WarnSaveReqVO {
private Long gzpOnOff=1L; private Long gzpOnOff=1L;
private Long warnKey=1L; private Long warnKey=1L;
private Long warnId=1L;
//推送诊断 //推送诊断
private Long copyToDiagOnOff; private Long copyToDiagOnOff;

3
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/model/ModelDO.java

@ -13,7 +13,8 @@ import java.time.LocalDateTime;
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class ModelDO extends BaseDO { public class ModelDO extends BaseDO {
private String id;
private String modelId;
/** /**
* 专业名称 * 专业名称

4
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/model/ModelVersionDO.java

@ -3,6 +3,7 @@ package cn.iocoder.yudao.module.alert.dal.dataobject.model;
import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateTime;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence; import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;
@ -15,7 +16,8 @@ import java.time.LocalDateTime;
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class ModelVersionDO extends BaseDO { public class ModelVersionDO extends BaseDO {
private String id; @TableId(value="version_id")
private String versionId;
private String modelId; private String modelId;

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/report/Report.java

@ -9,7 +9,7 @@ public class Report {
//相较于windows版本字段有变化 //相较于windows版本字段有变化
public List<point> assessRows; public List<point> assess;
@Data @Data
public static class point public static class point

4
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/warn/WarnDO.java

@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.alert.dal.dataobject.warn;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence; import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
@ -14,7 +15,8 @@ import java.time.LocalDateTime;
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class WarnDO extends BaseDO { public class WarnDO extends BaseDO {
private Long id; @TableId(value="warn_id")
private Long warnId;
private Long mpId; private Long mpId;

5
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/warn/WarnTableDO.java

@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.alert.dal.dataobject.warn;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence; import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
@ -14,7 +15,8 @@ import java.time.LocalDateTime;
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class WarnTableDO extends BaseDO { public class WarnTableDO extends BaseDO {
private Long id; @TableId(value="warn_id")
private Long warnId;
private Long mpId; private Long mpId;
@ -54,7 +56,6 @@ public class WarnTableDO extends BaseDO {
private Long warnKey; private Long warnKey;
private Long warnId;
private Double uplimit; private Double uplimit;

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/model/ModelMapper.java

@ -15,7 +15,7 @@ public interface ModelMapper extends BaseMapperX<ModelDO> {
.likeIfPresent(ModelDO::getModelName, reqVO.getModelName()) .likeIfPresent(ModelDO::getModelName, reqVO.getModelName())
.eqIfPresent(ModelDO::getStatus, reqVO.getStatus()) .eqIfPresent(ModelDO::getStatus, reqVO.getStatus())
.orderByAsc(ModelDO::getId)); .orderByAsc(ModelDO::getModelId));
} }

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/model/VersionMapper.java

@ -20,7 +20,7 @@ public interface VersionMapper extends BaseMapperX<ModelVersionDO> {
.eqIfPresent(ModelVersionDO::getModelId, reqVO.getModelId()) .eqIfPresent(ModelVersionDO::getModelId, reqVO.getModelId())
.likeIfPresent(ModelVersionDO::getModelName, reqVO.getModelName()) .likeIfPresent(ModelVersionDO::getModelName, reqVO.getModelName())
.orderByAsc(ModelVersionDO::getUpdateTime) .orderByAsc(ModelVersionDO::getUpdateTime)
.orderByAsc(ModelVersionDO::getId)); .orderByAsc(ModelVersionDO::getVersionId));
} }
default ModelVersionDO selectByModelId(ModelVersionPageReqVO reqVO) { default ModelVersionDO selectByModelId(ModelVersionPageReqVO reqVO) {

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/warn/WarnMapper.java

@ -14,7 +14,7 @@ public interface WarnMapper extends BaseMapperX<WarnDO> {
default PageResult<WarnDO> selectPage(WarnPageReqVO reqVO) { default PageResult<WarnDO> selectPage(WarnPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<WarnDO>() return selectPage(reqVO, new LambdaQueryWrapperX<WarnDO>()
.likeIfPresent(WarnDO::getMpId, reqVO.getMpId().toString()) .likeIfPresent(WarnDO::getMpId, reqVO.getMpId().toString())
.orderByAsc(WarnDO::getId)); .orderByAsc(WarnDO::getWarnId));
} }
} }

18
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/instant/InstantServiceImpl.java

@ -251,7 +251,7 @@ try{
Report reportObj = JsonUtils.parseObject(report.getReport(), Report.class); Report reportObj = JsonUtils.parseObject(report.getReport(), Report.class);
// 此处可根据业务需求处理解析后的Report对象(如后续预警逻辑) // 此处可根据业务需求处理解析后的Report对象(如后续预警逻辑)
// 循环getInputInfo构建并插入预警记录 // 循环getInputInfo构建并插入预警记录
for (int j = 0; j < reportObj.getAssessRows().size(); j++) { for (int j = 0; j < reportObj.getAssess().size(); j++) {
WarnSaveReqVO warnSaveReqVO = new WarnSaveReqVO(); WarnSaveReqVO warnSaveReqVO = new WarnSaveReqVO();
@ -259,14 +259,14 @@ try{
// warn.setId(insertId); // warn.setId(insertId);
//设置实例id //设置实例id
warnSaveReqVO.setMpId(instant.getMpId()); warnSaveReqVO.setMpId(instant.getMpId());
warnSaveReqVO.setPointId(createReqVO.getInputInfo().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setPointId(createReqVO.getInputInfo().get(reportObj.getAssess().get(j).getIndex()));
warnSaveReqVO.setPointName(createReqVO.getInputName().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setPointName(createReqVO.getInputName().get(reportObj.getAssess().get(j).getIndex()));
warnSaveReqVO.setGzpName(createReqVO.getInputName().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setGzpName(createReqVO.getInputName().get(reportObj.getAssess().get(j).getIndex()));
warnSaveReqVO.setEquation("[" + createReqVO.getBiasPointInfo().get(reportObj.getAssessRows().get(j).getIndex()) + "]>UPLIMIT or [" + createReqVO.getBiasPointInfo().get(reportObj.getAssessRows().get(j).getIndex()) + "]<LOWLIMIT"); warnSaveReqVO.setEquation("[" + createReqVO.getBiasPointInfo().get(reportObj.getAssess().get(j).getIndex()) + "]>UPLIMIT or [" + createReqVO.getBiasPointInfo().get(reportObj.getAssess().get(j).getIndex()) + "]<LOWLIMIT");
warnSaveReqVO.setUplimit(reportObj.getAssessRows().get(j).getAmplitude()); warnSaveReqVO.setUplimit(reportObj.getAssess().get(j).getAmplitude());
warnSaveReqVO.setLowlimit(-reportObj.getAssessRows().get(j).getAmplitude()); warnSaveReqVO.setLowlimit(-reportObj.getAssess().get(j).getAmplitude());
warnSaveReqVO.setOutputPoint(createReqVO.getOutPointInfo().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setOutputPoint(createReqVO.getOutPointInfo().get(reportObj.getAssess().get(j).getIndex()));
warnSaveReqVO.setUnit(createReqVO.getUnit().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setUnit(createReqVO.getUnit().get(reportObj.getAssess().get(j).getIndex()));
// 设置其他必要字段(根据实际业务补充) // 设置其他必要字段(根据实际业务补充)
warnSaveReqVO.setWarnStatus(1L); // 示例:设置初始状态 warnSaveReqVO.setWarnStatus(1L); // 示例:设置初始状态

6
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/warn/WarnServiceImpl.java

@ -68,7 +68,7 @@ public class WarnServiceImpl implements WarnService {
// 3. 记录操作日志上下文 // 3. 记录操作日志上下文
LogRecordContext.putVariable("warn", warn); LogRecordContext.putVariable("warn", warn);
return warn.getId(); return warn.getWarnId();
} }
@ -79,13 +79,13 @@ public class WarnServiceImpl implements WarnService {
return warnMapper.selectById(id); return warnMapper.selectById(id);
} }
@Override @Override
@CacheEvict(value = RedisKeyConstants.WARN, key = "#updateReqVO.id") @CacheEvict(value = RedisKeyConstants.WARN, key = "#updateReqVO.warnId")
@LogRecord(type = SYSTEM_WARN_TYPE, subType = SYSTEM_WARN_UPDATE_SUB_TYPE, bizNo = "{{#updateReqVO.id}}", @LogRecord(type = SYSTEM_WARN_TYPE, subType = SYSTEM_WARN_UPDATE_SUB_TYPE, bizNo = "{{#updateReqVO.id}}",
success = SYSTEM_WARN_UPDATE_SUCCESS) success = SYSTEM_WARN_UPDATE_SUCCESS)
public void updateWarn(WarnSaveReqVO updateReqVO) { public void updateWarn(WarnSaveReqVO updateReqVO) {
//为简单--省去检验步骤,之后根据情况增加 //为简单--省去检验步骤,之后根据情况增加
// 1.1 校验是否可以更新 // 1.1 校验是否可以更新
WarnDO warn = validateWarnForUpdate(updateReqVO.getId()); WarnDO warn = validateWarnForUpdate(updateReqVO.getWarnId());
// 1.2 校验角色的唯一字段是否重复 // 1.2 校验角色的唯一字段是否重复
// validateRoleDuplicate(updateReqVO.getName(), updateReqVO.getCode(), updateReqVO.getId()); // validateRoleDuplicate(updateReqVO.getName(), updateReqVO.getCode(), updateReqVO.getId());

Loading…
Cancel
Save