jikong_backend_code/005_H570/jikong_script/event_storage.py

import json
import re
from memory_storage import MemoryStorage
from hard_disk_storage import HardDiskStorage
from configuration import Configuration

class EventStorage:
    def __init__(self):
        self.config = Configuration().get_system_config()
        self.memoryStorage = MemoryStorage(self.config['memoryDatabase'])
        self.hardDiskStorage = HardDiskStorage(self.config['hardDiskdataBase'])

    def get_real_data(self, keys):
        data = self.memoryStorage.get_value(keys)
        return data

    def get_historical_data(self, select_info):
        data = self.hardDiskStorage.get_table_data(select_info)
        return data

    def real_time_data_storage(self, data):
        self.memoryStorage.set_value(data)

    def historical_data_storage(self, table_name, seve_time, data):
        self.hardDiskStorage.insert_column_many(table_name, seve_time, data)

    def get_connector_config(self, read_write):
        config = self.hardDiskStorage.get_connectors(read_write)
        for station_info in config:
            station_info['connector_config'] = json.loads(station_info['connector_config'])
        return config

    def get_station_info(self, station_name):
        return self.hardDiskStorage.get_station_info(station_name)

    def get_table_name(self):
        table_name = self.hardDiskStorage.get_table_name()
        return table_name

    # def table_xxx_insert_data(self, format_data_dict, table_name, save_time):
    #     self.hardDiskStorage.table_xxx_insert_data(format_data_dict, table_name, save_time)

    def get_point_info(self, keys):
        point_list = []
        if keys:
            for key in keys:
                point_list.append(re.sub("\D", "", key))
            point_tuple = tuple(point_list)
        else:
            point_tuple = None
        return self.hardDiskStorage.get_point_info(point_tuple)

    # 获取modbus命令
    def get_command_info(self, station_name):
        return self.hardDiskStorage.get_command_info(station_name)

    # 执行sql语句
    def execute_sql(self, sql):
        result = self.hardDiskStorage.execute_sql(sql)
        return result

    def execute_update_sql(self, sql):
        """执行UPDATE、INSERT、DELETE语句"""
        return self.hardDiskStorage.execute_update_sql(sql)

    def gather_fish_light_info(self, location):
        """水下聚鱼灯远程控制功能：查找指定位置的聚鱼灯的相关控制信息"""
        return self.hardDiskStorage.gather_fish_light_info(location)

    def get_gather_fish_light_command(self):
        """水下聚鱼灯远程控制功能：查看控制聚鱼灯的指令"""
        return self.hardDiskStorage.get_gather_fish_light_command()
          

class Networkerror(RuntimeError):
    def __init__(self, arg):
        self.args = arg