【项目开发】

1.增加实体类，及其对应的mapper、service类
2.完善技术文档中的表设计
3.增加数据库schema.sql文件

data-easy/src/main/java/com/dataeasy/server/atomic/entity/DataDaLeTou.java

@@ -0,0 +1,213 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 大乐透数据表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "data_da_le_tou")
+public class DataDaLeTou extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1105376426165091701L;
+
+    /**
+     * 开奖号码，以竖杠隔开
+     */
+    @Column(name = "number")
+    private String number;
+
+    /**
+     * 特别号码1，第一个尾号
+     */
+    @Column(name = "number1")
+    private String number1;
+
+    /**
+     * 特别号码2，第二个尾号
+     */
+    @Column(name = "number2")
+    private String number2;
+
+    /**
+     * 期号
+     */
+    @Column(name = "qihao")
+    private String qihao;
+
+    /**
+     * 开奖日期
+     */
+    @Column(name = "time")
+    private Date time;
+
+    /**
+     * 一等奖注数
+     */
+    @Column(name = "no1num")
+    private Integer no1num;
+
+    /**
+     * 二等奖注数
+     */
+    @Column(name = "no2num")
+    private Integer no2num;
+
+    /**
+     * 三等奖注数
+     */
+    @Column(name = "no3num")
+    private Integer no3num;
+
+    /**
+     * 四等奖注数
+     */
+    @Column(name = "no4num")
+    private Integer no4num;
+
+    /**
+     * 五等奖注数
+     */
+    @Column(name = "no5num")
+    private Integer no5num;
+
+    /**
+     * 六等奖注数
+     */
+    @Column(name = "no6num")
+    private Integer no6num;
+
+    /**
+     * 七等奖注数
+     */
+    @Column(name = "no7num")
+    private Integer no7num;
+
+    /**
+     * 八等奖注数
+     */
+    @Column(name = "no8num")
+    private Integer no8num;
+
+    /**
+     * 九等奖注数
+     */
+    @Column(name = "no9num")
+    private Integer no9num;
+
+    /**
+     * 一等奖金额
+     */
+    @Column(name = "no1money")
+    private BigDecimal no1money;
+
+    /**
+     * 二等奖金额
+     */
+    @Column(name = "no2money")
+    private BigDecimal no2money;
+
+    /**
+     * 三等奖金额
+     */
+    @Column(name = "no3money")
+    private BigDecimal no3money;
+
+    /**
+     * 四等奖金额
+     */
+    @Column(name = "no4money")
+    private BigDecimal no4money;
+
+    /**
+     * 五等奖金额
+     */
+    @Column(name = "no5money")
+    private BigDecimal no5money;
+
+    /**
+     * 六等奖金额
+     */
+    @Column(name = "no6money")
+    private BigDecimal no6money;
+
+    /**
+     * 七等奖金额
+     */
+    @Column(name = "no7money")
+    private BigDecimal no7money;
+
+    /**
+     * 八等奖金额
+     */
+    @Column(name = "no8money")
+    private BigDecimal no8money;
+
+    /**
+     * 九等奖金额
+     */
+    @Column(name = "no9money")
+    private BigDecimal no9money;
+
+    /**
+     * 彩票名称
+     */
+    @Column(name = "name")
+    private String name;
+
+    /**
+     * 销售额
+     */
+    @Column(name = "xiaoshou")
+    private BigDecimal xiaoshou;
+
+    /**
+     * 奖池金额
+     */
+    @Column(name = "jiangchi")
+    private BigDecimal jiangchi;
+
+    /**
+     * 截止兑奖时间
+     */
+    @Column(name = "endtime")
+    private Date endtime;
+
+    /**
+     * 一等奖追加注数
+     */
+    @Column(name = "no1numjia")
+    private Integer no1numjia;
+
+    /**
+     * 一等奖追加奖金
+     */
+    @Column(name = "no1moneyjia")
+    private BigDecimal no1moneyjia;
+
+    /**
+     * 二等奖追加注数
+     */
+    @Column(name = "no2numjia")
+    private Integer no2numjia;
+
+    /**
+     * 二等奖追加奖金
+     */
+    @Column(name = "no2moneyjia")
+    private BigDecimal no2moneyjia;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/DataIpoBond.java

