518 строки
22 KiB
Java
518 строки
22 KiB
Java
package com.github.catvod.spider;
|
|
|
|
import android.content.Context;
|
|
import android.text.TextUtils;
|
|
|
|
import com.github.catvod.crawler.Spider;
|
|
import com.github.catvod.crawler.SpiderDebug;
|
|
import com.github.catvod.utils.okhttp.OKCallBack;
|
|
import com.github.catvod.utils.okhttp.OkHttpUtil;
|
|
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
import java.util.LinkedHashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.TreeMap;
|
|
import java.util.regex.Matcher;
|
|
import java.util.regex.Pattern;
|
|
|
|
import okhttp3.Call;
|
|
|
|
public class YydsAli1 extends Spider {
|
|
private static final String siteUrl = "https://cmn.yyds.fans";
|
|
|
|
@Override
|
|
public void init(Context context) {
|
|
super.init(context);
|
|
}
|
|
|
|
private HashMap<String, String> getHeaders(String url) {
|
|
HashMap<String, String> headers = new HashMap<>();
|
|
headers.put("accept", "application/json, text/plain, */*");
|
|
headers.put("origin", "https://yyds.fans");
|
|
headers.put("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.54 Safari/537.36");
|
|
return headers;
|
|
}
|
|
|
|
@Override
|
|
public String homeContent(boolean filter) {
|
|
try {
|
|
String url = siteUrl + "/api/categories";
|
|
String content = OkHttpUtil.string(url, getHeaders(url));
|
|
JSONObject jsonObject = new JSONObject(content);
|
|
JSONArray jsonArray = jsonObject.getJSONArray("data");
|
|
JSONArray classes = new JSONArray();
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject jObj = jsonArray.getJSONObject(i);
|
|
String typeName = jObj.getString("title");
|
|
if (typeName.equals("首页") || typeName.equals("热门精选")) {
|
|
continue;
|
|
}
|
|
String typeId = jObj.getString("id");
|
|
JSONObject newCls = new JSONObject();
|
|
newCls.put("type_id", typeId);
|
|
newCls.put("type_name", typeName);
|
|
classes.put(newCls);
|
|
}
|
|
JSONObject result = new JSONObject();
|
|
result.put("class", classes);
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
@Override
|
|
public String homeVideoContent() {
|
|
try {
|
|
JSONArray videos = new JSONArray();
|
|
try {
|
|
String url = siteUrl + "/api/posts";
|
|
JSONObject json = new JSONObject();
|
|
json.put("category_id", "0");
|
|
json.put("skip", "0");
|
|
json.put("limit", "30");
|
|
json.put("keyword", "");
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), url, json.toString(), getHeaders(url), new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
try {
|
|
JSONObject jsonObject = new JSONObject(response);
|
|
JSONArray jsonArray = jsonObject.getJSONArray("data");
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject vObj = jsonArray.getJSONObject(i);
|
|
JSONObject v = new JSONObject();
|
|
v.put("vod_id", vObj.getString("id"));
|
|
v.put("vod_name", vObj.getString("title"));
|
|
v.put("vod_pic", vObj.optString("cover"));
|
|
String mark = vObj.optString("subtitle");
|
|
if (mark.equals("null"))
|
|
mark = "";
|
|
v.put("vod_remarks", mark);
|
|
videos.put(v);
|
|
}
|
|
} catch (JSONException e) {
|
|
}
|
|
}
|
|
});
|
|
} catch (Exception e) {
|
|
|
|
}
|
|
JSONObject result = new JSONObject();
|
|
result.put("list", videos);
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
@Override
|
|
public String categoryContent(String tid, String pg, boolean filter, HashMap<String, String> extend) {
|
|
try {
|
|
int limit = 30;
|
|
int page = Integer.parseInt(pg);
|
|
if (page == 0) {
|
|
page = 1;
|
|
}
|
|
String url = siteUrl + "/api/posts";
|
|
JSONObject json = new JSONObject();
|
|
json.put("category_id", tid);
|
|
json.put("skip", ((page - 1) * limit) + "");
|
|
json.put("limit", limit + "");
|
|
json.put("keyword", "");
|
|
JSONArray videos = new JSONArray();
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), url, json.toString(), getHeaders(url), new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
try {
|
|
JSONObject jsonObject = new JSONObject(response);
|
|
JSONArray jsonArray = jsonObject.getJSONArray("data");
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject vObj = jsonArray.getJSONObject(i);
|
|
JSONObject v = new JSONObject();
|
|
v.put("vod_id", vObj.getString("id"));
|
|
v.put("vod_name", vObj.getString("title"));
|
|
v.put("vod_pic", vObj.optString("cover"));
|
|
String mark = vObj.optString("subtitle");
|
|
if (mark.equals("null"))
|
|
mark = "";
|
|
v.put("vod_remarks", mark);
|
|
videos.put(v);
|
|
}
|
|
} catch (JSONException e) {
|
|
}
|
|
}
|
|
});
|
|
JSONObject result = new JSONObject();
|
|
result.put("page", page);
|
|
int pageCount = videos.length() == limit ? page + 1 : page;
|
|
result.put("pagecount", pageCount);
|
|
result.put("limit", limit);
|
|
result.put("total", Integer.MAX_VALUE);
|
|
result.put("list", videos);
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
Pattern aliyun = Pattern.compile(".*?aliyundrive.com/s/(\\w+)[^\\w]?");
|
|
Pattern aliyunShort = Pattern.compile(".*?alywp.net/(\\w+)[^\\w]?");
|
|
|
|
@Override
|
|
public String detailContent(List<String> ids) {
|
|
try {
|
|
String url = siteUrl + "/api/post-info";
|
|
JSONObject json = new JSONObject();
|
|
json.put("id", ids.get(0));
|
|
JSONObject vodAtom = new JSONObject();
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), url, json.toString(), getHeaders(url), new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
try {
|
|
JSONObject dataObject = new JSONObject(response);
|
|
JSONObject vObj = dataObject.getJSONObject("data");
|
|
|
|
vodAtom.put("vod_id", vObj.getString("id"));
|
|
vodAtom.put("vod_name", vObj.getString("title"));
|
|
vodAtom.put("vod_pic", vObj.getString("cover"));
|
|
vodAtom.put("type_name", "");
|
|
vodAtom.put("vod_year", vObj.getString("year"));
|
|
vodAtom.put("vod_area", vObj.getString("region"));
|
|
String mark = vObj.optString("subtitle");
|
|
if (mark.equals("null"))
|
|
mark = "";
|
|
vodAtom.put("vod_remarks", mark);
|
|
vodAtom.put("vod_actor", vObj.getString("actors"));
|
|
vodAtom.put("vod_director", vObj.getString("director"));
|
|
String desc = vObj.optString("desc");
|
|
if (desc.equals("null"))
|
|
desc = "";
|
|
vodAtom.put("vod_content", desc);
|
|
|
|
Map<String, String> vod_play = new LinkedHashMap<>();
|
|
JSONArray jsonArray = vObj.getJSONArray("links");
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject obj = jsonArray.getJSONObject(i);
|
|
String link = obj.optString("link", "");
|
|
updatePlaylist(link, vod_play);
|
|
}
|
|
if (vod_play.size() == 0 && vObj.optString("content").length() > 0) {
|
|
updatePlaylist(vObj.optString("content"), vod_play);
|
|
}
|
|
if (vod_play.size() > 0) {
|
|
String vod_play_from = TextUtils.join("$$$", vod_play.keySet());
|
|
String vod_play_url = TextUtils.join("$$$", vod_play.values());
|
|
vodAtom.put("vod_play_from", vod_play_from);
|
|
vodAtom.put("vod_play_url", vod_play_url);
|
|
}
|
|
} catch (JSONException e) {
|
|
}
|
|
}
|
|
});
|
|
JSONObject result = new JSONObject();
|
|
JSONArray list = new JSONArray();
|
|
list.put(vodAtom);
|
|
result.put("list", list);
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
private void updatePlaylist(String link, Map<String, String> vod_play) {
|
|
String shareId = null;
|
|
Matcher matcher = aliyun.matcher(link);
|
|
if (matcher.find()) {
|
|
shareId = matcher.group(1);
|
|
} else {
|
|
matcher = aliyunShort.matcher(link);
|
|
if (matcher.find()) {
|
|
shareId = matcher.group(1);
|
|
Map<String, List<String>> respHeaders = new TreeMap<>();
|
|
OkHttpUtil.stringNoRedirect("https://alywp.net/" + shareId, null, respHeaders);
|
|
shareId = OkHttpUtil.getRedirectLocation(respHeaders);
|
|
if (shareId != null) {
|
|
matcher = aliyun.matcher(shareId);
|
|
if (matcher.find()) {
|
|
shareId = matcher.group(1);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (shareId != null) {
|
|
String shareToken = getShareTk(shareId, "");
|
|
ArrayList<String> vodItems = new ArrayList<>();
|
|
getFileList(shareToken, shareId, "", "root", vodItems);
|
|
vod_play.put("阿里云盘" + (vod_play.size() > 0 ? vod_play.size() : ""), TextUtils.join("#", vodItems));
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public String playerContent(String flag, String id, List<String> vipFlags) {
|
|
try {
|
|
String[] infos = id.split("\\+");
|
|
String shareTk = getShareTk(infos[0], "");
|
|
refreshTk();
|
|
if (!accessTk.isEmpty()) {
|
|
JSONObject json = new JSONObject();
|
|
json.put("share_id", infos[0]);
|
|
json.put("category", "live_transcoding");
|
|
json.put("file_id", infos[1]);
|
|
json.put("template_id", "");
|
|
HashMap<String, String> headers = new HashMap<>();
|
|
headers.put("x-share-token", shareTk);
|
|
headers.put("authorization", accessTk);
|
|
OKCallBack.OKCallBackString callback = new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
String videoUrl = "";
|
|
try {
|
|
JSONArray playList = new JSONObject(response).getJSONObject("video_preview_play_info").getJSONArray("live_transcoding_task_list");
|
|
String[] orders = new String[]{"FHD", "HD", "SD"};
|
|
for (String or : orders) {
|
|
for (int i = 0; i < playList.length(); i++) {
|
|
JSONObject obj = playList.getJSONObject(i);
|
|
if (obj.optString("template_id").equals(or)) {
|
|
videoUrl = obj.getString("url");
|
|
break;
|
|
}
|
|
}
|
|
if (!videoUrl.isEmpty())
|
|
break;
|
|
}
|
|
if (videoUrl.isEmpty() && playList.length() > 0) {
|
|
videoUrl = playList.getJSONObject(0).getString("url");
|
|
}
|
|
} catch (JSONException e) {
|
|
} finally {
|
|
setResult(videoUrl);
|
|
}
|
|
}
|
|
};
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), "https://api.aliyundrive.com/v2/file/get_share_link_video_preview_play_info", json.toString(), headers, callback);
|
|
JSONArray playList = new JSONObject(callback.getResult()).getJSONObject("video_preview_play_info").getJSONArray("live_transcoding_task_list");
|
|
String videoUrl = "";
|
|
String[] orders = new String[]{"FHD", "HD", "SD"};
|
|
for (String or : orders) {
|
|
for (int i = 0; i < playList.length(); i++) {
|
|
JSONObject obj = playList.getJSONObject(i);
|
|
if (obj.optString("template_id").equals(or)) {
|
|
videoUrl = obj.getString("url");
|
|
break;
|
|
}
|
|
}
|
|
if (!videoUrl.isEmpty())
|
|
break;
|
|
}
|
|
if (videoUrl.isEmpty() && playList.length() > 0) {
|
|
videoUrl = playList.getJSONObject(0).getString("url");
|
|
}
|
|
JSONObject headerObj = new JSONObject();
|
|
headerObj.put("user-agent", " Dalvik/2.1.0 (Linux; U; Android 7.0; ZTE BA520 Build/MRA58K)");
|
|
headerObj.put("referer", " https://www.aliyundrive.com/");
|
|
JSONObject result = new JSONObject();
|
|
result.put("parse", 0);
|
|
result.put("playUrl", "");
|
|
result.put("url", videoUrl);
|
|
result.put("header", headerObj.toString());
|
|
return result.toString();
|
|
}
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
@Override
|
|
public String searchContent(String key, boolean quick) {
|
|
try {
|
|
if (quick)
|
|
return "";
|
|
JSONArray videos = new JSONArray();
|
|
try {
|
|
String url = siteUrl + "/api/posts";
|
|
JSONObject json = new JSONObject();
|
|
json.put("category_id", "-1");
|
|
json.put("skip", "0");
|
|
json.put("limit", "30");
|
|
json.put("keyword", key);
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), url, json.toString(), getHeaders(url), new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
try {
|
|
JSONObject jsonObject = new JSONObject(response);
|
|
JSONArray jsonArray = jsonObject.getJSONArray("data");
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject vObj = jsonArray.getJSONObject(i);
|
|
JSONObject v = new JSONObject();
|
|
v.put("vod_id", vObj.getString("id"));
|
|
v.put("vod_name", vObj.getString("title"));
|
|
v.put("vod_pic", vObj.getString("cover"));
|
|
v.put("vod_remarks", vObj.getString("subtitle"));
|
|
videos.put(v);
|
|
}
|
|
} catch (JSONException e) {
|
|
}
|
|
}
|
|
});
|
|
|
|
} catch (Exception e) {
|
|
|
|
}
|
|
JSONObject result = new JSONObject();
|
|
result.put("list", videos);
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
private String aliTk = "";
|
|
|
|
private void fetchAliTk() {
|
|
if (aliTk.isEmpty()) {
|
|
try {
|
|
HashMap<String, String> headers = new HashMap<>();
|
|
headers.put("User-Agent", "okhttp/4.5.0");
|
|
aliTk = new JSONObject(OkHttpUtil.string("http://81.68.244.5/tv/alitk", headers)).optString("alitk");
|
|
} catch (JSONException e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
}
|
|
}
|
|
|
|
private String accessTk = "";
|
|
|
|
private void refreshTk() {
|
|
fetchAliTk();
|
|
if (!aliTk.isEmpty() && accessTk.isEmpty()) {
|
|
try {
|
|
JSONObject json = new JSONObject();
|
|
json.put("refresh_token", aliTk);
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), "https://api.aliyundrive.com/token/refresh", json.toString(), new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
try {
|
|
JSONObject obj = new JSONObject(response);
|
|
accessTk = obj.getString("token_type") + " " + obj.getString("access_token");
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
}
|
|
});
|
|
} catch (JSONException e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
}
|
|
}
|
|
|
|
private String getShareTk(String shareId, String sharePwd) {
|
|
try {
|
|
JSONObject json = new JSONObject();
|
|
json.put("share_id", shareId);
|
|
json.put("share_pwd", "");
|
|
OKCallBack.OKCallBackString callback = new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
|
|
}
|
|
};
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), "https://api.aliyundrive.com/v2/share_link/get_share_token", json.toString(), callback);
|
|
return new JSONObject(callback.getResult()).optString("share_token");
|
|
} catch (JSONException e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
|
|
private void getFileList(String shareTk, String shareId, String sharePwd, String root, ArrayList<String> vodItems) {
|
|
try {
|
|
// 取文件夹
|
|
JSONObject json = new JSONObject();
|
|
json.put("share_id", shareId);
|
|
json.put("parent_file_id", root);
|
|
json.put("limit", 100);
|
|
json.put("image_thumbnail_process", "image/resize,w_160/format,jpeg");
|
|
json.put("image_url_process", "image/resize,w_1920/format,jpeg");
|
|
json.put("video_thumbnail_process", "video/snapshot,t_1000,f_jpg,ar_auto,w_300");
|
|
json.put("order_by", "name");
|
|
json.put("order_direction", "ASC");
|
|
HashMap<String, String> headers = new HashMap<>();
|
|
headers.put("x-share-token", shareTk);
|
|
OKCallBack.OKCallBackString callback = new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
|
|
}
|
|
};
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), "https://api.aliyundrive.com/adrive/v3/file/list", json.toString(), headers, callback);
|
|
JSONArray rootList = new JSONObject(callback.getResult()).optJSONArray("items");
|
|
if (rootList != null && rootList.length() > 0) {
|
|
for (int i = 0; i < rootList.length(); i++) {
|
|
JSONObject item = rootList.getJSONObject(i);
|
|
if (item.getString("type").equals("folder")) {
|
|
String dirId = item.getString("file_id");
|
|
getFileList(shareTk, shareId, sharePwd, dirId, vodItems);
|
|
} else {
|
|
if (item.getString("type").equals("file") && !item.getString("file_extension").equals("txt")) {
|
|
String fileId = item.getString("file_id");
|
|
String fileName = item.getString("name");
|
|
vodItems.add(fileName + "$" + shareId + "+" + fileId);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
// 取文件列表
|
|
} catch (JSONException e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
}
|
|
}
|