feat(UserEpisodeWatch): implement user episode watch tracking with upsert and mark unwatched functionality

Author: LiggMax

db/anime_flow.sql

@@ -267,6 +267,26 @@ CREATE TABLE `user_bgm_collection`  (
   INDEX `idx_user_sync_time`(`user_id` ASC, `sync_time` ASC) USING BTREE
 ) ENGINE = InnoDB AUTO_INCREMENT = 375 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '用户 Bangumi 收藏关系表' ROW_FORMAT = DYNAMIC;
 
+-- ----------------------------
+-- Table structure for user_episode_watch
+-- ----------------------------
+DROP TABLE IF EXISTS `user_episode_watch`;
+CREATE TABLE `user_episode_watch`  (
+  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `user_id` bigint NOT NULL COMMENT '用户 ID',
+  `subject_id` int UNSIGNED NOT NULL COMMENT '作品 ID，冗余自 bangumi_episode.subject_id，便于按作品查',
+  `episode_id` int UNSIGNED NOT NULL COMMENT '章节 ID',
+  `watch_status` tinyint NOT NULL DEFAULT 1 COMMENT '0未看 1已看，可为将来扩展预留',
+  `watched_at` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '首次标记已看时间',
+  `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`) USING BTREE,
+  UNIQUE INDEX `uk_user_episode`(`user_id` ASC, `episode_id` ASC) USING BTREE,
+  INDEX `idx_user_subject`(`user_id` ASC, `subject_id` ASC) USING BTREE,
+  INDEX `idx_subject_episode`(`subject_id` ASC, `episode_id` ASC) USING BTREE,
+  INDEX `idx_user_subject_status`(`user_id` ASC, `subject_id` ASC, `watch_status` ASC) USING BTREE
+) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '用户剧集观看记录' ROW_FORMAT = Dynamic;
+
 -- ----------------------------
 -- Table structure for user_oauth
 -- ----------------------------

flow-client/src/main/java/com/ligg/flowclient/mapper/UserEpisodeWatchMapper.java

@@ -2,8 +2,32 @@
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.ligg.common.entity.UserEpisodeWatchEntity;
+import org.apache.ibatis.annotations.Insert;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Update;
 
 @Mapper
 public interface UserEpisodeWatchMapper extends BaseMapper<UserEpisodeWatchEntity> {
+
+    @Insert("""
+            insert into user_episode_watch (user_id, subject_id, episode_id, watch_status, watched_at)
+            values (#{userId}, #{subjectId}, #{episodeId}, 1, current_timestamp)
+            on duplicate key update
+            subject_id = values(subject_id),
+            watch_status = values(watch_status),
+            watched_at = coalesce(watched_at, values(watched_at))
+            """)
+    int upsertWatched(@Param("userId") Long userId,
+                      @Param("subjectId") Integer subjectId,
+                      @Param("episodeId") Integer episodeId);
+
+    @Update("""
+            update user_episode_watch
+            set watch_status = 0
+            where user_id = #{userId}
+              and episode_id = #{episodeId}
+            """)
+    int markUnwatched(@Param("userId") Long userId,
+                      @Param("episodeId") Integer episodeId);
 }

flow-client/src/main/java/com/ligg/flowclient/service/impl/UserEpisodeWatchServiceImpl.java

@@ -15,7 +15,6 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
-import java.time.LocalDateTime;
 import java.util.Collections;
 import java.util.LinkedHashSet;
 import java.util.List;
@@ -25,7 +24,6 @@
 @RequiredArgsConstructor
 public class UserEpisodeWatchServiceImpl implements UserEpisodeWatchService {
 
-    private static final int WATCH_STATUS_UNWATCHED = 0;
     private static final int WATCH_STATUS_WATCHED = 1;
     private static final int EPISODE_TYPE_MAIN = 0;
 
@@ -42,17 +40,10 @@ public void updateEpisodeWatch(String accessToken, int episodeId, UpdateEpisodeW
             throw new IllegalArgumentException("剧集不存在");
         }
 
-        UserEpisodeWatchEntity existing = userEpisodeWatchMapper.selectOne(
-                new LambdaQueryWrapper<UserEpisodeWatchEntity>()
-                        .eq(UserEpisodeWatchEntity::getUserId, userId)
-                        .eq(UserEpisodeWatchEntity::getEpisodeId, episodeId)
-                        .last("LIMIT 1"));
-
         if (Boolean.TRUE.equals(dto.getWatched())) {
-            upsertWatched(userId, episode, existing);
-        } else if (existing != null) {
-            existing.setWatchStatus(WATCH_STATUS_UNWATCHED);
-            userEpisodeWatchMapper.updateById(existing);
+            userEpisodeWatchMapper.upsertWatched(userId, episode.getSubjectId(), episode.getId());
+        } else {
+            userEpisodeWatchMapper.markUnwatched(userId, episodeId);
         }
 
         refreshCollectionEpisodeProgress(userId, episode.getSubjectId());
@@ -84,25 +75,6 @@ public Set<Long> listWatchedEpisodeIds(long userId, int subjectId) {
         return watchedEpisodeIds;
     }
 
-    private void upsertWatched(Long userId, BangumiEpisodeEntity episode, UserEpisodeWatchEntity existing) {
-        if (existing != null) {
-            existing.setWatchStatus(WATCH_STATUS_WATCHED);
-            if (existing.getWatchedAt() == null) {
-                existing.setWatchedAt(LocalDateTime.now());
-            }
-            userEpisodeWatchMapper.updateById(existing);
-            return;
-        }
-
-        UserEpisodeWatchEntity row = new UserEpisodeWatchEntity();
-        row.setUserId(userId);
-        row.setSubjectId(episode.getSubjectId());
-        row.setEpisodeId(episode.getId());
-        row.setWatchStatus(WATCH_STATUS_WATCHED);
-        row.setWatchedAt(LocalDateTime.now());
-        userEpisodeWatchMapper.insert(row);
-    }
-
     /**
      * 维护 user_bgm_collection.ep_status，表示按正片顺序连续看完的话数。
      */