import UdpClient from './UdpClient';
import UdpClientByCenter from './UdpClientByCenter';
import { getSyncData} from '../service/initable'
import { dateFormat } from '../../common/utils/tools'
import prompt from '@ohos.prompt'
import TcpClient from './TcpClient';

export async function sendMsg(val){
  globalThis.udpClient1&&globalThis.udpClient1.sendMsg(val)
}
export async function getUDP() {
  getSyncData('IpConfigTable').then((result:Array<any>)=>{
    console.log('result222',JSON.stringify(result))
    if(result.length){
      if(globalThis.udpClient&&globalThis.udpClient.closeUdp){
        globalThis.udpClient.closeUdp(()=>{

          globalThis.udpClient.rebindUdp(result[0].udplocalIp, result[0].udplocalIpPort,result[0].udpOppositeIp,result[0].udpOppositeIpPort)

          globalThis.udpClient.sendMsg('111')

          // globalThis.udpClient = udpClient
        })
      }else{

        const udpClient: UdpClient =new UdpClient(result[0].udplocalIp, result[0].udplocalIpPort,result[0].udpOppositeIp,result[0].udpOppositeIpPort)
        udpClient.bindUdp()
        udpClient.sendMsg('111')
        globalThis.udpClient = udpClient
      }
      // globalThis.udpClient = new UdpClient(result[0].localIp, result[0].localIpPort,result[0].oppositeIp,result[0].oppositeIpPort)

    }else{
      globalThis.udpClient={}
      globalThis.udpClient.onMessage=()=>{}
    }
  })
}

export async function getUDP2() {
  getSyncData('IpConfigTable').then(async (result:Array<any>)=>{
    if(result.length){
      if(globalThis.udpClient2&&globalThis.udpClient2.closeUdp){
        globalThis.udpClient2.closeUdp(async ()=>{
          // globalThis.udpClient2.rebindUdp(result[0].udplocalIp, '8800','112.80.35.83','11056')
          globalThis.udpClient2.rebindUdp(result[0].udplocalIp, '8800',globalThis.carInfo?.udpAddress,globalThis.carInfo?.messagePort)
          // globalThis.udpClient2.rebindUdp(result[0].tcplocalIp, result[0].tcplocalIpPort,result[0].tcpOppositeIp,result[0].tcpOppositePort)
          // globalThis.udpClient2.rebindUdp(result[0].udplocalIp, result[0].udpLocalIpByGPS,result[0].udpOppositeIp,result[0].udpOppositeIpPortByGPS)
          globalThis.udpClient2.onMessage((val)=>{
            // globalThis.udpClnt2.sendMsg(heartMsg(context))
          })

        })
      }else{
        // const udpClient: UdpClient =new UdpClient(result[0].udplocalIp, result[0].udpLocalIpByGPS,result[0].udpOppositeIp,result[0].udpOppositeIpPortByGPS)
        const udpClient: UdpClientByCenter =new UdpClientByCenter(result[0].udplocalIp, '8800',globalThis.carInfo?.udpAddress,globalThis.carInfo?.messagePort)
        // const udpClient: UdpClientByCenter =new UdpClientByCenter(result[0].udplocalIp, '8800','112.80.35.83','11056')
        // const udpClient: UdpClient =new UdpClient(result[0].tcplocalIp, result[0].tcplocalIpPort,result[0].tcpOppositeIp,result[0].tcpOppositePort)

        globalThis.udpClient2 = udpClient
        globalThis.udpClient2.bindUdp()

        // globalThis.udpClient2.sendMsg(heartMsg(context))

        globalThis.udpClient2.onMessage((val)=>{

          if(val.id=='32'){
            globalThis.signNum=val.body[1]
          }else if(val.id=='46'){

            let tmpList = []
            console.log('lsh',globalThis.lsh)
            const str = globalThis.lsh
            for (let i = 0;i < str.length; i++) {
              tmpList.push(this.string2Bytes(str.charCodeAt(i), 1 * 8)[0])
            }

            const param = { id: 47, list: tmpList, carNo: globalThis.carInfo.carNo, placeId: globalThis.carInfo.examinationRoomId }
            globalThis.udpClient2.send(param)
          }

          // setTimeout(async ()=>{
          //
          //   globalThis.udpClient2.sendMsg(heartMsg(context))
          //
          // },1000)
        })
      }
    }else{
      globalThis.udpClient2={}
      globalThis.udpClient2.onMessage=()=>{}
    }
  })
}

export async function setTopLineUdp(){
  const config = await getSyncData('IpConfigTable');
  if(config && config[0] && config[0].udplocalIp){
    const {udplocalIp,udpOppositeIp,udpOppositeIpPort} = config[0];
    const udpClient: UdpClientByCenter = new UdpClientByCenter(udplocalIp, '55509',udpOppositeIp,udpOppositeIpPort)
    // const udpClient: UdpClientByCenter = new UdpClientByCenter(udplocalIp, '8800','192.168.36.4','33333')
    udpClient.bindUdp()

    return {
      send(bytes){
        udpClient.sendHeadMsg(bytes)
      }
    }
  }
}


export async function setJudgeUdp(){
  const config = await getSyncData('IpConfigTable');
  if(config && config[0] && config[0].udplocalIp){
    const {udplocalIp} = config[0];
    // const udpClient: UdpClientByCenter = new UdpClientByCenter(udplocalIp, '8080','192.168.32.167','33333')
    const udpClient: UdpClientByCenter = new UdpClientByCenter(udplocalIp, '8080',globalThis.carInfo?.gpsAddress,globalThis.carInfo?.hintPort)
    // const udpClient: UdpClientByCenter = new UdpClientByCenter(udplocalIp, '8800','192.168.36.4','33333')
    udpClient.bindUdp()
    udpClient.onMessage((val)=>{
    })
    globalThis.judgeUdpClient = udpClient;
    return {
      send(bytes){
        console.log('carInfo111',JSON.stringify(globalThis.carInfo))
        udpClient.sendMsg({id:45,list:bytes,carNo:globalThis.carInfo.carNo,placeId:globalThis.carInfo.examinationRoomId})
      }
    }
  }

}

// globalThis.udpClient.bindUdp()