apiWebSocket.py 文件源码

def open(self):
        device_id = str(self.get_argument("device_id"))
        # ????
        ApiDeviceSocketHandler.send_success(self)
        logging.info("device_id: " + device_id + " : connect_success")
        # ??????????
        ApiDeviceSocketHandler.device_client_map[device_id] = self
        logging.info("device_client_map: " + str(ApiDeviceSocketHandler.device_client_map))
        # ???????
        playlist = BaseFunctionHandler.get_res_group_by_device_id(device_id)
        self.write_message(json.dumps(playlist))
        logging.info(device_id + '????????:' + str(json.dumps(playlist)))
        # ?????????
        time_switch = BaseFunctionHandler.get_time_switch(device_id)
        self.write_message(json.dumps(time_switch))
        logging.info(device_id + '?????????:' + str(json.dumps(time_switch)))

    # ??websocket ?????