billetManager/main.py

from models.billet_counter import Counter
from models.data_sender import Sender
from models.billet_trace_pusher import Trace_pusher
from utils.s7data import S7data, S7Client
from utils.mqttdata import Mqttdata, MqttClient
from utils.logger import Logger
from models.parking import Parking
from models.overhead_crane import Crane
from models.data_checker import Checker

##############################################################
# 日志配置

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

logger_trace = Logger('trace')
logger_trace.file_on('logs/trace_log.log')
logger_trace.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_test333', '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_test333')
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


##############################################################
# 分炉分坯服务

position_5 = [10650, 11600, 12830, 13924, 15237, 16440, 17757, 18935]
position_6 = [8230, 9655, 10658, 11708, 12988, 14066, 15380, 16750]

pusher_5 = Trace_pusher(data_5, logger_5, sender, position_5, True)
pusher_6 = Trace_pusher(data_6, logger_6, sender, position_6)

flfp_5 = Counter(data_mes, data_5, 5, logger_5, sender, pusher_5)
flfp_6 = Counter(data_mes, data_6, 6, logger_6, sender, pusher_6)


##############################################################
# 停车位检测服务

parking = Parking(data_5, sender)


##############################################################
# 天车跟踪服务

crane = Crane(data_5, pusher_5, pusher_6, parking, sender, logger_trace)

##############################################################
# 数据警报服务

checker = Checker(data_5, data_6, logger_sender)
checker.async_start_check()