843 lines
27 KiB
TypeScript
Raw Normal View History

2024-01-05 11:11:15 +08:00
import systemTime from '@ohos.systemDateTime';
import router from '@ohos.router';
import util from '@ohos.util';
import buffer from '@ohos.buffer';
2024-02-21 14:53:53 +08:00
import {testMarkRules,testKm2Items} from './dataTest/index'
2024-01-05 11:11:15 +08:00
import VoiceAnnounce from './utils/voice-announcements'
import FileModel from './utils/file-model'
import FilePhoto from './utils/file-photo'
import JudgeTask from './utils/judge-task'
import FileUtil from '../../common/utils/File'
2024-02-21 14:53:53 +08:00
import { judgeConfig } from './utils/judge-config'
import {writeObjectOut,uploadExamProgressData} from '../../api/judge'
import {deepClone,getCurrentTime,stringToASC,string2Bytes,fillZero,Array2Byte,convertGpsCoord2} from '../../common/utils/tools'
import {getTranslateSignals,getCarStatus,getCarStatusType,getCenterProjectStatus,plcStrToJson,plcStrToWXJson,promptWxCode} from './utils//judge-common'
import {examJudgeSetLogCallback,examJudgeBeginExam,examJudgeInit,examJudgeRealExam,examJudgeSetRealExamCallback,examJudgeSetPerformCallback,examJudgeEndExam} from './api/index'
2024-01-31 14:35:16 +08:00
2024-01-05 11:11:15 +08:00
const judgeTag = 'SURENJUN_JUDGE'
2024-02-21 14:53:53 +08:00
2024-01-05 11:11:15 +08:00
export default class Judge{
constructor(judgeUI,fileLog) {
this.serialIndex = 1;
this.judgeUI = judgeUI
this.fileLog = fileLog;
//语音播放工具
this.avPlayer = new VoiceAnnounce();
//模型工具
this.fileModel = new FileModel(judgeUI.context);
//文件工具
this.fileUtil = new FileUtil(judgeUI.context)
this.judgeTask = new JudgeTask()
const mediaTest= new FilePhoto(judgeUI.context);
this.filePhoto = mediaTest
2024-01-31 14:35:16 +08:00
this.kfArr = judgeUI.kfArr
2024-02-21 14:53:53 +08:00
this.xmmcStr = '';this.xmmcCode = '';this.carztStr = '';
2024-01-05 11:11:15 +08:00
this.allKm2ItemsObj = {};
2024-02-21 14:53:53 +08:00
// 考试回放配置
const {isTrajectoryOpen,modelPath,trajectoryPath} = judgeConfig
this.isTrajectoryOpen = isTrajectoryOpen;
this.modelPath = modelPath;
this.trajectoryPath = trajectoryPath;
2024-01-05 11:11:15 +08:00
this.isExam = !globalThis.singlePlay;
const {projectsCenterObj} = judgeUI
2024-01-31 14:35:16 +08:00
//科目三待修改
2024-01-05 11:11:15 +08:00
testKm2Items.forEach(item => {
this.allKm2ItemsObj[item.code] = item;
//考试项目存在
if(projectsCenterObj[item.code]){
2024-02-21 14:53:53 +08:00
this.allKm2ItemsObj[item.code] = {code:item.code,status:1}
2024-01-05 11:11:15 +08:00
}
})
this.isEnd = false;
}
//开始评判
private async judging(callBack:Function){
2024-02-21 14:53:53 +08:00
const {getJudgeBeginData,getPlcData,fileLog,fileUtil,isTrajectoryOpen,trajectoryPath,avPlayer} = this;
2024-01-05 11:11:15 +08:00
const isJudgeInitBool = globalThis.isJudgeInitBool;
let strArr = [];
if(isTrajectoryOpen){
const folderPath = await this.fileUtil.initFolder(trajectoryPath);
const str = await fileUtil.readFile(folderPath)
strArr = str.split('\n')
}
//日志回调
console.info(judgeTag,'1.进入评判入口')
await examJudgeSetLogCallback(3, async (level, info,len)=>{
console.log('评判日志:' + info)
await fileLog.setExamJudgeLogData(info);
})
2024-01-31 14:42:14 +08:00
2024-01-05 11:11:15 +08:00
console.info(judgeTag,'2.注册日志回调完成')
2024-02-21 14:53:53 +08:00
let initInfo:any = ''
if(isTrajectoryOpen){
initInfo = JSON.parse(strArr[0])
}else{
initInfo = await this.getJudgeInitData();
}
2024-01-05 11:11:15 +08:00
//相关评判初始化只做一次
if(!isJudgeInitBool){
await fileLog.setExamJudgeData(initInfo)
const tempJudge = await examJudgeInit(initInfo);
globalThis.isJudgeInitBool = true
console.info(judgeTag,'4.评判初始化完成')
}else{
await fileLog.setExamJudgeData(initInfo)
}
2024-01-31 14:42:14 +08:00
2024-01-05 11:11:15 +08:00
globalThis.isJudge = true
// 2.评判过程回调
await examJudgeSetRealExamCallback(async (strData,len)=>{
await fileLog.setExamJudgeCallbackData(strData)
console.info('评判回调数据',strData)
this.handleRealExam(strData,callBack)
})
await examJudgeSetPerformCallback(async (info)=>{
console.info('评判实时数据',info)
this.performInfo = info
})
// 3.开始考试
2024-01-31 14:35:16 +08:00
let beginExamInfo
2024-01-05 11:11:15 +08:00
if(isTrajectoryOpen){
beginExamInfo = JSON.parse(strArr[1])
}else{
beginExamInfo = await getJudgeBeginData()
}
await fileLog.setExamJudgeData(beginExamInfo)
await examJudgeBeginExam(beginExamInfo);
console.info(judgeTag,'6.开始考试注册完成')
//实时plc数据信号
if(isTrajectoryOpen){
let num = 2;
const judgeTimer = setInterval(async ()=>{
const msg = JSON.parse(strArr[num]);
2024-01-31 14:35:16 +08:00
await fileLog.setExamJudgeData(msg)
2024-01-05 11:11:15 +08:00
if(!msg){
console.info(judgeTag,'模拟数据考试结束')
examJudgeEndExam();
globalThis.windowClass.setWindowSystemBarEnable(['navigation'])
clearInterval(judgeTimer)
return
}
// 4.过程数据
this.tempData = msg
this.plcData= msg
2024-02-21 14:53:53 +08:00
globalThis.msgStr= ''
2024-01-05 11:11:15 +08:00
await examJudgeRealExam(msg)
num++
2024-01-31 14:35:16 +08:00
},100)
2024-01-05 11:11:15 +08:00
globalThis.judgeTimer = judgeTimer;
return
}
globalThis.udpClient.onMessage(async (msg) => {
2024-01-31 14:35:16 +08:00
console.info('plc信号',msg)
2024-01-05 11:11:15 +08:00
const stachArr= msg.split(',')
const {isEnd} = this;
if (stachArr[0] != '#DN_GD' || isEnd) {
return
}
const plcData = await getPlcData(msg);
// 4.过程数据
await fileLog.setExamJudgeData(plcData)
await examJudgeRealExam(plcData)
const udpIndex = globalThis.udpIndex;
if(udpIndex % 5 === 0){
const judgeUdp = globalThis.judgeUdp
const bytes= await this.getMessageHeartbeat();
judgeUdp.send(bytes)
}
globalThis.udpIndex+=1
})
2024-01-31 14:35:16 +08:00
avPlayer.playAudio(['km2/ksks.WAV'],true)
2024-01-05 11:11:15 +08:00
}
public async onJudgeFn(fn:Function){
await this.judging(fn)
}
//处理评判过程回调
handleRealExam = async (strData,callBack) => {
// console.log('过程数据:' + strData);
let examData = JSON.parse(strData);
2024-01-31 14:35:16 +08:00
const {getDqxmStr,getKfStr,judgeUI} = this;
2024-01-05 11:11:15 +08:00
const {carzt,xmks,kf,event,xmjs,ksjs} = examData
2024-01-31 14:35:16 +08:00
2024-01-05 11:11:15 +08:00
//获取项目结束、项目开始代码
2024-01-31 14:35:16 +08:00
const xmdm = event == 2 ? xmjs.xmdm : xmks.xmdm
const xmxh = event == 2 ? xmjs.xmxh : xmks.xmxh;
2024-01-05 11:11:15 +08:00
switch (event){
//项目开始
case 1:
judgeUI.projectsObj[xmdm].type = '2';
const xmmcStr = judgeUI.projectsObj[xmdm].name;
const xmmcCode = judgeUI.projectsObj[xmdm].projectCodeCenter;
const xmmcSingleCode = judgeUI.projectsObj[xmdm].projectCode;
this.allKm2ItemsObj[xmmcCode].status = 2;
this.xmmcStr = xmmcStr;
this.xmmcCode = xmmcCode;
this.xmmcSingleCode = xmmcSingleCode
this.xmdm = xmdm;
2024-01-31 14:35:16 +08:00
this.xmxh = xmxh;
2024-01-05 11:11:15 +08:00
break;
//项目结束
case 2:
2024-01-31 14:35:16 +08:00
judgeUI.projectsObj[xmdm].type = (xmjs.xmhg === 0 ? '4' : '3');
2024-01-05 11:11:15 +08:00
this.xmmcStr = '无';
this.xmmcCode = '';
this.xmmcSingleCode = 0;
this.xmdm = '';
break;
//扣分
case 3:
const thisKf = getKfStr(`${kf.xmdm}_${kf.kfdm}`)
//扣分信息
this.kfArr.push({
//扣分项目名称
xmmcStr:getDqxmStr(kf.xmdm),
2024-01-31 14:35:16 +08:00
xmdm:kf.xmdm,
2024-01-05 11:11:15 +08:00
//扣分描述
desc:thisKf.desc,
//扣分分数
score:thisKf.score,
// 扣分无锡所代码
markcatalog:thisKf.markcatalog,
markserial:thisKf.markserial,
kfxh:thisKf.kfxh
})
this.judgeUI.totalScore += thisKf.score*1;
break;
//考车状态
case 4: this.carztStr = getCarStatus(carzt);break;
//考试结束
2024-01-31 14:35:16 +08:00
case 5: this.ksjs = ksjs;break;
default:;break;
2024-01-05 11:11:15 +08:00
}
const {xmmcStr,carztStr,kfArr} = this;
await callBack({
//项目名称 考车状态 扣分arr
xmmcStr, carztStr, kfArr
});
const copyProjectsObj = this.judgeUI.projectsObj;
2024-01-31 14:42:14 +08:00
//语音播报
2024-01-05 11:11:15 +08:00
this.goVoiceAnnounce(event,xmdm, this.kfArr,xmjs)
judgeUI.projectsObj = deepClone(copyProjectsObj)
}
//更改考试状态
goVoiceAnnounce = async (event,xmdm,kf,xmjs) => {
const projectsObj = this.judgeUI.projectsObj;
const {beginProject,pointsDedute,endProject,avPlayer,uploadProgressPhoto,judgeTask,handEndExam} = this;
const xmhg = xmjs.xmhg
const kfLen = kf.length
switch (event){
2024-01-31 14:35:16 +08:00
// 项目开始
2024-01-05 11:11:15 +08:00
case 1:
avPlayer.playAudio([`km2/${projectsObj[xmdm].projectCodeCenter}.mp3`],true)
//项目开始同步接口
await judgeTask.addTask(async ()=>{
console.info(judgeTag,'项目开始 start')
await beginProject(xmdm)
console.info(judgeTag,'上传照片 start')
await uploadProgressPhoto(xmdm)
})
break;
2024-01-31 14:35:16 +08:00
// 项目结束
2024-01-05 11:11:15 +08:00
case 2:
await judgeTask.addTask(async ()=>{
2024-02-21 14:53:53 +08:00
console.info(judgeTag,'项目结束 start')
2024-01-05 11:11:15 +08:00
await endProject(xmdm)
})
break;
2024-01-31 14:35:16 +08:00
// 扣分
2024-01-05 11:11:15 +08:00
case 3:
2024-01-31 14:35:16 +08:00
console.info(judgeTag ,kf[kfLen -1].markcatalog);
2024-01-05 11:11:15 +08:00
avPlayer.playAudio([`km2/${kf[kfLen -1].markcatalog}.mp3`])
await judgeTask.addTask(async ()=>{
console.info(judgeTag,'项目扣分 start')
await pointsDedute(kf[kfLen -1].xmdm,kf[kfLen -1])
})
break;
2024-01-31 14:35:16 +08:00
// 考车状态
2024-01-05 11:11:15 +08:00
case 4:break
2024-01-31 14:35:16 +08:00
// 考试结束
2024-01-05 11:11:15 +08:00
case 5:
clearInterval(globalThis.judgeTimer)
await judgeTask.addTask(async ()=>{
console.info(judgeTag,'考试结束 start')
await handEndExam()
})
break
2024-02-21 14:53:53 +08:00
default:break
2024-01-05 11:11:15 +08:00
}
}
//处理考试结束
2024-01-31 14:35:16 +08:00
public handEndExam = async ()=>{
const {isExam,judgeUI,endExam,avPlayer} = this;
2024-02-21 14:53:53 +08:00
2024-01-31 14:35:16 +08:00
avPlayer.playAudio(['km2/exam_waiting.mp3'],true)
2024-01-05 11:11:15 +08:00
this.isEnd = true
const bytes = await this.getMessageHeartbeat(true);
2024-02-21 14:53:53 +08:00
const singlePlay = globalThis.singlePlay
singlePlay || globalThis.judgeUdp.send(bytes)
//结束评判函数
2024-01-05 11:11:15 +08:00
await examJudgeEndExam();
globalThis.isJudge = false
await endExam()
}
2024-02-21 14:53:53 +08:00
// 过程照片拍照
2024-01-05 11:11:15 +08:00
getPhoto = async (empty?:boolean) => {
2024-01-31 14:35:16 +08:00
const singlePlay = globalThis.singlePlay
2024-02-21 14:53:53 +08:00
//单机模式返回空照片
2024-01-05 11:11:15 +08:00
if(singlePlay){
2024-01-31 14:35:16 +08:00
return ''
2024-01-05 11:11:15 +08:00
}else{
const {filePhoto} = this;
const photoBase64 = await filePhoto.getPhoto();
2024-01-31 14:35:16 +08:00
console.info(judgeTag,'拍照完成')
2024-01-05 11:11:15 +08:00
return photoBase64
}
}
2024-01-31 14:42:14 +08:00
// 当前项目转换
2024-01-05 11:11:15 +08:00
getDqxmStr = (type) => {
const projectsObj = this.judgeUI.projectsObj
2024-02-21 14:53:53 +08:00
return projectsObj[type]?.abbreviation || '通用评判'
2024-01-05 11:11:15 +08:00
}
// 扣分项目转换
getKfStr = (code) => {
const markRuleListObj = this.judgeUI.markRuleListObj;
const thisMark = markRuleListObj[code]
return {
desc: thisMark.markshow,
score: thisMark.markreal,
markcatalog: thisMark.markcatalog,
markserial:thisMark.markserial,
kfxh:thisMark.kfxh
}
}
// 项目开始接口同步
beginProject = async(ksxm) => {
const carInfo = globalThis.carInfo;
const { examSubject,plateNo } = carInfo;
2024-01-31 14:35:16 +08:00
const {judgeUI,fileLog,getSbbm,xmxh} = this;
2024-01-05 11:11:15 +08:00
const {lsh,idCard,serialNumber,projectsObj,ksdd,kslx} = judgeUI
const time = await getCurrentTime();
const project = projectsObj[ksxm]
2024-01-31 14:35:16 +08:00
const sbxh = getSbbm(ksxm,xmxh)
2024-01-05 11:11:15 +08:00
const data = {
2024-02-21 14:53:53 +08:00
//系统类别 接口序列号 接口标识
xtlb:'17', jkxlh:serialNumber, jkid:'17C52',
2024-01-05 11:11:15 +08:00
drvexam:{
2024-02-21 14:53:53 +08:00
// 考试科目 身份证号码
lsh, kskm:examSubject, sfzmhm:idCard, ksxm:project.projectCodeCenter,sbxh, kchp:encodeURI(plateNo),
// 开始时间
ksdd:encodeURI(ksdd), ksxl:encodeURI(kslx) || '', kssj:time
2024-01-05 11:11:15 +08:00
}
}
const code = await writeObjectOut(data)
console.info(judgeTag,'项目开始 end')
2024-02-21 14:53:53 +08:00
if(code === 2300007){this.isJudgeDisConnect = true;}
2024-01-31 14:35:16 +08:00
const isJudgeDisConnect = this.isJudgeDisConnect
isJudgeDisConnect ? fileLog.setExamJudgeDisWuxiProgressData(data) : fileLog.setExamJudgeWuxiData(data)
2024-02-21 14:53:53 +08:00
promptWxCode('17C52',code)
2024-01-05 11:11:15 +08:00
}
// 项目结束接口同步
endProject = async(ksxm) =>{
const carInfo = globalThis.carInfo;
const deviceNo = globalThis.deviceNo;
const { examSubject,plateNo,carNo } = carInfo;
2024-01-31 14:35:16 +08:00
const {judgeUI,fileLog,getSbxh,xmxh,getSbbm} = this;
2024-01-05 11:11:15 +08:00
const {lsh,idCard,serialNumber,projectsObj,cdsbInfoObj,ksdd,kslx} = judgeUI
const time = await getCurrentTime();
const project = projectsObj[ksxm]
2024-01-31 14:35:16 +08:00
const sbxh = getSbbm(ksxm,xmxh)
2024-01-05 11:11:15 +08:00
const data = {
2024-02-21 14:53:53 +08:00
xtlb:'17',jkxlh:serialNumber,jkid:'17C55',
2024-01-05 11:11:15 +08:00
drvexam:{
2024-02-21 14:53:53 +08:00
lsh,kskm:examSubject,sfzmhm:idCard,
2024-01-05 11:11:15 +08:00
ksxm:project.projectCodeCenter,
sbxh,
//操作类型 1:正常 0:撤销该考试记录
czlx:'1',
2024-02-21 14:53:53 +08:00
kchp:encodeURI(plateNo),ksdd:encodeURI(ksdd),ksxl:encodeURI(kslx) || '',
2024-01-05 11:11:15 +08:00
jssj:time
}
}
const code = await writeObjectOut(data)
2024-02-21 14:53:53 +08:00
if(code === 2300007){this.isJudgeDisConnect = true;}
2024-01-31 14:35:16 +08:00
const isJudgeDisConnect = this.isJudgeDisConnect
isJudgeDisConnect ? fileLog.setExamJudgeDisWuxiProgressData(data) : fileLog.setExamJudgeWuxiData(data)
2024-01-05 11:11:15 +08:00
console.info(judgeTag,'项目结束 end')
2024-02-21 14:53:53 +08:00
promptWxCode('17C55',code)
2024-01-05 11:11:15 +08:00
}
// 考试扣分
pointsDedute= async (ksxm,kf) => {
const carInfo = globalThis.carInfo;
const deviceNo = globalThis.deviceNo;
const { examSubject,plateNo,carNo } = carInfo;
const {judgeUI,getProjectInfo,fileLog} = this;
const {lsh,idCard,serialNumber,ksdd} = judgeUI
const time = await getCurrentTime();
const project = getProjectInfo(ksxm);
const data = {
2024-02-21 14:53:53 +08:00
xtlb:'17',jkxlh:serialNumber,jkid:'17C53',
2024-01-05 11:11:15 +08:00
drvexam:{
2024-02-21 14:53:53 +08:00
lsh,kskm:examSubject,
2024-01-05 11:11:15 +08:00
// 通用评判科二10000科三30000
ksxm:project?project.projectCodeCenter:10000,
kfxm:kf.markcatalog,
kfxmmx:`${ksxm},${kf.markserial}`,
2024-02-21 14:53:53 +08:00
sfzmhm:idCard, kchp:encodeURI(carInfo.plateNo),
2024-01-31 14:35:16 +08:00
//1:自动 2:人工
kffs:1,
2024-02-21 14:53:53 +08:00
ksdd:encodeURI(ksdd), kfsj:time
2024-01-05 11:11:15 +08:00
}
}
const code = await writeObjectOut(data);
2024-02-21 14:53:53 +08:00
if(code === 2300007){this.isJudgeDisConnect = true}
2024-01-31 14:35:16 +08:00
const isJudgeDisConnect = this.isJudgeDisConnect
isJudgeDisConnect ? fileLog.setExamJudgeDisWuxiProgressData(data) : fileLog.setExamJudgeWuxiData(data)
2024-01-05 11:11:15 +08:00
console.info(judgeTag,'项目扣分 end')
2024-02-21 14:53:53 +08:00
promptWxCode('17C53',code)
2024-01-05 11:11:15 +08:00
}
// 考试过程照片
uploadProgressPhoto = async (ksxm) => {
const time = await getCurrentTime();
const {judgeUI,plcData,getPhoto,fileLog} = this;
const photoBase64 = await getPhoto();
const carInfo = globalThis.carInfo;
const { examSubject,plateNo,carNo } = carInfo;
const {lsh,idCard,serialNumber,projectsObj,ksdd} = judgeUI;
2024-01-31 14:35:16 +08:00
const {sensor,gps} = plcData
2024-01-05 11:11:15 +08:00
const project = projectsObj[ksxm]
const data = {
2024-02-21 14:53:53 +08:00
xtlb:'17',jkxlh:serialNumber,jkid:'17C54',
2024-01-05 11:11:15 +08:00
drvexam:{
2024-02-21 14:53:53 +08:00
lsh,kskm:examSubject,ksxm:project.projectCodeCenter,
sfzmhm:idCard,kchp:encodeURI(plateNo),zpsj:time,
2024-01-05 11:11:15 +08:00
//@ts-ignore
zp:encodeURIComponent(photoBase64),
2024-01-31 14:35:16 +08:00
cs:Math.ceil(gps.sd * 1.852),
2024-01-05 11:11:15 +08:00
ksdd:encodeURI(ksdd)
}
};
const code = await writeObjectOut(data);
2024-02-21 14:53:53 +08:00
if(code === 2300007){this.isJudgeDisConnect = true}
promptWxCode('17C54',code)
2024-01-05 11:11:15 +08:00
fileLog.setExamJudgeWuxiData(data)
console.info(judgeTag,'上传照片 end')
}
// 考试结束
2024-01-31 14:35:16 +08:00
public endExam = async (isManual?:Boolean) => {
2024-01-05 11:11:15 +08:00
const carInfo = globalThis.carInfo;
const deviceNo = globalThis.deviceNo;
const { examSubject ,plateNo} = carInfo;
2024-01-31 14:35:16 +08:00
const {judgeUI,fileLog,ksjs,getPhoto,uploadProgressData,uploadDisConnectData,avPlayer} = this;
const {lsh,idCard,serialNumber,kssycs,totalScore} = judgeUI
await uploadDisConnectData();
2024-01-05 11:11:15 +08:00
const time = await getCurrentTime();
const photoBase64 = await getPhoto();
const data = {
2024-02-21 14:53:53 +08:00
xtlb:'17',jkxlh:serialNumber,jkid:'17C56',
2024-01-05 11:11:15 +08:00
drvexam:{
2024-02-21 14:53:53 +08:00
lsh,kchp:encodeURI(plateNo),kskm:examSubject,sfzmhm:idCard,
2024-01-31 14:35:16 +08:00
//@ts-ignore
2024-02-21 14:53:53 +08:00
zp:encodeURIComponent(photoBase64),jssj:time,
2024-01-31 14:35:16 +08:00
kscj:(totalScore*1) > 0 ? totalScore : 0,
kslc:(ksjs?.qjjl + ksjs?.dcjl) || 0,
2024-01-05 11:11:15 +08:00
dwlc:'',
}
}
const code = await writeObjectOut(data);
2024-02-21 14:53:53 +08:00
promptWxCode('17C56',code)
2024-01-05 11:11:15 +08:00
console.info(judgeTag,'考试结束 end')
2024-01-31 14:35:16 +08:00
if(!isManual){
if(totalScore < 80){
judgeUI.loadingPopupVisible = true
if(kssycs == 1){
avPlayer.playAudio(['km2/unqualified_one.wav'],true)
}else{
avPlayer.playAudio(['km2/unqualified_two.wav'],true)
}
}else{
avPlayer.playAudio(['km2/qualified.mp3'],true)
}
}
console.info(judgeTag,`考试成绩:${totalScore}`)
2024-01-05 11:11:15 +08:00
fileLog.setExamJudgeWuxiData(data)
await uploadProgressData();
setTimeout(()=>{
router.back();
},3000)
}
2024-01-31 14:35:16 +08:00
// 断网数据补传
uploadDisConnectData = async () => {
const {isJudgeDisConnect,fileLog,fileUtil} = this;
if(!isJudgeDisConnect){
return
}
const folderPath = fileLog.folderPath
const examDataStr = await fileUtil.readFile(`${folderPath}/wuxi_dis_progress_data.txt`);
const examDataArr = examDataStr.split('\n');
for(let examDataStr of examDataArr){
const examData = JSON.parse(examDataStr)
const code = await writeObjectOut(examData);
}
}
2024-01-05 11:11:15 +08:00
//上传无锡所过程数据
uploadProgressData = async () => {
const {judgeUI,fileUtil,fileLog} = this;
const {idCard,startFullTime} = judgeUI
const carInfo = globalThis.carInfo;
const {carId,examinationRoomId} = carInfo
const folderPath = fileLog.folderPath
const base64 = new util.Base64();
const time = await getCurrentTime();
const endTime = await getCurrentTime(1)
let examDataBase64
//@ts-ignore
2024-01-31 14:35:16 +08:00
//TODO try catch报错待优化
2024-01-05 11:11:15 +08:00
const examDataStr:string = await fileUtil.readFile(`${folderPath}/wuxi_progress_data.txt`);
try {
let tempBuff = buffer.alloc(examDataStr.length, examDataStr)
let examData:Uint8Array = new Uint8Array(tempBuff.buffer)
examDataBase64 = base64.encodeToStringSync(examData)
}catch (e){
console.info(judgeTag,JSON.stringify(e))
}
console.info(judgeTag,'过程数据文件上传 start')
await uploadExamProgressData({
time,
carId,
examinationRoomId,
examData:examDataBase64,
type:1,
cardNo:idCard,
examStartTime:startFullTime,
examEndTime:endTime,
})
console.info(judgeTag,'过程数据文件上传 end')
}
// 获取评判初始化数据
getJudgeInitData = async () => {
const {getModelData} = this
const carInfo = globalThis.carInfo;
const { examSubject,plateNo,carNo } = carInfo;
const {fileLog} = this
const judgeUI = this.judgeUI
2024-01-31 14:35:16 +08:00
const {projectsObj,cdsbInfoObj,markRuleListObj,carType,carName} = judgeUI
2024-01-05 11:11:15 +08:00
const initInfo = {
kskm:examSubject*1,
kchp:plateNo,
kchm:carNo*1,
kscx:carType,
cxcode:'1',
name:carName,
carmodel:getModelData(`${carType}.txt`),
2024-01-31 14:35:16 +08:00
allitems:Reflect.ownKeys(cdsbInfoObj).map(cdsbKey=>{
const cdsb = cdsbInfoObj[cdsbKey];
const {xmdm,xmxh,modelKey} = cdsb
2024-01-05 11:11:15 +08:00
return {
2024-01-31 14:35:16 +08:00
xmdm,xmxh,model:getModelData(`${modelKey}.txt`)
2024-01-05 11:11:15 +08:00
}
}),
mark:Reflect.ownKeys(markRuleListObj).map(ruleKey=>(markRuleListObj[ruleKey])) || testMarkRules,
2024-01-31 14:35:16 +08:00
sysset:judgeUI.judgeConfig,
2024-01-05 11:11:15 +08:00
};
console.info(judgeTag,'3.获取评判初始化数据完成')
return initInfo
}
2024-01-31 14:35:16 +08:00
// 消息心跳发送
getMessageHeartbeat = async (isEnd?:Boolean) => {
const carInfo = globalThis.carInfo;
const { examSubject,plateNo,ksyh } = carInfo;
const {judgeUI,isExam,serialIndex,tempData,xmmcCode,xmxh,xmmcSingleCode,xmdm,performInfo,kfArr,getTranslateProject,getSbxh} = this;
const {lsh,startHourTime,totalScore} = judgeUI;
const examType = isExam?examSubject:0;
const {sensor,gps} = tempData;
const {zfxd,yfxd,shtd,ygd,jgd,skd,dh1,dh2,lhq,jsc,ssc,fsc,lb,mkg,aqd,ygq,cs,fdjzs} = sensor
const {jd,wd, hxj, fyj, hbg,} = gps
const translateProject = getTranslateProject();
const sbxh = getSbxh(xmdm,xmxh)
const {carzt,dcjl,qjjl,dxjl,bxjl} = JSON.parse(performInfo);
const asclshArr = stringToASC(lsh);
//13不足要补0
const ascksyhArr = stringToASC(fillZero(ksyh || 0,13))
const ascsbxhArr = stringToASC(sbxh)
const translateSignals = getTranslateSignals(
[zfxd, yfxd, shtd, ygd, jgd, skd, dh1, dh2, lhq, jsc,ssc,fsc, lb, mkg, aqd, 0,0,0,0 ].concat(getCarStatusType(carzt)).concat([ ygq, sensor.wd, 0 ])
)
//@ts-ignore
const translateJd = convertGpsCoord2(wd).toFixed(7) * Math.pow(10,7)
//@ts-ignore
const translateWd = convertGpsCoord2(jd).toFixed(7) * Math.pow(10,7)
//@ts-ignore
const translateProjects= translateProject.map(num => string2Bytes(num,8)[0])
const arr = [
//考生号 TODO 考试员号
asclshArr.map(lsh => string2Bytes(lsh,8)[0]), ascksyhArr.map(ksyh => string2Bytes(ksyh,8)[0]),
//科目类型(0:未考试 1:科目二 2:科目三) + 考试开始时间
string2Bytes(`${examType}${startHourTime}`,4 * 8),
// TODO 消息序号从1开始0结束
string2Bytes(isEnd ? 0 : serialIndex,2 * 8),
/*左向灯 右向灯 双跳灯 远光灯 近光灯 视宽灯 点火1 点火2 离合器 脚刹 手刹 副刹 喇叭 门开关 安全带 档位 车辆状态 雨刮器 雾灯 0*/
translateSignals,
//速度 发动机转速 GPS纬度 GPS经度 主天线位置
//@ts-ignore
string2Bytes(cs,2 * 8), string2Bytes(fdjzs / 60,8), string2Bytes(translateJd,4*8), string2Bytes(translateWd,4*8), string2Bytes(1,8),
//GPS东向距离
string2Bytes(dxjl < 0 ? (dxjl+4294967296) : dxjl,4*8),
//GPS北向距离
string2Bytes(bxjl < 0 ? (bxjl+4294967296) : bxjl,4*8),
//航向角 俯仰角 高程(海拔)
string2Bytes((hxj+90) * 100,2*8), string2Bytes(fyj*100,2*8), string2Bytes(hbg*100,4*8),
//项目状态 parseInt('01010010',2) 二进制转成10进制
translateProjects,
//当前项目编号
string2Bytes(xmmcSingleCode ? (xmmcSingleCode*1 + 1) : 0,8),
//场地设备编号
ascsbxhArr.map(sbxh => string2Bytes(sbxh,8)[0]),
//本次考试行驶距离
string2Bytes(Math.floor((dcjl + qjjl)/100),2*8),
//扣分
string2Bytes(100 - Math.abs(totalScore),2*8),
//扣分项数量
string2Bytes(kfArr.length,8),
//n个扣分序号
kfArr.map(kf => string2Bytes(kf.kfxh,8)[0])
]
let tempArr = [];
arr.forEach(itemArr =>{ tempArr = tempArr.concat(itemArr)})
this.serialIndex += 1;
return Array2Byte(tempArr)
}
2024-01-05 11:11:15 +08:00
// 获取开始考试数据
getJudgeBeginData = async () => {
const {code,name:examinerName} = globalThis.examinerInfo;
const {isExam} = this;
const judgeUI = this.judgeUI
2024-01-31 14:35:16 +08:00
const {projects,carType,isDdxk,ddxkTime,projectsCenterObj,ddxkKsxmArr,ddxkKfArr} = judgeUI;
2024-01-05 11:11:15 +08:00
const beginInfo = {
ic:'',
kgid:'012',
kgxm:decodeURI(examinerName),
exam:isExam?1:0,
//生成的轨迹文件
track:'',
xm:judgeUI.name,
sex:0,
kslsh:judgeUI.lsh,
sfzmhm:judgeUI.idCard,
ksyy:'',
kscx:carType,
kkcs:1,
sfyk:0,
ykkkcs:1,
wayno:0,
czlx:0,
kskssj:await systemTime.getCurrentTime(),
ksxm:projects.map(project=>{
return {
xmdm:project.projectCode*1,
2024-01-31 14:35:16 +08:00
xmxh:'',
2024-01-05 11:11:15 +08:00
}
}),
//断点续考
2024-01-31 14:35:16 +08:00
ddxk:isDdxk ? 1 : 0,
ddkssj:ddxkTime,
ykxm:isDdxk?(ddxkKsxmArr?.map(projectCenterCode => (projectsCenterObj[projectCenterCode]?.projectCode)*1)):[],
kfxm:isDdxk?(ddxkKfArr?.map(kf => {
const [xmdm,kfdm] = kf.split(',')
return {
xmdm:xmdm*1,
kfdm
}
})):[],
2024-01-05 11:11:15 +08:00
yklc:0,
special:[]
}
console.info(judgeTag,'5.获取开始考试数据完成')
return beginInfo
}
// 获取plc数据
getPlcData = async (plc:string) => {
const {fileLog} = this;
await fileLog.setPlcProgressData(plc)
2024-02-21 14:53:53 +08:00
//plc字符串转化成评判初始化数据
const tempData = await plcStrToJson(plc);
//plc字符串转化成无锡所过程数据
const wuXiDataStr = await plcStrToWXJson(plc)
2024-01-05 11:11:15 +08:00
this.plcData= tempData
await fileLog.setExamJudgeWuxiProgressData(wuXiDataStr)
this.tempData = tempData
2024-01-31 14:35:16 +08:00
this.plcStr = plc;
globalThis.msgStr= plc
2024-01-05 11:11:15 +08:00
return tempData
}
//获取场地序号
2024-01-31 14:35:16 +08:00
getSbxh = (ksxm,xmxh) => {
2024-01-05 11:11:15 +08:00
const {judgeUI} = this;
const {cdsbInfoObj,projectsObj} = judgeUI;
const project = projectsObj[ksxm]
if(project === undefined){
return '0000000000'
}
const projectType = project.sbxh;
2024-01-31 14:35:16 +08:00
const projectKey = `${ksxm}_${xmxh}`;
2024-01-05 11:11:15 +08:00
const currentCdsb = cdsbInfoObj[projectKey] || {};
const sbxh = currentCdsb.sbbh || '0000000000'
return sbxh
}
2024-01-31 14:35:16 +08:00
getSbbm = (ksxm,xmxh) => {
2024-01-05 11:11:15 +08:00
const {judgeUI} = this;
const {cdsbInfoObj,projectsObj} = judgeUI;
const project = projectsObj[ksxm]
if(project === undefined){
return '00000000'
}
2024-01-31 14:35:16 +08:00
const projectKey = `${ksxm}_${xmxh}`;
2024-01-05 11:11:15 +08:00
const currentCdsb = cdsbInfoObj[projectKey] || {};
const sbxh = currentCdsb.sbbm || '00000000'
return sbxh
}
// 中心所有项目转换
getTranslateProject = () => {
2024-01-31 14:35:16 +08:00
const {allKm2ItemsObj} = this;
2024-01-05 11:11:15 +08:00
const tempItems = testKm2Items.map(item=>{
const current = allKm2ItemsObj[item.code];
return {
code:item.code,
status:getCenterProjectStatus(current.status)
}
})
const len = Math.floor(tempItems.length / 4);
const arr = [];
for(let i = 0;i <= len;i++){
const temp = tempItems.slice( i*4 , (i+1)*4 );
let tempArr = temp.map(item => item.status)
if(i === 4){
tempArr = tempArr.concat(['00','00'])
}
arr.push(tempArr.join(''));
}
return arr.map(numStr => parseInt(numStr,2));
}
2024-01-31 14:35:16 +08:00
// 获取考试项目详情
2024-01-05 11:11:15 +08:00
getProjectInfo = (projectCode) => {
const judgeUI = this.judgeUI;
return judgeUI.projectsObj[projectCode]
}
// 获取模型数据
getModelData = (modelName) => {
const modelPath = this.modelPath
const fileModel = this.fileModel;
const modelData = fileModel.getModelContent(modelPath,modelName);
return modelData
}
2024-01-31 14:35:16 +08:00
private judgeUI
private fileLog
private totalScore:number
private folderPath:string
private modelPath:string
private avPlayer
private carztStr:string
private xmmcStr:string
private xmmcCode:string
private xmmcSingleCode:number
private xmdm:string
private xmxh:string
private fileModel:FileModel
private filePhoto:FilePhoto
//是否是考试模式
private isExam:boolean
//考试是否结束了
private isEnd:boolean
//UDP服务序列号
private serialIndex:number
private fileUtil:FileUtil
private judgeTask:JudgeTask
private tempData:any
public plcStr:string
private performInfo:any
private ksjs:{
// 累计前进距离
qjjl:number,
// 累计倒车距离
dcjl:number
2024-01-05 11:11:15 +08:00
}
2024-01-31 14:35:16 +08:00
private kfArr:{
//项目名称
xmmcStr:string,
xmdm:string,
//扣分描述
desc:string,
//扣分
score:string
//无锡所扣分代码
markcatalog:string
markserial:string
kfxh:string
}[]
private plcData:any
private km2ItemsStatus:any[]
2024-01-05 11:11:15 +08:00
2024-01-31 14:35:16 +08:00
//所有的科目二考试项目(大车&小车)
private allKm2ItemsObj:any
//当前科目二的考试项目
private currentKm2ItemsObj:any
//本地轨迹回放地址
private trajectoryPath:string
private isTrajectoryOpen:boolean;
// 调代理接口是否断网了
private isJudgeDisConnect:boolean;
2024-01-05 11:11:15 +08:00
}