Unit PoESP32

from m5stack import *
from m5stack_ui import *
from uiflow import *
import unit

screen = M5Screen()
screen.clean_screen()
screen.set_screen_bg_color(0xFFFFFF)
RS485_0 = unit.get(unit.RS485, unit.PORTC)

RS485_0.init(1, baudrate=9600, data_bits=8, stop_bits=1, parity=None, ctrl_pin=None)
while True:
  RS485_0.write('hello'+"\r\n")
  print((str('data:') + str((RS485_0.read()))))
  wait_ms(2)

poesp32_0.create_mqtt_client('', 1883, '', '', '')

poesp32_0.uart_port_id(1)

print(poesp32_0.isConnect_ETH())

print(poesp32_0.check_uart())

print((str('status:') + str((poesp32_0.create_tcp_client('', 0)))))

print((str('mqtt:') + str((poesp32_0.publish_mqtt_msg('', '', 0))))) 

def poesp32_WrCiScb(value):
  global poesp32_mqtt_value1
  poesp32_mqtt_value1 = value
  pass

poesp32_0.receive_mqtt_msg(poesp32_WrCiScb)

print((str('mqtt:') + str((poesp32_0.subscribe_mqtt('', 0)))))

print((str('mqtt:') + str((poesp32_0.unsubscribe_mqtt('')))))

def poesp32_dFAnAcb(value):
  global poesp32_tcp_value1
  poesp32_tcp_value1 = value
  pass

poesp32_0.receive_tcp_packet(poesp32_dFAnAcb)

print(poesp32_0.send_tcp_packet('12345'))