1.在定时任务中定时调用socket，以便在销毁后重启

app/src/main/java/com/xhly/manageapp/ManageApplication.kt

@@ -500,7 +500,7 @@ class ManageApplication : MultiDexApplication() {
         super.onCreate()
         instance = this
         Toaster.init(this)
-        apppSocket = AppSocket()
+        apppSocket = AppSocket
         apppSocket?.startSocket(this)
         if (ModelNameUtils.IS_LianxX505f()) {
             //是505f则执行

app/src/main/java/com/xhly/manageapp/service/websocket/AppSocket.kt

@@ -37,23 +37,11 @@ import org.greenrobot.eventbus.ThreadMode
 import java.io.File
 import java.util.UUID
 
-class AppSocket : SocketClient() {
-    var logService = RetrofitService.create<LogService>()
-    private val serviceScope = CoroutineScope(MainScope().coroutineContext)
-
-
-    val spUtils by lazy { SharedPreferencesUtils.getInstance(context) }
-
-    companion object {
-        //标记上次打开的包名，当连续打开同一包名时，不认为打开多次
-        var lastPkgName = ""
-    }
+object AppSocket : SocketClient() {
 
     override fun startSocket(context: Context?) {
         connectUrl = Const.WSURL
-        /* startNotification()*/
         LogShow("已经创建")
-        //downLoadFile("")
         super.startSocket(context)
     }
 
@@ -86,12 +74,6 @@ class AppSocket : SocketClient() {
 
     override fun onDestroy() {
         super.onDestroy()
-        serviceScope.cancel()
-        /* stopForeground(Service.STOP_FOREGROUND_REMOVE)*/
-        val intent = Intent()
-        intent.setPackage("com.xhly.manageapp")
-        intent.setAction("test")
-        context.sendBroadcast(intent)
-        LogShow("Service被销毁")
+        LogShow("Socket被销毁")
     }
 }

app/src/main/java/com/xhly/manageapp/ui/main/activity/MainActivity.kt

@@ -578,12 +578,12 @@ class MainActivity : BaseActivity<MainViewModel, ActivityMainBinding>() {
 
             Const.LOGAPPSTART -> {
                 val message = uiEvent.message
-                if (AppSocket.lastPkgName == message) {
+                if (Const.LASTPKGNAME == message) {
                     return
                 }
                 val filter = dataList.filter { it.packageName == message }
                 if (filter.isNotEmpty()) {
-                    AppSocket.lastPkgName = message
+                    Const.LASTPKGNAME = message
                     val data = LogdOperateBean()
                     ManageApplication.getDeviceInfo()?.let {
                         data.sn = it

app/src/main/java/com/xhly/manageapp/workmanager/TimingWorker.kt

@@ -18,6 +18,7 @@ import com.xhly.manageapp.bean.log.LogAppStartBean
 import com.xhly.manageapp.bean.log.PadLocationBean
 import com.xhly.manageapp.bean.user.UserBean
 import com.xhly.manageapp.network.log.LogService
+import com.xhly.manageapp.service.websocket.AppSocket
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.MainScope
 import kotlinx.coroutines.cancel
@@ -74,6 +75,10 @@ class TimingWorker(context: Context, workerParams: WorkerParameters) :
             }catch (e:Exception){
                 LogShow("没有位置问题"+e.toString())
             }
+            //创建socket
+            ManageApplication.instance?.let {
+                AppSocket.startSocket(it)
+            }
         }
         return result
     }

corelib/src/main/java/com/xhly/corelib/Const.kt

@@ -16,6 +16,9 @@ object Const {
     //班级id
     var CLASSID = 0L
 
+    //标记上次打开的包名，当连续打开同一包名时，不认为打开多次
+    var LASTPKGNAME = ""
+
     //接口地址
     const val URL1: String = "https://mcapitest.xhkjedu.com/"
 

websocket/src/main/java/com/xhly/websocket/service/SocketClient.java

@@ -154,10 +154,7 @@ public abstract class SocketClient {
      * 连接长链接
      */
     private synchronized void startConnect() {
-        if (TextUtils.isEmpty("用户ID")) {
-            setStatus(WsStatus.DISCONNECT);
-            return;
-        }
+
         if (!NetworkUtils.isAvailable(context)) {
             Toast.makeText(context, "网络不可用", Toast.LENGTH_SHORT);
             return;