Das deutsche Python-Forum

Code: Alles auswählen

import serial
import RPi.GPIO as GPIO
import time

import os
import sys
import logging


class RS485config(object):
    def __init__(ser, Baudrate = 115200, dev = "/dev/ttyS0"):
        print (dev)
        ser.dev = dev
        ser.serial = serial.Serial(ser.dev, Baudrate)
        GPIO.setmode(GPIO.BCM)
        GPIO.setwarnings(False)
        
        GPIO.setmode(GPIO.BCM)
        
        GPIO.setup(TXDEN_1, GPIO.OUT)
        GPIO.setup(TXDEN_2, GPIO.OUT)

        GPIO.output(TXDEN_1, GPIO.HIGH)
        GPIO.output(TXDEN_2, GPIO.HIGH)
        
    def Uart_SendByte(ser, value): 
        ser.serial.write(value.encode('ascii')) 
    
    def Uart_SendString(ser, value): 
        ser.serial.write(value.encode('ascii'))

    def Uart_ReceiveByte(ser): 
        return ser.serial.read(1).decode("utf-8")

    def Uart_ReceiveString(ser, value): 
        data = ser.serial.read(value)
        return data.decode("utf-8")
        
    def Uart_Set_Baudrate(ser, Baudrate):
         ser.serial = serial.Serial(ser.dev, Baudrate)
    
  
logging.basicConfig(level=logging.INFO)
libdir = os.path.join(os.path.dirname(os.path.dirname(os.path.realpath(__file__))), 'lib')
if os.path.exists(libdir):
    sys.path.append(libdir)

TXDEN_1 = 27
TXDEN_2 = 22

endat_clock = RS485config(dev = "/dev/ttySC0")
endat_data = RS485config(dev = "/dev/ttySC1")

GPIO.output(TXDEN_1, GPIO.LOW) #send
GPIO.output(TXDEN_2, GPIO.HIGH) #read

clock = endat_clock.Uart_SendString("Hallo")
data = endat_data.Uart_ReceiveString(5)
    
print(data)

Code: Alles auswählen

def __init__(ser):

Code: Alles auswählen

def __init__(self):

Code: Alles auswählen

import logging
from contextlib import contextmanager
from threading import Lock

import RPi.GPIO as GPIO
import serial

TXDEN_1 = 27
TXDEN_2 = 22


def setup_gpio():
    """
    GPIO einrichten
    """
    GPIO.setmode(GPIO.BCM)
    GPIO.setwarnings(False)
    GPIO.setmode(GPIO.BCM)
    GPIO.setup((TXDEN_1, TXDEN_2), GPIO.OUT, value=True)


@contextmanager
def enable_send(channel):
    GPIO.output(channel, GPIO.HIGH)
    yield  # ab dann wird der Code im with-Block ausgeführt
    # ab hier ist der Code des Kontext-Managers abgearbeitet
    # output auf 0 setzen, um wieder empfangen zu können
    GPIO.output(channel, GPIO.LOW)


class RS485config(object):
    def __init__(self, dev, enable_gpio, baudrate=115200):
        self.serial = serial.Serial(dev, baudrate)
        self.enable_gpio = enable_gpio
        # soll gleichzeitiges Senden und Empfangen unterbinden
        self.send_receive_lock = Lock()

    def send(self, text):
        # zuerst wird der Lock abgefragt, danach der GPIO durch den Kontextmanager gesetzt
        # wenn er z.B. gerade Daten empfängt, wartet er, bis der Lock wieder freigegeben ist
        # danach wird erst der GPIO auf High gesetzt
        with (
            self.send_receive_lock,
            enable_send(self.enable_gpio),
        ):
            self.serial.write(text.encode("ascii"))

    def receive(self, size):
        with self.send_receive_lock:
            data = self.serial.read(size)
        return data.decode("ascii")

    def set_baudrate(self, baudrate):
        self.serial.close()
        self.serial = serial.Serial(self.serial.port, baudrate)


logging.basicConfig(level=logging.INFO)

# ist eigentlich nicht notwendig
# libdir = Path(__file__).parent.joinpath("lib")
# if libdir.exists():
#    sys.path.append(str(libdir))

# Wenn irgendwas in lib ist, dann importire es
# from lib.modul import funktion


setup_gpio()

# Signatur geändert: Port, Enable-GPIO, Baudrate
endat_clock = RS485config("/dev/ttySC0", TXDEN_1)
endat_data = RS485config("/dev/ttySC1", TXDEN_2)

clock = endat_clock.send("Hallo")
data = endat_data.receive(5)

print(data)