Easyelectronics.ru

# -*- coding: utf-8 -*-

import serial
from security_processor import PS
from remote_control_panel import RCP
from io import IO
from control_leds import CL
from log import exc

RS485_ADDRESS  = '/dev/ttyS2' # номер интерфейса uart
RS485_BAUDRATE = 115200 # максимальная скорость uart


########################################################################
class Driver():
    """Класс для работы с RS-485"""

    #----------------------------------------------------------------------
    def __init__(self, port = RS485_ADDRESS):
        """Constructor"""
        self._port = port
        self._ser = serial.Serial()
        self._ser.port = self._port
        self._ser.baudrate = RS485_BAUDRATE
        self._ser.bytesize = serial.EIGHTBITS    #number of bits per bytes
        self._ser.stopbits = serial.STOPBITS_ONE #number of stop bits
        self._ser.parity = serial.PARITY_NONE    #set parity check: no parity
        ##self._ser.timeout = None                 #timeout = None: wait forever
        ##self._ser.timeout = 0                    #timeout = 0: non-blocking mode (return immediately on read)
        self._ser.timeout = 0.01                 #timeout = x: set timeout to x seconds (float allowed)
        self._ser.xonxoff = False                #disable software flow control
        self._ser.rtscts = False                 #disable hardware (RTS/CTS) flow control
        self._ser.dsrdtr = False                 #disable hardware (DSR/DTR) flow control
        self._ser.writeTimeout = 0.05            #timeout for write
       
        try:
            self._ser.open()
        except Exception, err:
            exc("error open serial port: %s" % str(err))
            if self._ser:
                self.close()
        if self._ser.isOpen():
            self._ser.flushInput()
            self._ser.flushOutput()

    #----------------------------------------------------------------------
    def init(self):
        """"""
        pass

    #----------------------------------------------------------------------
    def write(self, data):
        """Записываем данные в подчиненное устройство"""
        res = None
        if not self._ser.isOpen():
            raise Exception('must open before write')
        try:
            res = self._ser.write(data)
        except Exception, e:
            exc('rs485 write error: %s' % str(e))
            self._ser.flushInput()
            self._ser.flushOutput()
       
        return res

    #----------------------------------------------------------------------
    def read(self, length=None):
        """Считываем данные с подчиненного устройства"""
        res = None
        if not self._ser.isOpen():
            raise Exception('must open before read')
        try:
            if length:
                res = self._ser.read(length)
            else:
                res = self._ser.read()
                res += self._ser.read(self._ser.inWaiting())
        except Exception, e:
            exc('rs485 read error: %s' % str(e))
            self._ser.flushInput()
            self._ser.flushOutput()
       
        return res

    #----------------------------------------------------------------------
    def close(self):
        """Закрываем соединение с подчиненным устройством"""
        self._ser.close()