mirror of https://github.com/FongMi/TV.git
FongMi
3 years ago
parent
e620faea0a
commit
3048407fea
@ -0,0 +1,23 @@ |
||||
<!DOCTYPE html> |
||||
<html lang="zh-TW"> |
||||
|
||||
<head> |
||||
<title>解析</title> |
||||
<meta charset="utf-8"/> |
||||
<meta name="viewport" content="width=device-width, user-scalable=yes, initial-scale=1"/> |
||||
</head> |
||||
|
||||
<body> |
||||
<script> |
||||
let html = ""; |
||||
const jxs = "%s"; |
||||
const url = "%s"; |
||||
const list = jxs.split(";"); |
||||
for (let i = 0; i < list.length; i++) { |
||||
html = html + "<iframe sandbox='allow-scripts allow-same-origin allow-forms' src=" + list[i] + url + "></iframe>"; |
||||
} |
||||
document.write(html); |
||||
</script> |
||||
</body> |
||||
|
||||
</html> |
||||
@ -0,0 +1,178 @@ |
||||
package com.fongmi.android.tv.player.parse; |
||||
|
||||
import android.text.TextUtils; |
||||
|
||||
import com.fongmi.android.tv.App; |
||||
import com.fongmi.android.tv.Constant; |
||||
import com.fongmi.android.tv.api.ApiConfig; |
||||
import com.fongmi.android.tv.bean.Parse; |
||||
import com.fongmi.android.tv.bean.Result; |
||||
import com.fongmi.android.tv.net.OkHttp; |
||||
import com.fongmi.android.tv.server.Server; |
||||
import com.fongmi.android.tv.ui.custom.CustomWebView; |
||||
import com.fongmi.android.tv.utils.Json; |
||||
import com.google.gson.JsonObject; |
||||
import com.google.gson.JsonParser; |
||||
|
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.concurrent.ExecutorService; |
||||
import java.util.concurrent.Executors; |
||||
import java.util.concurrent.TimeUnit; |
||||
|
||||
import okhttp3.Headers; |
||||
import okhttp3.Response; |
||||
|
||||
public class ParseJob { |
||||
|
||||
private ExecutorService executor; |
||||
private ExecutorService infinite; |
||||
private CustomWebView webView; |
||||
private Callback callback; |
||||
private Parse parse; |
||||
|
||||
public static ParseJob create(Callback callback) { |
||||
return new ParseJob(callback); |
||||
} |
||||
|
||||
public ParseJob(Callback callback) { |
||||
this.executor = Executors.newFixedThreadPool(2); |
||||
this.infinite = Executors.newCachedThreadPool(); |
||||
this.callback = callback; |
||||
} |
||||
|
||||
public ParseJob start(Result result, boolean useParse) { |
||||
setParse(result, useParse); |
||||
execute(result); |
||||
return this; |
||||
} |
||||
|
||||
private void setParse(Result result, boolean useParse) { |
||||
if (useParse) parse = ApiConfig.get().getParse(); |
||||
else if (result.getPlayUrl().startsWith("json:")) parse = Parse.get(1, result.getPlayUrl().substring(5)); |
||||
else if (result.getPlayUrl().startsWith("parse:")) parse = ApiConfig.get().getParse(result.getPlayUrl().substring(6)); |
||||
if (parse == null) parse = Parse.get(0, result.getPlayUrl(), result.getHeader()); |
||||
} |
||||
|
||||
private void execute(Result result) { |
||||
executor.execute(() -> { |
||||
try { |
||||
executor.submit(getTask(result)).get(Constant.TIMEOUT_PARSE_DEF, TimeUnit.MILLISECONDS); |
||||
} catch (Throwable e) { |
||||
onParseError(); |
||||
} |
||||
}); |
||||
} |
||||
|
||||
private Runnable getTask(Result result) { |
||||
return () -> { |
||||
try { |
||||
doInBackground(result.getKey(), result.getUrl(), result.getFlag()); |
||||
} catch (Exception e) { |
||||
onParseError(); |
||||
} |
||||
}; |
||||
} |
||||
|
||||
private void doInBackground(String key, String webUrl, String flag) throws Exception { |
||||
switch (parse.getType()) { |
||||
case 0: //嗅探
|
||||
App.post(() -> startWeb(key, parse.getUrl() + webUrl, parse.getHeaders(), callback)); |
||||
break; |
||||
case 1: //Json
|
||||
jsonParse(parse, webUrl, false); |
||||
break; |
||||
case 3: //聚合
|
||||
mixJson(webUrl, flag); |
||||
mixWeb(webUrl, flag); |
||||
break; |
||||
} |
||||
} |
||||
|
||||
private void jsonParse(Parse item, String webUrl, boolean strict) throws Exception { |
||||
Response response = OkHttp.newCall(item.getUrl() + webUrl, Headers.of(item.getHeaders())).execute(); |
||||
JsonObject object = JsonParser.parseString(response.body().string()).getAsJsonObject(); |
||||
object = object.has("data") ? object.getAsJsonObject("data") : object; |
||||
if (strict) checkResult(item, getHeader(object), Json.safeString(object, "url")); |
||||
else checkResult(getHeader(object), Json.safeString(object, "url")); |
||||
} |
||||
|
||||
private void mixJson(String webUrl, String flag) { |
||||
List<Parse> items = ApiConfig.get().getParses(1, flag); |
||||
for (Parse item : items) infinite.execute(() -> jsonParse(item, webUrl)); |
||||
} |
||||
|
||||
private void mixWeb(String webUrl, String flag) { |
||||
StringBuilder sb = new StringBuilder(); |
||||
List<Parse> items = ApiConfig.get().getParses(0, flag); |
||||
for (Parse item : items) sb.append(item.getUrl()).append(";"); |
||||
if (sb.length() > 0) App.post(() -> startWeb(Server.getParse(sb.toString(), webUrl), callback)); |
||||
} |
||||
|
||||
private void jsonParse(Parse item, String webUrl) { |
||||
try { |
||||
jsonParse(item, webUrl, true); |
||||
} catch (Exception ignored) { |
||||
} |
||||
} |
||||
|
||||
private void checkResult(HashMap<String, String> headers, String url) { |
||||
if (TextUtils.isEmpty(url)) onParseError(); |
||||
else onParseSuccess(headers, url, ""); |
||||
} |
||||
|
||||
private void checkResult(Parse item, HashMap<String, String> headers, String url) throws Exception { |
||||
int code = OkHttp.newCall(url, Headers.of(headers)).execute().code(); |
||||
if (code == 200) onParseSuccess(headers, url, item.getName()); |
||||
} |
||||
|
||||
private void startWeb(String url, Callback callback) { |
||||
startWeb(url, new HashMap<>(), callback); |
||||
} |
||||
|
||||
private void startWeb(String url, Map<String, String> headers, Callback callback) { |
||||
startWeb("", url, headers, callback); |
||||
} |
||||
|
||||
private void startWeb(String key, String url, Map<String, String> headers, Callback callback) { |
||||
webView = CustomWebView.create(App.get()).start(key, url, headers, callback); |
||||
} |
||||
|
||||
private HashMap<String, String> getHeader(JsonObject object) { |
||||
HashMap<String, String> headers = new HashMap<>(); |
||||
for (String key : object.keySet()) if (key.equalsIgnoreCase("user-agent") || key.equalsIgnoreCase("referer")) headers.put(key, object.get(key).getAsString()); |
||||
return headers; |
||||
} |
||||
|
||||
private void onParseSuccess(Map<String, String> headers, String url, String from) { |
||||
App.post(() -> { |
||||
if (callback != null) callback.onParseSuccess(headers, url, from); |
||||
stop(); |
||||
}); |
||||
} |
||||
|
||||
private void onParseError() { |
||||
App.post(() -> { |
||||
if (callback != null) callback.onParseError(); |
||||
stop(); |
||||
}); |
||||
} |
||||
|
||||
public void stop() { |
||||
if (executor != null) executor.shutdownNow(); |
||||
if (infinite != null) infinite.shutdownNow(); |
||||
if (webView != null) webView.stop(false); |
||||
infinite = null; |
||||
executor = null; |
||||
callback = null; |
||||
webView = null; |
||||
} |
||||
|
||||
public interface Callback { |
||||
|
||||
void onParseSuccess(Map<String, String> headers, String url, String from); |
||||
|
||||
void onParseError(); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue