Python zapytanie do kasy Novitus z protokołem TANGO

import socket
import time

KASA_IP = "192.168.1.XXX"
KASA_PORT = 5001
TOUT = 3  # Zwiększony czas oczekiwania

ENQ = b"\x05"
ACK = b"\x06"
NAK = b"\x15"
EOT = b"\x04"
STX = b"\x02"
ETX = b"\x03"

# Funkcja do obliczania sumy kontrolnej (CRC)
def oblicz_sume_kontrolna(pakiet):
    crc = 0
    for i, znak in enumerate(pakiet):
        crc ^= znak << (i % 9)
    return format(crc, '04X')  # Zwraca wynik jako 4-cyfrową liczbę heksadecymalną

# Funkcja do wysyłania pakietu startowego
def wyslij_pakiet_startowy(s):
    # Składając pakiet na podstawie specyfikacji
    numer_poczatkowy = b"000000000000000000"  # Zmienny początek (np. numery raportów)
    numer_koncowy = b"000000000000000000"    # Zmienny koniec (np. numery raportów)
    
    pakiet_startowy = STX + b'S' + b'A' + b'0' + numer_poczatkowy + numer_koncowy + ETX
    
    print(pakiet_startowy)
    
    suma = oblicz_sume_kontrolna(pakiet_startowy)
    
    # Dodajemy sumę kontrolną (cztery bajty)
    pakiet_startowy += bytes.fromhex(suma)  
    
    print(pakiet_startowy)
    
    s.sendall(pakiet_startowy)
    
    print(f"Wysłano pakiet startowy: {pakiet_startowy.hex()}")
    
def wyslij_pakiet_danych(s, dane):
    pakiet_danych = STX + dane + ETX
    suma = oblicz_sume_kontrolna(pakiet_danych)
    
    # Dodajemy sumę kontrolną (cztery bajty)
    pakiet_danych += bytes.fromhex(suma)
    
    s.sendall(pakiet_danych)
    print(f"Wysłano pakiet danych: {pakiet_danych.hex()}")

def komunikacja_z_kasą():
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.settimeout(TOUT)  # Timeout na odpowiedzi
        
        try:
            s.connect((KASA_IP, KASA_PORT))
            print("Połączono z kasą.")
            
            # Wysłanie ENQ do rozpoczęcia transmisji
            s.sendall(ENQ)
            print("Wysłano ENQ, oczekiwanie na odpowiedź...")
            odpowiedz = s.recv(1)
            print(f"Odebrano odpowiedź po ENQ: {odpowiedz.hex()}")
            
            if odpowiedz == ACK:
                print("Odebrano ACK - kasa gotowa do transmisji.")
                
                # Wysyłanie pakietu startowego
                wyslij_pakiet_startowy(s)

                # Oczekiwanie na ACK po wysłaniu pakietu startowego
                odpowiedz = s.recv(1)
                print(odpowiedz)
                print(f"Odebrano odpowiedź po pakiecie startowym: {odpowiedz.hex()}")
                
                if odpowiedz == ACK:
                    print("Odebrano ACK po pakiecie startowym.")
                    
                    # Wysyłanie pakietu danych (przykład danych: "12345678")
                    dane = b"12345678"  # Przykładowe dane do wysłania
                    wyslij_pakiet_danych(s, dane)

                    # Oczekiwanie na ACK po wysłaniu pakietu danych
                    odpowiedz = s.recv(1)
                    print(f"Odebrano odpowiedź po pakiecie danych: {odpowiedz.hex()}")
                    if odpowiedz == ACK:
                        print("Odebrano ACK po pakiecie danych.")
                    
                    # Wysłanie EOT
                    s.sendall(EOT)
                    print("Wysłano EOT, koniec transmisji.")
                    
                    # Oczekiwanie na EOT
                    odpowiedz = s.recv(1)
                    print(f"Odebrano odpowiedź po EOT: {odpowiedz.hex()}")
                    if odpowiedz == EOT:
                        print("Odebrano EOT - zakończenie transmisji.")
                
                else:
                    print("Błąd komunikacji - nie otrzymano ACK po wysłaniu pakietu startowego.")
            
            else:
                print(f"Odebrano nieoczekiwaną odpowiedź po ENQ: {odpowiedz.hex()}")
        
        except socket.timeout:
            print("Timeout - kasa nie odpowiada.")
        except Exception as e:
            print(f"Błąd: {e}")

if __name__ == "__main__":
    komunikacja_z_kasą()