|
@@ -0,0 +1,404 @@
|
|
|
+package cn.iocoder.yudao.module.iot.service.thinkmodelfunction;
|
|
|
+
|
|
|
+import cn.hutool.core.collection.CollUtil;
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
|
|
+import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
|
|
|
+import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.ThingModelEvent;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.ThingModelProperty;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.ThingModelService;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.dataType.ThingModelArgument;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.dataType.ThingModelArraySpecs;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.dataType.ThingModelArrayType;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.thingModel.dataType.ThingModelTextType;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.vo.IotThinkModelFunctionPageReqVO;
|
|
|
+import cn.iocoder.yudao.module.iot.controller.admin.thinkmodelfunction.vo.IotThinkModelFunctionSaveReqVO;
|
|
|
+import cn.iocoder.yudao.module.iot.convert.thinkmodelfunction.IotThinkModelFunctionConvert;
|
|
|
+import cn.iocoder.yudao.module.iot.dal.dataobject.thinkmodelfunction.IotThinkModelFunctionDO;
|
|
|
+import cn.iocoder.yudao.module.iot.dal.mysql.thinkmodelfunction.IotThinkModelFunctionMapper;
|
|
|
+import cn.iocoder.yudao.module.iot.enums.product.IotAccessModeEnum;
|
|
|
+import cn.iocoder.yudao.module.iot.enums.product.IotProductFunctionTypeEnum;
|
|
|
+import jakarta.annotation.Resource;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
+import org.springframework.validation.annotation.Validated;
|
|
|
+
|
|
|
+import java.util.*;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.diffList;
|
|
|
+import static cn.iocoder.yudao.module.iot.enums.ErrorCodeConstants.*;
|
|
|
+
|
|
|
+/**
|
|
|
+ * IoT 产品物模型 Service 实现类
|
|
|
+ *
|
|
|
+ * @author 芋道源码
|
|
|
+ */
|
|
|
+@Service
|
|
|
+@Validated
|
|
|
+@Slf4j
|
|
|
+public class IotThinkModelFunctionServiceImpl implements IotThinkModelFunctionService {
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private IotThinkModelFunctionMapper thinkModelFunctionMapper;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public Long createThinkModelFunction(IotThinkModelFunctionSaveReqVO createReqVO) {
|
|
|
+ // 1. 校验功能标识符在同一产品下是否唯一
|
|
|
+ validateIdentifierUnique(createReqVO.getProductId(), createReqVO.getIdentifier());
|
|
|
+
|
|
|
+ // 2. 功能名称在同一产品下是否唯一
|
|
|
+ validateNameUnique(createReqVO.getProductId(), createReqVO.getName());
|
|
|
+
|
|
|
+ // 3. 系统保留字段,不能用于标识符定义
|
|
|
+ validateNotDefaultEventAndService(createReqVO.getIdentifier());
|
|
|
+
|
|
|
+ // 3. 插入数据库
|
|
|
+ IotThinkModelFunctionDO function = IotThinkModelFunctionConvert.INSTANCE.convert(createReqVO);
|
|
|
+ thinkModelFunctionMapper.insert(function);
|
|
|
+
|
|
|
+ // 4. 如果创建的是属性,需要更新默认的事件和服务
|
|
|
+ if (Objects.equals(createReqVO.getType(), IotProductFunctionTypeEnum.PROPERTY.getType())) {
|
|
|
+ createDefaultEventsAndServices(createReqVO.getProductId(), createReqVO.getProductKey());
|
|
|
+ }
|
|
|
+ return function.getId();
|
|
|
+ }
|
|
|
+
|
|
|
+ private void validateNotDefaultEventAndService(String identifier) {
|
|
|
+ // set, get, post, property, event, time, value 是系统保留字段,不能用于标识符定义
|
|
|
+ if (CollUtil.containsAny(Arrays.asList("set", "get", "post", "property", "event", "time", "value"), Collections.singletonList(identifier))) {
|
|
|
+ throw exception(THINK_MODEL_FUNCTION_IDENTIFIER_INVALID);
|
|
|
+ }
|
|
|
+// if (CollUtil.containsAny(Arrays.asList("post", "set", "get"), identifier)) {
|
|
|
+// throw exception(THINK_MODEL_FUNCTION_IDENTIFIER_INVALID);
|
|
|
+// }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void validateNameUnique(Long productId, String name) {
|
|
|
+ IotThinkModelFunctionDO function = thinkModelFunctionMapper.selectByProductIdAndName(productId, name);
|
|
|
+ if (function != null) {
|
|
|
+ throw exception(THINK_MODEL_FUNCTION_NAME_EXISTS);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void validateIdentifierUnique(Long productId, String identifier) {
|
|
|
+ IotThinkModelFunctionDO function = thinkModelFunctionMapper.selectByProductIdAndIdentifier(productId, identifier);
|
|
|
+ if (function != null) {
|
|
|
+ throw exception(THINK_MODEL_FUNCTION_IDENTIFIER_EXISTS);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public void updateThinkModelFunction(IotThinkModelFunctionSaveReqVO updateReqVO) {
|
|
|
+ // 1. 校验功能是否存在
|
|
|
+ validateThinkModelFunctionExists(updateReqVO.getId());
|
|
|
+
|
|
|
+ // 2. 校验功能标识符是否唯一
|
|
|
+ validateIdentifierUniqueForUpdate(updateReqVO.getId(), updateReqVO.getProductId(), updateReqVO.getIdentifier());
|
|
|
+
|
|
|
+ // 3. 更新数据库
|
|
|
+ IotThinkModelFunctionDO thinkModelFunction = IotThinkModelFunctionConvert.INSTANCE.convert(updateReqVO);
|
|
|
+ thinkModelFunctionMapper.updateById(thinkModelFunction);
|
|
|
+
|
|
|
+ // 4. 如果更新的是属性,需要更新默认的事件和服务
|
|
|
+ if (Objects.equals(updateReqVO.getType(), IotProductFunctionTypeEnum.PROPERTY.getType())) {
|
|
|
+ createDefaultEventsAndServices(updateReqVO.getProductId(), updateReqVO.getProductKey());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void validateIdentifierUniqueForUpdate(Long id, Long productId, String identifier) {
|
|
|
+ IotThinkModelFunctionDO function = thinkModelFunctionMapper.selectByProductIdAndIdentifier(productId, identifier);
|
|
|
+ if (function != null && ObjectUtil.notEqual(function.getId(), id)) {
|
|
|
+ throw exception(THINK_MODEL_FUNCTION_IDENTIFIER_EXISTS);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public void deleteThinkModelFunction(Long id) {
|
|
|
+ // 1. 校验功能是否存在
|
|
|
+ IotThinkModelFunctionDO functionDO = thinkModelFunctionMapper.selectById(id);
|
|
|
+ if (functionDO == null) {
|
|
|
+ throw exception(THINK_MODEL_FUNCTION_NOT_EXISTS);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 2. 删除功能
|
|
|
+ thinkModelFunctionMapper.deleteById(id);
|
|
|
+
|
|
|
+ // 3. 如果删除的是属性,需要更新默认的事件和服务
|
|
|
+ if (Objects.equals(functionDO.getType(), IotProductFunctionTypeEnum.PROPERTY.getType())) {
|
|
|
+ createDefaultEventsAndServices(functionDO.getProductId(), functionDO.getProductKey());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 校验功能是否存在
|
|
|
+ *
|
|
|
+ * @param id 功能编号
|
|
|
+ */
|
|
|
+ private void validateThinkModelFunctionExists(Long id) {
|
|
|
+ if (thinkModelFunctionMapper.selectById(id) == null) {
|
|
|
+ throw exception(THINK_MODEL_FUNCTION_NOT_EXISTS);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public IotThinkModelFunctionDO getThinkModelFunction(Long id) {
|
|
|
+ return thinkModelFunctionMapper.selectById(id);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<IotThinkModelFunctionDO> getThinkModelFunctionListByProductId(Long productId) {
|
|
|
+ return thinkModelFunctionMapper.selectListByProductId(productId);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public PageResult<IotThinkModelFunctionDO> getThinkModelFunctionPage(IotThinkModelFunctionPageReqVO pageReqVO) {
|
|
|
+ return thinkModelFunctionMapper.selectPage(pageReqVO);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 创建默认的事件和服务
|
|
|
+ */
|
|
|
+ public void createDefaultEventsAndServices(Long productId, String productKey) {
|
|
|
+ // 1. 获取当前属性列表
|
|
|
+ List<IotThinkModelFunctionDO> propertyList = thinkModelFunctionMapper
|
|
|
+ .selectListByProductIdAndType(productId, IotProductFunctionTypeEnum.PROPERTY.getType());
|
|
|
+
|
|
|
+ // 2. 生成新的事件和服务列表
|
|
|
+ List<IotThinkModelFunctionDO> newFunctionList = new ArrayList<>();
|
|
|
+ // 生成属性上报事件
|
|
|
+ ThingModelEvent propertyPostEvent = generatePropertyPostEvent(propertyList);
|
|
|
+ if (propertyPostEvent != null) {
|
|
|
+ IotThinkModelFunctionDO eventFunction = buildEventFunctionDO(productId, productKey, propertyPostEvent);
|
|
|
+ newFunctionList.add(eventFunction);
|
|
|
+ }
|
|
|
+ // 生成属性设置服务
|
|
|
+ ThingModelService propertySetService = generatePropertySetService(propertyList);
|
|
|
+ if (propertySetService != null) {
|
|
|
+ IotThinkModelFunctionDO setServiceFunction = buildServiceFunctionDO(productId, productKey, propertySetService);
|
|
|
+ newFunctionList.add(setServiceFunction);
|
|
|
+ }
|
|
|
+ // 生成属性获取服务
|
|
|
+ ThingModelService propertyGetService = generatePropertyGetService(propertyList);
|
|
|
+ if (propertyGetService != null) {
|
|
|
+ IotThinkModelFunctionDO getServiceFunction = buildServiceFunctionDO(productId, productKey, propertyGetService);
|
|
|
+ newFunctionList.add(getServiceFunction);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 3. 获取数据库中的默认的旧事件和服务列表
|
|
|
+ List<IotThinkModelFunctionDO> oldFunctionList = thinkModelFunctionMapper.selectListByProductIdAndIdentifiersAndTypes(
|
|
|
+ productId,
|
|
|
+ Arrays.asList("post", "set", "get"),
|
|
|
+ Arrays.asList(IotProductFunctionTypeEnum.EVENT.getType(), IotProductFunctionTypeEnum.SERVICE.getType())
|
|
|
+ );
|
|
|
+
|
|
|
+ // 3.1 使用 diffList 方法比较新旧列表
|
|
|
+ List<List<IotThinkModelFunctionDO>> diffResult = diffList(oldFunctionList, newFunctionList,
|
|
|
+ // 继续使用 identifier 和 type 进行比较:这样可以准确地匹配对应的功能对象。
|
|
|
+ (oldFunc, newFunc) -> Objects.equals(oldFunc.getIdentifier(), newFunc.getIdentifier())
|
|
|
+ && Objects.equals(oldFunc.getType(), newFunc.getType()));
|
|
|
+ List<IotThinkModelFunctionDO> createList = diffResult.get(0); // 需要新增的
|
|
|
+ List<IotThinkModelFunctionDO> updateList = diffResult.get(1); // 需要更新的
|
|
|
+ List<IotThinkModelFunctionDO> deleteList = diffResult.get(2); // 需要删除的
|
|
|
+
|
|
|
+ // 3.2 批量执行数据库操作
|
|
|
+ // 新增数据库中的新事件和服务列表
|
|
|
+ if (CollUtil.isNotEmpty(createList)) {
|
|
|
+ thinkModelFunctionMapper.insertBatch(createList);
|
|
|
+ }
|
|
|
+ // 更新数据库中的事件和服务列表
|
|
|
+ if (CollUtil.isNotEmpty(updateList)) {
|
|
|
+ // 首先,为每个需要更新的对象设置其对应的 ID
|
|
|
+ updateList.forEach(updateFunc -> {
|
|
|
+ IotThinkModelFunctionDO oldFunc = findFunctionByIdentifierAndType(
|
|
|
+ oldFunctionList, updateFunc.getIdentifier(), updateFunc.getType());
|
|
|
+ if (oldFunc != null) {
|
|
|
+ updateFunc.setId(oldFunc.getId());
|
|
|
+ }
|
|
|
+ });
|
|
|
+ // 过滤掉没有设置 ID 的对象
|
|
|
+ List<IotThinkModelFunctionDO> validUpdateList = updateList.stream()
|
|
|
+ .filter(func -> func.getId() != null)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ // 执行批量更新
|
|
|
+ if (CollUtil.isNotEmpty(validUpdateList)) {
|
|
|
+ thinkModelFunctionMapper.updateBatch(validUpdateList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 删除数据库中的旧事件和服务列表
|
|
|
+ if (CollUtil.isNotEmpty(deleteList)) {
|
|
|
+ Set<Long> idsToDelete = CollectionUtils.convertSet(deleteList, IotThinkModelFunctionDO::getId);
|
|
|
+ thinkModelFunctionMapper.deleteByIds(idsToDelete);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据标识符和类型查找功能对象
|
|
|
+ */
|
|
|
+ private IotThinkModelFunctionDO findFunctionByIdentifierAndType(List<IotThinkModelFunctionDO> functionList,
|
|
|
+ String identifier, Integer type) {
|
|
|
+ return CollUtil.findOne(functionList, func ->
|
|
|
+ Objects.equals(func.getIdentifier(), identifier) && Objects.equals(func.getType(), type));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 构建事件功能对象
|
|
|
+ */
|
|
|
+ private IotThinkModelFunctionDO buildEventFunctionDO(Long productId, String productKey, ThingModelEvent event) {
|
|
|
+ return new IotThinkModelFunctionDO()
|
|
|
+ .setProductId(productId)
|
|
|
+ .setProductKey(productKey)
|
|
|
+ .setIdentifier(event.getIdentifier())
|
|
|
+ .setName(event.getName())
|
|
|
+ .setDescription(event.getDescription())
|
|
|
+ .setType(IotProductFunctionTypeEnum.EVENT.getType())
|
|
|
+ .setEvent(event);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 构建服务功能对象
|
|
|
+ */
|
|
|
+ private IotThinkModelFunctionDO buildServiceFunctionDO(Long productId, String productKey, ThingModelService service) {
|
|
|
+ return new IotThinkModelFunctionDO()
|
|
|
+ .setProductId(productId)
|
|
|
+ .setProductKey(productKey)
|
|
|
+ .setIdentifier(service.getIdentifier())
|
|
|
+ .setName(service.getName())
|
|
|
+ .setDescription(service.getDescription())
|
|
|
+ .setType(IotProductFunctionTypeEnum.SERVICE.getType())
|
|
|
+ .setService(service);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成属性上报事件
|
|
|
+ */
|
|
|
+ private ThingModelEvent generatePropertyPostEvent(List<IotThinkModelFunctionDO> propertyList) {
|
|
|
+ if (CollUtil.isEmpty(propertyList)) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ ThingModelEvent event = new ThingModelEvent()
|
|
|
+ .setIdentifier("post")
|
|
|
+ .setName("属性上报")
|
|
|
+ .setType("info")
|
|
|
+ .setDescription("属性上报事件")
|
|
|
+ .setMethod("thing.event.property.post");
|
|
|
+
|
|
|
+ // 将属性列表转换为事件的输出参数
|
|
|
+ List<ThingModelArgument> outputData = new ArrayList<>();
|
|
|
+ for (IotThinkModelFunctionDO functionDO : propertyList) {
|
|
|
+ ThingModelProperty property = functionDO.getProperty();
|
|
|
+ ThingModelArgument arg = new ThingModelArgument()
|
|
|
+ .setIdentifier(property.getIdentifier())
|
|
|
+ .setName(property.getName())
|
|
|
+ .setDataType(property.getDataType())
|
|
|
+ .setDescription(property.getDescription())
|
|
|
+ .setDirection("output"); // 设置为输出参数
|
|
|
+ outputData.add(arg);
|
|
|
+ }
|
|
|
+ event.setOutputData(outputData);
|
|
|
+ return event;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成属性设置服务
|
|
|
+ */
|
|
|
+ private ThingModelService generatePropertySetService(List<IotThinkModelFunctionDO> propertyList) {
|
|
|
+ if (propertyList == null || propertyList.isEmpty()) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ List<ThingModelArgument> inputData = new ArrayList<>();
|
|
|
+ for (IotThinkModelFunctionDO functionDO : propertyList) {
|
|
|
+ ThingModelProperty property = functionDO.getProperty();
|
|
|
+ if (IotAccessModeEnum.WRITE.getMode().equals(property.getAccessMode()) || IotAccessModeEnum.READ_WRITE.getMode().equals(property.getAccessMode())) {
|
|
|
+ ThingModelArgument arg = new ThingModelArgument()
|
|
|
+ .setIdentifier(property.getIdentifier())
|
|
|
+ .setName(property.getName())
|
|
|
+ .setDataType(property.getDataType())
|
|
|
+ .setDescription(property.getDescription())
|
|
|
+ .setDirection("input"); // 设置为输入参数
|
|
|
+ inputData.add(arg);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (inputData.isEmpty()) {
|
|
|
+ // 如果没有可写属性,不生成属性设置服务
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 属性设置服务一般不需要输出参数
|
|
|
+ return new ThingModelService()
|
|
|
+ .setIdentifier("set")
|
|
|
+ .setName("属性设置")
|
|
|
+ .setCallType("async")
|
|
|
+ .setDescription("属性设置服务")
|
|
|
+ .setMethod("thing.service.property.set")
|
|
|
+ .setInputData(inputData)
|
|
|
+ // 属性设置服务一般不需要输出参数
|
|
|
+ .setOutputData(new ArrayList<>());
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成属性获取服务
|
|
|
+ */
|
|
|
+ private ThingModelService generatePropertyGetService(List<IotThinkModelFunctionDO> propertyList) {
|
|
|
+ if (propertyList == null || propertyList.isEmpty()) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ List<ThingModelArgument> outputData = new ArrayList<>();
|
|
|
+ for (IotThinkModelFunctionDO functionDO : propertyList) {
|
|
|
+ ThingModelProperty property = functionDO.getProperty();
|
|
|
+ if (ObjectUtils.equalsAny(property.getAccessMode(),
|
|
|
+ IotAccessModeEnum.READ.getMode(), IotAccessModeEnum.READ_WRITE.getMode())) {
|
|
|
+ ThingModelArgument arg = new ThingModelArgument()
|
|
|
+ .setIdentifier(property.getIdentifier())
|
|
|
+ .setName(property.getName())
|
|
|
+ .setDataType(property.getDataType())
|
|
|
+ .setDescription(property.getDescription())
|
|
|
+ .setDirection("output"); // 设置为输出参数
|
|
|
+ outputData.add(arg);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (outputData.isEmpty()) {
|
|
|
+ // 如果没有可读属性,不生成属性获取服务
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ ThingModelService service = new ThingModelService()
|
|
|
+ .setIdentifier("get")
|
|
|
+ .setName("属性获取")
|
|
|
+ .setCallType("async")
|
|
|
+ .setDescription("属性获取服务")
|
|
|
+ .setMethod("thing.service.property.get");
|
|
|
+
|
|
|
+ // 定义输入参数:属性标识符列表
|
|
|
+ ThingModelArgument inputArg = new ThingModelArgument()
|
|
|
+ .setIdentifier("properties")
|
|
|
+ .setName("属性标识符列表")
|
|
|
+ .setDescription("需要获取的属性标识符列表")
|
|
|
+ .setDirection("input"); // 设置为输入参数
|
|
|
+
|
|
|
+ // 创建数组类型,元素类型为文本类型(字符串)
|
|
|
+ ThingModelArrayType arrayType = new ThingModelArrayType();
|
|
|
+ arrayType.setType("array");
|
|
|
+ ThingModelArraySpecs arraySpecs = new ThingModelArraySpecs();
|
|
|
+ ThingModelTextType textType = new ThingModelTextType();
|
|
|
+ textType.setType("text");
|
|
|
+ arraySpecs.setItem(textType);
|
|
|
+ arrayType.setSpecs(arraySpecs);
|
|
|
+ inputArg.setDataType(arrayType);
|
|
|
+
|
|
|
+ service.setInputData(Collections.singletonList(inputArg));
|
|
|
+ service.setOutputData(outputData);
|
|
|
+ return service;
|
|
|
+ }
|
|
|
+
|
|
|
+}
|