添加表结构

.gitignore

@@ -31,3 +31,4 @@ build/
 
 ### VS Code ###
 .vscode/
+/logs/

pom.xml

@@ -46,6 +46,11 @@
             <version>0.12.5</version>
             <scope>runtime</scope>
         </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-3-starter</artifactId>
+            <version>1.2.21</version>
+        </dependency>
         <dependency>
             <groupId>org.postgresql</groupId>
             <artifactId>postgresql</artifactId>
@@ -91,5 +96,15 @@
             <artifactId>jackson-databind</artifactId>
             <version>2.15.3</version>
         </dependency>
+        <dependency>
+            <groupId>io.minio</groupId>
+            <artifactId>minio</artifactId>
+            <version>8.2.2</version>
+        </dependency>
+        <!--将http客户端引入httpclient,以提供给spring-ai使用,因为minio引入了okhttp,如果不引入httpclient,会导致自动使用okhttp(okhttp超时时间短,会导致大模型来不及回答消息)-->
+        <dependency>
+            <groupId>org.apache.httpcomponents.client5</groupId>
+            <artifactId>httpclient5</artifactId>
+        </dependency>
     </dependencies>
 </project>

src/main/java/com/supervision/ai/service/hub/config/MinioClientConfig.java

@@ -0,0 +1,75 @@
+package com.supervision.ai.service.hub.config;
+
+import io.minio.MinioClient;
+import io.minio.SetBucketLifecycleArgs;
+import io.minio.errors.*;
+import io.minio.messages.*;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+import java.io.IOException;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.util.List;
+
+/**
+ * Endpoint	对象存储服务的URL
+ * Access Key	Access key就像用户ID，可以唯一标识你的账户。
+ * Secret Key	Secret key是你账户的密码。
+ *
+ * @author qmy
+ * @since 1.0.0
+ */
+@Configuration
+public class MinioClientConfig {
+
+    @Value("${minio.endpoint}")
+    private String endpoint;
+
+    @Value("${minio.accessKey}")
+    private String accessKey;
+
+    @Value("${minio.secretKey}")
+    private String secretKey;
+
+    @Value("${minio.bucketName}")
+    private String bucketName;
+
+    @Bean
+    @Primary
+    public MinioClient minioClient() {
+        MinioClient client = MinioClient.builder()
+                .endpoint(endpoint)
+                .credentials(accessKey, secretKey)
+                .build();
+        try {
+            client.setBucketLifecycle(
+                    SetBucketLifecycleArgs
+                            .builder()
+                            .config(new LifecycleConfiguration(
+                                    List.of(
+                                            new LifecycleRule(Status.ENABLED,
+                                                    null,
+                                                    new Expiration((ResponseDate) null, 1, null),
+                                                    new RuleFilter("temp-"),
+                                                    "TempFileDeleteRule",
+                                                    null,
+                                                    null,
+                                                    null)
+                                    )
+                            ))
+                            .bucket(bucketName)
+                            .build()
+            );
+        } catch (ErrorResponseException | InsufficientDataException | InternalException | InvalidKeyException |
+                 InvalidResponseException | IOException | NoSuchAlgorithmException | ServerException |
+                 XmlParserException e) {
+            throw new RuntimeException(e);
+        }
+        return client;
+    }
+
+}
+

src/main/java/com/supervision/ai/service/hub/controller/SysUserController.java

@@ -2,6 +2,7 @@ package com.supervision.ai.service.hub.controller;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.supervision.ai.service.hub.domain.SysApp;
+import com.supervision.ai.service.hub.domain.SysUser;
 import com.supervision.ai.service.hub.service.impl.SysUserService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
@@ -30,7 +31,7 @@ public class SysUserController {
     public ResponseEntity<?> getCurrentUserDetails() {
         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
         String username = authentication.getName();
-        SysApp user = sysUserService.getOne(new LambdaQueryWrapper<SysApp>().eq(SysApp::getAppName, username));
+        SysUser user = sysUserService.getOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getUserName, username));
         if (user == null) {
             return ResponseEntity.status(404).body("用户不存在");
         }

src/main/java/com/supervision/ai/service/hub/domain/AuditLog.java

