更新优化

dist/api/message_action.php

@@ -78,7 +78,7 @@ function fetchActionMessageRow(string $messageUid): array
     return is_array($row) ? $row : [];
 }
 
-function ensureMessageEditsTable(): void
+function ensureMessageEditsTable(): void
 {
     imDb()->exec(
         'create table if not exists `t_web_message_edits` ('
@@ -93,7 +93,40 @@ function ensureMessageEditsTable(): void
         . 'key `idx_edited_at_ms` (`edited_at_ms`)'
         . ') engine=InnoDB default charset=utf8mb4'
     );
-}
+}
+
+function ensurePinnedMessagesTable(): void
+{
+    imAppDb()->exec(
+        'create table if not exists `t_web_pinned_messages` ('
+        . '`user_id` varchar(64) not null,'
+        . '`conversation_type` varchar(16) not null,'
+        . '`target_id` varchar(128) not null,'
+        . '`message_uid` varchar(32) not null,'
+        . '`updated_at_ms` bigint not null,'
+        . 'primary key (`user_id`, `conversation_type`, `target_id`)'
+        . ') engine=InnoDB default charset=utf8mb4'
+    );
+}
+
+function savePinnedMessage(string $userId, string $conversationType, string $targetId, string $messageUid): void
+{
+    ensurePinnedMessagesTable();
+    $statement = imAppDb()->prepare(
+        'insert into `t_web_pinned_messages` (`user_id`, `conversation_type`, `target_id`, `message_uid`, `updated_at_ms`)'
+        . ' values (?, ?, ?, ?, ?) on duplicate key update `message_uid` = values(`message_uid`), `updated_at_ms` = values(`updated_at_ms`)'
+    );
+    $statement->execute([$userId, $conversationType, $targetId, $messageUid, nowTimestampMs()]);
+}
+
+function removePinnedMessage(string $userId, string $conversationType, string $targetId): void
+{
+    ensurePinnedMessagesTable();
+    $statement = imAppDb()->prepare(
+        'delete from `t_web_pinned_messages` where `user_id` = ? and `conversation_type` = ? and `target_id` = ?'
+    );
+    $statement->execute([$userId, $conversationType, $targetId]);
+}
 
 function editTextMessage(string $operatorId, string $messageUid, string $text): array
 {
@@ -222,7 +255,21 @@ if ($action === '' || $messageUid <= 0) {
     respond(400, '缺少操作类型或消息ID');
 }
 
-try {
+try {
+    if ($action === 'pin' || $action === 'unpin') {
+        if ($userId === '') respond(400, '缺少操作者ID');
+        $targetId = trim((string)($payload['target'] ?? ''));
+        $conversationType = trim((string)($payload['conversationType'] ?? 'single'));
+        if ($targetId === '') respond(400, '缺少会话ID');
+        $userId = resolveActionUserId($userId);
+        if ($action === 'pin') {
+            savePinnedMessage($userId, $conversationType, $targetId, $messageUidText);
+        } else {
+            removePinnedMessage($userId, $conversationType, $targetId);
+        }
+        respond(0, 'success', ['messageUid' => $messageUidText, 'action' => $action]);
+    }
+
     if ($action === 'recall') {
         if ($userId === '') {
             respond(400, '缺少操作者ID');