#成长营第五期#基于微信小程序物联掌控板监控月龄婴儿夜间哭闹 简单

from mpython import *

import network

my_wifi = wifi()

my_wifi.connectWiFi("ChinaNet-Q4Yt", "gyqwnfpt")

from umqtt.simple import MQTTClient

from machine import Timer

import machine

import ubinascii

def OneNET_recv(_msg):pass
_OneNET_msg_list = []
def OneNET_callback(_topic, _msg):
    global _OneNET_msg_list
    try: _msg = _msg.decode('utf-8', 'ignore')
    except: print(_msg);return
    OneNET_recv(_msg)
    if _msg in _OneNET_msg_list:
        eval('OneNET_recv_' + bytes.decode(ubinascii.hexlify(_msg)) + '()')

tim14 = Timer(14)

_iot_count = 0
def timer14_tick(_):
    global _iot, _iot_count
    _iot_count = _iot_count + 1
    if _iot_count == 1000: _iot.ping(); _iot_count = 0
    try: _iot.check_msg()
    except: machine.reset()

_iot = None
def OneNET_setup():
    global _iot
    _iot = MQTTClient('1198060789', '183.230.40.39', 6002, '221628', 'z4wAV=monF==SrNAdbkUp=7kt=U=', keepalive=300)
    _iot.set_callback(OneNET_callback)
    if 1 == _iot.connect(): print('Successfully connected to MQTT server.')
    tim14.init(period=200, mode=Timer.PERIODIC, callback=timer14_tick)

noise = None

lights = None

import json

def pubdata(_dic):
    print(_dic)
    _list = []
    for _key in list(_dic.keys()):
        _d = {'id':_key,'datapoints':[{'value':_dic[_key]}]}
        _list.append(_d)
    _data = {'datastreams': _list}
    j_d = json.dumps(_data)
    j_l = len(j_d)
    arr = bytearray(j_l + 3)
    arr[0] = 1
    arr[1] = int(j_l / 256)
    arr[2] = j_l % 256
    arr[3:] = j_d.encode('ascii')
    return arr

import time
OneNET_setup()
while True:
    noise = sound.read()
    lights = light.read()
    oled.fill(0)
    oled.DispChar(str(str('光照强度：') + str(lights)), 0, 0, 1)
    oled.DispChar(str(str('噪声：') + str(noise)), 0, 16, 1)
    oled.show()
    _iot.publish('$dp', pubdata({'light':light}))
    _iot.publish('$dp', pubdata({'noise':noise}))
    time.sleep(1)