1.创建通信模块websocket

websocket/.gitignore

@@ -0,0 +1 @@
+/build

websocket/build.gradle.kts

@@ -0,0 +1,46 @@
+@Suppress("DSL_SCOPE_VIOLATION") // TODO: Remove once KTIJ-19369 is fixed
+plugins {
+    alias(libs.plugins.androidLibrary)
+    alias(libs.plugins.kotlinAndroid)
+}
+
+android {
+    namespace = "com.xhly.websocket"
+    compileSdk = 33
+
+    defaultConfig {
+        minSdk = 24
+
+        testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+        consumerProguardFiles("consumer-rules.pro")
+    }
+
+    buildTypes {
+        release {
+            isMinifyEnabled = false
+            proguardFiles(
+                getDefaultProguardFile("proguard-android-optimize.txt"),
+                "proguard-rules.pro"
+            )
+        }
+    }
+    compileOptions {
+        sourceCompatibility = JavaVersion.VERSION_1_8
+        targetCompatibility = JavaVersion.VERSION_1_8
+    }
+    kotlinOptions {
+        jvmTarget = "1.8"
+    }
+}
+
+dependencies {
+
+    implementation(libs.core.ktx)
+    implementation(libs.appcompat)
+    implementation(libs.material)
+    api(project(mapOf("path" to ":corelib")))
+    testImplementation(libs.junit)
+    androidTestImplementation(libs.androidx.test.ext.junit)
+    androidTestImplementation(libs.espresso.core)
+    api("com.neovisionaries:nv-websocket-client:2.2")
+}

websocket/src/androidTest/java/com/xhly/websocket/ExampleInstrumentedTest.kt

@@ -0,0 +1,24 @@
+package com.xhly.websocket
+
+import androidx.test.platform.app.InstrumentationRegistry
+import androidx.test.ext.junit.runners.AndroidJUnit4
+
+import org.junit.Test
+import org.junit.runner.RunWith
+
+import org.junit.Assert.*
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+@RunWith(AndroidJUnit4::class)
+class ExampleInstrumentedTest {
+    @Test
+    fun useAppContext() {
+        // Context of the app under test.
+        val appContext = InstrumentationRegistry.getInstrumentation().targetContext
+        assertEquals("com.xhly.websocket.test", appContext.packageName)
+    }
+}

websocket/src/main/AndroidManifest.xml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE_SPECIAL_USE" />
+
+
+    <application>
+        <service android:name="com.xhly.websocket.service.SocketService"
+            android:foregroundServiceType="dataSync"
+            />
+        <service android:name="com.xhly.websocket.service.ManageService"
+            android:foregroundServiceType="dataSync"
+            />
+    </application>
+</manifest>

websocket/src/main/java/com/xhly/websocket/bean/HertBean.java

@@ -0,0 +1,13 @@
+package com.xhly.websocket.bean;
+
+public class HertBean {
+    String type;
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+}

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

@@ -0,0 +1,6 @@
+package com.xhly.websocket.bean
+
+class SocketMsgData() {
+    var code = 0
+    var body: String? = null
+}

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

@@ -0,0 +1,14 @@
+package com.xhly.websocket.bean
+
+class WebSocketData() {
+    //发送信息时使用
+    var code = 0
+    var mid: String? = null
+    var timeunix: Long = 0
+
+    //两次md5加密timeunix
+    var sign: String? = null
+    var fid: String? = null
+    var tids: String? = null
+    var body: String? = null
+}

websocket/src/main/java/com/xhly/websocket/service/ManageService.kt

@@ -0,0 +1,27 @@
+package com.xhly.websocket.service
+
+import android.app.Service
+import android.content.Intent
+import android.os.IBinder
+import com.xhly.corelib.utils.LogShow
+import com.xhly.websocket.utils.WebSocketUtils
+
+class ManageService: Service() {
+    override fun onBind(intent: Intent?): IBinder? {
+       return null
+    }
+
+    override fun onCreate() {
+        super.onCreate()
+        LogShow("创建service")
+    }
+    override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
+        WebSocketUtils.openWebSocket(this)
+        LogShow("执行service")
+        return super.onStartCommand(intent, flags, startId)
+    }
+
+    override fun onDestroy() {
+        super.onDestroy()
+    }
+}

