Compare commits
	
		
			8 Commits
		
	
	
		
			5b43845710
			...
			60d8f3dec4
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 60d8f3dec4 | |||
| 34017a09d1 | |||
| ca57859bee | |||
| afd3dbd72d | |||
| d04828c5b4 | |||
| a2fef1e83a | |||
| 6abd03b0b8 | |||
| 2a78525e42 | 
| @ -225,25 +225,30 @@ export async function takePhotoFn(context) { | ||||
|       // param[key] = false
 | ||||
|     } | ||||
|     for (let i = 0; i <= arr.length - 1; i++) { | ||||
|       let key = arr[i] | ||||
|       if (param[key]) { | ||||
|       let key1 = arr[i] | ||||
|       if (param[key1]) { | ||||
|         param.pztd = param[`td${Number(i) + 1}`] | ||||
|          takePhoto(param, context, 'jt/', 0, (data) => { | ||||
|           consoele.log('getPhtogetPhto',data) | ||||
|           if (Number(data.fileSize) <= (Number(param.zdyz) * 1000)) { | ||||
|             map[key] = true | ||||
|             console.log('getPhtot0000') | ||||
| 
 | ||||
|             map[key1] = true | ||||
|             promptAction.showToast({ | ||||
|               message: `视频遮挡`, | ||||
|               duration: 3000 | ||||
|             }); | ||||
|             globalThis.spzd[key] = true | ||||
|             globalThis.spzd[key1] = true | ||||
|           } else { | ||||
|             map[key] = false | ||||
|             globalThis.spzd[key] = false | ||||
|             map[key1] = false | ||||
|             globalThis.spzd[key1] = false | ||||
|           } | ||||
|           console.log('getPhtot0000') | ||||
|           setTimeout(() => { | ||||
|             takePhotoFn() | ||||
|           }, 3000) | ||||
|         }) | ||||
| 
 | ||||
|       } | ||||
|     } | ||||
|     globalThis.takePhotoNum++ | ||||
|  | ||||
| @ -9,11 +9,11 @@ import FileUtil from '../../common/utils/File' | ||||
| //获取设备信息
 | ||||
| export async function getDeviceInfo(context) { | ||||
|   // globalThis.deviceNo = '153216400880'; //科目三设备
 | ||||
|   globalThis.deviceNo = '150667400235'; //科目三设备
 | ||||
|   // globalThis.deviceNo = '150667400235'; //科目三设备
 | ||||
|   // globalThis.deviceNo = '1649018001275'; //洛阳科目三设备
 | ||||
|   // globalThis.deviceNo = 'MAC-36E6575F'; //杭州科目二设备 489
 | ||||
|   // globalThis.deviceNo = 'MAC-C57C8966'; //杭州科目二设备
 | ||||
| 
 | ||||
|   return | ||||
|   return new Promise(async (resolve, reject) => { | ||||
|     const fileUtil = new FileUtil(context) | ||||
|     const data = await fileUtil.readFile(GlobalConfig.comoonfileWriteAddress + '/config/deviceNo.txt'); | ||||
|  | ||||
| @ -80,6 +80,7 @@ interface  takePhotoParam { | ||||
|   name?:string, | ||||
|   base64?:string, | ||||
|   fileSize?:number, | ||||
|   errorCode?:number | ||||
| } | ||||
| /** | ||||
|  * | ||||
| @ -106,15 +107,15 @@ export async function takePhoto(param, context,dir,flag=1,callback?) { | ||||
|   if(flag==0){ | ||||
|     rtsp_server.detectVideoSnapshotSize(video_uri,fileName,(err,snapResult)=>{ | ||||
|       console.log("baohaowen_detectLoop round end size1:"+snapResult.fileSize); | ||||
|       callback({fileSize:snapResult.fileSize }) | ||||
|       callback({fileSize:snapResult.fileSize,errorCode:snapResult.errorCode }) | ||||
|     }); | ||||
| 
 | ||||
|   } | ||||
|   else{ | ||||
|     return new Promise<takePhotoParam>((resolve,reject)=>{ | ||||
|       rtsp_server.getVideoSnapshot(context, video_uri, fileName,dir,true,(err,snapResult)=>{ | ||||
|         console.log('getPhtot') | ||||
|         resolve({base64: snapResult.dataString,name:snapResult.fileName,fileSize:snapResult.fileSize }) | ||||
|         console.log('getPhtot',JSON.stringify(snapResult)) | ||||
|         resolve({base64: snapResult.dataString,name:snapResult.fileName,fileSize:snapResult.fileSize,errorCode:snapResult.errorCode }) | ||||
|       }); | ||||
|     }) | ||||
|     console.log('getmyLog02') | ||||
|  | ||||
| @ -17,12 +17,7 @@ export async function getTCP() { | ||||
|             await globalThis.TcpClient.sendMsg('1002') //1002
 | ||||
|             globalThis.TcpClient.onError((val) => { | ||||
|               setTimeout(() => { | ||||
|                 globalThis.TcpClient.sendMsg('1002') //1002
 | ||||
|                 if (val) { | ||||
|                   // const msg=val.substring(5,val.length-1)
 | ||||
|                   console.log('socketTag[PLC.UdpClient] status:', globalThis.udpClient.getStatus()) | ||||
|                   globalThis.udpClient?.sendMsg(val) | ||||
|                 } | ||||
|                 getTCP() | ||||
|               }, 1000) | ||||
|             }) | ||||
|             await globalThis.TcpClient.onMessage((val) => { | ||||
| @ -46,12 +41,8 @@ export async function getTCP() { | ||||
|         await globalThis.TcpClient.connectTcp() | ||||
|         await globalThis.TcpClient.sendMsg('1002') //1002
 | ||||
|         globalThis.TcpClient.onError((val) => { | ||||
|           hilog.info(0x0000, 'testTag', "valvalval2" + JSON.stringify(val)); | ||||
|           setTimeout(() => { | ||||
|             globalThis.TcpClient.sendMsg('1002') //1002
 | ||||
|             if (val && globalThis.udpClient?.sendMsg) { | ||||
|               globalThis.udpClient?.sendMsg(val) | ||||
|             } | ||||
|             getTCP() | ||||
|           }, 1000) | ||||
|         }) | ||||
|         await globalThis.TcpClient.onMessage((val) => { | ||||
|  | ||||
| @ -7,7 +7,7 @@ export async function sendMsg(val) { | ||||
|   // globalThis.udpClient1&&globalThis.udpClient1.sendMsg(val)
 | ||||
| } | ||||
| 
 | ||||
| export async function getUDP() { | ||||
| export async function getUDP(errorFlag?) { | ||||
|   return new Promise((reslove,reject)=>{ | ||||
|     getSyncData('IpConfigTable').then((result: Array<any>) => { | ||||
|       if (result.length) { | ||||
| @ -19,10 +19,19 @@ export async function getUDP() { | ||||
|               globalThis.udpClient.rebindUdp(result[0].udplocalIp, result[0].udplocalIpPort, result[0].udpOppositeIp, result[0].udpOppositeIpPort) | ||||
|               globalThis.udpClient.sendMsg('111', null) | ||||
|               globalThis.host = `http://${result[0].centerIp}:${result[0].centerPort}` | ||||
|               globalThis.udpClient.onError_Callback(()=>{ | ||||
|                 console.log('getUDPgetUDPgetUDP') | ||||
|                 getUDP(true) | ||||
|                 if(errorFlag&&globalThis.udpClient&&globalThis.udpClient.onMessage_1){ | ||||
|                   globalThis.udpClient.onMessage_1=globalThis.udpClient.onMessage_1 | ||||
|                 } | ||||
|               }) | ||||
|               reslove(`http://${result[0].centerIp}:${result[0].centerPort}`) | ||||
| 
 | ||||
|               // globalThis.udpClient.onError_resend(globalThis.udpClient.onMessage_1?globalThis.udpClient.onMessage_1:()=>{})
 | ||||
|             }, 1000) | ||||
|           }) | ||||
| 
 | ||||
|         } | ||||
|         else { | ||||
|           // 未绑定
 | ||||
| @ -31,11 +40,23 @@ export async function getUDP() { | ||||
|           udpClient.bindUdp() | ||||
|           udpClient.sendMsg('111') | ||||
|           globalThis.host = `http://${result[0].centerIp}:${result[0].centerPort}` | ||||
|           // udpClient.onError_resend(globalThis.udpClient.onMessage_1?globalThis.udpClient.onMessage_1:()=>{})
 | ||||
|           globalThis.udpClient = udpClient | ||||
| 
 | ||||
|           globalThis.udpClient.onMessage_1(()=>{ | ||||
|             console.log('getUDPonMessage_1msgmsgByGloalUdp') | ||||
| 
 | ||||
|           }) | ||||
|           globalThis.udpClient.onError_Callback(()=>{ | ||||
|             getUDP(true) | ||||
|             if(errorFlag&&globalThis.udpClient&&globalThis.udpClient.onMessage_1){ | ||||
|               globalThis.udpClient.onMessage_1=globalThis.udpClient.onMessage_1 | ||||
|             } | ||||
|           }) | ||||
|           // udpClient.onError_resend(globalThis.udpClient.onMessage_1?globalThis.udpClient.onMessage_1:()=>{})
 | ||||
|           getChuankouFn() | ||||
|           reslove(`http://${result[0].centerIp}:${result[0].centerPort}`) | ||||
| 
 | ||||
| 
 | ||||
|         } | ||||
| 
 | ||||
|       } else { | ||||
| @ -56,7 +77,7 @@ export async function getUDP() { | ||||
| 
 | ||||
| } | ||||
| 
 | ||||
| export async function getUDP2() { | ||||
| export async function getUDP2(errorFlag?) { | ||||
|   console.log(` getUDP2  enter`); | ||||
|   getSyncData('IpConfigTable').then(async (result: Array<any>) => { | ||||
|     if (result.length) { | ||||
| @ -66,6 +87,12 @@ export async function getUDP2() { | ||||
|         globalThis.udpClient2.closeUdp(async () => { | ||||
|           setTimeout(() => { | ||||
|             globalThis.udpClient2.rebindUdp(result[0].udplocalIp, '8800', globalThis.carInfo?.udpAddress, globalThis.carInfo?.messagePort) | ||||
|             globalThis.udpClient2.onError_Callback(()=>{ | ||||
|               getUDP2(true); | ||||
|               if(errorFlag&&globalThis.udpClient2&&globalThis.udpClient2.onMessage_2){ | ||||
|                 globalThis.udpClient2.onMessage_2=globalThis.udpClient2.onMessage_2 | ||||
|               } | ||||
|             }) | ||||
|           }, 1000) | ||||
|         }) | ||||
|       } | ||||
| @ -74,7 +101,13 @@ export async function getUDP2() { | ||||
|         console.log(` getUDP2  has no  udclent and  bind `); | ||||
|         const udpClient2: UdpClientByCenter = new UdpClientByCenter(result[0].udplocalIp, '8800', globalThis.carInfo?.udpAddress, globalThis.carInfo?.messagePort) | ||||
|         await udpClient2.bindUdp() | ||||
|         await udpClient2.onError_Callback() | ||||
|         await udpClient2.onError_Callback(()=>{ | ||||
|           getUDP2(true); | ||||
|           if(errorFlag&&globalThis.udpClient2&&globalThis.udpClient2.onMessage_2){ | ||||
|             globalThis.udpClient2.onMessage_2=globalThis.udpClient2.onMessage_2 | ||||
|           } | ||||
|         }) | ||||
|         if(!errorFlag){ | ||||
|           await udpClient2.onMessage_2((val) => { | ||||
|             if (val.id == '32') { | ||||
|               globalThis.signNum = val.body[1] | ||||
| @ -94,7 +127,9 @@ export async function getUDP2() { | ||||
|               globalThis.udpClient2.send(param) | ||||
|             } | ||||
|           }) | ||||
|         } | ||||
|         globalThis.udpClient2 = udpClient2 | ||||
| 
 | ||||
|       } | ||||
|     } else { | ||||
|       globalThis.udpClient2 = {} | ||||
| @ -137,6 +172,7 @@ export async function setJudgeUdp() { | ||||
|     await udpClientbyCenter.bindUdp() | ||||
|     await udpClientbyCenter.onMessage_1((val) => { | ||||
|       console.log('valval', val) | ||||
| 
 | ||||
|     }) | ||||
|     // globalThis.judgeUdpClient = udpClientbyCenter;
 | ||||
|     return { | ||||
|  | ||||
| @ -1,5 +1,6 @@ | ||||
| import socket from '@ohos.net.socket'; | ||||
| import hilog from '@ohos.hilog'; | ||||
| import { getTCP } from './GlobalTcp'; | ||||
| 
 | ||||
| const TAG = 'socketTag[TcpDemo.TcpClient]' | ||||
| 
 | ||||
| @ -24,9 +25,7 @@ export default class TcpClient { | ||||
|     this.tcp.on('error', err => { | ||||
|       console.log(TAG, 'tcpOnerror', JSON.stringify(err)) | ||||
|       setTimeout(async () => { | ||||
|         await this.bindTcp() | ||||
|         await this.connectTcp() | ||||
|         this.onMessage(callback) | ||||
|         getTCP() | ||||
|       }, 2000) | ||||
|       // this.closeUdp(()=>{
 | ||||
|       //   this.bindUdp()
 | ||||
|  | ||||
| @ -73,11 +73,11 @@ export default class UdpClientByCenter { | ||||
|     promise.then(() => { | ||||
|       //   globalThis.closeHeartSocket=false
 | ||||
|       this.isWorking = true | ||||
|       console.log(`${TAG} udp bind success`); | ||||
|       console.log(`${TAG} getUDPudp rebind success`); | ||||
|     }).catch(err => { | ||||
|       //globalThis.closeHeartSocket=true
 | ||||
|       this.isWorking = false | ||||
|       console.log(`${TAG} udp bind failed:${JSON.stringify(err)}`); | ||||
|       console.log(`${TAG} getUDPudp rebind failed:${JSON.stringify(err)}`); | ||||
|     }); | ||||
|   } | ||||
| 
 | ||||
| @ -87,10 +87,10 @@ export default class UdpClientByCenter { | ||||
|     }); | ||||
|     promise.then(() => { | ||||
|       this.isWorking = true | ||||
|       console.log(`${TAG} udp bind success`); | ||||
|       console.log(`${TAG} getUDPudp bind success`); | ||||
|     }).catch(err => { | ||||
|       this.isWorking = false | ||||
|       console.log(`${TAG} udp bind failed:${JSON.stringify(err)}`); | ||||
|       console.log(`${TAG} getUDPudp bind failed:${JSON.stringify(err)}`); | ||||
|     }); | ||||
|   } | ||||
| 
 | ||||
| @ -147,9 +147,9 @@ export default class UdpClientByCenter { | ||||
|   } | ||||
| 
 | ||||
|   sendHeadMsg(msgData) { | ||||
|     console.log('sendHeadMsg enter') | ||||
|     console.log('getUDPsendHeadMsg enter') | ||||
|     this.sendMsg(msgData, null) | ||||
|     console.log('sendHeadMsg exit') | ||||
|     console.log('getUDPsendHeadMsg exit') | ||||
|   } | ||||
| 
 | ||||
|   sendMsg(msg, sendCallback?) { | ||||
| @ -172,12 +172,12 @@ export default class UdpClientByCenter { | ||||
|           if (sendCallback) { | ||||
|             sendCallback() | ||||
|           } | ||||
|           console.log(`${TAG}udpCLient udp send success:oppositeIp${this.oppositeIp},oppositeIpPort:${this.oppositeIpPort},localIp:${this.localIp},localIpPort,${this.localIpPort}`); | ||||
|           console.log(`${TAG}getUDPudpCLient udp send success:oppositeIp${this.oppositeIp},oppositeIpPort:${this.oppositeIpPort},localIp:${this.localIp},localIpPort,${this.localIpPort}`); | ||||
|         }).catch(err => { | ||||
|           console.log(`${TAG}udpCLient udp send fail:oppositeIp${this.oppositeIp},oppositeIpPort:${this.oppositeIpPort},localIp:${this.localIp},localIpPort,${this.localIpPort}`); | ||||
|           console.log(`${TAG}getUDPudpCLient udp send fail:oppositeIp${this.oppositeIp},oppositeIpPort:${this.oppositeIpPort},localIp:${this.localIp},localIpPort,${this.localIpPort}`); | ||||
|         }); | ||||
|       } | ||||
|       console.log('getState success:' + JSON.stringify(data)); | ||||
|       console.log('getUDPgetState success:' + JSON.stringify(data)); | ||||
|     }) | ||||
|   } | ||||
| 
 | ||||
| @ -194,7 +194,7 @@ export default class UdpClientByCenter { | ||||
|   onError_Callback(callback?) { | ||||
|     this.udp.on('error', async err => { | ||||
|       this.isWorking = false; | ||||
|       console.log('UdpClientByCenter  onError err:' + JSON.stringify(err)); | ||||
|       console.log('getUDPUdpClientByCenter  onError err:' + JSON.stringify(err)); | ||||
|       callback && callback() | ||||
|     }); | ||||
|   } | ||||
| @ -202,7 +202,7 @@ export default class UdpClientByCenter { | ||||
|   onError_resend(callback?) { | ||||
|     this.udp.on('error', async err => { | ||||
|       this.isWorking = false; | ||||
|       console.log(TAG, 'udpError', JSON.stringify(err)) | ||||
|       console.log(TAG, 'getUDPudpError', JSON.stringify(err)) | ||||
|       await this.bindUdp() | ||||
|       await this.sendMsg('111', null) | ||||
|       await this.onMessage_1(callback) | ||||
| @ -243,16 +243,16 @@ export default class UdpClientByCenter { | ||||
|   } | ||||
| 
 | ||||
|   closeUdp(callback?) { | ||||
|     console.log('UdpClientByCenter  enter closeUdp ip:' + this.localIp + ' port:' + this.localIpPort); | ||||
|     console.log('getUDPUdpClientByCenter  enter closeUdp ip:' + this.localIp + ' port:' + this.localIpPort); | ||||
|     this.udp.close(err => { | ||||
|       if (err) { | ||||
|         console.log('UdpClientByCenter  closeUdp  failed ip:' + this.localIp + ' port:' + this.localIpPort + ' err:' + JSON.stringify(err)); | ||||
|         console.log('getUDPUdpClientByCenter  closeUdp  failed ip:' + this.localIp + ' port:' + this.localIpPort + ' err:' + JSON.stringify(err)); | ||||
|       } else { | ||||
|         this.isWorking = false | ||||
|         if (callback != null) { | ||||
|           callback() | ||||
|         } | ||||
|         console.log('UdpClientByCenter  closeUdp  succeed ip:' + this.localIp + ' port:' + this.localIpPort); | ||||
|         console.log('getUDPUdpClientByCenter  closeUdp  succeed ip:' + this.localIp + ' port:' + this.localIpPort); | ||||
|       } | ||||
|     }) | ||||
|   } | ||||
| @ -264,9 +264,9 @@ export default class UdpClientByCenter { | ||||
|   } | ||||
| 
 | ||||
|   closeMessage_1(){ | ||||
|     console.info('surenjun', '关闭udp message监听事件') | ||||
|     console.info('surenjun', 'getUDP关闭udp message监听事件') | ||||
|     this.udp.off('message',this.message_1Fn); | ||||
|     console.info('surenjun', '关闭udp message监听事件 成功') | ||||
|     console.info('surenjun', 'getUDP关闭udp message监听事件 成功') | ||||
|   } | ||||
| 
 | ||||
|   message_1Fn = (value)=>{ | ||||
| @ -291,7 +291,7 @@ export default class UdpClientByCenter { | ||||
|       } | ||||
|       console.log(`${TAG} udp222 on message array buffer:${str}`); | ||||
| 
 | ||||
|       strachArr[28] = globalThis.chuankoMsg || '0' | ||||
|       strachArr[28] = globalThis.chuankoMsg || strachArr[28] | ||||
|       // this.stashFn(str)
 | ||||
|       const newArr = JSON.parse(JSON.stringify(strachArr)) | ||||
|       // this.stashFn=()=>{}
 | ||||
|  | ||||
| @ -28,8 +28,8 @@ export default class EntryAbility extends UIAbility { | ||||
|         globalThis.examinerInfo = {} | ||||
|         globalThis.deviceNo = ''; | ||||
|         globalThis.hasAuth = false | ||||
|         globalThis.version = '2024.11.22.14' | ||||
|         globalThis.judgeVersion = '2024.11.22.14' | ||||
|         globalThis.version = '2022.08.13.01' | ||||
|         globalThis.judgeVersion = '2022.12.05.1' | ||||
|         globalThis.videoVersion= '1.0' | ||||
|         // globalThis.version = '2023.12.13.01'
 | ||||
|         // globalThis.judgeVersion = '2023.09.30.1'
 | ||||
|  | ||||
| @ -103,6 +103,9 @@ export default struct Index { | ||||
|     router.pushUrl({ | ||||
|       url: 'pages/SignDisplay', | ||||
|     }, router.RouterMode.Single); | ||||
|     this.stachValue = JSON.parse(JSON.stringify(StackValueData)) | ||||
|     this.warnFlag = JSON.parse(JSON.stringify(WarnFlagData)) | ||||
|     this.passArray = JSON.parse(JSON.stringify(PassData)) | ||||
|     // clearInterval(this.interval) | ||||
| 
 | ||||
|   } | ||||
| @ -157,6 +160,9 @@ export default struct Index { | ||||
|     this.warnFlag = WarnFlagData | ||||
|     this.passArray = PassData | ||||
|     this.checkListCopy = JSON.parse(JSON.stringify(this.checkList)) | ||||
|     this.stachValue = JSON.parse(JSON.stringify(StackValueData)) | ||||
|     this.warnFlag = JSON.parse(JSON.stringify(WarnFlagData)) | ||||
|     this.passArray = JSON.parse(JSON.stringify(PassData)) | ||||
|     this.index = this.checkListCopy[0].key | ||||
|     this.vocObj.playAudio({ | ||||
|       type: 1, | ||||
| @ -167,6 +173,8 @@ export default struct Index { | ||||
|   getPLCInfo() { | ||||
|     const that = this | ||||
|     globalThis.udpClient.onMessage_1 && globalThis.udpClient.onMessage_1((msg) => { | ||||
|       console.log('getUDPonMessage_1byCarCheck2') | ||||
| 
 | ||||
|       if (!this.breakFlag) { | ||||
|         return | ||||
|       } | ||||
| @ -309,6 +317,9 @@ export default struct Index { | ||||
|   outClick() { | ||||
|     this.vocObj && this.vocObj.releasePlayer() | ||||
|     this.breakFlag = false | ||||
|     this.stachValue = JSON.parse(JSON.stringify(StackValueData)) | ||||
|     this.warnFlag = JSON.parse(JSON.stringify(WarnFlagData)) | ||||
|     this.passArray = JSON.parse(JSON.stringify(PassData)) | ||||
|     // clearInterval(this.interval) | ||||
|   } | ||||
| 
 | ||||
|  | ||||
| @ -11,7 +11,7 @@ import FileUtil from '../common/utils/File'; | ||||
| import { getUDP, getUDP2 } from '../common/utils/GlobalUdp'; | ||||
| import { initJudgeUdp } from '../common/utils/UdpJudge'; | ||||
| import { getTCP } from '../common/utils/GlobalTcp'; | ||||
| import { getliushuiNum, setliushuiNum } from '../common/service/indexService'; | ||||
| import { getliushuiNum, setliushuiNum,takePhotoFn } from '../common/service/indexService'; | ||||
| import abilityAccessCtrl, { Permissions } from '@ohos.abilityAccessCtrl'; | ||||
| import worker, { MessageEvents } from '@ohos.worker'; | ||||
| import promptAction from '@ohos.promptAction' | ||||
| @ -285,7 +285,6 @@ struct Index { | ||||
|         this.heartMsg() | ||||
|       } | ||||
|     }, 1000) | ||||
|     // takePhotoFn(this.context) | ||||
| 
 | ||||
|     // | ||||
|     getTCP() | ||||
| @ -337,6 +336,7 @@ struct Index { | ||||
| 
 | ||||
|   async initParams() { | ||||
|     this.loading = false | ||||
|     takePhotoFn(this.context) | ||||
|     this.deviceId=await getDeviceInfo(this.context) || '' | ||||
|     await getCarInfo() | ||||
|     await setCurrentTime(); | ||||
|  | ||||
| @ -49,15 +49,22 @@ struct Index { | ||||
|       this.time = await getCurrentTime(); | ||||
|       this.examTime += 1; | ||||
|     }, 1000); | ||||
|     console.log('SURENJUN_JUDGE',10) | ||||
| 
 | ||||
|     //初始化数据库表 | ||||
|     await this.initDb() | ||||
| 
 | ||||
|     //断点续考 | ||||
|     console.log('SURENJUN_JUDGE',11) | ||||
| 
 | ||||
|     await this.goDdxkItems() | ||||
| 
 | ||||
|     //初始化评判 | ||||
|     console.log('SURENJUN_JUDGE',6) | ||||
| 
 | ||||
|     const judge = await this.initJudge(); | ||||
|     console.log('SURENJUN_JUDGE',7) | ||||
| 
 | ||||
|     this.judge = judge | ||||
| 
 | ||||
|   } | ||||
| @ -69,7 +76,6 @@ struct Index { | ||||
|     const {isTrajectoryOpen,trajectoryPath} = judgeConfig | ||||
|     await this.initStudent(); | ||||
|     await this.initCar(); | ||||
| 
 | ||||
|     //是否开启轨迹回放模式 | ||||
|     if (isTrajectoryOpen) { | ||||
|       this.initTrajectoryParam(trajectoryPath) | ||||
| @ -79,12 +85,16 @@ struct Index { | ||||
|       await this.initSysset(); | ||||
|       this.singlePlay = globalThis.singlePlay | ||||
|     } | ||||
| 
 | ||||
|     await this.initCDSBInfo() | ||||
| 
 | ||||
|     // 科目三新增读取表数据 | ||||
|     if (examSubject == 3) { | ||||
| 
 | ||||
|       await this.initMapPoint() | ||||
| 
 | ||||
|       await this.initMapPointItem() | ||||
| 
 | ||||
|       //定时上传考试里程 | ||||
|       // let mileageTimer = setInterval(()=>{ | ||||
|       //   this.uploadMileage() | ||||
| @ -331,7 +341,10 @@ struct Index { | ||||
| 
 | ||||
|   // 评判相关初始化 | ||||
|   async initJudge() { | ||||
|     console.log('SURENJUN_JUDGE',0) | ||||
| 
 | ||||
|     const judge = new Judge(this); | ||||
|     console.log('SURENJUN_JUDGE',30) | ||||
|     await judge.onJudgeFn(async (judgeData) => { | ||||
|       const {xmmcStr,carztStr,kfArr} = judgeData; | ||||
|       this.xmmcStr = xmmcStr; | ||||
|  | ||||
| @ -18,8 +18,8 @@ struct Index { | ||||
|   // '',] | ||||
|   // @State inputTextList2: string[] = ['192.168.7.124','20022'] | ||||
| 
 | ||||
|   @State inputTextList1: string[] = ['172.37.55.191','18782','172.37.55.191','8082','255.255.255.0','172.37.55.1','114.114.114.114','192.168.7.124','20022','172.37.55.59','20122'] | ||||
|   // @State inputTextList1: string[] = ['172.37.55.191','18782','172.37.55.191','8082','255.255.255.0','192.168.7.1','114.114.114.114','192.168.7.124','20022','192.168.7.170','20122'] | ||||
|   // @State inputTextList1: string[] = ['172.37.55.191','18782','192.168.7.1','8082','255.255.255.0','192.168.7.170','114.114.114.114','192.168.7.124','20022','172.37.55.59','20122'] | ||||
|   @State inputTextList1: string[] = ['192.168.1.144','18782','192.168.1.144','8082','255.255.255.0','192.168.7.1','114.114.114.114','192.168.7.124','20022','192.168.7.170','20122'] | ||||
|   // @State inputTextList2: string[] = [] | ||||
|   // 112.80.35.83 11052 | ||||
|   // @State inputTextList1: string[] = ['192.168.36.2','8084','192.168.36.200','20122','255.255.255.0','192.168.36.1','','','114.114.114.114','192.168.36.139','8000'] | ||||
|  | ||||
| @ -17,18 +17,14 @@ import promptAction from '@ohos.promptAction'; | ||||
| import FilePhoto from './judgeSDK/utils/filePhoto'; | ||||
| import { getSyncData, upDateTableByArray } from '../common/service/initable'; | ||||
| import { CandidateData, EmptyCandidateObject } from '../mock/CandidateData'; | ||||
| import BoardPrePareSetPopup from './compontents/judge/BoardPrePareSetPopup' | ||||
| import BoardPrePareSetPopup from './compontents/judge/BoardPrePareSetPopup'; | ||||
| import LoadingPopup from './compontents/judge/LoadingPopup'; | ||||
| import VoiceAnnounce from './judgeSDK/utils/voiceAnnouncements'; | ||||
| import { JudgeConfig } from '../config/judge'; | ||||
| import { judgeConfig } from './judgeSDK/utils/judgeConfig'; | ||||
| 
 | ||||
| @Entry | ||||
| @Component | ||||
| struct UserInfo { | ||||
|   private filePhoto: FilePhoto | ||||
|   private avPlayer | ||||
| 
 | ||||
|   @State pageIndex: number = 0 | ||||
|   @State ratio: number = 1700 / 960 | ||||
|   @State index: number = 0 | ||||
| @ -49,7 +45,10 @@ struct UserInfo { | ||||
|   @State isBoardPrePareSetPopupShow: boolean = false | ||||
|   @State isLoadingPopupVisible: boolean = false; | ||||
|   @State loadingText: string = '正在认证监管信息,请稍后...' | ||||
|   @State sczbkf:{xmdm:number,kfdm:string}[] = [] | ||||
|   @State sczbkf: { | ||||
|     xmdm: number, | ||||
|     kfdm: string | ||||
|   }[] = [] | ||||
|   @State currentUser: User = EmptyCandidateObject | ||||
|   @State dataList: Array<User> = [] | ||||
|   @State list: Array<User> = [] | ||||
| @ -70,6 +69,7 @@ struct UserInfo { | ||||
|   @State numCount: number = 0; | ||||
|   @State signNum: number = 0; | ||||
|   @State isCanClick: boolean = true; | ||||
|   @State updateTimeLimit: boolean = true | ||||
|   @State faceFlag: string = '0'; | ||||
|   @State FaceOpenStatue: string = '0'; //是否开启人脸识别 | ||||
|   subscriber; | ||||
| @ -86,7 +86,10 @@ struct UserInfo { | ||||
|       return photoBase64 | ||||
|     } | ||||
|   } | ||||
|   private AccountTable = new AccountTable(() => {}, USER); | ||||
|   private filePhoto: FilePhoto | ||||
|   private avPlayer | ||||
|   private AccountTable = new AccountTable(() => { | ||||
|   }, USER); | ||||
|   private context = getContext(this) as common.UIAbilityContext; | ||||
|   private labelBlocks = [ | ||||
|     { label: '考生姓名', key: 'xm' }, | ||||
| @ -308,7 +311,7 @@ struct UserInfo { | ||||
|         that.ksxtbh = ksxtbhArr?.[0]?.v_value || '222' | ||||
|         const studentRefreshParam = syssetParams.filter(sys => sys.v_no === '452') | ||||
|         that.studentRefreshStatue = studentRefreshParam?.[0]?.v_value || '0' | ||||
|         const faceParam = syssetParams.filter(sys => sys.v_no === '2313') | ||||
|         const faceParam = syssetParams.filter(sys => sys.v_no === '2413') | ||||
|         that.FaceOpenStatue = faceParam?.[0]?.v_value == '3' ? '1' : '0' | ||||
|         that.FaceOpenStatue = '0' | ||||
|         console.log('that.FaceOpenStatue', that.FaceOpenStatue) | ||||
| @ -383,11 +386,15 @@ struct UserInfo { | ||||
| 
 | ||||
|   //获取下载考生 | ||||
|   getExaminationStudentInfoFn() { | ||||
|     if (globalThis.singlePlay) { | ||||
|     if (globalThis.singlePlay && this.updateTimeLimit) { | ||||
|       return | ||||
|     } | ||||
|     const param = `<getExaminationStudentInfoReq><head><checkCode>${Md5.Instance.get_md5(globalThis.carInfo.carId + globalThis.carInfo.examinationRoomId + globalThis.username)}</checkCode></head><body><carId>${globalThis.carInfo.carId}</carId><examinationRoomId>${globalThis.carInfo.examinationRoomId}</examinationRoomId><examinerName>${globalThis.username}</examinerName></body></getExaminationStudentInfoReq>` | ||||
|     getExaminationStudentInfo(param).then(res => { | ||||
|       setTimeout(() => { | ||||
|         this.updateTimeLimit = true | ||||
|       }, 30000) | ||||
|       this.updateTimeLimit = false | ||||
|       if (!res) { | ||||
|         this.dataList = [] | ||||
|         this.currentUser = EmptyCandidateObject | ||||
| @ -755,13 +762,7 @@ struct UserInfo { | ||||
|                   if (!this.currentUser.xm) { | ||||
|                     return | ||||
|                   } | ||||
|                   // if(globalThis.spzdFlag){ | ||||
|                   //   promptAction.showToast({ | ||||
|                   //     message: '摄像头被遮挡', | ||||
|                   //     duration: 2000 | ||||
|                   //   }); | ||||
|                   //   return | ||||
|                   // } | ||||
| 
 | ||||
|                   console.info('surenjun currentUser', JSON.stringify(this.currentUser)) | ||||
|                   if (globalThis.singlePlay) { | ||||
|                     const {examSubject} = globalThis.carInfo; | ||||
| @ -886,7 +887,7 @@ struct CommText { | ||||
| 
 | ||||
|   build() { | ||||
|     Text(this.text) | ||||
|       .fontSize(16 * this.ratio) | ||||
|       .fontSize(19.5 * this.ratio) | ||||
|       .lineHeight(30 * this.ratio) | ||||
|       .fontWeight(500) | ||||
|       .fontColor(this.color) | ||||
| @ -912,9 +913,13 @@ struct LabelBlock { | ||||
| 
 | ||||
|   build() { | ||||
|     Row() { | ||||
|       Text(this.label).fontSize(16 * this.ratio).fontColor('#99948A') | ||||
|       Text(this.label).fontSize(18 * this.ratio).fontColor('#99948A') | ||||
|       Row() { | ||||
|         Text(decodeURIComponent(this.value)).fontColor('#fff').textAlign(TextAlign.Center).width('100%') | ||||
|         Text(decodeURIComponent(this.value)) | ||||
|           .fontColor('#fff') | ||||
|           .textAlign(TextAlign.Center) | ||||
|           .width('100%') | ||||
|           .fontSize(20 * this.ratio) | ||||
|       } | ||||
|       .commLabelStyle() | ||||
|     }.margin({ bottom: 10 * this.ratio }) | ||||
|  | ||||
| @ -235,7 +235,28 @@ export default struct SignDisplayCom { | ||||
|         .backgroundImage($r('app.media.km_open')) | ||||
|         .backgroundImageSize({ width: '100%', height: '100%' }) | ||||
|         .visibility(this.active == 0 ? Visibility.Visible : Visibility.None) | ||||
|         Column() { | ||||
|           Column() { | ||||
|             Text( this.msg || '0') | ||||
|               .fontColor('#FFF5E5') | ||||
|               .fontSize(14 * this.ratio) | ||||
|               .width('100%') | ||||
|               .textAlign(TextAlign.Start) | ||||
| 
 | ||||
|           } | ||||
|           .backgroundColor('#282828') | ||||
|           .width(this.ratio * 890) | ||||
|           .height(436 * this.ratio) | ||||
|           .margin({ left: 0 * this.ratio, top: 15 * this.ratio }) | ||||
| 
 | ||||
|         } | ||||
|         .width(936 * this.ratio) | ||||
|         .height(480 * this.ratio) | ||||
|         .margin({ left: 10 * this.ratio }) | ||||
|         .padding({ left: 10 * this.ratio, right: 10 * this.ratio }) | ||||
|         .backgroundImage($r('app.media.km_open')) | ||||
|         .backgroundImageSize({ width: '100%', height: '100%' }) | ||||
|         .visibility(this.active == 2 ? Visibility.Visible : Visibility.None) | ||||
|         Row() { | ||||
|           Flex({ direction: FlexDirection.Column }) { | ||||
|             Row() { | ||||
| @ -308,7 +329,7 @@ export default struct SignDisplayCom { | ||||
|     if (showBack) { | ||||
|       this.ratio = 1.4 | ||||
|       globalThis.udpClient.onMessage_1((msg) => { | ||||
|         console.log('msgmsg', msg) | ||||
|         console.log('getUDPonMessage_1bysignDisplay0', msg) | ||||
|         if (msg) { | ||||
|           getSignal(msg) | ||||
|         } | ||||
| @ -333,6 +354,8 @@ export default struct SignDisplayCom { | ||||
|     const showBack = this.showBack; | ||||
|     if (showBack) { | ||||
|       globalThis.udpClient.onMessage_1((msg) => { | ||||
|         console.log('getUDPonMessage_1bysignDisplay2', msg) | ||||
| 
 | ||||
|         getSignal(msg) | ||||
|       }) | ||||
|     } else { | ||||
|  | ||||
| @ -25,7 +25,10 @@ export async function examJudgeVersion(){ | ||||
|  * @desc 设置评判日志级别和日志回调函数 | ||||
|  */ | ||||
| export async function examJudgeSetLogCallback(level:number,handleLog:Function):Promise<string>{ | ||||
|   console.log('SURENJUN_JUDGESDK',0) | ||||
|   const temp = libJudgeSdk.examJudgeSetLogCallback(level,handleLog); | ||||
|   console.log('SURENJUN_JUDGESDK',1) | ||||
| 
 | ||||
|   return await handle(temp,'examJudgeSetLogCallback') | ||||
| } | ||||
| 
 | ||||
|  | ||||
| @ -2,7 +2,7 @@ | ||||
| //考试回放开关
 | ||||
| export const judgeConfig = { | ||||
|   //本地目录开关
 | ||||
|   isTrajectoryOpen: true, | ||||
|   isTrajectoryOpen: false, | ||||
|   //是否开启拍照
 | ||||
|   isPhotoOpen: false, | ||||
|   //扣分语音是否强制开启
 | ||||
|  | ||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user