refactor: modify data collection to python implementation (#214)

* feature: LabelStudio jumps without login

* refactor: modify data collection to python implementation

* refactor: modify data collection to python implementation

* refactor: modify data collection to python implementation

* refactor: modify data collection to python implementation

* refactor: modify data collection to python implementation

* refactor: modify data collection to python implementation

* fix: remove terrabase dependency

* feature: add the collection task executions page and the collection template page

* fix: fix the collection task creation

* fix: fix the collection task creation

Author: hefanli

backend/api-gateway/pom.xml

@@ -27,25 +27,6 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-gateway</artifactId>
         </dependency>
-        <dependency>
-            <groupId>com.terrabase</groupId>
-            <artifactId>enterprise-impl-commercial</artifactId>
-            <version>1.0.0</version>
-            <exclusions>
-                <exclusion>
-                    <artifactId>spring-web</artifactId>
-                    <groupId>org.springframework</groupId>
-                </exclusion>
-                <exclusion>
-                    <artifactId>spring-boot-starter-web</artifactId>
-                    <groupId>org.springframework.boot</groupId>
-                </exclusion>
-                <exclusion>
-                    <artifactId>spring-boot-starter-logging</artifactId>
-                    <groupId>org.springframework.boot</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
         <!-- Log4j2 API -->
         <dependency>
             <groupId>org.springframework.boot</groupId>

backend/api-gateway/src/main/java/com/datamate/gateway/ApiGatewayApplication.java

@@ -4,18 +4,14 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.gateway.route.RouteLocator;
 import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
-import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.ComponentScan;
 
 /**
  * API Gateway & Auth Service Application
  * 统一的API网关和认证授权微服务
  * 提供路由、鉴权、限流等功能
  */
 @SpringBootApplication
-@ComponentScan(basePackages = {"com.datamate.gateway", "com.terrabase"})
-@EnableFeignClients(basePackages = {"com.terrabase"})
 public class ApiGatewayApplication {
 
     public static void main(String[] args) {
@@ -37,6 +33,10 @@ public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
             .route("data-evaluation", r -> r.path("/api/evaluation/**")
                 .uri("http://datamate-backend-python:18000"))
 
+            // 数据归集服务路由
+            .route("data-collection", r -> r.path("/api/data-collection/**")
+                    .uri("http://datamate-backend-python:18000"))
+
             .route("deer-flow-frontend", r -> r.path("/chat/**")
                 .uri("http://deer-flow-frontend:3000"))
 

backend/api-gateway/src/main/java/com/datamate/gateway/filter/UserContextFilter.java

@@ -1,9 +1,6 @@
 package com.datamate.gateway.filter;
 
-import com.terrabase.enterprise.api.UserManagementService;
-import com.terrabase.enterprise.api.dto.LoginUserDto;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.gateway.filter.GatewayFilterChain;
 import org.springframework.cloud.gateway.filter.GlobalFilter;
@@ -21,16 +18,13 @@ public class UserContextFilter implements GlobalFilter {
     @Value("${commercial.switch:false}")
     private boolean isCommercial;
 
-    @Autowired
-    private UserManagementService userManagementService;
-
     @Override
     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
         if (!isCommercial) {
             return chain.filter(exchange);
         }
         try {
-            LoginUserDto loginUserDto = userManagementService.getCurrentUserInfo().getData().getFirst();
+
         } catch (Exception e) {
             log.error("get current user info error", e);
             return chain.filter(exchange);