init project

2025-05-16 14:46:48 +08:00
commit b2a5bedb30
1472 changed files with 152747 additions and 0 deletions
--- a/agt-module-infra/agt-module-infra-api/pom.xml
+++ b/agt-module-infra/agt-module-infra-api/pom.xml
@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <groupId>org.agt</groupId>
+        <artifactId>agt-module-infra</artifactId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>agt-module-infra-api</artifactId>
+    <packaging>jar</packaging>
+
+    <name>${project.artifactId}</name>
+    <description>
+        infra 模块 API，暴露给其它模块调用
+    </description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.agt</groupId>
+            <artifactId>agt-common</artifactId>
+        </dependency>
+
+        <!-- Web 相关 -->
+        <dependency>
+            <groupId>org.springdoc</groupId> <!-- 接口文档：使用最新版本的 Swagger 模型 -->
+            <artifactId>springdoc-openapi-starter-webmvc-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <!-- 参数校验 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <!-- RPC 远程调用相关 -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+            <optional>true</optional>
+        </dependency>
+    </dependencies>
+
+</project>
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/config/ConfigApi.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/config/ConfigApi.java
@@ -0,0 +1,21 @@
+package org.agt.module.infra.api.config;
+
+import org.agt.framework.common.pojo.CommonResult;
+import org.agt.module.infra.enums.ApiConstants;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(name = ApiConstants.NAME) // TODO 芋艿：fallbackFactory =
+@Tag(name = "RPC 服务 - 参数配置")
+public interface ConfigApi {
+
+    String PREFIX = ApiConstants.PREFIX + "/config";
+
+    @GetMapping(PREFIX + "/get-value-by-key")
+    @Operation(summary = "根据参数键查询参数值")
+    CommonResult<String> getConfigValueByKey(@RequestParam("key") String key);
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/file/FileApi.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/file/FileApi.java
@@ -0,0 +1,59 @@
+package org.agt.module.infra.api.file;
+
+import org.agt.framework.common.pojo.CommonResult;
+import org.agt.module.infra.api.file.dto.FileCreateReqDTO;
+import org.agt.module.infra.enums.ApiConstants;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotEmpty;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(name = ApiConstants.NAME) // TODO 芋艿：fallbackFactory =
+@Tag(name = "RPC 服务 - 文件")
+public interface FileApi {
+
+    String PREFIX = ApiConstants.PREFIX + "/file";
+
+    /**
+     * 保存文件，并返回文件的访问路径
+     *
+     * @param content 文件内容
+     * @return 文件路径
+     */
+    default String createFile(byte[] content) {
+        return createFile(content, null, null, null);
+    }
+
+    /**
+     * 保存文件，并返回文件的访问路径
+     *
+     * @param content 文件内容
+     * @param name 文件名称，允许空
+     * @return 文件路径
+     */
+    default String createFile(byte[] content, String name) {
+        return createFile(content, name, null, null);
+    }
+
+    /**
+     * 保存文件，并返回文件的访问路径
+     *
+     * @param content 文件内容
+     * @param name 文件名称，允许空
+     * @param directory 目录，允许空
+     * @param type 文件的 MIME 类型，允许空
+     * @return 文件路径
+     */
+    default String createFile(@NotEmpty(message = "文件内容不能为空") byte[] content,
+                              String name, String directory, String type) {
+        return createFile(new FileCreateReqDTO().setName(name).setDirectory(directory).setType(type).setContent(content)).getCheckedData();
+    }
+
+    @PostMapping(PREFIX + "/create")
+    @Operation(summary = "保存文件，并返回文件的访问路径")
+    CommonResult<String> createFile(@Valid @RequestBody FileCreateReqDTO createReqDTO);
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/file/dto/FileCreateReqDTO.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/file/dto/FileCreateReqDTO.java
@@ -0,0 +1,25 @@
+package org.agt.module.infra.api.file.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import jakarta.validation.constraints.NotEmpty;
+
+@Schema(description = "RPC 服务 - 文件创建 Request DTO")
+@Data
+public class FileCreateReqDTO {
+
+    @Schema(description = "原文件名称", example = "xxx.png")
+    private String name;
+
+    @Schema(description = "文件目录", example = "xxx")
+    private String directory;
+
+    @Schema(description = "文件的 MIME 类型", example = "image/png")
+    private String type;
+
+    @Schema(description = "文件内容", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotEmpty(message = "文件内容不能为空")
+    private byte[] content;
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/ApiAccessLogApi.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/ApiAccessLogApi.java
@@ -0,0 +1,35 @@
+package org.agt.module.infra.api.logger;
+
+import org.agt.framework.common.pojo.CommonResult;
+import org.agt.module.infra.api.logger.dto.ApiAccessLogCreateReqDTO;
+import org.agt.module.infra.enums.ApiConstants;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import io.swagger.v3.oas.annotations.Operation;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import jakarta.validation.Valid;
+
+@FeignClient(name = ApiConstants.NAME) // TODO 芋艿：fallbackFactory =
+@Tag(name = "RPC 服务 - API 访问日志")
+public interface ApiAccessLogApi {
+
+    String PREFIX = ApiConstants.PREFIX + "/api-access-log";
+
+    @PostMapping(PREFIX + "/create")
+    @Operation(summary = "创建 API 访问日志")
+    CommonResult<Boolean> createApiAccessLog(@Valid @RequestBody ApiAccessLogCreateReqDTO createDTO);
+
+    /**
+     * 【异步】创建 API 访问日志
+     *
+     * @param createDTO 访问日志 DTO
+     */
+    @Async
+    default void createApiAccessLogAsync(ApiAccessLogCreateReqDTO createDTO) {
+        createApiAccessLog(createDTO).checkError();
+    }
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/ApiErrorLogApi.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/ApiErrorLogApi.java
@@ -0,0 +1,35 @@
+package org.agt.module.infra.api.logger;
+
+import org.agt.framework.common.pojo.CommonResult;
+import org.agt.module.infra.api.logger.dto.ApiErrorLogCreateReqDTO;
+import org.agt.module.infra.enums.ApiConstants;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import io.swagger.v3.oas.annotations.Operation;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import jakarta.validation.Valid;
+
+@FeignClient(name = ApiConstants.NAME) // TODO 芋艿：fallbackFactory =
+@Tag(name = "RPC 服务 - API 异常日志")
+public interface ApiErrorLogApi {
+
+    String PREFIX = ApiConstants.PREFIX + "/api-error-log";
+
+    @PostMapping(PREFIX + "/create")
+    @Operation(summary = "创建 API 异常日志")
+    CommonResult<Boolean> createApiErrorLog(@Valid @RequestBody ApiErrorLogCreateReqDTO createDTO);
+
+    /**
+     * 【异步】创建 API 异常日志
+     *
+     * @param createDTO 异常日志 DTO
+     */
+    @Async
+    default void createApiErrorLogAsync(ApiErrorLogCreateReqDTO createDTO) {
+        createApiErrorLog(createDTO).checkError();
+    }
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/dto/ApiAccessLogCreateReqDTO.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/dto/ApiAccessLogCreateReqDTO.java
@@ -0,0 +1,63 @@
+package org.agt.module.infra.api.logger.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import jakarta.validation.constraints.NotNull;
+import java.time.LocalDateTime;
+
+@Schema(description = "RPC 服务 - API 访问日志创建 Request DTO")
+@Data
+public class ApiAccessLogCreateReqDTO {
+
+    @Schema(description = "链路追踪编号", example = "89aca178-a370-411c-ae02-3f0d672be4ab")
+    private String traceId;
+
+    @Schema(description = "用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
+    private Long userId;
+    @Schema(description = "用户类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer userType;
+    @Schema(description = "应用名", requiredMode = Schema.RequiredMode.REQUIRED, example = "system-server")
+    @NotNull(message = "应用名不能为空")
+    private String applicationName;
+
+    @Schema(description = "请求方法名", requiredMode = Schema.RequiredMode.REQUIRED, example = "GET")
+    @NotNull(message = "http 请求方法不能为空")
+    private String requestMethod;
+    @Schema(description = "请求地址", requiredMode = Schema.RequiredMode.REQUIRED, example = "/xxx/yyy")
+    @NotNull(message = "访问地址不能为空")
+    private String requestUrl;
+    @Schema(description = "请求参数")
+    private String requestParams;
+    @Schema(description = "响应结果")
+    private String responseBody;
+    @Schema(description = "用户 IP", requiredMode = Schema.RequiredMode.REQUIRED, example = "127.0.0.1")
+    @NotNull(message = "ip 不能为空")
+    private String userIp;
+    @Schema(description = "浏览器 UserAgent", requiredMode = Schema.RequiredMode.REQUIRED, example = "Mozilla/5.0")
+    @NotNull(message = "User-Agent 不能为空")
+    private String userAgent;
+
+    @Schema(description = "操作模块", requiredMode = Schema.RequiredMode.REQUIRED, example = "商品模块")
+    private String operateModule;
+    @Schema(description = "操作名", requiredMode = Schema.RequiredMode.REQUIRED, example = "商品新增")
+    private String operateName;
+    @Schema(description = "操作分类", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer operateType; // 参见 OperateTypeEnum 枚举
+
+    @Schema(description = "开始时间",requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "开始请求时间不能为空")
+    private LocalDateTime beginTime;
+    @Schema(description = "结束时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "结束请求时间不能为空")
+    private LocalDateTime endTime;
+    @Schema(description = "执行时长，单位：毫秒", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "执行时长不能为空")
+    private Integer duration;
+    @Schema(description = "结果码", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "错误码不能为空")
+    private Integer resultCode;
+    @Schema(description = "结果提示")
+    private String resultMsg;
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/dto/ApiErrorLogCreateReqDTO.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/logger/dto/ApiErrorLogCreateReqDTO.java
@@ -0,0 +1,68 @@
+package org.agt.module.infra.api.logger.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import jakarta.validation.constraints.NotNull;
+import java.time.LocalDateTime;
+
+@Schema(description = "RPC 服务 - API 错误日志创建 Request DTO")
+@Data
+public class ApiErrorLogCreateReqDTO {
+
+    @Schema(description = "链路追踪编号", example = "89aca178-a370-411c-ae02-3f0d672be4ab")
+    private String traceId;
+
+    @Schema(description = "用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
+    private Long userId;
+    @Schema(description = "用户类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer userType;
+    @Schema(description = "应用名", requiredMode = Schema.RequiredMode.REQUIRED, example = "system-server")
+    @NotNull(message = "应用名不能为空")
+    private String applicationName;
+
+    @Schema(description = "请求方法名", requiredMode = Schema.RequiredMode.REQUIRED, example = "GET")
+    @NotNull(message = "http 请求方法不能为空")
+    private String requestMethod;
+    @Schema(description = "请求地址", requiredMode = Schema.RequiredMode.REQUIRED, example = "/xxx/yyy")
+    @NotNull(message = "访问地址不能为空")
+    private String requestUrl;
+    @Schema(description = "请求参数", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "请求参数不能为空")
+    private String requestParams;
+    @Schema(description = "用户 IP", requiredMode = Schema.RequiredMode.REQUIRED, example = "127.0.0.1")
+    @NotNull(message = "ip 不能为空")
+    private String userIp;
+    @Schema(description = "浏览器 UserAgent", requiredMode = Schema.RequiredMode.REQUIRED, example = "Mozilla/5.0")
+    @NotNull(message = "User-Agent 不能为空")
+    private String userAgent;
+
+    @Schema(description = "异常时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常时间不能为空")
+    private LocalDateTime exceptionTime;
+    @Schema(description = "异常名", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常名不能为空")
+    private String exceptionName;
+    @Schema(description = "异常发生的类全名", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常发生的类全名不能为空")
+    private String exceptionClassName;
+    @Schema(description = "异常发生的类文件", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常发生的类文件不能为空")
+    private String exceptionFileName;
+    @Schema(description = "异常发生的方法名", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常发生的方法名不能为空")
+    private String exceptionMethodName;
+    @Schema(description = "异常发生的方法所在行", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常发生的方法所在行不能为空")
+    private Integer exceptionLineNumber;
+    @Schema(description = "异常的栈轨迹异常的栈轨迹", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常的栈轨迹不能为空")
+    private String exceptionStackTrace;
+    @Schema(description = "异常导致的根消息", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常导致的根消息不能为空")
+    private String exceptionRootCauseMessage;
+    @Schema(description = "异常导致的消息", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotNull(message = "异常导致的消息不能为空")
+    private String exceptionMessage;
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/package-info.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/package-info.java
@@ -0,0 +1,4 @@
+/**
+ * infra API 包，定义暴露给其它模块的 API
+ */
+package org.agt.module.infra.api;
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/websocket/WebSocketSenderApi.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/websocket/WebSocketSenderApi.java
@@ -0,0 +1,74 @@
+package org.agt.module.infra.api.websocket;
+
+import org.agt.framework.common.pojo.CommonResult;
+import org.agt.framework.common.util.json.JsonUtils;
+import org.agt.module.infra.api.websocket.dto.WebSocketSendReqDTO;
+import org.agt.module.infra.enums.ApiConstants;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import jakarta.validation.Valid;
+
+@FeignClient(name = ApiConstants.NAME) // TODO 芋艿：fallbackFactory =
+@Tag(name = "RPC 服务 - WebSocket 发送器的") // 对 WebSocketMessageSender 进行封装，提供给其它模块使用
+public interface WebSocketSenderApi {
+
+    String PREFIX = ApiConstants.PREFIX + "/websocket";
+
+    @PostMapping(PREFIX + "/send")
+    @Operation(summary = "发送 WebSocket 消息")
+    CommonResult<Boolean> send(@Valid @RequestBody WebSocketSendReqDTO message);
+
+    /**
+     * 发送消息给指定用户
+     *
+     * @param userType 用户类型
+     * @param userId 用户编号
+     * @param messageType 消息类型
+     * @param messageContent 消息内容，JSON 格式
+     */
+    default void send(Integer userType, Long userId, String messageType, String messageContent) {
+        send(new WebSocketSendReqDTO().setUserType(userType).setUserId(userId)
+                .setMessageType(messageType).setMessageContent(messageContent)).checkError();
+    }
+
+    /**
+     * 发送消息给指定用户类型
+     *
+     * @param userType 用户类型
+     * @param messageType 消息类型
+     * @param messageContent 消息内容，JSON 格式
+     */
+    default void send(Integer userType, String messageType, String messageContent) {
+        send(new WebSocketSendReqDTO().setUserType(userType)
+                .setMessageType(messageType).setMessageContent(messageContent)).checkError();
+    }
+
+    /**
+     * 发送消息给指定 Session
+     *
+     * @param sessionId Session 编号
+     * @param messageType 消息类型
+     * @param messageContent 消息内容，JSON 格式
+     */
+    default void send(String sessionId, String messageType, String messageContent) {
+        send(new WebSocketSendReqDTO().setSessionId(sessionId)
+                .setMessageType(messageType).setMessageContent(messageContent)).checkError();
+    }
+
+    default void sendObject(Integer userType, Long userId, String messageType, Object messageContent) {
+        send(userType, userId, messageType, JsonUtils.toJsonString(messageContent));
+    }
+
+    default void sendObject(Integer userType, String messageType, Object messageContent) {
+        send(userType, messageType, JsonUtils.toJsonString(messageContent));
+    }
+
+    default void sendObject(String sessionId, String messageType, Object messageContent) {
+        send(sessionId, messageType, JsonUtils.toJsonString(messageContent));
+    }
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/websocket/dto/WebSocketSendReqDTO.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/api/websocket/dto/WebSocketSendReqDTO.java
@@ -0,0 +1,26 @@
+package org.agt.module.infra.api.websocket.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import jakarta.validation.constraints.NotEmpty;
+
+@Schema(description = "RPC 服务 - WebSocket 消息发送 Request DTO")
+@Data
+public class WebSocketSendReqDTO {
+
+    @Schema(description = "Session 编号", example = "abc")
+    private String sessionId;
+    @Schema(description = "用户编号", example = "1024")
+    private Long userId;
+    @Schema(description = "用户类型", example = "1")
+    private Integer userType;
+
+    @Schema(description = "消息类型", example = "demo-message")
+    @NotEmpty(message = "消息类型不能为空")
+    private String messageType;
+    @Schema(description = "消息内容", example = "{\"name\":\"李四\"}}")
+    @NotEmpty(message = "消息内容不能为空")
+    private String messageContent;
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/enums/ApiConstants.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/enums/ApiConstants.java
@@ -0,0 +1,23 @@
+package org.agt.module.infra.enums;
+
+import org.agt.framework.common.enums.RpcConstants;
+
+/**
+ * API 相关的枚举
+ *
+ * @author 千通源码
+ */
+public class ApiConstants {
+
+    /**
+     * 服务名
+     *
+     * 注意，需要保证和 spring.application.name 保持一致
+     */
+    public static final String NAME = "infra-server";
+
+    public static final String PREFIX = RpcConstants.RPC_API_PREFIX + "/infra";
+
+    public static final String VERSION = "1.0.0";
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/enums/DictTypeConstants.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/enums/DictTypeConstants.java
@@ -0,0 +1,20 @@
+package org.agt.module.infra.enums;
+
+/**
+ * Infra 字典类型的枚举类
+ *
+ * @author 千通源码
+ */
+public interface DictTypeConstants {
+
+    String JOB_STATUS = "infra_job_status"; // 定时任务状态的枚举
+    String JOB_LOG_STATUS = "infra_job_log_status"; // 定时任务日志状态的枚举
+
+    String API_ERROR_LOG_PROCESS_STATUS = "infra_api_error_log_process_status"; // API 错误日志的处理状态的枚举
+
+    String CONFIG_TYPE = "infra_config_type"; // 参数配置类型
+    String BOOLEAN_STRING = "infra_boolean_string"; // Boolean 是否类型
+
+    String OPERATE_TYPE = "infra_operate_type"; // 操作类型
+
+}
--- a/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/enums/ErrorCodeConstants.java
+++ b/agt-module-infra/agt-module-infra-api/src/main/java/org/agt/module/infra/enums/ErrorCodeConstants.java
@@ -0,0 +1,71 @@
+package org.agt.module.infra.enums;
+
+import org.agt.framework.common.exception.ErrorCode;
+
+/**
+ * Infra 错误码枚举类
+ *
+ * infra 系统，使用 1-001-000-000 段
+ */
+public interface ErrorCodeConstants {
+
+    // ========== 参数配置 1-001-000-000 ==========
+    ErrorCode CONFIG_NOT_EXISTS = new ErrorCode(1_001_000_001, "参数配置不存在");
+    ErrorCode CONFIG_KEY_DUPLICATE = new ErrorCode(1_001_000_002, "参数配置 key 重复");
+    ErrorCode CONFIG_CAN_NOT_DELETE_SYSTEM_TYPE = new ErrorCode(1_001_000_003, "不能删除类型为系统内置的参数配置");
+    ErrorCode CONFIG_GET_VALUE_ERROR_IF_VISIBLE = new ErrorCode(1_001_000_004, "获取参数配置失败，原因：不允许获取不可见配置");
+
+    // ========== 定时任务 1-001-001-000 ==========
+    ErrorCode JOB_NOT_EXISTS = new ErrorCode(1_001_001_000, "定时任务不存在");
+    ErrorCode JOB_HANDLER_EXISTS = new ErrorCode(1_001_001_001, "定时任务的处理器已经存在");
+    ErrorCode JOB_CHANGE_STATUS_INVALID = new ErrorCode(1_001_001_002, "只允许修改为开启或者关闭状态");
+    ErrorCode JOB_CHANGE_STATUS_EQUALS = new ErrorCode(1_001_001_003, "定时任务已经处于该状态，无需修改");
+    ErrorCode JOB_UPDATE_ONLY_NORMAL_STATUS = new ErrorCode(1_001_001_004, "只有开启状态的任务，才可以修改");
+    ErrorCode JOB_CRON_EXPRESSION_VALID = new ErrorCode(1_001_001_005, "CRON 表达式不正确");
+    ErrorCode JOB_HANDLER_BEAN_NOT_EXISTS = new ErrorCode(1_001_001_006, "定时任务的处理器 Bean 不存在，注意 Bean 默认首字母小写");
+    ErrorCode JOB_HANDLER_BEAN_TYPE_ERROR = new ErrorCode(1_001_001_007, "定时任务的处理器 Bean 类型不正确，未实现 JobHandler 接口");
+
+    // ========== API 错误日志 1-001-002-000 ==========
+    ErrorCode API_ERROR_LOG_NOT_FOUND = new ErrorCode(1_001_002_000, "API 错误日志不存在");
+    ErrorCode API_ERROR_LOG_PROCESSED = new ErrorCode(1_001_002_001, "API 错误日志已处理");
+
+    // ========= 文件相关 1-001-003-000 =================
+    ErrorCode FILE_PATH_EXISTS = new ErrorCode(1_001_003_000, "文件路径已存在");
+    ErrorCode FILE_NOT_EXISTS = new ErrorCode(1_001_003_001, "文件不存在");
+    ErrorCode FILE_IS_EMPTY = new ErrorCode(1_001_003_002, "文件为空");
+
+    // ========== 代码生成器 1-001-004-000 ==========
+    ErrorCode CODEGEN_TABLE_EXISTS = new ErrorCode(1_001_004_002, "表定义已经存在");
+    ErrorCode CODEGEN_IMPORT_TABLE_NULL = new ErrorCode(1_001_004_001, "导入的表不存在");
+    ErrorCode CODEGEN_IMPORT_COLUMNS_NULL = new ErrorCode(1_001_004_002, "导入的字段不存在");
+    ErrorCode CODEGEN_TABLE_NOT_EXISTS = new ErrorCode(1_001_004_004, "表定义不存在");
+    ErrorCode CODEGEN_COLUMN_NOT_EXISTS = new ErrorCode(1_001_004_005, "字段义不存在");
+    ErrorCode CODEGEN_SYNC_COLUMNS_NULL = new ErrorCode(1_001_004_006, "同步的字段不存在");
+    ErrorCode CODEGEN_SYNC_NONE_CHANGE = new ErrorCode(1_001_004_007, "同步失败，不存在改变");
+    ErrorCode CODEGEN_TABLE_INFO_TABLE_COMMENT_IS_NULL = new ErrorCode(1_001_004_008, "数据库的表注释未填写");
+    ErrorCode CODEGEN_TABLE_INFO_COLUMN_COMMENT_IS_NULL = new ErrorCode(1_001_004_009, "数据库的表字段({})注释未填写");
+    ErrorCode CODEGEN_MASTER_TABLE_NOT_EXISTS = new ErrorCode(1_001_004_010, "主表(id={})定义不存在，请检查");
+    ErrorCode CODEGEN_SUB_COLUMN_NOT_EXISTS = new ErrorCode(1_001_004_011, "子表的字段(id={})不存在，请检查");
+    ErrorCode CODEGEN_MASTER_GENERATION_FAIL_NO_SUB_TABLE = new ErrorCode(1_001_004_012, "主表生成代码失败，原因：它没有子表");
+
+    // ========== 文件配置 1-001-006-000 ==========
+    ErrorCode FILE_CONFIG_NOT_EXISTS = new ErrorCode(1_001_006_000, "文件配置不存在");
+    ErrorCode FILE_CONFIG_DELETE_FAIL_MASTER = new ErrorCode(1_001_006_001, "该文件配置不允许删除，原因：它是主配置，删除会导致无法上传文件");
+
+    // ========== 数据源配置 1-001-007-000 ==========
+    ErrorCode DATA_SOURCE_CONFIG_NOT_EXISTS = new ErrorCode(1_001_007_000, "数据源配置不存在");
+    ErrorCode DATA_SOURCE_CONFIG_NOT_OK = new ErrorCode(1_001_007_001, "数据源配置不正确，无法进行连接");
+
+    // ========== 学生 1-001-201-000 ==========
+    ErrorCode DEMO01_CONTACT_NOT_EXISTS = new ErrorCode(1_001_201_000, "示例联系人不存在");
+    ErrorCode DEMO02_CATEGORY_NOT_EXISTS = new ErrorCode(1_001_201_001, "示例分类不存在");
+    ErrorCode DEMO02_CATEGORY_EXITS_CHILDREN = new ErrorCode(1_001_201_002, "存在存在子示例分类，无法删除");
+    ErrorCode DEMO02_CATEGORY_PARENT_NOT_EXITS = new ErrorCode(1_001_201_003,"父级示例分类不存在");
+    ErrorCode DEMO02_CATEGORY_PARENT_ERROR = new ErrorCode(1_001_201_004, "不能设置自己为父示例分类");
+    ErrorCode DEMO02_CATEGORY_NAME_DUPLICATE = new ErrorCode(1_001_201_005, "已经存在该名字的示例分类");
+    ErrorCode DEMO02_CATEGORY_PARENT_IS_CHILD = new ErrorCode(1_001_201_006, "不能设置自己的子示例分类为父示例分类");
+    ErrorCode DEMO03_STUDENT_NOT_EXISTS = new ErrorCode(1_001_201_007, "学生不存在");
+    ErrorCode DEMO03_GRADE_NOT_EXISTS = new ErrorCode(1_001_201_008, "学生班级不存在");
+    ErrorCode DEMO03_GRADE_EXISTS = new ErrorCode(1_001_201_009, "学生班级已存在");
+
+}