136 lines
4.5 KiB
Java
136 lines
4.5 KiB
Java
package com.github.catvod.spider;
|
|
|
|
import android.util.Base64;
|
|
|
|
import com.github.catvod.crawler.SpiderDebug;
|
|
import com.github.catvod.utils.okhttp.OKCallBack;
|
|
import com.github.catvod.utils.okhttp.OkHttpUtil;
|
|
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
|
|
import java.io.IOException;
|
|
import java.net.URLEncoder;
|
|
import java.util.HashMap;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
|
|
import okhttp3.Call;
|
|
import okhttp3.Response;
|
|
|
|
/**
|
|
* 需配合猫大的解密接口使用，没有接口不用尝试。
|
|
*/
|
|
|
|
public class XPathBde4 extends XPath {
|
|
|
|
String tk = "";
|
|
|
|
@Override
|
|
protected void loadRuleExt(String json) {
|
|
try {
|
|
JSONObject jsonObj = new JSONObject(json);
|
|
tk = jsonObj.optString("decodeTk").trim();
|
|
} catch (JSONException e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
protected String categoryUrl(String tid, String pg, boolean filter, HashMap<String, String> extend) {
|
|
String url = rule.getCateUrl().replace("{catePg}", pg);
|
|
String s = "all";
|
|
if (extend != null) {
|
|
if (extend.containsKey("s")) {
|
|
s = extend.get("s");
|
|
}
|
|
}
|
|
url = url.replace("{cateId}", s);
|
|
url += "?";
|
|
if (extend != null && extend.size() > 0) {
|
|
for (Iterator<String> it = extend.keySet().iterator(); it.hasNext(); ) {
|
|
String key = it.next();
|
|
if (key.equals("s"))
|
|
continue;
|
|
String value = extend.get(key);
|
|
if (value.length() > 0) {
|
|
url += (key + "=" + URLEncoder.encode(value) + "&");
|
|
}
|
|
}
|
|
}
|
|
if (!tid.equals("*")) {
|
|
url += ("type=" + tid);
|
|
}
|
|
return url;
|
|
}
|
|
|
|
@Override
|
|
public String playerContent(String flag, String id, List<String> vipFlags) {
|
|
try {
|
|
fetchRule();
|
|
String webUrl = rule.getPlayUrl().isEmpty() ? id : rule.getPlayUrl().replace("{playUrl}", id);
|
|
SpiderDebug.log(webUrl);
|
|
String content = OkHttpUtil.string(webUrl, getHeaders(webUrl));
|
|
String startFlag = "var m3u8 = \"";
|
|
int start = content.indexOf(startFlag);
|
|
start = start + startFlag.length();
|
|
int end = content.indexOf("\";", start);
|
|
String m3u8 = content.substring(start, end).replace("\\", "").replace("https", "http");
|
|
SpiderDebug.log(m3u8);
|
|
HashMap<String, String> headers = getHeaders(m3u8);
|
|
|
|
OKCallBack<String> m3u8Callback = new OKCallBack<String>() {
|
|
@Override
|
|
public String onParseResponse(Call call, Response response) {
|
|
try {
|
|
return new String(Base64.encode(response.body().bytes(), Base64.DEFAULT));
|
|
} catch (IOException e) {
|
|
return "";
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
setResult("");
|
|
SpiderDebug.log(e);
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
}
|
|
};
|
|
OkHttpUtil.get(OkHttpUtil.defaultClient(), m3u8, null, headers, m3u8Callback);
|
|
String m3u8Data = m3u8Callback.getResult();
|
|
if (m3u8Data != null && !m3u8Data.isEmpty()) {
|
|
JSONObject result = new JSONObject();
|
|
JSONObject json = new JSONObject();
|
|
json.put("data", m3u8Data);
|
|
json.put("t", tk);
|
|
OkHttpUtil.postJson(OkHttpUtil.defaultClient(), "https://cat.idontcare.top/ssr/bde4", json.toString(), new OKCallBack.OKCallBackString() {
|
|
@Override
|
|
public void onFailure(Call call, Exception e) {
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(String response) {
|
|
try {
|
|
result.put("url", response);
|
|
} catch (JSONException e) {
|
|
}
|
|
}
|
|
});
|
|
result.put("parse", 0);
|
|
result.put("playUrl", "");
|
|
if (!rule.getPlayUa().isEmpty()) {
|
|
result.put("ua", rule.getPlayUa());
|
|
}
|
|
return result.toString();
|
|
|
|
}
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
}
|