feat: 新增特关作者发作业站内信通知 (#239)

- 为用户关注关系增加特别关注状态和查询/设置接口
- 新增站内信表、实体、仓库、服务、响应模型和接口
- 作者上传公开作业后向特关粉丝生成站内信
- 补充站内信建表索引和已有数据库手工迁移 SQL

尝试实现（）

## Summary by Sourcery

为用户关系添加特别关注支持，并实现站内信机制，当作者发布新的公开 copilot 作业时通知其特别关注者。

New Features:
- 通过关注相关 API 支持标记和查询用户之间的特别关注关系。
- 引入带持久化的站内信系统，并提供 REST API 用于列出消息、查询未读数量以及标记消息为已读。

Enhancements:
- 在用户资料以及关注/粉丝列表响应中暴露特别关注状态。
- 当作者发布公开 copilot 作业时，向其特别关注者发送站内信通知。

<details>
<summary>Original summary in English</summary>

## Summary by Sourcery

Add special-follow support to user relations and implement an in-app
site messaging mechanism to notify special followers when authors
publish new public copilot assignments.

New Features:
- Support marking and querying special follow relationships between
users via follow APIs.
- Introduce a site message system with persistence and REST APIs for
listing messages, querying unread counts, and marking messages as read.

Enhancements:
- Expose special follow status in user profile and follow/fan list
responses.
- Send site messages to special followers when an author publishes a
public copilot assignment.

</details>

Author: dragove

docker/init.sql

@@ -17,10 +17,39 @@ create unique index if not exists idx_user_user_email on "user" (email);
 create table if not exists "user_follow"
 (
   user_id        bigint,
-  follow_user_id bigint       not null,
-  updated_at     timestamp(3) not null,
+  follow_user_id bigint                    not null,
+  special_follow boolean     default false not null,
+  updated_at     timestamp(3)              not null,
   primary key (user_id, follow_user_id)
 );
+create index if not exists idx_user_follow_special_author on user_follow (follow_user_id, special_follow);
+
+-- 站内信表
+create table if not exists site_message
+(
+  id          bigserial primary key,
+  receiver_id bigint       not null,
+  sender_id   bigint       not null,
+  sender_name text         not null,
+  type        text         not null,
+  title       text         not null,
+  content     text         not null,
+  copilot_id  bigint,
+  read_at     timestamp(3),
+  created_at  timestamp(3) not null
+);
+comment on table site_message is '站内信表';
+comment on column site_message.receiver_id is '接收用户ID';
+comment on column site_message.sender_id is '发送/触发用户ID';
+comment on column site_message.sender_name is '发送/触发用户名称快照';
+comment on column site_message.type is '站内信类型';
+comment on column site_message.title is '站内信标题';
+comment on column site_message.content is '站内信内容';
+comment on column site_message.copilot_id is '关联作业ID';
+comment on column site_message.read_at is '已读时间';
+comment on column site_message.created_at is '创建时间';
+create index if not exists idx_site_message_receiver_created on site_message (receiver_id, created_at desc);
+create index if not exists idx_site_message_receiver_read on site_message (receiver_id, read_at);
 
 -- 作业表
 create table if not exists copilot
@@ -205,3 +234,5 @@ ALTER SEQUENCE IF EXISTS comments_area_id_seq RESTART WITH 1;
 ALTER SEQUENCE IF EXISTS copilot_set_id_seq RESTART WITH 1;
 -- ark_level 表的 id 从 1 开始
 ALTER SEQUENCE IF EXISTS ark_level_id_seq RESTART WITH 1;
+-- site_message 表的 id 从 1 开始
+ALTER SEQUENCE IF EXISTS site_message_id_seq RESTART WITH 1;

docker/migration_site_message.sql

@@ -0,0 +1,32 @@
+alter table user_follow
+  add column if not exists special_follow boolean default false not null;
+
+create index if not exists idx_user_follow_special_author on user_follow (follow_user_id, special_follow);
+
+create table if not exists site_message
+(
+  id          bigserial primary key,
+  receiver_id bigint       not null,
+  sender_id   bigint       not null,
+  sender_name text         not null,
+  type        text         not null,
+  title       text         not null,
+  content     text         not null,
+  copilot_id  bigint,
+  read_at     timestamp(3),
+  created_at  timestamp(3) not null
+);
+
+comment on table site_message is '站内信表';
+comment on column site_message.receiver_id is '接收用户ID';
+comment on column site_message.sender_id is '发送/触发用户ID';
+comment on column site_message.sender_name is '发送/触发用户名称快照';
+comment on column site_message.type is '站内信类型';
+comment on column site_message.title is '站内信标题';
+comment on column site_message.content is '站内信内容';
+comment on column site_message.copilot_id is '关联作业ID';
+comment on column site_message.read_at is '已读时间';
+comment on column site_message.created_at is '创建时间';
+
+create index if not exists idx_site_message_receiver_created on site_message (receiver_id, created_at desc);
+create index if not exists idx_site_message_receiver_read on site_message (receiver_id, read_at);

src/main/kotlin/plus/maa/backend/controller/MessageController.kt

@@ -0,0 +1,63 @@
+package plus.maa.backend.controller
+
+import io.swagger.v3.oas.annotations.Operation
+import io.swagger.v3.oas.annotations.responses.ApiResponse
+import io.swagger.v3.oas.annotations.tags.Tag
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestParam
+import org.springframework.web.bind.annotation.RestController
+import plus.maa.backend.common.controller.PagedDTO
+import plus.maa.backend.config.doc.RequireJwt
+import plus.maa.backend.config.security.AuthenticationHelper
+import plus.maa.backend.controller.response.MaaResult
+import plus.maa.backend.controller.response.MaaResult.Companion.success
+import plus.maa.backend.controller.response.message.SiteMessageInfo
+import plus.maa.backend.controller.response.message.UnreadMessageCountInfo
+import plus.maa.backend.service.SiteMessageService
+
+@RestController
+@RequestMapping("/message")
+@Tag(name = "SiteMessage", description = "站内信接口")
+class MessageController(
+    private val siteMessageService: SiteMessageService,
+    private val helper: AuthenticationHelper,
+) {
+    @Operation(summary = "分页查询站内信")
+    @ApiResponse(description = "站内信列表")
+    @RequireJwt
+    @GetMapping("/list")
+    fun list(
+        @RequestParam page: Int = 1,
+        @RequestParam size: Int = 10,
+        @RequestParam("unread_only") unreadOnly: Boolean = false,
+    ): MaaResult<PagedDTO<SiteMessageInfo>> {
+        return success(siteMessageService.list(helper.userId, page, size, unreadOnly))
+    }
+
+    @Operation(summary = "查询未读站内信数量")
+    @ApiResponse(description = "未读站内信数量")
+    @RequireJwt
+    @GetMapping("/unreadCount")
+    fun unreadCount(): MaaResult<UnreadMessageCountInfo> {
+        return success(siteMessageService.unreadCount(helper.userId))
+    }
+
+    @Operation(summary = "标记单条站内信已读")
+    @ApiResponse(description = "标记结果，true=确实标记成功，false=该消息不存在/已读/不属于当前用户")
+    @RequireJwt
+    @PostMapping("/read/{id}")
+    fun read(@PathVariable id: Long): MaaResult<Boolean> {
+        return success(siteMessageService.markRead(helper.userId, id))
+    }
+
+    @Operation(summary = "标记全部站内信已读")
+    @ApiResponse(description = "本次实际标记已读的条数")
+    @RequireJwt
+    @PostMapping("/readAll")
+    fun readAll(): MaaResult<Int> {
+        return success(siteMessageService.markAllRead(helper.userId))
+    }
+}

src/main/kotlin/plus/maa/backend/controller/UserFollowController.kt

@@ -16,6 +16,7 @@ import plus.maa.backend.config.doc.RequireJwt
 import plus.maa.backend.config.security.AuthenticationHelper
 import plus.maa.backend.controller.response.MaaResult
 import plus.maa.backend.controller.response.MaaResult.Companion.success
+import plus.maa.backend.controller.response.user.FollowStatusInfo
 import plus.maa.backend.controller.response.user.MaaUserInfo
 import plus.maa.backend.service.follow.UserFollowService
 
@@ -43,6 +44,21 @@ class UserFollowController(
         userFollowService.unfollow(helper.userId, followUserId),
     )
 
+    @Operation(summary = "设置特别关注")
+    @ApiResponse(description = "设置特别关注结果")
+    @RequireJwt
+    @PostMapping("/special/{followUserId}")
+    fun specialFollow(@PathVariable followUserId: Long, @RequestParam status: Boolean): MaaResult<Unit> = success(
+        userFollowService.setSpecialFollow(helper.userId, followUserId, status),
+    )
+
+    @Operation(summary = "查询关注状态")
+    @ApiResponse(description = "关注状态")
+    @RequireJwt
+    @GetMapping("/status/{followUserId}")
+    fun getStatus(@PathVariable followUserId: Long): MaaResult<FollowStatusInfo> =
+        success(userFollowService.getStatus(helper.userId, followUserId))
+
     @Operation(summary = "获取关注列表")
     @ApiResponse(description = "关注列表")
     @RequireJwt

src/main/kotlin/plus/maa/backend/controller/response/message/SiteMessageInfo.kt

@@ -0,0 +1,22 @@
+package plus.maa.backend.controller.response.message
+
+import kotlinx.serialization.Contextual
+import kotlinx.serialization.Serializable
+import plus.maa.backend.service.model.SiteMessageType
+import java.time.LocalDateTime
+
+@Serializable
+data class SiteMessageInfo(
+    val id: Long,
+    val type: SiteMessageType,
+    val title: String,
+    val content: String,
+    val senderId: Long,
+    val senderName: String,
+    val copilotId: Long?,
+    @Contextual
+    val createdAt: LocalDateTime,
+    @Contextual
+    val readAt: LocalDateTime?,
+    val isRead: Boolean,
+)

src/main/kotlin/plus/maa/backend/controller/response/message/UnreadMessageCountInfo.kt

@@ -0,0 +1,8 @@
+package plus.maa.backend.controller.response.message
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class UnreadMessageCountInfo(
+    val unreadCount: Long,
+)

src/main/kotlin/plus/maa/backend/controller/response/user/FollowStatusInfo.kt

@@ -0,0 +1,14 @@
+package plus.maa.backend.controller.response.user
+
+import kotlinx.serialization.Contextual
+import kotlinx.serialization.Serializable
+import java.time.Instant
+
+@Serializable
+data class FollowStatusInfo(
+    val following: Boolean,
+    val specialFollow: Boolean,
+    val relation: RelationType,
+    @Contextual
+    val followedAt: Instant? = null,
+)

src/main/kotlin/plus/maa/backend/controller/response/user/MaaUserInfo.kt

@@ -19,6 +19,7 @@ data class MaaUserInfo(
     val followingCount: Int = 0,
     val fansCount: Int = 0,
     val relation: RelationType? = null,
+    val specialFollow: Boolean = false,
     @Contextual val followedAt: Instant? = null,
 ) {
     constructor(user: MaaUser) : this(

src/main/kotlin/plus/maa/backend/repository/entity/SiteMessageEntity.kt

@@ -0,0 +1,42 @@
+package plus.maa.backend.repository.entity
+
+import org.ktorm.database.Database
+import org.ktorm.entity.Entity
+import org.ktorm.entity.sequenceOf
+import org.ktorm.schema.Table
+import org.ktorm.schema.datetime
+import org.ktorm.schema.enum
+import org.ktorm.schema.long
+import org.ktorm.schema.text
+import plus.maa.backend.service.model.SiteMessageType
+import java.time.LocalDateTime
+
+interface SiteMessageEntity : Entity<SiteMessageEntity> {
+    var id: Long
+    var receiverId: Long
+    var senderId: Long
+    var senderName: String
+    var type: SiteMessageType
+    var title: String
+    var content: String
+    var copilotId: Long?
+    var readAt: LocalDateTime?
+    var createdAt: LocalDateTime
+
+    companion object : Entity.Factory<SiteMessageEntity>()
+}
+
+object SiteMessages : Table<SiteMessageEntity>("site_message") {
+    val id = long("id").primaryKey().bindTo { it.id }
+    val receiverId = long("receiver_id").bindTo { it.receiverId }
+    val senderId = long("sender_id").bindTo { it.senderId }
+    val senderName = text("sender_name").bindTo { it.senderName }
+    val type = enum<SiteMessageType>("type").bindTo { it.type }
+    val title = text("title").bindTo { it.title }
+    val content = text("content").bindTo { it.content }
+    val copilotId = long("copilot_id").bindTo { it.copilotId }
+    val readAt = datetime("read_at").bindTo { it.readAt }
+    val createdAt = datetime("created_at").bindTo { it.createdAt }
+}
+
+val Database.siteMessages get() = sequenceOf(SiteMessages)

src/main/kotlin/plus/maa/backend/repository/entity/UserFollowEntity.kt

@@ -2,13 +2,15 @@ package plus.maa.backend.repository.entity
 
 import org.ktorm.entity.Entity
 import org.ktorm.schema.Table
+import org.ktorm.schema.boolean
 import org.ktorm.schema.datetime
 import org.ktorm.schema.long
 import java.time.LocalDateTime
 
 interface UserFollowEntity : Entity<UserFollowEntity> {
     var userId: Long
     val followUserId: Long
+    var specialFollow: Boolean
     val updatedAt: LocalDateTime
 
     companion object : Entity.Factory<UserFollowEntity>()
@@ -17,5 +19,6 @@ interface UserFollowEntity : Entity<UserFollowEntity> {
 object UserFollows : Table<UserFollowEntity>("user_follow") {
     val userId = long("user_id").primaryKey().bindTo { it.userId }
     val followUserId = long("follow_user_id").primaryKey().bindTo { it.followUserId }
+    val specialFollow = boolean("special_follow").bindTo { it.specialFollow }
     val updatedAt = datetime("updated_at").bindTo { it.updatedAt }
 }