main.py 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. from models.billet_counter import Counter
  2. from models.data_sender import Sender
  3. from utils.s7data import S7data, S7Client
  4. from utils.mqttdata import Mqttdata, MqttClient
  5. from utils.logger import Logger
  6. from models.data_forward import *
  7. ##############################################################
  8. # 日志配置
  9. logger_5 = Logger('5#')
  10. logger_5.file_on('logs/5#log.log')
  11. logger_5.screen_on()
  12. logger_6 = Logger('6#')
  13. logger_6.file_on('logs/6#log.log')
  14. logger_6.screen_on()
  15. logger_sender = Logger('sender')
  16. logger_sender.file_on('logs/sender_log.log')
  17. logger_sender.screen_on()
  18. ##############################################################
  19. # S7数据源配置
  20. s7_5 = S7Client()
  21. s7_5.connect('192.168.1.215', 0, 0)
  22. data_5 = S7data(r"conf/5#nodes.csv")
  23. data_5.set_S7Client(s7_5)
  24. data_5.set_logger(logger_5)
  25. data_5.auto_update_group()
  26. logger_5.info('[PREPARE]5#机PLC连接成功')
  27. s7_6 = S7Client()
  28. s7_6.connect('192.168.1.216', 0, 0)
  29. data_6 = S7data(r"conf/6#nodes.csv")
  30. data_6.set_S7Client(s7_6)
  31. data_6.set_logger(logger_6)
  32. data_6.auto_update_group()
  33. logger_6.info('[PREPARE]6#机PLC连接成功')
  34. ##############################################################
  35. # MQTT数据源配置
  36. # mqtt_mes = MqttClient('python-mqtt-biller_digitalization', 'readonly', '1qazxsw@')
  37. # mqtt_mes.connect('192.168.12.201', 1883)
  38. # mqtt_mes.loop_start()
  39. # data_mes = Mqttdata()
  40. # data_mes.set_mqtt_client(mqtt_mes)
  41. # logger_5.info('[PREPARE]与MES使用MQTT连接成功')
  42. # logger_6.info('[PREPARE]与MES使用MQTT连接成功')
  43. mqtt_web = MqttClient('python-mqtt-992_forward_test')
  44. mqtt_web.connect('192.168.0.119', 1883)
  45. mqtt_web.loop_start()
  46. data_web = Mqttdata()
  47. data_web.set_mqtt_client(mqtt_web)
  48. logger_sender.info('[PREPARE]与WEB业务平台使用MQTT连接成功')
  49. ##############################################################
  50. # 数据发送服务
  51. sender = Sender(logger_sender)
  52. sender.set_mqtt_client(mqtt_web)
  53. # debug设置
  54. # sender.http_flag = False
  55. ##############################################################
  56. # 分炉分坯服务
  57. # flfp_5 = Counter(data_mes, data_5, 5, logger_5, sender)
  58. # flfp_6 = Counter(data_mes, data_6, 6, logger_6, sender)
  59. ##############################################################
  60. # 数据转发服务
  61. forward_5 = Forward(data_5, sender, True, '5')
  62. forward_5.start_auto_forward()
  63. forward_6 = Forward(data_6, sender, False, '6')
  64. forward_6.start_auto_forward()