增加移除不可播放的电影链接的功能
This commit is contained in:
parent
0894a2239f
commit
4b3b58c508
@ -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);
|
||||
|
@ -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);
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user