fix: 过程数据记录

entry/src/main/ets/model/Worker.ets

@@ -112,22 +112,22 @@ export enum WorkerMessageType {
 
 // 过程数据枚举
 export enum ProcessDataEnumType {
-  //four_one_log_byte_data
+  // //four_one_log_byte_data
-  FourOneLogByteData = "0",
+  // FourOneLogByteData = "0",
-  //four_one_log_data
+  // //four_one_log_data
-  FourOneLogData = "1",
+  // FourOneLogData = "1",
   //judge_exam_data
-  JudgeExamData = "2",
+  JudgeExamData = "0",
   //judge_log_data
-  JudgeLogData = "3",
+  JudgeLogData = "1",
   //judge_progress_callback_data
-  JudgeProgressCallbackData = "4",
+  JudgeProgressCallbackData = "2",
   //plc_data
-  PlcData = "5",
+  PlcData = "3",
   //wuxi_exam_data
-  WuxiExam = "6",
+  WuxiExam = "4",
   //wuxi_progress_data
-  WuxiProgressData = "7"
+  WuxiProgressData = "5"
 }
 
 export interface FileQueueType {

entry/src/main/ets/pages/Judge.ets

@@ -226,9 +226,10 @@ export struct JudgePage {
   async aboutToDisappear() {
     this.generateExamRecordsDialogController.close()
     this.signalTrajectoryDialogController.close()
-    // this.judgeBusiness.close()
+    this.judgeBusiness.close()
     clearInterval(this.mileageTimer)
     DifferentialAndSignal.offMsg(this.onCenterMsg)
+
   }
 
   //初始化相关数据库表
@@ -802,19 +803,19 @@ export struct JudgePage {
   private onCenterMsg = (msg: string) => {
     let result: WorkerBackMessage = JSON.parse(msg)
     if (result.type === WorkerBackMessageType.RemoteEndExam) {
-      dConsole.info("lixiao", msg)
+      dConsole.info(JudgeTag, msg)
       this.judgeBusiness.JudgeEnd(true)
     } else if (result.type === WorkerBackMessageType.RemoteKf) {
       let data = result.data as number[]
       const config810 = this.judgeConfigObj.param_810
-      dConsole.info("lixiao", '评判收到远程扣分项目内容：' + `kfxh=>${data[1]}; directives=>${data[0]}`)
+      dConsole.info(JudgeTag, '评判收到远程扣分项目内容：' + `kfxh=>${data[1]}; directives=>${data[0]}`)
       let currentKf = this.markRules.filter(item => {
         return item.kfxh === data[1].toString() && (config810 === "1" || Number(item.markserial) > 99)
       })[0]
       if (!currentKf) {
         return
       }
-      dConsole.info("lixiao", '远程扣分项目：', currentKf)
+      dConsole.info(JudgeTag, '远程扣分项目：', currentKf)
       this.judgeBusiness.setJudgeMark(currentKf.itemno!, currentKf.markserial!, 2)
       DifferentialAndSignal.sendMsg({
         type: WorkerMessageDataType.JudgeSend,

entry/src/main/ets/pages/Judge/BaseJudgeBussines.ets

@@ -519,7 +519,7 @@ export class BaseJudge {
     }
     //日志回调
     dConsole.info(JudgeTag, '1.进入评判入口')
-    await examJudgeSetLogCallback(1, async (level: number, info: string, len: number) => {
+    await examJudgeSetLogCallback(3, async (level: number, info: string, len: number) => {
       dConsole.log(JudgeTag, '评判日志：' + info)
       dConsole.writeProcessData(ProcessDataEnumType.JudgeLogData, info)
     })
@@ -533,6 +533,7 @@ export class BaseJudge {
       AppStorage.setOrCreate('isJudgeInitBool', true)
       dConsole.info(JudgeTag, '4.评判初始化完成')
     }
+    dConsole.writeProcessData(ProcessDataEnumType.JudgeExamData, JSON.stringify(initInfo))
     AppStorage.setOrCreate('isJudge', true)
     // 2.评判过程回调
     await examJudgeSetRealExamCallback(async (strData: string, len: number) => {
@@ -555,6 +556,7 @@ export class BaseJudge {
     // 3.开始考试
     if (beginExamInfo) {
       await examJudgeBeginExam(beginExamInfo);
+      dConsole.writeProcessData(ProcessDataEnumType.JudgeExamData, JSON.stringify(beginExamInfo))
     }
     dConsole.info(JudgeTag, '6.开始考试注册完成')
     that.avPlayer?.playAudio([judgeUI.singlePlay ? 'voice/ksks.wav' : 'voice/监管成功.mp3'])

entry/src/main/ets/pages/Judge/JudgeBusiness.ets

@@ -4,7 +4,6 @@ import {
   JudgeKSJS,
   JudgePerformInfo,
   LANE,
-  MarkRule,
   PLCType,
   ProcessDataEnumType,
   RecordHandleType,
@@ -133,7 +132,7 @@ export default class JudgeBusiness {
 
   // 结束考试
   public JudgeEnd(isManual?: boolean) {
-    dConsole.info("lixiao", '收到远程结束考试消息1')
+    dConsole.info(JudgeTag, '收到远程结束考试消息1')
     this.judgeBusiness.JudgeEnd(this.judgeUI, this, isManual)
   }
 

entry/src/main/ets/pages/Judge/ProcessDataTaskPool.ets

@@ -101,6 +101,7 @@ export class ProcessDataTaskPool {
           jkid: taskData.jkid,
           drvexam: drvexam,
         };
+        
         dConsole.writeProcessData(ProcessDataEnumType.WuxiExam, JSON.stringify(obj));
 
         await this.processSingleTaskWithRetries(taskData, callback);

entry/src/main/ets/utils/Common.ets

@@ -1,7 +1,7 @@
 import dayTs from './Date';
 import fs from '@ohos.file.fs';
 import { BusinessError } from '@ohos.base';
-import { CommonFileTag, JudgeConfig, JudgeTag } from '../config';
+import { CommonFileTag, JudgeConfig, JudgeTag, LogTag } from '../config';
 import abilityAccessCtrl, { Permissions } from '@ohos.abilityAccessCtrl';
 import Prompt from '@system.prompt';
 import common from '@ohos.app.ability.common';
@@ -272,9 +272,11 @@ export function CloseFile(fd: number): Promise<boolean> {
 export function EditFile(fd: number, data: string): Promise<boolean> {
   return new Promise((resolve, reject) => {
     try {
+      console.log(LogTag, "写入数据：" + data)
       fs.writeSync(fd, data + "\n")
       resolve(true)
     } catch (e) {
+      console.error(LogTag, "写入数据失败", data)
       reject(false)
     }
   })

entry/src/main/ets/utils/LogWorker.ets

@@ -75,6 +75,7 @@ class logWorker {
 
   // 过程数据写入
   writeProcessData(type: ProcessDataEnumType, data: string) {
+    dConsole.log(LogTag, "传入过程数据", data)
     let params: LogWorkerMessage = {
       type: WorkerMessageType.WriteProcessData,
       data,

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

@@ -94,7 +94,7 @@ class differentialAndSignal {
   getMessage() {
     this.workerInstance.onmessage = (e: MessageEvents): void => {
       if (e.data) {
-        console.log(WorkerTag, "lixiao", "Worker 收到消息: " + e.data);
+        // console.log(WorkerTag, "Worker 收到消息: " + e.data);
         this.events.forEach((callback) => {
           callback(e.data);
         });

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

@@ -10,6 +10,16 @@ export default class GetDistance {
   public totalTime: number
   public date: string
   public fd: number
+  //上传行驶里程数据
+  uploadData = async () => {
+    // setInterval(() => {
+    //   // const { carId } = AppStorage.get<CarInfoType>('carInfo');
+    //   // const { date, timeStr, totalDistance } = this;
+    //   return
+    //   //"carid":"1001","startTime":"2024-08-24 08:09:01","time":"111233", "mileage":"1222"
+    //
+    // }, 5000)
+  }
   //后续文件路径待替换
   private fileUtil: FileUtils
   // 设置文件夹
@@ -35,7 +45,6 @@ export default class GetDistance {
     this.fileUtil = fileUtil;
   }
 
-
   // 过程文件数据
   public setTimeData = async (str: number) => {
     console.log('folderPath', this.folderPath)
@@ -55,14 +64,4 @@ export default class GetDistance {
     //   `${folderPath}/${date}.txt`,contentArr.join('\n')
     // );
   }
-  //上传行驶里程数据
-  uploadData = async () => {
-    setInterval(() => {
-      // const { carId } = AppStorage.get<CarInfoType>('carInfo');
-      // const { date, timeStr, totalDistance } = this;
-      return
-      //"carid":"1001","startTime":"2024-08-24 08:09:01","time":"111233", "mileage":"1222"
-
-    }, 5000)
-  }
 }

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

@@ -13,7 +13,7 @@ import {
   UDPParamType
 } from '../../model';
 
-import { JudgeConfig } from '../../config';
+import { JudgeConfig, JudgeTag } from '../../config';
 import { FillZero, NumberToByteArray, StringToASCII } from '../Common';
 import UdpClient, { MsgExt } from '../UdpUtils';
 import systemTime from '@ohos.systemDateTime';
@@ -46,7 +46,7 @@ class JudgeUdpBusiness {
   }
 
   async getMessageHeartbeat(msg: string): Promise<number[]> {
-    dConsole.info(Tag, msg, this.lsh)
+    // dConsole.info(Tag, msg, this.lsh)
     if (!this.business || !this.performInfo) {
       return this.getOBDMessageHeart(msg)
     }
@@ -238,7 +238,7 @@ class JudgeUdpBusiness {
       carNo: this.carInfo.carNo!,
       placeId: this.carInfo!.examinationRoomId!,
     }
-    dConsole.info(Tag, "发送小红球数据", data)
+    // dConsole.info(Tag, "发送小红球数据", data)
     this.udp.sendMsgExt(data, udpLsh)
   }
 
@@ -284,7 +284,7 @@ class JudgeUdpBusiness {
     this.carInfo = carInfo
     return new Promise((resolve, reject) => {
       try {
-        dConsole.info("lixiao udp", config.udplocalIp!, '8080', carInfo.udpAddress!, carInfo.hintPort!)
+        dConsole.info(JudgeTag, "udp", config.udplocalIp!, '8080', carInfo.udpAddress!, carInfo.hintPort!)
         this.udp.create(config.udplocalIp!, '8080', carInfo.udpAddress!, carInfo.hintPort!).then(resolve).catch(reject)
       } catch (e) {
         reject(e)

entry/src/main/ets/workers/DifferentialCorrection.ets

@@ -19,7 +19,6 @@ import { DifferentialSignal } from '../utils/business/DifferentialSignal';
 import { JudgeUdpBusinessInstance } from '../utils/business/JudgeUdpBusiness';
 import { ObtainUdpBusinessInstance } from '../utils/business/ObtainUdpBusiness';
 import { SerialPortService } from '../utils/business/SerialPortService';
-import { dConsole } from '../utils/LogWorker';
 import dayTs from '../utils/Date';
 import { NumberToByteArray } from '../utils/Common';
 
@@ -141,7 +140,7 @@ function getDataFn(config: EnvironmentConfigurationType) {
         JudgeUdpBusinessInstance.sendData(byte, udpLsh)
       }
       udpIndex++
-      console.log(SerialPortTag, "后置机消息", data)
+      // console.log(SerialPortTag, "后置机消息", data)
       workerPort.postMessage(
         JSON.stringify({
           type: WorkerBackMessageType.ObtainUdpData,
@@ -154,7 +153,6 @@ function getDataFn(config: EnvironmentConfigurationType) {
     // TODO
     // 需要观察
     checkLsh()
-    dConsole.info("lixiao", data)
     switch (Number(data.id)) {
       case 32:
         signNum = data.body![1]
@@ -170,7 +168,6 @@ function getDataFn(config: EnvironmentConfigurationType) {
             } as WorkerBackMessage)
           )
         } else if (Number(data.body![0]) === 12) {
-          dConsole.info("lixiao", 12, data)
           workerPort.postMessage(
             JSON.stringify({
               type: WorkerBackMessageType.RemoteEndExam

entry/src/main/ets/workers/Log.ets

@@ -7,7 +7,8 @@ import fs from '@ohos.file.fs';
 
 const workerPort: ThreadWorkerGlobalScope = worker.workerPort;
 // 过程数据文件
-const fileNameArr: string[] = ["four_one_log_byte_data.txt", "four_one_log_data.txt", "judge_exam_data.txt", "judge_log_data.txt", "judge_progress_callback_data.txt", "plc_data.txt", "wuxi_exam_data.txt", "wuxi_progress_data.txt"]
+// "four_one_log_byte_data.txt", "four_one_log_data.txt",
+const fileNameArr: string[] = ["judge_exam_data.txt", "judge_log_data.txt", "judge_progress_callback_data.txt", "plc_data.txt", "wuxi_exam_data.txt", "wuxi_progress_data.txt"]
 // 过程数据fd
 let fileFdArr: number[] = []
 let writeQueue: Array<FileQueueType> = [];
@@ -29,6 +30,7 @@ workerPort.onmessage = (e: MessageEvents) => {
   }
   // 写过程数据
   if (result.type === WorkerMessageType.WriteProcessData && result.processDataType) {
+    console.log(LogTag, "work收到过程数据")
     WriteProcessData(result.processDataType, result.data || "")
   }
   //   关闭过程数据
@@ -82,21 +84,23 @@ async function InitExam(dirName: string) {
     await CreateDir(path);
   }
   //   创建几个文件
-  fileNameArr.forEach(async (item: string, index: number) => {
+  fileNameArr.forEach(async (item: string) => {
     let filePath = path + "/" + item
     console.log(LogTag, "创建文件", filePath)
     let result = await CreateFile(filePath)
-    fileFdArr[index] = result
+    // fileFdArr[index] = result
+    fileFdArr.push(result)
   })
 }
 
 // 写过程数据
 async function WriteProcessData(type: ProcessDataEnumType, data: string) {
-  // if (type === ProcessDataEnumType.WuxiExam) {
+  console.log(LogTag, "推入过程数据", type, data)
-  //   writeQueue.push({ type, data });
+  if (fileFdArr.length === 0) {
-  // } else {
+    return
+  }
   writeQueue.push({ type, data });
-  // }
+
   if (!isProcessing) {
     processQueue();
   }
@@ -104,23 +108,34 @@ async function WriteProcessData(type: ProcessDataEnumType, data: string) {
 
 async function processQueue() {
   isProcessing = true;
-  while (writeQueue.length > 0) {
+  while (writeQueue.length > 0 && isProcessing) {
+    console.log(LogTag, "处理过程数据")
     const item = writeQueue.shift()!;
     const index = Number(item.type);
+    try {
       await EditFile(fileFdArr[index], item.data);
+    } catch (e) {
+      console.error(LogTag, "写过程数据错误", JSON.stringify(e))
+    }
   }
   isProcessing = false;
 }
 
 // 关闭过程数据
 function CloseProcessData() {
+  writeQueue = []
+  isProcessing = false
   if (fileFdArr.length > 0) {
-    console.log(LogTag, "有文件需要 关闭过程数据")
+    console.log(LogTag, "有文件需要 关闭过程数据", fileFdArr)
     fileFdArr.forEach((item: number) => {
+      try {
         fs.closeSync(item)
-    })
+      } catch (e) {
-    fileFdArr = []
+        console.error(LogTag, JSON.stringify(e))
       }
+    })
+  }
+  fileFdArr = []
 }
 
 workerPort.onmessageerror = (e: MessageEvents) => {