1.修改Error类包路径

app/build.gradle

@@ -58,6 +58,7 @@ dependencies {
     implementation 'com.blankj:utilcodex:1.31.1'
     implementation 'org.jetbrains.kotlin:kotlin-reflect:1.7.20'
     implementation 'com.geyifeng.immersionbar:immersionbar:3.2.2'
+    implementation 'androidx.work:work-runtime-ktx:2.7.1'
     testImplementation 'junit:junit:4.13.2'
     androidTestImplementation 'androidx.test.ext:junit:1.1.3'
     androidTestImplementation 'androidx.test.espresso:espresso-core:3.4.0'

app/src/main/java/com/waytous/anticollision/listener/SessionListener.kt

 package com.waytous.anticollision.listener
 
-import com.waytous.anticollision.tcp.Error
 import com.waytous.anticollision.utils.ConnectStatus
-
+import com.waytous.anticollision.utils.Error
 interface SessionListener {
 
     /**

app/src/main/java/com/waytous/anticollision/tcp/ConnectListener.kt

 package com.waytous.anticollision.tcp
 
 import io.netty.buffer.ByteBuf
+import com.waytous.anticollision.utils.Error
 
 interface ConnectListener {
 

app/src/main/java/com/waytous/anticollision/tcp/TcpExt.kt

-package com.waytous.anticollision.tcp
-
-/**
- * tcp通信错误定义
- * */
-enum class Error(val reason:String = "success") {
-    NOError,
-    IOError("io error"),
-    StreamClosed("stream closed"),
-    ConnectionRefused("connection refused"),
-    Timeout("time out"),
-    NotConnected("not connected"),
-    UserDisconnected("user disconnected"),
-    InvalidParam("invalid param"),
-    ServerUnknownError("server unknown error"),
-    JT808EncodeError("jt808 codec encode error"),
-    JT808DecodeError("jt808 codec decode error")
-}

app/src/main/java/com/waytous/anticollision/tcp/TcpManager.kt

@@ -3,6 +3,7 @@ package com.waytous.anticollision.tcp
 import com.blankj.utilcode.util.LogUtils
 import com.waytous.anticollision.BuildConfig
 import com.waytous.anticollision.utils.NamedThreadFactory
+import com.waytous.anticollision.utils.Error
 import io.netty.buffer.UnpooledByteBufAllocator
 import java.io.IOException
 import java.io.InputStream
@@ -27,11 +28,6 @@ const val BUFFER_SIZE = 8192
 const val DEFAULT_TIMEOUT = 32
 
 /**
- * 每次希望读取的数据长度
- * */
-const val READ_SIZE = 1024
-
-/**
  * 链接状态
  * @author male
  * */

app/src/main/java/com/waytous/anticollision/utils/Extensions.kt

@@ -13,3 +13,20 @@ enum class ConnectStatus {
 enum class SignInStatus {
     SignOut, SignIn
 }
+
+/**
+ * tcp通信错误定义
+ * */
+enum class Error(val reason:String = "success") {
+    NOError,
+    IOError("io error"),
+    StreamClosed("stream closed"),
+    ConnectionRefused("connection refused"),
+    Timeout("time out"),
+    NotConnected("not connected"),
+    UserDisconnected("user disconnected"),
+    InvalidParam("invalid param"),
+    ServerUnknownError("server unknown error"),
+    JT808EncodeError("jt808 codec encode error"),
+    JT808DecodeError("jt808 codec decode error")
+}
\ No newline at end of file

app/src/main/java/com/waytous/anticollision/wm/ConnectionWork.kt

+package com.waytous.anticollision.wm
+
+import android.content.Context
+import androidx.work.Worker
+import androidx.work.WorkerParameters
+
+class ConnectionWork(appContext: Context, workerParams: WorkerParameters): Worker(appContext,workerParams) {
+    override fun doWork(): Result {
+        return Result.retry()
+    }
+}
\ No newline at end of file