264 строки
9.8 KiB
Java
264 строки
9.8 KiB
Java
package com.github.catvod.spider;
|
|
|
|
import com.github.catvod.crawler.Spider;
|
|
import com.github.catvod.crawler.SpiderDebug;
|
|
|
|
import android.annotation.TargetApi;
|
|
import android.content.Context;
|
|
import android.os.Build;
|
|
import android.text.TextUtils;
|
|
import android.util.Base64;
|
|
|
|
|
|
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.Response;
|
|
|
|
import org.jsoup.Jsoup;
|
|
import org.jsoup.nodes.Document;
|
|
import org.jsoup.nodes.Element;
|
|
import org.jsoup.select.Elements;
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
|
|
import java.io.IOException;
|
|
import java.nio.charset.StandardCharsets;
|
|
import java.security.spec.AlgorithmParameterSpec;
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
import java.util.TimeZone;
|
|
import java.util.TreeMap;
|
|
import java.util.regex.Matcher;
|
|
import java.util.regex.Pattern;
|
|
import java.util.Calendar;
|
|
import java.net.URLDecoder;
|
|
|
|
import javax.crypto.Cipher;
|
|
import javax.crypto.spec.IvParameterSpec;
|
|
import javax.crypto.spec.SecretKeySpec;
|
|
|
|
public class Xmau extends Spider {
|
|
@Override
|
|
public void init(Context context) {super.init(context);}
|
|
|
|
|
|
@Override
|
|
public String homeContent(boolean filter) {
|
|
try {
|
|
JSONObject cateobj = new JSONObject();
|
|
JSONArray classes = new JSONArray();
|
|
JSONObject result = new JSONObject();
|
|
JSONArray videos = new JSONArray();
|
|
JSONObject v = new JSONObject();
|
|
cateobj.put("type_name", "test111");
|
|
cateobj.put("type_id", "1");
|
|
classes.put(cateobj);
|
|
result.put("class", classes);
|
|
v.put("vod_id", "testid222");
|
|
v.put("vod_name", "testname333");
|
|
v.put("vod_pic","https://pic.rmb.bdstatic.com/bjh/1d0b02d0f57f0a42201f92caba5107ed.jpeg");
|
|
v.put("vod_remarks", "testmark444");
|
|
videos.put(v);
|
|
result.put("list", videos);
|
|
return result.toString();
|
|
} catch (
|
|
Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
@Override
|
|
public String detailContent(List<String> ids) {
|
|
try {
|
|
|
|
JSONObject result = new JSONObject();
|
|
JSONObject vodList = new JSONObject();
|
|
vodList.put("vod_id", "id");
|
|
vodList.put("vod_name", "Xmau解密练习，写固定播放连结，有需要请自行补齐");
|
|
vodList.put("vod_pic", "https://pic.rmb.bdstatic.com/bjh/1d0b02d0f57f0a42201f92caba5107ed.jpeg");
|
|
vodList.put("vod_year", "year9999");
|
|
vodList.put("type_name", "type7777");
|
|
vodList.put("vod_area","are0000a" );
|
|
vodList.put("vod_actor", "actor0987");
|
|
vodList.put("vod_content", "content1234567890");
|
|
String playList = "";
|
|
List<String> vodItems = new ArrayList<>();
|
|
String pl1 = "playname1$playlink1";
|
|
String pl2 = "playname2$playlink2";
|
|
vodItems.add(pl1);
|
|
vodItems.add(pl2);
|
|
if (vodItems.size() > 0)
|
|
playList = TextUtils.join("#", vodItems);
|
|
if (playList.length() == 0)
|
|
playList = "nothing here";
|
|
Map<String, String> vod_play = new TreeMap<>();
|
|
vod_play.put("test", playList);
|
|
if (vod_play.size() > 0) {
|
|
String vod_play_from = TextUtils.join("$$$", vod_play.keySet());
|
|
String vod_play_url = TextUtils.join("$$$", vod_play.values());
|
|
vodList.put("vod_play_from", vod_play_from);
|
|
vodList.put("vod_play_url", vod_play_url);
|
|
}
|
|
JSONArray list = new JSONArray();
|
|
list.put(vodList);
|
|
result.put("list", list);
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
|
|
@Override
|
|
public String playerContent(String flag, String id, List<String> vipFlags) {
|
|
try {
|
|
long currentTime = System.currentTimeMillis()/ 1000;
|
|
String apikey=getapikey();
|
|
String deturl ="http://eg.xmau.cn/lvdou_api.php/v1.vod/detail?vod_id=8055&rel_limit=10&apikey="+apikey+"&keytime="+currentTime;
|
|
String detsrc = OkHttpUtil.string(deturl, getHeaders(deturl));
|
|
JSONObject detsrcobj = new JSONObject(detsrc);
|
|
JSONObject detsrcobjdata= detsrcobj.getJSONObject("data");
|
|
String requrlsrc = detsrcobjdata.getString("vod_play_url");
|
|
String requrl = requrlsrc.substring(3);
|
|
currentTime = System.currentTimeMillis()/ 1000;
|
|
apikey=getapikey();
|
|
String reqapiurl="https://h5.freejson.xyz/?url="+requrl+"&apikey="+apikey+"&keytime="+currentTime;
|
|
String reqapirsp = OkHttpUtil.string(reqapiurl, getHeaders(reqapiurl));
|
|
Document doc = Jsoup.parse(reqapirsp);
|
|
Elements allScript = doc.select("script");
|
|
String iv="";
|
|
String enyurl="";
|
|
for (int i = 0; i < allScript.size(); i++) {
|
|
String scContent = allScript.get(i).toString();
|
|
if (scContent.contains("var le_token")) {
|
|
System.out.println("fpplog scContent:"+scContent);
|
|
int start = scContent.indexOf('"');
|
|
int end = scContent.lastIndexOf('"') + 1;
|
|
iv = scContent.substring(start+1, end-1);
|
|
}
|
|
if (scContent.contains("var config")) {
|
|
int start = scContent.indexOf("var config =");
|
|
int end = scContent.lastIndexOf('}') + 1;
|
|
String j1 = scContent.substring(start, end);
|
|
start = j1.indexOf('(');
|
|
end = j1.lastIndexOf(')') ;
|
|
enyurl = j1.substring(start+2, end-1);
|
|
break;
|
|
}
|
|
}
|
|
String enyurlb64dec=toHex(Base64.decode(enyurl.getBytes(), Base64.DEFAULT));
|
|
String key = "A42EAC0C2B408472";
|
|
String videolink=decrypt(enyurlb64dec,key,iv);
|
|
JSONObject result = new JSONObject();
|
|
result.put("url", videolink);
|
|
result.put("header", new JSONObject(getHeaders(videolink)).toString());
|
|
result.put("parse", 0);
|
|
result.put("playUrl", "");
|
|
return result.toString();
|
|
} catch (Exception e) {
|
|
SpiderDebug.log(e);
|
|
}
|
|
return "";
|
|
}
|
|
|
|
|
|
|
|
private HashMap<String, String> getHeaders(String url) {
|
|
HashMap<String, String> headers = new HashMap<>();
|
|
headers.put("User-Agent","User-Agent:okhttp/4.1.0");
|
|
return headers;
|
|
}
|
|
|
|
@TargetApi(Build.VERSION_CODES.KITKAT)
|
|
protected String getapikey() {
|
|
try {
|
|
Calendar cal=Calendar.getInstance();
|
|
int y=cal.get(Calendar.YEAR);
|
|
int h=cal.get(Calendar.HOUR_OF_DAY);
|
|
int m=cal.get(Calendar.MINUTE);
|
|
String apikeyori=y+":"+(h<10?("0"+h):h)+":"+y+":"+(m<10?("0"+m):m)+":lvdoutv-1.0.0";
|
|
String apikey=Misc.MD5(apikeyori,StandardCharsets.UTF_8);
|
|
return apikey;
|
|
} catch (Exception exception) {
|
|
SpiderDebug.log(exception);
|
|
}
|
|
return null;
|
|
}
|
|
protected String decrypt(String src, String KEY, String IV) {
|
|
try {
|
|
Cipher cipher = Cipher.getInstance("AES/CBC/PKCS7Padding");
|
|
SecretKeySpec keySpec = new SecretKeySpec(KEY.getBytes(), "AES");
|
|
AlgorithmParameterSpec paramSpec = new IvParameterSpec(IV.getBytes());
|
|
cipher.init(Cipher.DECRYPT_MODE, keySpec, paramSpec);
|
|
return new String(cipher.doFinal(hex2byte(src)));
|
|
} catch (Exception exception) {
|
|
SpiderDebug.log(exception);
|
|
}
|
|
return null;
|
|
}
|
|
protected String encrypt(String src, String KEY, String IV) {
|
|
try {
|
|
Cipher cipher = Cipher.getInstance("AES/CBC/PKCS7Padding");
|
|
SecretKeySpec keySpec = new SecretKeySpec(KEY.getBytes(), "AES");
|
|
AlgorithmParameterSpec paramSpec = new IvParameterSpec(IV.getBytes());
|
|
cipher.init(Cipher.ENCRYPT_MODE, keySpec, paramSpec);
|
|
return bytesToHexStr(cipher.doFinal(src.getBytes())).toUpperCase();
|
|
} catch (Exception exception) {
|
|
SpiderDebug.log(exception);
|
|
}
|
|
return null;
|
|
}
|
|
|
|
protected byte[] hex2byte(String hex) throws IllegalArgumentException {
|
|
if (hex.length() % 2 != 0){
|
|
throw new IllegalArgumentException("invalid hex string");
|
|
}
|
|
char[] arr = hex.toCharArray();
|
|
byte[] b = new byte[hex.length() / 2];
|
|
for (int i = 0, j = 0, l = hex.length(); i < l; i++, j++) {
|
|
String swap ="" + arr[i++] + arr[i];
|
|
int byteint = Integer.parseInt(swap, 16) & 0xFF;
|
|
b[j] = new Integer(byteint).byteValue();
|
|
}
|
|
return b;
|
|
}
|
|
|
|
protected String bytesToHexStr(byte[] bytes) {
|
|
StringBuilder hexStr = new StringBuilder();
|
|
for (byte b : bytes) {
|
|
String hex = Integer.toHexString(b & 0xFF);
|
|
if (hex.length() == 1) {
|
|
hex = '0' + hex;
|
|
}
|
|
hexStr.append(hex);
|
|
}
|
|
return hexStr.toString();
|
|
}
|
|
|
|
|
|
private static final char[] DIGITS
|
|
= {'0', '1', '2', '3', '4', '5', '6', '7',
|
|
'8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
|
|
|
|
private static final String toHex(byte[] data) {
|
|
final StringBuffer sb = new StringBuffer(data.length * 2);
|
|
for (int i = 0; i < data.length; i++) {
|
|
sb.append(DIGITS[(data[i] >>> 4) & 0x0F]);
|
|
sb.append(DIGITS[data[i] & 0x0F]);
|
|
}
|
|
return sb.toString();
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|