#include "HandleMessage.h"
#include "../shared/util.h"

HandleMessage::HandleMessage(QObject *parent) : QObject(parent) { }

// void HandleMessage::ParseToSQL(QString input) {
// 	QSqlQuery queryInsertData;
// 	QString output = "insert into WSdb.tblMain (temperature, humidity, pressure) values ";
// 	QStringList data;
// 
// 	output.append("(");
// 	data=input.split(",");
// 
// 	for (int i = 1; i < data.size(); i++) {
// 		bool valid;
// 		output.append(QString::number(data[i].toInt(&valid, 16)));
// 		if (i + 1 < data.size()) output.append(",");
// 	}
// 
// 	output.append(")");
// }

void HandleMessage::ParseToSQL(QString input) {
	QSqlQuery queryInsertData;
	QString output = "INSERT INTO `tblMain` (`temperature`, `humidity`, `pressure`) VALUES ";
	QStringList data;
	QStringList list = input.split("\n");
	for (int i = 0; i < list.size(); ++i) {
		if (list[i].size() == 0) continue;
		data=list[i].split(",");
		bool valid;

		output.append("(");
		output.append(QString::number(ws_sensor_tmp_to_f(data[1].toInt(&valid, 16))));
		output.append(",");
		output.append(QString::number(ws_sensor_hum_to_f(data[2].toInt(&valid, 16))));
		output.append(",");
		output.append(QString::number(ws_sensor_atm_to_f(data[3].toInt(&valid, 16))));
		output.append(")");

		if (i+1 < list.size()) output.append(",");
	}
	printf("%s\n", output.toStdString().c_str());
	queryInsertData.exec(output);
}