|
@@ -18,21 +18,20 @@ class Record(object):
|
|
|
return {'method':array[0], 'type':array[1], 'parent':array[2], 'child':array[2]}
|
|
|
|
|
|
def push(self, key, value):
|
|
|
- if value and value != '0' and value != 0:
|
|
|
- config = self.topic(key)
|
|
|
- method = 'record_' + config['method']
|
|
|
- cls = Demeter.getClass(method, 'service.')
|
|
|
- state = False
|
|
|
- if config['method'] != 'pic':
|
|
|
- if '{' in value:
|
|
|
- value = Demeter.isJson(value)
|
|
|
- if value:
|
|
|
- state = True
|
|
|
- for k,v in value.items():
|
|
|
- config['child'] = k
|
|
|
- cls().handle(self, config, v)
|
|
|
- if state == False:
|
|
|
- cls().handle(self, config, value)
|
|
|
+ config = self.topic(key)
|
|
|
+ method = 'record_' + config['method']
|
|
|
+ cls = Demeter.getClass(method, 'service.')
|
|
|
+ state = False
|
|
|
+ if config['method'] != 'pic':
|
|
|
+ if '{' in value:
|
|
|
+ value = Demeter.isJson(value)
|
|
|
+ if value:
|
|
|
+ state = True
|
|
|
+ for k,v in value.items():
|
|
|
+ config['child'] = k
|
|
|
+ cls().handle(self, config, v)
|
|
|
+ if state == False:
|
|
|
+ cls().handle(self, config, value)
|
|
|
|
|
|
def save(self, config, value, name='', device_type=None):
|
|
|
model = Demeter.model('device_gateway')
|