diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsDevCapacityPO.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsDevCapacityPO.java index a311cd8..6e4c2f7 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsDevCapacityPO.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsDevCapacityPO.java @@ -1,12 +1,9 @@ package com.njcn.csdevice.pojo.po; -import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.FieldStrategy; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; -import io.swagger.annotations.ApiModel; -import io.swagger.annotations.ApiModelProperty; -import java.math.BigDecimal; import lombok.Data; import lombok.NoArgsConstructor; @@ -25,13 +22,13 @@ public class CsDevCapacityPO { /** * 监测点id */ - @TableField(value = "line_id") + @TableId(value = "line_id") private String lineId; /** * 模块(0:表示主模块,其余数字表示当前模块,例如,1表示模块1) */ - @TableField(value = "cldid") + @TableField(value = "cldid",insertStrategy = FieldStrategy.IGNORED) private Integer cldid; /** diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java index 4d3e211..673b7f5 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevCapacityPOServiceImpl.java @@ -1,5 +1,6 @@ package com.njcn.csdevice.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.njcn.common.pojo.exception.BusinessException; import com.njcn.csdevice.enums.AlgorithmResponseEnum; import com.njcn.csdevice.pojo.po.CsLinePO; @@ -38,7 +39,11 @@ public class CsDevCapacityPOServiceImpl extends ServiceImpl list) { - this.saveOrUpdateBatch(list); + String line = list.get(0).getLineId(); + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(CsDevCapacityPO::getLineId,line); + this.remove(lambdaQueryWrapper); + this.saveBatch(list); } @Override