TermApp/app/src/main/java/com/xypower/mpapp/MicroPhotoService.java

package com.xypower.mpapp;

import static java.lang.System.loadLibrary;

import android.app.AlarmManager;
import android.app.Notification;
import android.app.NotificationChannel;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.app.Service;
import android.content.BroadcastReceiver;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.graphics.Bitmap;
import android.graphics.Canvas;
import android.graphics.Color;
import android.graphics.Paint;
import android.location.Location;
import android.location.LocationListener;
import android.location.LocationManager;
import android.location.LocationProvider;
import android.net.ConnectivityManager;
import android.net.Network;
import android.net.NetworkCapabilities;
import android.net.NetworkInfo;
import android.net.NetworkRequest;
import android.net.Uri;
import android.net.wifi.WifiManager;
import android.os.BatteryManager;
import android.os.Build;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.PowerManager;
import android.os.RemoteException;
import android.os.SystemClock;

import androidx.core.app.NotificationCompat;
import androidx.core.content.FileProvider;
import androidx.localbroadcastmanager.content.LocalBroadcastManager;

import android.telephony.SignalStrength;
import android.telephony.SubscriptionManager;
import android.telephony.TelephonyManager;
import android.text.TextPaint;
import android.text.TextUtils;
import android.text.format.DateFormat;
import android.util.Log;
import android.widget.RemoteViews;
import android.widget.Toast;

import com.dev.devapi.api.SysApi;
import com.xypower.common.FileDownloader;
import com.xypower.common.InetAddressUtils;
import com.xypower.common.MicroPhotoContext;
import com.xypower.mpapp.video.VideoActivity;

