package com.bytedance.ttcollector.utils;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.pm.PackageInfo;
import android.content.pm.PackageManager;
import android.content.pm.ResolveInfo;
import android.net.Uri;
import android.os.Build;
import android.os.Environment;
import android.provider.Settings;
import android.util.Log;
import android.util.Pair;
import androidx.core.content.FileProvider;
import com.mysql.jdbc.Statement;
import com.sound.apksource.ApkSource;
import com.sound.duoapks.ApkSourceBuilder;
import com.sound.filedescriptor.FlexSaiPackageInstaller;
import com.sound.filedescriptor.PreferencesHelper;
import com.sound.filedescriptor.SaiPiSessionParams;
import com.sound.shell.RootedSaiPackageInstaller;
import com.yanzhenjie.andserver.util.StringUtils;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import org.json.JSONTokener;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import de.robv.android.xposed.XposedBridge;
import okhttp3.FormBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

public class TTTask {
    public static Boolean _installRet;
    public static Boolean _paused;
    private static String TAG = "AFTask";

    private final Context _context;
    private final String _appid;
    private final String _downloadUrl;
    private Connection _dbConn;
    private Statement _dbStat;

    private static boolean go = false;

    static {
        _installRet = null;
        _paused = false;
    }

    public TTTask(Context context, String appid, String downloadUrl) throws Throwable {
        _context = context;
        _appid = appid;
        _downloadUrl = downloadUrl;
    }

    /**
     * 获取apk文件名
     * @param appid
     * @return
     * @throws Throwable
     */
    private String apkFileName(String appid) throws Throwable{
        String result = "";
        String sql="SELECT ApkPath FROM apkinfo1 WHERE PackageName = '" + appid + "';";
        ResultSet rs=_dbStat.executeQuery(sql);
        if(rs.next()){
            result = rs.getString("ApkPath");
        }
        rs.close();
        return result;
    }

    /**
     * 下载APk
     * @param downloadUrl
     * @param fileName
     * @return
     * @throws Throwable
     */
    private String downloadAPK(String downloadUrl, String fileName) throws Throwable {
        Log.d("AFTask", "downloadAPK: " + Environment.getExternalStorageState());
        if (Environment.getExternalStorageState().equals(Environment.MEDIA_MOUNTED)){
            String sdPath = Environment.getExternalStorageDirectory() + "/";
            String savePath = sdPath + "aftask";
            File dir = new File(savePath);
            if (!dir.exists()){
                Process process = Runtime.getRuntime().exec("su");
                PrintWriter PrintWriter = new PrintWriter(process.getOutputStream());
                PrintWriter.println("mkdir " + sdPath + "aftask");
                PrintWriter.println("chmod 777 " + sdPath + "aftask");
                PrintWriter.flush();
                PrintWriter.close();
                process.waitFor();
            }

            // 下载文件
            HttpURLConnection conn = (HttpURLConnection) new URL(downloadUrl + fileName).openConnection();
            conn.connect();
            InputStream is = conn.getInputStream();

            File apkFile = new File(savePath, fileName);
            FileOutputStream fos = new FileOutputStream(apkFile);

            byte[] buffer = new byte[10240];
            while (true) {
                int numread = is.read(buffer);
                if (numread < 0){ break; }
                fos.write(buffer, 0, numread);
            }
            fos.close();
            is.close();
            return apkFile.getPath();
        }
        return "";
    }

    private static boolean returnResult(int value){
        // 代表成功
        if (value == 0) {
            return true;
        } else if (value == 1) { // 失败
            return false;
        } else { // 未知情况
            return false;
        }
    }

    private boolean clientInstallApk(File apkFile){
        PrintWriter PrintWriter = null;
        Process process = null;
        try {
            process = Runtime.getRuntime().exec("su");
            PrintWriter = new PrintWriter(process.getOutputStream());
            PrintWriter.println("chmod 777 " + apkFile);
            PrintWriter.println("pm install -r " + apkFile);
            PrintWriter.flush();
            PrintWriter.close();
            int value = process.waitFor();
            return returnResult(value);
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            if(process!=null){
                process.destroy();
            }
        }
        return false;
    }

