fix: 过程数据写入文件,压测0.1秒同时写入8个文件,写1000次,cpu最大波动5%

entry/src/main/ets/mock/Test.ets

@@ -0,0 +1 @@
+export const ProcessDataMock:string="#DN_GD,$PLC,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,-0_0,0,0,0,0,0,0,0,0,511,0,0,0,0,0,0,0,0,0,0,0,0,15802,0,1,0_0_0_0,0.0.0.0,V9.1_V2.1_1,65535,0,0,0/0,15802/292,0,0/0,1,2,3,4,5,6,7,8,9,A,B,C,D,E,F,G,H,I,J,K,#END$GPS,1,16,6.068,1.301,0.000,1.07,0.64,+0.0000,+0.0000,0,091022,080109.20,3155.6715075,11851.9196718,0.012,#END"

entry/src/main/ets/mock/index.ets

@@ -7,3 +7,4 @@ export * from "./Judge"
 export * from "./SignDisplay"
 
 export * from "./CarCheck"
+export * from "./Test"

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

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

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

@@ -45,7 +45,7 @@ import dayTs from '../utils/Date';
 import { GetCurrentTime } from '../utils/Common';
 import FileUtils from '../utils/FileUtils';
 import SignalTrajectoryDialog from './Judge/SignalTrajectoryDialog';
-import { DefaultJudgeConfigData } from '../mock';
+import { DefaultJudgeConfigData, ProcessDataMock } from '../mock';
 import { dConsole } from '../utils/LogWorker';
 import ConfirmDialog from './compontents/ConfirmDialog';
 import CarLoadingDialog from './compontents/CarLoading';
@@ -206,7 +206,28 @@ struct JudgePage {
     this.startFullTime = GetCurrentTime(1);
     this.startTime = dayTs().format("YYYY-MM-DD HH:mm:ss")
     this.startExamTime = dayTs().format("YYYY-MM-DD HH:mm:ss")
-
+    // let count = 0;
+    // const totalTimes = 1000;
+    // const intervalTime = 100; // 0.1秒 = 100毫秒
+    //
+    // const timer = setInterval(() => {
+    //   if (count < totalTimes) {
+    //     dConsole.writeProcessData(ProcessDataEnumType.FourOneLogByteData, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.FourOneLogData, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.JudgeExamData, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.JudgeLogData, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.JudgeProgressCallbackData, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.PlcData, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.WuxiExam, ProcessDataMock);
+    //     dConsole.writeProcessData(ProcessDataEnumType.WuxiProgressData, ProcessDataMock);
+    //     count++;
+    //     console.log(`已调用 ${count} 次`);
+    //   } else {
+    //     dConsole.closeProcessData()
+    //     clearInterval(timer);
+    //     console.log('已完成1000次调用');
+    //   }
+    // }, intervalTime);
     //初始化数据库表
     await this.initDb()
     //断点续考
@@ -718,6 +739,7 @@ struct JudgePage {
           singlePlay: this.singlePlay,
           judgeConfigObj: this.judgeConfigObj,
           signalViewingClick: () => {
+            dConsole.writeProcessData(ProcessDataEnumType.FourOneLogByteData, '测试测试')
             this.signalTrajectoryDialogController.open()
           },
           artificialEvaluationClick: () => {

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

@@ -223,11 +223,9 @@ export function CreateDir(path: string): Promise<boolean> {
 export function EditFile(fd: number, data: string): Promise<boolean> {
   return new Promise((resolve, reject) => {
     try {
-      let result = fs.writeSync(fd, data + "\n")
-      console.log("创建文件之写文件成功", result.toString())
+      fs.writeSync(fd, data + "\n")
       resolve(true)
     } catch (e) {
-      console.log("创建文件之写文件失败")
       reject(false)
     }
   })

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

@@ -74,6 +74,15 @@ class logWorker {
       this.workerInstance?.postMessage(JSON.stringify(params))
     }
   }
+  // 关闭过程数据写入
+  closeProcessData(){
+    let params: LogWorkerMessage = {
+      type: WorkerMessageType.CloseProcessData,
+    }
+    if (this.isLogEnabled === "1") {
+      this.workerInstance?.postMessage(JSON.stringify(params))
+    }
+  }
 
   // 通用日志方法
   private logWithLevel(level: 'log' | 'info' | 'error', ...args: ESObject[]): void {

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

@@ -1,13 +1,22 @@
 import worker, { ErrorEvent, MessageEvents, ThreadWorkerGlobalScope } from '@ohos.worker';
 import { GlobalConfig } from '../config';
-import { LogFileFd, LogPathType, LogWorkerMessage, ProcessDataEnumType, WorkerMessageType } from '../model';
+import {
+  FileQueueType,
+  LogFileFd,
+  LogPathType,
+  LogWorkerMessage,
+  ProcessDataEnumType,
+  WorkerMessageType
+} from '../model';
 import { CreateDir, CreateFile, EditFile, IsExit } from '../utils/Common';
 import dayTs from '../utils/Date';
 import fs from '@ohos.file.fs';
 
 const workerPort: ThreadWorkerGlobalScope = worker.workerPort;
-const fileNameArr: string[] = ["four_one_log_byte_data.text", "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"]
+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"]
 let fileFdArr: number[] = []
+let writeQueue: Array<FileQueueType> = [];
+let isProcessing = false;
 workerPort.onmessage = (e: MessageEvents) => {
   console.log("日志系统worker收到消息")
   // 日志文件目录
@@ -15,7 +24,6 @@ workerPort.onmessage = (e: MessageEvents) => {
     log: `${GlobalConfig.commonFileWriteAddress}/logs/${dayTs().format("YYYY_MM_DD")}/log/log.log`,
     error: `${GlobalConfig.commonFileWriteAddress}/logs/${dayTs().format("YYYY_MM_DD")}/log/error.log`,
   }
-  let logFileFd: LogFileFd = {}
   const result: LogWorkerMessage = JSON.parse(e.data);
   if (result.type === WorkerMessageType.Init) {
     InitLog()
@@ -88,21 +96,29 @@ async function InitExam(dirName: string) {
 
 // 写过程数据
 async function WriteProcessData(type: ProcessDataEnumType, data: string) {
-  let index = Number(type)
-  console.log("创建文件",type,index.toString(),data)
-  let result=await EditFile(fileFdArr[index], data)
-  if(result){
-  //   写文件成功
-  }else{
-  //   写文件失败
+  writeQueue.push({ type, data });
+
+  if (!isProcessing) {
+    processQueue();
   }
 }
 
+async function processQueue() {
+  isProcessing = true;
+  while (writeQueue.length > 0) {
+    const item = writeQueue.shift()!;
+    const index = Number(item.type);
+    await EditFile(fileFdArr[index], item.data);
+  }
+  isProcessing = false;
+}
+
 // 关闭过程数据
 function CloseProcessData() {
   fileFdArr.forEach((item: number) => {
     fs.closeSync(item)
   })
+  console.log("关闭过程数据")
 }
 
 workerPort.onmessageerror = (e: MessageEvents) => {