@@ -0,0 +1,213 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新债数据表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "data_ipo_bond")
+public class DataIpoBond extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 9159696621291938139L;
+
+    /**
+     * 债券代码
+     */
+    @Column(name = "bond_code")
+    private String bondCode;
+
+    /**
+     * 债券简称
+     */
+    @Column(name = "bond_short_name")
+    private String bondShortName;
+
+    /**
+     * 公告日期
+     */
+    @Column(name = "announcement_date")
+    private Date announcementDate;
+
+    /**
+     * 发行起始日
+     */
+    @Column(name = "issue_start_date")
+    private Date issueStartDate;
+
+    /**
+     * 发行终止日
+     */
+    @Column(name = "issue_end_date")
+    private Date issueEndDate;
+
+    /**
+     * 计划发行总量
+     */
+    @Column(name = "planned_issue_amount")
+    private BigDecimal plannedIssueAmount;
+
+    /**
+     * 实际发行总量
+     */
+    @Column(name = "actual_issue_amount")
+    private BigDecimal actualIssueAmount;
+
+    /**
+     * 发行面值
+     */
+    @Column(name = "issue_par_value")
+    private BigDecimal issueParValue;
+
+    /**
+     * 发行价格
+     */
+    @Column(name = "issue_price")
+    private BigDecimal issuePrice;
+
+    /**
+     * 发行方式
+     */
+    @Column(name = "issue_method")
+    private String issueMethod;
+
+    /**
+     * 发行对象
+     */
+    @Column(name = "issue_target")
+    private String issueTarget;
+
+    /**
+     * 发行范围
+     */
+    @Column(name = "issue_scope")
+    private String issueScope;
+
+    /**
+     * 承销方式
+     */
+    @Column(name = "underwriting_method")
+    private String underwritingMethod;
+
+    /**
+     * 募资用途说明
+     */
+    @Column(name = "fundraising_purpose")
+    private String fundraisingPurpose;
+
+    /**
+     * 初始转股价格
+     */
+    @Column(name = "initial_conversion_price")
+    private BigDecimal initialConversionPrice;
+
+    /**
+     * 转股开始日期
+     */
+    @Column(name = "conversion_start_date")
+    private Date conversionStartDate;
+
+    /**
+     * 转股终止日期
+     */
+    @Column(name = "conversion_end_date")
+    private Date conversionEndDate;
+
+    /**
+     * 网上申购日期
+     */
+    @Column(name = "online_subscription_date")
+    private Date onlineSubscriptionDate;
+
+    /**
+     * 网上申购代码
+     */
+    @Column(name = "online_subscription_code")
+    private String onlineSubscriptionCode;
+
+    /**
+     * 网上申购简称
+     */
+    @Column(name = "online_subscription_short_name")
+    private String onlineSubscriptionShortName;
+
+    /**
+     * 网上申购数量上限
+     */
+    @Column(name = "online_subscription_max")
+    private BigDecimal onlineSubscriptionMax;
+
+    /**
+     * 网上申购数量下限
+     */
+    @Column(name = "online_subscription_min")
+    private BigDecimal onlineSubscriptionMin;
+
+    /**
+     * 网上申购单位
+     */
+    @Column(name = "online_subscription_unit")
+    private BigDecimal onlineSubscriptionUnit;
+
+    /**
+     * 网上申购中签结果公告日及退款日
+     */
+    @Column(name = "online_subscription_result_date")
+    private Date onlineSubscriptionResultDate;
+
+    /**
+     * 优先申购日
+     */
+    @Column(name = "priority_subscription_date")
+    private Date prioritySubscriptionDate;
+
+    /**
+     * 配售价格
+     */
+    @Column(name = "allotment_price")
+    private BigDecimal allotmentPrice;
+
+    /**
+     * 债权登记日
+     */
+    @Column(name = "creditor_registration_date")
+    private Date creditorRegistrationDate;
+
+    /**
+     * 优先申购缴款日
+     */
+    @Column(name = "priority_subscription_payment_date")
+    private Date prioritySubscriptionPaymentDate;
+
+    /**
+     * 转股代码
+     */
+    @Column(name = "conversion_code")
+    private String conversionCode;
+
+    /**
+     * 交易市场
+     */
+    @Column(name = "trading_market")
+    private String tradingMarket;
+
+    /**
+     * 债券名称
+     */
+    @Column(name = "bond_name")
+    private String bondName;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/DataIpoStock.java

@@ -0,0 +1,159 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新股数据表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "data_ipo_stock")
+public class DataIpoStock extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -7270372154434102398L;
+
+    /**
+     * 股票代码
+     */
+    @Column(name = "stock_code")
+    private String stockCode;
+
+    /**
+     * 股票简称
+     */
+    @Column(name = "stock_short_name")
+    private String stockShortName;
+
+    /**
+     * 申购代码
+     */
+    @Column(name = "subscription_code")
+    private String subscriptionCode;
+
+    /**
+     * 发行总数
+     */
+    @Column(name = "total_issued")
+    private BigDecimal totalIssued;
+
+    /**
+     * 网上发行
+     */
+    @Column(name = "online_issued")
+    private BigDecimal onlineIssued;
+
+    /**
+     * 顶格申购需配市值
+     */
+    @Column(name = "max_market_value_for_subscription")
+    private BigDecimal maxMarketValueForSubscription;
+
+    /**
+     * 申购上限
+     */
+    @Column(name = "subscription_limit")
+    private Integer subscriptionLimit;
+
+    /**
+     * 发行价格
+     */
+    @Column(name = "issue_price")
+    private BigDecimal issuePrice;
+
+    /**
+     * 最新价
+     */
+    @Column(name = "latest_price")
+    private BigDecimal latestPrice;
+
+    /**
+     * 首日收盘价
+     */
+    @Column(name = "first_day_closing_price")
+    private BigDecimal firstDayClosingPrice;
+
+    /**
+     * 申购日期
+     */
+    @Column(name = "subscription_date")
+    private Date subscriptionDate;
+
+    /**
+     * 中签号公布日
+     */
+    @Column(name = "winning_number_announcement_date")
+    private Date winningNumberAnnouncementDate;
+
+    /**
+     * 中签缴款日期
+     */
+    @Column(name = "payment_date_for_winning")
+    private Date paymentDateForWinning;
+
+    /**
+     * 上市日期
+     */
+    @Column(name = "listing_date")
+    private Date listingDate;
+
+    /**
+     * 发行市盈率
+     */
+    @Column(name = "issue_p_e_ratio")
+    private BigDecimal issuePeRatio;
+
+    /**
+     * 行业市盈率
+     */
+    @Column(name = "industry_p_e_ratio")
+    private BigDecimal industryPeRatio;
+
+    /**
+     * 中签率
+     */
+    @Column(name = "winning_rate")
+    private BigDecimal winningRate;
+
+    /**
+     * 询价累计报价倍数
+     */
+    @Column(name = "cumulative_bid_multiple")
+    private BigDecimal cumulativeBidMultiple;
+
+    /**
+     * 配售对象报价家数
+     */
+    @Column(name = "bidding_firms_count")
+    private Integer biddingFirmsCount;
+
+    /**
+     * 连续一字板数量
+     */
+    @Column(name = "consecutive_limit_up_days")
+    private String consecutiveLimitUpDays;
+
+    /**
+     * 涨幅
+     */
+    @Column(name = "increase_rate")
+    private BigDecimal increaseRate;
+
+    /**
+     * 每中一签获利
+     */
+    @Column(name = "profit_rer_winning_lot")
+    private BigDecimal profitRerWinningLot;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/DataProductHuntPost.java