import java.io.File;
import java.io.FileOutputStream;
import java.lang.reflect.Method;
import java.net.InetAddress;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class MicroPhotoService extends Service {
    public static final String TAG = "MPLOG";

    // Used to load the 'microphoto' library on application startup.
    static {
        loadLibrary("microphoto");
    }

    public static final int MSG_WHAT_LOG = 10;

    public final static int MSG_WHAT_NETWORK_CHANGE = 20;

    public final static int MSG_WHAT_SERVICE_STATUS_CHANGE = 30;

    public final static int MSG_WHAT_SENDING_HB = 40;

    public final static int MSG_WHAT_MAX = 1000;

    private static final String ALARM_EVENT = "com.xinyingpower.mp.MicroPhotoService.AlarmReceiver";
    public static final int NOTIFICATION_ID_FOREGROUND_SERVICE = 8466503;
    // public static final int NOTIFICATION_ID_FOREGROUND_SERVICE = 0;
    public static final String ACTION_MSG_BROADCAST = "ACT_MSG_BROADCAST";

    public static final String ACTION_START = "com.xypower.mpapp.ACT_START";
    public static final String ACTION_STOP = "com.xypower.mpapp.ACT_STOP";
    public static final String ACTION_MAIN = "com.xypower.mpapp.ACT_MAIN";
    private static final String ACTION_HEARTBEAT = "com.xypower.mpapp.ACT_HB";
    private static final String ACTION_TAKE_PHOTO = "com.xypower.mpapp.ACT_TP";

    private static final String ACTION_IMP_PUBKRY = "com.xypower.mpapp.ACT_IMP_PUBKEY";

    private static final String ACTION_TAKE_PHOTO_MANUALLY = "com.xypower.mpapp.ACT_TP_M";
    private static final String ACTION_HEARTBEAT_MANUALLY = "com.xypower.mpapp.ACT_HB_M";
    private static final String ACTION_UPDATE_CONFIGS = "com.xypower.mpapp.ACT_UPD_CFG";
    public static final String ACTION_VIDEO_FINISHED = "com.xypower.mpapp.ACT_V_FINISHED";
    private static final String EXTRA_PARAM_CHANNEL = "Channel";
    private static final String EXTRA_PARAM_PRESET = "Preset";
    private static final String EXTRA_PARAM_PHOTO_OR_VIDEO = "PhotoOrVideo";
    private static final String EXTRA_PARAM_SCHEDULES = "Schedules";
    private static final String EXTRA_PARAM_SCHEDULE = "Schedule_";
    private static final String EXTRA_PARAM_TAKING_TIME = "TakingTime";
    private static final String EXTRA_PARAM_TIME = "Time";
    // private static String EXTRA_PARAM_FILENAME = "FileName";
    private static final String EXTRA_PARAM_TIMER_UID = "TimerUid";
    // private static String EXTRA_PARAM_TIMER_TYPE = "TimerType";
    private static final String EXTRA_PARAM_TIMEOUT = "Timeout";
    private static final String EXTRA_PARAM_TIMES = "Times";
    private static final String EXTRA_PARAM_ELASPED_TIMES = "ElapsedTimes";
    private static final String FOREGROUND_CHANNEL_ID = "foreground_channel_id";
    public static class STATE_SERVICE {
        public static final int CONNECTED = 10;
        public static final int NOT_CONNECTED = 0;
    }
    private static int mStateService = STATE_SERVICE.NOT_CONNECTED;

    private String mCmdid = "";
    private NotificationManager mNotificationManager;
    private final Map<String, PowerManager.WakeLock> mWakeLocks = new HashMap<>();
    private int mHeartbeatDuration = 0; // MUST BE 0!!!
    private long mNextHeartbeatTime = 0;

    private PositionManager mPositionManager = null;
    private final Map<Long, PendingIntent> mTimers = new HashMap<>();

    protected long mNativeHandle = 0;
    private AlarmReceiver mAlarmReceiver = null;
    private AlarmReceiver mLocalMsgReceiver = null;
    private ScreenActionReceiver mScreenaAtionReceiver = null;
    private NetworkChangedReceiver mNetworkChangedReceiver = null;

    private ServiceHandler mHander = null;
    private Messenger mMessenger = null;

    private String mModelName = null;

    public static boolean isRunning = false;

    public MicroPhotoService() {
    }
    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
        throw new UnsupportedOperationException("Not yet implemented");
    }
    @Override
    public void onCreate() {
        super.onCreate();

        mHander = new ServiceHandler();

        mNotificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
        mStateService = STATE_SERVICE.NOT_CONNECTED;

        DeviceUtil.getPhoneState(this.getApplicationContext());

        mScreenaAtionReceiver = new ScreenActionReceiver();

        // 注册广播接受者
        {
            mAlarmReceiver = new AlarmReceiver(this);
            IntentFilter intentFilter = new IntentFilter(ACTION_HEARTBEAT);
            intentFilter.addAction(ACTION_TAKE_PHOTO);
            intentFilter.addAction(ACTION_UPDATE_CONFIGS);
            intentFilter.addAction(ACTION_IMP_PUBKRY);
            // intentFilter.addAction(ACTION_HEARTBEAT_MANUALLY);
            // intentFilter.addAction(ACTION_MSG_BROADCAST);
            // intentFilter.addAction(ACTION_VIDEO_FINISHED);
            // intentFilter.addAction(ACTION_STOP);
            // intentFilter.addCategory(Intent.CATEGORY_DEFAULT);
            getApplicationContext().registerReceiver(mAlarmReceiver, intentFilter, Context.RECEIVER_EXPORTED | Context.RECEIVER_VISIBLE_TO_INSTANT_APPS);

            // IntentFilter intentFilter2 = new IntentFilter(ACTION_MSG_BROADCAST);
            // registerReceiver(mAlarmReceiver, intentFilter2);

            // registerRe
        }
        {
            mLocalMsgReceiver = new AlarmReceiver(this);
            IntentFilter intentFilter = new IntentFilter();
            intentFilter.addAction(ACTION_HEARTBEAT);
            intentFilter.addAction(ACTION_TAKE_PHOTO);
            intentFilter.addAction(ACTION_TAKE_PHOTO_MANUALLY);
            intentFilter.addAction(ACTION_HEARTBEAT_MANUALLY);
            intentFilter.addAction(ACTION_MSG_BROADCAST);
            intentFilter.addAction(ACTION_VIDEO_FINISHED);
            intentFilter.addAction(ACTION_STOP);
            intentFilter.addAction(ACTION_UPDATE_CONFIGS);

            LocalBroadcastManager.getInstance(getApplicationContext()).registerReceiver (mLocalMsgReceiver, intentFilter);
        }

        {
            mNetworkChangedReceiver = new NetworkChangedReceiver(this);
            IntentFilter filter = new IntentFilter();
            filter.addAction(WifiManager.WIFI_STATE_CHANGED_ACTION);
            filter.addAction(WifiManager.NETWORK_STATE_CHANGED_ACTION);
            filter.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
            getApplicationContext().registerReceiver(mNetworkChangedReceiver, filter);
        }

        AlarmManager alarmManager = (AlarmManager) getApplicationContext().getSystemService(ALARM_SERVICE);

        while (true) {
            AlarmManager.AlarmClockInfo aci = alarmManager.getNextAlarmClock();
            if (aci == null) {
                break;
            }

            /*
            if (aci.getShowIntent().isBroadcast()) {
                // alarmManager.cancel(aci.getShowIntent());
            }

             */
        }
        // alarmManager.cancel();

        // boolean res = false;
        // Environment.getExternalStoragePublicDirectory(String)

        // registerHeartbeatTimer(getHeartbeatDuration());

        enableGps(true);
        requestPosition();
    }
    @Override
    public void onDestroy() {

        mStateService = STATE_SERVICE.NOT_CONNECTED;

        Log.w(TAG, "MicroPhotoService::onDestroy called");

        if (mNativeHandle != 0) {
            uninit(mNativeHandle);
            mNativeHandle = 0;
            isRunning = false;
        }

        getApplicationContext().unregisterReceiver(mAlarmReceiver);
        getApplicationContext().unregisterReceiver(mScreenaAtionReceiver);
        getApplicationContext().unregisterReceiver(mNetworkChangedReceiver);

        LocalBroadcastManager.getInstance(getApplicationContext()).unregisterReceiver(mLocalMsgReceiver);

        for(Map.Entry<String, PowerManager.WakeLock> entry : mWakeLocks.entrySet()) {
            try {
                PowerManager.WakeLock wl = entry.getValue();
                wl.setReferenceCounted(false);
                wl.release();
                wl = null;
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
        mWakeLocks.clear();

        super.onDestroy();
    }

    public static class ServiceHandler extends Handler {
        @Override
        public void dispatchMessage(Message msg) {
            super.dispatchMessage(msg);
            // Log.i("life", "MyHandler----dispatchMessage");
            // Log.i("life", Thread.currentThread().getName());
        }

        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            // Log.i("life", "MyHandler----handleMessage");
        }
    }

    public String getCmdid() {
        return mCmdid;
    }

    public static void sendMessage(Context context, int what, int data) {
        Intent intent = new Intent(ACTION_MSG_BROADCAST);
        intent.putExtra("what", what);
        intent.putExtra("data", data);
        intent.setPackage(context.getPackageName());
        String typeName = AlarmReceiver.class.getTypeName();
        intent.setComponent( new ComponentName(context.getPackageName(), AlarmReceiver.class.getTypeName()) );
        context.sendBroadcast(intent);
    }

    public static class AlarmReceiver extends BroadcastReceiver {
        private MicroPhotoService mService;
        public AlarmReceiver() {
            mService = null;
        }
        public AlarmReceiver(MicroPhotoService service) {
            mService = service;
        }
        public void onReceive(Context context, Intent intent) {
            String action = intent.getAction();
            if (TextUtils.equals(ACTION_HEARTBEAT, action)) {
                Log.i(TAG, "HB Timer Fired ACTION=" + action);
                Runnable runnable = new Runnable() {
                    public void run() {
                        mService.sendHeartbeat(mService.mNativeHandle, mService.getSignalLevel());
                    }
                };

                Thread th = new Thread(runnable);
                th.start();
                
                mService.registerHeartbeatTimer();

            } else if (TextUtils.equals(ACTION_TAKE_PHOTO, action)) {
                long ts = intent.getLongExtra(EXTRA_PARAM_TIME, 0);
                int cnt = intent.getIntExtra(EXTRA_PARAM_SCHEDULES, 0);
                if (cnt > 0) {
                    for (int idx = 0; idx < cnt; idx++) {
                        long val = intent.getLongExtra(EXTRA_PARAM_SCHEDULE + idx, 0);

                        int channel = (int) ((val & 0xFF0000L) >> 16);
                        int preset = (int) ((val & 0xFF00L) >> 8);
                        boolean photoOrVideo = ((val & 0xFFL) == 0);

                        Log.i(TAG, "PhotoTimer Fired: CH=" + channel + " PR=" + preset);
                        mService.notifyToTakePhoto(mService.mNativeHandle, channel, preset, ts, photoOrVideo);
                    }
                }

                // Register Next Photo Timer
                Date date = new Date();
                long startTime = (date.getTime() + 999) / 1000 + 1;    // Add one second
                mService.updateCaptureSchedule(startTime);
            } else if (TextUtils.equals(ACTION_HEARTBEAT_MANUALLY, action)) {
                Log.i(TAG, "HB Timer Fired ACTION=" + action);
                mService.sendHeartbeat(mService.mNativeHandle, mService.getSignalLevel());
            } else if (TextUtils.equals(ACTION_TAKE_PHOTO_MANUALLY, action)) {
                int channel = intent.getIntExtra(EXTRA_PARAM_CHANNEL, 0);
                int preset = intent.getIntExtra(EXTRA_PARAM_PRESET, 0);
                // long ts = intent.getLongExtra(EXTRA_PARAM_TIME, 0);
                boolean photoOrVideo = intent.getBooleanExtra(EXTRA_PARAM_PHOTO_OR_VIDEO, true);
                long ts = System.currentTimeMillis() / 1000;

                Log.i(TAG, "Take Photo CH=" + channel + " PR=" + preset + " Mannually");
                mService.notifyToTakePhoto(mService.mNativeHandle, channel, preset, ts, photoOrVideo);
            } else if (TextUtils.equals(ACTION_MSG_BROADCAST, action)) {

                int what = intent.getIntExtra("what", 0);
                int data = intent.getIntExtra("data", 0);

                if (what == MSG_WHAT_SENDING_HB) {
                    mService.sendHeartbeat(mService.mNativeHandle, mService.getSignalLevel());
                }
            } else if (TextUtils.equals(ACTION_UPDATE_CONFIGS, action)) {
                int restart = intent.getIntExtra("restart", 0);
                Log.i(TAG, "UPD CFG Fired ACTION=" + action + " restart=" + restart);
                if (restart != 0) {
                    MicroPhotoService.restartApp(context, context.getPackageName());
                } else if (mService.mNativeHandle != 0) {
                    mService.reloadConfigs(mService.mNativeHandle);
                }
            } else if (TextUtils.equals(ACTION_VIDEO_FINISHED, action)) {
                boolean result = intent.getBooleanExtra("result", false);
                String path = intent.getStringExtra("path");
                long videoId = intent.getLongExtra("videoId", 0);
                Log.i(TAG, "Recording received(" + Long.toString(videoId) + "):" + path);

                mService.recordingFinished(mService.mNativeHandle, result, path, videoId);
            } else if (TextUtils.equals(ACTION_STOP, action)) {
                mService.stopTerminalService();
            } else if (TextUtils.equals(ACTION_IMP_PUBKRY, action)) {
                String path = intent.getStringExtra("path");
                String md5 = intent.getStringExtra("md5");
            }
        }
    }

    // Will be called fron native
    private void registerHeartbeatTimer(int duration) {
        int orgHeartbeatDuration = mHeartbeatDuration;
        mHeartbeatDuration = duration;
        if (orgHeartbeatDuration == 0) {
            registerHeartbeatTimer();
        }

    }
    private void registerHeartbeatTimer() {

        // 创建延迟意图
        Intent alarmIntent = new Intent();
        alarmIntent.setAction(ACTION_HEARTBEAT);
        PendingIntent pendingIntent = PendingIntent.getBroadcast(this, 0, alarmIntent, 0);

        AlarmManager alarmManager = (AlarmManager) getSystemService(ALARM_SERVICE);
        alarmManager.setExactAndAllowWhileIdle(AlarmManager.ELAPSED_REALTIME_WAKEUP, SystemClock.elapsedRealtime() + mHeartbeatDuration, pendingIntent);

        mNextHeartbeatTime = System.currentTimeMillis() + mHeartbeatDuration;
        // alarmManager.setExactAndAllowWhileIdle(AlarmManager.ELAPSED_REALTIME, SystemClock.elapsedRealtime() + timeout, pendingIntent);
    }

    private static void registerPhotoTimer(Context context, long scheduleTime, long takingTime, long timeout, List<Long> schedules) {

        // 创建延迟意图
        Intent intent = new Intent();
        intent.setAction(ACTION_TAKE_PHOTO);
        int cnt = schedules.size();
        intent.putExtra(EXTRA_PARAM_SCHEDULES, cnt);
        StringBuilder channelStr = new StringBuilder();
        long val = 0;
        for (int idx = 0; idx < cnt; idx++) {
            val = schedules.get(idx).longValue();
            intent.putExtra(EXTRA_PARAM_SCHEDULE + idx, schedules.get(idx).longValue());
            channelStr.append("(" + ((val & 0XFF0000) >> 16) + "-" + Long.toString (((val & 0XFF00) >> 8), 16).toUpperCase() + ") ");
        }

        intent.putExtra(EXTRA_PARAM_TIME, scheduleTime);
        intent.putExtra(EXTRA_PARAM_TAKING_TIME, takingTime);

        if (timeout == 0) {
            // LocalBroadcast
            LocalBroadcastManager localBroadcastManager = LocalBroadcastManager.getInstance(context);
            localBroadcastManager.sendBroadcast(intent);
        } else {
            PendingIntent pendingIntent = PendingIntent.getBroadcast(context, 0, intent, PendingIntent.FLAG_UPDATE_CURRENT);

            AlarmManager alarmManager = (AlarmManager) context.getSystemService(ALARM_SERVICE);
            try {
                alarmManager.cancel(pendingIntent);
            } catch (Exception ex) {
                ex.printStackTrace();
            }

            long currentTimeMillis = System.currentTimeMillis();
            Date date = new Date(currentTimeMillis + timeout);
            String dateStr = (String) DateFormat.format("MM-dd kk:mm:ss", date);
            Log.d(TAG, "PhotoTimer Reg: " + dateStr + " currentTimeMillis=" + currentTimeMillis + " timeout=" + timeout + " CH-PR=" + channelStr.toString());

            alarmManager.setExactAndAllowWhileIdle(AlarmManager.RTC_WAKEUP, System.currentTimeMillis() + timeout, pendingIntent);
        }
    }

    private void registerPhotoTimer(long scheduleTime, long timeout, List<Long> schedules) {

        registerPhotoTimer(getApplicationContext(), scheduleTime, scheduleTime, timeout, schedules);
    }

    public void startRecording(int cameraId, long videoId, int duration, int width, int height, int quality, int orientation, String leftTopOsd, String rightTopOsd, String rightBottomOsd, String leftBottomOsd) {
        Context context = getApplicationContext();
        Intent intent = new Intent(this, VideoActivity.class);

        intent.putExtra("cameraId", cameraId);
        intent.putExtra("videoId", videoId);
        intent.putExtra("duration", duration);
        intent.putExtra("width", width);
        intent.putExtra("height", height);
        intent.putExtra("quality", quality);
        intent.putExtra("orientation", orientation);
        intent.putExtra("leftTopOsd", leftTopOsd);
        intent.putExtra("rightTopOsd", rightTopOsd);
        intent.putExtra("rightBottomOsd", rightBottomOsd);
        intent.putExtra("leftBottomOsd", leftBottomOsd);

        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
        startActivity(intent);
    }

    protected boolean updateCaptureSchedule(long startTime) {

        long[] photoTimeData = getPhotoTimeData(mNativeHandle, startTime);
        if (photoTimeData == null || photoTimeData.length < 4) {
            return false;
        }

        // int maxDuration = 35 * 60 * 1000 + 1000;
        List<Long> schedules = new ArrayList<>();
        for (int idx = 0; idx < photoTimeData[2]; idx++) {
            schedules.add(Long.valueOf(photoTimeData[3 + idx]));
        }

        if (schedules.isEmpty()) {
            return false;
        }

        long expectedTs = photoTimeData[0] + photoTimeData[1];

        registerPhotoTimer(expectedTs, expectedTs * 1000 - System.currentTimeMillis(), schedules);

        return true;
    }

    public static void takePhoto(Context context, int channel, int preset, boolean photoOrVideo) {

        List<Long> schedules = new ArrayList<>();
        long ts = System.currentTimeMillis() / 1000;
        // long val = (ts << 24);
        long val = 0;
        val |= ((long)channel << 16);
        val |= ((long)preset << 8);
        val |= photoOrVideo ? 0L : 1L;

        schedules.add(Long.valueOf(val));

        registerPhotoTimer(context, 0, ts, 0, schedules);
    }

    public static void sendHeartbeat(Context context) {
        Intent intent = new Intent();
        intent.setAction(ACTION_HEARTBEAT_MANUALLY);
        // PendingIntent pendingIntent = PendingIntent.getBroadcast(context, 0, intent, 0);
        LocalBroadcastManager localBroadcastManager = LocalBroadcastManager.getInstance(context);
        localBroadcastManager.sendBroadcast(intent);
    }

    public static void updateConfigs(Context context) {
        Intent intent = new Intent();
        intent.setAction(ACTION_UPDATE_CONFIGS);
        // PendingIntent pendingIntent = PendingIntent.getBroadcast(context, 0, intent, 0);
        LocalBroadcastManager localBroadcastManager = LocalBroadcastManager.getInstance(context);
        localBroadcastManager.sendBroadcast(intent);
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {

        if (intent == null) {
            stopForeground(true);
            stopSelf();
            return START_NOT_STICKY;
        }

        // if user starts the service
        switch (intent.getAction()) {
            case ACTION_START:
                Log.d(TAG, "Received user starts foreground intent");
                startForeground(NOTIFICATION_ID_FOREGROUND_SERVICE, prepareNotification());

                connect();

                getApplicationContext().registerReceiver(mScreenaAtionReceiver, mScreenaAtionReceiver.getFilter());
                if (intent.hasExtra("messenger")) {
                    mMessenger = intent.getParcelableExtra("messenger");
                }

                int network = intent.getIntExtra("network", 0);

                network = 0;
                if (network == 0) {
                    startTerminalService(intent);
                } else {
                    ConnectivityManager cm =(ConnectivityManager) getApplicationContext().getSystemService(Context.CONNECTIVITY_SERVICE);

                    NetworkRequest.Builder builder = new NetworkRequest.Builder();
                    builder.addCapability(NetworkCapabilities.NET_CAPABILITY_DUN);
                    builder.addCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET);

                    List<NetworkInfo> availableNetworkInfos = new ArrayList<>();

                    cm.registerNetworkCallback(builder.build(), new ConnectivityManager.NetworkCallback() {

                        @Override
                        public void onAvailable(Network network) {
                            super.onAvailable(network);

                            availableNetworkInfos.add(cm.getNetworkInfo(network));

                            Log.i(TAG, "Network");
                        }

                    });

                    NetworkInfo[] networkInfos = cm.getAllNetworkInfo();

                    for (NetworkInfo ni : networkInfos) {
                        if (ni.getType() == ConnectivityManager.TYPE_MOBILE ||
                                ni.getType() == ConnectivityManager.TYPE_MOBILE_DUN ||
                                ni.getType() == ConnectivityManager.TYPE_WIFI) {

                            // availableNetworkInfos.add(ni);
                        }
                    }
                    Network[] networks = cm.getAllNetworks();

                    for (Network nw : networks) {
                        NetworkInfo nwi = cm.getNetworkInfo(nw);
                        String name = nwi.toString();
                        if (name.equals("")) {

                        }
                    }
                }

                break;
            case ACTION_STOP:
                try {
                    getApplicationContext().unregisterReceiver(mScreenaAtionReceiver);
                } catch (Exception ex) {

                }
                stopForeground(true);
                stopSelf();
                break;
            default:
                stopForeground(true);
                stopSelf();
        }

        return START_NOT_STICKY;
    }

    private void startTerminalService(Intent intent) {

        if (MicroPhotoService.this.mNativeHandle != 0) {
            return;
        }

        final String appPath = MicroPhotoContext.buildAppDir(this.getApplicationContext());

        final String server = intent.getStringExtra("server");
        final int port = intent.getIntExtra("port", 0);
        final String cmdid = intent.getStringExtra("cmdid");
        final int protocol = intent.getIntExtra("protocol", 0);
        final int networkProtocol = intent.getIntExtra("networkProtocol", 0);
        final int encryptData = intent.getIntExtra("encryption", 0);

        Runnable runnable = new Runnable() {
            public void run() {

                String ip = server;
                if (!InetAddressUtils.isIPv4Address(ip) && !InetAddressUtils.isIPv6Address(ip)) {
                    // It is a domain
                    InetAddress addr = null;
                    try {
                        addr = InetAddress.getByName(server);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    if (addr != null) {
                        ip = addr.getHostAddress();
                    }
                }

                Log.i(TAG, "AppPath=" + appPath + " Server=" + ip + ":" + port + " cmdid=" + cmdid + " Protocol=" + protocol + " Network=" + networkProtocol);

                MicroPhotoService service = MicroPhotoService.this;

                int versionCode = MicroPhotoContext.getVersionCode(MicroPhotoService.this.getApplicationContext());

                service.mNativeHandle = init(appPath, server, port, cmdid, protocol, networkProtocol, encryptData, 0, service.getSignalLevel(), versionCode);

                if (service.mNativeHandle != 0) {
                    isRunning = true;
                    service.mCmdid = cmdid;

                    Date date = new Date();
                    long startTime = (date.getTime() + 999) / 1000;
                    service.updateCaptureSchedule(startTime);

                    try {
                        Location location = mLocationManager.getLastKnownLocation(mLocateType);
                        if (location != null) {
                            service.updatePosition(service.mNativeHandle, location.getLongitude(), location.getLatitude(), location.getAccuracy(), location.getTime() / 1000);
                        }
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                }
            }
        };

        Thread th = new Thread(runnable);
        th.start();
    }

    public static void stopTerminalService(Context context) {

        Intent alarmIntent = new Intent();

        alarmIntent.setPackage(context.getPackageName());
        alarmIntent.setAction(ACTION_STOP);
        PendingIntent pendingIntent = PendingIntent.getBroadcast(context.getApplicationContext(), 0, alarmIntent, 0);

        AlarmManager alarmManager = (AlarmManager) context.getApplicationContext().getSystemService(ALARM_SERVICE);
        alarmManager.setExactAndAllowWhileIdle(AlarmManager.ELAPSED_REALTIME_WAKEUP, SystemClock.elapsedRealtime() + 100, pendingIntent);
    }

    public void stopTerminalService() {

        if (mNativeHandle == 0) {
            return;
        }

        Runnable runnable = new Runnable() {
            public void run() {
                uninit(mNativeHandle);
                mNativeHandle = 0;

                try {
                    getApplicationContext().unregisterReceiver(mScreenaAtionReceiver);
                } catch (Exception ex) {

                }
                stopForeground(true);
                stopSelf();
            }
        };

        Thread thread = new Thread(runnable);
        thread.start();
    }

    public void requestWakelock(String name, long timeout) {
        PowerManager powerManager = (PowerManager) getSystemService(POWER_SERVICE);
        PowerManager.WakeLock wl = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK/* | PowerManager.ON_AFTER_RELEASE*/, name);
        PowerManager.WakeLock wl2 = null;
        synchronized (mWakeLocks) {
            wl2 = mWakeLocks.get(name);
            mWakeLocks.put(name, wl);
        }
        if (wl2 != null) {
            Log.i(TAG, "Release same name wakelock:" + name);
            wl2.setReferenceCounted(false);
            wl2.release();
        }
        Log.i(TAG, "Request wakelock:" + name);
        if (timeout == 0) wl.acquire();
        else wl.acquire(timeout);
    }

    public void releaseWakelock(String name) {
        PowerManager.WakeLock wl = null;
        synchronized (mWakeLocks) {
            try {
                wl = mWakeLocks.get(name);
                mWakeLocks.remove(name);
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
        if (wl != null) {
            Log.i(TAG, "Release wakelock:" + name);
            try {
                wl.setReferenceCounted(false);
                wl.release();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
            wl = null;
        }
    }

    private void connect() {
        // after 10 seconds its connected
        mHander.postDelayed(
                new Runnable() {
                    public void run() {
                        Log.d(TAG, "Bluetooth Low Energy device is connected!!");
                        Toast.makeText(getApplicationContext(), "Connected!", Toast.LENGTH_SHORT).show();
                        mStateService = STATE_SERVICE.CONNECTED;
                        startForeground(NOTIFICATION_ID_FOREGROUND_SERVICE, prepareNotification());
                    }
                }, 10000);

    }

    private Notification prepareNotification() {
        // handle build version above android oreo
        if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.O &&
                mNotificationManager.getNotificationChannel(FOREGROUND_CHANNEL_ID) == null) {
            CharSequence name = getString(R.string.text_name_notification);
            int importance = NotificationManager.IMPORTANCE_DEFAULT;
            NotificationChannel channel = new NotificationChannel(FOREGROUND_CHANNEL_ID, name, importance);
            channel.enableVibration(false);
            mNotificationManager.createNotificationChannel(channel);
        }

        Intent notificationIntent = new Intent(this, MainActivity.class);
        notificationIntent.setAction(ACTION_MAIN);
        notificationIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK | Intent.FLAG_ACTIVITY_CLEAR_TASK);

        // if min sdk goes below honeycomb
        /*if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.HONEYCOMB) {
            notificationIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK | Intent.FLAG_ACTIVITY_CLEAR_TASK);
        } else {
            notificationIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
        }*/

        PendingIntent pendingIntent = PendingIntent.getActivity(this, 0, notificationIntent, PendingIntent.FLAG_UPDATE_CURRENT);

        // make a stop intent
        Intent stopIntent = new Intent(this, MicroPhotoService.class);
        stopIntent.setAction(ACTION_STOP);
        PendingIntent pendingStopIntent = PendingIntent.getService(this, 0, stopIntent, PendingIntent.FLAG_UPDATE_CURRENT);
        RemoteViews remoteViews = new RemoteViews(getPackageName(), R.layout.notification);
        remoteViews.setOnClickPendingIntent(R.id.btn_stop, pendingStopIntent);

        // if it is connected
        switch (mStateService) {
            case STATE_SERVICE.NOT_CONNECTED:
                remoteViews.setTextViewText(R.id.tv_state, "DISCONNECTED");
                break;
            case STATE_SERVICE.CONNECTED:
                remoteViews.setTextViewText(R.id.tv_state, "CONNECTED");
                break;
        }

        // notification builder
        NotificationCompat.Builder notificationBuilder;
        if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.O) {
            notificationBuilder = new NotificationCompat.Builder(this, FOREGROUND_CHANNEL_ID);
        } else {
            notificationBuilder = new NotificationCompat.Builder(this);
        }
        notificationBuilder
                .setContent(remoteViews)
                .setSmallIcon(R.mipmap.ic_launcher)
                .setCategory(NotificationCompat.CATEGORY_SERVICE)
                .setOnlyAlertOnce(true)
                .setOngoing(true)
                .setAutoCancel(true)
                .setContentIntent(pendingIntent);

        if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.LOLLIPOP) {
            notificationBuilder.setVisibility(NotificationCompat.VISIBILITY_PUBLIC);
        }

        return notificationBuilder.build();
    }

    public boolean updateTime(long timeInMillis) {
        try {
            SysApi.setSystemTime(getApplicationContext(), timeInMillis);
        } catch (Exception ex) {
        }
        return true;
    }

    public static Uri getUriForFile(Context context, File file) {
        if (Build.VERSION.SDK_INT > 24) {
            return FileProvider.getUriForFile(context, context.getPackageName() + ".fileProvider", file);
        }
        return Uri.fromFile(file);
    }

    public boolean requestPosition() {

        try {

            if (mLocationManager == null) {
                mLocationManager = (LocationManager) getSystemService (Context.LOCATION_SERVICE);

                if (!mLocationManager.isProviderEnabled(android.location.LocationManager.GPS_PROVIDER)) {
                    return false;
                }

                mLocateType = mLocationManager.GPS_PROVIDER;
                // Set Listener
            }
            try {
                mLocationManager.requestLocationUpdates(mLocateType, 100, 1, mLocationListener);
            } catch (Exception ex) {
                ex.printStackTrace();
            }

            Location location = mLocationManager.getLastKnownLocation(mLocateType);
            if (location != null && mNativeHandle != 0) {
                updatePosition(mNativeHandle, location.getLongitude(), location.getLatitude(), location.getAccuracy(), location.getTime() / 1000);
            }

            return true;
        } catch (SecurityException ex) {
            ex.printStackTrace();
        }

        return false;
    }

    public void downloadAndInstall(final String url) {

        final Context context = getApplicationContext();
        final String tempPath = MicroPhotoContext.buildAppDir(context) + File.separator + "tmp";
        File file = new File(tempPath);
        file.mkdirs();
        final String filePath = tempPath + File.separator + "mp.apk";
        Thread th =new Thread(new Runnable() {
            @Override
            public void run() {

                PowerManager powerManager = (PowerManager) getSystemService(POWER_SERVICE);
                PowerManager.WakeLock wl = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK | PowerManager.ON_AFTER_RELEASE, "com.xinyingpower.microphoto:Upgrader");

                FileDownloader fd = new FileDownloader();
                fd.download(url, filePath);

                SysApi.installApk(context, filePath, context.getPackageName(), true);

                try {
                    wl.setReferenceCounted(false);
                    wl.release();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        });
        th.start();
    }

    protected int getSignalLevel() {
        try {
            final TelephonyManager telephonyManager = (TelephonyManager) getApplicationContext().getSystemService(Context.TELEPHONY_SERVICE);
            SignalStrength ss = telephonyManager.getSignalStrength();

            if (ss != null) {
                return ss.getLevel();
            }
        } catch (Exception ex) {
        }
        return -1;
    }

    public String getSystemInfo() {

        boolean isXyPlatform = mModelName.startsWith("tb8788");

        StringBuilder sb = new StringBuilder();

        IntentFilter intentFilter = new IntentFilter(Intent.ACTION_BATTERY_CHANGED);
        Intent intent = getApplicationContext().registerReceiver(null, intentFilter);

        int batteryStatus = intent.getIntExtra(BatteryManager.EXTRA_STATUS, -1);
        int isCahrging = ((batteryStatus == BatteryManager.BATTERY_STATUS_CHARGING) ||
                (batteryStatus == BatteryManager.BATTERY_STATUS_FULL)) ? 1 : 0;

        int level = intent.getIntExtra("level", 0);    ///电池剩余电量
        int scale = intent.getIntExtra("scale", 0);  ///获取电池满电量数值
        // intent.getStringExtra("technology");  ///获取电池技术支持
        // intent.getIntExtra("status",BatteryManager.BATTERY_STATUS_UNKNOWN); ///获取电池状态
        // intent.getIntExtra("plugged", 0);  ///获取电源信息
        // intent.getIntExtra("health",BatteryManager.BATTERY_HEALTH_UNKNOWN);  ///获取电池健康度
        int bv = intent.getIntExtra("voltage", 0);  /// mv
        int temp = intent.getIntExtra("temperature", 0);  ///获取电池温度

        BatteryManager manager = (BatteryManager) getSystemService(BATTERY_SERVICE);
        // manager.getIntProperty(BatteryManager.BATTERY_PROPERTY_CHARGE_COUNTER);
        int bca = manager.getIntProperty(BatteryManager.BATTERY_PROPERTY_CURRENT_AVERAGE);
        int bc = manager.getIntProperty(BatteryManager.BATTERY_PROPERTY_CURRENT_NOW);
        level = manager.getIntProperty(BatteryManager.BATTERY_PROPERTY_CAPACITY);

        float bcaVal = (bca < 0) ? ((-bca)/1000000000) : (bca / 1000000000);

        sb.append("&BC=" + Float.toString(bcaVal));
        sb.append("&BV=" + Float.toString(((float)bv) / 1000));
        sb.append("&BP=" + level);
        sb.append("&BS=" + scale);
        sb.append("&CS=" + isCahrging);

        ConnectivityManager cm = (ConnectivityManager)getApplicationContext().getSystemService(Context.CONNECTIVITY_SERVICE);
        boolean isMetered = cm.isActiveNetworkMetered();

        sb.append("&NS=" + (isMetered ? "1" : "0"));

        final TelephonyManager telephonyManager = (TelephonyManager) getApplicationContext().getSystemService(Context.TELEPHONY_SERVICE);

        SignalStrength ss = telephonyManager.getSignalStrength();
        // List<CellSignalStrength> css = ss.getCellSignalStrengths();

        if (ss != null) {
            int signalLevel = ss.getLevel();
            sb.append("&Signal4G=" + signalLevel);
            sb.append("&Signal2G=" + signalLevel);
            sb.append("&SL=" + signalLevel);
        }

        // SysApi.getCpuRate();

        return sb.toString();
    }

    public boolean installApp(final String path, long delayedTime) {
        if (delayedTime < 0) {
            delayedTime = 0;
        }

        final Context context = getApplicationContext();
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                SysApi.installApk(context, path, context.getPackageName(), true);
            }
        };
        mHander.postDelayed(runnable, delayedTime);

        return true;
    }

    public void reboot(final int rebootType) {

        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                if (rebootType == 0) {
                    Context context = MicroPhotoService.this.getApplicationContext();
                    restartApp(context, context.getPackageName());

                } else {
                    Log.w(TAG, "Recv REBOOT command");
                    SysApi.reboot(MicroPhotoService.this.getApplicationContext());
                }
            }
        };
        mHander.postDelayed(runnable, 1000);
    }

    public static void restartApp(Context context, String packageName) {

        Intent intent = new Intent(context, MainActivity.class);
        int noDelay = 1;
        intent.putExtra("noDelay", noDelay);

        intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK | Intent.FLAG_ACTIVITY_CLEAR_TASK);
        context.startActivity(intent);
        System.exit(0);


        /*
        Intent intent = context.getPackageManager().getLaunchIntentForPackage(context.getPackageName());
        int noDelay = 1;
        intent.putExtra("noDelay", noDelay);
        PendingIntent restartIntent = PendingIntent.getActivity(context, 0, intent, 0);
        AlarmManager mgr = (AlarmManager)context.getSystemService(Context.ALARM_SERVICE);

        mgr.setExactAndAllowWhileIdle(AlarmManager.RTC_WAKEUP, System.currentTimeMillis() + 500, restartIntent);

        System.exit(0);

        */
    }
    public void enableGps(boolean enabled) {
        SysApi.enableGps(getApplicationContext(), enabled);
    }

    public void selectSimCard(int num) {
        SysApi.selectSimCard4Data(getApplicationContext(), num);
    }

    /*
    TelephonyManager telephonyManager = (TelephonyManager)this.getSystemService(Context.TELEPHONY_SERVICE);
// for example value of first element
CellInfoGsm cellInfoGsm = (CellInfoGsm)telephonyManager.getAllCellInfo().get(0);
CellSignalStrengthGsm cellSignalStrengthGsm = cellInfoGsm.getCellSignalStrength();
cellSignalStrengthGsm.getDbm();
     */

    protected native long init(String appPath, String ip, int port, String cmdid, int protocol, int networkProtocl, int encryptData, long netHandle, int signalLevel, int versionCode);
    protected native long getHeartbeatDuration(long handler);
    protected native long[] getPhotoTimeData(long handler, long startTime);
    protected native long[] getPhotoTimeData2(long handler);
    // protected native long[] getNextScheduleItem(long handler);
    protected native boolean notifyToTakePhoto(long handler, int channel, int preset, long scheduleTime, boolean photoOrVideo);
    protected native boolean sendHeartbeat(long handler, int signalLevel);
    protected native boolean reloadConfigs(long handler);
    protected native void updatePosition(long handler, double lon, double lat, double radius, long ts);
    protected native boolean uninit(long handler);
    protected native void recordingFinished(long handler, boolean result, String path, long videoId);
    public static native void setOtgState(boolean enabled);
    public static native void setCam3V3Enable(boolean enabled);
    public static native String getSerialNumber();
    public static native void importPublicKey(String path, String md5);

    ////////////////////////GPS////////////////////
    // private static final String GPS_LOCATION_NAME = android.location.LocationManager.GPS_PROVIDER;
    private LocationManager mLocationManager;
    private String mLocateType;

    private LocationListener mLocationListener = new LocationListener() {

        @Override
        public void onLocationChanged(Location location) {
            if (mNativeHandle != 0) {
                updatePosition(mNativeHandle, location.getLongitude(), location.getLatitude(), location.getAccuracy(), location.getTime() / 1000);

                mLocationManager.removeUpdates(this);
                // Close GPS
                enableGps(false);
            }
            Log.i(TAG, "Time:" + location.getTime() + " Lon=" + location.getLongitude() + "Lat=" + location.getLatitude() + "Alt=" + location.getAltitude());
        }

        @Override
        public void onStatusChanged(String provider, int status, Bundle extras) {
            switch (status) {
                case LocationProvider.AVAILABLE:
                    // Toast.makeText(MainActivity.this, "onStatusChanged：当前GPS状态为可见状态", Toast.LENGTH_SHORT).show();
                    break;
                case LocationProvider.OUT_OF_SERVICE:
                    // Toast.makeText(MainActivity.this, "onStatusChanged:当前GPS状态为服务区外状态", Toast.LENGTH_SHORT).show();
                    break;
                case LocationProvider.TEMPORARILY_UNAVAILABLE:
                    // Toast.makeText(MainActivity.this, "onStatusChanged:当前GPS状态为暂停服务状态", Toast.LENGTH_SHORT).show();
                    break;
            }
        }

        /**
         * @param provider
         */
        @Override
        public void onProviderEnabled(String provider) {
            // Toast.makeText(MainActivity.this, "onProviderEnabled:方法被触发", Toast.LENGTH_SHORT).show();
            requestPosition();
        }

        /**
         * @param provider
         */
        @Override
        public void onProviderDisabled(String provider) {

        }

        protected void writeLog(String log) {
            if (mMessenger != null) {
                Message msg = Message.obtain();
                msg.what = MSG_WHAT_LOG;
                msg.obj = log;
                try {
                    mMessenger.send(msg);
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }
        }
    };

    ////////////////////////GPS////////////////////

    private void setDefaultDataSubId(int subId) {
        SubscriptionManager subscriptionManager = (SubscriptionManager) getSystemService(Context.TELEPHONY_SUBSCRIPTION_SERVICE);
        try {
            Method method = subscriptionManager.getClass().getDeclaredMethod("setDefaultDataSubId", int.class);
            method.invoke(subscriptionManager, subId);
            TelephonyManager telephonyManager = (TelephonyManager) getSystemService(Context.TELEPHONY_SERVICE);
            Method method1 = telephonyManager.getClass().getDeclaredMethod("setDataEnabled", boolean.class);
            method1.invoke(telephonyManager, true);
        } catch (Exception e) {
            Log.e(TAG, "wjz debug setDefaultDataSubId: error is " + e.getMessage());
        }
    }
    private int getDefaultDataSubId() {
        SubscriptionManager subscriptionManager = (SubscriptionManager) getSystemService(Context.TELEPHONY_SUBSCRIPTION_SERVICE);
        try {
            Method method = subscriptionManager.getClass().getDeclaredMethod("getDefaultDataSubscriptionId");
            return (int) method.invoke(subscriptionManager);
        } catch (Exception e) {
            Log.e(TAG, "wjz debug getDefaultDataSubId: error is " + e.getMessage());
        }
        return 0;
    }
}