import serial
import time

# กำหนดพอร์ตอนุกรมและ baudrate
ser = serial.Serial('/dev/ttyUSB0', 9600, timeout=1)

def send_command(command):
    ser.write(command)
    time.sleep(0.1)

def read_response(expected_length):
    buffer = bytearray()
    while True:
        if ser.in_waiting:
            buffer.extend(ser.read(ser.in_waiting))
        if len(buffer) >= expected_length:
            break
        time.sleep(0.01)
    return buffer

if __name__ == '__main__':
    # ตัวอย่างคำสั่งสำหรับ Inverter
    command = b'\x01\x03\x00\x00\x00\x10\x14\x0B'  # ตรวจสอบคำสั่งให้ถูกต้องตามโปรโตคอลของ Inverter
    expected_length = 37  # กำหนดความยาวข้อมูลที่คาดว่าจะได้รับ

    send_command(command)
    response = read_response(expected_length)
   
    if response:
        print(f'Received data: {response}')
    else:
        print('No data received')

    ser.close()

import serial
import time

# กำหนดพอร์ตอนุกรมและ baudrate
ser = serial.Serial('/dev/ttyUSB0', 9600, timeout=1)

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def append_crc(data):
    crc = calculate_crc(data)
    return data + bytes([crc & 0xFF, (crc >> 8) & 0xFF])

def check_crc(response):
    received_crc = (response[-1] << 8) | response[-2]
    calculated_crc = calculate_crc(response[:-2])
    return received_crc == calculated_crc

def send_command_with_crc(command):
    command_with_crc = append_crc(command)
    ser.write(command_with_crc)

def read_response(expected_length):
    buffer = bytearray()
    while len(buffer) < expected_length + 2:
        if ser.in_waiting:
            buffer.extend(ser.read(ser.in_waiting))
        time.sleep(0.01)
    return buffer

if __name__ == '__main__':
    command = b'COMMAND'  # คำสั่งที่ต้องการทดสอบ
    success_count = 0
    total_tests = 100

    for _ in range(total_tests):
        send_command_with_crc(command)
        response = read_response(len(command))
        if check_crc(response):
            if response[:-2] == command:
                success_count += 1

    print(f'Successful transmissions: {success_count}/{total_tests}')
    ser.close()

import serial
import time

# กำหนดพอร์ตอนุกรมและ baudrate
ser = serial.Serial('/dev/ttyUSB0', 9600, timeout=1)

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def append_crc(data):
    crc = calculate_crc(data)
    return data + bytes([crc & 0xFF, (crc >> 8) & 0xFF])

def check_crc(response):
    received_crc = (response[-1] << 8) | response[-2]
    calculated_crc = calculate_crc(response[:-2])
    return received_crc == calculated_crc

def send_command_with_crc(command):
    command_with_crc = append_crc(command)
    ser.write(command_with_crc)

def read_response(expected_length):
    buffer = bytearray()
    while len(buffer) < expected_length + 2:
        if ser.in_waiting:
            buffer.extend(ser.read(ser.in_waiting))
        time.sleep(0.01)
    return buffer

if __name__ == '__main__':
    command = b'COMMAND'  # คำสั่งที่ต้องการทดสอบ
    success_count = 0
    total_tests = 100

    for _ in range(total_tests):
        send_command_with_crc(command)
        response = read_response(len(command))
        if check_crc(response):
            if response[:-2] == command:
                success_count += 1

    print(f'Successful transmissions: {success_count}/{total_tests}')
    ser.close()

import paho.mqtt.client as mqtt
import struct

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    payload = b'Hello, MQTT!'
    crc = calculate_crc(payload)
    payload_with_crc = payload + struct.pack('<H', crc)
    client.publish("test/topic", payload_with_crc)

client = mqtt.Client()
client.on_connect = on_connect
client.connect("mqtt.eclipse.org", 1883, 60)
client.loop_forever()

import paho.mqtt.client as mqtt
import struct

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def on_message(client, userdata, msg):
    payload = msg.payload
    received_crc = struct.unpack('<H', payload[-2:])[0]
    data = payload[:-2]
    calculated_crc = calculate_crc(data)
    if received_crc == calculated_crc:
        print("Received valid data:", data)
    else:
        print("Received data with invalid CRC")

client = mqtt.Client()
client.on_message = on_message
client.connect("mqtt.eclipse.org", 1883, 60)
client.subscribe("test/topic")
client.loop_forever()

import serial
import time

