jikong_backend_code/001_H511/jikong_script/auto_switch_juyudeng.py

#!/usr/bin/env python
# encoding: utf-8
"""
@CreateTime: 2022/06/28 18:53
@Author: lxc
@LastEditTime:
@Desctiption: 聚鱼灯
"""

from event_storage import EventStorage
from log import OutPutLog
import time
from datetime import datetime
from utility import Utility
import json


class AutoSwitchJuyudeng:
    def __init__(self):
        self._storage = EventStorage()
        self._log = OutPutLog()

    def run(self):
        self._log.info("[AutoSwitchDevice] - AutoSwitchDevice module is running!")
        run_time = 0
        while True:
            this_time = time.time()
            self.now = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
            if this_time - run_time > 60:
                run_time = this_time

                self.check_status()
                self.update_juyudeng_status()


    def get_light_real_status(self):
        """
        获取聚鱼灯的实时状态：光敏模式的状态、灯的开关状态
        :return: {'juyudeng_1#_guangmin': 0, 'juyudeng_2#_guangmin': 1, 'juyudeng_3#_guangmin': 0,
        'juyudeng_4#_guangmin': 0, 'juyudeng_5#_guangmin': 0, 'juyudeng_6#_guangmin': 1, 'juyudeng_7#_guangmin': 1,
        'juyudeng_8#_guangmin': 1, 'juyudeng_1#_status': 1, 'juyudeng_2#_status': 1, 'juyudeng_3#_status': 0,
        'juyudeng_4#_status': 0, 'juyudeng_5#_status': 1, 'juyudeng_6#_status': 1, 'juyudeng_7#_status': 0,
        'juyudeng_8#_status': 0}
        """

        sql_point_info = "SELECT serial_number,io_point_name " \
                         "FROM `data_point_tbl` " \
                         "WHERE `io_point_name` LIKE 'juyudeng_%_%';"
        point_info = self._storage.execute_sql(sql_point_info)

        read_real_list = []
        point_name_dict = {}
        for each in point_info:
            serial_number = "c"+str(each["serial_number"])
            read_real_list.append(serial_number)
            point_name_dict[serial_number] = each["io_point_name"]
        real_data_dict = self._storage.get_real_data(read_real_list)

        light_real_status = {}
        for k, v in real_data_dict.items():
            light_real_status[point_name_dict[k]] = v

        return light_real_status


    def get_light_his_status(self):
        """
        获取聚鱼灯的历史状态信息
        :return: [{'station_name': 'juyudeng_12#', 'location': '1#', 'control_mode': 0, 'status': 0,
        'definite_time': '[]', 'commands': '{"open_light": [{"res": 65280, "device_id": 1, "start_addr": 0,
        "output_value": 65280, "function_code": 5}], "close_light": [{"res": 0, "device_id": 1, "start_addr": 0,
        "output_value": 0, "function_code": 5}], "open_photosense": [{"res": 0, "device_id": 1, "start_addr": 2,
        "output_value": 0, "function_code": 5}], "close_photosense": [{"res": 65280, "device_id": 1, "start_addr": 2,
        "output_value": 65280, "function_code": 5}]}', 'conn_status': 1}, ...]
        """

        sql_his_info = "SELECT station_name,location,control_mode,status,definite_time,commands,conn_status " \
                       "FROM `gather_fish_light_control`;"
        his_info = self._storage.execute_sql(sql_his_info)

        return his_info



    def check_status(self):

        # 获取聚鱼灯的实时状态：光敏模式的状态、灯的开关状态
        light_real_status = self.get_light_real_status()
        # print("light_real_status=", light_real_status)

        # 获取聚鱼灯的历史状态信息
        light_his_status = self.get_light_his_status()

        for each in light_his_status:
            # {'station_name': 'juyudeng_12#', 'location': '2#', 'control_mode': 1, 'status': 1, 'definite_time': '[["00:00:00,23:59:59"]]', 'commands': '{}', 'conn_status': 0}

            station_name = each['station_name']         #　聚鱼灯的站名
            location = each['location']                 #　聚鱼灯的位置
            his_control_mode = each['control_mode']     # 历史控制模式（0=光敏控制 1=手动控制 2=定时控制）
            his_status = each['status']                 # 历史状态（0=关 1=开，模式1需要获取该参数的值）
            his_conn_status = each['conn_status']       # 历史通讯状态（0=在线，1=不在线）
            command = json.loads(each['commands'])                  # 控制开关的指令
            guangmin_status = light_real_status[f"{station_name}_guangmin"]         # 此刻光敏模式的状态（0=开 1=关）
            light_status = light_real_status[f"juyudeng_{location}_status"]         # 此刻灯的状态（0=关 1=开）

            sql_update = False
            all_command = []
            # 对比现在的状态和断电之前的状态
            try:
                if light_status is not None and his_conn_status == 1:
                    # 现在能读到聚鱼灯的状态且上一次读不到：将聚鱼灯的状态恢复至断电之前的状态，更新conn_status的状态
                    print(f"{self.now}-[check_status]-{location}聚鱼灯 ({light_status},{guangmin_status}) 1路表示灯开关(0关 1开) 2路表示光敏模式开关(0开 1关)")
                    if his_control_mode == 0:
                        # 恢复至光敏模式
                        if int(guangmin_status) == 1:
                            # 当前是非光敏模式，需要改为光敏模式
                            if light_status == 1:
                                # 先关灯 ??????????关两个灯?????????
                                all_command.extend(command['close_light'])
                                print(f"{self.now}-[check_status]-{location}聚鱼灯 先关灯，再设为光敏模式")
                            # 再开光敏
                            all_command.extend(command['open_photosense'])
                            print(f"{self.now}-[check_status]-{location}聚鱼灯 设为光敏模式")
                        else:
                            # 当前是光敏模式，不需要处理
                            # print(f"{self.now}-[check_status]-{location}聚鱼灯 当前是光敏模式，不需要处理")
                            pass
                    elif his_control_mode == 1:
                        # 恢复至手动模式
                        if int(guangmin_status) == 0:
                            # 先关闭光敏模式
                            all_command.extend(command['close_photosense'])
                            print(f"{self.now}-[check_status]-{location}聚鱼灯 先关闭光敏模式，再修改灯的状态为{his_status}")
                        if light_status != his_status:
                            # 聚鱼灯改为his_status的状态(0=关 1=开)
                            if his_status == 0:
                                all_command.extend(command['close_light'])
                            elif his_status == 1:
                                all_command.extend(command['open_light'])
                            print(f"{self.now}-[check_status]-{location}聚鱼灯 修改灯的状态为{his_status}")
                        else:
                            # print(f"{self.now}-[check_status]-{location}聚鱼灯 状态相同{his_status}，不需要处理")
                            pass
                    elif his_control_mode == 2:
                        # 恢复至定时模式
                        if int(guangmin_status) == 0:
                            # 先关闭光敏模式
                            all_command.extend(command['close_photosense'])
                            print(f"{self.now}-[check_status]-{location}聚鱼灯 定时模式:先关闭光敏模式")
                        # 判断开关灯在 command_polling 方法中

                    # 更新conn_status的状态
                    sql_update = f"UPDATE `gather_fish_light_control` SET conn_status=0 WHERE `location`='{location}';"
                elif light_status is None and his_conn_status == 0:
                    # 现在读不到聚鱼灯的状态且上一次能读到：更新conn_status的状态
                    sql_update = f"UPDATE `gather_fish_light_control` SET conn_status=1 WHERE location='{location}';"

                elif light_status is None and his_conn_status == 1:
                    # print(f"{self.now}-[check_status]-{location}聚鱼灯一直处于离线状态，不做处理")
                    pass

                elif light_status is not None and his_conn_status == 0:
                    # 聚鱼灯一直处于在线状态
                    if int(his_status) == int(light_status):
                        # print(f"{self.now}-[check_status]-{location}聚鱼灯一直处于在线状态，status与当前状态一致！")
                        pass
                    else:
                        # 更新status字段的状态（control_mode字段的状态由前端调接口修改）
                        sql_update = f"UPDATE `gather_fish_light_control` SET status={light_status} WHERE `location`='{location}';"
                        print(f"{self.now}-[check_status]-{location}聚鱼灯一直处于在线状态，保存当前模式status={light_status}")


                # 执行修改状态的指令
                if len(all_command) > 0:
                    # jyd_connectors = Utility.available_connectors[f"juyudeng_{location}"]
                    jyd_connectors = Utility.available_connectors[station_name]
                    for each_command in all_command:
                        print(f"{self.now}-[check_status]-{location}聚鱼灯 {each_command}")
                        jyd_connectors.send_command(each_command)

                if sql_update:
                    print(f"{self.now}-[check_status]-{location}聚鱼灯 {sql_update}")
                    self._storage.execute_update_sql(sql_update)
            except Exception as e:
                print(f"{self.now}-[check_status]-{location}聚鱼灯 ERROR:{e}")
                self._log.error(e)



    def get_real_status(self):
        """
        获取聚鱼灯的实时状态
        return:{'juyudeng_1#': '1', 'juyudeng_2#': None, 'juyudeng_3#': None,...}
        """
        juyudeng_point_sql = "SELECT serial_number,io_point_name FROM `data_point_tbl` WHERE `io_point_name` LIKE 'juyudeng_%_status';"
        juyudeng_point = self._storage.execute_sql(juyudeng_point_sql)
        read_real_list = []
        point_name_dict = {}
        for each in juyudeng_point:
            serial_number = "c"+str(each["serial_number"])
            read_real_list.append(serial_number)
            juyudeng_name = each["io_point_name"].replace("_status", "")
            point_name_dict[serial_number] = juyudeng_name
        real_data_dict = self._storage.get_real_data(read_real_list)

        light_real_status = {}
        for k,v in real_data_dict.items():
            light_real_status[point_name_dict[k]] = v

        return light_real_status


    def update_juyudeng_status(self):
        """判断聚鱼灯的状态是否需要修改"""
        # 获取聚鱼灯的实时状态
        all_light_real_status = self.get_real_status()      # {'juyudeng_1#': '1', 'juyudeng_2#': None,...}
        # print(all_light_real_status)

        # 判断聚鱼灯的状态是否需要修改
        juyudeng_info_sql = "SELECT station_name,location,control_mode,definite_time,commands FROM `gather_fish_light_control`;"
        get_juyudeng_info = self._storage.execute_sql(juyudeng_info_sql)
        for juyudeng_info in get_juyudeng_info:
            # {'location': '1#', 'control_mode': 0, 'definite_time': '[["06:00:00,10:59:59"], ["00:03:00,03:50:59"]]', 'commands': None}
            control_mode = juyudeng_info["control_mode"]     # 0：光敏控制，1：手动控制，2：定时控制

            if control_mode == 0:
                '''光敏模式：前端发送控制指令'''
                pass
            elif control_mode == 1:
                '''手动模式：前端发送控制指令'''
                pass
            elif control_mode == 2:
                '''定时模式'''
                light_status = 0        # 默认聚鱼灯处于关闭状态
                now_time = datetime.now().strftime("%H:%M:%S")
                definite_time = json.loads(juyudeng_info["definite_time"])
                # 依次判断每个时间段
                for time_list in definite_time:
                    each_time = time_list[0].split(",")
                    time1 = each_time[0]
                    time2 = each_time[1]
                    if time1 < time2:
                        if time1 <= now_time <= time2:
                            light_status = 1
                    else:
                        if time2 <= now_time <= time1:
                            light_status = 1
                # 判断是否需要修改当前状态
                light_name = f"juyudeng_{juyudeng_info['location']}"
                station_name = juyudeng_info['station_name']    # 聚鱼灯的站名
                light_real_status = all_light_real_status[light_name]
                # print("///////////////////////",light_name, light_real_status, light_status)

                if light_real_status is None or int(light_status) != int(light_real_status):
                    commands = json.loads(juyudeng_info["commands"])
                    if int(light_status) == 0:
                        # 关灯
                        command = commands["close_light"]
                    elif int(light_status) == 1:
                        # 开灯
                        command = commands["open_light"]
                    # print(light_name, light_real_status. light_status, command)

                    try:
                        Utility.available_connectors[station_name].send_command(command)
                    except Exception as e:
                        self._log.error(e)

