|
from decimal import Decimal
|
|
|
|
import json
|
|
import unittest
|
|
|
|
from dsmr_parser import telegram_specifications, obis_references
|
|
from dsmr_parser.objects import MbusDevice
|
|
|
|
|
|
class MbusDeviceTest(unittest.TestCase):
|
|
|
|
def setUp(self):
|
|
v5_objects = telegram_specifications.V5['objects']
|
|
|
|
device_type_parser = v5_objects[obis_references.DEVICE_TYPE]
|
|
device_type = device_type_parser.parse('0-2:24.1.0(003)\r\n')
|
|
|
|
equipment_parser = v5_objects[obis_references.EQUIPMENT_IDENTIFIER_GAS]
|
|
equipment = equipment_parser.parse('0-2:96.1.0(4730303339303031393336393930363139)\r\n')
|
|
|
|
gas_reading_parser = v5_objects[obis_references.HOURLY_GAS_METER_READING]
|
|
gas_reading = gas_reading_parser.parse('0-2:24.2.1(200426223001S)(00246.138*m3)\r\n')
|
|
|
|
mbus_device = MbusDevice(channel_id=1)
|
|
mbus_device.add(obis_references.DEVICE_TYPE, device_type)
|
|
mbus_device.add(obis_references.EQUIPMENT_IDENTIFIER_GAS, equipment)
|
|
mbus_device.add(obis_references.HOURLY_GAS_METER_READING, gas_reading)
|
|
|
|
self.mbus_device = mbus_device
|
|
|
|
def test_attributes(self):
|
|
self.assertEqual(self.mbus_device.DEVICE_TYPE.value, 3)
|
|
self.assertEqual(self.mbus_device.DEVICE_TYPE.unit, None)
|
|
|
|
self.assertEqual(self.mbus_device.EQUIPMENT_IDENTIFIER_GAS.value,
|
|
'4730303339303031393336393930363139')
|
|
self.assertEqual(self.mbus_device.EQUIPMENT_IDENTIFIER_GAS.unit, None)
|
|
|
|
self.assertEqual(self.mbus_device.HOURLY_GAS_METER_READING.value, Decimal('246.138'))
|
|
self.assertEqual(self.mbus_device.HOURLY_GAS_METER_READING.unit, 'm3')
|
|
|
|
def test_to_json(self):
|
|
self.assertEqual(
|
|
json.loads(self.mbus_device.to_json()),
|
|
{
|
|
'CHANNEL_ID': 1,
|
|
'DEVICE_TYPE': {'value': 3, 'unit': None},
|
|
'EQUIPMENT_IDENTIFIER_GAS': {'value': '4730303339303031393336393930363139', 'unit': None},
|
|
'HOURLY_GAS_METER_READING': {'datetime': '2020-04-26T22:30:01+02:00', 'value': 246.138, 'unit': 'm3'}}
|
|
)
|