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.data_forward import *
from models.parking import Parking
from models.overhead_crane import Crane
from models.data_checker import Checker
from models.billet_stacks import Stack_manager, Billet_stack
from models.jiaoban import Banci
import pymysql

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

logger_5 = Logger('5#')
logger_5.file_on_with_rotation('logs/5#log.log')
# logger_5.screen_on()

logger_6 = Logger('6#')
logger_6.file_on_with_rotation('logs/6#log.log')
# logger_6.screen_on()

logger_sender = Logger('sender')
logger_sender.file_on_with_rotation('logs/sender_log.log')
# logger_sender.screen_on()

logger_trace = Logger('trace')
logger_trace.file_on_with_rotation('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连接成功')


##############################################################
# MYSQL数据库连接

db = pymysql.connect(host='localhost', port=3306, user='root', password='1qaz2wsx@..', database='steel_production_db')


##############################################################
# 数据发送服务

sender = Sender(logger_sender)
#sender.set_mqtt_client(mqtt_web)
#sender.set_mysql_client(db)

# debug设置
sender.http_flag = False
sender.mysql_flag = True


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

position_5 = [10650, 11600, 12830, 13924, 15237, 16440, 17757, 18935]
position_6 = [8084, 9303, 10618, 11998, 13040, 14409, 15584, 16853]

pusher_5 = Trace_pusher(data_5, logger_5, sender, position_5, data_web.make_point('5#手动换炉'), True)
pusher_6 = Trace_pusher(data_6, logger_6, sender, position_6, data_web.make_point('6#手动换炉'), hostmove_flag=True)

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)


##############################################################
# 堆垛管理服务

stack_manager = Stack_manager()
stack_manager.add_stack('501', '5', data_5)
stack_manager.add_stack('601', '6', data_5, -170)


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

parking = Parking(data_5, sender)


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

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


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

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


##############################################################
# 自动交班服务

banci_5 = Banci(data_5, sender, logger_5, '5')
banci_6 = Banci(data_6, sender, logger_6, '6')


##############################################################
# 数据转发服务

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