add - remark111
This commit is contained in:
yangqiang3504
@@ -9,9 +9,7 @@ import com.github.catvod.utils.Misc;
|
||||
import com.github.catvod.utils.okhttp.OKCallBack;
|
||||
import com.github.catvod.utils.okhttp.OkHttpUtil;
|
||||
import okhttp3.Call;
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Response;
|
||||
import okhttp3.ResponseBody;
|
||||
import org.json.JSONArray;
|
||||
import org.json.JSONException;
|
||||
import org.json.JSONObject;
|
||||
@@ -30,7 +28,6 @@ import java.util.regex.Pattern;
|
||||
public class PushAgent extends Spider {
|
||||
private static long timeToken = 0;
|
||||
private static String accessToken = "";
|
||||
private static String refreshToken = "http://catvod.fun:8001/tv/ali.txt";
|
||||
private static Map<String, String> shareToken = new HashMap<>();
|
||||
private static Map<String, Long> shareExpires = new HashMap<>();
|
||||
private static final Map<String, Map<String, String>> videosMap = new HashMap<>();
|
||||
@@ -39,8 +36,6 @@ public class PushAgent extends Spider {
|
||||
public static Pattern regexAli = Pattern.compile("(https://www.aliyundrive.com/s/[^\"]+)");
|
||||
public static Pattern regexAliFolder = Pattern.compile("www.aliyundrive.com/s/([^/]+)(/folder/([^/]+))?");
|
||||
|
||||
public static JSONObject siteRule = null;
|
||||
public static Integer type=1;
|
||||
@Override
|
||||
public void init(Context context, String extend) {
|
||||
super.init(context, extend);
|
||||
@@ -54,13 +49,13 @@ public class PushAgent extends Spider {
|
||||
|
||||
public static void getToken(String token){
|
||||
if (token.startsWith("http")) {
|
||||
refreshToken = OkHttpUtil.string(token, null);
|
||||
}else refreshToken = token;
|
||||
Misc.refreshToken = OkHttpUtil.string(token, null);
|
||||
}else Misc.refreshToken = token;
|
||||
}
|
||||
|
||||
public static JSONObject fetchRule(boolean flag,int t) {
|
||||
try {
|
||||
if (flag || siteRule == null) {
|
||||
if (flag || Misc.siteRule == null) {
|
||||
String json = OkHttpUtil.string(Misc.jsonUrl+"?t="+Time(), null);
|
||||
JSONObject jo = new JSONObject(json);
|
||||
if(t==0) {
|
||||
@@ -69,18 +64,18 @@ public class PushAgent extends Spider {
|
||||
String[] info = fenlei.split("\\$");
|
||||
jo.remove(info[1]);
|
||||
}
|
||||
siteRule = jo;
|
||||
String tk = siteRule.optString("token","");
|
||||
Misc.siteRule = jo;
|
||||
String tk = Misc.siteRule.optString("token","");
|
||||
if(!tk.equals("")){
|
||||
getToken(tk);
|
||||
}
|
||||
type = siteRule.optInt("ua", 1);
|
||||
Misc.type = Misc.siteRule.optInt("ua", 1);
|
||||
}
|
||||
return jo;
|
||||
}
|
||||
} catch (JSONException e) {
|
||||
}
|
||||
return siteRule;
|
||||
return Misc.siteRule;
|
||||
}
|
||||
|
||||
public static String getRuleVal(JSONObject o,String key, String defaultVal) {
|
||||
@@ -134,7 +129,7 @@ public class PushAgent extends Spider {
|
||||
if (accessToken.isEmpty() || timeToken - timeSys <= 600) {
|
||||
try {
|
||||
JSONObject json = new JSONObject();
|
||||
json.put("refresh_token", refreshToken);
|
||||
json.put("refresh_token", Misc.refreshToken);
|
||||
JSONObject response = new JSONObject(postJson("https://api.aliyundrive.com/token/refresh", json.toString(), getHeaders()));
|
||||
accessToken = response.getString("token_type") + " " + response.getString("access_token");
|
||||
timeToken = response.getLong("expires_in") + timeSys;
|
||||
@@ -324,7 +319,7 @@ public class PushAgent extends Spider {
|
||||
}
|
||||
|
||||
|
||||
public static void listFiles(Map<String, String> map, String shareId, String shareToken, String fileId) {
|
||||
public static void listFiles(Map<String, String> map, String shareId, String shareToken, String fileId,String _url) {
|
||||
try {
|
||||
String url = "https://api.aliyundrive.com/adrive/v3/file/list";
|
||||
HashMap<String, String> headers = getHeaders();
|
||||
@@ -355,7 +350,7 @@ public class PushAgent extends Spider {
|
||||
//vnd.rn-realmedia-vbr 为rmvb格式
|
||||
if (item.getString("mime_type").contains("video")||item.getString("mime_type").contains("vnd.rn-realmedia-vbr")) {
|
||||
String replace = item.getString("name").replace("#", "_").replace("$", "_");
|
||||
map.put(replace, shareId + "+" + shareToken + "+" + item.getString("file_id")+"+"+item.getString("category"));
|
||||
map.put(replace, shareId + "+" + shareToken + "+" + item.getString("file_id")+"+"+item.getString("category")+"+"+_url);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -364,7 +359,7 @@ public class PushAgent extends Spider {
|
||||
|
||||
for (String item : arrayList) {
|
||||
try {
|
||||
listFiles(map, shareId, shareToken, item);
|
||||
listFiles(map, shareId, shareToken, item,_url);
|
||||
} catch (Exception e) {
|
||||
SpiderDebug.log(e);
|
||||
return;
|
||||
@@ -418,7 +413,7 @@ public class PushAgent extends Spider {
|
||||
}
|
||||
String shareTk = getShareTk(shareId, "");
|
||||
Map<String, String> hashMap = new HashMap<>();
|
||||
listFiles(hashMap, shareId, shareTk, fileId);
|
||||
listFiles(hashMap, shareId, shareTk, fileId,url);
|
||||
ArrayList<String> arrayList2 = new ArrayList<>(hashMap.keySet());
|
||||
Collections.sort(arrayList2);
|
||||
for (String item : arrayList2) {
|
||||
@@ -476,7 +471,7 @@ public class PushAgent extends Spider {
|
||||
vodAtom.put("vod_pic", pic);
|
||||
vodAtom.put("type_name", typeName);
|
||||
vodAtom.put("vod_content", url);
|
||||
vodAtom.put("vod_area", type + refreshToken);
|
||||
vodAtom.put("vod_area", Misc.btype);
|
||||
if (Misc.isVip(url) && !url.contains("qq.com") && !url.contains("mgtv.com")) {
|
||||
Elements playListA = null;
|
||||
Document doc = Jsoup.parse(OkHttpUtil.string(url, Misc.Headers(0,url)));
|
||||
@@ -793,14 +788,14 @@ public class PushAgent extends Spider {
|
||||
result.put("playUrl", "");
|
||||
if(id.contains("bilibili")){
|
||||
result.put("header", Misc.jHeaders(0,id).toString());
|
||||
} else result.put("header", Misc.jHeaders(type,id).toString());
|
||||
} else result.put("header", Misc.jHeaders(Misc.type,id).toString());
|
||||
return result.toString();
|
||||
}
|
||||
case "player": {
|
||||
result.put("parse", 0);
|
||||
result.put("playUrl", "");
|
||||
result.put("url", id);
|
||||
result.put("header", Misc.jHeaders(type,id).toString());
|
||||
result.put("header", Misc.jHeaders(Misc.type,id).toString());
|
||||
return result.toString();
|
||||
}
|
||||
case "AliYun":
|
||||
@@ -812,6 +807,7 @@ public class PushAgent extends Spider {
|
||||
result.put("playUrl", "");
|
||||
result.put("url", url);
|
||||
result.put("header", "");
|
||||
Misc.btype = split[4];
|
||||
return result.toString();
|
||||
case "4K原画": {
|
||||
split = id.split("\\+");
|
||||
@@ -828,7 +824,7 @@ public class PushAgent extends Spider {
|
||||
}
|
||||
}
|
||||
if(flag.startsWith("嗅探")){
|
||||
result.put("header", Misc.jHeaders(type,id).toString());
|
||||
result.put("header", Misc.jHeaders(Misc.type,id).toString());
|
||||
}
|
||||
if(id.contains("b23.tv"))result.put("header", Misc.jHeaders(1,id).toString());
|
||||
result.put("parse", 1);
|
||||
|
||||
@@ -16,6 +16,9 @@ public class Misc {
|
||||
public static final String DeAgent = "Dalvik/2.1.0 (Linux; U; Android " + Build.VERSION.RELEASE + "; " + Build.MODEL + " Build/" + Build.ID + ")";
|
||||
public static final String MoAgent = "Mozilla/5.0 (Linux; Android 11; Ghxi Build/RKQ1.200826.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/76.0.3809.89 Mobile Safari/537.36 T7/12.16 SearchCraft/3.9.1 (Baidu; P1 11)";
|
||||
public static String jsonUrl = "http://test.xinjun58.com/sp/d.json";
|
||||
public static String refreshToken="http://catvod.fun:8001/tv/ali.txt";
|
||||
public static JSONObject siteRule = null;
|
||||
public static Integer type=1;
|
||||
public static boolean isVip(String url) {
|
||||
// 适配2.0.6的调用应用内解析列表的支持, 需要配合直连分析一起使用，参考cjt影视和极品直连
|
||||
try {
|
||||
|
||||
Reference in New Issue
Block a user