first commit
This commit is contained in:
编码猿
288
ksAll/api/play.js
Normal file
288
ksAll/api/play.js
Normal file
@@ -0,0 +1,288 @@
|
||||
var express = require('express');
|
||||
var router = express.Router();
|
||||
const config = require("../config");
|
||||
const GraphqlRequest = require("../http");
|
||||
var request = require('request');
|
||||
var axios = require('axios');
|
||||
var fs = require('fs');
|
||||
|
||||
/**
|
||||
* 对视频进行点赞
|
||||
*/
|
||||
|
||||
router.get('/likeVideo', async function (req, res, next) {
|
||||
let principalId = req.query.principalId;
|
||||
let photoId = req.query.photoId;
|
||||
let cancel = req.query.cancel;
|
||||
let data = (await (new GraphqlRequest("kuaishou")).post(
|
||||
config.likeVideo(principalId, photoId, cancel))
|
||||
);
|
||||
|
||||
console.log("data: ", data);
|
||||
// res.json({
|
||||
// pcursor,
|
||||
// list
|
||||
// });
|
||||
});
|
||||
|
||||
/**
|
||||
* 获取主播首页的视频
|
||||
* http://127.0.0.1:8090/api/publicFeeds?principalId=3xfjgnm9f89bave&count=200
|
||||
*/
|
||||
router.get('/publicFeeds', async function (req, res, next) {
|
||||
let principalId = req.query.principalId;
|
||||
let page = req.query.pcursor || "";
|
||||
let count = req.query.count || "";
|
||||
let { list, pcursor } = (await (new GraphqlRequest("kuaishou")).post(config.publicFeeds(principalId, page, count))).publicFeeds;
|
||||
|
||||
mkDir(principalId);
|
||||
|
||||
let imageNums = 0;
|
||||
list.forEach(async (val, index) => {
|
||||
console.log("val: ", val);
|
||||
// if (val.useVideoPlayer == false) {
|
||||
// imageNums += val.imgUrls.length
|
||||
// console.log(val.id);
|
||||
// DownImage(val)
|
||||
// } else {
|
||||
// getVideoData()
|
||||
// }
|
||||
})
|
||||
|
||||
res.json({
|
||||
pcursor,
|
||||
list
|
||||
});
|
||||
});
|
||||
|
||||
|
||||
/**
|
||||
* 获取视频真实播放地址
|
||||
*/
|
||||
router.get('/play', async function (req, res, next) {
|
||||
let principalId = req.query.principalId;
|
||||
let photoId = req.query.photoId;
|
||||
res.json((await (new GraphqlRequest()).post(config.feedById(principalId, photoId))).feedById.currentWork);
|
||||
});
|
||||
|
||||
/**
|
||||
* 获取视频相关的推荐
|
||||
* http://127.0.0.1:8090/api/RecommendFeeds?photoId=3xhzfvheg3wpsra
|
||||
*/
|
||||
router.get('/RecommendFeeds', async function (req, res, next) {
|
||||
let photoId = req.query.photoId;
|
||||
let result = await (new GraphqlRequest()).post(config.RecommendFeeds(photoId))
|
||||
res.json(result.videoRecommendFeeds);
|
||||
});
|
||||
|
||||
/**
|
||||
* 获取评论
|
||||
* http://127.0.0.1:8090/api/CommentList?photoId=3xz5ue2p6betigm
|
||||
*/
|
||||
router.get('/CommentList', async function (req, res, next) {
|
||||
let photoId = req.query.photoId;
|
||||
let pcursor = req.query.pcursor || "";
|
||||
res.json((await (new GraphqlRequest()).post(config.shortVideoCommentList(photoId, pcursor))).shortVideoCommentList);
|
||||
});
|
||||
|
||||
/**
|
||||
* 获取评论展开
|
||||
* http://127.0.0.1:8090/api/subCommentList?photoId=3xz5ue2p6betigm&rootCommentId=225526137195
|
||||
*/
|
||||
router.get('/subCommentList', async function (req, res, next) {
|
||||
let photoId = req.query.photoId;
|
||||
let rootCommentId = req.query.rootCommentId;
|
||||
let pcursor = req.query.pcursor || "";
|
||||
let ddd = (await (new GraphqlRequest()).post(config.subCommentList(photoId, rootCommentId, pcursor))).subCommentList
|
||||
res.json(ddd);
|
||||
});
|
||||
|
||||
|
||||
/**
|
||||
* 快手官网，获取无水印视频！！
|
||||
* http://127.0.0.1:8090/api/likeList
|
||||
*/
|
||||
router.get('/likeList', async function (req, res, next) {
|
||||
let pcursor = req.query.pcursor || "";
|
||||
let rea = await (new GraphqlRequest("kuaishou")).post(config.visionProfileLikePhotoList, {
|
||||
page: "profile",
|
||||
pcursor: pcursor
|
||||
});
|
||||
res.json(rea.visionProfileLikePhotoList);
|
||||
});
|
||||
|
||||
|
||||
/**
|
||||
* 获取收藏的视频
|
||||
* http://127.0.0.1:8090/api/list
|
||||
*/
|
||||
router.get('/list', async function (req, res, next) {
|
||||
let page = req.query.page || "";
|
||||
res.json({
|
||||
data: (await (new GraphqlRequest("kuaishou")).post(config.likedFeeds(page))).likedFeeds
|
||||
});
|
||||
});
|
||||
|
||||
/**
|
||||
* 不是接口，主要作用是为了循环下载主播主页的视频和图片到本地
|
||||
* 用的新接口，下载的是无水印的视频
|
||||
* http://127.0.0.1:8090/api/down?userId=3xfjgnm9f89bave
|
||||
*/
|
||||
router.get('/down', async function (req, res, next) {
|
||||
let userId = req.query.userId;
|
||||
let pcursors = req.query.pcursor || '';
|
||||
|
||||
|
||||
// https://live.kuaishou.com/live_api/profile/public?count=157&pcursor=&principalId=3xfjgnm9f89bave&hasMore=true
|
||||
let result = await axios.get(config.visionProfilePhotoList, {
|
||||
params: {
|
||||
count: 220,
|
||||
pcursor: pcursors,
|
||||
principalId: userId,
|
||||
hasMore: true
|
||||
},
|
||||
headers: {
|
||||
"Cookie": `did=web_45504037cde380da3c57769b2726e6f2`
|
||||
}
|
||||
})
|
||||
|
||||
let list = result.data.data.list;
|
||||
// 创建文件夹
|
||||
mkDir(userId)
|
||||
|
||||
list.forEach(async (val, index) => {
|
||||
// 如果遇到 图片
|
||||
if (val.workType == 'vertical' || val.workType == 'multiple' || val.workType == 'single') {
|
||||
DownImage(val)
|
||||
} else {
|
||||
console.log(val.id);
|
||||
DownMp4(val.playUrl,val.id, userId)
|
||||
}
|
||||
});
|
||||
// res.json(list);
|
||||
});
|
||||
|
||||
/**
|
||||
* 发送get请求获取视频流数据
|
||||
* @param {*} url 视频地址
|
||||
* @param {*} encoding 获取的类型
|
||||
* @param {*} filename 文件名
|
||||
* @returns
|
||||
*/
|
||||
const getVideoData = (url, encoding, filename) => {
|
||||
return new Promise((resolve, reject) => {
|
||||
let req = https.get(url, function (res) {
|
||||
let result = ''
|
||||
encoding && res.setEncoding(encoding)
|
||||
res.on('data', function (d) {
|
||||
result += d
|
||||
})
|
||||
res.on('end', function () {
|
||||
savefileToPath(result, filename)
|
||||
})
|
||||
res.on('error', function (e) {
|
||||
console.log("1 res.on 出错了：", e);
|
||||
console.log("重新请求数据中：", url);
|
||||
getVideoData(url, encoding, filename)
|
||||
// reject(e)
|
||||
})
|
||||
})
|
||||
req.end()
|
||||
})
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 保存视频到本地
|
||||
* @param {*} fileData 视频流数据
|
||||
* @param {*} fileName 文件名
|
||||
* @returns
|
||||
*/
|
||||
const savefileToPath = async (fileData, fileName) => {
|
||||
let fileFullName = `dist/${fileName}.mp4`;
|
||||
return new Promise((resolve, reject) => {
|
||||
fs.writeFile(fileFullName, fileData, 'binary', function (err) {
|
||||
if (err) {
|
||||
console.log('savefileToPath error:', err)
|
||||
} else {
|
||||
TotalCount += 1;
|
||||
console.log(`第 ${TotalCount} 条视频：${fileName}.mp4 已下载！`);
|
||||
Screenshot(fileName)
|
||||
if (TotalCount >= TotalFeeds.length) {
|
||||
console.log("");
|
||||
console.log(`已下载：${TotalFeeds.length} 条视频，20秒后将开始继续下载..`);
|
||||
console.log("结束 ==============================================================");
|
||||
setTimeout(() => {
|
||||
main();
|
||||
}, 10000)
|
||||
}
|
||||
resolve('已下载')
|
||||
}
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
// /**
|
||||
// *
|
||||
// * @param {*} url 视频下载地址
|
||||
// * @param {*} id 视频文件名
|
||||
// * @param {*} page 用主播id作为文件夹名称
|
||||
// */
|
||||
// function DownMp4(url, id, page) {
|
||||
// var options = {
|
||||
// url: url,
|
||||
// headers: {
|
||||
// 'Upgrade-Insecure-Requests': '1',
|
||||
// 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.97 Safari/537.36',
|
||||
// "Cookie": `did=web_45504037cde380da3c57769b2726e6f2`
|
||||
// }
|
||||
// };
|
||||
|
||||
// //发送get请求下载视频
|
||||
// request(options)
|
||||
// .on('error', function (err) {
|
||||
// console.log(err)
|
||||
// })
|
||||
// // 将视频写入到mp4文件夹里
|
||||
// .pipe(fs.createWriteStream(`mp4/${page}/${id}.mp4`))
|
||||
// }
|
||||
|
||||
function DownImage(data) {
|
||||
let promise = Promise.resolve();
|
||||
data.imgUrls.forEach((val, ix) => {
|
||||
promise = promise.then(() => {
|
||||
return new Promise(resolve => {
|
||||
setTimeout(async () => {
|
||||
let index = val.indexOf("atlas/") + 6
|
||||
var options = {
|
||||
url: val,
|
||||
headers: { 'Upgrade-Insecure-Requests': '1', 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.97 Safari/537.36' }
|
||||
};
|
||||
//发送get请求下载视频
|
||||
request(options)
|
||||
.on('error', function (err) {
|
||||
console.log(err)
|
||||
})
|
||||
// 将视频写入到mp4文件夹里
|
||||
.pipe(fs.createWriteStream(`mp4/${data.author.id}/${val.substring(index)}`))
|
||||
|
||||
resolve('成功');
|
||||
|
||||
}, 1)
|
||||
})
|
||||
.then(val => {
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 创建文件夹
|
||||
* @param {*} page
|
||||
*/
|
||||
function mkDir(page) {
|
||||
fs.mkdir(`mp4/${page}`, 0777, err => err ? console.log(err) : console.log('文件夹创建成功'))
|
||||
}
|
||||
|
||||
module.exports = router;
|
||||
Reference in New Issue
Block a user