DataCollectionDevice/converters/nmea0183_converter.py

"""
@Date  :2021/5/21/00219:10:57
@Desc  : 波浪传感器解析器
"""
from tools.format_value import format_value
from logging_config import sm140_converter as logger
import binascii

from converter import Converter


class NEMA0183Converter(Converter):
    def __init__(self, name):
        self._name = name

    def convert(self, config, data):
        logger.info(f"[{self._name}]原始接收数据: len: {len(data)}, values: {data}")
        data = data.decode().split("\r\n")
        logger.info(f"[{self._name}]解码分割: len: {len(data)}, values: {data}")
        for i in data:
            if self.checksum(i):
                res = self.check_type(config, i)
                return res
            else:
                logger.info(f"checksum校验失败：{i}")
                return "error"

    def make_checksum(self, data):
        '''
        Calculates a checksum from a NMEA sentence.
        
        Keyword arguments:
        data -- the NMEA sentence to create
        
        '''
        csum = 0
        i = 0
        # Remove ! or $ and *xx in the sentence
        data = data[1:data.rfind('*')]
        while (i < len(data)):
            input = binascii.b2a_hex(data[i].encode("utf8"))
            input = int(input, 16)
            # xor
            csum = csum ^ input
            i += 1
        return csum

    def checksum(self, data):
        '''
        Reads the checksum of an NMEA sentence.
        
        Keyword arguments:
        data -- the NMEA sentence to check
        
        '''
        try:
            # Create an integer of the two characters after the *, to the right
            supplied_csum = int(data[data.rfind('*') + 1:data.rfind('*') + 3], 16)
        except:
            return ''
        # Create the checksum
        csum = self.make_checksum(data)
        # Compare and return
        if csum == supplied_csum:
            return True
        else:
            return False

    def check_type(self, config, data):
        dict = {}
        data = data.split('*')
        # Splits up the NMEA data by comma
        data = data[0].split(',')
        logger.info(f"[{self._name}]进一步格式化数据: len: {len(data)}, values: {data}")
        if data[0] == '$PMIRWM':
            for index in config:
                name = 'c' + str(index['serial_number'])
                address = int(index['address'])
                dict[name] = format_value(index, data[address])
            logger.info(f"[{self._name}]解析后数据: len: {len(dict)}, values: {dict}")
            return dict

    def nmea2utc(self, data):
        '''
        Converts NMEA utc format to more standardized format.
        '''
        time = data[1][0:2] + ':' + data[1][2:4] + ':' + data[1][4:6]
        date = '20' + data[9][4:6] + '-' + data[9][2:4] + '-' + data[9][0:2]
        return date + 'T' + time + 'Z'


'''        
data = "$PMIRR,20210325,033351.719,0.000,0.000,V,0.00*0F"

data2 = data.split('*')
data2 = data2[0].split(',')

logger.debug(data2[0][3:6])

c = NEMA0183Converter(None)
d = c.checksum(data)  
logger.debug(d)

logger.debug(c.nmea2utc(data2[1]))
'''