@@ -0,0 +1,92 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description Product Hunt数据表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "data_product_hunt_post")
+public class DataProductHuntPost extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -3386709939694532309L;
+
+    /**
+     * 榜单日期
+     */
+    @Column(name = "rank_date")
+    private Date rankDate;
+
+    /**
+     * 排名位置
+     */
+    @Column(name = "rank_num")
+    private Integer rankNum;
+
+    /**
+     * 帖子ID
+     */
+    @Column(name = "post_id")
+    private Long postId;
+
+    /**
+     * 帖子名称
+     */
+    @Column(name = "name")
+    private String name;
+
+    /**
+     * 帖子的标语
+     */
+    @Column(name = "tagline")
+    private String tagline;
+
+    /**
+     * 帖子信息
+     */
+    @Column(name = "description")
+    private String description;
+
+    /**
+     * 投票数
+     */
+    @Column(name = "votes_count")
+    private Integer votesCount;
+
+    /**
+     * 帖子的创建日期和时间
+     */
+    @Column(name = "created_at")
+    private Date createdAt;
+
+    /**
+     * 帖子被特色展示的日期和时间
+     */
+    @Column(name = "featured_at")
+    private Date featuredAt;
+
+    /**
+     * 指向该帖子网站的重定向 URL
+     */
+    @Column(name = "website")
+    private String website;
+
+    /**
+     * 帖子URL
+     */
+    @Column(name = "url")
+    private String url;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/DataShuangSeQiu.java

@@ -0,0 +1,146 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 双色球数据表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "data_shuang_se_qiu")
+public class DataShuangSeQiu extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -1707114960359713234L;
+
+    /**
+     * 开奖号码，以竖杠隔开
+     */
+    @Column(name = "number")
+    private String number;
+
+    /**
+     * 特别号码，尾号
+     */
+    @Column(name = "number1")
+    private String number1;
+
+    /**
+     * 期号
+     */
+    @Column(name = "qihao")
+    private String qihao;
+
+    /**
+     * 开奖日期
+     */
+    @Column(name = "time")
+    private String time;
+
+    /**
+     * 一等奖注数
+     */
+    @Column(name = "no1num")
+    private Integer no1num;
+
+    /**
+     * 二等奖注数
+     */
+    @Column(name = "no2num")
+    private Integer no2num;
+
+    /**
+     * 三等奖注数
+     */
+    @Column(name = "no3num")
+    private Integer no3num;
+
+    /**
+     * 四等奖注数
+     */
+    @Column(name = "no4num")
+    private Integer no4num;
+
+    /**
+     * 五等奖注数
+     */
+    @Column(name = "no5num")
+    private Integer no5num;
+
+    /**
+     * 六等奖注数
+     */
+    @Column(name = "no6num")
+    private Integer no6num;
+
+    /**
+     * 一等奖金额
+     */
+    @Column(name = "no1money")
+    private BigDecimal no1money;
+
+    /**
+     * 二等奖金额
+     */
+    @Column(name = "no2money")
+    private BigDecimal no2money;
+
+    /**
+     * 三等奖金额
+     */
+    @Column(name = "no3money")
+    private BigDecimal no3money;
+
+    /**
+     * 四等奖金额
+     */
+    @Column(name = "no4money")
+    private BigDecimal no4money;
+
+    /**
+     * 五等奖金额
+     */
+    @Column(name = "no5money")
+    private BigDecimal no5money;
+
+    /**
+     * 六等奖金额
+     */
+    @Column(name = "no6money")
+    private BigDecimal no6money;
+
+    /**
+     * 彩票名称
+     */
+    @Column(name = "name")
+    private String name;
+
+    /**
+     * 销售额
+     */
+    @Column(name = "xiaoshou")
+    private BigDecimal xiaoshou;
+
+    /**
+     * 奖池金额
+     */
+    @Column(name = "jiangchi")
+    private BigDecimal jiangchi;
+
+    /**
+     * 一等奖中奖地域
+     */
+    @Column(name = "no1msg")
+    private String no1msg;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SubscriptionOrder.java

@@ -0,0 +1,68 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅源表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "subscription_order")
+public class SubscriptionOrder extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -1126473384837577762L;
+
+    /**
+     * 用户ID
+     */
+    @Column(name = "user_id")
+    private Long userId;
+
+    /**
+     * 订阅源ID
+     */
+    @Column(name = "subscription_source_id")
+    private Long subscriptionSourceId;
+
+    /**
+     * 订阅价格计划ID
+     */
+    @Column(name = "subscription_plan_id")
+    private Long subscriptionPlanId;
+
+    /**
+     * 订单号（格式：3位业务编码 + YYYYMMDD + 6位序列号）
+     */
+    @Column(name = "order_no")
+    private String orderNo;
+
+    /**
+     * 订阅价格（单位：元）
+     */
+    @Column(name = "subscription_price")
+    private BigDecimal subscriptionPrice;
+
+    /**
+     * 订阅时长（单位：天）
+     */
+    @Column(name = "subscription_duration")
+    private Integer subscriptionDuration;
+
+    /**
+     * 支付状态（NOTPAY-未支付，SUCCESS-支付成功、REFUND-转入退款、CLOSED-已关闭、REVOKED-已撤销）
+     */
+    @Column(name = "payment_status")
+    private String paymentStatus;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SubscriptionPlan.java

@@ -0,0 +1,50 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅价格计划表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "subscription_plan")
+public class SubscriptionPlan extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -9222273410926982272L;
+
+    /**
+     * 订阅源ID
+     */
+    @Column(name = "subscription_source_id")
+    private Long subscriptionSourceId;
+
+    /**
+     * 付费选项（FREE-免费、PAID-付费）
+     */
+    @Column(name = "paid_option")
+    private String paidOption;
+
+    /**
+     * 订阅价格（单位：元）
+     */
+    @Column(name = "subscription_price")
+    private BigDecimal subscriptionPrice;
+
+    /**
+     * 订阅时长（单位：天）
+     */
+    @Column(name = "subscription_duration")
+    private Integer subscriptionDuration;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SubscriptionSource.java

@@ -0,0 +1,61 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅源表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "subscription_source")
+public class SubscriptionSource extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -5513593762548197292L;
+
+    /**
+     * 主标题
+     */
+    @Column(name = "title")
+    private String title;
+
+    /**
+     * 副标题
+     */
+    @Column(name = "sub_title")
+    private String subTitle;
+
+    /**
+     * 推送渠道（WXMP-微信服务号）
+     */
+    @Column(name = "push_channel")
+    private String pushChannel;
+
+    /**
+     * 推送频率
+     */
+    @Column(name = "push_frequency")
+    private String pushFrequency;
+
+    /**
+     * 详情描述
+     */
+    @Column(name = "description")
+    private String description;
+
+    /**
+     * 详情图片
+     */
+    @Column(name = "pics")
+    private String pics;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SubscriptionUserConfig.java

