#include "UART.h"
#include "Json.h"
#include <QFile>

UART::UART(QObject *parent) : QObject(parent),uart(this),socket(this)
{
 rmtPort=0;
}

void UART::init()
{
 QFile file("/link/config/uart.json");
 file.open(QFile::ReadOnly);
 QString json=file.readAll();
 file.close();
 update(json);

 connect(&uart,SIGNAL(readyRead()),this,SLOT(onReadUart()));
 connect(&socket,SIGNAL(readyRead()),this,SLOT(onReadUDP()));
}

bool UART::update(QString json)
{
 QVariantMap cfg=Json::decode(json).toMap();

 if(cfg["device"].toString()!=uart.portName() || cfg["baudRate"].toInt()!=uart.baudRate())
 {
 if(uart.isOpen())
 uart.close();
 uart.setPortName(cfg["device"].toString());
 if(uart.open(QIODevice::ReadWrite))
 {
 uart.setBaudRate(cfg["baudRate"].toInt());
 uart.setDataBits(QSerialPort::Data8);
 uart.setParity(QSerialPort::NoParity);
 uart.setFlowControl(QSerialPort::NoFlowControl);
 uart.setStopBits(QSerialPort::OneStop);

 }
 else
 {
 qDebug()<<"can not open uart "<<uart.portName();
 }
 }

 if(cfg["port"].toInt()!=socket.localPort())
 {
 socket.close();
 socket.bind(cfg["port"].toInt());
 }

 if(cfg.contains("ip"))
 {
 rmtIp.setAddress(cfg["ip"].toString());
 rmtPort=cfg["port"].toInt();
 }


 Json::saveFile(cfg,"/link/config/uart.json");

 return true;
}

void UART::onReadUart()
{
 while(uart.bytesAvailable()>0)
 {
 QByteArray ba=uart.readAll();
 if(rmtPort!=0)
 socket.writeDatagram(ba,rmtIp,rmtPort);
 }
}

void UART::onReadUDP()
{
 while(socket.hasPendingDatagrams())
 {
 QByteArray ba;
 ba.resize(socket.pendingDatagramSize());

 socket.readDatagram(ba.data(),ba.size(),&rmtIp,&rmtPort);

 qDebug()<<ba;
 if(uart.isOpen())
 uart.write(ba);
 }
}