BeartvSpider/app/src/main/java/com/github/catvod/spider/XPathMac.java

package com.github.catvod.spider;

import android.content.Context;
import android.text.TextUtils;
import android.util.Base64;

import com.github.catvod.crawler.SpiderDebug;
import com.github.catvod.utils.Utils;
import com.google.gson.Gson;

import org.json.JSONException;
import org.json.JSONObject;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.select.Elements;

import java.net.URLDecoder;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class XPathMac extends XPath {

    // 嘗試分析直連
    private boolean decodePlayUrl;
    // 嘗試匹配官源標識以調用應用配置中的解析列表
    private boolean decodeVipFlag;
    // 播放器配置js
    private String playerConfigJs = "";
    // 播放器配置js取值正則
    private String playerConfigJsRegex = "[\\W|\\S|.]*?MacPlayerConfig.player_list[\\W|\\S|.]*?=([\\W|\\S|.]*?),MacPlayerConfig.downer_list";
    // 站點里播放源對應的真實官源
    private final HashMap<String, String> show2VipFlag = new HashMap<>();

    /**
     * mac cms 直連和官源調用應用內播放列表支持
     *
     * @param context
     * @param extend
     */
    public void init(Context context, String extend) {
        super.init(context, extend);
    }

    @Override
    protected void loadRuleExt(String json) {
        try {
            JSONObject jsonObj = new JSONObject(json);
            decodePlayUrl = jsonObj.optBoolean("dcPlayUrl", false);
            decodeVipFlag = jsonObj.optBoolean("dcVipFlag", false);
            JSONObject dcShow2Vip = jsonObj.optJSONObject("dcShow2Vip");
            if (dcShow2Vip != null) {
                Iterator<String> keys = dcShow2Vip.keys();
                while (keys.hasNext()) {
                    String name = keys.next();
                    show2VipFlag.put(name.trim(), dcShow2Vip.getString(name).trim());
                }
            }
            playerConfigJs = jsonObj.optString("pCfgJs").trim();
            playerConfigJsRegex = jsonObj.optString("pCfgJsR", playerConfigJsRegex).trim();
        } catch (JSONException e) {
            SpiderDebug.log(e);
        }
    }

    @Override
    public String homeContent(boolean filter) {
        String result = super.homeContent(filter);
        if (result.length() > 0 && playerConfigJs.length() > 0) { // 嘗試通過playerConfigJs獲取展示和flag匹配關系
            String webContent = fetch(playerConfigJs);
            Matcher matcher = Pattern.compile(playerConfigJsRegex).matcher(webContent);
            if (matcher.find()) {
                try {
                    JSONObject jsonObject = new JSONObject(matcher.group(1));
                    Iterator<String> keys = jsonObject.keys();
                    while (keys.hasNext()) {
                        String key = keys.next();
                        JSONObject keyObj = jsonObject.optJSONObject(key);
                        if (keyObj == null) continue;
                        String show = keyObj.optString("show").trim();
                        if (show.isEmpty()) continue;
                        show2VipFlag.put(show, key);
                    }
                } catch (Exception e) {
                    SpiderDebug.log(e);
                }
            }
        }
        return result;
    }

    @Override
    public String detailContent(List<String> ids) {
        String result = super.detailContent(ids);
        if (decodeVipFlag && result.length() > 0) {
            try {
                JSONObject jsonObject = new JSONObject(result);
                String[] playFrom = jsonObject.optJSONArray("list").getJSONObject(0).optString("vod_play_from").split("\\$\\$\\$");
                if (playFrom.length > 0) {
                    for (int i = 0; i < playFrom.length; i++) {
                        if (show2VipFlag.containsKey(playFrom[i])) {
                            playFrom[i] = show2VipFlag.get(playFrom[i]);
                        }
                    }
                    jsonObject.optJSONArray("list").getJSONObject(0).put("vod_play_from", TextUtils.join("$$$", playFrom));
                    result = jsonObject.toString();
                }
            } catch (Throwable th) {
                SpiderDebug.log(th);
            }
        }
        return result;
    }

    @Override
    public String playerContent(String flag, String id, List<String> vipFlags) {
        fetchRule();
        String webUrl = rule.getPlayUrl().isEmpty() ? id : rule.getPlayUrl().replace("{playUrl}", id);
        String videoUrl = null;
        // 嘗試分析直連
        if (decodePlayUrl) {
            try {
                Document doc = Jsoup.parse(fetch(webUrl));
                Elements allScript = doc.select("script");
                for (int i = 0; i < allScript.size(); i++) {
                    String scContent = allScript.get(i).html().trim();
                    if (scContent.startsWith("var player_")) {
                        int start = scContent.indexOf('{');
                        int end = scContent.lastIndexOf('}') + 1;
                        String json = scContent.substring(start, end);
                        JSONObject player = new JSONObject(json);
                        String videoUrlTmp = player.getString("url");
                        if (player.has("encrypt")) {
                            int encrypt = player.getInt("encrypt");
                            if (encrypt == 1) {
                                videoUrlTmp = URLDecoder.decode(videoUrlTmp);
                            } else if (encrypt == 2) {
                                videoUrlTmp = new String(Base64.decode(videoUrlTmp, Base64.DEFAULT));
                                videoUrlTmp = URLDecoder.decode(videoUrlTmp);
                            }
                        }
                        videoUrl = videoUrlTmp;
                        break;
                    }
                }
            } catch (Exception e) {
                SpiderDebug.log(e);
            }
        }
        if (videoUrl != null) {
            // 適配2.0.6的調用應用內解析列表的支持, 需要配合直連分析和匹配官源解析一起使用，參考cjt影視和極品直連
            if (decodeVipFlag && Utils.isVip(videoUrl)) { // 使用jx:1
                try {
                    JSONObject result = new JSONObject();
                    result.put("parse", 1);
                    result.put("jx", "1");
                    result.put("url", videoUrl);
                    return result.toString();
                } catch (Exception e) {
                    SpiderDebug.log(e);
                }
            } else if (decodeVipFlag && vipFlags.contains(flag)) { // 是否使用應用內解析列表解析官源
                try {
                    JSONObject result = new JSONObject();
                    result.put("parse", 1);
                    result.put("playUrl", "");
                    result.put("url", videoUrl);
                    result.put("header", "");
                    return result.toString();
                } catch (Exception e) {
                    SpiderDebug.log(e);
                }
            }
            // 如果是視頻直連 直接返回免解
            else if (isVideoFormat(videoUrl)) {
                try {
                    JSONObject result = new JSONObject();
                    result.put("parse", 0);
                    result.put("playUrl", "");
                    result.put("url", videoUrl);
                    HashMap<String, String> headers = new HashMap<>();
                    if (rule.getPlayUa().length() > 0) headers.put("User-Agent", rule.getPlayUa());
                    if (rule.getPlayReferer().length() > 0) headers.put("Referer", rule.getPlayReferer());
                    result.put("header", new Gson().toJson(headers));
                    return result.toString();
                } catch (Exception e) {
                    SpiderDebug.log(e);
                }
            }
        }
        // 上述都失敗了就按默認模式走
        return super.playerContent(flag, id, vipFlags);
    }
}