hhyykk/ipms-sjy
1
1
Fork 0
mirror of https://gitee.com/hhyykk/ipms-sjy.git synced 2025-11-04 12:18:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修改：IOT 优化根据属性列表，自动生成属性上报事件和属性设置、获取服务

Browse Source
This commit is contained in:
安浩浩
2024-09-14 08:32:04 +08:00
parent 1f8576f643
commit 061819f25b
1 changed files with 52 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

67
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/thinkmodelfunction/IotThinkModelFunctionServiceImpl.java
View File

@@ -96,7 +96,6 @@ public class IotThinkModelFunctionServiceImpl implements IotThinkModelFunctionSe
} }
/** /**
* @ TODO 还要再优化
* 根据属性列表，自动生成属性上报事件和属性设置、获取服务 * 根据属性列表，自动生成属性上报事件和属性设置、获取服务
*/ */
private void generateDefaultEventsAndServices(IotThinkModelFunctionSaveReqVO reqVO, IotThinkModelFunctionDO thinkModelFunction) { private void generateDefaultEventsAndServices(IotThinkModelFunctionSaveReqVO reqVO, IotThinkModelFunctionDO thinkModelFunction) {
@@ -106,27 +105,65 @@ public class IotThinkModelFunctionServiceImpl implements IotThinkModelFunctionSe
properties = new ArrayList<>(); properties = new ArrayList<>();
} }
// 生成属性上报事件 // 获取现有的事件和服务
List<ThingModelEvent> events = reqVO.getEvents() != null ? new ArrayList<>(reqVO.getEvents()) : new ArrayList<>(); List<ThingModelEvent> existingEvents = reqVO.getEvents() != null ? new ArrayList<>(reqVO.getEvents()) : new ArrayList<>();
ThingModelEvent propertyPostEvent = generatePropertyPostEvent(properties); List<ThingModelService> existingServices = reqVO.getServices() != null ? new ArrayList<>(reqVO.getServices()) : new ArrayList<>();
events.add(propertyPostEvent);
// 生成属性设置和获取服务 // 生成或更新属性上报事件
List<ThingModelService> services = reqVO.getServices() != null ? new ArrayList<>(reqVO.getServices()) : new ArrayList<>(); ThingModelEvent propertyPostEvent = generatePropertyPostEvent(properties);
updateEventInList(existingEvents, propertyPostEvent);
// 生成或更新属性设置和获取服务
ThingModelService propertySetService = generatePropertySetService(properties); ThingModelService propertySetService = generatePropertySetService(properties);
if (propertySetService != null) { updateServiceInList(existingServices, propertySetService);
services.add(propertySetService);
}
ThingModelService propertyGetService = generatePropertyGetService(properties); ThingModelService propertyGetService = generatePropertyGetService(properties);
if (propertyGetService != null) { updateServiceInList(existingServices, propertyGetService);
services.add(propertyGetService);
}
// 更新 thinkModelFunction 对象的 events 和 services 字段 // 更新 thinkModelFunction 对象的 events 和 services 字段
thinkModelFunction.setEvents(JSONUtil.toJsonStr(events)); thinkModelFunction.setEvents(JSONUtil.toJsonStr(existingEvents));
thinkModelFunction.setServices(JSONUtil.toJsonStr(services)); thinkModelFunction.setServices(JSONUtil.toJsonStr(existingServices));
} }
/**
* 在事件列表中更新或添加事件
*/
private void updateEventInList(List<ThingModelEvent> events, ThingModelEvent newEvent) {
if (newEvent == null) {
return;
}
for (int i = 0; i < events.size(); i++) {
ThingModelEvent event = events.get(i);
if (event.getIdentifier().equals(newEvent.getIdentifier())) {
// 更新已有的事件
events.set(i, newEvent);
return;
}
}
// 如果不存在，则添加新的事件
events.add(newEvent);
}
/**
* 在服务列表中更新或添加服务
*/
private void updateServiceInList(List<ThingModelService> services, ThingModelService newService) {
if (newService == null) {
return;
}
for (int i = 0; i < services.size(); i++) {
ThingModelService service = services.get(i);
if (service.getIdentifier().equals(newService.getIdentifier())) {
// 更新已有的服务
services.set(i, newService);
return;
}
}
// 如果不存在，则添加新的服务
services.add(newService);
}
/** /**
* 生成属性上报事件 * 生成属性上报事件
*/ */