//调用方法为：
//InstallUtils.install28(MainActivity.this,"/data/local/tmp/test.apk",InstallResultReceiver.class)
 
//需系统签名和添加以下权限
//<uses-permission android:name="android.permission.INSTALL_PACKAGES" />
//<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
 
package com.android.settings;
import android.app.PendingIntent;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.pm.PackageInstaller;
import android.util.Log;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;


public class InstallUtils {
    private static final String TAG = "myLog";

    // 适配android9的安装方法。
    public static void install28(Context context, String apkFilePath,Class<InstallResultReceiver> receiver) {

        Log.d(TAG,"install28 path="+apkFilePath);

        File apkFile = new File(apkFilePath);

        PackageInstaller packageInstaller = context.getPackageManager().getPackageInstaller();

        PackageInstaller.SessionParams sessionParams
                = new PackageInstaller.SessionParams(PackageInstaller
                .SessionParams.MODE_FULL_INSTALL);

        sessionParams.setSize(apkFile.length());
        int sessionId = createSession(packageInstaller, sessionParams);

        Log.d(TAG,"install28  sessionId="+sessionId);

        if (sessionId != -1) {
            boolean copySuccess = copyInstallFile(packageInstaller, sessionId, apkFilePath);
            Log.d(TAG,"install28  copySuccess="+copySuccess);
            if (copySuccess) {
                execInstallCommand(context,packageInstaller, sessionId,receiver);
            }
        }
    }

    private static int createSession(PackageInstaller packageInstaller,
                                    PackageInstaller.SessionParams sessionParams) {

        int sessionId = -1;

        try {
            sessionId = packageInstaller.createSession(sessionParams);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return sessionId;
    }

    private static boolean copyInstallFile(PackageInstaller packageInstaller,int sessionId, String apkFilePath) {

        InputStream in = null;
        OutputStream out = null;
        PackageInstaller.Session session = null;
        boolean success = false;

        try {

            File apkFile = new File(apkFilePath);
            session = packageInstaller.openSession(sessionId);
            out = session.openWrite("base.apk", 0, apkFile.length());
            in = new FileInputStream(apkFile);

            int total = 0, c;
            byte[] buffer = new byte[65536];
            while ((c = in.read(buffer)) != -1) {
                total += c;
                out.write(buffer, 0, c);
            }

            session.fsync(out);
            Log.i(TAG, "streamed " + total + " bytes");
            success = true;
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

            try {
                if (out!=null){
                    out.close();
                }

                if (in!=null){
                    in.close();
                }

                if (session!=null){
                    session.close();
                }

            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        return success;
    }


    private static void execInstallCommand(Context context, PackageInstaller packageInstaller, int sessionId, Class<InstallResultReceiver> receiver) {

        PackageInstaller.Session session = null;
        try {
            session = packageInstaller.openSession(sessionId);
            Intent intent = new Intent(context, receiver);
            PendingIntent pendingIntent = PendingIntent.getBroadcast(context,
                    1, intent,
                    PendingIntent.FLAG_UPDATE_CURRENT);

            session.commit(pendingIntent.getIntentSender());

            Log.i(TAG, "begin session");

        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            session.close();
        }
    }
}