diff --git a/das/src/main/java/com/das/modules/equipment/service/impl/SysIotModelServiceImpl.java b/das/src/main/java/com/das/modules/equipment/service/impl/SysIotModelServiceImpl.java index 05e86556..aa7389d2 100644 --- a/das/src/main/java/com/das/modules/equipment/service/impl/SysIotModelServiceImpl.java +++ b/das/src/main/java/com/das/modules/equipment/service/impl/SysIotModelServiceImpl.java @@ -418,33 +418,33 @@ public class SysIotModelServiceImpl implements SysIotModelService { } if (CollectionUtils.isNotEmpty(sysIotModelFieldList)) { sysIotModelFieldMapper.insertBatch(sysIotModelFieldList); - ListUtil.page(sysIotModelFieldList, COMMIT_COUNT, create -> { - for (SysIotModelField item : create){ - createTdStableOrColumn(item); - } - }); +// ListUtil.page(sysIotModelFieldList, COMMIT_COUNT, create -> { +// for (SysIotModelField item : create){ +// createTdStableOrColumn(item); +// } +// }); } if (CollectionUtils.isNotEmpty(updateSysIotModelFieldList)) { - ListUtil.page(updateSysIotModelFieldList, COMMIT_COUNT, update -> { - for (SysIotModelField item : update){ - SysIotModelField oldSysIotField = sysIotModelFieldMapper.selectById(item.getId()); - if (oldSysIotField != null){ - if (!oldSysIotField.getAttributeCode().equals(item.getAttributeCode()) && oldSysIotField.getDataType().equals(item.getDataType()) && Objects.equals(oldSysIotField.getHighSpeed(), item.getHighSpeed())){ - //更新td表结构 - updateTDStableOrColumn(item,oldSysIotField); - } - } - } - }); +// ListUtil.page(updateSysIotModelFieldList, COMMIT_COUNT, update -> { +// for (SysIotModelField item : update){ +// SysIotModelField oldSysIotField = sysIotModelFieldMapper.selectById(item.getId()); +// if (oldSysIotField != null){ +// if (!oldSysIotField.getAttributeCode().equals(item.getAttributeCode()) && oldSysIotField.getDataType().equals(item.getDataType()) && Objects.equals(oldSysIotField.getHighSpeed(), item.getHighSpeed())){ +// //更新td表结构 +// updateTDStableOrColumn(item,oldSysIotField); +// } +// } +// } +// }); sysIotModelFieldMapper.updateBatchById(updateSysIotModelFieldList); } if (CollectionUtils.isNotEmpty(delSysIotModelFieldList)) { - ListUtil.page(updateSysIotModelFieldList, COMMIT_COUNT, delete -> { - for (SysIotModelField item : delete){ - deleteTDStableOrColumn(item); - } - }); +// ListUtil.page(updateSysIotModelFieldList, COMMIT_COUNT, delete -> { +// for (SysIotModelField item : delete){ +// deleteTDStableOrColumn(item); +// } +// }); sysIotModelFieldMapper.deleteBatchIds(delSysIotModelFieldList); } }