This commit is contained in:
2023-10-13 12:52:55 +08:00
parent 332ea634ad
commit 27383d989a
2 changed files with 9 additions and 7 deletions

View File

@@ -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;
/**

View File

@@ -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<CsDevCapacityPOMappe
@Override
public void addList(List<CsDevCapacityPO> list) {
this.saveOrUpdateBatch(list);
String line = list.get(0).getLineId();
LambdaQueryWrapper<CsDevCapacityPO> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(CsDevCapacityPO::getLineId,line);
this.remove(lambdaQueryWrapper);
this.saveBatch(list);
}
@Override