21 changed files with 190 additions and 244 deletions
--- a/entry/oh-package-lock.json5
+++ b/entry/oh-package-lock.json5
@ -1,5 +1,5 @@
 {
-  "lockfileVersion": 2,
+  "lockfileVersion": 1,
  "ATTENTION": "THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.",
  "specifiers": {},
  "packages": {}
--- a/entry/src/main/ets/config/LogEnum.ets
+++ b/entry/src/main/ets/config/LogEnum.ets
@ -81,9 +81,3 @@ export const LogTag = '[LogWorker]';
 // 开始考试,结束考试标志
 export const StartEndExamTag = '[StartEndExam]';

-// Queue
-export const QueueTag = '[Queue]'
-
-// 考试过程数据
-export const ExamProcessDataTag = '[ExamProcessData]';
-
--- a/entry/src/main/ets/config/judge.ets
+++ b/entry/src/main/ets/config/judge.ets
@ -16,7 +16,7 @@ export const JudgeConfig: JudgeConfigType = {
  //是否开启拍照
  isPhotoOpen: true,
  //扣分语音是否强制开启
-  kfVoiceOpen: false,
+  kfVoiceOpen: true,
  //忽略的考试项目
  ignoreProjects: [],
  // 是否忽略考试前熄火、车门检查
--- a/entry/src/main/ets/model/Judge.ets
+++ b/entry/src/main/ets/model/Judge.ets
@ -433,8 +433,6 @@ export interface MAPPOINT {
  f_gps_e: number,
  f_gps_n: number,
  passed: number
-  X_MCH: string,
-
 }

 export interface MAPITEMPOINTITEM {
@ -560,7 +558,6 @@ export interface CAR_INFO {
  FLAG: string,
  BK1: string,
  BK2: string
-  X_MCH: string,
 }

 export interface KmItem {
@ -818,7 +815,7 @@ export interface DistanceClass {

 export interface WR {
  message?: string
-  code: string
+  code?: number
  keystr?: string
 }

--- a/entry/src/main/ets/model/ProcessData.ets
+++ b/entry/src/main/ets/model/ProcessData.ets
@ -1,38 +0,0 @@
-/**
- * 定义批次进度更新时的回调函数类型
- * @param totalTasks 本批次总任务数
- * @param completedTasks 已完成任务数 (成功 + 失败)
- * @param successfulTasks 成功完成的任务数
- * @param failedTasks 失败的任务数
- * @param progressPercentage 当前进度百分比 (0-100)
- */
-import { RegulatoryInterfaceParams, WR } from '.';
-
-export type OnBatchProgressUpdateCallback = (
-  totalTasks: number,
-  completedTasks: number,
-  successfulTasks: number,
-  failedTasks: number,
-  progressPercentage: number
-) => void;
-
-/**
- * 定义所有任务完成时的回调函数类型
- * @param totalTasks 本批次总任务数
- * @param completedTasks 已完成任务数 (成功 + 失败)
- * @param successfulTasks 成功完成的任务数
- * @param failedTasks 失败的任务数
- */
-export type OnAllTasksCompletedCallback = (
-  totalTasks: number,
-  completedTasks: number,
-  successfulTasks: number,
-  failedTasks: number
-) => void;
-
-export type ProgressCallback = (data: WR) => void;
-
-export interface QueueTask {
-  data: RegulatoryInterfaceParams;
-  callback?: ProgressCallback;
-}
--- a/entry/src/main/ets/model/api.ets
+++ b/entry/src/main/ets/model/api.ets
@ -248,7 +248,6 @@ export interface ObtainCarExamInfoParams {

 //监管接口参数
 export interface RegulatoryInterfaceParams {
-  JGHOST?: string
  xtlb?: string;
  jkxlh?: string;
  jkid?: string;
--- a/entry/src/main/ets/model/index.ets
+++ b/entry/src/main/ets/model/index.ets
@ -20,6 +20,4 @@ export * from "./TableColumn"

 export * from "./Other"

-export * from "./Worker"
-
-export * from "./ProcessData"
+export * from "./Worker"
--- a/entry/src/main/ets/pages/Judge.ets
+++ b/entry/src/main/ets/pages/Judge.ets
@ -23,6 +23,7 @@ import {
  LANE,
  MA_CDSBINFOType,
  MA_ITEMINFOType,
+  MA_SYSTEMPARMType,
  MAPITEMPOINTITEM,
  MAPPOINT,
  MarkRule,
@ -161,7 +162,6 @@ export struct JudgePage {
    customStyle: true
  })
  // private judge: Judge = new Judge(this)
-  private judgeBusiness = new JudgeBusiness(this)
  // 结束考试弹窗
  endExamDialogController: CustomDialogController = new CustomDialogController({
    builder: ConfirmDialog({
@ -194,9 +194,10 @@ export struct JudgePage {
    }),
    customStyle: true
  })
+  private judgeBusiness = new JudgeBusiness(this)

  laneSignalChange() {
-    // dConsole.log("车道信号变化1", this.laneSignal)
+    dConsole.log("车道信号变化1", this.laneSignal)
  }

  async aboutToDisappear() {
@ -260,7 +261,6 @@ export struct JudgePage {
      FLAG: carInfo.flag!,
      BK1: carInfo.bk1!,
      BK2: carInfo.bk2!,
-      X_MCH: carInfo.x_mch || "",
    })
    dConsole.info(JudgeTag, 'surenjun =>carinfoArrr', JSON.stringify(this.carinfoArr))
  }
--- a/entry/src/main/ets/pages/Judge/BaseJudgeBussines.ets
+++ b/entry/src/main/ets/pages/Judge/BaseJudgeBussines.ets
@ -1,4 +1,5 @@
 import {
+  CarInfoType,
  JudgeBeginObj,
  JudgeCallBackData,
  JudgeConfigObj,
@ -11,14 +12,13 @@ import {
  ProjectInfo,
  ProjectInfos,
  SYSTEM_PARAM,
-  User,
-  WR
+  User
 } from '../../model'
 import JudgeBusiness from './JudgeBusiness'
 import { JudgePage } from '../Judge'
 import VoiceAnnounce from '../judgeSDK/utils/voiceAnnouncements'
 import { dConsole } from '../../utils/LogWorker'
-import { ExamProcessDataTag, JudgeConfig, JudgeTag, QueueTag } from '../../config'
+import { JudgeConfig, JudgeTag } from '../../config'
 import {
  examJudgeArtificialItem,
  examJudgeBeginExam,
@ -29,7 +29,7 @@ import {
  examJudgeSetRealExamCallback,
  examJudgeSoundEnd
 } from './JudgeSDKUtils'
-import { DeductPoints, ProjectEnd, ProjectStart, TheExamIsOver, UploadProgressPhoto } from './ProcessDataProcessing'
+import { ProjectStart, UploadProgressPhoto } from './ProcessDataProcessing'
 import { endRecordVideo, saveStartRecordVideo } from '../../utils/Video'
 import router from '@ohos.router'
 import { GetSyncData, UpdateTableByArray } from '../../utils/table/Operation'
@ -110,31 +110,19 @@ export class BaseJudge {
          }
        }, 200)
        if (!project.isEnd) {
-          // judgeTask.addTask(async () => {
-          //   console.info(judgeTag, `项目开始-${xmdm}-${projectsObj[xmdm].name}`)
-          //   await beginProject(xmdm, xmxh)
-          // }, {
-          //   isDelay: true
-          // })
-          // judgeTask.addTask(async () => {
-          //   console.info(judgeTag, `项目-${xmdm}-上传照片 start`)
-          //   await uploadProgressPhoto(xmdm)
-          // }, {
-          //   isDelay: true
-          // })
          ProjectStart(xmdm, that.xmxh, judgeUI)
          UploadProgressPhoto(xmdm, that.plcData!, judgeUI)
        }
        break;
      }
      case 2: {
-        dConsole.log(JudgeTag, ExamProcessDataTag, "项目结束判定1")
+        dConsole.log(JudgeTag, "项目结束判定1")
        const project: ProjectInfo = Reflect.get(judgeUI.projectsObj, xmdm)
        const isStart = await this.checkProjectIsStart(xmdm, 2, judgeUI, that)

        if (isStart) {
          // 项目结束了就不再生成数据
-          dConsole.info(JudgeTag, ExamProcessDataTag, ' 项目是否结束 =>', project.isEnd)
+          dConsole.info(JudgeTag + ' projectIsEnd =>', project.isEnd)
          if (!project.isEnd) {
            // judgeTask.addTask(async () => {
            //   dConsole.info(JudgeTag, `项目结束-${xmdm}-${project.name}`)
@ -144,10 +132,9 @@ export class BaseJudge {
            // }, {
            //   isDelay: true
            // })
-            ProjectEnd(xmdm, that.xmxh, judgeUI)
          }
        }
-        dConsole.log(JudgeTag, ExamProcessDataTag, "项目结束判定3")
+        dConsole.log(JudgeTag, "项目结束判定3")
        try {
          const param512: JudgeConfigObj = (Reflect.get(judgeUI.judgeConfigObj, '512') || '').split(',');
          if (!judgeUI.isProjectIn) {
@ -177,24 +164,16 @@ export class BaseJudge {
          // }, {
          //   isDelay: true
          // })
-          DeductPoints(Number(currentKf.xmdm), currentKf, that.xmmcEndCode || "", judgeUI)
        }
        break
      }
      case 5: {
-        dConsole.log(JudgeTag, QueueTag, "考试结束")
+        dConsole.log(JudgeTag, "考试结束")
        const singlePlay = AppStorage.get<boolean>('singlePlay')
        //   关闭录像
        if (!singlePlay && that.videoData) {
          await endRecordVideo(that.videoData)
        }
-        // TODO
-        // ProcessDataTaskPoolInstance.setOnAllTasksCompletedCallback((data) => {
-        //   if (event === 5) {
-        //     dConsole.log(JudgeTag, QueueTag, "这才是考试结束判定")
-        //   }
-        //   dConsole.log(JudgeTag, QueueTag, "考试结束判断", data)
-        // })
        // judgeTask.addTask(async () => {
        //   dConsole.info(JudgeTag, '考试结束 start')
        //   AppStorage.setOrCreate('isJudge', false)
@ -377,36 +356,51 @@ export class BaseJudge {
      } catch (e) {
        console.info(JudgeTag, JSON.stringify(e))
      }
-      TheExamIsOver(judgeUI, that, async (res: WR) => {
-        dConsole.log(JudgeTag, ExamProcessDataTag, "考试结束接口完成", res)
-        const code = res.code!.toString()
-        if (code !== "1") {
-          that?.avPlayer?.playAudio(['voice/监管失败.mp3'])
-          judgeUI.errorMsg = decodeURIComponent(res?.message || "")
-
-          if (code.toString() === "2300028" || code.toString() === "2300007") {
-            judgeUI.errorMsg = '当前的考试过程信息监管审核未通过，程序将退出！'
-          }
-          judgeUI.generateExamRecordsDialogController.close();
-          return
-        } else {
-          await this.endExam(judgeUI, that)
-        }
-      })
      await this.endExam(judgeUI, that)
    })
  }

  // 考试结束 Todo
  async endExam(judgeUI: JudgePage, that: JudgeBusiness) {
+    const carInfo: CarInfoType = AppStorage.get("carInfo")!
    const singlePlay = judgeUI.singlePlay
    //TODO 断网考试结束补传
    // await uploadDisConnectData();
-
+    // const time = GetCurrentTime();
+    // const photoBase64 = await getPhoto();
+    // const {d1,d2,d3,d4,d5} = that.ksjs
+    // const data = {
+    //   xtlb: '17', jkxlh: serialNumber, jkid: '17C56',
+    //   drvexam: {
+    //     lsh,
+    //     kchp: encodeURI(plateNo),
+    //     kskm: examSubject,
+    //     sfzmhm: idCard,
+    //     //@ts-ignore
+    //     zp: photoBase64,
+    //     jssj: time,
+    //     kscj: (totalScore * 1) > 0 ? totalScore : 0,
+    //     kslc: Math.ceil(((ksjs?.qjjl + ksjs?.dcjl) || 0) / 100),
+    //     // 1,22;2,560;3,128;4,0;5,0;
+    //     dwlc: [d1, d2, d3, d4, d5].map((d, index) => `${index + 1},${Math.floor(d / 100)}`).join(';'),
+    //   }
+    // }
    let backTimeOut = setTimeout(() => {
      router.back()
    }, 90 * 1000)
+    // const {code,keystr,message} = await this.sendWriteObjectOut(data, filePath);
+    // promptWxCode('17C56', code)

+    // if (code != 1) {
+    //   that.avPlayer.playAudio(['voice/监管失败.mp3'])
+    //   judgeUI.errorMsg = decodeURIComponent(message)
+    //
+    //   if (code == 2300028 || code == 2300007) {
+    //     judgeUI.errorMsg = '当前的考试过程信息监管审核未通过，程序将退出！'
+    //   }
+    //   judgeUI.generateExamRecordsDialogController.close();
+    //   return
+    // }
    console.info(JudgeTag, '考试结束 end')
    const param302 = judgeUI.judgeConfigObj.param_302;
    let currentKssycs = 0;
@ -457,6 +451,7 @@ export class BaseJudge {
        case 'voice/exam_pass.mp3':
          currentKssycs = 0;
          break;
+
      }
    }

@ -519,7 +514,7 @@ export class BaseJudge {
    }
    const currentProject: ProjectInfo = Reflect.get(judgeUI.projectsObj, xmdm)

-    if (!currentProject.isUpload) {
+    if (currentProject.isUpload) {
      dConsole.info(JudgeTag, '项目补传开始')
      // judgeTask.addTask(async () => {
      //   await this.beginProject(xmdm)
@ -575,7 +570,7 @@ export class BaseJudge {
    }
    //日志回调
    dConsole.info(JudgeTag, '1.进入评判入口')
-    await examJudgeSetLogCallback(1, async (level: number, info: string, len: number) => {
+    await examJudgeSetLogCallback(6, async (level: number, info: string, len: number) => {
      dConsole.log(JudgeTag, '评判日志：' + info)
      dConsole.writeProcessData(ProcessDataEnumType.JudgeLogData, info)
    })
@ -598,7 +593,7 @@ export class BaseJudge {
      await this.judging(strData, callBack, judgeUI, that)
    })
    await examJudgeSetPerformCallback(async (info: string) => {
-      // dConsole.info('评判实时数据', info)
+      dConsole.info('评判实时数据', info)
      that.performInfo = JSON.parse(info)
      const jl = Math.floor((that.performInfo!.qjjl + that.performInfo!.dcjl) / 100);
      if (jl > Number(judgeUI.examMileage)) {
@ -740,6 +735,9 @@ export class BaseJudge {
      case 5: {
        dConsole.info(JudgeTag, "考试结束")
        that.ksjs = ksjs;
+        // await fileLog?.setExamJudgeData(JSON.stringify({
+        //   method: 'examJudgeEndExam'
+        // }))
        dConsole.writeProcessData(ProcessDataEnumType.JudgeExamData, JSON.stringify({
          method: 'examJudgeEndExam'
        }))
--- a/entry/src/main/ets/pages/Judge/ProcessDataProcessing.ets
+++ b/entry/src/main/ets/pages/Judge/ProcessDataProcessing.ets
@ -1,15 +1,15 @@
 /**
 * 过程数据处理
 */
-import { ExamProcessDataTag, ProcessDataTag, QueueTag } from '../../config';
+import { ProcessDataTag } from '../../config';
 import {
  CarInfoType,
  CDSBInfo,
  CDSBInfos,
  DrvexamType,
+  JudgeUI,
  MarkRule,
  PLCType,
-  ProgressCallback,
  ProjectInfo,
  RegulatoryInterfaceParams
 } from '../../model';
@ -17,7 +17,6 @@ import { GetPhotoBase64 } from '../../utils/Common';
 import dayTs from '../../utils/Date';
 import { dConsole } from '../../utils/LogWorker';
 import { JudgePage } from '../Judge';
-import JudgeBusiness from './JudgeBusiness';
 import { ProcessDataTaskPoolInstance } from './ProcessDataTaskPool';

 /**
@ -40,14 +39,13 @@ export const ProjectStart = (ksxm: number, xmxh: string, judgeUI: JudgePage) =>
    kssj: dayTs().format("YYYY-MM-DD HH:mm:ss")
  }
  const data: RegulatoryInterfaceParams = {
-    JGHOST: AppStorage.get<string>("JGHOST") || "",
    //系统类别   接口序列号             接口标识
    xtlb: '17',
    jkxlh: judgeUI.serialNumber,
    jkid: '17C52',
    drvexam
  }
-  dConsole.log(ProcessDataTag, QueueTag, ExamProcessDataTag, "项目开始数据处理", data)
+  dConsole.log(ProcessDataTag, "项目开始数据处理", data)
  ProcessDataTaskPoolInstance.addTask(data)
 }

@ -71,13 +69,12 @@ export const UploadProgressPhoto = async (ksxm: number, plcData: PLCType, judgeU
    ksdd: encodeURI(judgeUI.ksdd)
  }
  const data: RegulatoryInterfaceParams = {
-    JGHOST: AppStorage.get<string>("JGHOST") || "",
    xtlb: '17',
    jkxlh: judgeUI.serialNumber,
    jkid: '17C54',
    drvexam
  };
-  dConsole.log(ProcessDataTag, QueueTag, ExamProcessDataTag, "上传过程照片数据处理", data);
+  dConsole.log(ProcessDataTag, "上传过程照片数据处理", data);
  ProcessDataTaskPoolInstance.addTask(data)
 }

@ -134,13 +131,12 @@ export const DeductPoints = (ksxm: number, kf: MarkRule, xmmcEndCode: string, ju
    kfsj: dayTs().format("YYYY-MM-DD HH:mm:ss"),
  }
  const data: RegulatoryInterfaceParams = {
-    JGHOST: AppStorage.get<string>("JGHOST") || "",
    xtlb: '17',
    jkxlh: serialNumber,
    jkid: '17C53',
    drvexam
  }
-  dConsole.log(ProcessDataTag, QueueTag, ExamProcessDataTag, "扣分上传数据", data)
+  dConsole.log(ProcessDataTag, "扣分上传数据", data)
  ProcessDataTaskPoolInstance.addTask(data)
 }

@ -167,45 +163,14 @@ export const ProjectEnd = (ksxm: number, xmxh: string, judgeUI: JudgePage) => {
  }
  const data: RegulatoryInterfaceParams = {
    xtlb: '17',
-    JGHOST: AppStorage.get<string>("JGHOST") || "",
    jkxlh: judgeUI.serialNumber,
    jkid: '17C55',
    drvexam
  }
-  dConsole.log(ProcessDataTag, QueueTag, ExamProcessDataTag, "结束项目数据", data)
+  dConsole.log(ProcessDataTag, "结束项目数据", data)
  ProcessDataTaskPoolInstance.addTask(data)
 }

-/**
- * 考试结束接口
- * @returns
- */
-export const TheExamIsOver = async (judgeUI: JudgePage, that: JudgeBusiness, callback: ProgressCallback) => {
-  const carInfo: CarInfoType = AppStorage.get("carInfo")!
-  const photoBase64 = await GetPhotoBase64(judgeUI.context);
-  const ksjs = that.ksjs!
-  const data: RegulatoryInterfaceParams = {
-    JGHOST: AppStorage.get<string>("JGHOST") || "",
-    xtlb: '17',
-    jkxlh: judgeUI.serialNumber,
-    jkid: '17C56',
-    drvexam: {
-      lsh: judgeUI.lsh,
-      kchp: encodeURI(carInfo?.plateNo || ""),
-      kskm: carInfo?.examSubject || "2",
-      sfzmhm: judgeUI.idCard,
-      zp: photoBase64,
-      jssj: dayTs().format("YYYY-MM-DD HH:mm:ss"),
-      kscj: (judgeUI.totalScore * 1) > 0 ? judgeUI.totalScore : 0,
-      kslc: Math.ceil(((ksjs?.qjjl! + ksjs?.dcjl!) || 0) / 100),
-      dwlc: [ksjs.d1, ksjs.d2, ksjs.d3, ksjs.d4, ksjs!.d5].map((d, index) => `${index + 1},${Math.floor(d / 100)}`)
-        .join(';'),
-    }
-  }
-  dConsole.log(ProcessDataTag, QueueTag, ExamProcessDataTag, "考试结束数据", data)
-  ProcessDataTaskPoolInstance.addTask(data, callback)
-}
-

 const getSBXH = (ksxm: number, xmxh: string, cdsbInfoObj: CDSBInfos, projectsObj: object, examSubject: string): string => {
  const project: ProjectInfo = Reflect.get(projectsObj, ksxm);
--- a/entry/src/main/ets/pages/Judge/ProcessDataTaskPool.ets
+++ b/entry/src/main/ets/pages/Judge/ProcessDataTaskPool.ets
@ -1,22 +1,42 @@
-import {
-  OnAllTasksCompletedCallback,
-  OnBatchProgressUpdateCallback,
-  ProcessDataEnumType,
-  ProgressCallback,
-  QueueTask,
-  RegulatoryInterfaceParams,
-  WR,
-  WuxiExamType
-} from '../../model';
+import { ProcessDataEnumType, RegulatoryInterfaceParams, WR, WuxiExamType } from '../../model';
 import taskpool from '@ohos.taskpool';
-import { QueueTag } from '../../config';
+import { dConsole } from '../../utils/LogWorker';
 import http from '@ohos.net.http';
 import Request from '../../utils/Request';
-import { dConsole } from '../../utils/LogWorker';
+
+/**
+ * 定义批次进度更新时的回调函数类型
+ * @param totalTasks 本批次总任务数
+ * @param completedTasks 已完成任务数 (成功 + 失败)
+ * @param successfulTasks 成功完成的任务数
+ * @param failedTasks 失败的任务数
+ * @param progressPercentage 当前进度百分比 (0-100)
+ */
+export type OnBatchProgressUpdateCallback = (
+  totalTasks: number,
+  completedTasks: number,
+  successfulTasks: number,
+  failedTasks: number,
+  progressPercentage: number
+) => void;
+
+/**
+ * 定义所有任务完成时的回调函数类型
+ * @param totalTasks 本批次总任务数
+ * @param completedTasks 已完成任务数 (成功 + 失败)
+ * @param successfulTasks 成功完成的任务数
+ * @param failedTasks 失败的任务数
+ */
+export type OnAllTasksCompletedCallback = (
+  totalTasks: number,
+  completedTasks: number,
+  successfulTasks: number,
+  failedTasks: number
+) => void;


 export class ProcessDataTaskPool {
-  private queue: QueueTask[] = [];
+  private queue: RegulatoryInterfaceParams[] = [];
  private isProcessing: boolean = false;
  /** 最大重试次数。1次初次尝试 + 5次重试 = 总共6次尝试。 */
  private readonly maxRetries = 5;
@ -57,9 +77,9 @@ export class ProcessDataTaskPool {
   * 进而影响 `onAllTasksCompletedCallback` 的触发时机和进度计算。
   * @param dataItem 任务数据
   */
-  public addTask(dataItem: RegulatoryInterfaceParams, callback?: ProgressCallback): void {
-    console.info(QueueTag, `新任务已添加: ${JSON.stringify(dataItem)}，当前队列长度: ${this.queue.length + 1}`);
-    this.queue.push({ data: dataItem, callback: callback }); // 将任务添加到队尾
+  public addTask(dataItem: RegulatoryInterfaceParams): void {
+    console.info(`[Queue] 新任务已添加: ${JSON.stringify(dataItem)}，当前队列长度: ${this.queue.length + 1}`);
+    this.queue.push(dataItem); // 将任务添加到队尾

    // 每次添加任务，增加当前批次的总任务数
    this.totalTasksInCurrentBatch++;
@ -72,7 +92,7 @@ export class ProcessDataTaskPool {
   */
  private triggerProcessing(): void {
    if (this.isProcessing) {
-      console.log(QueueTag, '处理器正在运行中，新任务将在稍后被处理。');
+      console.log('[Queue] 处理器正在运行中，新任务将在稍后被处理。');
      return;
    }
    this.processQueue();
@ -80,16 +100,14 @@ export class ProcessDataTaskPool {

  private async processQueue(): Promise<void> {
    this.isProcessing = true;
-    console.log(QueueTag, `启动处理器... 待处理任务数: ${this.queue.length}`);
+    console.log(`[Queue] 启动处理器... 待处理任务数: ${this.queue.length}`);

    while (this.queue.length > 0) {
-      const taskData = this.queue[0].data; // 查看队首任务
-      const callback = this.queue[0].callback || (() => {
-      });
+      const taskData = this.queue[0]; // 查看队首任务
      this.taskStartTime = Date.now(); // 记录任务开始时间

      try {
-        console.log(QueueTag, `开始处理任务: ${JSON.stringify(taskData)}`);
+        console.log(`[Queue] 开始处理任务: ${JSON.stringify(taskData)}`);

        const obj: WuxiExamType = {
          xtlb: taskData.xtlb,
@ -101,15 +119,15 @@ export class ProcessDataTaskPool {
        };
        dConsole.writeProcessData(ProcessDataEnumType.WuxiExam, JSON.stringify(obj));

-        await this.processSingleTaskWithRetries(taskData, callback);
+        await this.processSingleTaskWithRetries(taskData);

        // 任务成功
        this.queue.shift();
-        console.log(QueueTag, `✅ 任务处理成功，已从队列移除。剩余任务: ${this.queue.length}`);
+        console.log(`[Queue] ✅ 任务处理成功，已从队列移除。剩余任务: ${this.queue.length}`);
        this.successfulTasksInCurrentBatch++; // 增加成功任务计数
      } catch (error) {
        // 任务永久失败
-        console.error(QueueTag, ` 🔥 任务永久失败: ${(error as Error).message}`);
+        console.error(`[Queue] 🔥 任务永久失败: ${(error as Error).message}`);
        const failedTask = this.queue.shift(); // 移除失败的任务
        console.error(`[Queue] 失败的任务已被移除: ${JSON.stringify(failedTask)}，将继续处理下一个任务。`);
        this.failedTasksInCurrentBatch++; // 增加失败任务计数
@ -122,7 +140,7 @@ export class ProcessDataTaskPool {

        // 检查是否所有任务都已处理完
        if (this.queue.length === 0 && this.completedTasksInCurrentBatch === this.totalTasksInCurrentBatch) {
-          console.log(QueueTag, ' 所有任务处理完毕！"总数', this.totalTasksInCurrentBatch, "完成的");
+          console.log('[Queue] 所有任务处理完毕！');
          this.onAllTasksCompletedCallback?.(
            this.totalTasksInCurrentBatch,
            this.completedTasksInCurrentBatch,
@ -137,14 +155,14 @@ export class ProcessDataTaskPool {
        const elapsedTime = Date.now() - this.taskStartTime;
        if (elapsedTime < this.minProcessingTime) {
          const delayTime = this.minProcessingTime - elapsedTime;
-          console.log(QueueTag, ` 任务处理耗时 ${elapsedTime}ms，需要延迟 ${delayTime}ms 以满足最小处理时间要求`);
+          console.log(`[Queue] 任务处理耗时 ${elapsedTime}ms，需要延迟 ${delayTime}ms 以满足最小处理时间要求`);
          await this.delay(delayTime);
        }
      }
    }

    this.isProcessing = false;
-    console.log(QueueTag, ' 处理器已停止。');
+    console.log('[Queue] 处理器已停止。');
  }

  /**
@ -181,22 +199,23 @@ export class ProcessDataTaskPool {
    return new Promise(resolve => setTimeout(resolve, ms));
  }

-  private async processSingleTaskWithRetries(taskData: RegulatoryInterfaceParams, callback: ProgressCallback): Promise<void> {
+  private async processSingleTaskWithRetries(taskData: RegulatoryInterfaceParams): Promise<void> {
    for (let attempt = 0; attempt <= this.maxRetries; attempt++) {
      const attemptNum = attempt + 1;
      try {
        const attemptType = attempt === 0 ? '初次尝试' : `重试 ${attempt}`;
-        console.log(QueueTag, `开始上传 (${attemptType}, 总共第 ${attemptNum} 次)`);
+        console.log(`[Queue] 开始上传 (${attemptType}, 总共第 ${attemptNum} 次)`);
+
        const result: WR = (await taskpool.execute(uploadWorkerTask, taskData)) as WR;
-        callback(result)
+
        dConsole.writeProcessData(ProcessDataEnumType.WuxiExam, JSON.stringify(result));
-        if (result.code === "1") {
-          console.log(QueueTag, ` ✔️ 上传成功 (在第 ${attemptNum} 次尝试)`);
+        if (result.code === 1) {
+          console.log(`[Queue] ✔️ 上传成功 (在第 ${attemptNum} 次尝试)`);
          return; // 成功，立即返回
        }
-        console.warn(QueueTag, ` ❌ 上传失败 (第 ${attemptNum} 次)。${result.code},响应: ${decodeURIComponent(result.message)}`);
+        console.warn(`[Queue] ❌ 上传失败 (第 ${attemptNum} 次)。响应: ${result.message}`);
      } catch (e) {
-        console.error(QueueTag, ` ❌ TaskPool 执行或网络错误 (第 ${attemptNum} 次): ${e}`);
+        console.error(`[Queue] ❌ TaskPool 执行或网络错误 (第 ${attemptNum} 次): ${e}`);
      }

      if (attempt === this.maxRetries) {
@ -210,39 +229,40 @@ export class ProcessDataTaskPool {

 export const ProcessDataTaskPoolInstance = new ProcessDataTaskPool();

-@Concurrent
 export async function uploadWorkerTask(data: RegulatoryInterfaceParams): Promise<WR> {
  let singlePlay: boolean = false;
  let isJGNew = false;
  try {
-    const sendProcessData = async (data: RegulatoryInterfaceParams, singlePlay: boolean, isJGNew: boolean): Promise<WR> => {
-      if (singlePlay) {
-        return { code: "1" }
-      }
-      if (isJGNew) {
-        //   调用新监管
-      }
-      data.drvexam = data.drvexam ?? {};
-      if (data.drvexam.zp !== undefined && data.drvexam.zp !== null) {
-        data.drvexam.zp = encodeURIComponent(data.drvexam.zp);
-      }
-
-      const drvexamArr = Object.entries(data.drvexam)
-        .filter((item: [string, string]) => item[1] != undefined)
-        .map((item: [string, object]) => `<${item[0]}>${item[1]}</${item[0]}>`)
-      return await Request<object>({
-        host: data.JGHOST,
-        url: '/dems_ws/services/TmriOutAccess?wsdl',
-        data: `<?xml version="1.0"?> <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xs="http://www.w3.org/2001/XMLSchema-instance" > <SOAP-ENV:Body> <writeObjectOut  xmlns="http://service.es.doron"> <xtlb>${data.xtlb}</xtlb> <jkxlh>${data.jkxlh}</jkxlh> <jkid>${data.jkid}</jkid> <UTF8XmlDoc> <![CDATA[ <?xm lversion="1.0 "encoding="GBK"?> <root> <drvexam> ${drvexamArr.join('')} </drvexam> </root> ]]> </UTF8XmlDoc> </writeObjectOut> </SOAP-ENV:Body> </SOAP-ENV:Envelope>`,
-        method: http.RequestMethod.POST,
-        xml: true
-      }) as WR
-    }
    const response = await sendProcessData(data, singlePlay, isJGNew);
    return response;
  } catch (err) {
    const error = err as Error;
-    console.error(QueueTag, `[Worker] 上传时发生异常: ${error.message}`);
+    console.error(`[Worker] 上传时发生异常: ${error.message}`);
    throw error;
  }
 }
+
+async function sendProcessData(data: RegulatoryInterfaceParams, singlePlay: boolean, isJGNew: boolean): Promise<WR> {
+  if (singlePlay) {
+    return { code: 1 }
+  }
+  if (isJGNew) {
+    //   调用新监管
+  }
+  data.drvexam = data.drvexam ?? {};
+  if (data.drvexam.zp !== undefined && data.drvexam.zp !== null) {
+    data.drvexam.zp = encodeURIComponent(data.drvexam.zp);
+  }
+
+  const drvexamArr = Object.entries(data.drvexam)
+    .filter((item: [string, string]) => item[1] != undefined)
+    .map((item: [string, object]) => `<${item[0]}>${item[1]}</${item[0]}>`)
+  let JGHOST: string = AppStorage.get<string>("JGHOST") || ""
+  return await Request<object>({
+    host: JGHOST,
+    url: '/dems_ws/services/TmriOutAccess?wsdl',
+    data: `<?xml version="1.0"?> <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xs="http://www.w3.org/2001/XMLSchema-instance" > <SOAP-ENV:Body> <writeObjectOut  xmlns="http://service.es.doron"> <xtlb>${data.xtlb}</xtlb> <jkxlh>${data.jkxlh}</jkxlh> <jkid>${data.jkid}</jkid> <UTF8XmlDoc> <![CDATA[ <?xm lversion="1.0 "encoding="GBK"?> <root> <drvexam> ${drvexamArr.join('')} </drvexam> </root> ]]> </UTF8XmlDoc> </writeObjectOut> </SOAP-ENV:Body> </SOAP-ENV:Envelope>`,
+    method: http.RequestMethod.POST,
+    xml: true
+  })
+}
--- a/entry/src/main/ets/pages/Judge/SmallJudgeBusiness.ets
+++ b/entry/src/main/ets/pages/Judge/SmallJudgeBusiness.ets
@ -15,25 +15,43 @@ import {
  MAPITEMPOINTITEM,
  MAPPOINT,
  MarkRule,
-  Project,
+  ProcessDataEnumType,
  ProjectInfo,
-  ProjectInfos,
  RouteParamsType,
  SyssetConfig,
-  SYSTEM_PARAM
+  SYSTEM_PARAM,
+  Project,
+  ProjectInfos,
+  JudgeCallBackData,
+  KmItem
 } from '../../model';
 import common from '@ohos.app.ability.common';
 import { dConsole } from '../../utils/LogWorker';
-import { examJudgeVersion } from './JudgeSDKUtils';
+import {
+  examJudgeBeginExam,
+  examJudgeEndExam,
+  examJudgeInit,
+  examJudgeSetLogCallback,
+  examJudgeSetPerformCallback,
+  examJudgeSetRealExamCallback,
+  examJudgeVersion
+} from './JudgeSDKUtils';
 import JudgeBusiness from './JudgeBusiness';
+import { saveStartRecordVideo } from '../../utils/Video';
 import router from '@ohos.router';
-import { GetModelData } from './utils';
+import {
+  CurrentProjectConversion,
+  DeductionProjectConversion,
+  DetectingDifferences,
+  GetCarStatus,
+  GetModelData
+} from './utils';
 import { BaseJudge, BaseJudgeImpl, GetSysSetResult } from './BaseJudgeBussines';
 import { GetSyncData } from '../../utils/table/Operation';
 import promptAction from '@ohos.promptAction';
 import { JudgePage } from '../Judge';
 import systemDateTime from '@ohos.systemDateTime';
-import { testKm2Items, testKm3Items } from '../../mock/Judge';
+import { testKm2Items, testKm3Items } from "../../mock/Judge"

 export class SmallJudge extends BaseJudge implements BaseJudgeImpl {
  public async GetJudgeBeginData(projects: Project[], carType: string, kssycs: string, isDdxk: boolean, ddxkTime: number, projectsCenterObj: Object, ddxkKsxmArr: string[], ddxkKfArr: string[], passingScore: number, wayno: number, name: string, lsh: string, idCard: string, isExam: boolean) {
@ -115,11 +133,10 @@ export class SmallJudge extends BaseJudge implements BaseJudgeImpl {
    }

    //获取版本号
-    // const mark: MarkRule[] = Reflect.ownKeys(markRuleListObj).map(ruleKey => {
-    //   const current: MarkRule = Reflect.get(markRuleListObj, ruleKey)
-    //   return current
-    // })
-    const mark: MarkRule[] = Object.values(markRuleListObj)
+    const mark: MarkRule[] = Reflect.ownKeys(markRuleListObj).map(ruleKey => {
+      const current: MarkRule = Reflect.get(markRuleListObj, ruleKey)
+      return current
+    })
    const initInfo: JudgeInitObj = {
      sdkver: await examJudgeVersion(),
      appver: AppStorage.get<BaseInfoType>('baseInfo')?.version || "",
--- a/entry/src/main/ets/pages/UserInfo.ets
+++ b/entry/src/main/ets/pages/UserInfo.ets
@ -274,7 +274,6 @@ struct UserInfoPage {
          res.id = index.toString()
        })
        await SqlInsertTable("USERLIST", this.list || [])
-
      } else {
        await this.getExaminationStudentInfoFn()
      }
--- a/entry/src/main/ets/utils/LogWorker.ets
+++ b/entry/src/main/ets/utils/LogWorker.ets
@ -13,7 +13,7 @@ class logWorker {
  public currentExamCatalog: string = ""
  private workerInstance: worker.ThreadWorker | null = null;
  // 是否开启日志 1开启
-  private isLogEnabled: string = "1";
+  private isLogEnabled: string = "0";

  constructor() {
    if (logWorker.instance) {
--- a/entry/src/main/ets/utils/Request.ets
+++ b/entry/src/main/ets/utils/Request.ets
@ -145,7 +145,7 @@ type RequestResult = Object | object | string | CenterCodeResult

 export default function Request<T extends RequestResult>(options: RequestOption): Promise<T> {
  return new Promise((resolve, reject) => {
-    const base: string = options.host ? options.host : AppStorage.get<string>("host") || "http://127.0.0.1"
+    const base: string = AppStorage.get<string>("host") || "http://127.0.0.1"
    const instance = http.createHttp()
    const baseURL = options.host || base
    console.log(RequestTag, "基础url:", baseURL)
--- a/entry/src/main/ets/utils/UdpUtils.ets
+++ b/entry/src/main/ets/utils/UdpUtils.ets
@ -144,7 +144,7 @@ export default class UdpClient {
  private bindEvent() {
    this.udp?.on("message", value => {
      let result = this.dealMethod?.(value.message)
-      // console.log(UDPTag, "udp获取消息", result)
+      console.log(UDPTag, "udp获取消息", result)
      this.messageEvents.forEach(cb => {
        cb(result)
      })
--- a/entry/src/main/ets/utils/business/DifferentialAndSignalWorker.ets
+++ b/entry/src/main/ets/utils/business/DifferentialAndSignalWorker.ets
@ -72,8 +72,8 @@ class differentialAndSignal {
  getMessage() {
    this.workerInstance.onmessage = (e: MessageEvents): void => {
      if (e.data) {
-        // console.log(WorkerTag, "Worker 收到消息: " + e.data);
-        // console.log(WorkerTag, "Worker 目前监听数量: " + this.events.length.toString());
+        console.log(WorkerTag, "Worker 收到消息: " + e.data);
+        console.log(WorkerTag, "Worker 目前监听数量: " + this.events.length.toString());
        this.events.forEach((callback) => {
          callback(e.data);
        });
--- a/entry/src/main/ets/utils/business/DifferentialSignal.ets
+++ b/entry/src/main/ets/utils/business/DifferentialSignal.ets
@ -1,7 +1,6 @@
 //差分信号
 import { TCPTag } from '../../config';
 import { EnvironmentConfigurationType } from '../../model';
-import { dConsole } from '../LogWorker';
 import TcpClient from '../TcpUtils';

 class differentialSignal {
@ -17,7 +16,7 @@ class differentialSignal {
      console.error(TCPTag, "TCP发生错误")
      this.differentialSignalTcp.reBind()
    })
-    dConsole.low(TCPTag, "初始化", JSON.stringify(config))
+    console.log(TCPTag, "初始化", JSON.stringify(config))
    if (config.tcplocalIp || config.tcplocalIpPort || config.tcpOppositeIp || config.tcpOppositePort) {
      this.differentialSignalTcp.init(config.tcplocalIp || "", config.tcplocalIpPort || "", config.tcpOppositeIp || "",
        config.tcpOppositePort || "");
@ -31,7 +30,7 @@ class differentialSignal {
    // 组装消息,一秒发送五次
    let data = "1";
    this.timer = setInterval(() => {
-      // dConsole.low(TCPTag, "发送给中心消息")
+      console.log(TCPTag, "发送给中心消息")
      this.differentialSignalTcp.sendMsg(data);
    }, 200);

@ -40,7 +39,7 @@ class differentialSignal {
  //   获取消息
  getData(callback: (data: ArrayBuffer) => void) {
    this.differentialSignalTcp.onMsg((data: ArrayBuffer) => {
-      // dConsole.low(TCPTag, "获取TCP消息", data);
+      // console.log(TCPTag, "获取TCP消息", data);
      callback(data);
    });
  }
--- a/entry/src/main/ets/workers/DifferentialCorrection.ets
+++ b/entry/src/main/ets/workers/DifferentialCorrection.ets
@ -1,6 +1,6 @@
 // 处理worker线程的消息tcp拿差分改正数,udp给后置机
 import worker, { ErrorEvent, MessageEvents, ThreadWorkerGlobalScope } from '@ohos.worker';
-import { WorkerTag } from '../config';
+import { SerialPortTag, WorkerTag } from '../config';
 import {
  CenterCallBackMsgType,
  EnvironmentConfigurationType,
@ -68,17 +68,17 @@ function getDataFn(config: EnvironmentConfigurationType) {
    if (data !== "" && config.carType !== "2") {
      // TODO
      // 需要观察
-      // console.log(WorkerTag, "后置机消息", data)
+      console.log(WorkerTag, "后置机消息", data)
      const res = await SerialPortService.getData()
-      // console.log(SerialPortTag, "档位原始数据", res)
+      console.log(SerialPortTag, "档位原始数据", res)
      if (res.length > 0) {
        const dataArray = data.split(",");
        // 替换data的第28位
        dataArray[28] = res[9].toString();
        data = dataArray.join(",");
-        // console.log(SerialPortTag, "档位", res[9].toString())
+        console.log(SerialPortTag, "档位", res[9].toString())
      }
-      // console.log(SerialPortTag, "处理完的档位信号", data)
+      console.log(SerialPortTag, "处理完的档位信号", data)
      workerPort.postMessage(
        JSON.stringify({
          type: WorkerBackMessageType.ObtainUdpData,
--- a/entry/src/main/ets/workers/Log.ets
+++ b/entry/src/main/ets/workers/Log.ets
@ -13,7 +13,7 @@ let fileFdArr: number[] = []
 let writeQueue: Array<FileQueueType> = [];
 let isProcessing = false;
 workerPort.onmessage = (e: MessageEvents) => {
-  // console.log(LogTag, "日志系统worker收到消息")
+  console.log(LogTag, "日志系统worker收到消息")
  // 日志文件目录
  let logPaths: LogPathType = {
    log: `${GlobalConfig.commonFileWriteAddress}/logs/${dayTs().format("YYYY_MM_DD")}/log/log.log`,
--- a/oh-package-lock.json5
+++ b/oh-package-lock.json5
@ -1,20 +1,18 @@
 {
-  "lockfileVersion": 2,
+  "lockfileVersion": 1,
  "ATTENTION": "THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.",
  "specifiers": {
-    "@ohos/hypium@1.0.19": "@ohos/hypium@1.0.19",
-    "@ohos/crypto-js@2.0.3": "@ohos/crypto-js@2.0.3"
+    "@ohos/crypto-js@2.0.3": "@ohos/crypto-js@2.0.3",
+    "@ohos/hypium@1.0.19": "@ohos/hypium@1.0.19"
  },
  "packages": {
-    "@ohos/hypium@1.0.19": {
-      "resolved": "https://ohpm.openharmony.cn/ohpm/@ohos/hypium/-/hypium-1.0.19.har",
-      "integrity": "sha512-cEjDgLFCm3cWZDeRXk7agBUkPqjWxUo6AQeiu0gEkb3J8ESqlduQLSIXeo3cCsm8U/asL7iKjF85ZyOuufAGSQ==",
-      "registryType": "ohpm"
-    },
    "@ohos/crypto-js@2.0.3": {
      "resolved": "https://ohpm.openharmony.cn/ohpm/@ohos/crypto-js/-/crypto-js-2.0.3.har",
-      "integrity": "sha512-LuHaR1kD5PxnOXnuR1fWvPwGtbed9Q/QGzk6JOh8y5Wdzvi8brPesODZiaWf9scOVRHsbTPOtZw91vWB35p1vQ==",
-      "registryType": "ohpm"
+      "integrity": "sha512-LuHaR1kD5PxnOXnuR1fWvPwGtbed9Q/QGzk6JOh8y5Wdzvi8brPesODZiaWf9scOVRHsbTPOtZw91vWB35p1vQ=="
+    },
+    "@ohos/hypium@1.0.19": {
+      "resolved": "https://ohpm.openharmony.cn/ohpm/@ohos/hypium/-/hypium-1.0.19.har",
+      "integrity": "sha512-cEjDgLFCm3cWZDeRXk7agBUkPqjWxUo6AQeiu0gEkb3J8ESqlduQLSIXeo3cCsm8U/asL7iKjF85ZyOuufAGSQ=="
    }
  }
 }