修改数据回流插入

This commit is contained in:
sunxiqing 2025-01-02 11:26:01 +08:00
parent 40f2ba64ac
commit 6d4246b1c4

View File

@ -46,6 +46,13 @@ public class DataRefluxConfigServiceImpl implements DataRefluxConfigService {
public Long createDataRefluxConfig(DataRefluxConfigSaveReqVO createReqVO) {
// 插入
DataRefluxConfigDO dataRefluxConfig = BeanUtils.toBean(createReqVO, DataRefluxConfigDO.class);
LambdaQueryWrapper<DataRefluxConfigDO> eq = new LambdaQueryWrapper<DataRefluxConfigDO>()
.eq(DataRefluxConfigDO::getModelServiceId, dataRefluxConfig.getModelServiceId())
.eq(DataRefluxConfigDO::getModelType, dataRefluxConfig.getModelType())
.eq(DataRefluxConfigDO::getCreator, dataRefluxConfig.getCreator());
if (dataRefluxConfigMapper.selectCount(eq) > 0) {
throw new RuntimeException("该模型服务已存在");
}
dataRefluxConfigMapper.insert(dataRefluxConfig);
// 返回
return dataRefluxConfig.getId();