from utils.s7data import S7data from utils.logger import Logger import requests, time, threading, warnings class Checker: def __init__(self, data_5: S7data, data_6: S7data, logger: Logger): self.data_5 = data_5 self.data_6 = data_6 self.logger = logger self.already = set() self.policy_5 = { # 信号： [无响应报警间隔, 信号描述, 信号名称, 处理方法] '定尺看门狗1': [60, '5#机1-4流定尺数据', '定尺信号', '立刻排查通信'], '定尺看门狗2': [60, '5#机5-8流定尺数据', '定尺信号', '立刻排查通信'], '推钢机激光': [1800, '5#机组坯、装运等除直轧外所有数据', '推钢机信号', '排查停机、plc内信号响应'], ('天车A1位置', '天车A2位置', '天车A3位置'): [600, '所有天车吊运钢坯数据', '天车位置信号', '立刻排查plc内信号，小概率是停机导致'], '车位1视觉看门狗': [60, '5#机车位1到站离站信号、车厢数据', '车位1信号', '立刻排查通信、识别软件是否启动'], '车位2视觉看门狗': [60, '5#机车位2到站离站信号、车厢数据', '车位2信号', '立刻排查通信、识别软件是否启动'], '车位3视觉看门狗': [60, '5#机车位3到站离站信号、车厢数据', '车位3信号', '立刻排查通信、识别软件是否启动'], '车位4视觉看门狗': [60, '5#机车位4到站离站信号、车厢数据', '车位4信号', '立刻排查通信、识别软件是否启动'], '车位1车牌看门狗': [60, '5#机车位1车牌识别', '车位1车牌识别', '立刻排查通信、识别软件是否启动'], '车位2车牌看门狗': [60, '6#机车位2车牌识别', '车位2车牌识别', '立刻排查通信、识别软件是否启动'], '车位3车牌看门狗': [60, '6#机车位3车牌识别', '车位3车牌识别', '立刻排查通信、识别软件是否启动'], '车位4车牌看门狗': [60, '6#机车位4车牌识别', '车位4车牌识别', '立刻排查通信、识别软件是否启动'], ('L1切割信号[1]', 'L2切割信号[1]', 'L3切割信号[1]', 'L4切割信号[1]'): [600, '5#机1-4流切割数据', '液压剪信号', '立刻排查停机/通信异常'], ('L5切割信号[1]', 'L6切割信号[1]', 'L7切割信号[1]', 'L8切割信号[1]'): [600, '5#机5-8流切割数据', '液压剪信号', '立刻排查停机/通信异常'] } self.policy_6 = { '定尺看门狗1': [60, '6#机1-4流定尺数据', '定尺信号', '立刻排查通信'], '定尺看门狗2': [60, '6#机5-8流定尺数据', '定尺信号', '立刻排查通信'], '推钢机激光': [300, '6#机钢坯基础信息、组坯等所有数据', '推钢机信号', '排查停机、plc内信号响应'], ('L1切割信号[1]', 'L2切割信号[1]', 'L3切割信号[1]', 'L4切割信号[1]'): [600, '6#机1-4流切割数据', '液压剪信号', '立刻排查停机/通信异常'], ('L5切割信号[1]', 'L6切割信号[1]', 'L7切割信号[1]', 'L8切割信号[1]'): [600, '6#机5-8流切割数据', '液压剪信号', '立刻排查停机/通信异常'] } self.time_5 = {} self.time_6 = {} self.value_5 = {} self.value_6 = {} now = time.time() for i in self.policy_5.keys(): self.time_5[i] = now self.value_5[i] = 0 for i in self.policy_6.keys(): self.time_6[i] = now self.value_6[i] = 0 self.threading_sig = True def push(self, name, ccmNo): url = 'https://oapi.dingtalk.com/robot/send?access_token=60fbad9923c55730485ead3270621fd0a03fdc28d6a8e78a85a4ce4d0ee727dd' tmp = {} tmp['msgtype'] = 'markdown' tmp['markdown'] = {} tmp['markdown']['title'] = '数据异常警告' tmp['markdown']['text'] = f'''#### 警告：钢坯数字化项目数据异常！ **异常详情：** - **异常信号**：{self.policy_5[name][2] if ccmNo == '5' else self.policy_6[name][2]} - **异常描述**：{self.policy_5[name][0] if ccmNo == '5' else self.policy_6[name][0]}秒无响应 - **发生时间**：{time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())} - **影响范围**：{self.policy_5[name][1] if ccmNo == '5' else self.policy_6[name][1]} - **处理方法**：{self.policy_5[name][3] if ccmNo == '5' else self.policy_6[name][3]} --- > 看门狗信号异常请立即检查，其他异常请先检查是否设备停机或短暂停止''' response = requests.post(url, json=tmp) if response.ok and response.json()['errcode'] == 0: self.logger.warning(f"[WARNING]{str(name)}信号异常，已经提交了报告") else: self.logger.warning(f"[WARNING]{str(name)}信号异常，但提交报告失败") def start_check(self): while self.threading_sig: for i, j in self.policy_5.items(): if isinstance(i, tuple): newdata = [] for k in i: newdata.append(self.data_5.get_value(k)) newdata = tuple(newdata) elif isinstance(i, str): newdata = self.data_5.get_value(i) else: warnings.warn('checker模块Error:使用不支持的信号变量类型') self.logger.error('checker模块Error:使用不支持的信号变量类型') return None if newdata != self.value_5[i]: self.value_5[i] = newdata self.time_5[i] = time.time() self.already.discard('5#'+str(i)) if '5#'+str(i) not in self.already and time.time() - self.time_5[i] > j[0]: self.push(i, '5') self.already.add('5#'+str(i)) for i, j in self.policy_6.items(): if isinstance(i, tuple): newdata = [] for k in i: newdata.append(self.data_6.get_value(k)) newdata = tuple(newdata) elif isinstance(i, str): newdata = self.data_6.get_value(i) else: warnings.warn('checker模块Error:使用不支持的信号变量类型') self.logger.error('checker模块Error:使用不支持的信号变量类型') return None if newdata != self.value_6[i]: self.value_6[i] = newdata self.time_6[i] = time.time() self.already.discard('6#'+str(i)) if '6#'+str(i) not in self.already and time.time() - self.time_6[i] > j[0]: self.push(i, '6') self.already.add('6#'+str(i)) time.sleep(5) def async_start_check(self): self.thread = threading.Thread(target=self.start_check) self.thread.start() def clear(self): self.already = set()