harmony_car/harmony_vehicle_terminal
4
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases 24 Wiki Activity

fix: 修复轨迹

Browse Source
This commit is contained in:
wangzhongjie 2025-08-19 16:54:10 +08:00
parent 1016b32873
commit 0077cdc077
3 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
entry/src/main/ets/utils/UdpUtils.ets
View File

@ -1,6 +1,7 @@
import socket from '@ohos.net.socket' import socket from '@ohos.net.socket'
import { UDPTag } from '../config' import { UDPTag } from '../config'
import { FillZero, StringToASCII } from './Common' import { FillZero, StringToASCII } from './Common'
import { BusinessError } from '@ohos.base'
interface MsgExt { interface MsgExt {
id: number, id: number,
@ -81,7 +82,9 @@ export default class UdpClient {
address: this.oppositeIp, port: parseInt(this.oppositeIpPort), family: 1 address: this.oppositeIp, port: parseInt(this.oppositeIpPort), family: 1
} }
}).then(res => { }).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() { private bindEvent() {
this.udp?.on("message", value => { this.udp?.on("message", value => {
let result = this.dealMethod?.(value.message) let result = this.dealMethod?.(value.message)
// console.log(UDPTag, "中心返回消息", result) console.log(UDPTag, "udp获取消息", result)
this.messageEvents.forEach(cb => { this.messageEvents.forEach(cb => {
cb(result) cb(result)
}) })

7
entry/src/main/ets/utils/business/DifferentialSignal.ets
View File

@ -12,6 +12,10 @@ class differentialSignal {
init(config: EnvironmentConfigurationType) { init(config: EnvironmentConfigurationType) {
this.differentialSignalTcp = new TcpClient(); this.differentialSignalTcp = new TcpClient();
this.differentialSignalTcp.onError(() => {
console.error(TCPTag, "TCP发生错误")
this.differentialSignalTcp.reBind()
})
// let config: EnvironmentConfigurationType = // let config: EnvironmentConfigurationType =
// AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration") || { // AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration") || {
// tcplocalIp: "", // tcplocalIp: "",
@ -33,6 +37,7 @@ class differentialSignal {
// 组装消息,一秒发送五次 // 组装消息,一秒发送五次
let data = "1"; let data = "1";
this.timer = setInterval(() => { this.timer = setInterval(() => {
console.log(TCPTag, "发送给中心消息")
this.differentialSignalTcp.sendMsg(data); this.differentialSignalTcp.sendMsg(data);
}, 200); }, 200);
@ -41,7 +46,7 @@ class differentialSignal {
// 获取消息 // 获取消息
getData(callback: (data: ArrayBuffer) => void) { getData(callback: (data: ArrayBuffer) => void) {
this.differentialSignalTcp.onMsg((data: ArrayBuffer) => { this.differentialSignalTcp.onMsg((data: ArrayBuffer) => {
// console.log(TCPTag, "获取", data); console.log(TCPTag, "获取TCP消息", data);
callback(data); callback(data);
}); });
} }

2
entry/src/main/ets/workers/DifferentialCorrection.ets
View File

@ -59,7 +59,7 @@ function initFn(result: WorkerMessage) {
function getDataFn(config: EnvironmentConfigurationType) { function getDataFn(config: EnvironmentConfigurationType) {
// 获取TCP差分改正数信号 // 获取TCP差分改正数信号
DifferentialSignal.getData((data: ArrayBuffer) => { DifferentialSignal.getData((data: ArrayBuffer) => {
// console.log(WorkerTag, "Received differential signal data:", data.byteLength, "bytes") console.log(WorkerTag, "获取中心差分改正消息:", data.byteLength, "bytes")
// TCP拿到差分改正数发给后置机 // TCP拿到差分改正数发给后置机
ObtainUdpBusinessInstance.sendData(data) ObtainUdpBusinessInstance.sendData(data)
}) })