"""
station_name:
    juyudeng_12#
    juyudeng_34#
    juyudeng_56#
    juyudeng_78#


开灯1/3/5/7：[{"res": 65280, "device_id": 1, "start_addr": 0, "output_value": 65280, "function_code": 5}]
关灯1/3/5/7：[{"res": 0, "device_id": 1, "start_addr": 0, "output_value": 0, "function_code": 5}]

开灯2/4/6/8：[{"res": 65280, "device_id": 1, "start_addr": 1, "output_value": 65280, "function_code": 5}]
关灯2/4/6/8：[{"res": 0, "device_id": 1, "start_addr": 1, "output_value": 0, "function_code": 5}]

开光敏1-8：[{"res": 0, "device_id": 1, "start_addr": 2, "output_value": 0, "function_code": 5}]
关光敏1-8：[{"res": 65280, "device_id": 1, "start_addr": 2, "output_value": 65280, "function_code": 5}]


1/3/5/7
{"open_light": [{"res": 65280, "device_id": 1, "start_addr": 0, "output_value": 65280, "function_code": 5}], 
"close_light": [{"res": 0, "device_id": 1, "start_addr": 0, "output_value": 0, "function_code": 5}], 
"open_photosense": [{"res": 0, "device_id": 1, "start_addr": 2, "output_value": 0, "function_code": 5}], 
"close_photosense": [{"res": 65280, "device_id": 1, "start_addr": 2, "output_value": 65280, "function_code": 5}]}


2/4/6/8
{"open_light": [{"res": 65280, "device_id": 1, "start_addr": 1, "output_value": 65280, "function_code": 5}], 
"close_light": [{"res": 0, "device_id": 1, "start_addr": 1, "output_value": 0, "function_code": 5}], 
"open_photosense": [{"res": 0, "device_id": 1, "start_addr": 2, "output_value": 0, "function_code": 5}], 
"close_photosense": [{"res": 65280, "device_id": 1, "start_addr": 2, "output_value": 65280, "function_code": 5}]}

"""