ASJServer/Controller/SensorGateway/SmartSocketController.py

# -*- encoding: utf-8 -*-
"""
@File    : SmartSocketController.py
@Time    : 2023/3/17 11:52
@Author  : stephen
@Email   : zhangdongming@asj6.wecom.work
@Software: PyCharm
"""
import calendar
import datetime
import logging
import time

from dateutil.parser import parse
from django.db import transaction
from django.db.models import Sum, Count
from django.http import QueryDict
from django.views import View
from decimal import Decimal

from Model.models import SocketInfo, SocketSchedule, Device_Info, SocketPowerStatistics, SceneLog
from Object.ResponseObject import ResponseObject
from Object.utils import LocalDateTimeUtil
from Service.CommonService import CommonService

LOGGER = logging.getLogger('info')
SOCKET_TOPIC_NAME = 'loocam/smart-socket/{}'  # 插座发布消息主题（因设备当前版本只能订阅一个主题）


class SmartSocketView(View):
    def get(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.GET, request, operation)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        return self.validation(request.POST, request, operation)

    def delete(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        delete = QueryDict(request.body)
        if not delete:
            delete = request.GET
        return self.validation(delete, request, operation)

    def put(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation')
        put = QueryDict(request.body)
        return self.validation(put, request, operation)

    def validation(self, request_dict, request, operation):
        ResponseObject('cn')
        if operation == 'savePowerStatistics':  # 保存电量上报统计
            return self.save_power_statistics(request_dict, ResponseObject('cn'))
        elif operation == 'reset':  # 设备复位
            return self.socket_reset(request_dict, ResponseObject('cn'))
        token_code, user_id, response = CommonService \
            .verify_token_get_user_id(request_dict, request)
        if token_code != 0:
            return response.json(token_code)
        if operation == 'saveSwitch':  # 添加插座开关
            return self.save_switch(request_dict, response)
        elif operation == 'saveCountDown':  # 添加插座倒计时
            return self.save_count_down(request_dict, response)
        elif operation == 'saveSchedule':  # 添加插座排程
            return self.save_socket_schedule(request_dict, response)
        elif operation == 'get-all-scene':  # 统计智能插座电量
            return self.get_all_scene(request_dict, response)
        elif operation == 'get-socket-schedule':  # 智能插座排程记录查询
            return self.get_socket_schedule(request_dict, response)
        elif operation == 'get-log':  # 智能插座开关日志记录查询
            return self.get_log(request_dict, response)
        elif operation == 'del-socket-schedule':  # 批量刪除排程
            return self.del_socket_schedule(request_dict, response, user_id)
        elif operation == 'get-unit-scene':  # 查詢設備每日/月用電量
            return self.get_unit_scene(request_dict, response)
        elif operation == 'get-schedule-data':  # 查询插座记录日期
            return self.get_schedule_data(request_dict, response)
        return response.json(404)

    @classmethod
    def socket_reset(cls, request_dict, response):
        """
        智能插座复位删除数据
        """
        try:
            with transaction.atomic():
                serial_number = request_dict.get('serialNumber', None)
                if not serial_number:
                    return response.json(444)
                socket_info_qs = SocketInfo.objects.filter(serial_number=serial_number, type_switch=0)
                if not socket_info_qs.exists():
                    return response.json(173)
                device_id = socket_info_qs.first().device_id
                if socket_info_qs.first().status == 1:  # 设备电源开时 恢复为关闭状态
                    socket_info_qs.update(status=0, updated_time=int(time.time()))
                # 删除插座倒计时
                SocketInfo.objects.filter(device_id=device_id, type_switch=1).delete()
                # 删除插座电量统计
                SocketPowerStatistics.objects.filter(device_id=device_id).delete()
                # 删除插座排程
                SocketSchedule.objects.filter(device_id=device_id).delete()
                # 删除插座开关日志
                SceneLog.objects.filter(device_id=serial_number).delete()
                return response.json(0)
        except Exception as e:
            LOGGER.info('插座复位删除数据异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(177)

    @classmethod
    def save_power_statistics(cls, request_dict, response):
        """
        保存设备上报电量统计
        """
        try:
            serial_number = request_dict.get('serialNumber', None)
            watt = request_dict.get('electricity', 0.00)  # 功率
            power = request_dict.get('power', 0.00)  # 负载功率
            # 在线时长分钟
            accumulated_time = request_dict.get('accumulatedTime', None)
            device_time = request_dict.get('deviceTime', None)
            LOGGER.info('{}上报电量统计data：{}'.format(serial_number, request_dict))
            if not all([serial_number, watt, power, accumulated_time, device_time]):
                return response.json(444)
            device_time = int(device_time)
            watt = float(watt)
            power = float(power)
            accumulated_time = int(accumulated_time)
            now_time = int(time.time())
            start_time, end_time = LocalDateTimeUtil.get_today_date(True)
            # 查询当前序列号当天是否有上传过电量统计
            power_qs = SocketPowerStatistics.objects.filter(serial_number=serial_number,
                                                            created_time__gt=start_time,
                                                            created_time__lte=end_time)
            data = {
                'power': power,
                'updated_time': now_time,
                'watt': watt
            }
            if not power_qs.exists():  # 添加插座上报电量统计
                socket_info_qs = SocketInfo.objects.filter(serial_number=serial_number).values('device_id')
                if not socket_info_qs.exists():
                    return response.json(173)
                data['device_id'] = socket_info_qs[0]['device_id']
                data['created_time'] = device_time
                data['serial_number'] = serial_number
                data['electricity'] = cls.calculated_power(watt, accumulated_time)
                data['accumulated_time'] = accumulated_time
                SocketPowerStatistics.objects.create(**data)
                return response.json(0)
            power_vo = power_qs.first()
            # 累加在线时间目前是以分钟为单位
            data['accumulated_time'] = power_vo.accumulated_time + accumulated_time
            # kwh 千瓦时
            kilowatt_hour = cls.calculated_power(watt, accumulated_time)
            data['electricity'] = kilowatt_hour + float(power_vo.electricity)
            # 所消耗累计功率
            data['watt'] = float(power_vo.watt) + watt
            # 更新当天电量统计
            power_qs.update(**data)
            return response.json(0)
        except Exception as e:
            LOGGER.info('智能插座电量存库异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(177)

    @staticmethod
    def calculated_power(watt, minute):
        """
        通过每分钟所消耗的功率（瓦）得到千瓦时kwh
        """
        if watt == 0 or watt < 0.1 or minute == 0:
            return 0.00
        hours = minute / 60
        kilowatt_hour = watt * hours / 1000
        LOGGER.info('瓦计算得到千瓦时结果{}'.format(kilowatt_hour))
        return kilowatt_hour

    @staticmethod
    def get_serial_number_by_device_id(deviceId):
        """
        根据设备ID获取序列号
        """
        device_info = Device_Info.objects.get(id=deviceId)
        return device_info.serial_number

    @classmethod
    def save_switch(cls, request_dict, response):
        """
        添加开关
        """
        device_id = request_dict.get('deviceId', None)
        status = request_dict.get('status', None)
        if not all([device_id, status]):
            return response.json(444)
        serial_number = cls.get_serial_number_by_device_id(device_id)
        # 保存数据库并下发MQTT消息到插座设备
        result = cls.save_socket_switch(device_id, serial_number, int(status))
        if not result:
            return response.json(177)
        return response.json(0)

    @staticmethod
    def save_socket_switch(device_id, serial_number, status, type_switch=0):
        """
        保存插座开关信息
        @param device_id: 设备ID
        @param serial_number: 序列号
        @param status: 状态 0关，1开
        @param type_switch: 0：总开关，1倒计时开关
        @return: True | False
        """
        if not device_id:
            return False
        socket_info_qs = SocketInfo.objects.filter(device_id=device_id, type_switch=type_switch)
        now_time = int(time.time())
        try:
            with transaction.atomic():
                # 创建插座开关信息
                if not socket_info_qs.exists():
                    socket_dict = {"device_id": device_id,
                                   "serial_number": serial_number,
                                   "status": status,
                                   "type_switch": type_switch,
                                   "created_time": now_time,
                                   "updated_time": now_time,
                                   "online": True}
                    SocketInfo.objects.create(**socket_dict)
                    return True
                if socket_info_qs.first().status == status:
                    return True
                socket_info_qs.update(status=status, updated_time=now_time)
                # 主题名称
                topic_name = SOCKET_TOPIC_NAME.format(serial_number)
                # 发布消息内容
                msg = {'type': 1, 'data': {'deviceSwitch': status}}
                result = CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg)
                LOGGER.info('智能插座开关设置发布MQTT消息结果{}'.format(result))
                return True
        except Exception as e:
            LOGGER.info('智能插座异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def save_count_down(cls, request_dict, response):
        """
        添加倒计时
        """
        device_id = request_dict.get('deviceId', None)
        status = request_dict.get('status', None)
        start = request_dict.get('start', None)
        count_down_time = request_dict.get('countDownTime', None)
        if not all([device_id, status, count_down_time]):
            return response.json(444)
        serial_number = cls.get_serial_number_by_device_id(device_id)
        # 保存数据库并下发MQTT消息到插座设备
        result = cls.save_socket_count_down(device_id, serial_number, int(status), int(start), int(count_down_time))
        if not result:
            return response.json(177)
        return response.json(0)

    @staticmethod
    def save_socket_count_down(device_id, serial_number, status, start, count_down_time, type_switch=1):
        """
        保存插座倒计时信息
        @param count_down_time: 倒计时时间戳
        @param start: 是否启动倒计时 0：关闭，1：开始
        @param device_id: 设备ID
        @param serial_number: 序列号
        @param status: 倒计时电源状态 0关，1开
        @param type_switch: 0：总开关，1倒计时开关
        @return:
        """
        if not device_id:
            return False
        socket_info_qs = SocketInfo.objects.filter(device_id=device_id, type_switch=type_switch)
        now_time = int(time.time())
        try:
            with transaction.atomic():
                # 创建插座倒计时信息
                if not socket_info_qs.exists():
                    socket_dict = {"device_id": device_id,
                                   "serial_number": serial_number,
                                   "status": status,
                                   "type_switch": type_switch,
                                   "created_time": now_time,
                                   "updated_time": now_time,
                                   "online": True,
                                   "start": True if start == 1 else False,
                                   "count_down_time": count_down_time}
                    socket_info_qs = SocketInfo.objects.create(**socket_dict)
                    count_down_id = socket_info_qs.id
                else:
                    socket_info_qs.update(status=status, count_down_time=count_down_time,
                                          updated_time=now_time)
                    count_down_id = socket_info_qs.first().id
                # 主题名称
                topic_name = SOCKET_TOPIC_NAME.format(serial_number)
                # 发布消息内容
                msg = {'type': 2,
                       'data': {'powerType': status,
                                'countDownId': count_down_id,
                                'time': count_down_time,
                                'start': start}}
                result = CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg)
                LOGGER.info('智能插座倒计时发布MQTT消息结果{}'.format(result))
                return True
        except Exception as e:
            LOGGER.info('智能插座异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return False

    @classmethod
    def save_socket_schedule(cls, request_dict, response):
        """
        插座添加排程
        """
        try:
            device_id = request_dict.get('deviceId', None)
            task_type = request_dict.get('timeType', None)
            start_time = request_dict.get('startTime', None)
            end_time = request_dict.get('endTime', 0)
            repeat = request_dict.get('repeat', None)
            task_id = request_dict.get('taskId', None)
            device_switch = request_dict.get('deviceSwitch', None)
            task_switch = request_dict.get('taskSwitch', None)
            if not all([task_type, start_time, end_time, repeat, device_switch, task_switch]):
                return response.json(444)
            device_switch = int(device_switch)
            task_switch = int(task_switch)
            now_time = int(time.time())
            task_type = int(task_type)
            end_time = int(end_time) if task_type == 1 else 0
            data = {'time_type': task_type, 'start_time': int(start_time), 'repeat': int(repeat),
                    'switch_status': True if device_switch == 1 else False,
                    'task_status': True if task_switch == 1 else False}
            serial_number = cls.get_serial_number_by_device_id(device_id)
            if task_id:  # 修改排程
                task_id = int(task_id)
                socket_schedule_qs = SocketSchedule.objects.filter(id=task_id)
                if not socket_schedule_qs.exists():
                    return response.json(174)
                if end_time:
                    data['end_time'] = end_time
                data['updated_time'] = now_time
                socket_schedule_qs.update(**data)
            else:
                # 查询是否已设置过当前排程
                socket_s_qs = SocketSchedule.objects.filter(device_id=device_id,
                                                            start_time=int(start_time),
                                                            end_time=end_time,
                                                            time_type=task_type)
                if socket_s_qs.exists():
                    return response.json(174)
                schedule_count = SocketSchedule.objects.filter(device_id=device_id).count()
                if schedule_count >= 30:
                    return response.json(10061)
                # 添加排程
                data['device_id'] = device_id
                data['end_time'] = end_time
                data['serial_number'] = serial_number
                data['updated_time'] = now_time
                data['created_time'] = now_time
                socket_schedule = SocketSchedule.objects.create(**data)
                task_id = socket_schedule.id
            # 将排程任务下发给设备
            cls.send_socket_schedule(serial_number, task_id, task_type, int(start_time),
                                     end_time, int(repeat), device_switch,
                                     task_switch)
            return response.json(0)
        except Exception as e:
            LOGGER.info('智能插座异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return False

    @staticmethod
    def send_socket_schedule(serial_number, task_id, time_type, start_time, end_time, repeat, device_switch,
                             task_switch):
        """
        排程下发设备
        @param serial_number: 序列号
        @param task_id: 当前排程任务id
        @param time_type: 任务类型 0：设定时间，1：设定时间段
        @param start_time: 开启时间
        @param end_time: 结束时间
        @param repeat: 重复日期
        @param device_switch: 任务执行后期望设备状态，0：关闭，1：开启
        @param task_switch: 任务执行状态 0：不执行，1：执行
        @return: True | False
        """
        msg = {
            'type': 3,
            'data': {'taskId': task_id, 'timeType': time_type,
                     'startTime': start_time, 'endTime': end_time,
                     'repeat': repeat,
                     'deviceSwitch': device_switch,
                     'taskSwitch': task_switch}
        }
        # 主题名称
        topic_name = SOCKET_TOPIC_NAME.format(serial_number)
        result = CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg)
        LOGGER.info('智能插座排程任务发布MQTT消息结果{}'.format(result))
        return result

    # 以下是查询智能插座接口
    @staticmethod
    def get_all_scene(request_dict, response):
        """
        统计智能插座电量
        @request_dict serialNumber: 序列号
        @request_dict unit: 时间单位
        @param request_dict: 请求数据
        @param response: 响应
        @return: response
        """
        serial_number = request_dict.get('serialNumber', None)
        # 确定是否会传值
        if not all([serial_number]):
            return response.json(444, {'error param': 'serialNumber'})
        socket_power_qs = SocketPowerStatistics.objects.filter(serial_number=serial_number).values('electricity',
                                                                                                   'accumulated_time',
                                                                                                   'power',
                                                                                                   'created_time'). \
            order_by('-created_time')
        if not socket_power_qs.exists():
            return response.json(0, {})
        try:
            data = {}
            # 设备累计电量
            all_electricity = socket_power_qs.aggregate(total=Sum('electricity'))
            data['electricityAll'] = Decimal(all_electricity['total']).quantize(Decimal("0.00")) if all_electricity[
                'total'] else 0
            # 当天使用电量
            data['electricityToday'] = Decimal(socket_power_qs[0]['electricity']).quantize(Decimal("0.00")) if \
                socket_power_qs[0]['electricity'] else 0
            # 当天累计时长
            data['accumulated_time'] = socket_power_qs[0]['accumulated_time']
            # 功率
            data['power'] = socket_power_qs[0]['power']

            # 本月电费
            nowTime = int(time.time())
            nowTime = CommonService.timestamp_to_str(nowTime)
            year, month = str(nowTime).split('-')[0], str(nowTime).split('-')[1]
            end = calendar.monthrange(int(year), int(month))[1]
            startTime_now = parse('%s-%s-01 00:00:00' % (year, month))
            endTime_now = parse('%s-%s-%s 23:59:59' % (year, month, end))
            startTime_now = CommonService.str_to_timestamp(str(startTime_now))
            endTime_now = CommonService.str_to_timestamp(str(endTime_now))
            electricity = socket_power_qs.filter(created_time__gte=startTime_now,
                                                 created_time__lt=endTime_now).aggregate(
                total=Sum('electricity'))
            data['electricityMonth'] = Decimal(electricity['total']).quantize(Decimal("0.00")) if electricity[
                'total'] else 0

            # 昨天使用电量
            today = datetime.date.today()  # 获取今日日期
            yesterday = today - datetime.timedelta(days=1)
            # 昨天开始时间戳
            yesterday_start_time = int(time.mktime(time.strptime(str(yesterday), '%Y-%m-%d')))
            # 昨天结束时间戳
            yesterday_end_time = int(time.mktime(time.strptime(str(today), '%Y-%m-%d'))) - 1
            socket_qs = socket_power_qs.filter(created_time__gte=yesterday_start_time,
                                               created_time__lt=yesterday_end_time).values('electricity')
            data['electricityYesterday'] = Decimal(socket_qs[0]['electricity']).quantize(Decimal("0.00")) if \
                socket_qs[0]['electricity'] else 0
            return response.json(0, data)
        except Exception as e:
            return response.json(500, repr(e))

    @staticmethod
    def get_socket_schedule(request_dict, response):
        """
        智能插座排程记录查询
        @param request_dict: 请求参数
        @request_dict page: 页数
        @request_dict size: 条数
        @request_dict serialNumber: 设备序列号
        @param response: 响应对象
        @return: response
        """
        page = request_dict.get('pageNo', None)
        size = request_dict.get('pageSize', None)
        serial_number = request_dict.get('serialNumber', None)

        if not all([page, size, serial_number]):
            return response.json(444)
        page, size = int(page), int(size)
        socket_schedule_qs = SocketSchedule.objects.filter(serial_number=serial_number).values('switch_status',
                                                                                               'start_time',
                                                                                               'end_time',
                                                                                               'repeat',
                                                                                               'task_status',
                                                                                               'time_type',
                                                                                               'created_time',
                                                                                               'updated_time',
                                                                                               'device_id',
                                                                                               'id').order_by(
            '-created_time')[(page - 1) * size:page * size]
        if not socket_schedule_qs.exists():
            return response.json(0, [])
        try:
            schedule_list = []
            for socket_schedule in socket_schedule_qs:
                schedule_list.append({
                    'taskId': socket_schedule['id'],
                    'deviceID': socket_schedule['device_id'],
                    'serialNumber': serial_number,
                    'timeType': socket_schedule['time_type'],
                    'startTime': socket_schedule['start_time'],
                    'endTime': socket_schedule['end_time'],
                    'switchStatus': socket_schedule['switch_status'],
                    'taskStatus': socket_schedule['task_status'],
                    # 进制
                    'repeat': socket_schedule['repeat'],
                })
            return response.json(0, schedule_list)
        except Exception as e:
            return response.json(500, repr(e))

    @staticmethod
    def get_log(request_dict, response):
        """
        智能插座开关日志记录查询
        @param request_dict: 请求参数
        @request_dict page: 页数
        @request_dict size: 条数
        @request_dict serialNumber: 设备序列号
        @request_dict startTime: 开始时间
        @request_dict endTime: 结束时间
        @param response: 响应对象
        @return: response
        # 日誌擦護用序列號查詢
        """
        page = request_dict.get('page', None)
        size = request_dict.get('size', None)
        serial_number = request_dict.get('serialNumber', None)
        startTime = request_dict.get('startTime', None)
        endTime = request_dict.get('endTime', None)
        if not all([page, size, serial_number]):
            return response.json(444, {'errno: page or size or serial_number'})
        page, size = int(page), int(size)

        try:
            if startTime is None and endTime is None:
                scene_log_qs = SceneLog.objects.filter(device_id=serial_number).values('tasks', 'status',
                                                                                       'created_time').order_by(
                    '-created_time')[(page - 1) * size:page * size]
                if not scene_log_qs.exists():
                    return response.json(0, [])
            else:
                scene_log_qs = SceneLog.objects.filter(device_id=serial_number, created_time__gte=startTime,
                                                       created_time__lt=endTime).values('tasks', 'status',
                                                                                        'created_time').order_by(
                    '-created_time')[(page - 1) * size:page * size]
                if not scene_log_qs.exists():
                    return response.json(0, [])
            log_list = []
            for scene_log in scene_log_qs:
                data = {
                    'serialNumber': serial_number,
                    'tasks': scene_log['tasks'] if scene_log['tasks'] else '',
                    'status': scene_log['status'],
                    'createdTime': scene_log['created_time'],
                }
                log_list.append(data)
            return response.json(0, log_list)
        except Exception as e:
            return response.json(500, repr(e))

    @classmethod
    def splittings_time(cls, startTime, endTime, unit):
        """
        根據時間單位分割時間
        """
        diction = {}
        time_list = []
        # 开始时间
        startTime = CommonService.timestamp_to_str(int(startTime))
        endTime = CommonService.timestamp_to_str(int(endTime))
        startYear, startMonth, startDay = \
            str(startTime).split('-')[0], str(startTime).split('-')[1], str(startTime).split('-')[2]
        # 结束时间
        endYear, endMonth, endDay = str(endTime).split('-')[0], str(endTime).split('-')[1], str(endTime).split('-')[
            2]
        if unit == 'week' or unit == 'month':
            startTime = parse('%s-%s-%s' % (startYear, startMonth, startDay))
            endTime = parse('%s-%s-%s' % (endYear, endMonth, endDay))
            time_list = CommonService.cutting_time(startTime, endTime, time_unit='day')
        elif unit == 'year':
            startYear, startMonth = int(startTime.split('-')[0]), int(startTime.split('-')[1])
            endYear, endMonth = int(endTime.split('-')[0]), int(endTime.split('-')[1])
            # 获取下个月的第一天
            if startMonth == 12:
                startYear += 1
                startMonth = 1
            else:
                startMonth += 1
            #  计算（开始月，结束月）
            startTime = parse('%s-%s-01 00:00:00' % (str(startYear), str(startMonth)))
            # 获取上个月最后一天
            if endMonth == 1:
                endYear -= 1
                endMonth = 12
            else:
                endMonth -= 1
            endDay = calendar.monthrange(endYear, endMonth)[1]
            endTime = parse('%s-%s-%s 23:59:59' % (str(endYear), str(endMonth), endDay))
            time_list = CommonService.cutting_time(startTime, endTime, time_unit='month')
            #  开始月的时间区间
            startMonth_time = CommonService.str_to_timestamp(str(startTime))
            #  结束月的时间区间
            endMonth_time = CommonService.str_to_timestamp(str(endTime))
            diction['startMonth_time'] = startMonth_time
            diction['endMonth_time'] = endMonth_time
        diction['time_list'] = time_list
        return diction

    @staticmethod
    def del_socket_schedule(request_dict, response, user_id):
        """
        批量刪除排程
        @param request_dict: 请求参数
        @param user_id: 用戶user_id
        @request_dict ids: 排程id
        @request_dict serialNumber: 设备序列号
        @param response: 响应对象
        @return: response
        """
        try:
            with transaction.atomic():
                ids = request_dict.get('ids', None)
                serial_number = request_dict.get('serialNumber', None)
                if not all({ids, serial_number}):
                    return response.json(444, {'error param': 'id or serialNumber'})
                device_info_qs = Device_Info.objects.filter(userID_id=user_id, serial_number=serial_number)
                if not device_info_qs.exists():
                    return response.json(173)
                socket_schedule_qs = SocketSchedule.objects.filter(id__in=ids.split(','))
                if not socket_schedule_qs.exists():
                    return response.json(173)
                # 发布MQTT消息通知设备删除排程任务
                for val in socket_schedule_qs:
                    if val.task_status:
                        switch_status = 1 if val.switch_status else 0
                        result = SmartSocketView.send_socket_schedule(val.serial_number, val.id, val.time_type,
                                                                      val.start_time, val.end_time,
                                                                      val.repeat, switch_status, 0)
                        LOGGER.info('删除排程发布结果：{}'.format(result))
                socket_schedule_qs.delete()
                return response.json(0)
        except Exception as e:
            LOGGER.info('插座排程删除数据异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(177)

    @classmethod
    def get_unit_scene(cls, request_dict, response):
        """
        查詢設備每日/月用電量
        @request_dict serialNumber: 设备序列号
        @request_dict startTime: 开始时间
        @request_dict endTime: 结束时间
        @param request_dict: 请求参数
        @param response: 响应对象
        @return: response
        """
        serial_number = request_dict.get('serialNumber', None)
        unit = request_dict.get('unit', None)
        startTime = request_dict.get('startTime', None)
        endTime = request_dict.get('endTime', None)
        if not all([unit, startTime, endTime, serial_number]):
            return response.json(500, {'errno': 'unit or startTime or endTime or serialNumber'})
        try:
            socket_power_qs = SocketPowerStatistics.objects.filter(serial_number=serial_number). \
                values('electricity', 'accumulated_time', 'power', 'created_time')
            if not socket_power_qs.exists():
                return response.json(0, {})
            #  时间和功耗
            data = {}
            new_list = []
            socket_qs = socket_power_qs.filter(created_time__gte=startTime, created_time__lt=endTime).aggregate(
                electricity=Sum('electricity'), accumulatedTime=Sum('accumulated_time'))
            data['electricityTimeAll'] = Decimal(socket_qs['electricity']).quantize(Decimal("0.00")) if socket_qs[
                'electricity'] else 0
            data['accumulatedTimeAll'] = socket_qs['accumulatedTime'] if socket_qs['accumulatedTime'] else 0

            #  分割时间
            diction = cls.splittings_time(startTime, endTime, unit)
            if unit == 'year':
                # 开始月
                socket_qs = socket_power_qs.filter(created_time__gte=startTime,
                                                   created_time__lt=diction['startMonth_time']).aggregate(
                    electricity=Sum('electricity'), accumulatedTime=Sum('accumulated_time'))
                electricity = Decimal(socket_qs['electricity']).quantize(Decimal("0.00")) if socket_qs[
                    'electricity'] else 0
                # 標記月日
                subscript = cls.get_subscript(unit, startTime)
                new_list.append({
                    'subscript': subscript,
                    'time': int(startTime),
                    'electricity': round(electricity, 1)
                })
            # 查询天月
            for item in diction['time_list']:
                socket_qs = socket_power_qs.filter(created_time__gte=item[0],
                                                   created_time__lt=item[1]).aggregate(
                    electricity=Sum('electricity'))
                electricity = Decimal(socket_qs['electricity']).quantize(Decimal("0.00")) if socket_qs[
                    'electricity'] else 0
                # 標記月日
                subscript = cls.get_subscript(unit, item[0])
                new_list.append({
                    'subscript': subscript,
                    'time': item[0],
                    'electricity': round(electricity, 1)
                })

            if unit == 'year':
                # 结束月
                socket_qs = socket_power_qs.filter(created_time__gte=diction['endMonth_time'],
                                                   created_time__lt=endTime).aggregate(
                    electricity=Sum('electricity'))
                electricity = Decimal(socket_qs['electricity']).quantize(Decimal("0.00")) if socket_qs[
                    'electricity'] else 0
                # 標記月日
                subscript = cls.get_subscript(unit, endTime)
                new_list.append({
                    'subscript': subscript,
                    'time': int(endTime),
                    'electricity': round(electricity, 1)
                })
            #  降序排序
            # new_list.sort(key=lambda k: k["time"], reverse=True)
            data['week_or_month_or_year'] = new_list
            return response.json(0, data)
        except Exception as e:
            return response.json(500, repr(e))

    @classmethod
    def get_subscript(cls, unit, time_stamp):
        """
        標記月日
        @param unit: 时间单位
        @param time_stamp: 时间戳
        @return: subscript
        """
        time_tuple = time.localtime(int(time_stamp))  # 把时间戳转换成时间元祖
        time_tuple = time.strftime('%Y-%m-%d-%w', time_tuple)  # 把时间元祖转换成格式化好的时间
        if unit == 'week' or unit == 'year':
            if unit == 'week':
                subscript = int(str(time_tuple).split('-')[3])
                return subscript
            else:
                Year, Month, Day = int(time_tuple.split('-')[0]), int(time_tuple.split('-')[1]), int(
                    time_tuple.split('-')[2])
                subscript = datetime.date(Year, Month, Day).month
                subscript -= 1
                return subscript
        else:
            Year, Month, Day = int(time_tuple.split('-')[0]), int(time_tuple.split('-')[1]), int(
                time_tuple.split('-')[2])
            subscript = datetime.date(Year, Month, Day).day
            subscript -= 1
            return subscript

    @staticmethod
    def get_schedule_data(request_dict, response):
        """
        查询插座日志记录日期
        @request_dict serialNumber: 设备序列号
        @param request_dict: 请求参数
        @param response: 响应对象
        @return: response
        """
        serial_number = request_dict.get('serialNumber', None)
        if not serial_number:
            return response.json(444, {'error': 'serialNumber'})

        try:
            socket_schedule_qs = SceneLog.objects.extra(
                select={'date': "FROM_UNIXTIME(created_time,'%%Y-%%m-%%d')"}).values('date').filter(
                device_id=serial_number).annotate(count=Count('created_time')).order_by('-date')[:31]
            schedule_date_list = []
            for socket_schedule in socket_schedule_qs:
                schedule_date_list.append({
                    'timestamp': CommonService.str_to_timestamp(socket_schedule['date'], '%Y-%m-%d'),
                    'count': socket_schedule['count'],
                    'format': socket_schedule['date']
                })
            return response.json(0, schedule_date_list)
        except Exception as e:
            return response.json(500, repr(e))