# กำหนดพอร์ตอนุกรมและ baudrate
ser = serial.Serial('/dev/ttyUSB0', 9600, timeout=1)

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def append_crc(data):
    crc = calculate_crc(data)
    return data + bytes([crc & 0xFF, (crc >> 8) & 0xFF])

def check_crc(response):
    received_crc = (response[-1] << 8) | response[-2]
    calculated_crc = calculate_crc(response[:-2])
    return received_crc == calculated_crc

def send_command_with_crc(command):
    command_with_crc = append_crc(command)
    ser.write(command_with_crc)

def read_response(expected_length):
    buffer = bytearray()
    while len(buffer) < expected_length + 2:
        if ser.in_waiting:
            buffer.extend(ser.read(ser.in_waiting))
        time.sleep(0.01)
    return buffer

if __name__ == '__main__':
    command = b'COMMAND'  # คำสั่งที่ต้องการทดสอบ
    success_count = 0
    total_tests = 100

    for _ in range(total_tests):
        send_command_with_crc(command)
        response = read_response(len(command))
        if check_crc(response):
            if response[:-2] == command:
                success_count += 1

    print(f'Successful transmissions: {success_count}/{total_tests}')
    ser.close()

import paho.mqtt.client as mqtt
import struct

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    payload = b'Hello, MQTT!'
    crc = calculate_crc(payload)
    payload_with_crc = payload + struct.pack('<H', crc)
    client.publish("test/topic", payload_with_crc)

client = mqtt.Client()
client.on_connect = on_connect
client.connect("mqtt.eclipse.org", 1883, 60)
client.loop_forever()

import paho.mqtt.client as mqtt
import struct

def calculate_crc(data):
    crc = 0xFFFF
    for pos in data:
        crc ^= pos
        for _ in range(8):
            if crc & 1:
                crc >>= 1
                crc ^= 0xA001
            else:
                crc >>= 1
    return crc

def on_message(client, userdata, msg):
    payload = msg.payload
    received_crc = struct.unpack('<H', payload[-2:])[0]
    data = payload[:-2]
    calculated_crc = calculate_crc(data)
    if received_crc == calculated_crc:
        print("Received valid data:", data)
    else:
        print("Received data with invalid CRC")

client = mqtt.Client()
client.on_message = on_message
client.connect("mqtt.eclipse.org", 1883, 60)
client.subscribe("test/topic")
client.loop_forever()

#include <SoftwareSerial.h>

// กำหนดพอร์ตอนุกรม
SoftwareSerial mySerial(10, 11); // RX, TX

// ฟังก์ชันคำนวณ CRC
unsigned int calculateCRC(byte *array, int length) {
    unsigned int crc = 0xFFFF;
    for (int pos = 0; pos < length; pos++) {
        crc ^= (unsigned int)array[pos];
        for (int i = 8; i != 0; i--) {
            if ((crc & 0x0001) != 0) {
                crc >>= 1;
                crc ^= 0xA001;
            } else {
                crc >>= 1;
            }
        }
    }
    return crc;
}

// ฟังก์ชันส่งคำสั่งพร้อม CRC
void sendCommand(byte *command, int length) {
    unsigned int crc = calculateCRC(command, length);
    command[length] = crc & 0xFF;
    command[length + 1] = (crc >> 8) & 0xFF;
    mySerial.write(command, length + 2);
}

// ฟังก์ชันอ่านและตรวจสอบ CRC
bool checkCRC(byte *response, int length) {
    unsigned int receivedCRC = (response[length - 1] << 8) | response[length - 2];
    unsigned int calculatedCRC = calculateCRC(response, length - 2);
    return receivedCRC == calculatedCRC;
}

void setup() {
    Serial.begin(9600);
    mySerial.begin(9600);

    // คำสั่งตัวอย่างสำหรับ Inverter
    byte command[] = {0x01, 0x03, 0x00, 0x00, 0x00, 0x10};
    sendCommand(command, sizeof(command));

    delay(1000);
    byte response[37];
    int index = 0;

    // รับข้อมูล
    while (mySerial.available() && index < sizeof(response)) {
        response[index++] = mySerial.read();
    }

    // ตรวจสอบ CRC
    if (checkCRC(response, index)) {
        Serial.println("Received valid data:");
        for (int i = 0; i < index; i++) {
            Serial.print(response[i], HEX);
            Serial.print(" ");
        }
        Serial.println();
    } else {
        Serial.println("Received data with invalid CRC");
    }
}

void loop() {
    // ว่างเปล่า
}