Browse Source

fix:因数据库instant_cfg更改字段,group_view更改表名,修改相关实体

pull/38/head
xjf 1 month ago
parent
commit
0c853d2575
  1. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/calcgroup/CalcGroupController.java
  2. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/calcgroup/vo/CalcGroupRespVO.java
  3. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/instant/vo/InstantPointRespVO.java
  4. 4
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/instant/vo/InstantRespVO.java
  5. 4
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/instant/vo/InstantSaveReqVO.java
  6. 5
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/calcgroup/CalcGroupDO.java
  7. 6
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/instant/InstantDO.java
  8. 6
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/instant/InstantTableDO.java
  9. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/calcgroup/CalcGroupMapper.java
  10. 2
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/instant/InstantMapper.java
  11. 18
      yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/instant/InstantServiceImpl.java

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/calcgroup/CalcGroupController.java

@ -34,7 +34,7 @@ public class CalcGroupController {
public CommonResult<List<CalcGroupRespVO>> getCalcGroupList(CalcGroupPageReqVO ReqVO) { public CommonResult<List<CalcGroupRespVO>> getCalcGroupList(CalcGroupPageReqVO ReqVO) {
ReqVO.setPageSize(PageParam.PAGE_SIZE_NONE); ReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
List<CalcGroupDO> list = calcGroupService.getCalcGroupPage(ReqVO).getList(); List<CalcGroupDO> list = calcGroupService.getCalcGroupPage(ReqVO).getList();
list.sort(Comparator.comparing(CalcGroupDO::getId)); list.sort(Comparator.comparing(CalcGroupDO::getGroupId));
return success(BeanUtils.toBean(list, CalcGroupRespVO.class)); return success(BeanUtils.toBean(list, CalcGroupRespVO.class));
} }
} }

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

