| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136 |
- import time
- from event_storage import EventStorage
- from log import OutPutLog
- from datetime import datetime, timedelta
- class Alarm:
- def __init__(self):
- self._storage = EventStorage()
- self._save_frequency = 5
- self._last_save_time = 0
- self._log = OutPutLog()
- def get_real_time_data(self):
- """
- :return: data_dict {'c1': '064', 'c2': '0.1', 'c3': '20.3', 'c4': '43.2', 'c5': '1025.1', 'c6': '0.25', 'c81': '29.823', 'c82': '104.507', 'c83': '253.153'...}
- """
- point_info = self._storage.hardDiskStorage.get_point_info(point_tuple=None)
- # print(point_info)
- keys_list = []
- for index in point_info:
- keys_list.append('c' + str(index['serial_number']))
- data_dict = self._storage.memoryStorage.get_value(keys_list)
- # print(data_dict)
- return data_dict
- def get_point_table(self):
- """
- 获取所有点的点表，并增加alarm_status属性
- :return: point_info 字典组成的列表
- """
- point_info = self._storage.hardDiskStorage.get_point_info(point_tuple=None)
- for obj in point_info:
- obj['alarm_status'] = 0
- return point_info
- def update_point_table(self, point_info):
- """
- 更新点表，主要更新报警上限和报警下限
- :param point_info: 更新前的点表
- :return: 更新后的点表
- """
- new = self._storage.hardDiskStorage.get_point_info(point_tuple=None)
- for i in range(0, len(new)):
- point_info[i]['alarm_low_limit'] = new[i]['alarm_low_limit']
- point_info[i]['alarm_up_limit'] = new[i]['alarm_up_limit']
- # 越限报警
- def overrun_alarm(self):
- self._log.info('[overrun_alarm] - Over run alarm module is running!')
- try:
- point_info = self.get_point_table()
- while 1:
- self.update_point_table(point_info)
- # print(time.time(), point_info[0]['alarm_low_limit'], point_info[0]['alarm_up_limit'])
- data_dict = self.get_real_time_data()
- # print(data_dict['c1'])
- for index in point_info:
- key = 'c' + str(index['serial_number'])
- # print('addr = ', addr, 'addr type = ', type(addr))
- if data_dict[key]: # 数据不为空且报警状态为零
- data_dict[key] = float(data_dict[key])
- if index['alarm_low_limit'] is None or index['alarm_up_limit'] is None: # 未设置报警限值
- continue
- elif index['alarm_low_limit'] <= data_dict[key] <= index['alarm_up_limit']: # 在合理范围内
- index['alarm_status'] = 0
- else: # 数据越限
- if index['alarm_status'] == 0: # alarm_status == 0：表示第一次报警，存储报警信息
- alarm_unit = {'name': "'" + key + "'", 'data': data_dict[key]}
- table_name = "alarm_data_tbl" # 报警存储表名，可以通过配置文件配置
- alarm_time = time.strftime("%Y-%m-%d %H:%M:%S")
- self._log.debug('[overrun_alarm] - ' + repr(alarm_unit))
- self._storage.hardDiskStorage.insert_column_many(table_name, alarm_time, alarm_unit)
- index['alarm_status'] = 1
- elif index['alarm_status'] == 1: # alarm_status == 1：表示本次报警期间非第一次检测的越限
- continue
- time.sleep(1)
- except Exception as e:
- msg = str(time.strftime("%Y-%m-%d %H:%M:%M"))
- print(f'{msg}: error in overrun_alarm: {e}')
- def overrun_alarm_storage(self, table_name, save_time, item):
- pass
- # 变位报警
- def displacement_alarm(self):
- self._log.info('[displacement_alarm] - Displacement alarm module is running!')
- point_info = self._storage.hardDiskStorage.get_point_info(point_tuple=None)
- keys_list = []
- for index in point_info:
- keys_list.append('c' + str(index['serial_number']))
- last_data_dict = self._storage.memoryStorage.get_value(keys_list)
- while 1:
- now_data_dict = self._storage.memoryStorage.get_value(keys_list)
- # print(now_data_dict)
- for index in point_info:
- key = 'c' + str(index['serial_number'])
- if index['signal_type'] == 'Switch' and now_data_dict[key]:
- if now_data_dict[key] != last_data_dict[key]:
- self._log.info(repr(now_data_dict[key]) + repr(last_data_dict[key]))
- else:
- pass
- last_data_dict = now_data_dict
- self._log.info(last_data_dict)
- time.sleep(1)
- def displacement_alarm_storage(self):
- pass
- def moxa_e1210_alarm(self):
- """开关量综合报警的提示"""
- point_list = ["c365", "c367", "c368", "c371", "c372", "c373", "c374", "c375", "c376", "c377"]
- real_data_dict = self._storage.get_real_data(point_list)
- # real_data_dict = {'c365': '0', 'c367': '0', 'c368': '1', 'c371': '0', 'c372': '0', 'c373': '0', 'c374': '0', 'c375': '0', 'c376': '1', 'c377': '0'}
- alarm_time = datetime.now()
- alarm_time_limit = (alarm_time+timedelta(minutes=-30)).strftime("%Y-%m-%d %H:%M:%S")
- for serial_number,value in real_data_dict.items():
- if value and int(value) == 1:
- select_sql = f"SELECT serial_number FROM alarm_moxa_e1210 WHERE serial_number=\'{serial_number}\' AND update_time>\'{alarm_time_limit}\';"
- if not self._storage.execute_sql(select_sql):
- insert_sql = f"INSERT INTO alarm_moxa_e1210 (`create_time`, `update_time`, `serial_number`) VALUES (\'{alarm_time}\', \'{alarm_time}\', \'{serial_number}\');"
- self._storage.execute_update_sql(insert_sql)
- else:
- update_sql = f"UPDATE alarm_moxa_e1210 SET update_time=\'{alarm_time}\' WHERE serial_number=\'{serial_number}\' AND update_time>\'{alarm_time_limit}\';"
- self._storage.execute_update_sql(update_sql)
- if __name__ == '__main__':
- alarm = Alarm()
- alarm.overrun_alarm()
|
