billetManager/main.py

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()