subject-two/entry/src/main/ets/common/service/indexService.ts

// @ts-nocheck
import promptAction from '@ohos.promptAction'
import router from '@ohos.router'
import { dateFormat } from '../utils/tools'
import FileUtil from '../../common/utils/File'
import AccountTable from '../../common/database/tables/AccountTable';
import MA_SYSSET from '../../common/constants/MA_SYSSET';
import { takePhoto, deleteAllFileByPiC } from '../../common/service/videoService'

import {
  getDataBaseTable,
  upDateTable,
  getMySystemSetTable,
  delSyncTable,
  upDataZhongxinginitialization
} from '../../common/service/initable'
import { GlobalConfig } from '../../config/index'
import testNapi from '@ohos.hiserialsdk'

export async function getliushuiNum(){
  console.log('getLiushuihao')
  this.fileUtil = new FileUtil(this.context)
  const data = await this.fileUtil.readFile(GlobalConfig.comoonfileWriteAddress+'/config/liushui.txt');
  if(data === '' || data === undefined){
    this.num=0
    let str=this.num.toString()
    for(let i=0;str.length<=5;i++){
      str='0'+str
    }
    this.lsh=str
    // return str
  }else{
    this.num=Number(JSON.parse(data).value)+1
    let str=this.num.toString()
    for(let i=0;str.length<=5;i++){
      str='0'+str
    }
    this.lsh=str
    // return str
  }
}
//配置流水号
export async function setliushuiNum(context) {
  const fileUtil = new FileUtil(context)
  try {
    const fileData = await fileUtil.readFile(GlobalConfig.comoonfileWriteAddress + '/config/liushui.txt');
    const date = new Date()
    const time1 = JSON.parse(fileData).date.split(' ')[0]
    const time2 = dateFormat(date).split(' ')[0]
    if (time1 == time2) {
      const param = {
        date: dateFormat(date),
        value: Number(JSON.parse(fileData).value) + 1
      }
      const folderPath = await fileUtil.initFolder(`/config`);
      fileUtil.addFile(`${folderPath}/liushui.txt`, JSON.stringify(param))
      return
    }
    const param = {
      date: dateFormat(date),
      value: 0
    }
    const folderPath = await fileUtil.initFolder(`/config`);
    fileUtil.addFile(`${folderPath}/liushui.txt`, JSON.stringify(param))
  } catch (err) {
    const date = new Date()
    const param = {
      date: dateFormat(date),
      value: 0
    }
    const folderPath = await fileUtil.initFolder(`/config`);
    fileUtil.addFile(`${folderPath}/liushui.txt`, JSON.stringify(param))
  }

}

//双中心表
export async function getDoubleCeneterTable() {
  return new Promise(async (reslove, reject) => {
    // MA_SYSSET双中心下做合并表格操作
    const db = new AccountTable(() => {
    }, MA_SYSSET);
    db.getRdbStore(() => {
      db.query('0', async (array) => {
        if (array.length) {
          delSyncTable('MA_SYSSET').then(async () => {
            await getDataBaseTable({ tableName: 'MA_SYSSET' })
            await getMySystemSetTable({ tableName: 'MA_SYSSET' })
          })
        } else {
          await getDataBaseTable({ tableName: 'MA_SYSSET' })
          await getMySystemSetTable({ tableName: 'MA_SYSSET' })
        }
      })
    })
    const typeObj = {
      'MA_MARKRULE': false,
      'MA_SYSTEMPARM': false,
      'MA_MAP_COLLECT': false,
      'MA_MAP_COLLECT_SHAPE': false,
      'MA_MAP_ITEMCLASS': false,
      'MA_MAP_POINT': false,
      'MA_MAP_POINT_ITEM': false,
      'MA_MAP_ROAD': false,
      'MA_MAP_ROAD_LANE': false,
      'MA_MAP_SUBITEM': false,
      'ES_CARINFO': false,
      'ES_EXAMPOINTDETAIL': false,
      'MA_MARKRULESET': false,
      'ES_CAR_VIDEO_PARAMETER': false,
      'MA_CDSBINFO': false,
      'MA_ITEMINFO': false,
      'MA_T_CARPARMSET': false
    }
    for (let key in typeObj) {
      typeObj[key] = await upDateTable({ tableName: key })
      if (!typeObj[key]) {
        promptAction.showToast({
          message: `未能查询到${key}表数据， 请先检查网络是否连接正常`,
          duration: 3000
        });
        reslove(false)
        return
      }
    }
    reslove(true)
    router.pushUrl({
      url: 'pages/ExaminerLogin',
    }, router.RouterMode.Single);
  })

}
//单中心存表
export async function getSingleCenterTable() {
  return new Promise((reslove, reject) => {
    upDataZhongxinginitialization().then((result) => {
      if (result) {
        router.pushUrl({
          url: 'pages/ExaminerLogin',
        }, router.RouterMode.Single)
        reslove(true)
      } else {
        promptAction.showDialog({
          title: '提示',
          message: '联网更新失败，请检查网络后重新更新',
          buttons: [
            {
              text: '确认',
              color: '#000000',
            },
            {
              text: '取消',
              color: '#000000',
            }
          ],
        })
          .then(data => {
            reslove(false)
          })
          .catch(err => {
            reslove(false)
          })

        reslove(false)
      }
    }).catch((error) => {
      reslove(false)
      console.log(error)
    })

  })

}

