v 1.0091 后端添加定时发布功能

Author: yyyCode

docs/openblog_mysql.sql

@@ -59,6 +59,7 @@ CREATE TABLE IF NOT EXISTS articles (
   category_id BIGINT NULL,
   status VARCHAR(16) NOT NULL,
   published_at TIMESTAMP(6) NULL,
+  scheduled_at TIMESTAMP(6) NULL,
   submitted_at TIMESTAMP(6) NULL,
   reviewed_at TIMESTAMP(6) NULL,
   rejected_reason VARCHAR(512) NULL,
@@ -71,6 +72,7 @@ CREATE TABLE IF NOT EXISTS articles (
   updated_at TIMESTAMP(6) NOT NULL,
   KEY idx_articles_author_id (author_id),
   KEY idx_articles_status_published_at (status, published_at),
+  KEY idx_articles_status_scheduled_at (status, scheduled_at),
   KEY idx_articles_title (title),
   CONSTRAINT fk_articles_author
     FOREIGN KEY (author_id) REFERENCES users(id)

src/main/java/com/yqz/openblog/OpenBlogApplication.java

@@ -7,8 +7,10 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableScheduling
 @EnableConfigurationProperties({
         SiteProperties.class,
         CorsProperties.class,

src/main/java/com/yqz/openblog/article/entity/Article.java

@@ -43,6 +43,13 @@ public class Article {
     @Column
     private Instant publishedAt;
 
+    /**
+     * 定时发布的预约时间（UTC Instant）。当 status=SCHEDULED 时该字段必填。
+     * 到点后由后台定时任务把文章置为 PUBLISHED，并把 publishedAt=scheduledAt。
+     */
+    @Column
+    private Instant scheduledAt;
+
     @Column
     private Instant submittedAt;
 
@@ -164,6 +171,14 @@ public void setSubmittedAt(Instant submittedAt) {
         this.submittedAt = submittedAt;
     }
 
+    public Instant getScheduledAt() {
+        return scheduledAt;
+    }
+
+    public void setScheduledAt(Instant scheduledAt) {
+        this.scheduledAt = scheduledAt;
+    }
+
     public Instant getReviewedAt() {
         return reviewedAt;
     }

src/main/java/com/yqz/openblog/article/entity/ArticleStatus.java

@@ -2,6 +2,10 @@
 
 public enum ArticleStatus {
     DRAFT,
+    /**
+     * 已预约（到达 scheduledAt 前不可见），由定时任务自动转为 PUBLISHED。
+     */
+    SCHEDULED,
     PUBLISHED,
     DELETED
 }

src/main/java/com/yqz/openblog/article/job/ArticleScheduledPublishJob.java

@@ -0,0 +1,27 @@
+package com.yqz.openblog.article.job;
+
+import com.yqz.openblog.article.service.ArticleService;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * 定时发布：把到点的 SCHEDULED 文章自动发布为 PUBLISHED。
+ *
+ * 说明：多实例部署时通过“条件更新”保证只会发布一次，无需额外分布式锁。
+ */
+@Component
+public class ArticleScheduledPublishJob {
+
+    private final ArticleService articleService;
+
+    public ArticleScheduledPublishJob(ArticleService articleService) {
+        this.articleService = articleService;
+    }
+
+    @Scheduled(fixedDelayString = "${openblog.article-schedule.scan-delay-ms:30000}")
+    public void run() {
+        // 每轮最多发布 N 篇，避免长事务/长循环；下一轮会继续扫。
+        articleService.publishDueScheduled(200);
+    }
+}
+

src/main/java/com/yqz/openblog/article/repo/ArticleMapper.java

@@ -5,12 +5,43 @@
 import com.yqz.openblog.article.entity.ArticleStatus;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 import org.apache.ibatis.annotations.Update;
 
+import java.time.Instant;
+import java.util.List;
+
 @Mapper
 public interface ArticleMapper extends BaseMapper<Article> {
 
     @Update("update articles set view_count = view_count + 1 where id = #{articleId} and status = #{status}")
     int incrementViewCount(@Param("articleId") Long articleId, @Param("status") ArticleStatus status);
+
+    @Select("""
+            select id
+            from articles
+            where status = 'SCHEDULED'
+              and scheduled_at is not null
+              and scheduled_at <= #{now}
+            order by scheduled_at asc
+            limit #{limit}
+            """)
+    List<Long> listDueScheduledIds(@Param("now") Instant now, @Param("limit") int limit);
+
+    /**
+     * 原子发布：仅当仍为 SCHEDULED 且已到点时才会成功（多实例下确保只发布一次）。
+     */
+    @Update("""
+            update articles
+            set status = 'PUBLISHED',
+                published_at = scheduled_at,
+                scheduled_at = null,
+                updated_at = now(6)
+            where id = #{articleId}
+              and status = 'SCHEDULED'
+              and scheduled_at is not null
+              and scheduled_at <= #{now}
+            """)
+    int publishScheduledIfDue(@Param("articleId") Long articleId, @Param("now") Instant now);
 }
 

src/main/java/com/yqz/openblog/article/service/ArticleService.java

@@ -207,8 +207,17 @@ public ArticleListItemResponse publish(Long authorId, Long articleId, Instant pu
         if (a.getTitle() == null || a.getTitle().trim().isEmpty() || a.getContentMarkdown() == null || a.getContentMarkdown().trim().isEmpty()) {
             throw new BizException(4002, "标题和正文不能为空");
         }
-        a.setStatus(ArticleStatus.PUBLISHED);
-        a.setPublishedAt(publishedAt == null ? Instant.now() : publishedAt);
+        Instant now = Instant.now();
+        // 未来时间：按“定时发布”处理（文章在到点前不可见）
+        if (publishedAt != null && publishedAt.isAfter(now)) {
+            a.setStatus(ArticleStatus.SCHEDULED);
+            a.setScheduledAt(publishedAt);
+            a.setPublishedAt(null);
+        } else {
+            a.setStatus(ArticleStatus.PUBLISHED);
+            a.setPublishedAt(publishedAt == null ? now : publishedAt);
+            a.setScheduledAt(null);
+        }
         a.setSubmittedAt(null);
         a.setReviewedAt(null);
         a.setRejectedReason(null);
@@ -217,6 +226,28 @@ public ArticleListItemResponse publish(Long authorId, Long articleId, Instant pu
         return mapListItem(a);
     }
 
+    /**
+     * 定时任务扫描到点文章并发布。
+     *
+     * @return 本轮成功发布数量（可能为 0）
+     */
+    public int publishDueScheduled(int batchSize) {
+        int limit = Math.max(1, Math.min(batchSize, 500));
+        Instant now = Instant.now();
+        List<Long> ids = articleMapper.listDueScheduledIds(now, limit);
+        if (ids.isEmpty()) return 0;
+
+        int published = 0;
+        for (Long id : ids) {
+            int updated = articleMapper.publishScheduledIfDue(id, now);
+            if (updated > 0) {
+                published++;
+                publishedContentCache.evict(id);
+            }
+        }
+        return published;
+    }
+
     public void unpublishOrDelete(Long authorId, Long articleId) {
         Article a = articleMapper.selectById(articleId);
         if (a == null) {
@@ -229,12 +260,13 @@ public void unpublishOrDelete(Long authorId, Long articleId) {
             return;
         }
         a.setStatus(ArticleStatus.DELETED);
+        a.setScheduledAt(null);
         articleMapper.updateById(a);
         publishedContentCache.evict(articleId);
     }
 
     public PageResult<ArticleListItemResponse> listMine(Long authorId, int page, int size) {
-        List<ArticleStatus> statuses = List.of(ArticleStatus.DRAFT, ArticleStatus.PUBLISHED);
+        List<ArticleStatus> statuses = List.of(ArticleStatus.DRAFT, ArticleStatus.SCHEDULED, ArticleStatus.PUBLISHED);
         Page<Article> mpPage = new Page<>(page + 1L, size);
         LambdaQueryWrapper<Article> w = Wrappers.lambdaQuery();
         w.eq(Article::getAuthorId, authorId)