udp优化

entry/src/main/ets/pages/CarCheck.ets

@@ -8,7 +8,7 @@ import { CarCheckDataType, CarConfigurationParams, CarInfoType, SpzdType } from
 import { BusinessError } from '@ohos.base';
 import { voiceService } from '../utils/Voice';
 import dayTs from '../utils/Date';
-import { ObtainSignalData } from '../utils/business/ObtainSignalData';
+import { ObtainUdpBusinessInstance } from '../utils/business/ObtainUdpBusiness';
 
 @Entry
 @Component
@@ -180,7 +180,7 @@ struct Index {
 
   getPLCInfo() {
     const that = this
-    ObtainSignalData.getData((msg) => {
+    ObtainUdpBusinessInstance.onMsg((msg) => {
       if (!this.breakFlag) {
         return
       }

entry/src/main/ets/pages/Index.ets

@@ -20,8 +20,8 @@ import { BusinessError } from '@ohos.base';
 import { delPic } from '../utils/Video';
 import { FileHelper } from '../utils/FileHelp';
 import { GetCurrentTime } from '../utils/Common';
-import { ObtainSignalData } from '../utils/business/ObtainSignalData';
+import { ObtainUdpBusinessInstance } from '../utils/business/ObtainUdpBusiness';
-import { CentralHeartbeat } from '../utils/business/CentralHeartbeat';
+import { CenterUDPClientInstance } from '../utils/business/CenterUdpBusiness';
 import { DrivingDataStorage } from '../utils/business/DrivingDataStorage';
 import { initJudgeUdp } from '../utils/business/UdpJudge';
 import { centerUDPClient, judgeUDPClient, lightUDPClient, objUDPClient } from '../utils/UdpUtils';
@@ -64,6 +64,181 @@ struct Index {
   private timeInfo: TimeSynchronizationRspBody
   private context = getContext(this) as common.UIAbilityContext;
 
+  async aboutToAppear() {
+    this.avPlayer = new VoiceAnnounce();
+    this.ratio = AppStorage.get<number>('ratio')
+    this.initParamFlag = false
+    this.delLoading = false
+    this.dialogVisiable = false
+    this.angle = 0
+    this.loading = false
+    AppStorage.set('lsh', '1111111111111')
+    // TODO 未改
+    // globalThis.errorDialog = this.errorDialog
+    // globalThis.udpEvent = new UdpEvent();
+    GetSyncData<MASYSSETTableType>("MA_SYSSET").then((res: MASYSSETTableType[]) => {
+      res.forEach((element) => {
+        if (element.v_no === "305") {
+          delPic(Number(element.v_value), 1, this.context)
+          delPic(Number(element.v_value), 2, this.context)
+        }
+      });
+    });
+    this.singlePlay = AppStorage.get<boolean>('singlePlay')
+    this.baseInfo = AppStorage.get<BaseInfoType>('baseInfo')
+
+    UseAuth(this.context).then(() => {
+      this.initParams()
+    }).catch(() => {
+    });
+
+    if (this.singlePlay == undefined || this.singlePlay == null) {
+      this.context.resourceManager.getRawFileContent("welcome.wav")
+        .then(() => {
+          this.avPlayer.playAudio(['welcome.wav'])
+
+          // this.vocObj.playAudio({
+          //   type: 1,
+          //   name: 'welcome.wav'
+          // })
+          // let rawFile = value;
+        })
+        .catch((error: BusinessError) => {
+          console.log("getRawFileContent promise error is " + error);
+        });
+
+      this.singlePlay = false
+      AppStorage.setOrCreate('singlePlay', false)
+    }
+    this.num = 0
+    AppStorage.setOrCreate('lsh', '1111111111111')
+  }
+
+  async testXMLToJSONInWorker() {
+    if (this.loading) {
+      return
+    }
+    // let mode=globalThis.timeInfo?.mode?globalThis.timeInfo?.mode:1
+
+    // console.log('mode',mode)
+
+    const param: InitializeTheCentralTableType = {
+      carId: this.carInfo?.carId,
+      examinationRoomId: this.carInfo?.examinationRoomId,
+      judgeVersion: this.baseInfo.judgeVersion,
+      shellVersion: this.baseInfo.version,
+      paraKdid: this.timeInfo?.paraKdid || this.timeInfo?.kdid,
+      kdid: this.timeInfo?.kdid || this.timeInfo?.paraKdid,
+      mode: this.timeInfo?.mode,
+      context: this.context,
+      host: AppStorage.get<string>('host'),
+      centerHost: this.timeInfo?.url,
+      singlePlay: this.singlePlay
+    }
+    this.loading = true
+
+    // getSingleCenterTable(param).then((ret) => {
+    InitializeTheCentralTable(param).then((ret) => {
+      if (ret) {
+        GetSyncData<MASYSSETTableType>("MA_SYSSET").then(data => {
+          data.forEach(sys => {
+            //判断是否能点开始考试
+            if (sys.v_no === '854') {
+              AppStorage.setOrCreate('param854Str', sys.v_value)
+            }
+            if (sys.v_no === '824' && decodeURIComponent(sys.v_value) == '0') {
+              router.pushUrl({
+                url: 'pages/CarCheck',
+                params: {
+                  'fromIndex': true
+                }
+              }, router.RouterMode.Single)
+            } else {
+              router.pushUrl({
+                url: 'pages/ExaminerLogin',
+              }, router.RouterMode.Single)
+            }
+          })
+        });
+
+      }
+    })
+
+  }
+
+  async heartMsg() {
+    // const signNum = AppStorage.get<number>('signNum')
+    // const statue = AppStorage.get<string>('statue')
+    // const lsh = AppStorage.get<string>('lsh')
+    // const arr = [signNum || 0, statue || 1]
+    // let tmpList: number[] = [];
+    // tmpList.push(NumberToByteArray(Number(arr[0]), 1 * 8)[0])
+    // tmpList.push(NumberToByteArray(Number(arr[1]), 1 * 8)[0])
+    // const str = lsh || '0000000000000'
+    // for (let i = 0; i < str.length; i++) {
+    //   tmpList.push(NumberToByteArray(str.charCodeAt(i), 1 * 8)[0])
+    // }
+    // TODO 未改
+    // const param = {
+    //   id: 31,
+    //   list: tmpList,
+    //   carNo: this.carInfo.carNo,
+    //   placeId: this.carInfo.examinationRoomId
+    // }
+    // globalThis.udpClient2.initHeartSendMsg(param,this.context)
+    // if (globalThis.udpClient2.getStatus()) {
+    //   globalThis.udpClient2.sendMsgExt(param, this.context)
+    // }
+  }
+
+  async createAlbum() {
+    this.fileHelper = new FileHelper();
+    const time = GetCurrentTime()
+    const date = time.split(' ')[0]
+    this.fileHelper.createAlbum('jt')
+    // this.fileHelper.createAlbum('2025-01-02')
+    this.fileHelper.createAlbum('pz');
+    this.fileHelper.createAlbum(date);
+  }
+
+  async initParams() {
+    //设置plc udp 同步requesthost
+
+    ObtainUdpBusinessInstance.init();
+    CenterUDPClientInstance.init();
+    CenterUDPClientInstance.startHeartBeat()
+    CenterUDPClientInstance.onMsg((data: centerCallBackMsgType) => {
+      if (data.id == 32) {
+        AppStorage.setOrCreate('signNum', data.body[1])
+      }
+    },)
+    this.loading = false
+    await GetDeviceInfo(this.context)
+    await GetCarInfo()
+    // getTCP()
+    this.carInfo = AppStorage.get<CarInfoType>('carInfo')
+    this.deviceId = this.carInfo.carNo
+    await SetCurrentTime()
+    this.timeInfo = AppStorage.get<TimeSynchronizationRspBody>('timeInfo')
+    DrivingDataStorage.init(this.context)
+    DrivingDataStorage.initializeTheDrivingDataFolder()
+    setTimeout(() => {
+      this.initParamFlag = true
+    }, 3000)
+    initJudgeUdp()
+    // TODO 摄像头遮挡
+    // takePhotoFn(this.context)
+    clearInterval(this.interval)
+    this.interval = setInterval(() => {
+      this.num++
+      SetSerialNumber()
+      if (this.num >= 3) {
+        this.heartMsg()
+      }
+    }, 1000)
+    this.createAlbum()
+  }
+
   @Styles
   commStyle(){
     .width(220 * this.ratio * this.dialogRatio)
@@ -355,188 +530,4 @@ struct Index {
     .backgroundImage($r('app.media.index_bg'))
     .backgroundImageSize({ width: '100%', height: '100%' })
   }
-
-  async aboutToAppear() {
-    this.avPlayer = new VoiceAnnounce();
-    this.ratio = AppStorage.get<number>('ratio')
-    this.initParamFlag = false
-    this.delLoading = false
-    this.dialogVisiable = false
-    this.angle = 0
-    this.loading = false
-    AppStorage.set('lsh', '1111111111111')
-    // TODO 未改
-    // globalThis.errorDialog = this.errorDialog
-    // globalThis.udpEvent = new UdpEvent();
-    GetSyncData<MASYSSETTableType>("MA_SYSSET").then((res: MASYSSETTableType[]) => {
-      res.forEach((element) => {
-        if (element.v_no === "305") {
-          delPic(Number(element.v_value), 1, this.context)
-          delPic(Number(element.v_value), 2, this.context)
-        }
-      });
-    });
-
-  }
-
-  async testXMLToJSONInWorker() {
-    if (this.loading) {
-      return
-    }
-    // let mode=globalThis.timeInfo?.mode?globalThis.timeInfo?.mode:1
-
-    // console.log('mode',mode)
-
-    const param: InitializeTheCentralTableType = {
-      carId: this.carInfo?.carId,
-      examinationRoomId: this.carInfo?.examinationRoomId,
-      judgeVersion: this.baseInfo.judgeVersion,
-      shellVersion: this.baseInfo.version,
-      paraKdid: this.timeInfo?.paraKdid || this.timeInfo?.kdid,
-      kdid: this.timeInfo?.kdid || this.timeInfo?.paraKdid,
-      mode: this.timeInfo?.mode,
-      context: this.context,
-      host: AppStorage.get<string>('host'),
-      centerHost: this.timeInfo?.url,
-      singlePlay: this.singlePlay
-    }
-    this.loading = true
-
-    // getSingleCenterTable(param).then((ret) => {
-    InitializeTheCentralTable(param).then((ret) => {
-      if (ret) {
-        GetSyncData<MASYSSETTableType>("MA_SYSSET").then(data => {
-          data.forEach(sys => {
-            //判断是否能点开始考试
-            if (sys.v_no === '854') {
-              AppStorage.setOrCreate('param854Str', sys.v_value)
-            }
-            if (sys.v_no === '824' && decodeURIComponent(sys.v_value) == '0') {
-              router.pushUrl({
-                url: 'pages/CarCheck',
-                params: {
-                  'fromIndex': true
-                }
-              }, router.RouterMode.Single)
-            } else {
-              router.pushUrl({
-                url: 'pages/ExaminerLogin',
-              }, router.RouterMode.Single)
-            }
-          })
-        });
-
-      }
-    })
-
-  }
-
-  async heartMsg() {
-    // const signNum = AppStorage.get<number>('signNum')
-    // const statue = AppStorage.get<string>('statue')
-    // const lsh = AppStorage.get<string>('lsh')
-    // const arr = [signNum || 0, statue || 1]
-    // let tmpList: number[] = [];
-    // tmpList.push(NumberToByteArray(Number(arr[0]), 1 * 8)[0])
-    // tmpList.push(NumberToByteArray(Number(arr[1]), 1 * 8)[0])
-    // const str = lsh || '0000000000000'
-    // for (let i = 0; i < str.length; i++) {
-    //   tmpList.push(NumberToByteArray(str.charCodeAt(i), 1 * 8)[0])
-    // }
-    // TODO 未改
-    // const param = {
-    //   id: 31,
-    //   list: tmpList,
-    //   carNo: this.carInfo.carNo,
-    //   placeId: this.carInfo.examinationRoomId
-    // }
-    // globalThis.udpClient2.initHeartSendMsg(param,this.context)
-    // if (globalThis.udpClient2.getStatus()) {
-    //   globalThis.udpClient2.sendMsgExt(param, this.context)
-    // }
-  }
-
-  async onPageShow() {
-    this.singlePlay = AppStorage.get<boolean>('singlePlay')
-    this.baseInfo = AppStorage.get<BaseInfoType>('baseInfo')
-    // await this.userAuth();
-    UseAuth(this.context).then(() => {
-      this.initParams()
-    }).catch(() => {
-    });
-    if (this.singlePlay == undefined || this.singlePlay == null) {
-      // setVideoParam()
-      this.context.resourceManager.getRawFileContent("welcome.wav")
-        .then(() => {
-          this.avPlayer.playAudio(['welcome.wav'])
-
-          // this.vocObj.playAudio({
-          //   type: 1,
-          //   name: 'welcome.wav'
-          // })
-          // let rawFile = value;
-        })
-        .catch((error: BusinessError) => {
-          console.log("getRawFileContent promise error is " + error);
-        });
-
-      this.singlePlay = false
-      AppStorage.setOrCreate('singlePlay', false)
-    }
-    // this.loading = false
-    this.num = 0
-    AppStorage.setOrCreate('lsh', '1111111111111')
-  }
-
-  async createAlbum() {
-    this.fileHelper = new FileHelper();
-    const time = GetCurrentTime()
-    const date = time.split(' ')[0]
-    this.fileHelper.createAlbum('jt')
-    // this.fileHelper.createAlbum('2025-01-02')
-    this.fileHelper.createAlbum('pz');
-    this.fileHelper.createAlbum(date);
-  }
-
-  async initParams() {
-    //设置plc udp 同步requesthost
-    objUDPClient.init()
-    centerUDPClient.init()
-    lightUDPClient.init()
-    judgeUDPClient.init()
-
-    ObtainSignalData.init();
-    CentralHeartbeat.init();
-    CentralHeartbeat.sendHeartData()
-    CentralHeartbeat.getData((data: centerCallBackMsgType) => {
-      if (data.id == 32) {
-        AppStorage.setOrCreate('signNum', data.body[1])
-      }
-    },)
-    this.loading = false
-    await GetDeviceInfo(this.context)
-    await GetCarInfo()
-    // getTCP()
-    this.carInfo = AppStorage.get<CarInfoType>('carInfo')
-    this.deviceId = this.carInfo.carNo
-    await SetCurrentTime()
-    this.timeInfo = AppStorage.get<TimeSynchronizationRspBody>('timeInfo')
-    DrivingDataStorage.init(this.context)
-    DrivingDataStorage.initializeTheDrivingDataFolder()
-    setTimeout(() => {
-      this.initParamFlag = true
-    }, 3000)
-    initJudgeUdp()
-    // TODO 摄像头遮挡
-    // takePhotoFn(this.context)
-    clearInterval(this.interval)
-    this.interval = setInterval(() => {
-      this.num++
-      SetSerialNumber()
-      if (this.num >= 3) {
-        this.heartMsg()
-      }
-    }, 1000)
-    this.createAlbum()
-  }
 }

entry/src/main/ets/pages/UserInfo.ets

@@ -43,7 +43,7 @@ import { GetCurrentUserKeyValue } from './UserInfo/utils';
 import dayTs from '../utils/Date';
 import { GetCurrentTime, NumberToByteArray } from '../utils/Common';
 import DB from '../utils/DbSql';
-import { CentralHeartbeat } from '../utils/business/CentralHeartbeat';
+import { CenterUDPClientInstance } from '../utils/business/CenterUdpBusiness';
 
 @Entry
 @Component
@@ -208,6 +208,20 @@ struct UserInfo {
     { label: '考试员名', key: 'ksy2' },
   ]
 
+  private onCenterMsg = (val: centerCallBackMsgType) => {
+    if (val.id == 32) {
+      AppStorage.setOrCreate('signNum', val.body[1])
+      if (val.body[0] == 7) {
+        //缺考处理
+        this.getqkFn()
+        this.signNum = val.body[1]
+      }
+    } else if (val.id == 42) {
+      //收到中心缺考确认消息
+      this.qkFn()
+    }
+  }
+
   aboutToAppear() {
     this.avPlayer = new VoiceAnnounce();
   }
@@ -306,6 +320,10 @@ struct UserInfo {
 
   }
 
+  async onPageHide(): Promise<void> {
+    CenterUDPClientInstance.offMsg(this.onCenterMsg)
+  }
+
   //身份证读卡器初始化
   openDeviceByIDCard() {
     AppStorage.setOrCreate('indexComponent', this)
@@ -464,19 +482,7 @@ struct UserInfo {
   }
 
   async heartMsg() {
-    CentralHeartbeat.getData((val: centerCallBackMsgType) => {
+    CenterUDPClientInstance.onMsg(this.onCenterMsg)
-      if (val.id == 32) {
-        AppStorage.setOrCreate('signNum', val.body[1])
-        if (val.body[0] == 7) {
-          //缺考处理
-          this.getqkFn()
-          this.signNum = val.body[1]
-        }
-      } else if (val.id == 42) {
-        //收到中心缺考确认消息
-        this.qkFn()
-      }
-    },)
   }
 
   //考点端查询缺考指令内容消息请求
@@ -490,7 +496,7 @@ struct UserInfo {
       placeId: this.carInfo.examinationRoomId as string
     }
     // globalThis.udpClient2.sendMsgExt(param, this.context)
-    CentralHeartbeat.sendData(param)
+    CenterUDPClientInstance.sendData(param)
   }
 
   async initSysset() {
@@ -814,7 +820,7 @@ struct UserInfo {
         carNo: this.carInfo.carNo,
         placeId: this.carInfo.examinationRoomId
       }
-      CentralHeartbeat.sendData(param)
+      CenterUDPClientInstance.sendData(param)
       // globalThis.udpClient2.sendMsgExt(param, this.context)
       if (res.examinationStuAbsentRsp.head.resultCode == '0') {
         this.pageIndex = 0

entry/src/main/ets/pages/compontents/FaceCompare.ets

@@ -9,7 +9,7 @@ import { VideoConfigData } from '../../mock';
 import { CarInfoType, UDPParamType, VideoConfig } from '../../model';
 import { NumberToByteArray } from '../../utils/Common';
 import FileUtils from '../../utils/FileUtils';
-import { CentralHeartbeat } from '../../utils/business/CentralHeartbeat';
+import { CenterUDPClientInstance } from '../../utils/business/CenterUdpBusiness';
 
 interface ParamType {
   id?: number;
@@ -242,7 +242,7 @@ export default struct FaceCompare {
         this.callBackFlag = true
       }
     }
-    CentralHeartbeat.sendData(param)
+    CenterUDPClientInstance.sendData(param)
     // UDP缺失
     // globalThis.udpClient2 && globalThis.udpClient2.sendMsgExt(param, this.context)
     clearInterval(this.interval)
@@ -254,10 +254,10 @@ export default struct FaceCompare {
           carNo: this.carInfo.carNo,
           placeId: this.carInfo.examinationRoomId,
         }
-        CentralHeartbeat.sendData(param2)
+        CenterUDPClientInstance.sendData(param2)
       }
     }, 1000)
-    CentralHeartbeat.getData((val)=>{
+    CenterUDPClientInstance.getData((val)=>{
         if (AppStorage.get('statue') != 3) {
           return
         }

entry/src/main/ets/utils/UdpUtils.ets

@@ -5,8 +5,6 @@ import { UDPTag } from '../config'
 import { BusinessError } from '@ohos.base'
 import { FillZero, StringToBytes, StringToASCII } from './Common'
 
-type DealMethod = (value: ArrayBuffer) => string
-
 interface MsgExt {
   id: number,
   list: number[],
@@ -30,15 +28,18 @@ function exclusive(target: number[]): number[] {
   return [result];
 }
 
+type DealMethod<T extends Object> = (value: ArrayBuffer) => T
+
+
 export default class UdpClient {
   private localIp: string = ''
   private localIpPort: string = ''
   private oppositeIp: string = ''
   private oppositeIpPort: string = ''
-  private udp: socket.UDPSocket = null
+  protected udp: socket.UDPSocket = null
   private messageEvents: Array<Function> = []
   private errorEvents: Array<Function> = []
-  private dealMethod: DealMethod
+  private dealMethod: DealMethod<object>
 
   bindUdp(): Promise<void> {
     return this.udp.bind({
@@ -59,18 +60,10 @@ export default class UdpClient {
     return this.udp?.close()
   }
 
-  setDealMethod(fun: DealMethod) {
+  setDealMethod<T extends Object>(fun: DealMethod<T>) {
     this.dealMethod = fun
   }
 
-  onMsg(callback: Function) {
-    this.messageEvents.push(callback)
-  }
-
-  onError(callback: Function) {
-    this.errorEvents.push(callback)
-  }
-
   sendMsg(data: ArrayBuffer | string): Promise<void> {
     return this.udp.send({
       data,
@@ -95,7 +88,7 @@ export default class UdpClient {
     this.sendMsg(msgData)
   }
 
-  async create(udpLocalIp: string, udpLocalIpPort: string, udpOppositeIp: string, udpOppositeIpPort: string) {
+  create(udpLocalIp: string, udpLocalIpPort: string, udpOppositeIp: string, udpOppositeIpPort: string) {
     this.localIp = udpLocalIp
     this.oppositeIp = udpOppositeIp
     this.localIpPort = udpLocalIpPort
@@ -105,13 +98,24 @@ export default class UdpClient {
     return this.bindUdp()
   }
 
+  onMsg(callback: Function) {
+    if (this.messageEvents.findIndex(cb => cb === callback)) {
+      return
+    }
+    this.messageEvents.push(callback)
+  }
+
+  onError(callback: Function) {
+    this.errorEvents.push(callback)
+  }
+
   offMsg(callback: Function) {
     this.messageEvents = this.messageEvents.filter(cb => cb !== callback)
   }
 
   private bindEvent() {
     this.udp?.on("message", value => {
-      let result = this?.dealMethod(value.message)
+      let result = this.dealMethod(value.message)
       this.messageEvents.forEach(cb => {
         cb(result)
       })
@@ -248,9 +252,6 @@ class JudgeUdpClient extends UdpClient {
         }
       } catch (e) {
         reject(e)
-        promptAction.showToast({
-          message: "初始化评判 udp失败"
-        })
       }
     })
   }

entry/src/main/ets/utils/business/CenterUdpBusiness.ets

@@ -3,66 +3,53 @@ import { CarInfoType, centerCallBackMsgType, EnvironmentConfigurationType, UDPPa
 import { fillZero, string2Bytes } from '../../pages/judgeSDK/utils/Common';
 import { NumberToByteArray } from '../Common';
 import UdpClient from '../UdpUtils';
+import { UDPTag } from '../../config';
 
-class centralHeartbeat {
+// 中心UDP业务逻辑
-  private centralHeartbeatUdp: UdpClient;
+class CenterUDPBusiness {
+  private static instance: CenterUDPBusiness
+  private udp: UdpClient
   private timer: number = -1
-  private headLenth: number = 9
+  private headLength: number = 9
   private sendId: number = 0
 
   constructor() {
+    if (!CenterUDPBusiness.instance) {
+      CenterUDPBusiness.instance = this
+    }
+    return CenterUDPBusiness.instance
   }
 
-  // 初始化
+  private dealMsg(msg: ArrayBuffer): centerCallBackMsgType {
-  init() {
+    let arr: number[] = []
-    let config: EnvironmentConfigurationType =
+    let dataView = new DataView(msg)
-      AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration")
+    for (let i = 0; i < dataView?.byteLength; ++i) {
-    this.centralHeartbeatUdp = new UdpClient();
+      arr[i] = dataView?.getUint8(i)
-    this.centralHeartbeatUdp.create(config.udplocalIp, config.udplocalIpPort, config.udpOppositeIp,
+    }
-      config.udpOppositeIpPort);
+    let id = Math.floor(Number('0x' + fillZero(arr[1].toString(16), 2) + fillZero(arr[0].toString(16), 2)) / 1000)
+    let length = Number('0x' + fillZero(arr[7].toString(16), 2) + fillZero(arr[6].toString(16), 2));
+    let list: number[] = []
+    for (let i = this.headLength; i <= this.headLength + length - 1; i++) {
+      list.push(arr[i])
+    }
+    return {
+      id,
+      length,
+      body: list,
+      sendId: this.sendId
+    }
   }
 
-  // 接受中心远程指令
+  private setWholeMsg(params: UDPParamType) {
-  getData(callback: (data: centerCallBackMsgType) => void) {
-    this.centralHeartbeatUdp.onMsg((data: ArrayBuffer) => {
-      let arr: number[] = []
-      let dataView = new DataView(data)
-      for (let i = 0; i < dataView?.byteLength; ++i) {
-        arr[i] = dataView?.getUint8(i)
-      }
-      let idNum = '0x' + fillZero(arr[1].toString(16), 2) + fillZero(arr[0].toString(16), 2);
-      let id = Math.floor(Number(idNum) / 1000)
-
-      let lengthNum = '0x' + fillZero(arr[7].toString(16), 2) + fillZero(arr[6].toString(16), 2);
-      let length = Number(lengthNum);
-      let list: number[] = []
-      for (let i = this.headLenth; i <= this.headLenth + length - 1; i++) {
-        list.push(arr[i])
-      }
-      const result: centerCallBackMsgType = {
-        id,
-        length,
-        body: list,
-        sendId: this.sendId
-      }
-      callback(result)
-
-      // callback(data);
-    });
-  }
-
-  setWholeMsg(params: UDPParamType) {
     let head: Array<number> = this.setMsgHead(params);
     let headJudge = this.setMessageExclusive(head);
     let bodyJudge = this.setMessageExclusive(params.list);
     let end = [13, 10];
     const arr: Array<number> = [...head, ...headJudge, ...params.list, ...bodyJudge, ...end]
-    return this.Array2Byte(arr).buffer
+    return this.array2Byte(arr).buffer
   }
 
-  //length消息体bufferlength   id消息类型id  bodyStr消息体string
+  private array2Byte(array: Array<number>) {
-  // setMsyBody(id,bodyByte){
-  Array2Byte(array: Array<number>) {
     const buf = new ArrayBuffer(array.length);
     const view = new Uint8Array(buf);
     for (let i = 0; i != array.length; ++i) {
@@ -71,15 +58,14 @@ class centralHeartbeat {
     return view;
   }
 
-  setMsgHead(params: UDPParamType) {
+  private setMsgHead(params: UDPParamType) {
     let a = string2Bytes(Number(`${params.id}${fillZero(params.placeId, 3)}`), 2 * 8);
     let b = string2Bytes(Number(`${fillZero(params.carNo, 4)}${AppStorage.get('lshNo')}`), 4 * 8);
     let c = string2Bytes(params.list.length, 2 * 8);
     return [...a, ...b, ...c];
   }
 
-  //异或运算
+  private setMessageExclusive(tmpList: Array<number>) {
-  setMessageExclusive(tmpList: Array<number>) {
     let result: number = tmpList[0];
     for (let i = 1; i < tmpList.length; i++) {
       result = result ^ tmpList[i]
@@ -90,13 +76,11 @@ class centralHeartbeat {
   sendData(data: UDPParamType) {
     this.sendId = data.id
     const param = this.setWholeMsg(data)
-    this.centralHeartbeatUdp.sendMsg(param);
+    this.udp.sendMsg(param);
   }
 
-  // 发送消息
+  startHeartBeat() {
-  sendHeartData() {
     // 组装消息,一秒发送一次
-    // let data = "1";
     this.timer = setInterval(() => {
       const signNum = AppStorage.get<number>('signNum')
       const statue = AppStorage.get<string>('statue')
@@ -117,15 +101,40 @@ class centralHeartbeat {
         placeId: carInfo.examinationRoomId
       }
       const param = this.setWholeMsg(data)
-      this.centralHeartbeatUdp.sendMsg(param);
+      this.udp.sendMsg(param);
     }, 1000);
   }
 
-  //  关闭所有动作
+  onMsg(cb: (param: centerCallBackMsgType) => void) {
-  close() {
+    this.udp.onMsg(cb)
-    clearInterval(this.timer);
+  }
-    this.centralHeartbeatUdp.close()
+
+  offMsg(cb: (param: centerCallBackMsgType) => void) {
+    this.udp.offMsg(cb)
+  }
+
+  async init(): Promise<void> {
+    return new Promise((resolve, reject) => {
+      try {
+        let result: EnvironmentConfigurationType =
+          AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration")
+        const carInfo: CarInfoType = AppStorage.get<CarInfoType>('carInfo')
+        this.udp.create(result.udplocalIp, '8800', carInfo?.udpAddress, carInfo?.messagePort)
+          .then(resolve)
+          .catch(reject)
+        this.udp.setDealMethod(this.dealMsg)
+      } catch (e) {
+        reject(e)
+        console.error(UDPTag, "初始化中心 udp失败")
+      }
+    })
+  }
+
+  // 关闭所有动作
+  async close() {
+    clearInterval(this.timer)
+    return this.udp.close()
   }
 }
 
-export const CentralHeartbeat = new centralHeartbeat();
+export const CenterUDPClientInstance = new CenterUDPBusiness();

entry/src/main/ets/utils/business/JudgeUdpBusiness.ets

@@ -0,0 +1,414 @@
+import { CarInfoType, EnvironmentConfigurationType, Gps, Sensor, UDPParamType } from '../../model'
+import { testKm2Items, testKm3Items } from '../../pages/judgeSDK/dataTest';
+import { fillZero, } from '../../pages/judgeSDK/utils/Common';
+import { judgeConfig } from '../../pages/judgeSDK/utils/judgeConfig';
+import { FillZero, StringToASCII } from '../Common';
+import UdpClient from '../UdpUtils'
+import { CenterUDPClientInstance } from './CenterUdpBusiness';
+import { ObtainUdpBusinessInstance } from './ObtainUdpBusiness';
+import systemTime from '@ohos.systemDateTime';
+import { examCalcGpsDistance } from '../../pages/judgeSDK/api';
+
+interface PLCDataType {
+  sensor: Sensor,
+  gps: Gps,
+}
+
+interface ProjectDataType {
+  code: string
+  status: number
+}
+
+interface ProjectItemType {
+  code: ProjectDataType
+  status: string
+}
+
+function string2Bytes(num: number | string, len: number) {
+  let str = (Math.floor(Number(num))).toString(2);
+  if (str.length > len) {
+    console.log('数据长度不对~~');
+    return
+  }
+  let byteString = FillZero(str, len);
+
+  let arrBytes: number[] = [];
+  for (let i = byteString.length; i > 0; ) {
+    let j = i - 8;
+    if (j < 0) {
+      j = 0
+    }
+    let s = byteString.slice(j, i);
+    let v = parseInt(s, 2);
+    arrBytes.push(v);
+    i = i - 8
+  }
+  return arrBytes;
+}
+
+class JudgeUdpBusiness {
+  private static instance: JudgeUdpBusiness
+  private udp: UdpClient
+  private udpIndex = 0;
+  private currentUdpIndex = 0;
+
+  constructor() {
+    if (!JudgeUdpBusiness.instance) {
+      JudgeUdpBusiness.instance = this
+    }
+    return JudgeUdpBusiness.instance
+  }
+
+  private setWholeMsg(params: UDPParamType) {
+    let head: Array<number> = this.setMsgHead(params);
+    let headJudge = this.setMessageExclusive(head);
+    let bodyJudge = this.setMessageExclusive(params.list);
+    let end = [13, 10];
+    const arr: Array<number> = [...head, ...headJudge, ...params.list, ...bodyJudge, ...end]
+    return this.array2Byte(arr).buffer
+  }
+
+  private array2Byte(array: Array<number>) {
+    const buf = new ArrayBuffer(array.length);
+    const view = new Uint8Array(buf);
+    for (let i = 0; i != array.length; ++i) {
+      view[i] = array[i] & 0xFF;
+    }
+    return view;
+  }
+
+  private setMsgHead(params: UDPParamType) {
+    let a = string2Bytes(Number(`${params.id}${fillZero(params.placeId, 3)}`), 2 * 8);
+    let b = string2Bytes(Number(`${fillZero(params.carNo, 4)}${AppStorage.get('lshNo')}`), 4 * 8);
+    let c = string2Bytes(params.list.length, 2 * 8);
+    return [...a, ...b, ...c];
+  }
+
+  private setMessageExclusive(tmpList: Array<number>) {
+    let result: number = tmpList[0];
+    for (let i = 1; i < tmpList.length; i++) {
+      result = result ^ tmpList[i]
+    }
+    return [result];
+  }
+
+  private convertGpsCoord2(num: number) {
+    const tempNum = Math.floor(num);
+    const du = Math.floor(tempNum / 100);
+    const fen = tempNum % 100 + num - tempNum;
+    return du + fen / 60
+  }
+
+  // 中心plc实时信号转换成字节
+  private getTranslateSignals(tempItems: number[]) {
+    const len = Math.floor(tempItems.length / 8);
+    const arr: string[] = [];
+    for (let i = 0; i < len; i++) {
+      arr.push(tempItems.slice(i * 8, (i + 1) * 8).join(''));
+    }
+    return arr.map(numStr => parseInt(numStr, 2)).map(item => string2Bytes(item, 8)[0])
+  }
+
+  // 中心所有项目转换
+  private getTranslateProject(): string[] {
+    const examSubject = AppStorage.get<string>("examSubject");
+    const tempItems: ProjectItemType[] =
+      (examSubject === '2' ? testKm2Items : testKm3Items).map((code: ProjectDataType) => {
+        let data: ProjectItemType = {
+          code,
+          status: '0'
+        }
+        return data
+      })
+    const arr: string[] = [];
+    for (let i = 0; i <= 4; i++) {
+      const temp = tempItems.slice(i * 4, (i + 1) * 4);
+      let tempArr = temp.map(item => item.status)
+      if (i === 4) {
+        tempArr = examSubject === '2'
+          //bit36-bit39保留
+          ? tempArr.concat(['00', '00'])
+          //bit30-bit39保留
+          : tempArr.concat(['00', '00', '00'])
+      }
+
+      arr.push(tempArr.join(''));
+    }
+    return arr
+  }
+
+  // plc数据转换成对象
+  private async getPlcData(plc: string): Promise<PLCDataType> {
+    const time = await systemTime.getCurrentTime()
+    let origin = plc.split(",")
+    let p = origin.map(item => Number(item))
+    let sensor: Sensor = {
+      aqd: p[19],
+      mkg: p[14],
+      ssc: p[13],
+      jsc: p[12],
+      fsc: p[18],
+      lhq: p[17],
+      lb: p[4],
+      skd: p[9],
+      jgd: p[7],
+      ygd: p[8],
+      //左方向灯   右方向灯     双跳灯      雾灯        雨刮器      点火1     点火2      发动机转速     档位       车速
+      zfxd: p[2],
+      yfxd: p[3],
+      shtd: p[20],
+      wd: p[10],
+      ygq: p[11],
+      dh1: p[5],
+      dh2: p[6],
+      fdjzs: p[25],
+      dw: p[28],
+      cs: p[23],
+      fxp: Number(origin[27].split('_')[0]),
+      //累计脉冲   溜车脉冲   超声波左后     超声波右后     超声波右前     超声波左前    座椅    仪表盘   后视镜   倒车镜   光照  雨量
+      ljmc: p[24],
+      lcmc: 0,
+      csbzh: p[32],
+      csbyh: p[30],
+      csbyq: p[31],
+      csbzq: p[29],
+      zy: 0,
+      tbp: 0,
+      hsj: 0,
+      dcj: 0,
+      gx: 0,
+      yl: 0,
+      yy: 0,
+      sde: 0,
+      xhd: '',
+      rmndg: 0,
+      wav: 0,
+      mndg: ''
+    }
+    let gps: Gps = {
+      bklx: p[56],
+      dwzt: p[83],
+      jdzt: Number(origin[92].split('-')[0]),
+      sj: time,
+      jd: p[96],
+      wd: p[95],
+      hxj: p[90],
+      fyj: p[91],
+      hbg: p[85],
+      gdc: p[86],
+      sd: p[97],
+      age: p[87],
+      jdyz: p[89],
+      wdyz: p[88],
+      dwsxs: p[84],
+      jdsxs: Number(origin[92].split('-')[1])
+    }
+
+    return {
+      sensor,
+      gps,
+    }
+  }
+
+  private getDwStatusType(dw: number) {
+    switch (dw) {
+      case 0:
+        return [0, 0, 0, 0]
+      case 1:
+        return [0, 0, 0, 1]
+      case 2:
+        return [0, 0, 1, 0]
+      case 3:
+        return [0, 0, 1, 1]
+      case 4:
+        return [0, 1, 0, 0]
+      case 5:
+        return [0, 1, 0, 1]
+      case 9:
+        return [1, 0, 0, 1]
+      default:
+        return [0, 0, 0, 0]
+    }
+  }
+
+  private async getMessageHeartbeat(msg: string): Promise<number[]> {
+    const carInfo: CarInfoType = AppStorage.get<CarInfoType>('carInfo')
+    let gpsDigit = judgeConfig.fourInOneScreen.gpsDigit
+    const asclshArr = StringToASCII(FillZero(
+      AppStorage.get<boolean>("singlePlay")
+        ? '1111111111111'
+        : AppStorage.get<string>("lsh"),
+      13));
+    const ascksyhArr = StringToASCII(carInfo.examSubject === '2' ? '0000000000000' : '1111111111111')
+    const ascsbxhArr = StringToASCII('00000000')
+    const serialIndex = AppStorage.get<number>("serialIndex")
+    const plcData = await this.getPlcData(msg);
+    let param: number[] = Object.entries(plcData.sensor)
+      .filter((item: [string, number]) => {
+        let keys =
+          ["zfxd", "yfxd", "shtd", "ygd", "jgd", "skd", "dh1", "dh2", "lhq", "jsc", "ssc", "fsc", "lb", "mkg", "aqd"]
+        return keys.indexOf(item[0])
+      })
+      .map((item: [string, number]) => item[1])
+      .concat(this.getDwStatusType(plcData.sensor.dw))
+      .concat([0, 0, plcData.sensor.ygq, plcData.sensor.wd, 0])
+    const translateSignals = this.getTranslateSignals(param)
+    const translateProject = this.getTranslateProject();
+    const translateJd = Number(this.convertGpsCoord2(plcData.gps.wd).toFixed(gpsDigit)) * Math.pow(10, gpsDigit);
+    const translateWd = Number(this.convertGpsCoord2(plcData.gps.jd).toFixed(gpsDigit)) * Math.pow(10, gpsDigit)
+    const translateProjects = translateProject.map(numStr => string2Bytes(parseInt(numStr, 2), 8)[0])
+    let tempSd = Number((plcData.gps.sd * 1.852).toFixed(0))
+    if (tempSd < 1) {
+      tempSd = 0
+    }
+    const arr: number[][] = [
+    //考生号
+      asclshArr.map(lsh => string2Bytes(lsh, 8)[0]),
+      //考试员号
+      ascksyhArr.map(ksyh => string2Bytes(ksyh, 8)[0]),
+      //科目类型(0:未考试 1:科目二 2:科目三) + 考试开始时间
+      string2Bytes(`${0}${'00:00:000'}`, 4 * 8),
+      // 消息序号
+      string2Bytes(serialIndex, 2 * 8),
+      translateSignals,
+      string2Bytes(tempSd * 100, 2 * 8),
+      string2Bytes(plcData.sensor.fdjzs / 100, 8),
+      string2Bytes(translateJd, 4 * 8),
+      string2Bytes(translateWd, 4 * 8), string2Bytes(1, 8),
+      //GPS东向距离
+      string2Bytes(0, 4 * 8),
+      //GPS北向距离
+      string2Bytes(0, 4 * 8),
+      //航向角
+      string2Bytes(plcData.gps.hxj * 100, 2 * 8),
+      //俯仰角
+      string2Bytes(plcData.gps.fyj * 100, 2 * 8),
+      // 高程(海拔)
+      string2Bytes(plcData.gps.hbg * 100, 4 * 8),
+      //dddd
+      translateProjects,
+      //当前项目编号
+      string2Bytes(0, 8),
+      //场地设备编号
+      ascsbxhArr.map(sbxh => string2Bytes(sbxh, 8)[0]),
+      //本次考试行驶距离
+      string2Bytes(0, 2 * 8),
+      //扣分值
+      string2Bytes(0, 2 * 8),
+      //扣分数
+      string2Bytes(0, 2 * 8),
+      //扣分项数量
+      string2Bytes(0, 8),
+      //n个扣分序号
+      // [].map(kf => string2Bytes(kf.markcatalog, 8)),
+      [],
+      //牵引车第二gps精度、纬度
+      string2Bytes(0, 4 * 8), string2Bytes(0, 4 * 8),
+      //牵引车第二航向角
+      string2Bytes(0, 2 * 8),
+      //摩托压线 Byte[20],
+      string2Bytes(0, 20 * 8),
+      //考试用时
+      string2Bytes(FillZero(0, 4), 4 * 8),
+      //项目用时
+      string2Bytes(FillZero(0, 2), 2 * 8),
+      //设备信号状态
+      string2Bytes(0, 4 * 8),
+    ]
+    let result: number[] = [];
+    arr.forEach(itemArr => {
+      result = result.concat(itemArr)
+    })
+    AppStorage.setOrCreate("serialIndex", 0)
+    return [...new Uint8Array(result)]
+  }
+
+  send(data: UDPParamType) {
+    const param = this.setWholeMsg(data)
+    this.udp.sendMsg(param);
+  }
+
+  sendData(bytes: number[]) {
+    const carInfo: CarInfoType = AppStorage.get<CarInfoType>('carInfo')
+    if (this.udpIndex > this.currentUdpIndex) {
+      this.udp.sendMsgExt({
+        id: 45,
+        list: bytes,
+        carNo: carInfo.carNo,
+        placeId: carInfo.examinationRoomId
+      })
+      this.currentUdpIndex = this.udpIndex
+    }
+  }
+
+  //申请远程扣分查询
+  askKf(directives: number) {
+    const carInfo: CarInfoType = AppStorage.get<CarInfoType>('carInfo')
+    CenterUDPClientInstance.sendData({
+      id: 35,
+      list: [directives],
+      carNo: carInfo.carNo,
+      placeId: carInfo.examinationRoomId,
+    })
+    console.info('surenjun', `考车查询扣分项目内容，请求指令为：${directives}`)
+  }
+
+  //确定远程扣分
+  confirmKf(directives: number, code: number) {
+    const carInfo: CarInfoType = AppStorage.get<CarInfoType>('carInfo')
+    CenterUDPClientInstance.sendData({
+      id: 37,
+      list: [directives, code],
+      carNo: carInfo.carNo,
+      placeId: carInfo.examinationRoomId
+    })
+    console.info('surenjun', `考车发送确定扣分指令，指令为：${directives}`)
+  }
+
+  async init(): Promise<void> {
+    return new Promise((resolve, reject) => {
+      try {
+        let result: EnvironmentConfigurationType =
+          AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration")
+        const carInfo: CarInfoType = AppStorage.get<CarInfoType>('carInfo')
+        this.udp.create(result.udplocalIp, '8080', carInfo.udpAddress, carInfo.hintPort).then(resolve).catch(reject)
+        ObtainUdpBusinessInstance.onMsg(async (msg: string) => {
+          let prevJd = 0, preWd = 0
+
+          const stashArr = msg.split(',')
+          if (stashArr[0] != '#DN_GD') {
+            return
+          }
+          const udpIndex = AppStorage.get<number>("udpIndex");
+          const isJudge = AppStorage.get<boolean>("isJudge");
+          if (udpIndex % 5 === 0 && !isJudge) {
+            const bytes = await this.getMessageHeartbeat(msg);
+            const msgArr: string[] = msg.split(',');
+            const jd = this.convertGpsCoord2(Number(msgArr[96]));
+            const wd = this.convertGpsCoord2(Number(msgArr[95]) || 0);
+            this.sendData(bytes)
+            if (prevJd && Number(msgArr[83]) === 4) {
+              await examCalcGpsDistance({
+                jd1: prevJd,
+                wd1: preWd,
+                jd2: jd,
+                wd2: wd,
+                h: Number(msgArr[90]) || 1,
+              })
+            }
+            prevJd = jd;
+            preWd = wd;
+          }
+          AppStorage.set("udpIndex", udpIndex + 1)
+        })
+        setInterval(() => {
+          this.udpIndex += 1
+        }, 1000)
+      } catch (e) {
+        reject(e)
+      }
+    })
+  }
+}
+
+export const JudgeUdpBusinessInstance = new JudgeUdpBusiness()

entry/src/main/ets/utils/business/ObtainSignalData.ets

@@ -1,70 +0,0 @@
-import { GlobalConfig } from '../../config'
-import { EnvironmentConfigurationType } from '../../model'
-import UdpClient from '../UdpUtils'
-
-// 获取PLC GPS信号
-class obtainSignalData {
-  // 三代机UDP
-  private thirdGenerationMachineUdp: UdpClient
-  // 几代机
-  private modelNo: string = "3"
-
-  constructor() {
-    this.modelNo = GlobalConfig.modelNo
-  }
-
-  //   一些初始化
-  init() {
-    if (this.modelNo === "0") {
-    } else if (this.modelNo === "1") {
-    } else if (this.modelNo === "2") {
-    } else if (this.modelNo === "3") {
-      //   初始化UDP
-      let config: EnvironmentConfigurationType =
-        AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration")
-      this.thirdGenerationMachineUdp = new UdpClient()
-      this.thirdGenerationMachineUdp.create(config.udplocalIp, config.udplocalIpPort, config.udpOppositeIp,
-        config.udpOppositeIpPort)
-    }
-
-  }
-
-  //   获取信号
-  getData(callback: (data: string) => void) {
-    //   一代机
-
-    //   二代机
-
-    //   三代机 通过UDP onMessage获取信号
-    if (this.modelNo === "3") {
-      this.thirdGenerationMachineUdp.onMsg((data: ArrayBuffer) => {
-        const dataView = new DataView(data);
-        let str = ""
-        for (let i = 0; i < dataView?.byteLength; ++i) {
-          let c = String.fromCharCode(dataView?.getUint8(i))
-          if (c !== "\n") {
-            str += c
-          }
-        }
-        callback(str)
-      })
-    }
-    //   一体机
-  }
-
-  //   发送数据
-  sendData(data: string) {
-    //   一代机
-
-    //   二代机
-
-    //   三代机 通过UDP发送数据
-    if (this.modelNo === "3") {
-      this.thirdGenerationMachineUdp.sendMsg(data)
-    }
-    //   一体机
-
-  }
-}
-
-export const ObtainSignalData = new obtainSignalData()

entry/src/main/ets/utils/business/ObtainUdpBusiness.ets

@@ -0,0 +1,168 @@
+import { GlobalConfig } from '../../config'
+import { EnvironmentConfigurationType } from '../../model'
+import UdpClient from '../UdpUtils'
+
+// 获取PLC GPS信号
+class ObtainUdpBusiness {
+  // 三代机UDP
+  private thirdGenerationMachineUdp: UdpClient
+  // 几代机
+  private modelNo: string = "3"
+
+  constructor() {
+    this.modelNo = GlobalConfig.modelNo
+  }
+
+  private initSecondaryBoard() {
+
+  }
+
+  private initFirstGeneration() {
+
+  }
+
+  private initSecondGeneration() {
+
+  }
+
+  private initThirdGeneration() {
+    let config: EnvironmentConfigurationType =
+      AppStorage.get<EnvironmentConfigurationType>("EnvironmentConfiguration")
+    this.thirdGenerationMachineUdp = new UdpClient()
+    this.thirdGenerationMachineUdp.create(config.udplocalIp, config.udplocalIpPort, config.udpOppositeIp,
+      config.udpOppositeIpPort)
+    this.thirdGenerationMachineUdp.setDealMethod(this.dealThirdGenerationMsg)
+  }
+
+  private dealSecondaryBoardMsg() {
+
+  }
+
+  private dealFirstGenerationMsg() {
+
+  }
+
+  private dealSecondGenerationMsg() {
+
+  }
+
+  private dealThirdGenerationMsg(data: ArrayBuffer) {
+    const dataView = new DataView(data);
+    let str = ""
+    for (let i = 0; i < dataView?.byteLength; ++i) {
+      let c = String.fromCharCode(dataView?.getUint8(i))
+      if (c !== "\n") {
+        str += c
+      }
+    }
+    return str
+  }
+
+  private onSecondaryBoardMsg(cb: Function) {
+
+  }
+
+  private onFirstGenerationMsg(cb: Function) {
+
+  }
+
+  private onSecondGenerationMsg(cb: Function) {
+
+  }
+
+  private onThirdGenerationMsg(cb: Function) {
+    this.thirdGenerationMachineUdp.onMsg(cb)
+  }
+
+  private sendSecondaryBoardMsg(data: string) {
+
+  }
+
+  private sendFirstGenerationMsg(data: string) {
+
+  }
+
+  private sendSecondGenerationMsg(data: string) {
+
+  }
+
+  private sendThirdGenerationMsg(data: string) {
+    this.thirdGenerationMachineUdp.sendMsg(data)
+  }
+
+  init() {
+    switch (this.modelNo) {
+      case "0":
+        this.initSecondaryBoard()
+        break
+      case "1":
+        this.initFirstGeneration()
+        break
+      case "2":
+        this.initSecondGeneration()
+        break
+      case "3":
+        this.initThirdGeneration()
+        break
+      default:
+        this.initFirstGeneration()
+        break
+    }
+  }
+
+  onMsg(callback: (data: string) => void) {
+    switch (this.modelNo) {
+      case "0":
+        this.onSecondaryBoardMsg(callback)
+        break
+      case "1":
+        this.onFirstGenerationMsg(callback)
+        break
+      case "2":
+        this.onSecondGenerationMsg(callback)
+        break
+      case "3":
+        this.onThirdGenerationMsg(callback)
+        break
+      default:
+        break
+    }
+  }
+
+  offMsg(cb: Function) {
+    switch (this.modelNo) {
+      case "0":
+        break
+      case "1":
+        break
+      case "2":
+        break
+      case "3":
+        this.thirdGenerationMachineUdp.offMsg(cb)
+        break
+      default:
+        break
+    }
+  }
+
+  sendData(data: string) {
+    switch (this.modelNo) {
+      case "0":
+        this.sendSecondaryBoardMsg(data)
+        break
+      case "1":
+        this.sendFirstGenerationMsg(data)
+        break
+      case "2":
+        this.sendSecondGenerationMsg(data)
+        break
+      case "3":
+        this.sendThirdGenerationMsg(data)
+        break
+      default:
+        break
+    }
+  }
+}
+
+export const ObtainUdpBusinessInstance = new ObtainUdpBusiness()