使用MongoDB实现视频播放进度的保存与恢复(断点续播)

@data
@document(collection = "user_video_play_process")
public class uservideoplayprocess {

    @id
    private string id;

    /** 用户id */
    private long userid;

    /** 视频id */
    private long videoid;

    /** 当前播放到的秒数 */
    private bigdecimal playsecond;

    /** 视频总时长（秒） */
    private bigdecimal duration;

    /** 是否播放完成：0-未完成，1-已完成 */
    private integer isfinished;

    /** 创建时间 */
    private date createtime;

    /** 更新时间 */
    private date updatetime;
}

db.user_video_play_process.createindex(
  { userid: 1, videoid: 1 },
  { unique: true }
)

@getmapping("/getplaysecond/{videoid}")
public result<bigdecimal> getplaysecond(@pathvariable long videoid) {
    long userid = authcontextholder.getuserid();
    return result.ok(
        videoplayprocessservice.getplaysecond(userid, videoid)
    );
}

@override
public bigdecimal getplaysecond(long userid, long videoid) {

    query query = query.query(
        criteria.where("userid").is(userid)
                .and("videoid").is(videoid)
    );

    uservideoplayprocess process =
        mongotemplate.findone(query, uservideoplayprocess.class);

    return process == null ? bigdecimal.zero : process.getplaysecond();
}

@data
public class videoplayprocessvo {

    private long videoid;

    private bigdecimal playsecond;

    private bigdecimal duration;
}

@postmapping("/updateplayprocess")
public result updateplayprocess(
        @requestbody videoplayprocessvo vo) {

    long userid = authcontextholder.getuserid();
    videoplayprocessservice.updateplayprocess(userid, vo);
    return result.ok();
}

@override
public void updateplayprocess(long userid, videoplayprocessvo vo) {

    query query = query.query(
        criteria.where("userid").is(userid)
                .and("videoid").is(vo.getvideoid())
    );

    boolean finished = vo.getplaysecond().compareto(
        vo.getduration().multiply(new bigdecimal("0.95"))
    ) >= 0;

    update update = new update()
            .set("playsecond", vo.getplaysecond())
            .set("duration", vo.getduration())
            .set("isfinished", finished ? 1 : 0)
            .set("updatetime", new date())
            .setoninsert("userid", userid)
            .setoninsert("videoid", vo.getvideoid())
            .setoninsert("createtime", new date());

    mongotemplate.upsert(
        query,
        update,
        uservideoplayprocess.class
    );
}

1. 进入视频页面
2. 调用 getplaysecond(videoid)
3. 播放器 seek 到返回的秒数
4. 播放过程中每 10 秒调用 updateplayprocess
5. 页面关闭 / 切视频时最后一次保存