let interval

export async function takePhotoFn(context) {
  let param = {
    videoNum: '1',
    spls: '1',
    wz: '0,0',
    faceFlag: false,
    shuiying: true,
    pztd: '2',
    ljlx: '',
    ip: '192.168.36.94',
    port: '554',
    userName: 'admin',
    pwd: '12345qwe',
    td1: '1',
    td2: '2',
    td3: '3',
    td4: '4',
    videoRecord1: false,
    videoRecord2: true,
    videoRecord3: false,
    videoRecord4: false,
    text1: '',
    text2: '',
    text3: '',
    dolt: '',
    fontSize: '',
    rlls: '1',
    spzd4: false,
    spzd3: false,
    spzd2: false,
    spzd1: false,
    zdyz: '5',
  }
  globalThis.spzd={
    spzd1:false,
    spzd2:false,
    spzd3:false,
    spzd4:false,
  }
  globalThis.takePhotoNum = 0
  const map = {}
  const fileUtil = new FileUtil(context)
  const fileData = await fileUtil.readFile(GlobalConfig.comoonfileWriteAddress + '/config/config3.txt');
  console.log('sizesize', fileData)
  param = JSON.parse(fileData)
  console.log('paramparam')
  clearInterval(interval)
  interval = setTimeout(async () => {
    const arr = ['spzd1', 'spzd2', 'spzd3', 'spzd4']

    for (let key in map) {
      map[key] = false
      // param[key] = false
    }
    for(let i=0;i<=arr.length-1;i++){
      let key=arr[i]
      if (param[key]) {
        param.pztd = param[`td${Number(i) + 1}`]
        takePhoto(param, context, 'jt/',0,(data)=>{
          if (Number(data.fileSize) <= (Number(param.zdyz) * 1000)) {
            map[key] = true
            promptAction.showToast({
              message: `视频遮挡`,
              duration: 3000
            });
            globalThis.spzd[key] = true
          } else {
            map[key] = false
            globalThis.spzd[key] = false
          }
          setTimeout(()=>{
            takePhotoFn()
          },3000)
        })
      }
    }
    globalThis.takePhotoNum++
    if (globalThis.takePhotoNum >= 20) {
      globalThis.takePhotoNum = 0
      // deleteAllFileByPiC('jt')
    }
  }, 3000)
}
let fd
const devPath="/dev/ttyS3"
function openChuankouFn() {
  fd = testNapi.SerialOpen(devPath);
  globalThis.num=0
  globalThis.fd=fd
  console.log('fdfd1111',globalThis.fd)

  let parity = 0x4e; // 'N'
  let ret = testNapi.SerialSet(globalThis.fd, 115200, 0, 8, 1, parity);
}

function getChuankouFnMsg() {
  let timeout = 50000; // 2秒超时
  let databuff = [0x61, 0xAA, 0x0A, 0X15, 0X00]; // send ABCDE
  console.log('fdfd',globalThis.fd)
  let ret = testNapi.SerialSend(globalThis.fd, databuff);
  console.log('mmmm',ret)
  // let revTestInfo = testNapi?.SerialRecv(globalThis.fd, timeout);
  testNapi.SerialRecvAsync(globalThis.fd, timeout, (revTestInfo) => {
    console.log('revTestInfo',revTestInfo.recevedBuf.length)

    const message = revTestInfo?.recevedBuf?.toString()
    console.log('chuankou',message)
    if (message == '') {
      globalThis.num++
      return
    }
    const msg = message?.split(',')
    if(!msg?.length){
      return
    }
    if (msg[0] != '98' || msg[1] != '85' || msg.length < 9) {
      return
    }
    globalThis.chuankoMsg=msg[9]
    // hilog.info(0x0000, 'testTag', 'Test NAPI SerialRecvAsync callback in');
    // hilog.info(0x0000, 'testTag', 'Test NAPI SerialRecvAsync recevedLen = %{public}d', revTestInfo.recevedLen);
    // hilog.info(0x0000, 'testTag', 'Test NAPI SerialRecvAsync recevedBuf = %{public}s', revTestInfo.recevedBuf.toString());
  });



}
let chuankou
export async function getChuankouFn(){
  return
  if(globalThis.fd){
    return
  }
  openChuankouFn()
  clearInterval(chuankou)
  chuankou=setInterval(()=>{
    if(globalThis.num==5){
      testNapi.SerialClose(globalThis.fd);
      globalThis.fd=null
      getChuankouFn()
    }
    getChuankouFnMsg()
  },1000)

}