FongMi
3 years ago
parent
c420df5c80
commit
22011c8412
@ -1,363 +1,55 @@ |
||||
package com.github.catvod.spider; |
||||
|
||||
import android.app.AlertDialog; |
||||
import android.content.DialogInterface; |
||||
import android.graphics.Color; |
||||
import android.graphics.drawable.ColorDrawable; |
||||
import android.os.SystemClock; |
||||
import android.text.TextUtils; |
||||
import android.util.Log; |
||||
import android.view.Gravity; |
||||
import android.widget.FrameLayout; |
||||
import android.widget.ImageView; |
||||
import android.content.Context; |
||||
|
||||
import com.github.catvod.ali.API; |
||||
import com.github.catvod.bean.Result; |
||||
import com.github.catvod.bean.Sub; |
||||
import com.github.catvod.bean.Vod; |
||||
import com.github.catvod.bean.ali.Auth; |
||||
import com.github.catvod.bean.ali.Data; |
||||
import com.github.catvod.bean.ali.Item; |
||||
import com.github.catvod.net.OkHttp; |
||||
import com.github.catvod.utils.Prefers; |
||||
import com.github.catvod.utils.QRCode; |
||||
import com.github.catvod.utils.Trans; |
||||
import com.github.catvod.utils.Utils; |
||||
import com.github.catvod.crawler.Spider; |
||||
|
||||
import org.json.JSONArray; |
||||
import org.json.JSONObject; |
||||
|
||||
import java.io.ByteArrayInputStream; |
||||
import java.util.ArrayList; |
||||
import java.util.Arrays; |
||||
import java.util.HashMap; |
||||
import java.util.LinkedHashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.concurrent.Executors; |
||||
import java.util.concurrent.ScheduledExecutorService; |
||||
import java.util.concurrent.TimeUnit; |
||||
import java.util.regex.Matcher; |
||||
import java.util.regex.Pattern; |
||||
|
||||
/** |
||||
* @author ColaMint & Adam & FongMi |
||||
*/ |
||||
public class Ali { |
||||
public class Ali extends Spider { |
||||
|
||||
public static final Pattern pattern = Pattern.compile("www.aliyundrive.com/s/([^/]+)(/folder/([^/]+))?"); |
||||
private ScheduledExecutorService service; |
||||
private final Auth auth; |
||||
private AlertDialog dialog; |
||||
|
||||
private static class Loader { |
||||
static volatile Ali INSTANCE = new Ali(); |
||||
} |
||||
|
||||
public static Ali get() { |
||||
return Loader.INSTANCE; |
||||
} |
||||
|
||||
public Ali() { |
||||
this.auth = new Auth(); |
||||
} |
||||
|
||||
public Ali init(String token) { |
||||
auth.setRefreshToken(Prefers.getString("token", token)); |
||||
return this; |
||||
} |
||||
|
||||
private HashMap<String, String> getHeaders() { |
||||
HashMap<String, String> headers = new HashMap<>(); |
||||
headers.put("User-Agent", Utils.CHROME); |
||||
headers.put("Referer", "https://www.aliyundrive.com/"); |
||||
return headers; |
||||
} |
||||
|
||||
private HashMap<String, String> getAuthHeader() { |
||||
HashMap<String, String> headers = getHeaders(); |
||||
headers.put("content-type", "application/json"); |
||||
headers.put("Authorization", auth.getAccessToken()); |
||||
headers.put("x-share-token", auth.getShareToken()); |
||||
return headers; |
||||
} |
||||
|
||||
private String post(String url, JSONObject body) { |
||||
url = url.startsWith("https") ? url : "https://api.aliyundrive.com/" + url; |
||||
return OkHttp.postJson(url, body.toString(), getHeaders()); |
||||
} |
||||
|
||||
private String postAuth(String url, JSONObject body) { |
||||
url = url.startsWith("https") ? url : "https://api.aliyundrive.com/" + url; |
||||
String result = OkHttp.postJson(url, body.toString(), getAuthHeader()); |
||||
if (check401(result)) return postAuth(url, body); |
||||
return result; |
||||
} |
||||
|
||||
private boolean check401(String result) { |
||||
if (result.contains("AccessTokenInvalid")) return refreshAccessToken(); |
||||
if (result.contains("ShareLinkTokenInvalid")) return refreshShareToken(); |
||||
if (result.contains("InvalidParameterNotMatch")) return refreshShareToken(); |
||||
return false; |
||||
@Override |
||||
public void init(Context context, String extend) { |
||||
API.get().setRefreshToken(extend); |
||||
} |
||||
|
||||
@Override |
||||
public String detailContent(List<String> ids) throws Exception { |
||||
String url = ids.get(0).trim(); |
||||
Matcher matcher = pattern.matcher(url); |
||||
if (!matcher.find()) return ""; |
||||
String shareId = matcher.group(1); |
||||
String fileId = matcher.groupCount() == 3 ? matcher.group(3) : ""; |
||||
auth.setShareId(shareId); |
||||
refreshShareToken(); |
||||
return Result.string(getVod(url, fileId)); |
||||
API.get().setShareId(shareId); |
||||
return Result.string(API.get().getVod(url, fileId)); |
||||
} |
||||
|
||||
public String playerContent(String flag, String id) { |
||||
@Override |
||||
public String playerContent(String flag, String id, List<String> vipFlags) { |
||||
API.get().checkAccessToken(); |
||||
String[] ids = id.split("\\+"); |
||||
if (auth.isEmpty()) refreshAccessToken(); |
||||
return Result.get().url(getDownloadUrl(ids[0])).subs(getSub(ids)).header(getHeaders()).string(); |
||||
} |
||||
|
||||
private Vod getVod(String url, String fileId) throws Exception { |
||||
JSONObject body = new JSONObject(); |
||||
body.put("share_id", auth.getShareId()); |
||||
String json = post("adrive/v3/share_link/get_share_by_anonymous", body); |
||||
JSONObject object = new JSONObject(json); |
||||
List<Item> files = new ArrayList<>(); |
||||
LinkedHashMap<String, List<String>> subMap = new LinkedHashMap<>(); |
||||
listFiles(new Item(getParentFileId(fileId, object)), files, subMap); |
||||
List<String> playUrls = new ArrayList<>(); |
||||
for (Item file : files) playUrls.add(Trans.get(file.getDisplayName()) + "$" + file.getFileId() + findSubs(file.getName(), subMap)); |
||||
List<String> sourceUrls = new ArrayList<>(); |
||||
sourceUrls.add(TextUtils.join("#", playUrls)); |
||||
sourceUrls.add(TextUtils.join("#", playUrls)); |
||||
Vod vod = new Vod(); |
||||
vod.setVodId(url); |
||||
vod.setVodContent(url); |
||||
vod.setVodPic(object.getString("avatar")); |
||||
vod.setVodName(object.getString("share_name")); |
||||
vod.setVodPlayUrl(TextUtils.join("$$$", sourceUrls)); |
||||
vod.setVodPlayFrom("原畫"); |
||||
vod.setTypeName("阿里雲盤"); |
||||
return vod; |
||||
} |
||||
|
||||
private void listFiles(Item folder, List<Item> files, LinkedHashMap<String, List<String>> subMap) throws Exception { |
||||
listFiles(folder, files, subMap, ""); |
||||
} |
||||
|
||||
private void listFiles(Item parent, List<Item> files, LinkedHashMap<String, List<String>> subMap, String marker) throws Exception { |
||||
JSONObject body = new JSONObject(); |
||||
List<Item> folders = new ArrayList<>(); |
||||
body.put("limit", 200); |
||||
body.put("share_id", auth.getShareId()); |
||||
body.put("parent_file_id", parent.getFileId()); |
||||
body.put("order_by", "name"); |
||||
body.put("order_direction", "ASC"); |
||||
if (marker.length() > 0) body.put("marker", marker); |
||||
Item item = Item.objectFrom(postAuth("adrive/v3/file/list", body)); |
||||
for (Item file : item.getItems()) { |
||||
if (file.getType().equals("folder")) { |
||||
folders.add(file); |
||||
} else if (file.getCategory().equals("video") || file.getCategory().equals("audio")) { |
||||
files.add(file.parent(parent.getName())); |
||||
} else if (Utils.isSub(file.getExt())) { |
||||
String key = file.removeExt(); |
||||
if (!subMap.containsKey(key)) subMap.put(key, new ArrayList<>()); |
||||
subMap.get(key).add(key + "@@@" + file.getExt() + "@@@" + file.getFileId()); |
||||
} |
||||
} |
||||
if (item.getNextMarker().length() > 0) { |
||||
listFiles(parent, files, subMap, item.getNextMarker()); |
||||
} |
||||
for (Item folder : folders) { |
||||
listFiles(folder, files, subMap); |
||||
} |
||||
} |
||||
|
||||
private String getParentFileId(String fileId, JSONObject shareInfo) throws Exception { |
||||
JSONArray array = shareInfo.getJSONArray("file_infos"); |
||||
if (!TextUtils.isEmpty(fileId)) return fileId; |
||||
if (array.length() == 0) return ""; |
||||
JSONObject fileInfo = array.getJSONObject(0); |
||||
if (fileInfo.getString("type").equals("folder")) return fileInfo.getString("file_id"); |
||||
if (fileInfo.getString("type").equals("file") && fileInfo.getString("category").equals("video")) return "root"; |
||||
return ""; |
||||
} |
||||
|
||||
private boolean refreshAccessToken() { |
||||
try { |
||||
JSONObject body = new JSONObject(); |
||||
String token = auth.getRefreshToken(); |
||||
if (token.startsWith("http")) token = OkHttp.string(token).replaceAll("[^A-Za-z0-9]", ""); |
||||
body.put("refresh_token", token); |
||||
body.put("grant_type", "refresh_token"); |
||||
JSONObject object = new JSONObject(post("https://auth.aliyundrive.com/v2/account/token", body)); |
||||
auth.setUserId(object.getString("user_id")); |
||||
auth.setDeviceId(object.getString("device_id")); |
||||
auth.setAccessToken(object.getString("token_type") + " " + object.getString("access_token")); |
||||
auth.setRefreshToken(object.getString("refresh_token")); |
||||
return true; |
||||
} catch (Exception e) { |
||||
stopService(); |
||||
auth.clean(); |
||||
getQRCode(); |
||||
return true; |
||||
} finally { |
||||
while (auth.isEmpty()) SystemClock.sleep(250); |
||||
} |
||||
} |
||||
|
||||
private boolean refreshShareToken() { |
||||
try { |
||||
JSONObject body = new JSONObject(); |
||||
body.put("share_id", auth.getShareId()); |
||||
body.put("share_pwd", ""); |
||||
JSONObject object = new JSONObject(post("v2/share_link/get_share_token", body)); |
||||
auth.setShareToken(object.getString("share_token")); |
||||
return true; |
||||
} catch (Exception e) { |
||||
Init.show("來晚啦，該分享已失效。"); |
||||
e.printStackTrace(); |
||||
return false; |
||||
if (flag.equals("原畫")) { |
||||
return Result.get().url(API.get().getDownloadUrl(ids[0])).subs(API.get().getSub(ids)).header(API.get().getHeader()).parse(0).string(); |
||||
} else { |
||||
return Result.get().url(API.get().getPreviewUrl(ids[0])).subs(API.get().getSub(ids)).header(API.get().getHeader()).parse(0).string(); |
||||
} |
||||
} |
||||
|
||||
private String findSubs(String name, Map<String, List<String>> subMap) { |
||||
name = name.substring(0, name.lastIndexOf(".")); |
||||
List<String> subs = subMap.get(name); |
||||
if (subs != null && subs.size() > 0) return combineSubs(subs); |
||||
StringBuilder sb = new StringBuilder(); |
||||
for (Map.Entry<String, List<String>> entry : subMap.entrySet()) sb.append(combineSubs(entry.getValue())); |
||||
return sb.toString(); |
||||
} |
||||
|
||||
private String combineSubs(List<String> subs) { |
||||
StringBuilder sb = new StringBuilder(); |
||||
for (String sub : subs) sb.append("+").append(sub); |
||||
return sb.toString(); |
||||
} |
||||
|
||||
private List<Sub> getSub(String[] ids) { |
||||
List<Sub> sub = new ArrayList<>(); |
||||
for (String text : ids) { |
||||
if (!text.contains("@@@")) continue; |
||||
String[] split = text.split("@@@"); |
||||
String name = split[0]; |
||||
String ext = split[1]; |
||||
String url = Proxy.getUrl() + "?do=ali&type=sub" + "&file_id=" + split[2]; |
||||
sub.add(Sub.create().name(name).ext(ext).url(url)); |
||||
} |
||||
return sub; |
||||
} |
||||
|
||||
private String getPreviewQuality(JSONArray taskList) throws Exception { |
||||
for (String templateId : Arrays.asList("FHD", "HD", "SD", "LD")) { |
||||
for (int i = 0; i < taskList.length(); ++i) { |
||||
JSONObject task = taskList.getJSONObject(i); |
||||
if (task.getString("template_id").equals(templateId)) { |
||||
return task.getString("url"); |
||||
} |
||||
} |
||||
} |
||||
return taskList.getJSONObject(0).getString("url"); |
||||
} |
||||
|
||||
private String getPreviewUrl(String fileId) { |
||||
try { |
||||
JSONObject body = new JSONObject(); |
||||
body.put("file_id", fileId); |
||||
body.put("share_id", auth.getShareId()); |
||||
body.put("template_id", ""); |
||||
body.put("category", "live_transcoding"); |
||||
String json = postAuth("v2/file/get_share_link_video_preview_play_info", body); |
||||
JSONArray taskList = new JSONObject(json).getJSONObject("video_preview_play_info").getJSONArray("live_transcoding_task_list"); |
||||
Map<String, List<String>> respHeaders = new HashMap<>(); |
||||
OkHttp.stringNoRedirect(getPreviewQuality(taskList), getHeaders(), respHeaders); |
||||
return OkHttp.getRedirectLocation(respHeaders); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
return ""; |
||||
} |
||||
} |
||||
|
||||
private String getDownloadUrl(String fileId) { |
||||
try { |
||||
JSONObject body = new JSONObject(); |
||||
body.put("file_id", fileId); |
||||
body.put("share_id", auth.getShareId()); |
||||
body.put("expire_sec", 600); |
||||
String json = postAuth("v2/file/get_share_link_download_url", body); |
||||
Log.e("DDD", json); |
||||
String url = new JSONObject(json).optString("download_url"); |
||||
Map<String, List<String>> respHeaders = new HashMap<>(); |
||||
OkHttp.stringNoRedirect(url, getHeaders(), respHeaders); |
||||
return OkHttp.getRedirectLocation(respHeaders); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
return ""; |
||||
} |
||||
} |
||||
|
||||
public Object[] vod(Map<String, String> params) { |
||||
String fileId = params.get("file_id"); |
||||
String text = OkHttp.string(getDownloadUrl(fileId), getAuthHeader()); |
||||
Object[] result = new Object[3]; |
||||
result[0] = 200; |
||||
result[1] = "application/octet-stream"; |
||||
result[2] = new ByteArrayInputStream(text.getBytes()); |
||||
return result; |
||||
} |
||||
|
||||
private void getQRCode() { |
||||
Data data = Data.objectFrom(OkHttp.string("https://passport.aliyundrive.com/newlogin/qrcode/generate.do?appName=aliyun_drive&fromSite=52&appName=aliyun_drive&appEntrance=web&isMobile=false&lang=zh_CN&returnUrl=&bizParams=&_bx-v=2.2.3")).getContent().getData(); |
||||
Init.run(() -> showQRCode(data)); |
||||
} |
||||
|
||||
private void showQRCode(Data data) { |
||||
try { |
||||
FrameLayout.LayoutParams params = new FrameLayout.LayoutParams(Utils.dp2px(240), Utils.dp2px(240)); |
||||
ImageView image = new ImageView(Init.context()); |
||||
image.setScaleType(ImageView.ScaleType.CENTER_CROP); |
||||
image.setImageBitmap(QRCode.getBitmap(data.getCodeContent(), 240, 2)); |
||||
FrameLayout frame = new FrameLayout(Init.context()); |
||||
params.gravity = Gravity.CENTER; |
||||
frame.addView(image, params); |
||||
dialog = new AlertDialog.Builder(Init.getActivity()).setView(frame).setOnDismissListener(this::dismiss).show(); |
||||
dialog.getWindow().setBackgroundDrawable(new ColorDrawable(Color.TRANSPARENT)); |
||||
Init.execute(() -> startService(data.getParams())); |
||||
Init.show("請使用阿里雲盤 App 掃描二維碼"); |
||||
} catch (Exception ignored) { |
||||
} |
||||
} |
||||
|
||||
private void startService(Map<String, String> params) { |
||||
service = Executors.newScheduledThreadPool(1); |
||||
service.scheduleAtFixedRate(() -> { |
||||
Data result = Data.objectFrom(OkHttp.post("https://passport.aliyundrive.com/newlogin/qrcode/query.do?appName=aliyun_drive&fromSite=52&_bx-v=2.2.3", params)).getContent().getData(); |
||||
if (result.hasToken()) setToken(result.getToken()); |
||||
}, 1, 1, TimeUnit.SECONDS); |
||||
} |
||||
|
||||
private void setToken(String value) { |
||||
Prefers.put("token", value); |
||||
Init.show("請重新進入播放頁"); |
||||
auth.setRefreshToken(value); |
||||
stopService(); |
||||
} |
||||
|
||||
private void stopService() { |
||||
if (service != null) service.shutdownNow(); |
||||
Init.run(this::dismiss); |
||||
} |
||||
|
||||
private void dismiss(DialogInterface dialog) { |
||||
stopService(); |
||||
} |
||||
|
||||
private void dismiss() { |
||||
try { |
||||
if (dialog != null) dialog.dismiss(); |
||||
} catch (Exception ignored) { |
||||
} |
||||
public static Object[] vod(Map<String, String> params) { |
||||
String type = params.get("type"); |
||||
if (type.equals("sub")) return API.get().proxySub(params); |
||||
if (type.equals("m3u8")) return API.get().proxyM3U8(params); |
||||
if (type.equals("media")) return API.get().proxyMedia(params); |
||||
return null; |
||||
} |
||||
} |
||||
@ -1 +1 @@ |
||||
029605ba89c58f14982a8aa1665cbeef |
||||
a6131c24d26ebf307dd82c75ef91591f |
||||
|
||||
Loading…
Reference in new issue