# -*- coding: utf-8 -*-
# !/usr/bin/env python

import logging

from apps.web.device.models import Device
from apps.web.eventer.base import WorkEvent
from apps.web.eventer import EventBuilder

logger = logging.getLogger(__name__)


class builder(EventBuilder):
    def __getEvent__(self, device_event):
        event_data = self.deviceAdapter.analyze_event_data(device_event['data'])

        if event_data is None:
            return None

        return LanguangEvent(self.deviceAdapter, event_data)


class LanguangEvent(WorkEvent):
    def do(self, **args):
        devNo = self.device['devNo']

        logger.info('languang  washing mechine event detected, devNo=%s,curInfo=%s' % (devNo, self.event_data))

        # TODO 这个具体更新什么信息
        Device.get_and_update_device_cache(devNo, **self.event_data)