diff --git a/src/main/java/com/afe/dc/tranlog/config/AsyncConfig.java b/src/main/java/com/afe/dc/tranlog/config/AsyncConfig.java index 43b20ea..c181dad 100644 --- a/src/main/java/com/afe/dc/tranlog/config/AsyncConfig.java +++ b/src/main/java/com/afe/dc/tranlog/config/AsyncConfig.java @@ -12,6 +12,7 @@ import java.util.concurrent.ThreadPoolExecutor; /** * 异步配置类 * 对应C++的线程池配置 + * @author ben.yang */ @Slf4j @Configuration diff --git a/src/main/java/com/afe/dc/tranlog/config/MulticastConfig.java b/src/main/java/com/afe/dc/tranlog/config/MulticastConfig.java index e589105..5acd7af 100644 --- a/src/main/java/com/afe/dc/tranlog/config/MulticastConfig.java +++ b/src/main/java/com/afe/dc/tranlog/config/MulticastConfig.java @@ -10,6 +10,7 @@ import java.util.List; /** * UDP多播接收配置 * 对应C++的LoadConfig中的配置项 + * @author ben.yang */ @Data @Configuration diff --git a/src/main/java/com/afe/dc/tranlog/config/ScheduleConfig.java b/src/main/java/com/afe/dc/tranlog/config/ScheduleConfig.java index 1dbdbb3..2a08e5f 100644 --- a/src/main/java/com/afe/dc/tranlog/config/ScheduleConfig.java +++ b/src/main/java/com/afe/dc/tranlog/config/ScheduleConfig.java @@ -7,6 +7,7 @@ import org.springframework.scheduling.annotation.EnableScheduling; /** * 定时任务配置类 * 对应C++的定时器配置 + * @author ben.yang */ @Slf4j @Configuration diff --git a/src/main/java/com/afe/dc/tranlog/controller/internal/DataQueryController.java b/src/main/java/com/afe/dc/tranlog/controller/internal/DataQueryController.java index 1e780d9..7631d80 100644 --- a/src/main/java/com/afe/dc/tranlog/controller/internal/DataQueryController.java +++ b/src/main/java/com/afe/dc/tranlog/controller/internal/DataQueryController.java @@ -17,6 +17,7 @@ import java.util.List; /** * 数据查询控制器 * 提供交易数据查询接口 + * @author ben.yang */ @Slf4j @RestController diff --git a/src/main/java/com/afe/dc/tranlog/controller/internal/DataReceiverController.java b/src/main/java/com/afe/dc/tranlog/controller/internal/DataReceiverController.java index 75b506e..e5b08f4 100644 --- a/src/main/java/com/afe/dc/tranlog/controller/internal/DataReceiverController.java +++ b/src/main/java/com/afe/dc/tranlog/controller/internal/DataReceiverController.java @@ -11,6 +11,7 @@ import org.springframework.web.bind.annotation.*; * 数据接收控制器 * 对应C++的CallbackFunc回调函数 * 接收实时交易数据 + * @author ben.yang */ @Slf4j @RestController diff --git a/src/main/java/com/afe/dc/tranlog/controller/internal/JobController.java b/src/main/java/com/afe/dc/tranlog/controller/internal/JobController.java index 791a04d..92c1252 100644 --- a/src/main/java/com/afe/dc/tranlog/controller/internal/JobController.java +++ b/src/main/java/com/afe/dc/tranlog/controller/internal/JobController.java @@ -10,6 +10,7 @@ import org.springframework.web.bind.annotation.*; * 供 dc-job-service 通过 Feign 调用执行任务 * * @author stock-system + * @author ben.yang */ @Slf4j @RestController diff --git a/src/main/java/com/afe/dc/tranlog/controller/internal/TradeDayController.java b/src/main/java/com/afe/dc/tranlog/controller/internal/TradeDayController.java index 7823b1b..f461707 100644 --- a/src/main/java/com/afe/dc/tranlog/controller/internal/TradeDayController.java +++ b/src/main/java/com/afe/dc/tranlog/controller/internal/TradeDayController.java @@ -11,6 +11,7 @@ import java.time.LocalDate; /** * 交易日管理控制器 + * @author ben.yang */ @Slf4j @RestController diff --git a/src/main/java/com/afe/dc/tranlog/domain/dto/AccumulatedData.java b/src/main/java/com/afe/dc/tranlog/domain/dto/AccumulatedData.java index 116639c..c37d213 100644 --- a/src/main/java/com/afe/dc/tranlog/domain/dto/AccumulatedData.java +++ b/src/main/java/com/afe/dc/tranlog/domain/dto/AccumulatedData.java @@ -10,6 +10,7 @@ import java.io.Serializable; /** * 累计数据DTO * 对应C++的CAccumulatedLogic计算结果 + * @author ben.yang */ @Data @Builder diff --git a/src/main/java/com/afe/dc/tranlog/domain/dto/COPItem.java b/src/main/java/com/afe/dc/tranlog/domain/dto/COPItem.java index 3a67b9c..68ed533 100644 --- a/src/main/java/com/afe/dc/tranlog/domain/dto/COPItem.java +++ b/src/main/java/com/afe/dc/tranlog/domain/dto/COPItem.java @@ -14,6 +14,7 @@ import java.util.Map; * COP数据项DTO * 对应C++的COP_ITEM * 用于数据传输和消息传递 + * @author ben.yang */ @Data @Builder diff --git a/src/main/java/com/afe/dc/tranlog/domain/model/entity/BsRecord.java b/src/main/java/com/afe/dc/tranlog/domain/model/entity/BsRecord.java index 8c00b42..54fb201 100644 --- a/src/main/java/com/afe/dc/tranlog/domain/model/entity/BsRecord.java +++ b/src/main/java/com/afe/dc/tranlog/domain/model/entity/BsRecord.java @@ -10,6 +10,7 @@ import java.io.Serializable; /** * 买卖强度记录实体类 * 对应C++的BsRecord结构体 + * @author ben.yang */ @Data @Builder diff --git a/src/main/java/com/afe/dc/tranlog/domain/model/entity/MtcRecord.java b/src/main/java/com/afe/dc/tranlog/domain/model/entity/MtcRecord.java index 129f5bc..d13247f 100644 --- a/src/main/java/com/afe/dc/tranlog/domain/model/entity/MtcRecord.java +++ b/src/main/java/com/afe/dc/tranlog/domain/model/entity/MtcRecord.java @@ -11,6 +11,7 @@ import java.io.Serializable; * MTC记录实体类 * 对应C++的MtcRecord结构体 * MTC = Minute Transaction Count (分钟交易数据) + * @author ben.yang */ @Data @Builder diff --git a/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranRecord.java b/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranRecord.java index 2643205..56ec0b9 100644 --- a/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranRecord.java +++ b/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranRecord.java @@ -10,6 +10,7 @@ import java.io.Serializable; /** * 交易记录实体类 * 对应C++的CTranRecord + * @author ben.yang */ @Data @Builder diff --git a/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranTable.java b/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranTable.java index 5a14a0d..9a01bc2 100644 --- a/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranTable.java +++ b/src/main/java/com/afe/dc/tranlog/domain/model/entity/TranTable.java @@ -14,6 +14,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; * 交易表实体类 * 对应C++的CTranTable类 * 存储单个交易品种的所有交易记录和业务逻辑数据 + * @author ben.yang */ @Data @Builder diff --git a/src/main/java/com/afe/dc/tranlog/service/AccumulatedLogicService.java b/src/main/java/com/afe/dc/tranlog/service/AccumulatedLogicService.java index 86ad34d..d19e986 100644 --- a/src/main/java/com/afe/dc/tranlog/service/AccumulatedLogicService.java +++ b/src/main/java/com/afe/dc/tranlog/service/AccumulatedLogicService.java @@ -11,6 +11,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; * 累计数据逻辑服务 * 对应C++的CAccumulatedLogic类 * 负责计算累计成交量和成交额 + * @author ben.yang */ @Slf4j @Service diff --git a/src/main/java/com/afe/dc/tranlog/service/BuySellStrengthService.java b/src/main/java/com/afe/dc/tranlog/service/BuySellStrengthService.java index 548c5bf..1cda419 100644 --- a/src/main/java/com/afe/dc/tranlog/service/BuySellStrengthService.java +++ b/src/main/java/com/afe/dc/tranlog/service/BuySellStrengthService.java @@ -11,6 +11,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; * 买卖强度逻辑服务 * 对应C++的CBuySellStrengthLogic类 * 负责计算买卖强度（高/中/低） + * @author ben.yang */ @Slf4j @Service diff --git a/src/main/java/com/afe/dc/tranlog/service/COPParser.java b/src/main/java/com/afe/dc/tranlog/service/COPParser.java index 51f85f2..ed39a5e 100644 --- a/src/main/java/com/afe/dc/tranlog/service/COPParser.java +++ b/src/main/java/com/afe/dc/tranlog/service/COPParser.java @@ -13,6 +13,7 @@ import java.util.Map; * COP协议解析器 * 解析UDP多播接收到的COP协议数据 * 对应C++的MsgObject和COP_ITEM解析逻辑 + * @author ben.yang */ @Slf4j public class COPParser { diff --git a/src/main/java/com/afe/dc/tranlog/service/MTCLogicService.java b/src/main/java/com/afe/dc/tranlog/service/MTCLogicService.java index 12104af..32eccf6 100644 --- a/src/main/java/com/afe/dc/tranlog/service/MTCLogicService.java +++ b/src/main/java/com/afe/dc/tranlog/service/MTCLogicService.java @@ -15,6 +15,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; * MTC逻辑服务 * 对应C++的CMTCLogic类 * 负责计算和生成分钟级交易数据（MTC - Minute Transaction Count） + * @author ben.yang */ @Slf4j @Service diff --git a/src/main/java/com/afe/dc/tranlog/service/TranDatabaseService.java b/src/main/java/com/afe/dc/tranlog/service/TranDatabaseService.java index fa4193d..11ce08d 100644 --- a/src/main/java/com/afe/dc/tranlog/service/TranDatabaseService.java +++ b/src/main/java/com/afe/dc/tranlog/service/TranDatabaseService.java @@ -15,6 +15,7 @@ import java.util.stream.Collectors; * 交易数据库服务 * 对应C++的CTranDatabase类 * 管理所有交易表的集合 + * @author ben.yang */ @Slf4j @Service diff --git a/src/main/java/com/afe/dc/tranlog/service/TranTableService.java b/src/main/java/com/afe/dc/tranlog/service/TranTableService.java index 8b471e0..cce5ea0 100644 --- a/src/main/java/com/afe/dc/tranlog/service/TranTableService.java +++ b/src/main/java/com/afe/dc/tranlog/service/TranTableService.java @@ -15,6 +15,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; * 交易表服务 * 对应C++的CTranTable类 * 管理单个交易品种的数据和业务逻辑 + * @author ben.yang */ @Slf4j @Service diff --git a/src/main/java/com/afe/dc/tranlog/task/ScheduledTask.java b/src/main/java/com/afe/dc/tranlog/task/ScheduledTask.java index bf6dd3a..4480193 100644 --- a/src/main/java/com/afe/dc/tranlog/task/ScheduledTask.java +++ b/src/main/java/com/afe/dc/tranlog/task/ScheduledTask.java @@ -9,6 +9,7 @@ import org.springframework.stereotype.Component; /** * 定时任务类 * 对应C++的定时器事件处理 + * @author ben.yang */ @Slf4j @Component