1.修改Socket接收和发送的数据结构

app/src/main/java/com/xhly/manageapp/broadcastreceiver/XhlyBroadCastReceiver.kt

@@ -9,7 +9,7 @@ import com.xhly.corelib.utils.AppUtils
 class XhlyBroadCastReceiver : BroadcastReceiver() {
     override fun onReceive(context: Context?, intent: Intent?) {
         Log.i("收到广播", "这是finish广播")
-        val getAppList1 = AppUtils.GetAppList1(context)
+        val getAppList1 = AppUtils.GetAppList(context)
         getAppList1?.forEach {
             if (it.packageName.equals("com.xhly.easystud")) {
                 it.intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK)

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

@@ -14,13 +14,17 @@ import com.xhly.corelib.bean.AppInfo
 import com.xhly.corelib.eventbus.UIEvent
 import com.xhly.corelib.network.RetrofitService
 import com.xhly.corelib.utils.AppUtils
+import com.xhly.corelib.utils.GsonUtils
 import com.xhly.corelib.utils.LogShow
+import com.xhly.corelib.utils.MD5Utils
 import com.xhly.corelib.utils.SharedPreferencesUtils
 import com.xhly.manageapp.ManageApplication
 import com.xhly.manageapp.bean.LogAppStartBean
 import com.xhly.manageapp.bean.LogdOperateBean
 import com.xhly.manageapp.network.LogService
+import com.xhly.websocket.bean.WebSocketData
 import com.xhly.websocket.service.LongConnService
+import com.xhly.websocket.service.WebSocketHelper
 import com.xhly.websocket.utils.SocketPushUtils.dealPushMessage
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.MainScope
@@ -29,6 +33,7 @@ import kotlinx.coroutines.launch
 import org.greenrobot.eventbus.EventBus
 import org.greenrobot.eventbus.Subscribe
 import org.greenrobot.eventbus.ThreadMode
+import java.util.UUID
 
 open class AppSocketService : LongConnService() {
     var CHANNEL_ID = "1"
@@ -64,6 +69,7 @@ open class AppSocketService : LongConnService() {
         appList = AppUtils.GetAppList(this) as ArrayList<AppInfo>
     }
 
+
     override fun processTextMessage(text: String) {
         //Log.v("websocket收到的消息", text);
         dealPushMessage(text)
@@ -72,6 +78,15 @@ open class AppSocketService : LongConnService() {
     override fun onConnectedSuccess() {
         super.onConnectedSuccess()
         UIEvent(Const.UPDATE_CONNECTED_SUCCESS).post()
+        val webData=WebSocketData()
+        webData.code=1002
+        webData.mid=UUID.randomUUID().toString()
+        val currentTimeSeconds = System.currentTimeMillis() / 1000
+        webData.timeunix=currentTimeSeconds
+        webData.fid=1
+        val jsMD5 = MD5Utils.getJsMD5(webData.code.toString()+"_"+webData.mid+"_"+webData.timeunix.toString())
+        webData.sign=MD5Utils.getJsMD5(jsMD5)
+        WebSocketHelper.getInstance().sendSocketString(GsonUtils.parseClassToJson(webData))
     }
 
     @Subscribe(threadMode = ThreadMode.MAIN)

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

@@ -52,9 +52,6 @@ class MainActivity : BaseActivity<CommonBaseViewModel, ActivityMainBinding>() {
         }
         val getAppList1 = AppUtils.GetAppList(this)
         dataList.addAll(getAppList1)
-        dataList.forEach {
-            LogShow("数据" + it.packageName + "|||")
-        }
         adapter = AppAdapter(this, dataList)
         mBinding.rv.layoutManager = GridLayoutManager(this, 6, GridLayoutManager.VERTICAL, false)
         mBinding.rv.adapter = adapter

websocket/src/main/java/com/xhly/websocket/bean/WebSocketData.kt

@@ -8,7 +8,7 @@ class WebSocketData() {
 
     //两次md5加密timeunix
     var sign: String? = null
-    var fid: String? = null
-    var tids: String? = null
-    var body: String? = null
+    var fid: Int = 0
+    var tids: IntArray = intArrayOf()
+    var body: Any? = null
 }

websocket/src/main/java/com/xhly/websocket/utils/SocketPushUtils.kt

@@ -9,9 +9,8 @@ object SocketPushUtils {
     fun dealPushMessage(content: String) {
         try {
             //没用泛型是因为如果带有泛型的类型，可能会遇到解析异常的问题。需要使用TypeToken
-          /*  var socketData = GsonUtils.parseJsonWithGson(content, WebSocketData::class.java)*/
+            var socketData = GsonUtils.parseJsonWithGson(content, WebSocketData::class.java)
             LogShow("数据$content")
-            var socketData=WebSocketData()
             socketData.code.let { code ->
                 when (code) {
                     1001 -> {