fix: provider query device relation

@@ -438,6 +438,13 @@ public class TkDeviceController extends BaseController {
         getCurrentUser().getCurrentTenantId(), tbDeviceId);
   }
 
+  @GetMapping("/device/relation")
+  public String getDeviceRelation(
+      @ApiParam(value = "网关子设备：true 非网关子设备：false") @RequestParam(value = "isSlave") boolean isSlave,
+      @ApiParam(value = "设备ID") @RequestParam(value = "deviceId") String deviceId) {
+    return tkdeviceService.getDeviceRelation(isSlave, deviceId);
+  }
+
   private Device buildTbDeviceFromDeviceDTO(TenantId tenantId, DeviceDTO deviceDTO) {
     Device tbDevice = new Device();
     String deviceId = deviceDTO.getTbDeviceId();

@@ -286,12 +286,12 @@ public class TkDeviceServiceImpl extends AbstractBaseService<DeviceMapper, TkDev
         baseMapper.selectList(
             new LambdaQueryWrapper<TkDeviceEntity>()
                 .eq(TkDeviceEntity::getTenantId, tenantId)
-                .eq(TkDeviceEntity::getDeviceType,DeviceTypeEnum.GATEWAY)
+                .eq(TkDeviceEntity::getDeviceType, DeviceTypeEnum.GATEWAY)
                 .in(TkDeviceEntity::getOrganizationId, orgIds));
-    if(null != deviceProfileIds && !deviceProfileIds.isEmpty()){
+    if (null != deviceProfileIds && !deviceProfileIds.isEmpty()) {
       List<TkDeviceEntity> result = new ArrayList<>();
-      for (TkDeviceEntity entity :entities){
-        if(deviceProfileIds.contains(entity.getDeviceProfileId())){
+      for (TkDeviceEntity entity : entities) {
+        if (deviceProfileIds.contains(entity.getDeviceProfileId())) {
           result.add(entity);
         }
       }
@@ -625,4 +625,12 @@ public class TkDeviceServiceImpl extends AbstractBaseService<DeviceMapper, TkDev
     }
     return jsonNode;
   }
+
+  @Override
+  public String getDeviceRelation(boolean isSlave, String deviceId) {
+    if (StringUtils.isEmpty(deviceId)) {
+      throw new TkDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+    }
+    return baseMapper.getDeviceRelation(isSlave, deviceId);
+  }
 }

@@ -64,7 +64,8 @@ public interface DeviceMapper extends BaseMapper<TkDeviceEntity> {
    */
   List<String> findDeviceIdsByCustomerId(@Param("customerId") String customerId);
 
-  List<DeviceDTO> findDeviceInfoByCustomerId(@Param("tenantId") String tenantId,@Param("customerId") String customerId);
+  List<DeviceDTO> findDeviceInfoByCustomerId(
+      @Param("tenantId") String tenantId, @Param("customerId") String customerId);
 
   List<BaseHomePageTop> findDeviceMessageInfo(
       @Param("todayTime") Long todayTime, @Param("customerId") String customerId);
@@ -141,4 +142,6 @@ public interface DeviceMapper extends BaseMapper<TkDeviceEntity> {
       @Param("customerId") String customerId,
       @Param("organizationIds") List<String> organizationIds,
       @Param("deviceIds") List<String> deviceIds);
+
+  String getDeviceRelation(@Param("isSlave") boolean isSlave, @Param("deviceId") String deviceId);
 }

@@ -188,4 +188,6 @@ public interface TkDeviceService extends BaseService<TkDeviceEntity> {
    * @return 属性信息de
    */
   JsonNode getDeviceAttributes(String deviceProfileId, String tenantId, DataTypeEnum dataType);
+
+  String getDeviceRelation(boolean isSlave,String deviceId);
 }

@@ -424,4 +424,24 @@
             </if>
         </where>
     </select>
+
+    <select id="getDeviceRelation" resultType="java.lang.String">
+        SELECT
+        <if test="isSlave !=null and isSlave == true">
+            from_id
+        </if>
+        <if test="isSlave !=null and isSlave == false">
+            to_id
+        </if>
+        FROM relation
+        WHERE
+          from_type = 'DEVICE'
+          AND relation_type_group = 'COMMON'
+        <if test="isSlave !=null and isSlave == false">
+          AND from_id :: TEXT = #{deviceId}
+        </if>
+        <if test="isSlave !=null and isSlave == true">
+          AND to_id :: TEXT = #{deviceId}
+        </if>
+    </select>
 </mapper>