    private boolean clientInstallApks(File apkFile){
        Uri uri = Uri.fromFile(apkFile);

        FlexSaiPackageInstaller mInstaller = FlexSaiPackageInstaller.getInstance(_context);
        PreferencesHelper mPrefsHelper = PreferencesHelper.getInstance(_context);
        RootedSaiPackageInstaller rootedSaiPackageInstaller = RootedSaiPackageInstaller.getInstance(_context);

        ApkSource apkSource = new ApkSourceBuilder(_context)
                .fromZipContentUri(uri)
                .setZipExtractionEnabled(mPrefsHelper.shouldExtractArchives())
                .setReadZipViaZipFileEnabled(mPrefsHelper.shouldUseZipFileApi())
                .setSigningEnabled(mPrefsHelper.shouldSignApks())
                .build();

        // mInstaller.enqueueSession(mInstaller.createSessionOnInstaller(mPrefsHelper.getInstaller(), new SaiPiSessionParams(apkSource)));
        rootedSaiPackageInstaller.enqueueSession(mInstaller.createSessionOnInstaller(mPrefsHelper.getInstaller(), new SaiPiSessionParams(apkSource)));

        while(_installRet == null){
            try{
                Thread.sleep(1000);
            }catch (Exception e){}
        }

        boolean result = _installRet;
        _installRet = null;
        return result;
    }

    /**
     * 删除APK
     * @param apk_file_path
     * @return
     */
    private boolean deleteAPK(final String apk_file_path) {
        try {
            File f = new File(apk_file_path);
            return f.delete();
        }catch (Throwable err){
            return false;
        }
    }

    /**
     * 卸载APK
     * @param packageName
     * @return
     * @throws Throwable
     */
    private boolean clientUninstall(String packageName) {
        PrintWriter PrintWriter = null;
        Process process = null;
        try {
            process = Runtime.getRuntime().exec("su");
            PrintWriter = new PrintWriter(process.getOutputStream());
            PrintWriter.println("pm uninstall " + packageName);
            PrintWriter.flush();
            PrintWriter.close();
            int value = process.waitFor();
            return returnResult(value);
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            if(process!=null){
                process.destroy();
            }
        }
        return false;
    }

    /**
     * 打开APP
     * @param packageName
     * @throws Throwable
     */
    private boolean openApp(String packageName) {
        try{
            Global.setTargetAppName(packageName);
            Intent intent = _context.getPackageManager().getLaunchIntentForPackage(packageName);
//            if(intent != null){
//                _context.startActivity(intent);
//                return true;
//            }else{
//                CmdUtils.amStart(getApkMainActivity(packageName));
//                return false;
//            }
            _context.startActivity(intent);
        }catch (Throwable e){
            e.printStackTrace();
            return false;
        }
        return true;
    }