@@ -15,7 +15,7 @@ import lombok.Data;
 @Data
 public class AuditLog implements Serializable {
     /**
-     * 主键id
+     * 主键
      */
     @TableId
     private String id;
@@ -26,68 +26,72 @@ public class AuditLog implements Serializable {
     private String recordType;
 
     /**
-     * 应用名称
+     * 
      */
     private String appName;
 
     /**
-     * 用户id
+     * 
      */
     private String userId;
 
+    /**
+     * 
+     */
+    private String appId;
 
     /**
-     * 操作人ip地址
+     * 
      */
     private String ip;
 
     /**
-     * 请求类型 GET POST PUT DELETE
+     * 
      */
     private String method;
 
     /**
-     * url地址
+     * 
      */
     private String url;
 
     /**
-     * 请求参数
+     * 
      */
     private String requestParams;
 
     /**
-     * 操作耗时 单位ms
+     * 
      */
     private Integer costTime;
 
     /**
-     * 响应结果
+     * 
      */
     private String response;
 
     /**
-     * 异常描述
+     * 
      */
     private String exceptionDesc;
 
     /**
-     * 创建时间
+     * 
      */
-    private LocalDateTime createTime;
+    private String createUserId;
 
     /**
-     * 创建人
+     * 
      */
-    private String createUserId;
+    private LocalDateTime createTime;
 
     /**
-     * 更新时间
+     * 
      */
     private LocalDateTime updateTime;
 
     /**
-     * 更新用户id
+     * 
      */
     private String updateUserId;
 

src/main/java/com/supervision/ai/service/hub/domain/ComfyuiPrompt.java

@@ -1,10 +1,8 @@
 package com.supervision.ai.service.hub.domain;
 
 import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.*;
-import com.baomidou.mybatisplus.annotation.TableField;
+
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
 import java.io.Serializable;
 import java.time.LocalDateTime;
 
@@ -12,11 +10,11 @@ import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
 import lombok.Data;
 
 /**
- * comfyui提示词表
+ * 
  * @TableName comfyui_prompt
  */
+@TableName(value ="comfyui_prompt")
 @Data
-@TableName(value ="comfyui_prompt",autoResultMap = true)
 public class ComfyuiPrompt implements Serializable {
     /**
      * 主键
@@ -40,6 +38,11 @@ public class ComfyuiPrompt implements Serializable {
     @TableField(typeHandler = FastjsonTypeHandler.class)
     private JSONObject prompt;
 
+    /**
+     * 创建人id
+     */
+    private String createUserId;
+
     /**
      * 创建时间
      */
@@ -52,7 +55,11 @@ public class ComfyuiPrompt implements Serializable {
     @TableField(fill = FieldFill.INSERT_UPDATE)
     private LocalDateTime updateTime;
 
+    /**
+     * 更新人id
+     */
+    private String updateUserId;
+
     @TableField(exist = false)
     private static final long serialVersionUID = 1L;
-
 }

src/main/java/com/supervision/ai/service/hub/domain/ComfyuiPromptParam.java

@@ -1,28 +1,26 @@
 package com.supervision.ai.service.hub.domain;
 
-import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.*;
-import com.baomidou.mybatisplus.annotation.TableField;
+
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
 import java.io.Serializable;
 import java.time.LocalDateTime;
 import lombok.Data;
 
 /**
- * 
+ * comfyui提示词参数表
  * @TableName comfyui_prompt_param
  */
 @TableName(value ="comfyui_prompt_param")
 @Data
 public class ComfyuiPromptParam implements Serializable {
     /**
-     * 主键
+     * 
      */
     @TableId
     private String id;
 
     /**
-     * varchar(64)
+     * 提示词id
      */
     private String promptId;
 
@@ -31,16 +29,41 @@ public class ComfyuiPromptParam implements Serializable {
      */
     private String paramKey;
 
+    /**
+     * 参数json路径，用户后端设置模板中的值
+     */
+    private String paramPath;
+
     /**
      * 参数类型 0：整数 1：浮点型 2：字符串 3：布尔值
      */
     private Integer paramType;
 
     /**
-     * 是否必填 true：必填 false:非必填
+     * 组件类型，用于前端展示
+     */
+    private String componentType;
+
+    /**
+     * 标签，用于前端展示
+     */
+    private String label;
+
+    /**
+     * 是否必填
      */
     private Boolean required;
 
+    /**
+     * 默认值，用于前端展示
+     */
+    private String defaultValue;
+
+    /**
+     * 创建人id
+     */
+    private String createUserId;
+
     /**
      * 创建时间
      */
@@ -53,7 +76,11 @@ public class ComfyuiPromptParam implements Serializable {
     @TableField(fill = FieldFill.INSERT_UPDATE)
     private LocalDateTime updateTime;
 
+    /**
+     * 更新人id
+     */
+    private String updateUserId;
+
     @TableField(exist = false)
     private static final long serialVersionUID = 1L;
-
 }

src/main/java/com/supervision/ai/service/hub/domain/ComfyuiTask.java

@@ -0,0 +1,82 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * comfyui任务表
+ * @TableName comfyui_task
+ */
+@TableName(value ="comfyui_task")
+@Data
+public class ComfyuiTask implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 提示词id
+     */
+    private String promptId;
+
+    /**
+     * 创建人id
+     */
+    private String userId;
+
+    /**
+     * 应用id
+     */
+    private String appId;
+
+    /**
+     * 运行状态 0未开始、1进行中、2成功、3失败
+     */
+    private String runStatus;
+
+    /**
+     * 开始运行时间
+     */
+    private LocalDate runStartTime;
+
+    /**
+     * 运行结束时间
+     */
+    private LocalDate runEndTime;
+
+    /**
+     * webhook url
+     */
+    private String webHook;
+
+    /**
+     * 创建人id
+     */
+    private String createUserId;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 更新人id
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/domain/ComfyuiTaskParam.java

@@ -0,0 +1,91 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * comfyui任务参数表
+ * @TableName comfyui_task_param
+ */
+@TableName(value ="comfyui_task_param")
+@Data
+public class ComfyuiTaskParam implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 提示词id
+     */
+    private String promptId;
+
+    /**
+     * 任务id
+     */
+    private String taskId;
+
+    /**
+     * 参数key
+     */
+    private String paramKey;
+
+    /**
+     * 参数路径
+     */
+    private String paramPath;
+
+    /**
+     * 参数值
+     */
+    private String value;
+
+    /**
+     * 标签
+     */
+    private String label;
+
+    /**
+     * 是否必填
+     */
+    private Boolean required;
+
+    /**
+     * 参数类型
+     */
+    private String paramType;
+
+    /**
+     * 组件类型
+     */
+    private String componentType;
+
+    /**
+     * 创建人id
+     */
+    private String createUserId;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     *更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 更新人id
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/domain/ComfyuiTaskResult.java

@@ -0,0 +1,56 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 
+ * @TableName comfyui_task_result
+ */
+@TableName(value ="comfyui_task_result")
+@Data
+public class ComfyuiTaskResult implements Serializable {
+    /**
+     * 主键id
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 任务id
+     */
+    private String taskId;
+
+    /**
+     * 结果id
+     */
+    private String resultFileId;
+
+    /**
+     * 创建人id
+     */
+    private String createUserId;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 更新人id
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/domain/SysApp.java

@@ -1,22 +1,60 @@
 package com.supervision.ai.service.hub.domain;
 
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
-import com.baomidou.mybatisplus.annotation.TableId;
+
-import com.baomidou.mybatisplus.annotation.IdType;
+import java.io.Serializable;
-import com.fasterxml.jackson.annotation.JsonIgnore;
+import java.time.LocalDateTime;
 import lombok.Data;
 
+/**
+ * 
+ * @TableName sys_app
+ */
+@TableName(value ="sys_app")
 @Data
-@TableName("sys_app")
+public class SysApp implements Serializable {
-public class SysApp {
+    /**
+     * 主键
+     */
+    private String id;
+
+    /**
+     * 应用名
+     */
+    private String appName;
+
+    /**
+     * 密码
+     */
+    private String password;
+
+    /**
+     * 状态 0:禁用 1:启用
+     */
+    private Integer status;
+
+    /**
+     * 创建人id
+     */
+    private String createUserId;
 
-    @TableId(type = IdType.AUTO)
+    /**
-    private Long id;           // 主键ID
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
 
-    private String appName;   // 应用名称
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
 
-    @JsonIgnore
+    /**
-    private String password;   // 密码 (加密存储)
+     * 更新人id
+     */
+    private String updateUserId;
 
-    private String status;     // 状态 (1表示正常，0表示禁用)
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
 }

src/main/java/com/supervision/ai/service/hub/domain/SysFile.java

@@ -0,0 +1,61 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 系统文件表
+ * @TableName sys_file
+ */
+@TableName(value ="sys_file")
+@Data
+public class SysFile implements Serializable {
+    /**
+     * 主键id
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 文件名
+     */
+    private String fileName;
+
+    /**
+     * 文件大小
+     */
+    private String fileSize;
+
+    /**
+     * 文件类型
+     */
+    private String fileType;
+
+    /**
+     * 创建人id
+     */
+    private String createUserId;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 更新人id
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/domain/SysRole.java

@@ -0,0 +1,60 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 
+ * @TableName sys_role
+ */
+@TableName(value ="sys_role")
+@Data
+public class SysRole implements Serializable {
+    /**
+     * 
+     */
+    private String id;
+
+    /**
+     * 
+     */
+    private String roleName;
+
+    /**
+     * 
+     */
+    private String roleDesc;
+
+    /**
+     * 
+     */
+    private String roleCode;
+
+    /**
+     * 
+     */
+    private String createUserId;
+
+    /**
+     * 
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/domain/SysUser.java

@@ -0,0 +1,66 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 
+ * @TableName sys_user
+ */
+@TableName(value ="sys_user")
+@Data
+public class SysUser implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 
+     */
+    private String appId;
+
+    /**
+     * 用户名
+     */
+    private String userName;
+
+    /**
+     * 密码
+     */
+    private String password;
+
+    /**
+     * 状态 0:禁用 1:启用
+     */
+    private String status;
+
+    /**
+     * 
+     */
+    private String createUserId;
+
+    /**
+     * 
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/domain/SysUserRole.java

@@ -0,0 +1,50 @@
+package com.supervision.ai.service.hub.domain;
+
+import com.baomidou.mybatisplus.annotation.*;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+/**
+ * 
+ * @TableName sys_user_role
+ */
+@TableName(value ="sys_user_role")
+@Data
+public class SysUserRole implements Serializable {
+    /**
+     * 
+     */
+    private String uid;
+
+    /**
+     * 
+     */
+    private String rid;
+
+    /**
+     * 
+     */
+    private String createUserId;
+
+    /**
+     * 
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+    /**
+     * 
+     */
+    private String updateUserId;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/ai/service/hub/filter/JwtAuthenticationFilter.java

@@ -45,8 +45,8 @@ public class JwtAuthenticationFilter extends OncePerRequestFilter {
             if (username != null && SecurityContextHolder.getContext().getAuthentication() == null) {
                 // 根据用户名从数据库加载用户信息
                 UserDetails userDetails = sysUserService.loadUserByUsername(username);
-                // 验证Token的有效性（是否未过期，用户名是否匹配）
+                // 验证Token的有效性（是否未过期）
-                if (jwtUtils.validateToken(token, userDetails)) {
+                if (jwtUtils.isTokenExpired(token)) {
                     // 将用户信息封装到Authentication对象中，标记为已认证
                     UsernamePasswordAuthenticationToken authToken =
                             new UsernamePasswordAuthenticationToken(userDetails, null, userDetails.getAuthorities());

src/main/java/com/supervision/ai/service/hub/mapper/AuditLogMapper.java

@@ -6,7 +6,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 /**
 * @author Administrator
 * @description 针对表【audit_log(日志审计表)】的数据库操作Mapper
-* @createDate 2025-04-08 13:21:37
+* @createDate 2025-04-11 15:51:10
 * @Entity com.supervision.ai.service.hub.domain.AuditLog
 */
 public interface AuditLogMapper extends BaseMapper<AuditLog> {

src/main/java/com/supervision/ai/service/hub/mapper/ComfyuiPromptMapper.java

@@ -5,8 +5,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
 /**
 * @author Administrator
-* @description 针对表【comfyui_prompt(comfyui提示词表)】的数据库操作Mapper
+* @description 针对表【comfyui_prompt】的数据库操作Mapper
-* @createDate 2025-03-31 17:49:56
+* @createDate 2025-04-11 15:51:10
 * @Entity com.supervision.ai.service.hub.domain.ComfyuiPrompt
 */
 public interface ComfyuiPromptMapper extends BaseMapper<ComfyuiPrompt> {

src/main/java/com/supervision/ai/service/hub/mapper/ComfyuiPromptParamMapper.java

@@ -5,8 +5,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
 /**
 * @author Administrator
-* @description 针对表【comfyui_prompt_param】的数据库操作Mapper
+* @description 针对表【comfyui_prompt_param(comfyui提示词参数表)】的数据库操作Mapper
-* @createDate 2025-03-31 17:49:56
+* @createDate 2025-04-11 15:51:10
 * @Entity com.supervision.ai.service.hub.domain.ComfyuiPromptParam
 */
 public interface ComfyuiPromptParamMapper extends BaseMapper<ComfyuiPromptParam> {

src/main/java/com/supervision/ai/service/hub/mapper/ComfyuiTaskMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.ComfyuiTask;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task(comfyui任务表)】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.ComfyuiTask
+*/
+public interface ComfyuiTaskMapper extends BaseMapper<ComfyuiTask> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/ComfyuiTaskParamMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.ComfyuiTaskParam;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task_param(comfyui任务参数表)】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.ComfyuiTaskParam
+*/
+public interface ComfyuiTaskParamMapper extends BaseMapper<ComfyuiTaskParam> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/ComfyuiTaskResultMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.ComfyuiTaskResult;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task_result】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.ComfyuiTaskResult
+*/
+public interface ComfyuiTaskResultMapper extends BaseMapper<ComfyuiTaskResult> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/SysAppMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.SysApp;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【sys_app】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.SysApp
+*/
+public interface SysAppMapper extends BaseMapper<SysApp> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/SysFileMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.SysFile;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【sys_file(系统文件表)】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.SysFile
+*/
+public interface SysFileMapper extends BaseMapper<SysFile> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/SysRoleMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.SysRole;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【sys_role】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.SysRole
+*/
+public interface SysRoleMapper extends BaseMapper<SysRole> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/SysUserMapper.java

@@ -1,10 +1,18 @@
 package com.supervision.ai.service.hub.mapper;
 
-import com.supervision.ai.service.hub.domain.SysApp;
+import com.supervision.ai.service.hub.domain.SysUser;
-import org.apache.ibatis.annotations.Mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
-@Mapper
+/**
-public interface SysUserMapper extends BaseMapper<SysApp> {
+* @author Administrator
-    // 继承BaseMapper后，CRUD方法可直接使用，无需额外定义
+* @description 针对表【sys_user】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.SysUser
+*/
+public interface SysUserMapper extends BaseMapper<SysUser> {
+
 }
+
+
+
+

src/main/java/com/supervision/ai/service/hub/mapper/SysUserRoleMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.ai.service.hub.mapper;
+
+import com.supervision.ai.service.hub.domain.SysUserRole;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【sys_user_role】的数据库操作Mapper
+* @createDate 2025-04-11 15:51:10
+* @Entity com.supervision.ai.service.hub.domain.SysUserRole
+*/
+public interface SysUserRoleMapper extends BaseMapper<SysUserRole> {
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/AuditLogService.java

@@ -7,7 +7,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
 /**
 * @author Administrator
 * @description 针对表【audit_log(日志审计表)】的数据库操作Service
-* @createDate 2025-04-08 13:21:37
+* @createDate 2025-04-11 15:51:10
 */
 public interface AuditLogService extends IService<AuditLog> {
 

src/main/java/com/supervision/ai/service/hub/service/ComfyUIPromptService.java

@@ -5,8 +5,8 @@ import com.baomidou.mybatisplus.extension.service.IService;
 
 /**
 * @author Administrator
-* @description 针对表【comfyui_prompt(comfyui提示词表)】的数据库操作Service
+* @description 针对表【comfyui_prompt】的数据库操作Service
-* @createDate 2025-03-31 17:49:56
+* @createDate 2025-04-11 15:51:10
 */
 public interface ComfyUIPromptService extends IService<ComfyuiPrompt> {
 

src/main/java/com/supervision/ai/service/hub/service/ComfyuiTaskParamService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.ComfyuiTaskParam;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task_param(comfyui任务参数表)】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface ComfyuiTaskParamService extends IService<ComfyuiTaskParam> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/ComfyuiTaskResultService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.ComfyuiTaskResult;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task_result】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface ComfyuiTaskResultService extends IService<ComfyuiTaskResult> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/ComfyuiTaskService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.ComfyuiTask;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task(comfyui任务表)】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface ComfyuiTaskService extends IService<ComfyuiTask> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/SysAppService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.SysApp;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【sys_app】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface SysAppService extends IService<SysApp> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/SysFileService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.SysFile;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【sys_file(系统文件表)】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface SysFileService extends IService<SysFile> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/SysRoleService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.SysRole;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【sys_role】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface SysRoleService extends IService<SysRole> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/SysUserRoleService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.SysUserRole;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【sys_user_role】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface SysUserRoleService extends IService<SysUserRole> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/SysUserService.java

@@ -0,0 +1,13 @@
+package com.supervision.ai.service.hub.service;
+
+import com.supervision.ai.service.hub.domain.SysUser;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【sys_user】的数据库操作Service
+* @createDate 2025-04-11 15:51:10
+*/
+public interface SysUserService extends IService<SysUser> {
+
+}

src/main/java/com/supervision/ai/service/hub/service/impl/AuditLogServiceImpl.java

@@ -10,7 +10,7 @@ import org.springframework.stereotype.Service;
 /**
 * @author Administrator
 * @description 针对表【audit_log(日志审计表)】的数据库操作Service实现
-* @createDate 2025-04-08 13:21:37
+* @createDate 2025-04-11 15:51:10
 */
 @Service
 public class AuditLogServiceImpl extends ServiceImpl<AuditLogMapper, AuditLog>

src/main/java/com/supervision/ai/service/hub/service/impl/ComfyuiTaskParamServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.ComfyuiTaskParam;
+import com.supervision.ai.service.hub.service.ComfyuiTaskParamService;
+import com.supervision.ai.service.hub.mapper.ComfyuiTaskParamMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task_param(comfyui任务参数表)】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class ComfyuiTaskParamServiceImpl extends ServiceImpl<ComfyuiTaskParamMapper, ComfyuiTaskParam>
+    implements ComfyuiTaskParamService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/ComfyuiTaskResultServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.ComfyuiTaskResult;
+import com.supervision.ai.service.hub.service.ComfyuiTaskResultService;
+import com.supervision.ai.service.hub.mapper.ComfyuiTaskResultMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task_result】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class ComfyuiTaskResultServiceImpl extends ServiceImpl<ComfyuiTaskResultMapper, ComfyuiTaskResult>
+    implements ComfyuiTaskResultService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/ComfyuiTaskServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.ComfyuiTask;
+import com.supervision.ai.service.hub.service.ComfyuiTaskService;
+import com.supervision.ai.service.hub.mapper.ComfyuiTaskMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【comfyui_task(comfyui任务表)】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class ComfyuiTaskServiceImpl extends ServiceImpl<ComfyuiTaskMapper, ComfyuiTask>
+    implements ComfyuiTaskService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/SysAppServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.SysApp;
+import com.supervision.ai.service.hub.service.SysAppService;
+import com.supervision.ai.service.hub.mapper.SysAppMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【sys_app】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class SysAppServiceImpl extends ServiceImpl<SysAppMapper, SysApp>
+    implements SysAppService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/SysFileServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.SysFile;
+import com.supervision.ai.service.hub.service.SysFileService;
+import com.supervision.ai.service.hub.mapper.SysFileMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【sys_file(系统文件表)】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class SysFileServiceImpl extends ServiceImpl<SysFileMapper, SysFile>
+    implements SysFileService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/SysRoleServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.SysRole;
+import com.supervision.ai.service.hub.service.SysRoleService;
+import com.supervision.ai.service.hub.mapper.SysRoleMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【sys_role】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class SysRoleServiceImpl extends ServiceImpl<SysRoleMapper, SysRole>
+    implements SysRoleService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/SysUserRoleServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.SysUserRole;
+import com.supervision.ai.service.hub.service.SysUserRoleService;
+import com.supervision.ai.service.hub.mapper.SysUserRoleMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【sys_user_role】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class SysUserRoleServiceImpl extends ServiceImpl<SysUserRoleMapper, SysUserRole>
+    implements SysUserRoleService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/service/impl/SysUserService.java

@@ -3,6 +3,7 @@ package com.supervision.ai.service.hub.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.supervision.ai.service.hub.domain.SysApp;
+import com.supervision.ai.service.hub.domain.SysUser;
 import com.supervision.ai.service.hub.mapper.SysUserMapper;
 import org.springframework.security.authentication.DisabledException;
 import org.springframework.security.core.GrantedAuthority;
@@ -18,7 +19,7 @@ import java.util.List;
 import static com.supervision.ai.service.hub.constant.UserConstant.USER_STATUS_DISABLED;
 
 @Service
-public class SysUserService extends ServiceImpl<SysUserMapper, SysApp> implements UserDetailsService {
+public class SysUserService extends ServiceImpl<SysUserMapper, SysUser> implements UserDetailsService {
 
     /**
      * 根据用户名加载用户信息
@@ -30,7 +31,7 @@ public class SysUserService extends ServiceImpl<SysUserMapper, SysApp> implement
      */
     @Override
     public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
-        SysApp user = this.getOne(new LambdaQueryWrapper<SysApp>().eq(SysApp::getAppName, username));
+        SysUser user = this.getOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getUserName, username));
         if (user == null) {
             throw new UsernameNotFoundException("用户不存在: " + username);
         }
@@ -41,7 +42,7 @@ public class SysUserService extends ServiceImpl<SysUserMapper, SysApp> implement
         // **扩展点**：如需加载用户角色权限，可在此处查询 sys_user_role 表关联的角色，并将角色加入 authorities 列表
         List<GrantedAuthority> authorities = Collections.emptyList();
         // 使用Spring Security提供的User对象作为UserDetails返回
-        return new User(user.getAppName(), user.getPassword(), authorities);
+        return new User(user.getUserName(), user.getPassword(), authorities);
     }
 
 }

src/main/java/com/supervision/ai/service/hub/service/impl/SysUserServiceImpl.java

@@ -0,0 +1,22 @@
+package com.supervision.ai.service.hub.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.ai.service.hub.domain.SysUser;
+import com.supervision.ai.service.hub.service.SysUserService;
+import com.supervision.ai.service.hub.mapper.SysUserMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Administrator
+* @description 针对表【sys_user】的数据库操作Service实现
+* @createDate 2025-04-11 15:51:10
+*/
+@Service
+public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser>
+    implements SysUserService{
+
+}
+
+
+
+

src/main/java/com/supervision/ai/service/hub/util/JwtUtils.java

@@ -49,19 +49,8 @@ public class JwtUtils {
         return jws.getPayload().getSubject();
     }
 
-
-    // 校验Token是否有效
-    public boolean validateToken(String token, UserDetails userDetails) {
-        try {
-            String username = getUsernameFromToken(token);
-            return username.equals(userDetails.getUsername()) && !isTokenExpired(token);
-        } catch (Exception e) {
-            return false;
-        }
-    }
-
     // 判断是否过期
-    private boolean isTokenExpired(String token) {
+    public boolean isTokenExpired(String token) {
         Jws<Claims> jws = Jwts.parser()
                 .verifyWith(secretKey)
                 .build()

src/main/resources/application.yml

@@ -2,10 +2,11 @@ spring:
   application:
     name: ai-service-hub
   datasource:
-    url: jdbc:postgresql://192.168.10.137:54321/ai-service-hub
+    druid:
-    username: postgres
+      url: jdbc:postgresql://192.168.10.137:54321/ai-service-hub
-    password: 123456
+      username: postgres
-    driver-class-name: org.postgresql.Driver
+      password: 123456
+      driver-class-name: org.postgresql.Driver
   servlet:
     multipart:
       max-file-size: 10MB
@@ -35,3 +36,8 @@ comfyUI:
   server:
     ip: 192.168.10.113
     port: 8188
+minio:
+  endpoint: http:192.168.10.137:9002
+  accessKey: admin
+  secretKey: 12345678
+  bucketName: nxfuhsi

src/main/resources/logback-spring.xml

@@ -0,0 +1,75 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration scan="true" scanPeriod="30 seconds">
+
+    <!-- 定义日志文件保存的路径和文件名 -->
+    <property name="LOG_PATH" value="./logs"/>
+    <property name="LOG_FILE" value="${LOG_PATH}/application.log"/>
+    <property name="LOGBACK_LOG_LEVEL" value="INFO"/>
+
+    <!-- 控制台输出，带有颜色 -->
+    <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %highlight(%-5level) %cyan(%logger{36}) - %msg%n</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+    </appender>
+
+    <!-- 日志文件输出 -->
+    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${LOG_FILE}</file>
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_PATH}/application/application.%d{yyyy-MM-dd}.log</fileNamePattern>
+            <maxHistory>30</maxHistory>
+            <totalSizeCap>100MB</totalSizeCap>
+        </rollingPolicy>
+    </appender>
+
+    <!-- 异常错误日志单独输出 -->
+    <appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${LOG_PATH}/error/error.log</file>
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_PATH}/error/error.%d{yyyy-MM-dd}.log</fileNamePattern>
+            <maxHistory>30</maxHistory>
+            <totalSizeCap>100MB</totalSizeCap>
+        </rollingPolicy>
+        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+            <level>ERROR</level>
+        </filter>
+    </appender>
+
+
+    <!-- AOP -->
+    <appender name="AOP_LOG" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${LOG_PATH}/AOP_LOG/AOP_LOG.log</file>
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_PATH}/AOP_LOG/AOP_LOG.%d{yyyy-MM-dd}.log</fileNamePattern>
+            <maxHistory>30</maxHistory>
+            <totalSizeCap>100MB</totalSizeCap>
+        </rollingPolicy>
+    </appender>
+
+
+    <!-- AOP日志输出到AOP文件，不输出到默认日志 -->
+    <logger name="com.supervision.ai.service.hub.aop.RequestLogAop" level="INFO" additivity="false">
+        <appender-ref ref="AOP_LOG"/>
+    </logger>
+
+    <!-- 根日志记录器 -->
+    <root level="${LOGBACK_LOG_LEVEL}">
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="FILE"/>
+        <appender-ref ref="ERROR_FILE"/>
+    </root>
+</configuration>

src/main/resources/mapper/AuditLogMapper.xml

@@ -9,6 +9,7 @@
             <result property="recordType" column="record_type" jdbcType="VARCHAR"/>
             <result property="appName" column="app_name" jdbcType="VARCHAR"/>
             <result property="userId" column="user_id" jdbcType="VARCHAR"/>
+            <result property="appId" column="app_id" jdbcType="VARCHAR"/>
             <result property="ip" column="ip" jdbcType="VARCHAR"/>
             <result property="method" column="method" jdbcType="VARCHAR"/>
             <result property="url" column="url" jdbcType="VARCHAR"/>
@@ -16,18 +17,18 @@
             <result property="costTime" column="cost_time" jdbcType="INTEGER"/>
             <result property="response" column="response" jdbcType="VARCHAR"/>
             <result property="exceptionDesc" column="exception_desc" jdbcType="VARCHAR"/>
-            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
             <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
             <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
             <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
     </resultMap>
 
     <sql id="Base_Column_List">
         id,record_type,app_name,
-        user_id,ip,
+        user_id,app_id,ip,
         method,url,request_params,
         cost_time,response,exception_desc,
-        create_time,create_user_id,update_time,
+        create_user_id,create_time,update_time,
         update_user_id
     </sql>
 </mapper>

src/main/resources/mapper/ComfyuiPromptMapper.xml

@@ -9,12 +9,15 @@
             <result property="promptName" column="prompt_name" jdbcType="VARCHAR"/>
             <result property="promptType" column="prompt_type" jdbcType="VARCHAR"/>
             <result property="prompt" column="prompt" jdbcType="OTHER" typeHandler="com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
             <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
             <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
     </resultMap>
 
     <sql id="Base_Column_List">
         id,prompt_name,prompt_type,
-        prompt,create_time,update_time
+        prompt,create_user_id,create_time,
+        update_time,update_user_id
     </sql>
 </mapper>

src/main/resources/mapper/ComfyuiPromptParamMapper.xml

@@ -8,15 +8,23 @@
             <id property="id" column="id" jdbcType="VARCHAR"/>
             <result property="promptId" column="prompt_id" jdbcType="VARCHAR"/>
             <result property="paramKey" column="param_key" jdbcType="VARCHAR"/>
+            <result property="paramPath" column="param_path" jdbcType="VARCHAR"/>
             <result property="paramType" column="param_type" jdbcType="INTEGER"/>
+            <result property="componentType" column="component_type" jdbcType="VARCHAR"/>
+            <result property="label" column="label" jdbcType="VARCHAR"/>
             <result property="required" column="required" jdbcType="BOOLEAN"/>
+            <result property="defaultValue" column="default_value" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
             <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
             <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
     </resultMap>
 
     <sql id="Base_Column_List">
         id,prompt_id,param_key,
-        param_type,required,create_time,
+        param_path,param_type,component_type,
-        update_time
+        label,required,default_value,
+        create_user_id,create_time,update_time,
+        update_user_id
     </sql>
 </mapper>

src/main/resources/mapper/ComfyuiTaskMapper.xml

@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.ComfyuiTaskMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.ComfyuiTask">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="promptId" column="prompt_id" jdbcType="VARCHAR"/>
+            <result property="userId" column="user_id" jdbcType="VARCHAR"/>
+            <result property="appId" column="app_id" jdbcType="VARCHAR"/>
+            <result property="runStatus" column="run_status" jdbcType="VARCHAR"/>
+            <result property="runStartTime" column="run_start_time" jdbcType="DATE"/>
+            <result property="runEndTime" column="run_end_time" jdbcType="DATE"/>
+            <result property="webHook" column="web_hook" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,prompt_id,user_id,
+        app_id,run_status,run_start_time,
+        run_end_time,web_hook,create_user_id,
+        create_time,update_time,update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/ComfyuiTaskParamMapper.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.ComfyuiTaskParamMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.ComfyuiTaskParam">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="promptId" column="prompt_id" jdbcType="VARCHAR"/>
+            <result property="taskId" column="task_id" jdbcType="VARCHAR"/>
+            <result property="paramKey" column="param_key" jdbcType="VARCHAR"/>
+            <result property="paramPath" column="param_path" jdbcType="VARCHAR"/>
+            <result property="value" column="value" jdbcType="VARCHAR"/>
+            <result property="label" column="label" jdbcType="VARCHAR"/>
+            <result property="required" column="required" jdbcType="BOOLEAN"/>
+            <result property="paramType" column="param_type" jdbcType="VARCHAR"/>
+            <result property="componentType" column="component_type" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,prompt_id,task_id,
+        param_key,param_path,value,
+        label,required,param_type,
+        component_type,create_user_id,create_time,
+        update_time,update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/ComfyuiTaskResultMapper.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.ComfyuiTaskResultMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.ComfyuiTaskResult">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="taskId" column="task_id" jdbcType="VARCHAR"/>
+            <result property="resultFileId" column="result_file_id" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,task_id,result_file_id,
+        create_user_id,create_time,update_time,
+        update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/SysAppMapper.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.SysAppMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.SysApp">
+            <result property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="appName" column="app_name" jdbcType="VARCHAR"/>
+            <result property="password" column="password" jdbcType="VARCHAR"/>
+            <result property="status" column="status" jdbcType="INTEGER"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,app_name,password,
+        status,create_user_id,create_time,
+        update_time,update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/SysFileMapper.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.SysFileMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.SysFile">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="fileName" column="file_name" jdbcType="VARCHAR"/>
+            <result property="fileSize" column="file_size" jdbcType="VARCHAR"/>
+            <result property="fileType" column="file_type" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,file_name,file_size,
+        file_type,create_user_id,create_time,
+        update_time,update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/SysRoleMapper.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.SysRoleMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.SysRole">
+            <result property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="roleName" column="role_name" jdbcType="VARCHAR"/>
+            <result property="roleDesc" column="role_desc" jdbcType="VARCHAR"/>
+            <result property="roleCode" column="role_code" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,role_name,role_desc,
+        role_code,create_user_id,create_time,
+        update_time,update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/SysUserMapper.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.SysUserMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.SysUser">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="appId" column="app_id" jdbcType="VARCHAR"/>
+            <result property="userName" column="user_name" jdbcType="VARCHAR"/>
+            <result property="password" column="password" jdbcType="VARCHAR"/>
+            <result property="status" column="status" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,app_id,user_name,
+        password,status,create_user_id,
+        create_time,update_time,update_user_id
+    </sql>
+</mapper>

src/main/resources/mapper/SysUserRoleMapper.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervision.ai.service.hub.mapper.SysUserRoleMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.ai.service.hub.domain.SysUserRole">
+            <id property="uid" column="uid" jdbcType="VARCHAR"/>
+            <id property="rid" column="rid" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        uid,rid,create_user_id,
+        create_time,update_time,update_user_id
+    </sql>
+</mapper>

src/test/java/com/supervision/ai/service/hub/AiServiceHubApplicationTests.java

@@ -1,13 +1,28 @@
 package com.supervision.ai.service.hub;
 
+import io.minio.MinioClient;
+import io.minio.errors.*;
+import io.minio.messages.Bucket;
+import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
+import java.io.IOException;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.util.List;
+
+@Slf4j
 @SpringBootTest
 class AiServiceHubApplicationTests {
 
+	@Autowired
+	private MinioClient minioClient;
 	@Test
-	void contextLoads() {
+	void minioTest() throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
+		List<Bucket> buckets = minioClient.listBuckets();
+		log.info("buckets size :{}", buckets.size());
 	}
 
 }