feat: 提供批量获取产品物模型的接口

@@ -24,10 +24,7 @@ import org.thingsboard.server.common.data.yunteng.common.DeleteGroup;
 import org.thingsboard.server.common.data.yunteng.common.UpdateGroup;
 import org.thingsboard.server.common.data.yunteng.common.UpdateGroup;
 import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
 import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
 import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
 import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
-import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
-import org.thingsboard.server.common.data.yunteng.dto.DeviceProfileDTO;
-import org.thingsboard.server.common.data.yunteng.dto.ThingsModelDTO;
-import org.thingsboard.server.common.data.yunteng.dto.TkThingsModel;
+import org.thingsboard.server.common.data.yunteng.dto.*;
 import org.thingsboard.server.common.data.yunteng.dto.thingsmodel.ImportThingsModelDTO;
 import org.thingsboard.server.common.data.yunteng.dto.thingsmodel.ImportThingsModelDTO;
 import org.thingsboard.server.common.data.yunteng.enums.FunctionTypeEnum;
 import org.thingsboard.server.common.data.yunteng.enums.FunctionTypeEnum;
 import org.thingsboard.server.common.data.yunteng.enums.ImportEnum;
 import org.thingsboard.server.common.data.yunteng.enums.ImportEnum;
@@ -44,6 +41,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStream;
 import java.util.HashMap;
 import java.util.HashMap;
 import java.util.List;
 import java.util.List;
+import java.util.Map;
 
 
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.*;
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.*;
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.ORDER_TYPE;
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.ORDER_TYPE;
@@ -367,4 +365,16 @@ public class ThingsModelController extends BaseController {
       return null;
       return null;
     }
     }
   }
   }
+
+  @PostMapping("/batch/get_tsl")
+  @ApiOperation("获取多个产品的物模型数据")
+  public ResponseEntity<List<BatchDeviceProfileInfoDTO>> getDeviceProfilesTSL(@RequestBody DeviceProfileTSLDTO profileTSLDTO)
+          throws ThingsboardException {
+    if(null == profileTSLDTO.getDeviceProfileIds() || null == profileTSLDTO.getFunctionTypeEnum() ||
+    profileTSLDTO.getDeviceProfileIds().isEmpty()){
+      throw new TkDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+    }
+    return ResponseEntity.ok(thingsModelService.getDeviceProfileTSLInfoByIds(getCurrentUser().getCurrentTenantId(),
+            profileTSLDTO.getDeviceProfileIds(),profileTSLDTO.getFunctionTypeEnum()));
+  }
 }
 }

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.thingsboard.server.common.data.yunteng.enums.DeviceTypeEnum;
+
+@Data
+public class BatchDeviceProfileInfoDTO {
+
+    @ApiModelProperty(value = "产品ID/设备配置ID")
+    private String id;
+    @ApiModelProperty(value = "产品名称/设备配置名称")
+    private String name;
+    @ApiModelProperty(value = "传输协议")
+    private String transportType;
+    @ApiModelProperty(value = "产品类型：GATEWAY,DIRECT_CONNECTION,SENSOR")
+    private DeviceTypeEnum deviceType;
+    @ApiModelProperty(value = "物模型TSL")
+    private JsonNode tsl;
+}

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.thingsboard.server.common.data.yunteng.enums.FunctionTypeEnum;
+
+import java.util.List;
+
+@Data
+public class DeviceProfileTSLDTO {
+
+    @ApiModelProperty(value = "产品id列表", required = true)
+    private List<String> deviceProfileIds;
+
+    @ApiModelProperty(value = "查询的物模型类型", required = true)
+    private FunctionTypeEnum functionTypeEnum;
+}

@@ -188,7 +188,7 @@ public class ThingsModelServiceImpl
             new LambdaQueryWrapper<TkThingsModelEntity>()
             new LambdaQueryWrapper<TkThingsModelEntity>()
                 .eq(TkThingsModelEntity::getTenantId, tenantId)
                 .eq(TkThingsModelEntity::getTenantId, tenantId)
                 .eq(TkThingsModelEntity::getDeviceProfileId, deviceProfileId)
                 .eq(TkThingsModelEntity::getDeviceProfileId, deviceProfileId)