@@ -0,0 +1,56 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅源配置表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "subscription_user_config")
+public class SubscriptionUserConfig extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 6020912167152937035L;
+
+    /**
+     * 用户ID
+     */
+    @Column(name = "user_id")
+    private Long userId;
+
+    /**
+     * 订阅源ID
+     */
+    @Column(name = "subscription_source_id")
+    private Long subscriptionSourceId;
+
+    /**
+     * 订阅开始时间
+     */
+    @Column(name = "start_time")
+    private Date startTime;
+
+    /**
+     * 订阅结束时间
+     */
+    @Column(name = "end_time")
+    private Date endTime;
+
+    /**
+     * 消息推送选项(ENABLE-开启、DISABLE-关闭)
+     */
+    @Column(name = "push_option")
+    private String pushOption;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SubscriptionUserLog.java

@@ -0,0 +1,87 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅日志表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "subscription_user_log")
+public class SubscriptionUserLog extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -2715602700348689895L;
+
+    /**
+     * 用户ID
+     */
+    @Column(name = "user_id")
+    private Long userId;
+
+    /**
+     * 订阅源ID
+     */
+    @Column(name = "subscription_source_id")
+    private Long subscriptionSourceId;
+
+    /**
+     * 订阅价格计划ID
+     */
+    @Column(name = "subscription_plan_id")
+    private Long subscriptionPlanId;
+
+    /**
+     * 订单ID
+     */
+    @Column(name = "subscription_order_id")
+    private Long subscriptionOrderId;
+
+    /**
+     * 付费选项（FREE-免费、PAID-付费）
+     */
+    @Column(name = "paid_option")
+    private String paidOption;
+
+    /**
+     * 订阅价格（单位：元）
+     */
+    @Column(name = "subscription_price")
+    private BigDecimal subscriptionPrice;
+
+    /**
+     * 本次订阅时长（单位：天）
+     */
+    @Column(name = "subscription_duration")
+    private Integer subscriptionDuration;
+
+    /**
+     * 订阅前开始时间
+     */
+    @Column(name = "start_time")
+    private Date startTime;
+
+    /**
+     * 订阅前结束时间
+     */
+    @Column(name = "before_end_time")
+    private Date beforeEndTime;
+
+    /**
+     * 订阅后结束时间
+     */
+    @Column(name = "after_end_time")
+    private Date afterEndTime;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SysDict.java

@@ -0,0 +1,49 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "sys_dict")
+public class SysDict extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -4517032917841462495L;
+
+    /**
+     * 字典编码
+     */
+    @Column(name = "dict_code")
+    private String dictCode;
+
+    /**
+     * 字典名称
+     */
+    @Column(name = "dict_name")
+    private String dictName;
+
+    /**
+     * 描述
+     */
+    @Column(name = "description")
+    private String description;
+
+    /**
+     * 状态(1-启用，0-失效)
+     */
+    @Column(name = "status")
+    private Integer status;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SysDictItem.java

@@ -0,0 +1,61 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典项表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "sys_dict_item")
+public class SysDictItem extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -8548988714625164520L;
+
+    /**
+     * 字典表主键
+     */
+    @Column(name = "dict_id")
+    private Long dictId;
+
+    /**
+     * 数据类型（0-String，1-Number）
+     */
+    @Column(name = "data_type")
+    private Integer dataType;
+
+    /**
+     * 字典项编码
+     */
+    @Column(name = "item_code")
+    private String itemCode;
+
+    /**
+     * 字典项名称
+     */
+    @Column(name = "item_name")
+    private String itemName;
+
+    /**
+     * 描述
+     */
+    @Column(name = "description")
+    private String description;
+
+    /**
+     * 状态(1-启用，0-失效)
+     */
+    @Column(name = "status")
+    private Integer status;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/SysScheduleTaskLog.java

@@ -0,0 +1,62 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 定时任务执行记录表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "sys_schedule_task_log")
+public class SysScheduleTaskLog extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 2489118240447875517L;
+
+    /**
+     * 定时任务编码
+     */
+    @Column(name = "task_code")
+    private String taskCode;
+
+    /**
+     * 定时任务名称
+     */
+    @Column(name = "task_name")
+    private String taskName;
+
+    /**
+     * 启动方式（AUTO-自动，MANUAL-手动）
+     */
+    @Column(name = "launch_method")
+    private String launchMethod;
+
+    /**
+     * 任务开始时间
+     */
+    @Column(name = "start_time")
+    private Date startTime;
+
+    /**
+     * 任务结束时间
+     */
+    @Column(name = "end_time")
+    private Date endTime;
+
+    /**
+     * 执行状态（DOING-执行中，SUCCESS-成功，FAIL-失败）
+     */
+    @Column(name = "process_status")
+    private String processStatus;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/entity/User.java

@@ -0,0 +1,49 @@
+package com.dataeasy.server.atomic.entity;
+
+import com.dataeasy.server.common.pojo.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Table;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户表
+ * @date 2025/3/6 15:09
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "user")
+public class User extends BaseEntity implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -2094068210047914838L;
+
+    /**
+     * 微信唯一标识id
+     */
+    @Column(name = "union_id")
+    private String unionId;
+
+    /**
+     * 微信用户小程序标识id
+     */
+    @Column(name = "ma_open_id")
+    private String maOpenId;
+
+    /**
+     * 微信用户服务号标识id
+     */
+    @Column(name = "mp_open_id")
+    private String mpOpenId;
+
+    /**
+     * 用户昵称
+     */
+    @Column(name = "nickname")
+    private String nickname;
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/DataDaLeTouMapper.java

