算子市场列表查询

Author: hhhhsc701

backend/openapi/specs/operator-market.yaml

@@ -47,6 +47,9 @@ paths:
                 labelName:
                   type: string
                   description: 标签名称
+                isStar:
+                  type: boolean
+                  description: 是否收藏
               required:
                 - page
                 - size
@@ -478,15 +481,9 @@ components:
         description:
           type: string
           description: 算子描述
-        language:
-          type: string
-          description: 开发语言
         version:
           type: string
           description: 算子版本
-        modal:
-          type: string
-          description: 模态
         inputs:
           type: string
           description: 输入类型

backend/services/operator-market-service/src/main/java/com/dataengine/operator/domain/modal/Operator.java

@@ -14,12 +14,8 @@ public class Operator {
 
     private String description;
 
-    private String language;
-
     private String version;
 
-    private String modal;
-
     private String inputs;
 
     private String outputs;

backend/services/operator-market-service/src/main/java/com/dataengine/operator/infrastructure/persistence/mapper/OperatorMapper.java

@@ -2,10 +2,16 @@
 
 import com.dataengine.operator.domain.modal.Operator;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
 @Mapper
 public interface OperatorMapper {
     List<Operator> findAllOperators();
+
+    List<Operator> findOperatorsByCriteria(@Param("size") Integer size, @Param("offset") Integer offset,
+                                           @Param("operatorName") String operatorName,
+                                           @Param("categories") List<Integer> categories,
+                                           @Param("isStar") Boolean isStar);
 }

backend/services/operator-market-service/src/main/java/com/dataengine/operator/interfaces/api/OperatorController.java

@@ -6,7 +6,6 @@
 import com.dataengine.operator.interfaces.dto.*;
 import com.dataengine.operator.application.OperatorService;
 import lombok.RequiredArgsConstructor;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.multipart.MultipartFile;
@@ -22,8 +21,10 @@ public class OperatorController implements OperatorApi {
 
     @Override
     public ResponseEntity<List<OperatorResponse>> operatorsListPost(OperatorsListPostRequest request) {
-        List<Operator> allOperators = operatorMapper.findAllOperators();
-        List<OperatorResponse> responses = allOperators.stream()
+        Integer offset = (request.getPage() - 1) * request.getSize();
+        List<Operator> filteredOperators = operatorMapper.findOperatorsByCriteria(request.getSize(), offset,
+            request.getOperatorName(), request.getCategories(), request.getIsStar());
+        List<OperatorResponse> responses = filteredOperators.stream()
             .map(OperatorConverter.INSTANCE::operatorToResponse).toList();
         return ResponseEntity.ok(responses);
     }
@@ -48,4 +49,3 @@ public ResponseEntity<OperatorResponse> operatorsUploadPost(MultipartFile file,
         return ResponseEntity.ok(operatorService.uploadOperator(file, description));
     }
 }
-

backend/services/operator-market-service/src/main/resources/mappers/OperatorMapper.xml

@@ -3,6 +3,37 @@
 
 <mapper namespace="com.dataengine.operator.infrastructure.persistence.mapper.OperatorMapper">
     <select id="findAllOperators" resultType="com.dataengine.operator.domain.modal.Operator">
-      SELECT id, name, description, language, version, modal, inputs, outputs, runtime, settings, is_star, create_at, update_at FROM t_operator
+      SELECT id, name, description, version, inputs, outputs, runtime, settings, is_star, created_at, updated_at FROM
+        t_operator
+    </select>
+
+    <select id="findOperatorsByCriteria" parameterType="map" resultType="com.dataengine.operator.domain.modal.Operator">
+        SELECT operator_id as id, operator_name as name, description, version, inputs, outputs, runtime, settings,
+            is_star, created_at, updated_at
+        FROM
+        (
+            SELECT operator_id, operator_name, description, version, inputs, outputs, runtime, settings, is_star,
+                created_at, updated_at, ROW_NUMBER() OVER (
+            PARTITION BY operator_id -- 按 id 分组
+            ORDER BY created_at DESC -- 按创建时间降序排列 (最新时间在前)
+        ) AS rn -- 为每组内的行分配序号
+        FROM v_operator
+        <where>
+            <if test="operatorName != null and operatorName != ''">
+                AND operator_name LIKE CONCAT('%', #{operatorName}, '%')
+            </if>
+            <if test="categories != null and !categories.isEmpty()">
+                AND category_id IN
+                <foreach collection="categories" item="category" open="(" separator="," close=")">
+                    #{category}
+                </foreach>
+            </if>
+            <if test="isStar != null">
+                AND is_star = #{isStar}
+            </if>
+        </where>
+        ) ranked_data
+        WHERE rn = 1
+        LIMIT ${size} OFFSET ${offset};
     </select>
 </mapper>

scripts/db/data-engine-operator-init.sql

@@ -2,20 +2,18 @@ USE dataengine;
 
 CREATE TABLE IF NOT EXISTS t_operator
 (
-  id          varchar(64),
+  id          varchar(64) primary key,
   name        varchar(64),
   description varchar(256),
-  language    varchar(256),
   version     varchar(256),
-  modal       varchar(256),
   inputs      varchar(256),
   outputs     varchar(256),
   runtime     text,
   settings    text,
   file_name   text,
   is_star     bool,
-  create_at   timestamp,
-  update_at   timestamp
+  created_at   timestamp default current_timestamp,
+  updated_at   timestamp default current_timestamp
 );
 
 CREATE TABLE IF NOT EXISTS t_operator_category
@@ -33,3 +31,46 @@ CREATE TABLE IF NOT EXISTS t_operator_category_relation
   operator_id varchar(64)
 );
 
+CREATE OR REPLACE VIEW v_operator AS
+SELECT
+  o.id AS operator_id,
+  o.name AS operator_name,
+  description,
+  version,
+  inputs,
+  outputs,
+  runtime,
+  settings,
+  is_star,
+  created_at,
+  updated_at,
+  toc.id AS category_id,
+  toc.name AS category_name
+FROM t_operator_category_relation tocr
+LEFT JOIN t_operator o ON tocr.operator_id = o.id
+LEFT JOIN t_operator_category toc ON tocr.category_id = toc.id;
+
+INSERT IGNORE INTO t_operator_category(id, name, type, parent_id) VALUES
+(1, 'modal', 'predefined', 0),
+(2, 'language', 'predefined', 0),
+(3, 'text', 'predefined', 1),
+(4, 'image', 'predefined', 1),
+(5, 'audio', 'predefined', 1),
+(6, 'video', 'predefined', 1),
+(7, 'multimodal', 'predefined', 1),
+(8, 'python', 'predefined', 2),
+(9, 'java', 'predefined', 2);
+
+INSERT IGNORE INTO t_operator
+  (id, name, description, version, inputs, outputs, runtime, settings, file_name, is_star) VALUES
+('TestOp1', 'TestOp1', '', '1.0.0', 'text', 'text', '', '', '', false),
+('TestOp2', 'TestOp2', '', '1.0.0', 'text', 'text', '', '', '', false),
+('TestOp3', 'TestOp3', '', '1.0.0', 'text', 'text', '', '', '', false);
+
+INSERT IGNORE INTO t_operator_category_relation(category_id, operator_id) VALUES
+(3, 'TestOp1'),
+(3, 'TestOp2'),
+(3, 'TestOp3'),
+(8, 'TestOp1'),
+(8, 'TestOp2'),
+(9, 'TestOp3');