From 0077cdc077b5acb4a3095457449ba9f3a9e12b4d Mon Sep 17 00:00:00 2001
From: wangzhongjie <uvdream@163.com>
Date: Tue, 19 Aug 2025 16:54:10 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E8=BD=A8=E8=BF=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 entry/src/main/ets/utils/UdpUtils.ets                    | 7 +++++--
 entry/src/main/ets/utils/business/DifferentialSignal.ets | 7 ++++++-
 entry/src/main/ets/workers/DifferentialCorrection.ets    | 2 +-
 3 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/entry/src/main/ets/utils/UdpUtils.ets b/entry/src/main/ets/utils/UdpUtils.ets
index 3c39f63..e06b934 100644
--- a/entry/src/main/ets/utils/UdpUtils.ets
+++ b/entry/src/main/ets/utils/UdpUtils.ets
@@ -1,6 +1,7 @@
 import socket from '@ohos.net.socket'
 import { UDPTag } from '../config'
 import { FillZero, StringToASCII } from './Common'
+import { BusinessError } from '@ohos.base'
 
 interface MsgExt {
   id: number,
@@ -81,7 +82,9 @@ export default class UdpClient {
         address: this.oppositeIp, port: parseInt(this.oppositeIpPort), family: 1
       }
     }).then(res => {
-      // console.log(UDPTag, "udp发送成功", JSON.stringify(res))
+      console.log(UDPTag, "udp发送成功", JSON.stringify(res))
+    }).catch((e: BusinessError) => {
+      console.error(UDPTag, "udp发送失败", JSON.stringify(e))
     })
   }
 
@@ -141,7 +144,7 @@ export default class UdpClient {
   private bindEvent() {
     this.udp?.on("message", value => {
       let result = this.dealMethod?.(value.message)
-      // console.log(UDPTag, "中心返回消息", result)
+      console.log(UDPTag, "udp获取消息", result)
       this.messageEvents.forEach(cb => {
         cb(result)
       })
diff --git a/entry/src/main/ets/utils/business/DifferentialSignal.ets b/entry/src/main/ets/utils/business/DifferentialSignal.ets
index 2aa99ca..a7a9987 100644
--- a/entry/src/main/ets/utils/business/DifferentialSignal.ets
+++ b/entry/src/main/ets/utils/business/DifferentialSignal.ets
@@ -12,6 +12,10 @@ class differentialSignal {
 
   init(config: EnvironmentConfigurationType) {
     this.differentialSignalTcp = new TcpClient();
+    this.differentialSignalTcp.onError(() => {
+      console.error(TCPTag, "TCP发生错误")
+      this.differentialSignalTcp.reBind()
+    })
     // let config: EnvironmentConfigurationType =
     //   AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration") || {
     //     tcplocalIp: "",
@@ -33,6 +37,7 @@ class differentialSignal {
     // 组装消息,一秒发送五次
     let data = "1";
     this.timer = setInterval(() => {
+      console.log(TCPTag, "发送给中心消息")
       this.differentialSignalTcp.sendMsg(data);
     }, 200);
 
@@ -41,7 +46,7 @@ class differentialSignal {
   //   获取消息
   getData(callback: (data: ArrayBuffer) => void) {
     this.differentialSignalTcp.onMsg((data: ArrayBuffer) => {
-      // console.log(TCPTag, "获取", data);
+      console.log(TCPTag, "获取TCP消息", data);
       callback(data);
     });
   }
diff --git a/entry/src/main/ets/workers/DifferentialCorrection.ets b/entry/src/main/ets/workers/DifferentialCorrection.ets
index 34ca52f..7f95cd6 100644
--- a/entry/src/main/ets/workers/DifferentialCorrection.ets
+++ b/entry/src/main/ets/workers/DifferentialCorrection.ets
@@ -59,7 +59,7 @@ function initFn(result: WorkerMessage) {
 function getDataFn(config: EnvironmentConfigurationType) {
   // 获取TCP差分改正数信号
   DifferentialSignal.getData((data: ArrayBuffer) => {
-    // console.log(WorkerTag, "Received differential signal data:", data.byteLength, "bytes")
+    console.log(WorkerTag, "获取中心差分改正消息:", data.byteLength, "bytes")
     // TCP拿到差分改正数发给后置机
     ObtainUdpBusinessInstance.sendData(data)
   })