eros/service/mqtt/record_control.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
    demeter service
    name:record_control.py 处理控制器的状态数据
    author:rabin
    key:control/type/gateway/device
"""
import time
import json
from demeter.core import *
class Record_control(object):

    def handle(self, record, config, value):
        self.record = record
        model = Demeter.model('setting_device_type')
        model.key = config['type']
        device_type = model.select(type='fetchone')
        if device_type:
            name = device_type['name'] + '#' + str(config['child'])
            self.record.save(config, value, name, device_type)