1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889 |
- from models.billet_counter import Counter
- from models.data_sender import Sender
- from utils.s7data import S7data, S7Client
- from utils.mqttdata import Mqttdata, MqttClient
- from utils.logger import Logger
- from models.data_forward import *
- ##############################################################
- # 日志配置
- logger_5 = Logger('5#')
- logger_5.file_on('logs/5#log.log')
- logger_5.screen_on()
- logger_6 = Logger('6#')
- logger_6.file_on('logs/6#log.log')
- logger_6.screen_on()
- logger_sender = Logger('sender')
- logger_sender.file_on('logs/sender_log.log')
- logger_sender.screen_on()
- ##############################################################
- # S7数据源配置
- s7_5 = S7Client()
- s7_5.connect('192.168.1.215', 0, 0)
- data_5 = S7data(r"conf/5#nodes.csv")
- data_5.set_S7Client(s7_5)
- data_5.set_logger(logger_5)
- data_5.auto_update_group()
- logger_5.info('[PREPARE]5#机PLC连接成功')
- s7_6 = S7Client()
- s7_6.connect('192.168.1.216', 0, 0)
- data_6 = S7data(r"conf/6#nodes.csv")
- data_6.set_S7Client(s7_6)
- data_6.set_logger(logger_6)
- data_6.auto_update_group()
- logger_6.info('[PREPARE]6#机PLC连接成功')
- ##############################################################
- # MQTT数据源配置
- # mqtt_mes = MqttClient('python-mqtt-biller_digitalization', 'readonly', '1qazxsw@')
- # mqtt_mes.connect('192.168.12.201', 1883)
- # mqtt_mes.loop_start()
- # data_mes = Mqttdata()
- # data_mes.set_mqtt_client(mqtt_mes)
- # logger_5.info('[PREPARE]与MES使用MQTT连接成功')
- # logger_6.info('[PREPARE]与MES使用MQTT连接成功')
- mqtt_web = MqttClient('python-mqtt-992_forward_test')
- mqtt_web.connect('192.168.0.119', 1883)
- mqtt_web.loop_start()
- data_web = Mqttdata()
- data_web.set_mqtt_client(mqtt_web)
- logger_sender.info('[PREPARE]与WEB业务平台使用MQTT连接成功')
- ##############################################################
- # 数据发送服务
- sender = Sender(logger_sender)
- sender.set_mqtt_client(mqtt_web)
- # debug设置
- # sender.http_flag = False
- ##############################################################
- # 分炉分坯服务
- # flfp_5 = Counter(data_mes, data_5, 5, logger_5, sender)
- # flfp_6 = Counter(data_mes, data_6, 6, logger_6, sender)
- ##############################################################
- # 数据转发服务
- forward_5 = Forward(data_5, sender, True, '5')
- forward_5.start_auto_forward()
- forward_6 = Forward(data_6, sender, False, '6')
- forward_6.start_auto_forward()
|