diff --git a/src/sites/hoh8.js b/src/sites/hoh8.js index 496281a..304076d 100644 --- a/src/sites/hoh8.js +++ b/src/sites/hoh8.js @@ -121,8 +121,8 @@ const parseSocketMsg = () => { console.log('socket on open'); // getMovieList(0); //获取所有电影列表 // getGameList(0); //获取所有游戏列表 - // parseAllRecord('movie'); //更新详情 - getVideoToken(0); //刷钱 + parseAllRecord('movie'); //更新详情 + // getVideoToken(0); //刷钱 } client.onmessage = async (data, flags, number) => { console.log(data); diff --git a/src/sites/movie.js b/src/sites/movie.js index 5a2b7f7..7d4a978 100644 --- a/src/sites/movie.js +++ b/src/sites/movie.js @@ -40,10 +40,31 @@ const parseAllMovie = async () => { console.log(err); } } +// 移除电影中不可播放的链接 +const removeErrorMovieLink = async () => { + try { + let records = await Movie.find({}); + for (let record of records) { + let links = []; + for(let link of record.resources) { + if (link.link.toLowerCase().startsWith('http')) { + links.push(link); + } + } + record.resources = links; + record.markModified('resources'); + record.save(); + } + console.log('all done'); + } catch (err) { + console.log(err); + } +} export default { run: async () => { try { - parseAllMovie(); + // parseAllMovie(); + removeErrorMovieLink(); } catch (err) { console.log(err); }