| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105 |
- from utils.s7data import *
- from models.data_sender import *
- import copy
- class Forward:
- def __init__(self, data_s7: S7data, sender: Sender, crane_flag: bool, ccmNo: str):
- self.data_s7 = data_s7
- self.sender = sender
- self.crane_flag = crane_flag
- self.ccmNo = ccmNo
- self.billet_position_list = []
- self.barrier_state_list = []
- for i in range(8):
- self.billet_position_list.append(data_s7.make_point(f"L{i+1}坯头位置"))
- self.barrier_state_list.append(data_s7.make_point(f"L{i+1}挡板"))
- self.pusher = data_s7.make_point("推钢机激光")
- if self.crane_flag:
- self.crane_A1 = data_s7.make_point("天车A1位置")
- self.crane_A2 = data_s7.make_point("天车A2位置")
- self.crane_A3 = data_s7.make_point("天车A3位置")
- self.topic = 'trace/performance/billet/monitor'
- self.qos = 0
- self.template = {
- "type": "", # string 钢坯流道，行车，推钢机，辊道，车辆，堆垛
- "data": {
- "machine": 0, # number 如果是流道的话，哪个铸机
- "channel": 0, # number 如果是流道的话，第几流
- "direction": "", # string 运行方向 up, down, left, right
- "distance": 0, # number 运行距离 ，（应该是毫米）
- "has_billet": False, # boolean 是否夹起钢坯
- "position": 0, # number 车辆位置 ， 从上到下，从左到右， 1 | 2 | 3 | 4， 行车位置 ， 按图中位置，从左到右， A1 | A2 | A3 | B1 | B2
- "car_num": "", # string 车牌号
- "car_running": "", # string 车辆运行， in 表示车辆到站， out 车辆离开
- "billet_stacking": "", # string 堆垛 501 601 602 604 coolbed（步进冷床）
- "layers": 0, # number 堆垛层数
- "amount": 0 # number 堆垛夹数
- }
- }
- self.task_thread = None
- self.run_flag = False
- def billet_position(self, strandNo, position):
- tmp = copy.deepcopy(self.template)
- tmp['type'] = 'channel'
- tmp['data']['machine'] = self.ccmNo
- tmp['data']['channel'] = strandNo
- tmp['data']['direction'] = 'down'
- tmp['data']['distance'] = position
-
- self.sender.mqtt_publish(self.topic, tmp, self.qos)
- def barrier_state(self, strandNo, state):
- tmp = copy.deepcopy(self.template)
- tmp['type'] = 'channel_barrier'
- tmp['data']['machine'] = self.ccmNo
- tmp['data']['channel'] = strandNo
- if state:
- tmp['data']['direction'] = 'down'
- else:
- tmp['data']['direction'] = 'up'
-
- self.sender.mqtt_publish(self.topic, tmp, self.qos)
- def pusher_position(self, position):
- tmp = copy.deepcopy(self.template)
- tmp['type'] = 'steel_pusher'
- tmp['data']['machine'] = self.ccmNo
- tmp['data']['distance'] = position
-
- self.sender.mqtt_publish(self.topic, tmp, self.qos)
- def overhead_crane_position(self, craneNo, position):
- tmp = copy.deepcopy(self.template)
- tmp['type'] = 'train_working'
- tmp['data']['position'] = craneNo
- tmp['data']['direction'] = 'left'
- tmp['data']['distance'] = position
- tmp['data']['has_billet'] = False
-
- self.sender.mqtt_publish(self.topic, tmp, self.qos)
- def auto_forward(self):
- while self.run_flag:
- for i in range(8):
- self.billet_position(i+1, self.billet_position_list[i].data)
- self.barrier_state(i+1, self.barrier_state_list[i].data)
- self.pusher_position(self.pusher.data)
- if self.crane_flag:
- self.overhead_crane_position('A1', self.crane_A1.data)
- self.overhead_crane_position('A2', self.crane_A2.data)
- self.overhead_crane_position('A3', self.crane_A3.data)
-
- time.sleep(0.5)
- def start_auto_forward(self):
- if self.task_thread:
- self.run_flag = False
- self.task_thread.join()
- self.run_flag = True
- self.task_thread = threading.Thread(target=self.auto_forward)
- self.task_thread.start()
|
