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