sx/map
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

风机页面遥控接口

Browse Source
This commit is contained in:
huguanghan 2024-10-24 18:32:00 +08:00
parent c8b1a13853
commit 6551d37d6f
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
das/src/main/java/com/das/modules/equipment/service/impl/SysIotModelServiceImpl.java
View File

@ -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);
}
}