mqtt_publisher.py 文件源码

def mqtt_pub_node_setting():
    gateway_addr = '0b001' # 1
    node_addr = '0b0000000010100' # 1
    trans_direct = '0b1'  # 1
    func_code = '0b0010010' # 18
    new_gateway_addr = '0b001'
    # new_node_addr = '0b0000000001111'
    new_node_addr = node_addr
    reserve = '0b0000'
    sleep_time = '0b0100101100' #5 minute
    # sleep_time = '0b0000110111' #55 second
    # sleep_time = '0b0001111000' #120 second

    send_power = '0b11'

    str_replaced = replace_0b(gateway_addr) + replace_0b(node_addr) + replace_0b(trans_direct) + replace_0b(func_code) + replace_0b(new_gateway_addr) + replace_0b(new_node_addr) + replace_0b(reserve) + replace_0b(sleep_time) + replace_0b(send_power)
    print('str_repalced:', str_replaced)
    str_bin = BitStream('0b' + str_replaced)
    print('str_bin:', str_bin)
    units, crc = return_crc(str_bin)
    str_bytes = struct.pack('8B', units[0], units[1], units[2], units[3], units[4], units[5], units[6], crc)
    print(str_bytes)
    print(len(str_bytes))
    print(repr(str_bytes))

    transmitMQTT(str_bytes)