@ -9,7 +9,7 @@ import lombok.Data;
@ExcelIgnoreUnannotated @ExcelIgnoreUnannotated
public class CalcGroupRespVO { public class CalcGroupRespVO {
@Schema(description = "版本id", example = "id") @Schema(description = "版本id", example = "id")
private Long id; private Long groupId;
@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/instant/vo/InstantPointRespVO.java

@ -8,7 +8,7 @@ import lombok.Data;
@Schema(description = "运行中心 - 模型实例所用测点 Req VO") @Schema(description = "运行中心 - 模型实例所用测点 Req VO")
@Data @Data
public class InstantPointRespVO { public class InstantPointRespVO {
@Schema(description = "实例编号,后端手动生成--直接用", example = "1") @Schema(description = "点号编号,后端手动生成--直接用", example = "1")
private Long id; private Long id;

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

@ -14,7 +14,7 @@ import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_
@ExcelIgnoreUnannotated @ExcelIgnoreUnannotated
public class InstantRespVO { public class InstantRespVO {
@Schema(description = "实例id", example = "id") @Schema(description = "实例id", example = "id")
private Long id; private Long mpId;
@Schema(description = "模型id", example = "yudao") @Schema(description = "模型id", example = "yudao")
private Long modelId; private Long modelId;
@ -35,7 +35,7 @@ public class InstantRespVO {
private Integer visible; private Integer visible;
@Schema(description = "状态", example = "1") @Schema(description = "状态", example = "1")
private Integer status; private Integer instantStatus;
@Schema(description = "创建时间", example = "2022-07-01 00:00:00") @Schema(description = "创建时间", example = "2022-07-01 00:00:00")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)

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

@ -19,7 +19,7 @@ public class InstantSaveReqVO extends InstantInfoVO {
@Schema(description = "实例编号", example = "1") @Schema(description = "实例编号", example = "1")
@NotNull(message = "实例编号不能为空") @NotNull(message = "实例编号不能为空")
private Long id; private Long mpId;
@Schema(description = "模型编号", requiredMode = Schema.RequiredMode.REQUIRED,example = "1") @Schema(description = "模型编号", requiredMode = Schema.RequiredMode.REQUIRED,example = "1")
@ -51,7 +51,7 @@ public class InstantSaveReqVO extends InstantInfoVO {
@Schema(description = "状态可见", requiredMode = Schema.RequiredMode.REQUIRED,example = "1") @Schema(description = "状态可见", requiredMode = Schema.RequiredMode.REQUIRED,example = "1")
@DiffLogField(name = "状态") @DiffLogField(name = "状态")
private Long status; private Long instantStatus;
@Schema(description = "是否存历史-是(存),否(不存)", requiredMode = Schema.RequiredMode.REQUIRED, example = "1") @Schema(description = "是否存历史-是(存),否(不存)", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")

5
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/calcgroup/CalcGroupDO.java

@ -6,12 +6,13 @@ import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
@TableName(value = "group_view", autoResultMap = true) @TableName(value = "Calc_group_view", autoResultMap = true)
@KeySequence("system_role_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。 @KeySequence("system_role_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class CalcGroupDO extends BaseDO { public class CalcGroupDO extends BaseDO {
private String id;
private String groupId;
/** /**
* 计算组名称 * 计算组名称

6
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/instant/InstantDO.java

@ -3,6 +3,7 @@ package cn.iocoder.yudao.module.alert.dal.dataobject.instant;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import cn.iocoder.yudao.module.alert.controller.admin.instant.vo.InstantInfoVO; import cn.iocoder.yudao.module.alert.controller.admin.instant.vo.InstantInfoVO;
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;
@ -16,7 +17,8 @@ import java.util.List;
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class InstantDO extends BaseDO { public class InstantDO extends BaseDO {
private Long id; @TableId(value="mp_id")
private Long mpId;
private Long modelId; private Long modelId;
@ -34,7 +36,7 @@ public class InstantDO extends BaseDO {
private Long visible; private Long visible;
private Long status; private Long instantStatus;
private LocalDateTime setupTime; private LocalDateTime setupTime;

6
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/dataobject/instant/InstantTableDO.java

@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.alert.dal.dataobject.instant;
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;
@ -13,7 +14,8 @@ import java.time.LocalDateTime;
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class InstantTableDO extends BaseDO { public class InstantTableDO extends BaseDO {
private Long id; @TableId(value="mp_id")
private Long mpId;
private Long modelId; private Long modelId;
@ -31,7 +33,7 @@ public class InstantTableDO extends BaseDO {
private Long visible; private Long visible;
private Long status; private Long instantStatus;
private LocalDateTime setupTime; private LocalDateTime setupTime;

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/calcgroup/CalcGroupMapper.java

@ -16,7 +16,7 @@ public interface CalcGroupMapper extends BaseMapperX<CalcGroupDO> {
return selectPage(reqVO, new LambdaQueryWrapperX<CalcGroupDO>() return selectPage(reqVO, new LambdaQueryWrapperX<CalcGroupDO>()
.eqIfPresent(CalcGroupDO::getUnitId, reqVO.getUnitId()) .eqIfPresent(CalcGroupDO::getUnitId, reqVO.getUnitId())
.orderByAsc(CalcGroupDO::getId)); .orderByAsc(CalcGroupDO::getGroupId));
} }
} }

2
yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/dal/mysql/instant/InstantMapper.java

@ -20,7 +20,7 @@ public interface InstantMapper extends BaseMapperX<InstantDO> {
.eqIfPresent(InstantDO::getUnitId,reqVO.getUnit()) .eqIfPresent(InstantDO::getUnitId,reqVO.getUnit())
.eqIfPresent(InstantDO::getSystemTypeId,reqVO.getType()) .eqIfPresent(InstantDO::getSystemTypeId,reqVO.getType())
.eqIfPresent(InstantDO::getSystemId,reqVO.getSystem()) .eqIfPresent(InstantDO::getSystemId,reqVO.getSystem())
.orderByAsc(InstantDO::getId)); .orderByAsc(InstantDO::getMpId));
} }
default Long selectCountByRunningLog(String runningLog){ default Long selectCountByRunningLog(String runningLog){

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

@ -85,7 +85,7 @@ public class InstantServiceImpl implements InstantService {
//插入除instantInfo外的所有数据,获取到id //插入除instantInfo外的所有数据,获取到id
// 2. 插入到数据库-status、visible默认值 // 2. 插入到数据库-status、visible默认值
InstantTableDO instant = BeanUtils.toBean(createReqVO, InstantTableDO.class) InstantTableDO instant = BeanUtils.toBean(createReqVO, InstantTableDO.class)
.setStatus(ObjUtil.defaultIfNull(createReqVO.getStatus(), 1L)) .setInstantStatus(ObjUtil.defaultIfNull(createReqVO.getInstantStatus(), 1L))
.setVisible(ObjUtil.defaultIfNull(createReqVO.getVisible(), 1L)); .setVisible(ObjUtil.defaultIfNull(createReqVO.getVisible(), 1L));
instantTableMapper.insert(instant); instantTableMapper.insert(instant);
@ -93,7 +93,7 @@ public class InstantServiceImpl implements InstantService {
// 3. 记录操作日志上下文 // 3. 记录操作日志上下文
LogRecordContext.putVariable("instant", instant); LogRecordContext.putVariable("instant", instant);
Long insertId = instant.getId(); Long insertId = instant.getMpId();
//处理数据 //处理数据
// inputInfo 各种转换 // inputInfo 各种转换
@ -169,8 +169,8 @@ public class InstantServiceImpl implements InstantService {
} }
createReqVO.setId(insertId); createReqVO.setMpId(insertId);
createReqVO.setStatus(instant.getStatus()); createReqVO.setInstantStatus(instant.getInstantStatus());
createReqVO.setVisible(instant.getVisible()); createReqVO.setVisible(instant.getVisible());
createReqVO.setInputInfo(inputInfoList); createReqVO.setInputInfo(inputInfoList);
createReqVO.setInputName(inputNameList); createReqVO.setInputName(inputNameList);
@ -206,13 +206,13 @@ public class InstantServiceImpl implements InstantService {
//更新instantInfo字段 //更新instantInfo字段
InstantSaveReqVO updateReqVO = new InstantSaveReqVO(); InstantSaveReqVO updateReqVO = new InstantSaveReqVO();
updateReqVO.setId(instant.getId()); updateReqVO.setMpId(instant.getMpId());
updateReqVO.setInstantInfo(JsonUtils.toJsonString(createReqVO)); updateReqVO.setInstantInfo(JsonUtils.toJsonString(createReqVO));
updateInstant(updateReqVO); updateInstant(updateReqVO);
List<String> resultList = new ArrayList<String>(); List<String> resultList = new ArrayList<String>();
resultList.add(instant.getId().toString()); resultList.add(instant.getMpId().toString());
for (Point item : InstantPointList) { for (Point item : InstantPointList) {
@ -251,7 +251,7 @@ public class InstantServiceImpl implements InstantService {
// 设置预警ID(假设insertId为当前预警主记录ID) // 设置预警ID(假设insertId为当前预警主记录ID)
// warn.setId(insertId); // warn.setId(insertId);
//设置实例id //设置实例id
warnSaveReqVO.setMpId(instant.getId()); warnSaveReqVO.setMpId(instant.getMpId());
warnSaveReqVO.setPointId(createReqVO.getInputInfo().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setPointId(createReqVO.getInputInfo().get(reportObj.getAssessRows().get(j).getIndex()));
warnSaveReqVO.setPointName(createReqVO.getInputName().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setPointName(createReqVO.getInputName().get(reportObj.getAssessRows().get(j).getIndex()));
warnSaveReqVO.setGzpName(createReqVO.getInputName().get(reportObj.getAssessRows().get(j).getIndex())); warnSaveReqVO.setGzpName(createReqVO.getInputName().get(reportObj.getAssessRows().get(j).getIndex()));
@ -361,13 +361,13 @@ public class InstantServiceImpl implements InstantService {
} }
@Override @Override
@CacheEvict(value = RedisKeyConstants.INSTANT, key = "#updateReqVO.id") @CacheEvict(value = RedisKeyConstants.INSTANT, key = "#updateReqVO.mpId")
@LogRecord(type = SYSTEM_INSTANT_TYPE, subType = SYSTEM_INSTANT_UPDATE_SUB_TYPE, bizNo = "{{#updateReqVO.id}}", @LogRecord(type = SYSTEM_INSTANT_TYPE, subType = SYSTEM_INSTANT_UPDATE_SUB_TYPE, bizNo = "{{#updateReqVO.id}}",
success = SYSTEM_INSTANT_UPDATE_SUCCESS) success = SYSTEM_INSTANT_UPDATE_SUCCESS)
public void updateInstant(InstantSaveReqVO updateReqVO) { public void updateInstant(InstantSaveReqVO updateReqVO) {
//为简单--省去检验步骤,之后根据情况增加 //为简单--省去检验步骤,之后根据情况增加
// 1.1 校验是否可以更新 // 1.1 校验是否可以更新
InstantDO instant = validateRoleForUpdate(updateReqVO.getId()); InstantDO instant = validateRoleForUpdate(updateReqVO.getMpId());
// 1.2 校验角色的唯一字段是否重复 // 1.2 校验角色的唯一字段是否重复
// validateRoleDuplicate(updateReqVO.getName(), updateReqVO.getCode(), updateReqVO.getId()); // validateRoleDuplicate(updateReqVO.getName(), updateReqVO.getCode(), updateReqVO.getId());

Loading…
Cancel
Save