feat: implement querying group-id

Author: MoeexT

backend/api-gateway/src/main/java/com/datamate/gateway/infrastructure/client/dto/ResourceGroup.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2026-2026. All rights reserved.
+ */
+
+package com.datamate.gateway.infrastructure.client.dto;
+
+import lombok.Getter;
+
+import java.time.LocalDateTime;
+
+/**
+ * 资源组信息
+ */
+@Getter
+public class ResourceGroup {
+    private String id;
+
+    private String parentId;
+
+    private String name;
+
+    private String description;
+
+    private LocalDateTime createTime;
+
+    private LocalDateTime updateTime;
+
+    private boolean isDeleted;
+
+    private boolean isBuiltin;
+}

backend/api-gateway/src/main/java/com/datamate/gateway/infrastructure/client/dto/Resp.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2026-2026. All rights reserved.
+ */
+
+package com.datamate.gateway.infrastructure.client.dto;
+
+import lombok.Getter;
+
+/**
+ * oms-extension统一返回包装类
+ *
+ * @param code 状态码
+ * @param msg 消息
+ * @param data 数据
+ * @param <T> 数据类
+ */
+public record Resp<T>(String code, String msg, T data) {
+    public static final String SUCCESS = "0";
+
+    /**
+     * 成功
+     * @param data 数据
+     * @return 响应体
+     * @param <T> 数据类型
+     */
+    public static <T> Resp<T> ok(T data) {
+        return new Resp<>(SUCCESS, "success", data);
+    }
+
+    /**
+     * 成功
+     *
+     * @return 响应体
+     * @param <T> 数据类型
+     */
+    public static <T> Resp<T> ok() {
+        return Resp.ok(null);
+    }
+
+    /**
+     * 失败返回
+     *
+     * @param code 状态码
+     * @param message 错误信息
+     * @return 响应体
+     * @param <T> 数据类型
+     */
+    public static <T> Resp<T> error(String code, String message) {
+        return new Resp<>(code, message, null);
+    }
+}

backend/api-gateway/src/main/java/com/datamate/gateway/infrastructure/client/impl/OmsExtensionServiceImpl.java

@@ -1,18 +1,77 @@
 package com.datamate.gateway.infrastructure.client.impl;
 
+import com.datamate.gateway.common.config.SslIgnoreHttpClientFactory;
 import com.datamate.gateway.infrastructure.client.OmsExtensionService;
+import com.datamate.gateway.infrastructure.client.dto.ResourceGroup;
+import com.datamate.gateway.infrastructure.client.dto.Resp;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import lombok.extern.slf4j.Slf4j;
+
+import org.apache.hc.client5.http.classic.methods.HttpGet;
+import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
+import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
+import org.apache.hc.core5.http.ParseException;
+import org.apache.hc.core5.http.io.entity.EntityUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.io.IOException;
+import java.util.List;
+
 /**
  * OmsExtensionServiceImpl is an implementation of OmsExtensionService.
- * 
- * @author songyongtan
- * @date 2026-03-17
+ *
+ * @author MoeexT
+ * @since 2026-03-17
  */
+@Slf4j
 @Service
 public class OmsExtensionServiceImpl implements OmsExtensionService {
+    @Value("${OMS_EXTENSION_URL:https://oms-extension:8021}")
+    private final String omsExtensionUrl;
+
+    private final ObjectMapper objectMapper;
+
+    private CloseableHttpClient httpClient;
+
+    public OmsExtensionServiceImpl(@Value("${oms.service.url}") String omsExtensionUrl, ObjectMapper objectMapper,
+        SslIgnoreHttpClientFactory sslIgnoreHttpClientFactory) {
+        this.omsExtensionUrl = omsExtensionUrl;
+        this.objectMapper = objectMapper;
+        try {
+            this.httpClient = sslIgnoreHttpClientFactory.getHttpClient();
+        } catch (Exception e) {
+            log.error("Failed to create SSL ignore HTTP client", e);
+        }
+    }
+
+    /**
+     * Get the group ID of the user's user group
+     *
+     * @param userName the username
+     * @return resource-group-id of this user
+     */
     @Override
     public String getUserGroupId(String userName) {
-        return userName;
+        try {
+            String fullPath = this.omsExtensionUrl + "/ui/v1/resource-groups/user/" + userName + "/resource-group";
+            HttpGet httpGet = new HttpGet(fullPath);
+            CloseableHttpResponse response = httpClient.execute(httpGet);
+            String responseBody = EntityUtils.toString(response.getEntity());
+            log.info("response code: {}, response body: {}", response.getCode(), responseBody);
+
+            Resp<List<ResourceGroup>> resp = objectMapper.readValue(responseBody,
+                objectMapper.getTypeFactory().constructParametricType(Resp.class, List.class, ResourceGroup.class));
+
+            if (resp.data() == null || resp.data().isEmpty()) {
+                return null;
+            }
+
+            return resp.data().getFirst().getId();
+        } catch (IOException | ParseException e) {
+            log.error("Failed to get user name from OMS service", e);
+            return null;
+        }
     }
 }