billetManager/models/jiaoban.py

from utils.s7data import S7data
from models.data_sender import Sender
from utils.logger import Logger
import time, threading

class Banci:
    def __init__(self, s7_data: S7data, sender: Sender, logger: Logger, ccmNo):
        self.s7_data = s7_data
        self.sender = sender
        self.logger = logger
        self.ccmNo = ccmNo

        self.ban_5 = s7_data.make_point('当前班别')
        self.ban_now_5 = self.ban_5.data

        self.thread = threading.Thread(target=self.jiaoban_action)
        self.thread.start()

    def jiaoban_action(self):
        time.sleep(2)
        self.ban_now_5 = self.ban_5.data
        while True:
            if self.ban_5.data != self.ban_now_5:
                self.ban_now_5 = self.ban_5.data
                self.logger.info(f'{self.ccmNo}#机触发交班信号')
                if self.ccmNo == '6':
                    self.sender.jiaoban_6(self.ccmNo, self.ban_now_5)
                elif self.ccmNo == '5':
                    self.sender.jiaoban(self.ccmNo, self.ban_now_5)
            time.sleep(1)