version: 0.0.8
This commit is contained in:
parent
52a8cec532
commit
9d95f11282
@ -184,6 +184,37 @@ export default class Judge {
|
|||||||
private isExamEnd: boolean
|
private isExamEnd: boolean
|
||||||
// 是否发送udp
|
// 是否发送udp
|
||||||
private isUdpEnd: boolean = false
|
private isUdpEnd: boolean = false
|
||||||
|
// 处理udp plc信号
|
||||||
|
handleUdp = async (msg: string) => {
|
||||||
|
const stachArr = msg.split(',')
|
||||||
|
if (stachArr[0] != '#DN_GD' || this.isUdpEnd) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
const plcData = await this.getPlcData(msg);
|
||||||
|
// 4.过程数据
|
||||||
|
await this.fileLog?.setExamJudgeData(JSON.stringify(plcData))
|
||||||
|
//检测到有无锡所设备接入,需要发送特定的数据,供检测
|
||||||
|
// if (this.usbService.isWXUSBDevice) {
|
||||||
|
// const str = await senorToWXDataStr(msg);
|
||||||
|
// this.usbService.sendUSB(str)
|
||||||
|
// }
|
||||||
|
const param350: number = Reflect.get(this.judgeUI.judgeConfigObj, '350')
|
||||||
|
this.judgeUI.sd = ((param350 == 0 ? plcData.gps.sd : plcData.sensor.cs) as number * 1.852).toFixed(0) + ''
|
||||||
|
this.judgeUI.dw = (Math.floor(plcData.sensor.dw as number) || 0) + ''
|
||||||
|
//TODO 暂时关闭差分检测异常
|
||||||
|
// await this.checkDwzt(plcData.gps.dwzt,plcData.gps.jdzt);
|
||||||
|
if (!this.isExamEnd) {
|
||||||
|
await examJudgeRealExam(plcData)
|
||||||
|
}
|
||||||
|
// let udpIndex = AppStorage.get<number>('udpIndex') || 0;
|
||||||
|
// if (udpIndex % 5 === 0 && !this.isUdpEnd) {
|
||||||
|
// TODO UPD缺失
|
||||||
|
// const judgeUdp = globalThis.judgeUdp
|
||||||
|
// const bytes = await this.getMessageHeartbeat(this.isExamEnd);
|
||||||
|
// judgeUdp.send(bytes)
|
||||||
|
// }
|
||||||
|
// AppStorage.setOrCreate('udpIndex', udpIndex++)
|
||||||
|
}
|
||||||
//是否手动结束考试
|
//是否手动结束考试
|
||||||
private isManual: boolean = false
|
private isManual: boolean = false
|
||||||
//UDP服务序列号
|
//UDP服务序列号
|
||||||
@ -278,37 +309,26 @@ export default class Judge {
|
|||||||
AppStorage.setOrCreate('msgStr', plc)
|
AppStorage.setOrCreate('msgStr', plc)
|
||||||
return tempData
|
return tempData
|
||||||
}
|
}
|
||||||
// 处理udp plc信号
|
private isEndTip: boolean = false;
|
||||||
handleUdp = async (msg: string) => {
|
//本地轨迹回放地址
|
||||||
const stachArr = msg.split(',')
|
private trajectoryPath: string
|
||||||
if (stachArr[0] != '#DN_GD' || this.isUdpEnd) {
|
// private currentKm2ItemsObj: any
|
||||||
|
private isTrajectoryOpen: boolean;
|
||||||
|
// 调代理接口是否断网了
|
||||||
|
private isJudgeDisConnect: boolean = false;
|
||||||
|
// 断网数据补传
|
||||||
|
uploadDisConnectData = async () => {
|
||||||
|
if (!this.isJudgeDisConnect) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
const plcData = await this.getPlcData(msg);
|
const folderPath = this.fileLog?.folderPath
|
||||||
// 4.过程数据
|
const examDataStr = await this.fileUtil.readFile(`${folderPath}/wuxi_dis_progress_data.txt`);
|
||||||
await this.fileLog?.setExamJudgeData(JSON.stringify(plcData))
|
const examDataArr = examDataStr.split('\n');
|
||||||
//检测到有无锡所设备接入,需要发送特定的数据,供检测
|
for (let examDataStr of examDataArr) {
|
||||||
// if (this.usbService.isWXUSBDevice) {
|
const code = await writeObjectOut(JSON.parse(examDataStr), "", this.context);
|
||||||
// const str = await senorToWXDataStr(msg);
|
|
||||||
// this.usbService.sendUSB(str)
|
|
||||||
// }
|
|
||||||
const param350: number = Reflect.get(this.judgeUI.judgeConfigObj, '350')
|
|
||||||
this.judgeUI.sd = ((param350 == 0 ? plcData.gps.sd : plcData.sensor.cs) as number * 1.852).toFixed(0) + ''
|
|
||||||
this.judgeUI.dw = (Math.floor(plcData.sensor.dw as number) || 0) + ''
|
|
||||||
//TODO 暂时关闭差分检测异常
|
|
||||||
// await this.checkDwzt(plcData.gps.dwzt,plcData.gps.jdzt);
|
|
||||||
if (!this.isExamEnd) {
|
|
||||||
await examJudgeRealExam(plcData)
|
|
||||||
}
|
}
|
||||||
// let udpIndex = AppStorage.get<number>('udpIndex') || 0;
|
|
||||||
// if (udpIndex % 5 === 0 && !this.isUdpEnd) {
|
|
||||||
// TODO UPD缺失
|
|
||||||
// const judgeUdp = globalThis.judgeUdp
|
|
||||||
// const bytes = await this.getMessageHeartbeat(this.isExamEnd);
|
|
||||||
// judgeUdp.send(bytes)
|
|
||||||
// }
|
|
||||||
// AppStorage.setOrCreate('udpIndex', udpIndex++)
|
|
||||||
}
|
}
|
||||||
|
private artSubject3ProjectsCodesArr: number[] = [3, 9, 4, 10, 12, 11]
|
||||||
// 处理轨迹plc信号
|
// 处理轨迹plc信号
|
||||||
handleTrajectoryUdp = async (strArr: string[]) => {
|
handleTrajectoryUdp = async (strArr: string[]) => {
|
||||||
let num = 2;
|
let num = 2;
|
||||||
@ -398,26 +418,6 @@ export default class Judge {
|
|||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
private isEndTip: boolean = false;
|
|
||||||
//本地轨迹回放地址
|
|
||||||
private trajectoryPath: string
|
|
||||||
// private currentKm2ItemsObj: any
|
|
||||||
private isTrajectoryOpen: boolean;
|
|
||||||
// 调代理接口是否断网了
|
|
||||||
private isJudgeDisConnect: boolean = false;
|
|
||||||
// 断网数据补传
|
|
||||||
uploadDisConnectData = async () => {
|
|
||||||
if (!this.isJudgeDisConnect) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
const folderPath = this.fileLog?.folderPath
|
|
||||||
const examDataStr = await this.fileUtil.readFile(`${folderPath}/wuxi_dis_progress_data.txt`);
|
|
||||||
const examDataArr = examDataStr.split('\n');
|
|
||||||
for (let examDataStr of examDataArr) {
|
|
||||||
const code = await writeObjectOut(JSON.parse(examDataStr), "", this.context);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
private artSubject3ProjectsCodesArr: number[] = [3, 9, 4, 10, 12, 11]
|
|
||||||
// 项目开始接口同步
|
// 项目开始接口同步
|
||||||
beginProject = async (ksxm: number) => {
|
beginProject = async (ksxm: number) => {
|
||||||
const carInfo = AppStorage.get<CarInfoType>('carInfo');
|
const carInfo = AppStorage.get<CarInfoType>('carInfo');
|
||||||
@ -521,6 +521,9 @@ export default class Judge {
|
|||||||
UploadRegulatoryCodeConversion('17C54', temp.code || 0)
|
UploadRegulatoryCodeConversion('17C54', temp.code || 0)
|
||||||
dConsole.info(JudgeTag, '上传照片 end')
|
dConsole.info(JudgeTag, '上传照片 end')
|
||||||
}
|
}
|
||||||
|
private lane: LANE = {
|
||||||
|
road: '', num: 0, count: 0
|
||||||
|
}
|
||||||
private disConnectNum: number = 0;
|
private disConnectNum: number = 0;
|
||||||
//调用监管接口
|
//调用监管接口
|
||||||
sendWriteObjectOut: SendWriteObjectOut = async (data, filePath) => {
|
sendWriteObjectOut: SendWriteObjectOut = async (data, filePath) => {
|
||||||
@ -543,9 +546,6 @@ export default class Judge {
|
|||||||
this.disConnectNum = 0
|
this.disConnectNum = 0
|
||||||
return temp
|
return temp
|
||||||
}
|
}
|
||||||
private lane: LANE = {
|
|
||||||
road: '', num: 0, count: 0
|
|
||||||
}
|
|
||||||
// 校验考试是否结束
|
// 校验考试是否结束
|
||||||
checkExamIsEnd = async (isManual?: boolean) => {
|
checkExamIsEnd = async (isManual?: boolean) => {
|
||||||
dConsole.log(JudgeTag, "校验考试是否结束")
|
dConsole.log(JudgeTag, "校验考试是否结束")
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user