@@ -0,0 +1,15 @@
+package com.dataeasy.server.atomic.mapper;
+
+
+import com.dataeasy.server.atomic.entity.DataDaLeTou;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 大乐透数据表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface DataDaLeTouMapper extends Mapper<DataDaLeTou> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/DataIpoBondMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.DataIpoBond;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新债数据表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface DataIpoBondMapper extends Mapper<DataIpoBond> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/DataIpoStockMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.DataIpoStock;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新股数据表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface DataIpoStockMapper extends Mapper<DataIpoStock> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/DataProductHuntPostMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.DataProductHuntPost;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description Product Hunt榜单的帖子数据 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface DataProductHuntPostMapper extends Mapper<DataProductHuntPost> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/DataShuangSeQiuMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.DataShuangSeQiu;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 双色球数据表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface DataShuangSeQiuMapper extends Mapper<DataShuangSeQiu> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SubscriptionOrderMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SubscriptionOrder;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订单表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SubscriptionOrderMapper extends Mapper<SubscriptionOrder> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SubscriptionPlanMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SubscriptionPlan;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅价格计划表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SubscriptionPlanMapper extends Mapper<SubscriptionPlan> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SubscriptionSourceMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SubscriptionSource;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅源表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SubscriptionSourceMapper extends Mapper<SubscriptionSource> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SubscriptionUserConfigMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SubscriptionUserConfig;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅源配置表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SubscriptionUserConfigMapper extends Mapper<SubscriptionUserConfig> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SubscriptionUserLogMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SubscriptionUserLog;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅日志表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SubscriptionUserLogMapper extends Mapper<SubscriptionUserLog> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SysDictItemMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SysDictItem;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典项表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SysDictItemMapper extends Mapper<SysDictItem> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SysDictMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SysDict;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SysDictMapper extends Mapper<SysDict> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/SysScheduleTaskLogMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.SysScheduleTaskLog;
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 定时任务执行记录表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface SysScheduleTaskLogMapper extends Mapper<SysScheduleTaskLog> {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/mapper/UserMapper.java

@@ -0,0 +1,14 @@
+package com.dataeasy.server.atomic.mapper;
+
+import com.dataeasy.server.atomic.entity.User;
+
+import tk.mybatis.mapper.common.Mapper;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户表 mapper
+ * @date 2025/3/6 15:30
+ */
+public interface UserMapper extends Mapper<User> {
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/IDataDaLeTouService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 大乐透数据表 service
+ * @date 2025/3/6 15:31
+ */
+public interface IDataDaLeTouService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/IDataIpoBondService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新债数据表 service
+ * @date 2025/3/6 15:31
+ */
+public interface IDataIpoBondService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/IDataIpoStockService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新股数据表 service
+ * @date 2025/3/6 15:31
+ */
+public interface IDataIpoStockService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/IDataProductHuntPostService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description Product Hunt榜单的帖子数据 service
+ * @date 2025/3/6 15:31
+ */
+public interface IDataProductHuntPostService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/IDataShuangSeQiuService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 双色球数据表 service
+ * @date 2025/3/6 15:31
+ */
+public interface IDataShuangSeQiuService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISubscriptionOrderService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订单表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISubscriptionOrderService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISubscriptionPlanService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅价格计划表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISubscriptionPlanService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISubscriptionSourceService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅源表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISubscriptionSourceService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISubscriptionUserConfigService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅源配置表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISubscriptionUserConfigService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISubscriptionUserLogService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅日志表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISubscriptionUserLogService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISysDictItemService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典项表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISysDictItemService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISysDictService.java

@@ -0,0 +1,11 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISysDictService {
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/ISysScheduleTaskLogService.java

@@ -0,0 +1,10 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 定时任务执行记录表 service
+ * @date 2025/3/6 15:31
+ */
+public interface ISysScheduleTaskLogService {
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/IUserService.java

@@ -0,0 +1,10 @@
+package com.dataeasy.server.atomic.service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户表 service
+ * @date 2025/3/6 15:31
+ */
+public interface IUserService {
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/DataDaLeTouServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.DataDaLeTouMapper;
+import com.dataeasy.server.atomic.service.IDataDaLeTouService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 大乐透数据表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class DataDaLeTouServiceImpl implements IDataDaLeTouService {
+
+    @Autowired
+    private DataDaLeTouMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/DataIpoBondServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.DataIpoBondMapper;
+import com.dataeasy.server.atomic.service.IDataIpoBondService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新债数据表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class DataIpoBondServiceImpl implements IDataIpoBondService {
+
+    @Autowired
+    private DataIpoBondMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/DataIpoStockServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.DataIpoStockMapper;
+import com.dataeasy.server.atomic.service.IDataIpoStockService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 新股数据表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class DataIpoStockServiceImpl implements IDataIpoStockService {
+
+    @Autowired
+    private DataIpoStockMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/DataProductHuntPostServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.DataProductHuntPostMapper;
+import com.dataeasy.server.atomic.service.IDataProductHuntPostService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description Product Hunt榜单的帖子数据 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class DataProductHuntPostServiceImpl implements IDataProductHuntPostService {
+
+    @Autowired
+    private DataProductHuntPostMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/DataShuangSeQiuServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.DataShuangSeQiuMapper;
+import com.dataeasy.server.atomic.service.IDataShuangSeQiuService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 双色球数据表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class DataShuangSeQiuServiceImpl implements IDataShuangSeQiuService {
+
+    @Autowired
+    private DataShuangSeQiuMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SubscriptionOrderServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SubscriptionOrderMapper;
+import com.dataeasy.server.atomic.service.ISubscriptionOrderService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订单表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SubscriptionOrderServiceImpl implements ISubscriptionOrderService {
+
+    @Autowired
+    private SubscriptionOrderMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SubscriptionPlanServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SubscriptionPlanMapper;
+import com.dataeasy.server.atomic.service.ISubscriptionPlanService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅价格计划表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SubscriptionPlanServiceImpl implements ISubscriptionPlanService {
+
+    @Autowired
+    private SubscriptionPlanMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SubscriptionSourceServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SubscriptionSourceMapper;
+import com.dataeasy.server.atomic.service.ISubscriptionSourceService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 订阅源表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SubscriptionSourceServiceImpl implements ISubscriptionSourceService {
+
+    @Autowired
+    private SubscriptionSourceMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SubscriptionUserConfigServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SubscriptionUserConfigMapper;
+import com.dataeasy.server.atomic.service.ISubscriptionUserConfigService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅源配置表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SubscriptionUserConfigServiceImpl implements ISubscriptionUserConfigService {
+
+    @Autowired
+    private SubscriptionUserConfigMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SubscriptionUserLogServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SubscriptionUserLogMapper;
+import com.dataeasy.server.atomic.service.ISubscriptionUserLogService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户的订阅日志表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SubscriptionUserLogServiceImpl implements ISubscriptionUserLogService {
+
+    @Autowired
+    private SubscriptionUserLogMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SysDictItemServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SysDictItemMapper;
+import com.dataeasy.server.atomic.service.ISysDictItemService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典项表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SysDictItemServiceImpl implements ISysDictItemService {
+
+    @Autowired
+    private SysDictItemMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SysDictServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SysDictMapper;
+import com.dataeasy.server.atomic.service.ISysDictService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 系统字典表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SysDictServiceImpl implements ISysDictService {
+
+    @Autowired
+    private SysDictMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/SysScheduleTaskLogServiceImpl.java

@@ -0,0 +1,21 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.dataeasy.server.atomic.mapper.SysScheduleTaskLogMapper;
+import com.dataeasy.server.atomic.service.ISysScheduleTaskLogService;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 定时任务执行记录表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class SysScheduleTaskLogServiceImpl implements ISysScheduleTaskLogService {
+
+    @Autowired
+    private SysScheduleTaskLogMapper mapper;
+
+}

data-easy/src/main/java/com/dataeasy/server/atomic/service/impl/UserServiceImpl.java

@@ -0,0 +1,19 @@
+package com.dataeasy.server.atomic.service.impl;
+
+import com.dataeasy.server.atomic.mapper.UserMapper;
+import com.dataeasy.server.atomic.service.IUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author tyuio
+ * @version 1.0.0
+ * @description 用户表 service
+ * @date 2025/3/6 15:32
+ */
+@Service
+public class UserServiceImpl implements IUserService {
+
+    @Autowired
+    private UserMapper userMapper;
+}

doc/sql/schema.sql

@@ -0,0 +1,336 @@
+
+-- 用户表
+CREATE TABLE `user` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `union_id` varchar(128) NOT NULL COMMENT '微信唯一标识id',
+  `ma_open_id` varchar(128) NOT NULL COMMENT '微信用户小程序标识id',
+  `mp_open_id` varchar(128) DEFAULT NULL COMMENT '微信用户服务号标识id',
+  `nickname` varchar(100) NOT NULL COMMENT '用户昵称',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='用户表';
+
+-- 系统字典表
+CREATE TABLE `sys_dict` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `dict_code` varchar(100) NOT NULL COMMENT '字典编码',
+  `dict_name` varchar(100) NOT NULL COMMENT '字典名称',
+  `description` varchar(200) DEFAULT NULL COMMENT '描述',
+  `status` int NOT NULL DEFAULT 1 COMMENT '状态(1-启用，0-失效)',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='系统字典表';
+
+-- 系统字典项表
+CREATE TABLE `sys_dict_item` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `dict_id` bigint NOT NULL COMMENT '字典表主键',
+  `data_type` int NOT NULL COMMENT '数据类型（0-String，1-Number）',
+  `item_code` varchar(100) NOT NULL COMMENT '字典项编码',
+  `item_name` varchar(100) NOT NULL COMMENT '字典项名称',
+  `description` varchar(200) DEFAULT NULL COMMENT '描述',
+  `status` int NOT NULL DEFAULT 1 COMMENT '状态(1-启用，0-失效)',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='系统字典项表';
+
+-- Product Hunt数据表
+CREATE TABLE `data_product_hunt_post` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `rank_date` date NOT NULL COMMENT '榜单日期',
+  `rank_num` int NOT NULL COMMENT '排名位置',
+  `post_id` bigint NOT NULL COMMENT '帖子ID',
+  `name` varchar(200) NOT NULL COMMENT '帖子名称',
+  `tagline` varchar(300) DEFAULT NULL COMMENT '帖子的标语',
+  `description` varchar(1000) DEFAULT NULL COMMENT '帖子信息',
+  `votesCount` int DEFAULT 0 COMMENT '投票数',
+  `createdAt` timestamp DEFAULT NULL COMMENT '帖子的创建日期和时间',
+  `featuredAt` timestamp DEFAULT NULL COMMENT '帖子被特色展示的日期和时间',
+  `website` varchar(500) DEFAULT NULL COMMENT '指向该帖子网站的重定向 URL',
+  `url` varchar(500) DEFAULT NULL COMMENT '帖子URL',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='Product Hunt榜单的帖子数据';
+
+-- 大乐透数据表
+CREATE TABLE `data_da_le_tou` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `number` varchar(30) NOT NULL COMMENT '开奖号码，以竖杠隔开',
+  `number1` varchar(2) DEFAULT NULL COMMENT '特别号码1，第一个尾号',
+  `number2` varchar(2) DEFAULT NULL COMMENT '特别号码2，第二个尾号',
+  `qihao` char(5) NOT NULL COMMENT '期号',
+  `time` date DEFAULT NULL COMMENT '开奖日期',
+  `no1num` int NOT NULL DEFAULT 0 COMMENT '一等奖注数',
+  `no2num` int NOT NULL DEFAULT 0 COMMENT '二等奖注数',
+  `no3num` int NOT NULL DEFAULT 0 COMMENT '三等奖注数',
+  `no4num` int NOT NULL DEFAULT 0 COMMENT '四等奖注数',
+  `no5num` int NOT NULL DEFAULT 0 COMMENT '五等奖注数',
+  `no6num` int NOT NULL DEFAULT 0 COMMENT '六等奖注数',
+  `no7num` int NOT NULL DEFAULT 0 COMMENT '七等奖注数',
+  `no8num` int NOT NULL DEFAULT 0 COMMENT '八等奖注数',
+  `no9num` int NOT NULL DEFAULT 0 COMMENT '九等奖注数',
+  `no1money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '一等奖金额',
+  `no2money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '二等奖金额',
+  `no3money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '三等奖金额',
+  `no4money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '四等奖金额',
+  `no5money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '五等奖金额',
+  `no6money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '六等奖金额',
+  `no7money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '七等奖金额',
+  `no8money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '八等奖金额',
+  `no9money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '九等奖金额',
+  `name` varchar(30) DEFAULT NULL COMMENT '彩票名称',
+  `xiaoshou` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '销售额',
+  `jiangchi` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '奖池金额',
+  `endtime` timestamp DEFAULT NULL COMMENT '截止兑奖时间',
+  `no1numjia` int NOT NULL DEFAULT 0 COMMENT '一等奖追加注数',
+  `no1moneyjia` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '一等奖追加奖金',
+  `no2numjia` int NOT NULL DEFAULT 0 COMMENT '二等奖追加注数',
+  `no2moneyjia` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '二等奖追加奖金',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='大乐透数据表';
+
+-- 双色球数据表
+CREATE TABLE `data_shuang_se_qiu` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `number` varchar(30) NOT NULL COMMENT '开奖号码，以竖杠隔开',
+  `number1` varchar(2) DEFAULT NULL COMMENT '特别号码，尾号',
+  `qihao` char(8) NOT NULL COMMENT '期号',
+  `time` varchar(15) DEFAULT NULL COMMENT '开奖日期',
+  `no1num` int NOT NULL DEFAULT 0 COMMENT '一等奖注数',
+  `no2num` int NOT NULL DEFAULT 0 COMMENT '二等奖注数',
+  `no3num` int NOT NULL DEFAULT 0 COMMENT '三等奖注数',
+  `no4num` int NOT NULL DEFAULT 0 COMMENT '四等奖注数',
+  `no5num` int NOT NULL DEFAULT 0 COMMENT '五等奖注数',
+  `no6num` int NOT NULL DEFAULT 0 COMMENT '六等奖注数',
+  `no1money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '一等奖金额',
+  `no2money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '二等奖金额',
+  `no3money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '三等奖金额',
+  `no4money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '四等奖金额',
+  `no5money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '五等奖金额',
+  `no6money` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '六等奖金额',
+  `name` varchar(30) DEFAULT NULL COMMENT '彩票名称',
+  `xiaoshou` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '销售额',
+  `jiangchi` decimal(18,2) NOT NULL DEFAULT 0.00 COMMENT '奖池金额',
+  `no1msg` varchar(1000) DEFAULT NULL COMMENT '一等奖中奖地域',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='双色球数据表';
+
+-- 新股数据表
+CREATE TABLE `data_ipo_stock` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `stock_code` varchar(10) NOT NULL COMMENT '股票代码',
+  `stock_short_name` varchar(30) NOT NULL COMMENT '股票简称',
+  `subscription_code` varchar(10) NOT NULL COMMENT '申购代码',
+  `total_issued` decimal(22,4) NOT NULL DEFAULT 0.0000 COMMENT '发行总数',
+  `online_issued` decimal(22,4) NOT NULL DEFAULT 0.0000 COMMENT '网上发行',
+  `max_market_value_for_subscription` decimal(22,4) NOT NULL DEFAULT 0.0000 COMMENT '顶格申购需配市值',
+  `subscription_limit` int NOT NULL DEFAULT 0 COMMENT '申购上限',
+  `issue_price` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '发行价格',
+  `latest_price` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '最新价',
+  `first_day_closing_price` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '首日收盘价',
+  `subscription_date` date NOT NULL COMMENT '申购日期',
+  `winning_number_announcement_date` date NOT NULL COMMENT '中签号公布日',
+  `payment_date_for_winning` date NOT NULL COMMENT '中签缴款日期',
+  `listing_date` date NOT NULL COMMENT '上市日期',
+  `issue_p_e_ratio` decimal(5,2) NOT NULL DEFAULT 0.00 COMMENT '发行市盈率',
+  `industry_p_e_ratio` decimal(5,2) NOT NULL DEFAULT 0.00 COMMENT '行业市盈率',
+  `winning_rate` decimal(11,10) NOT NULL DEFAULT 0.0000000000 COMMENT '中签率',
+  `cumulative_bid_multiple` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '询价累计报价倍数',
+  `bidding_firms_count` int NOT NULL DEFAULT 0 COMMENT '配售对象报价家数',
+  `consecutive_limit_up_days` varchar(10) DEFAULT NULL COMMENT '连续一字板数量',
+  `increase_rate` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '涨幅',
+  `profit_rer_winning_lot` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '每中一签获利',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='新股数据表';
+
+-- 新债数据表
+CREATE TABLE `data_ipo_bond` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `bond_code` varchar(10) NOT NULL COMMENT '债券代码',
+  `bond_short_name` varchar(30) NOT NULL COMMENT '债券简称',
+  `announcement_date` date DEFAULT NULL COMMENT '公告日期',
+  `issue_start_date` date DEFAULT NULL COMMENT '发行起始日',
+  `issue_end_date` date DEFAULT NULL COMMENT '发行终止日',
+  `planned_issue_amount` decimal(22,4) NOT NULL DEFAULT 0.0000 COMMENT '计划发行总量',
+  `actual_issue_amount` decimal(22,4) NOT NULL DEFAULT 0.0000 COMMENT '实际发行总量',
+  `issue_par_value` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '发行面值',
+  `issue_price` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '发行价格',
+  `issue_method` varchar(200) DEFAULT NULL COMMENT '发行方式',
+  `issue_target` varchar(2000) DEFAULT NULL COMMENT '发行对象',
+  `issue_scope` varchar(200) DEFAULT NULL COMMENT '发行范围',
+  `underwriting_method` varchar(30) DEFAULT NULL COMMENT '承销方式',
+  `fundraising_purpose` varchar(200) DEFAULT NULL COMMENT '募资用途说明',
+  `initial_conversion_price` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '初始转股价格',
+  `conversion_start_date` date DEFAULT NULL COMMENT '转股开始日期',
+  `conversion_end_date` date DEFAULT NULL COMMENT '转股终止日期',
+  `online_subscription_date` date DEFAULT NULL COMMENT '网上申购日期',
+  `online_subscription_code` varchar(10) DEFAULT NULL COMMENT '网上申购代码',
+  `online_subscription_short_name` varchar(30) DEFAULT NULL COMMENT '网上申购简称',
+  `online_subscription_max` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '网上申购数量上限',
+  `online_subscription_min` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '网上申购数量下限',
+  `online_subscription_unit` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '网上申购单位',
+  `online_subscription_result_date` date DEFAULT NULL COMMENT '网上申购中签结果公告日及退款日',
+  `priority_subscription_date` date DEFAULT NULL COMMENT '优先申购日',
+  `allotment_price` decimal(20,2) NOT NULL DEFAULT 0.00 COMMENT '配售价格',
+  `creditor_registration_date` date DEFAULT NULL COMMENT '债权登记日',
+  `priority_subscription_payment_date` date DEFAULT NULL COMMENT '优先申购缴款日',
+  `conversion_code` varchar(10) DEFAULT NULL COMMENT '转股代码',
+  `trading_market` varchar(30) DEFAULT NULL COMMENT '交易市场',
+  `bond_name` varchar(100) DEFAULT NULL COMMENT '债券名称',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='新债数据表';
+
+
+-- 定时任务执行记录表
+CREATE TABLE `sys_schedule_task_log` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `task_code` varchar(100) NOT NULL COMMENT '定时任务编码',
+  `task_name` varchar(100) NOT NULL COMMENT '定时任务名称',
+  `launch_method` varchar(10) NOT NULL COMMENT '启动方式（AUTO-自动，MANUAL-手动）',
+  `start_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '任务开始时间',
+  `end_time` timestamp DEFAULT NULL COMMENT '任务结束时间',
+  `process_status` varchar(10) NOT NULL COMMENT '执行状态（DOING-执行中，SUCCESS-成功，FAIL-失败）',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='定时任务执行记录表';
+
+-- 订阅源表
+CREATE TABLE `subscription_source` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `title` varchar(100) NOT NULL COMMENT '主标题',
+  `sub_title` varchar(300) DEFAULT NULL COMMENT '副标题',
+  `push_channel` varchar(10) NOT NULL COMMENT '推送渠道（WXMP-微信服务号）',
+  `push_frequency` varchar(100) NOT NULL COMMENT '推送频率',
+  `description` varchar(1000) DEFAULT NULL COMMENT '详情描述',
+  `pics` varchar(2000) DEFAULT NULL COMMENT '详情图片',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='订阅源表';
+
+-- 订阅价格计划表
+CREATE TABLE `subscription_plan` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `subscription_source_id` bigint NOT NULL COMMENT '订阅源ID',
+  `paid_option` varchar(10) NOT NULL COMMENT '付费选项（FREE-免费、PAID-付费）',
+  `subscription_price` decimal(12,2) NOT NULL DEFAULT 0.00 COMMENT '订阅价格（单位：元）',
+  `subscription_duration` int NOT NULL COMMENT '订阅时长（单位：天）',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='订阅价格计划表';
+
+-- 用户的订阅源配置表
+CREATE TABLE `subscription_user_config` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `user_id` bigint NOT NULL COMMENT '用户ID',
+  `subscription_source_id` bigint NOT NULL COMMENT '订阅源ID',
+  `start_time` timestamp NOT NULL COMMENT '订阅开始时间',
+  `end_time` timestamp NOT NULL COMMENT '订阅结束时间',
+  `push_option` varchar(10) NOT NULL COMMENT '消息推送选项(ENABLE-开启、DISABLE-关闭)',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='用户的订阅源配置表';
+
+-- 用户的订阅日志表
+CREATE TABLE `subscription_user_log` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `user_id` bigint NOT NULL COMMENT '用户ID',
+  `subscription_source_id` bigint NOT NULL COMMENT '订阅源ID',
+  `subscription_plan_id` bigint NOT NULL COMMENT '订阅价格计划ID',
+  `subscription_order_id` bigint NOT NULL COMMENT '订单ID',
+  `paid_option` varchar(10) NOT NULL COMMENT '付费选项（FREE-免费、PAID-付费）',
+  `subscription_price` decimal(12,2) NOT NULL DEFAULT 0.00 COMMENT '订阅价格（单位：元）',
+  `subscription_duration` int NOT NULL COMMENT '本次订阅时长（单位：天）',
+  `start_time` timestamp NOT NULL COMMENT '订阅前开始时间',
+  `before_end_time` timestamp NOT NULL COMMENT '订阅前结束时间',
+  `after_end_time` timestamp NOT NULL COMMENT '订阅后结束时间',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='用户的订阅日志表';
+
+-- 订单表
+CREATE TABLE `subscription_order` (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `user_id` bigint NOT NULL COMMENT '用户ID',
+  `subscription_source_id` bigint NOT NULL COMMENT '订阅源ID',
+  `subscription_plan_id` bigint NOT NULL COMMENT '订阅价格计划ID',
+  `order_no` varchar(15) NOT NULL COMMENT '订单号（格式：3位业务编码 + YYYYMMDD + 6位序列号）',
+  `subscription_price` decimal(12,2) NOT NULL DEFAULT 0.00 COMMENT '订阅价格（单位：元）',
+  `subscription_duration` int NOT NULL COMMENT '订阅时长（单位：天）',
+  `payment_status` varchar(10) NOT NULL COMMENT '支付状态（NOTPAY-未支付，SUCCESS-支付成功、REFUND-转入退款、CLOSED-已关闭、REVOKED-已撤销）',
+  `created_by` bigint NOT NULL COMMENT '创建人',
+  `creation_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `last_updated_by` bigint NOT NULL COMMENT '最后更新人',
+  `last_update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `version` bigint NOT NULL DEFAULT '1' COMMENT '版本号',
+  `delete_flag` tinyint NOT NULL DEFAULT '0' COMMENT '逻辑删除标志（0-未删除，1-已删除）',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='订单表';

doc/技术文档.md

@@ -295,7 +295,7 @@
 
 ### 定时任务执行记录表
 
-表名：sys_schedule_task
+表名：sys_schedule_task_log
 
 | 字段             | 类型         | 描述                                              |
 | ---------------- | ------------ | ------------------------------------------------- |