websocket/src/main/java/com/xhly/websocket/service/SocketService.kt

@@ -0,0 +1,112 @@
+package com.xhly.websocket.service
+
+import android.app.Notification
+import android.app.NotificationChannel
+import android.app.NotificationManager
+import android.app.Service
+import android.content.ComponentName
+import android.content.Intent
+import android.os.Build
+import android.widget.Toast
+import com.xhly.corelib.Const
+import com.xhly.corelib.eventbus.UIEvent
+import com.xhly.corelib.utils.LogShow
+import com.xhly.corelib.utils.SharedPreferencesUtils
+import com.xhly.websocket.utils.SocketPushUtils.dealPushMessage
+import org.greenrobot.eventbus.EventBus
+import org.greenrobot.eventbus.Subscribe
+import org.greenrobot.eventbus.ThreadMode
+
+open class SocketService : LongConnService() {
+    var CHANNEL_ID = "1"
+    var CHANNEL_NAME = "通知"
+  /*  private var csdkManager: CSDKManager? = null*/
+    val spUtils by lazy { SharedPreferencesUtils.getInstance(this) }
+    override fun onCreate() {
+        super.onCreate()
+        EventBus.getDefault().register(this)
+        connectUrl = "wss://api.stsotc.com/api/ws"
+     /*   csdkManager = CSDKManager(this)*/
+        /* startNotification()*/
+    }
+
+    override fun processTextMessage(text: String) {
+        //Log.v("websocket收到的消息", text);
+        dealPushMessage(text)
+    }
+
+    override fun onConnectedSuccess() {
+        super.onConnectedSuccess()
+        UIEvent(Const.UPDATE_CONNECTED_SUCCESS).post()
+    }
+
+    @Subscribe(threadMode = ThreadMode.MAIN)
+    fun onUiEvent(uiEvent: UIEvent) {
+       /* if (csdkManager == null) {
+            csdkManager = CSDKManager(this)
+        }*/
+        when (uiEvent.event) {
+            Const.CODE2001.toString() -> {
+                Toast.makeText(this, "这就是新消息", Toast.LENGTH_LONG).show()
+            }
+
+            Const.CODE2002.toString() -> {
+                Toast.makeText(this, "限制使用", Toast.LENGTH_LONG).show()
+                spUtils.setParam(Const.DISABLEAPP, true)
+                goMainActivity()
+            }
+
+            Const.CODE2005.toString() -> {
+                //csdkManager?.rebootDevice()
+            }
+
+            Const.CODE2006.toString() -> {
+                //csdkManager?.launchFactoryReset()
+            }
+
+            "10086" -> {
+                Toast.makeText(this, "违规操作，安装未知应用", Toast.LENGTH_LONG).show()
+                goMainActivity()
+            }
+        }
+    }
+
+    private fun goMainActivity() {
+        try {
+            // 为应用程序的启动Activity 准备Intent
+            val launchIntent = Intent()
+            launchIntent.setComponent(
+                ComponentName(
+                    "com.xhly.manageapp",
+                    "com.xhly.manageapp.ui.MainActivity"
+                )
+            )
+            launchIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK)
+            startActivity(launchIntent)
+        } catch (e: Exception) {
+            LogShow("跳转失败$e")
+        }
+    }
+
+    override fun onDestroy() {
+        super.onDestroy()
+        EventBus.getDefault().unregister(this)
+        stopForeground(Service.STOP_FOREGROUND_REMOVE)
+        /*  val intent=Intent(this,ManageService::class.java)
+          startService(intent)*/
+    }
+
+    private fun startNotification() {
+        var channel: NotificationChannel? = null
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+            channel =
+                NotificationChannel(CHANNEL_ID, CHANNEL_NAME, NotificationManager.IMPORTANCE_HIGH)
+            val manager = getSystemService(NOTIFICATION_SERVICE) as NotificationManager
+            manager.createNotificationChannel(channel)
+            val notification = Notification.Builder(
+                applicationContext, CHANNEL_ID
+            ).build()
+            startForeground(1, notification)
+        }
+    }
+}

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