-                .eq(TkThingsModelEntity::getFunctionType, typeEnum)
+                .eq(!typeEnum.equals(FunctionTypeEnum.all),TkThingsModelEntity::getFunctionType, typeEnum)
                 .eq(TkThingsModelEntity::getStatus, StatusEnum.ENABLE.getIndex()));
                 .eq(TkThingsModelEntity::getStatus, StatusEnum.ENABLE.getIndex()));
     if (entityList.isEmpty()) {
     if (entityList.isEmpty()) {
       return null;
       return null;
@@ -267,7 +267,7 @@ public class ThingsModelServiceImpl
       for (ThingsModelDTO thingsModelDTO : thingsModelDTOS) {
       for (ThingsModelDTO thingsModelDTO : thingsModelDTOS) {
         JsonNode functionJson = thingsModelDTO.getFunctionJson();
         JsonNode functionJson = thingsModelDTO.getFunctionJson();
         if (null != functionJson) {
         if (null != functionJson) {
-          switch (typeEnum) {
+          switch (thingsModelDTO.getFunctionType()) {
             case properties:
             case properties:
               AttributeModelDTO attributeModelDTO = new AttributeModelDTO();
               AttributeModelDTO attributeModelDTO = new AttributeModelDTO();
               BeanUtils.copyProperties(thingsModelDTO, attributeModelDTO);
               BeanUtils.copyProperties(thingsModelDTO, attributeModelDTO);
@@ -440,6 +440,30 @@ public class ThingsModelServiceImpl
     }
     }
     return true;
     return true;
   }
   }
+
+  @Override
+  public List<BatchDeviceProfileInfoDTO> getDeviceProfileTSLInfoByIds(String tenantId, List<String> deviceProfileIds, FunctionTypeEnum functionTypeEnum) {
+    List<BatchDeviceProfileInfoDTO> list = new ArrayList<>();
+    if(null != deviceProfileIds && !deviceProfileIds.isEmpty()){
+      deviceProfileIds.stream().forEach(deviceProfileId->{
+        BatchDeviceProfileInfoDTO batchDeviceProfileInfo  = new BatchDeviceProfileInfoDTO();
+        DeviceProfileDTO deviceProfileDTO = tkDeviceProfileService.getDeviceProfile(tenantId,deviceProfileId);
+        if(null != deviceProfileDTO){
+          batchDeviceProfileInfo.setId(deviceProfileId);
+          batchDeviceProfileInfo.setName(deviceProfileDTO.getName());
+          batchDeviceProfileInfo.setDeviceType(deviceProfileDTO.getDeviceType());
+          batchDeviceProfileInfo.setTransportType(deviceProfileDTO.getTransportType());
+          JsonNode tsl = getTingsModelTSL(functionTypeEnum,tenantId,deviceProfileId);
+          if(null != tsl && tsl.isArray()){
+            batchDeviceProfileInfo.setTsl(tsl);
+          }
+          list.add(batchDeviceProfileInfo);
+        }
+      });
+    }
+    return list;
+  }
+
   private void checkNameAndIdentifier(
   private void checkNameAndIdentifier(
       List<String> existIdentifiers,
       List<String> existIdentifiers,
       FunctionTypeEnum functionType,
       FunctionTypeEnum functionType,

 package org.thingsboard.server.dao.yunteng.service;
 package org.thingsboard.server.dao.yunteng.service;
 
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.JsonNode;
+import org.thingsboard.server.common.data.yunteng.dto.BatchDeviceProfileInfoDTO;
 import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
 import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
 import org.thingsboard.server.common.data.yunteng.dto.ThingsModelDTO;
 import org.thingsboard.server.common.data.yunteng.dto.ThingsModelDTO;
 import org.thingsboard.server.common.data.yunteng.dto.TkThingsModel;
 import org.thingsboard.server.common.data.yunteng.dto.TkThingsModel;
@@ -50,8 +51,14 @@ public interface ThingsModelService extends BaseService<TkThingsModelEntity>{
 
 
   boolean getByIdentifier(String tenantId, String deviceProfileId,String categoryId,String identifier);
   boolean getByIdentifier(String tenantId, String deviceProfileId,String categoryId,String identifier);
 
 
-
-
-
+  /**
+   * 获取对应产品列表的物模型信息
+   * @param tenantId 租户ID
+   * @param deviceProfileIds 产品列表
+   * @param functionTypeEnum
+   * @return
+   */
+  List<BatchDeviceProfileInfoDTO> getDeviceProfileTSLInfoByIds(String tenantId, List<String> deviceProfileIds,
+                                                               FunctionTypeEnum functionTypeEnum);
 
 
 }
 }