    public String getApkMainActivity(String packageName) {
        String mainActivity = null;
        final PackageManager packageManager = _context.getPackageManager();
        PackageInfo pi             = null;
        try {
            pi = _context.getPackageManager().getPackageInfo(packageName, 0);
        } catch (PackageManager.NameNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        if(pi == null || pi.packageName == null){
            //Toast.makeText(this, "还没安装！", 2000).show();
            Log.d(TAG, "getMainActivity: " + "apk还没安装");
            return null;
        }
        Intent resolveIntent = new Intent(Intent.ACTION_MAIN, null);
        resolveIntent.addCategory(Intent.CATEGORY_LAUNCHER);
        resolveIntent.setPackage(pi.packageName);

        List<ResolveInfo> apps = packageManager.queryIntentActivities(resolveIntent, 0);

        ResolveInfo ri = apps.iterator().next();
        if (ri != null) {
            String pkgName = ri.activityInfo.packageName;
            String className = ri.activityInfo.name;

            Intent intent = new Intent(Intent.ACTION_MAIN);
            intent.addCategory(Intent.CATEGORY_LAUNCHER);

            ComponentName cn = new ComponentName(pkgName, className);

            Log.d(TAG, "openApp: " + cn.toString());
            Log.d(TAG, "openApp: " + cn.toShortString());
            Log.d(TAG, "openApp: " + cn.flattenToString());
            Log.d(TAG, "openApp: " + cn.flattenToShortString());

            mainActivity = cn.flattenToShortString();
//            intent.setComponent(cn);
//            MyApplication.getContext().startActivity(intent);
        }

        return mainActivity;
    }

    /**
     * 拷贝日志文件
     * @param packageName
     * @param maxSecondOfWait
     * @return
     * @throws Throwable
     */
    private boolean copyLogFile(String packageName, long maxSecondOfWait, long minSecondOfWait) throws Throwable {
        long begin = System.currentTimeMillis();

        Process process = Runtime.getRuntime().exec("su");
        PrintWriter printWriter = new PrintWriter(process.getOutputStream());
        printWriter.println("chmod 777 /data/data/" + packageName);
        printWriter.println("mkdir /data/data/com.bytedance.ttcollector/" + packageName);
        printWriter.println("chmod 777 /data/data/com.bytedance.ttcollector/" + packageName);
        printWriter.flush();

        boolean afCopied = false, adCopied = false;
        while ((!afCopied || !adCopied) && (System.currentTimeMillis() - begin <= (maxSecondOfWait * 1000))){
            boolean notAF = new File("/data/data/" + packageName + "/AFNOEXISTS.lock").exists();
            boolean notAD = new File("/data/data/" + packageName + "/ADNOEXISTS.lock").exists();
            if (notAF) {
                afCopied = true;
            } else {
                boolean existsAFVer = new File("/data/data/" + packageName + "/AFVERSION.lock").exists();
                boolean existsAFApp = new File("/data/data/" + packageName + "/AFAPP.lock").exists();
                boolean existsAFPostT = new File("/data/data/" + packageName + "/AFT.lock").exists();
                boolean existsAFPostC = new File("/data/data/" + packageName + "/AFCONVERSIONS.lock").exists();
                afCopied = existsAFVer && existsAFApp && (existsAFPostT || existsAFPostC);
            }
            if (notAD) {
                adCopied = true;
            } else {
                boolean existsADVer = new File("/data/data/" + packageName + "/ADVERSION.lock").exists();
                boolean existsADApp = new File("/data/data/" + packageName + "/ADAPP.lock").exists();
                adCopied = existsADVer && existsADApp;
            }

            Thread.sleep(2000);
        }
        while (System.currentTimeMillis() - begin <= minSecondOfWait * 1000){ Thread.sleep(2000); }

        printWriter.println("cp -a /data/data/" + packageName + "/AFVERSION.txt /data/data/com.bytedance.ttcollector/" + packageName + "/AFVERSION.txt");
        printWriter.println("cp -a /data/data/" + packageName + "/AFAPP.txt /data/data/com.bytedance.ttcollector/" + packageName + "/AFAPP.txt");
        printWriter.println("cp -a /data/data/" + packageName + "/AFT.txt /data/data/com.bytedance.ttcollector/" + packageName + "/AFT.txt");
        printWriter.println("cp -a /data/data/" + packageName + "/AFCONVERSIONS.txt /data/data/com.bytedance.ttcollector/" + packageName + "/AFCONVERSIONS.txt");
        printWriter.println("cp -a /data/data/" + packageName + "/AFREQUEST.txt /data/data/com.bytedance.ttcollector/" + packageName + "/AFREQUEST.txt");
        printWriter.println("cp -a /data/data/" + packageName + "/ADVERSION.txt /data/data/com.bytedance.ttcollector/" + packageName + "/ADVERSION.txt");
        printWriter.println("cp -a /data/data/" + packageName + "/ADAPP.txt /data/data/com.bytedance.ttcollector/" + packageName + "/ADAPP.txt");
        printWriter.println("chmod 777 /data/data/com.bytedance.ttcollector/" + packageName + "/*.*");
        printWriter.flush();

        printWriter.close();
        return returnResult(process.waitFor());
    }

    private Pair<String, String> readSdkVer(String packageName, String verFileName, String appFileName, String nameIfExists){
        Pair<String, String> result = new Pair("unknown", "unknown");
        try {
            File fVer = new File("/data/data/com.bytedance.ttcollector/" + packageName, verFileName);
            if (fVer.exists()){
                File fApp = new File("/data/data/com.bytedance.ttcollector/" + packageName, appFileName);
                BufferedReader readerVer = new BufferedReader(new InputStreamReader(new FileInputStream(fVer)));
                String thirdDetect = fApp.exists() ? nameIfExists : (nameIfExists + "2");
                String thirdVer = readerVer.readLine();
                readerVer.close();
                result = new Pair<>(thirdDetect, thirdVer);
            }
        }catch (Throwable e){ }
        return result;
    }
    private Pair<String, String> saveInfoOfApkVer(String packageName, String fileName, Pair<String, String> afver, Pair<String, String> adver){
        String thirdDetect = "unknown", thirdVer = "unknown";
        try {
            if (!afver.first.equals("unknown") && !adver.first.equals("unknown")) {
                thirdDetect = afver.first + "+" + adver.first;
                thirdVer = afver.second + "+" + adver.second;
            }else if(!afver.first.equals("unknown") || !adver.first.equals("unknown")) {
                if(afver.first.equals("unknown")) {
                    thirdDetect = adver.first;
                    thirdVer = adver.second;
                } else {
                    thirdDetect = afver.first;
                    thirdVer = afver.second;
                }
            }
            String sql = "UPDATE apkinfo1 SET ThirdDetect = '" + thirdDetect + "', ThirdVer = '" + thirdVer + "' WHERE PackageName = '" + packageName + "' AND ApkPath = '" + fileName + "'";
            _dbStat.execute(sql);
        } catch(Throwable e){
            e.printStackTrace();
        }
        return new Pair<>(thirdDetect, thirdVer);
    }

    private String addAFOption(String packageName, String latestVerOption, String json, String postFile){
        String result = "";
        try {
            JSONObject target = new JSONObject(json);
            FileReader fileReader = new FileReader(postFile);
            BufferedReader reader = new BufferedReader(fileReader);
            JSONObject option = new JSONObject();

            JSONObject post = new JSONObject(reader.readLine());
            if (post.has("android_id")){
                String android_id = "", current_value = post.getString("android_id");
                try { android_id = Settings.Secure.getString(_context.getContentResolver(), Settings.Secure.ANDROID_ID); }catch (Throwable ex){}
                if (android_id != null && !android_id.isEmpty()) {
                    current_value = current_value.replace(android_id, "{android_id}");
                }
                if (post.has("advertiserId")){
                    String advertiserId = post.getString("advertiserId");
                    current_value = current_value.replace(advertiserId, "{gaid}");
                }
                if (post.has("uid")){
                    String uid = post.getString("uid");
                    current_value = current_value.replace(uid, "{uid}");
                }
                if(!current_value.contains("{")){
                    option.put("manualhandle", true);
                }
                option.put("android_id", current_value);
            }
            if (post.has("appUserId")){
                String android_id = "", current_value = post.getString("appUserId");
                try { android_id = Settings.Secure.getString(_context.getContentResolver(), Settings.Secure.ANDROID_ID); }catch (Throwable ex){}
                if (android_id != null && !android_id.isEmpty()) {
                    current_value = current_value.replace(android_id, "{android_id}");
                }
                if (post.has("advertiserId")){
                    String advertiserId = post.getString("advertiserId");
                    current_value = current_value.replace(advertiserId, "{gaid}");
                }
                if (post.has("uid")){
                    String uid = post.getString("uid");
                    current_value = current_value.replace(uid, "{uid}");
                }
                if(!current_value.contains("{")){
                    option.put("manualhandle", true);
                }
                option.put("appUserId", current_value);
            }
            if (post.has("customData")){
                String android_id = "", current_value = post.getString("customData");
                try { android_id = Settings.Secure.getString(_context.getContentResolver(), Settings.Secure.ANDROID_ID); }catch (Throwable ex){}
                if (android_id != null && !android_id.isEmpty()) {
                    current_value = current_value.replace(android_id, "{android_id}");
                }
                if (post.has("advertiserId")){
                    String advertiserId = post.getString("advertiserId");
                    current_value = current_value.replace(advertiserId, "{gaid}");
                }
                if(!current_value.contains("{")){
                    option.put("manualhandle", true);
                }
                option.put("customData", current_value);
            }
            if (post.has("currency")){
                option.put("currency", post.getString("currency"));
            }
            if (post.has("onelink_id")){
                option.put("onelink_id", post.getString("onelink_id"));
            }
            if (post.has("af_currentstore")){
                option.put("api_store_value", post.getString("af_currentstore"));
            }
//            if (post.has("channel")){
//                option.put("channel", post.getString("channel"));
//            }
//            if (post.has("imei")){
//                option.put("imei", post.getString("imei"));
//            }
//            if (post.has("lvl")){
//                option.put("lvl", true);
//            }

            //比对
            if (latestVerOption != null && latestVerOption.length() != 0) {
                JSONObject latestVerOptionJson = new JSONObject(latestVerOption);
                Iterator<String> it = latestVerOptionJson.keys();
                while (it.hasNext()) {
                    String key = it.next();
//                    Log.d(TAG, "propCorrection: key " + key);
//                    Log.d(TAG, "propCorrection: value " + prop4ServerJson.getString(key));

                    //信任服务器旧版数据模式
//                    if ((!option.has(key)) || option.getString(key).equals("")) {
//                        //propJson.put(key, prop4ServerJson.getString(key));
//                        option.put(key, latestVerOptionJson.get(key));
//                    }

                    //信任自己取到的数据模式
                    if ((option.has(key))) {
                        option.remove(key);
                        option.put(key, latestVerOptionJson.get(key));
                    }
                }
            }

            if (option.length() > 0) {
                //替换uuid android_id gaid
                String optionStr = option.toString();
                optionStr = optionStr.replaceAll("[0-9a-f]{8}(-[0-9a-f]{4}){3}-[0-9a-f]{12}", "{uuid36}");
                optionStr = optionStr.replaceAll("[0-9A-F]{8}(-[0-9A-F]{4}){3}-[0-9A-F]{12}", "{uuid36U}");
                optionStr = optionStr.replaceAll("[0-9a-f]{32}", "{uuid32}");
                optionStr = optionStr.replaceAll("[0-9A-F]{32}", "{uuid32U}");
                optionStr = optionStr.replaceAll("[0-9a-fA-F]{16}", "{android_id}");

                //额外需要修改参数的apk判断
                optionStr = specOption(packageName, optionStr);
                option = new JSONObject(optionStr);
                //prop.put("option", option);
                target.put("option", option);
            }

            result = target.toString();
            reader.close();
            fileReader.close();
        }catch (Throwable e){
            e.printStackTrace();
        }
        return result;
    }

    //特殊APP的option处理
    public static String specOption(String packageName, String optionStr) {
        String specPackageNames = "com.eterno.shortvideos|com.fiverr.fiverr";
        if (specPackageNames.contains(packageName)) {
            JSONObject prop = null;
            try {
                prop = new JSONObject(optionStr);
                if (prop == null) return optionStr;

                switch (packageName) {
                    case "com.eterno.shortvideos":
                        if (prop.has("appUserId")) {
                            prop.put("appUserId", "j.{2}{0}{2}{1}{2}{1}{1}{1}{2}{1}{1}{1}{2}{2}{2}{1}{1}{1}{2}{1}{2}{1}{2}{2}{2}{0}{2}{2}{2}{1}09A");
                        }
                        break;
                    case "com.fiverr.fiverr":
                        if (prop.has("appUserId")) {
                            prop.put("appUserId", "{timestamp13}{0}{0}{0}{0}{0}{0}{0}{0}{0}{0}");
                        }
                        break;
                    case "com.neptune.domino":
                        if (prop.has("appUserId")) {
                            prop.put("appUserId", "{4}{4}:{4}{4}:{4}{4}:{4}{4}:{4}{4}:{4}{4}");
                        }
                        break;
                }
            } catch (JSONException e) {
                e.printStackTrace();
            }
            optionStr = prop.toString();
        }
        return optionStr;
    }

    private JSONArray getRequestEvents(String packageName){
        JSONArray subEvents = new JSONArray();
        try{
            File fRequest = new File("/data/data/com.bytedance.ttcollector/" + packageName, "AFREQUEST.txt");
            if (fRequest.exists()){
                BufferedReader readerApp = new BufferedReader(new InputStreamReader(new FileInputStream(fRequest)));
                List<Long> timestamps = new ArrayList<>();
                HashMap<Long, JSONObject> map = new HashMap<>();
                String line = readerApp.readLine();
                while (line != null){
                    try{
                        if (!line.isEmpty()){
                            JSONObject request = new JSONObject(line);
                            long timestamp = request.getLong("timestamp");
                            String url = request.getString("url");
                            if (!url.contains("t.appsflyer.com") && !url.contains("conversions.appsflyer.com")){
                                map.put(timestamp, request);
                                timestamps.add(timestamp);
                            }
                        }
                        line = readerApp.readLine();
                    }catch (Exception ex){
                        line = "";
                    }
                }
                Collections.sort(timestamps);
                for (int i = 0; i < timestamps.size(); i++) {
                    String type = "", name = "", value = "";
                    long timeDelayMin = 100, timeDelayMax = 100;
                    try{
                        JSONObject target = map.get(timestamps.get(i));
                        JSONObject targetContent = new JSONObject(target.getString("content"));
                        URL url = new URL(target.getString("url"));
                        String host = url.getHost();
                        if (host.equals("attr.appsflyer.com")){ type = "attr"; }
                        else if (host.equals("register.appsflyer.com")){ type = "register"; }
                        else if (host.equals("launches.appsflyer.com")){ type = "launche"; }
                        else if (host.equals("inapps.appsflyer.com")){
                            type = "inapp";
                            name = targetContent.getString("eventName");
                            value = targetContent.getString("eventValue");
                        }
                        if (i < (timestamps.size() - 1)){
                            timeDelayMin = timestamps.get(i + 1) - timestamps.get(i) - 2;
                            timeDelayMax = timestamps.get(i + 1) - timestamps.get(i) + 2;
                        }

                        JSONObject subEventsItem = new JSONObject();
                        subEventsItem.put("type", type);
                        subEventsItem.put("name", name);
                        subEventsItem.put("value", value);
                        subEventsItem.put("timeDelayMin", timeDelayMin);
                        subEventsItem.put("timeDelayMax", timeDelayMax);
                        subEvents.put(subEventsItem);
                    }catch (Exception ex){
                    }
                }
            }
        }catch (Throwable err){
            err.printStackTrace();
        }
        return subEvents;
    }
    private void saveInfoOfApkAFInfo(String packageName, String fileVer, String afVer){
        try {
            File fApp = new File("/data/data/com.bytedance.ttcollector/" + packageName, "AFAPP.txt");
            File fPostT = new File("/data/data/com.bytedance.ttcollector/" + packageName, "AFT.txt");
            File fPostC = new File("/data/data/com.bytedance.ttcollector/" + packageName, "AFCONVERSIONS.txt");
            if (fApp.exists()){
                BufferedReader readerApp = new BufferedReader(new InputStreamReader(new FileInputStream(fApp)));
                String dataContent = readerApp.readLine();
                readerApp.close();
                if (fPostT.exists() || fPostC.exists()){
                    //从服务器读取参数
                    String latestVerOption = queryLatestProp(packageName);
                    dataContent = addAFOption(packageName, latestVerOption, dataContent, fPostC.exists() ? fPostC.getPath() : fPostT.getPath());
                }
                String sql = "INSERT INTO apkprotocprop (PackageName, Prop, appVer, thirdParty, thirdVer) VALUES(?, ?, ?, ?, ?);";
//                PreparedStatement ps = _dbConn.prepareStatement(sql);
//                ps.setString(1, packageName);
//                ps.setString(2, dataContent);
//                ps.setString(3, fileVer);
//                ps.setString(4, "AF");
//                ps.setString(5, afVer);
//                ps.executeUpdate();
//                Log.e("AFTask", "apkprotocprop update ok");
//                String url = String.format("http://123.56.44.45/tt/manage/apkInfo!addApkProtocPropOp.do?apkProtocProp.packageName=%s&apkProtocProp.appVer=%s&apkProtocProp.thirdParty=%s&apkProtocProp.thirdVer=%s&apkProtocProp.prop=%s", packageName, fileVer, "AF", afVer, dataContent);
//                System.out.println(url);
                OkHttpClient client = new OkHttpClient();
                FormBody formBody = null;
                JSONObject jsonObject = new JSONObject(dataContent);
                formBody = new FormBody.Builder()
                        .add("apkProtocProp.packageName", packageName)
                        .add("apkProtocProp.appVer", fileVer)
                        .add("apkProtocProp.thirdParty", "AF")
                        .add("apkProtocProp.thirdVer", afVer)
                        .add("apkProtocProp.prop", jsonObject.toString())
                        .build();
                Request request = new Request.Builder()
                        .url("http://123.56.44.45/tt/manage/apkInfo!addApkProtocPropOp.do?")
                        .addHeader("Content-Type", "application/x-www-form-urlencoded")
                        .method("POST", formBody)
                        .build();
                Response response = client.newCall(request).execute();
                if(response.code() == 200) {
                    System.out.println("UpdateOK");
                }
                else {
                    System.out.println("UpdateError");
                }
            }
        }catch (IOException | JSONException e){
            e.printStackTrace();
        }
    }

    private String queryLatestProp(String packageName) {
        String propString = null;
        int latestVersionCode = 0;
        String optionString = null;

        String sql = "SELECT * FROM apkprotocprop WHERE PackageName = ?;";
        try {
            PreparedStatement ps = _dbConn.prepareStatement(sql);
            ps.setString(1, packageName);
            ResultSet rs = ps.executeQuery();
            while (rs.next()){
                propString =  rs.getString("Prop");
                JSONObject jsonObject = new JSONObject(propString);
                if (jsonObject.has("versionCode")){
                    if (jsonObject.getInt("versionCode") > latestVersionCode){
                        latestVersionCode = jsonObject.getInt("versionCode");
                        if (jsonObject.has("option")){
                            optionString = jsonObject.getString("option");
                        }
                    }
                }
            }
            Log.d("AFTask", "queryLatestProp: " + propString);
        } catch (SQLException | JSONException e) {
            e.printStackTrace();
        }
        Log.e("AFTask", "latestVersionCode: " + latestVersionCode + "  option: " + optionString);
        return optionString;
    }

    private void saveInfoOfApkADInfo(String packageName, String fileVer, String adVer){
        try {
            File fApp = new File("/data/data/com.bytedance.ttcollector/" + packageName, "ADAPP.txt");
            if (fApp.exists()){
                BufferedReader readerApp = new BufferedReader(new InputStreamReader(new FileInputStream(fApp)));
                String dataContent = readerApp.readLine();
                readerApp.close();

                String sql = "INSERT INTO apkprotocprop (PackageName, Prop, appVer, thirdParty, thirdVer) VALUES(?, ?, ?, ?, ?);";
//                PreparedStatement ps = _dbConn.prepareStatement(sql);
//                ps.setString(1, packageName);
//                ps.setString(2, dataContent);
//                ps.setString(3, fileVer);
//                ps.setString(4, "ADJUST");
//                ps.setString(5, adVer);
//                ps.executeUpdate();
//                Log.e("AFTask", "apkprotocprop update ok");
//                String url = String.format("http://123.56.44.45/tt/manage/apkInfo!addApkProtocPropOp.do?apkProtocProp.packageName=%s&apkProtocProp.appVer=%s&apkProtocProp.thirdParty=%s&apkProtocProp.thirdVer=%s&apkProtocProp.prop=%s", packageName, fileVer, "ADJUST", adVer, dataContent);
//                System.out.println(url);
                OkHttpClient client = new OkHttpClient();
                FormBody formBody = null;
                JSONObject jsonObject = new JSONObject(dataContent);
                formBody = new FormBody.Builder()
                        .add("apkProtocProp.packageName", packageName)
                        .add("apkProtocProp.appVer", fileVer)
                        .add("apkProtocProp.thirdParty", "ADJUST")
                        .add("apkProtocProp.thirdVer", adVer)
                        .add("apkProtocProp.prop", jsonObject.toString())
                        .build();
                Request request = new Request.Builder()
                        .url("http://123.56.44.45/tt/manage/apkInfo!addApkProtocPropOp.do?")
                        .addHeader("Content-Type", "application/x-www-form-urlencoded")
                        .method("POST", formBody)
                        .build();
                Response response = client.newCall(request).execute();
                if(response.code() == 200) {
                    System.out.println("UpdateOK");
                }
                else {
                    System.out.println("UpdateError");
                }
            }
        }catch (IOException | JSONException e){
            e.printStackTrace();
        }
    }

    private void updateEventOfApk(String packageName, String fileName){
        JSONObject eventJson = new JSONObject();
        try{
            eventJson.put("afterInstallSync", true);
            eventJson.put("afterInstallDelayMin", 3);
            eventJson.put("afterInstallDelayMax", 10);
            eventJson.put("sysVars", new JSONObject());
            JSONArray events = new JSONArray();
            JSONObject eventsItem = new JSONObject();

            eventsItem.put("sort", 1);
            eventsItem.put("subEvents", getRequestEvents(packageName));
            events.put(eventsItem);
            eventJson.put("events", events);

            String sql = "UPDATE apkinfo1 SET eventJson = ? WHERE PackageName = ? AND ApkPath = ?";
            PreparedStatement ps = _dbConn.prepareStatement(sql);
            ps.setString(1, eventJson.toString());
            ps.setString(2, packageName);
            ps.setString(3, fileName);
            ps.executeUpdate();
        }catch (Exception err){
            err.printStackTrace();
        }
    }

    /**
     * 保存参数到数据库
     * @param packageName
     * @param fileName
     * @return
     * @throws Throwable
     */
    private void saveInfoOfApk(String packageName, String fileName) {
        String fileVer = fileName.substring(fileName.lastIndexOf("_") + 1, fileName.lastIndexOf("."));
        Pair<String, String> afver = readSdkVer(packageName, "AFVERSION.txt", "AFAPP.txt", "appsflyer");
        Pair<String, String> adver = readSdkVer(packageName, "ADVERSION.txt", "ADAPP.txt", "adjust");
        saveInfoOfApkVer(packageName, fileName, afver, adver);
        saveInfoOfApkAFInfo(packageName, fileVer, afver.second);
        saveInfoOfApkADInfo(packageName, fileVer, adver.second);
        updateEventOfApk(packageName, fileName);
    }

    private void saveApp(String appid, String fileName, long waitMaxSecond, long waitMinSecond){
        try{
            if (copyLogFile(appid, waitMaxSecond, waitMinSecond)){
                saveInfoOfApk(appid, fileName);
            }
        } catch (Throwable e) {
            e.printStackTrace();
        }
    }

    private void doBusiness(String apkPath, long waitMaxSecond, long waitMinSecond) throws Throwable{
        String fileName = "";
        if(apkPath != ""){
            fileName = apkPath;
        }else {
            fileName = apkFileName(_appid);
        }
        String path = downloadAPK(_downloadUrl, fileName);
        Log.e("AFTask", "Download apk end");
        //移动到tmp文件夹
        CmdUtils.moveFile2Tmp(path);
        String apkSdcard = path;
        path = "/data/local/tmp/" + fileName;
        if(path.endsWith(".apk")) {
            clientInstallApk(new File(path));
        } else {
            clientInstallApks(new File(path));
        }
        Log.e("AFTask", "install apk end");
//        deleteAPK(path);
        deleteAPK(apkSdcard);
        CmdUtils.deleteFile(path);
        if (openApp(_appid)){
            Log.e("AFTask", "open apk end");
            saveApp(_appid, fileName, waitMaxSecond, waitMinSecond);
        }
        clientUninstall(_appid);
    }

//    /**
//     * 初始化
//     * @throws Throwablel
//     */
    public void init(String dbhost, String dbname, String dbuser, String dbpass) throws Throwable {
        Class.forName("com.mysql.jdbc.Driver");
        _dbConn= DriverManager.getConnection("jdbc:mysql://" + dbhost + "/" + dbname, dbuser, dbpass);
        _dbStat = (Statement)_dbConn.createStatement();
    }

    public void start(long waitMaxSecond, long waitMinSecond){
        new Thread(new Runnable(){
            @Override
            public void run() {
                try{
                    doBusiness("", waitMaxSecond, waitMinSecond);
                }catch (Throwable err){
                    XposedBridge.log("AFTASK ERROR : " + err.getMessage());
                }
            }
        }).start();
    }

    public static void startTask(Context context){
        new Thread(new Runnable(){
            @Override
            public void run() {
                while(!_paused){
                    String packageName = "", apkPath = "";
                    int code = -1;
                    try {
                        HttpURLConnection conn = (HttpURLConnection) new URL("http://123.56.44.45/tt/ddj/autoApk.do").openConnection();
                        conn.setConnectTimeout(5000);
                        conn.setRequestMethod("GET");
                        if (200 == conn.getResponseCode()){
                            String line;
                            StringBuilder sb = new StringBuilder();
                            BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
                            while ((line = br.readLine()) != null) {
                                sb.append(line);
                            }
                            Log.e("AFTask", sb.toString());
                            JSONObject json = new JSONObject(sb.toString());
                            if (go)
                            {
                                json = new JSONObject("{\"code\":1,\"apkPath\":\"com.jar.app_4.9.6.apk\",\"packageName\":\"com.jar.app\"}");
                                go = false;
                            }
                            //JSONObject json = new JSONObject("{\"code\":1,\"apkPath\":\"ru.ligastavok.android_3.8.0.apk\",\"packageName\":\"ru.ligastavok.android\"}");
                            code = json.has("code") ? json.getInt("code"): -1;
                            packageName = json.has("packageName") ? json.getString("packageName") : "";
                            apkPath = json.has("apkPath") ? json.getString("apkPath") : "";
                        }
                        if (code != 1) {
                            Thread.sleep(5000);
                            continue;
                        }
                        //if (code != 1) { continue; }
                        if (packageName == null || apkPath == null) { continue; }
                        if (packageName.isEmpty() || apkPath.isEmpty()) { continue; }
                        //TTTask task = new TTTask(context, packageName, "http://123.56.44.45/tt/upload/ddj/");
                        TTTask task = new TTTask(context, packageName, "http://39.103.73.250/tt/upload/ddj/");
                        task.init("pc-2ze3t9ojzloi45k3to.mysql.polardb.rds.aliyuncs.com", "advert_lcddj", "advertuser1116", "IvM@ck#z9$Eqy3KGBK4g");
                        task.doBusiness(apkPath, 60, 0);
                        Log.e("AFTask", "Loop end for pack: " + packageName);
                    } catch(Throwable e){
                        Log.d("AFTask", "run: " + e.toString());
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }
}