@@ -0,0 +1,12 @@
+package com.xhly.websocket.service;
+
+public enum WsStatus {
+    //连接成功
+    CONNECT_SUCCESS,
+    //连接失败
+    CONNECT_FAIL,
+    // 断开连接
+    DISCONNECT,
+    //正在连接
+    CONNECTING
+}

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

@@ -0,0 +1,67 @@
+package com.xhly.websocket.utils
+
+import com.xhly.corelib.eventbus.UIEvent
+import com.xhly.corelib.utils.GsonUtils
+import com.xhly.corelib.utils.LogShow
+import com.xhly.websocket.bean.WebSocketData
+
+object SocketPushUtils {
+    fun dealPushMessage(content: String) {
+        try {
+            //没用泛型是因为如果带有泛型的类型，可能会遇到解析异常的问题。需要使用TypeToken
+            var socketData = GsonUtils.parseJsonWithGson(content, WebSocketData::class.java)
+            socketData.code.let { code ->
+                when (code) {
+                    1001 -> {
+                        //连接后回发 body{userid,username,usertype(1管理员，2学生)}
+                    }
+
+                    1002 -> {
+                        //获取在线用户列表
+                    }
+
+                    1003 -> {
+                        //返回在线用户列表 body{userlist(userid,username)}
+                    }
+
+                    2001 -> {
+                        //发送消息 body{userid,username,msg}
+                        UIEvent("2001").post()
+                    }
+
+                    2002 -> {
+                        //限制使用
+                    }
+
+                    2003 -> {
+                        //解除限制
+
+                    }
+
+                    2004 -> {
+                        //更新策略
+                    }
+
+                    2005 -> {
+                        //重启设备
+                    }
+
+                    2006 -> {
+                        //恢复出厂
+                    }
+                    666->{
+                        //消息确认回发mid 消息id
+                    }
+                    999->{
+                        //错误消息 body msg(错误消息)
+                    }
+                    else -> {
+                        //Log.d("message解析", socketData .message!!)
+                    }
+                }
+            }
+        } catch (e: Exception) {
+            LogShow("解析问题$e")
+        }
+    }
+}

websocket/src/main/java/com/xhly/websocket/utils/WebSocketUtils.java

@@ -0,0 +1,26 @@
+package com.xhly.websocket.utils;
+
+import android.content.Context;
+import android.content.Intent;
+
+import com.neovisionaries.ws.client.WebSocket;
+import com.xhly.websocket.service.SocketService;
+import com.xhly.websocket.service.WebSocketHelper;
+
+
+public class WebSocketUtils {
+    //启动服务
+    public static void openWebSocket(Context context) {
+        context.startService(new Intent(context, SocketService.class));
+    }
+
+    public static void closeWebSocket(Context context) {
+        context.stopService(new Intent(context, SocketService.class));
+    }
+
+    //心跳消息
+    public static void hearBeat(WebSocket webSocket) {
+        WebSocketHelper.getInstance().hearBeat(webSocket);
+    }
+
+}

websocket/src/test/java/com/xhly/websocket/ExampleUnitTest.kt

@@ -0,0 +1,17 @@
+package com.xhly.websocket
+
+import org.junit.Test
+
+import org.junit.Assert.*
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+class ExampleUnitTest {
+    @Test
+    fun addition_isCorrect() {
+        assertEquals(4, 2 + 2)
+    }
+}