import kv
from driver import UART
import tool
import app_aliyunIot
import utime   # 延时函数在utime库中
uart = UART()

takeOver=False
def getTakeOver():
    global takeOver
    return  takeOver 


#打开串口通讯
def uart_init():
    uart.open("serial2")
    print('open -----------serial2')
    utime.sleep_ms(1000) 
#发送K到串口 读取返回数据
def uart_read(timeJg):
    global takeOver
    print('时间间隔---------')
    print(timeJg)
    while True:
        print('sund-----K-----------'+kv.get('key'))
        uart.write(bytearray(kv.get('key')))
        #发送3秒后就读数据
        utime.sleep_ms(3000)
        readBuf = bytearray(570)
        recvSize = uart.read(readBuf)
        # print(recvSize) 
        # print(readBuf)
        # 是否收到血透机回传数据 如果没有就修改发送K
        if recvSize==0 or recvSize==4:
            if kv.get('key')=='K\r\n':
                kv.set('key','K0000\r\n')
            else:
                kv.set('key','K\r\n')
            print('-----get key---11---',kv.get('key'))
            utime.sleep_ms(10000)
        if recvSize>=268:
            takeOver=True
            #收到数据后 
            print('收到数据长度270---')
            print(readBuf.decode('utf-16-le'))
            strText= readBuf.decode('utf-16-le')
            zuobiaoBen= strText.find('K')
            zuobaioEnd=strText.find('$')
            #字符串长度
            changdu=zuobaioEnd-zuobiaoBen
            if changdu==264:
                #如果有报警信息马上发送数据模型到阿里云 60秒后循环
                #验证后端data
                print('---------------------')
                yzStr=strText[zuobiaoBen:zuobiaoBen+270]
                print(yzStr)
                #只要K开头的270个字符长度
                yzData=readBuf[zuobiaoBen:zuobiaoBen+270]
                print(yzData)
                 #解析串口回传的数据
                jsonData= tool.toParams(yzData.decode('utf-16-le'))
                #判断是否报警
                if tool.isObjectValueEqual(jsonData)==False:
                    # app_aliyunIot.sudDataIot(yzData)
                    app_aliyunIot.sudDataPostProps(jsonData)
                    print('发送数据')
                    utime.sleep_ms(60000)
                else:
                    # 如果没有报警发送后就等待60秒在执行循环
                    print('deng dai---'+str(timeJg))
                    # app_aliyunIot.sudDataIot(yzData)
                    app_aliyunIot.sudDataPostProps(jsonData)
                    print('发送数据')
                    utime.sleep_ms(timeJg*1000) 
            else:
                print('数据格式不正确不传iot')
        else:
            print(readBuf.decode('utf-16-le'))
            print('数据不够长')
#临时发K 更具服务事件发K
def sund_key():
    print('sund--service---K-----------'+kv.get('key'))
    uart.write(bytearray(kv.get('key')))
    #发送3秒后就读数据
    utime.sleep_ms(3000)
    readBuf = bytearray(570)
    recvSize = uart.read(readBuf)
    if recvSize>=270:
        #收到数据后 
        print('收到数据长度270---')
        print(readBuf.decode('utf-16-le'))
        strText= readBuf.decode('utf-16-le')
        zuobiaoBen= strText.find('K')
        zuobaioEnd=strText.find('$')
        #字符串长度
        changdu=zuobaioEnd-zuobiaoBen
        if changdu==264:        
            #只要K开头的270个字符长度
            yzData=readBuf[zuobiaoBen:zuobiaoBen+270]
            print(yzData)
                #解析串口回传的数据
            jsonData= tool.toParams(yzData.decode('utf-16-le'))
            app_aliyunIot.sudDataPostProps(jsonData)     
        else:
            print('数据格式不正确不传iot')
    else:
        print(readBuf.decode('utf-16-le'))
        print('数据不够长')