# -*- 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)