#include "ToolDialog.h"
#include <QImage>
#include <QFileInfo>
#include <QFileDialog>
#include <QElapsedTimer>
#include <QGridLayout>

QEvent::Type SyncValueEvent::m_EventType = QEvent::None;

ToolDialogImpl::ToolDialogImpl(QWidget *parent)
	: DllToolDialog(parent)
{
	ui.setupUi(this);
	this->setWindowFlags(Qt::Dialog | Qt::WindowCloseButtonHint /*| Qt::WindowStaysOnTopHint*/);

	connect(this, SIGNAL(sigUpdateUI()), this, SLOT(on_UpdateUI()));

	m_nTableRowCount = 0;
	// 列数
	ui.tableWidget->setColumnCount(5);

	// 设置表头文字
	QStringList headers;
	headers
		<< ("Index")
		<< ("Name")
		<< ("DataAddr")
		<< ("Value")
		<< ("Comment");

	ui.tableWidget->setHorizontalHeaderLabels(headers);

	//设置表头字体
	QFont font = ui.tableWidget->horizontalHeader()->font();
	font.setBold(true);
	ui.tableWidget->horizontalHeader()->setFont(font);
	// 设置文字左对齐
	ui.tableWidget->horizontalHeader()->setDefaultAlignment(Qt::AlignCenter);
	// 设置为不可编辑
	ui.tableWidget->setEditTriggers(QAbstractItemView::NoEditTriggers);
	// 设置为整行选中模式
	ui.tableWidget->setSelectionBehavior(QAbstractItemView::SelectRows);
	ui.tableWidget->setSelectionMode(QAbstractItemView::SingleSelection);
	// 设置最左侧的序号不用显示
	ui.tableWidget->verticalHeader()->setVisible(false);
	//设置行高
	ui.tableWidget->verticalHeader()->setDefaultSectionSize(10);
	//点击表时不对表头行光亮（获取焦点）
	ui.tableWidget->horizontalHeader()->setHighlightSections(false);


	m_strTP = "127.0.0.1";
	ui.edit_IP->setText(m_strTP);


	m_nTimerID = 0;
	m_nTimerID = this->startTimer(1000);
	
	m_nIsCOnnect = -1;
	m_pS7Client = nullptr;
	m_pS7Client = new TS7Client();



	m_nThreadState = 1;

	// 启动线程
	m_ReadThreadPool.start(
		new _ReadThread(this)
	);
	// 启动线程
	m_WriteThreadPool.start(
		new _WriteThread(this)
	);
}


ToolDialogImpl::~ToolDialogImpl()
{
	m_nThreadState = 0;
}



/// <summary>
/// 调整大小的消息中改变表格栏的宽度
/// </summary>
/// <param name="event"></param>
void ToolDialogImpl::resizeEvent(QResizeEvent* event)
{
	Q_UNUSED(event);

	// qDebug() << "WindowAppVariableTable::resizeEvent";
	int nTotalSize = ui.tableWidget->size().width();

	ui.tableWidget->setColumnWidth(0, nTotalSize * 0.05);
	ui.tableWidget->setColumnWidth(1, nTotalSize * 0.2);
	ui.tableWidget->setColumnWidth(2, nTotalSize * 0.2);
	ui.tableWidget->setColumnWidth(3, nTotalSize * 0.2);
	ui.tableWidget->setColumnWidth(4, nTotalSize * 0.34);


	//ui.tableWidget->resize(ui.tableWidget->size());
}


VPEnum::RETURN_VALUE ToolDialogImpl::Execute()
{
	emit sigUpdateUI();
	return VPEnum::RETURN_VALUE::Success;
}


void ToolDialogImpl::Running(bool bRun)
{

}


/// <summary>
/// 
/// </summary>
/// <param name="nIndex"></param>
/// <returns></returns>
bool ToolDialogImpl::updateValue(int nIndex)
{
	return writeValueToPLC(nIndex);
}


void ToolDialogImpl::timerEvent(QTimerEvent* event)
{
	if (event->timerId() == m_nTimerID)
	{

	}


}

bool ToolDialogImpl::Serialized(QDataStream& ar, bool bIsOut)
{
	int paranum;//参数数量
	if (bIsOut)//保存参数流程
	{
		paranum = 3;
		ar << paranum;//先保存参数数量

		ar << (int)1 << m_strTP;
		ar << (int)2 << m_strPort;
		ar << (int)3 << m_nIsCOnnect;
		
		


	}
	else//加载参数流程，参数加载顺序一定要跟保存顺序一致
	{
		int nSize1 = 0;

		int para;
		ar >> paranum;//读取参数数量
		for (int i = 0; i < paranum; i++)
		{
			ar >> para;
			switch (para)
			{
			case 1:			  ar >> m_strTP;										break;
			case 2:			  ar >> m_strPort;										break;
			case 3:			  ar >> m_nIsCOnnect;										break;

			default:
			{
				qWarning() << "Serialized(In) Error";
				return false;
			}
			break;
			}
		}

		setValueToUI();
		//hwndUnit->getHWndCtrl()->useROIController(&roiController);

	}
	return true;
}


void ToolDialogImpl::on_UpdateUI()
{
	if (m_pDB != nullptr)
	{
		// 更新表格
		if (m_nTableRowCount != m_pDB->Variables.size())
		{
			m_nTableRowCount = m_pDB->Variables.size();
		
			for (int row = 0; row < m_nTableRowCount; row++)
			{
				ui.tableWidget->removeRow(0);
			}
			m_TableWidgetItems.clear();

			int i = 0;
			for (VARIABLE* var : m_pDB->Variables)
			{
				ui.tableWidget->insertRow(ui.tableWidget->rowCount());//增加一行
				ui.tableWidget->setItem(i, 0, new QTableWidgetItem(QString::number(i)));
				ui.tableWidget->setItem(i, 1, new QTableWidgetItem(var->strName));
				ui.tableWidget->setItem(i, 2, new QTableWidgetItem(var->strCommAddress));

				QTableWidgetItem* pItem = new QTableWidgetItem(var->strComment);
				m_TableWidgetItems.push_back(pItem);
				ui.tableWidget->setItem(i, 3, pItem);
				ui.tableWidget->setItem(i, 4, new QTableWidgetItem(var->strComment));
				i++;
			}
		}

		// 更新值
		const QVector<QTableWidgetItem*>& pTaskItems = m_TableWidgetItems;
		int i = 0;
		for (VARIABLE* var : m_pDB->Variables)
		{
			//pTaskItems[i]->setText(var->getValueString());

			pTaskItems[i]->setText(valueString(var));

			i++;
		}
	}
}



/// <summary>
/// 确定
/// </summary>
void ToolDialogImpl::on_btnOK_clicked()
{
	this->hide();
}


/// <summary>
/// 取消按钮
/// </summary>
void ToolDialogImpl::on_btnCancel_clicked()
{
	// 将本工具的恢复到打开工具之前的状态
	RecoverData();
}


/// <summary>
/// 测试按钮
/// </summary>
void ToolDialogImpl::on_btnExecute_clicked()
{
	QElapsedTimer toolTimer;
	toolTimer.start();
	// 发送事件
	ToolEvent* pToolEvent = new ToolEvent(m_strPouName, m_strInstanceName, TOOL_EVENT_TYPE::TOOL_TRIGGER);
	QCoreApplication::sendEvent(m_pEventTarget, pToolEvent);
	delete pToolEvent;

	// 统计返回值
	VPEnum::RETURN_VALUE ret = VPEnum::RETURN_VALUE::Success;

	double nExecTime = toolTimer.elapsed();
	QString str;
	str = QString("耗时： %1 ms").arg(nExecTime, 0, 'G', 5);
	ui.label_time->setText(str);

	str = QString("状态： %1 ").arg(QMetaEnum::fromType<VPEnum::RETURN_VALUE>().key((short)ret));
	ui.label_state->setText(str);

}



void ToolDialogImpl::on_btn_Connect_clicked()
{
	//if (m_pModbus != nullptr)
	{
		int nRet = ConnectToPLC();

		// Connect OK
		if (nRet == 0)
		{
			m_nIsCOnnect = 1;
			ui.btn_Connect->setText("ok");
		}
	}

}


/// <summary>
/// 2022-3-1 向exe中的变量表界面同步数值
/// </summary>
/// <param name="pInfs"></param>
void ToolDialogImpl::syncValuesToTableUI(QList<VARIABLE*> pInfs)
{
	SyncValueEvent* valueEvent = new SyncValueEvent();

	// 携带需要同步的多个接口
	valueEvent->setSyncValues(pInfs);

	// post数值同步消息
	QCoreApplication::postEvent((QObject*)this->m_pGvlTarget, valueEvent);
}



int ToolDialogImpl::ConnectToPLC()
{
	int m_nRock = 0;
	int m_nSlot = 1;

	if (!m_pS7Client->Connected())
	{
		return m_pS7Client->ConnectTo(m_strTP.toStdString().c_str(), m_nRock, m_nSlot);
	}
	else 
	{
		return m_pS7Client->Connected();
	}

	return   -1;
}


void ToolDialogImpl::setValueToUI()
{


	// 如果反序列化上来，发现之前是连接的状态，即开始新的链接。注：如果此时链接不成功，该值会被覆盖为未连接状态
	if (m_nIsCOnnect != -1)
	{
		ConnectToPLC();
	}
}


/************************************************************************/
/*
Bit = 1,	//1 位		布尔											0 到 1
Byte = 2,	//8 位		有符号字节（SIMATIC 模式仅用于 SHRB 指令）		- 128 到 + 127   8 位   无符号字节0 到 255
Word = 3,	//16 位		无符号整数										0 到 65, 535
DWord = 4,	//32 位		无符号双整数									0 到 4294967295
Int = 5,	//16 位		有符号整数										- 32768 到 + 32767
DInt =6,	//32 位		有符号双整数									-2147483648 到 +2147483647
Real = 7,	//32 位		IEEE 32 位浮点									+1.175495E-38 至 +3.402823E+38
*/
/************************************************************************/



/// <summary>
/// 
/// </summary>
/// <returns></returns>
bool ToolDialogImpl::readValueByPLC()
{
	if (m_pDB == nullptr || m_pS7Client == nullptr || m_nIsCOnnect == -1)
	{
		return false;
	}

	// 如果窗口的tab 行数与变量行数不一致，就需要添加数据行
	
	emit sigUpdateUI();
		
	
	QList<VARIABLE*> infs;
	int i = 0;
	for (VARIABLE* var : m_pDB->Variables)
	{
		if (var->accessMode == VPEnum::GVL_ACCESS_MODE::All
			|| var->accessMode == VPEnum::GVL_ACCESS_MODE::ReadOnly
			)
		{
			QString strCommAddress = var->strCommAddress;


			if (var->value.type == VALUE_TYPE::Type_Bool)
			{
			
			}

			else if (var->value.type == VALUE_TYPE::Type_Int)
			{
				int nValue = (*(int*)(var->value.Ptr));

				if (!strCommAddress.isEmpty())
				{
					// 根据DB 中的地址，去PLC 中读取对用的值
			
					short dbNumber = 0;
					VarType varType = VarType::Int;
					short address = 0;
					short bitNumber = 0;
					PLCAddressParse(strCommAddress, &dbNumber, &varType, &address, &bitNumber);

					int nReadVar = 0;
					int strte = ReadIntVal(dbNumber, address, &nReadVar);
					if (strte == 0)
					{
						// 如果发现读上来的值与实际DB 中值不一致，就需要修改DB的值，并更新 DB的UI
						if (nReadVar != nValue)
						{
							(*(int*)(var->value.Ptr)) = nReadVar;
							infs.push_back(var);// 储存要刷新的变量列表
						}
					}
				}
			}

			else if (var->value.type == VALUE_TYPE::Type_Float)
			{
				float fValue = (*(float*)(var->value.Ptr));

				if (!strCommAddress.isEmpty())
				{
					// 根据DB 中的地址，去PLC 中读取对用的值
					short dbNumber = 0;
					VarType varType = VarType::Int;
					short address = 0;
					short bitNumber = 0;
					PLCAddressParse(strCommAddress, &dbNumber, &varType, &address, &bitNumber);


					float fReadVar = 0.0;
					int strte = ReadFloatVal(dbNumber, address , &fReadVar);
					if (strte == 0)
					{
						// 如果发现读上来的值与实际DB 中值不一致，就需要修改DB的值，并更新 DB的UI
						if ((fabs(fReadVar - fValue)) > 0.0001)
						{
							(*(float*)(var->value.Ptr)) = fReadVar;
							infs.push_back(var);// 储存要刷新的变量列表
						}
					}
				}
			}

			else if (var->value.type == VALUE_TYPE::Type_Double)
			{
				double fValue = (*(double*)(var->value.Ptr));

				if (!strCommAddress.isEmpty())
				{
					// 根据DB 中的地址，去PLC 中读取对用的值
					short dbNumber = 0;
					VarType varType = VarType::Int;
					short address = 0;
					short bitNumber = 0;
					PLCAddressParse(strCommAddress, &dbNumber, &varType, &address, &bitNumber);

					double fReadVar = 0.0;
					int strte = ReadRealVal(dbNumber, address, &fReadVar);
					if (strte == 0)
					{
						// 如果发现读上来的值与实际DB 中值不一致，就需要修改DB的值，并更新 DB的UI

						if (fabs(fReadVar - fValue) > 0.0001)
						{
							(*(double*)(var->value.Ptr)) = fReadVar;
							infs.push_back(var);// 储存要刷新的变量列表
						}
					}
				}
			}

		}

		i++;
	}


	if (infs.size() > 0)
	{
		// 发送变更通知
		this->syncValuesToTableUI(infs);
	}
	return true;
}


/// <summary>
/// 
/// </summary>
/// <param name="nIndex"></param>
/// <returns></returns>
bool ToolDialogImpl::writeValueToPLC(int nIndex)
{
	
	if (m_pDB != nullptr)
	{
		if (nIndex == -1)
		{
			QList<VARIABLE*> infs;

			for (VARIABLE* var : m_pDB->Variables)
			{
				
				if (m_strTemps[var->nIndex] != valueString(var))
				{
					writeValue(var);

					m_strTemps[var->nIndex] = valueString(var);

					infs.push_back(var);
				}

			}
			if (infs.size() > 0)
			{
				// 发送变更通知
				this->syncValuesToTableUI(infs);
			}
		}
		else
		{
			VARIABLE* var = m_pDB->Variables[nIndex];
			writeValue(var);
		}
	
	}
	return true;
}


bool ToolDialogImpl::writeValue(VARIABLE* var)
{
	if (var != nullptr)
	{
		if (var->accessMode == VPEnum::GVL_ACCESS_MODE::All
			|| var->accessMode == VPEnum::GVL_ACCESS_MODE::WriteOnly
			)
		{
			//qDebug() << "Variable:" << var->strName << "[" << var->getValueString() << "]";
			QString strCommAddress = var->strCommAddress;

			// bool
			if (var->value.type == VALUE_TYPE::Type_Bool)
			{

			}

			// int
			else if (var->value.type == VALUE_TYPE::Type_Int)
			{
				if (!strCommAddress.isEmpty())
				{
					short dbNumber = 0;
					VarType varType = VarType::Int;
					short address = 0;
					short bitNumber = 0;
					PLCAddressParse(strCommAddress, &dbNumber, &varType, &address, &bitNumber);

					int nValue = valueString(var).toInt();
					int strte = WriteIntVal(dbNumber, address, nValue);
					if (strte == 0)
					{

					}
				}
			}

			// float
			else if (var->value.type == VALUE_TYPE::Type_Float)
			{
				if (!strCommAddress.isEmpty())
				{
					short dbNumber = 0;
					VarType varType = VarType::Int;
					short address = 0;
					short bitNumber = 0;
					PLCAddressParse(strCommAddress, &dbNumber, &varType, &address, &bitNumber);

					float fVilue = valueString(var).toFloat();

					int strte = WriteFloatVal(dbNumber, address, fVilue);
					if (strte == 0)
					{

					}
				}
			}

			// dobule
			else if (var->value.type == VALUE_TYPE::Type_Double)
			{
				if (!strCommAddress.isEmpty())
				{
					short dbNumber = 0;
					VarType varType = VarType::Int;
					short address = 0;
					short bitNumber = 0;
					PLCAddressParse(strCommAddress, &dbNumber, &varType, &address, &bitNumber);

					double fVilue = valueString(var).toFloat();

					int strte = WriteRealVal(dbNumber, address, fVilue);
					if (strte == 0)
					{

					}
				}
			}


			// string
			else if (var->value.type == VALUE_TYPE::Type_String)
			{
				if (!strCommAddress.isEmpty())
				{

				}
			}
		}

		
	}



	return  false;
}


//---将输入的PLC绝对地址分解为enumeration对应的数据类型
int ToolDialogImpl::PLCAddressParse(QString inputAddress, short* dbNumber, VarType* varType, short* address, short* bitNumber)
{

	QStringList strlist = inputAddress.split(".", QString::SkipEmptyParts);

	if (inputAddress.leftJustified(2, '.', true) == "DB")
	{
		*dbNumber = (((QString)strlist[0]).mid(2, 5)).toInt();
		*address = (((QString)strlist[1]).mid(2, 5)).toInt();

		QString str = ((QString)(strlist[1])).leftJustified(2, '.', true);

		if (str == "MB")
		{
			*varType = VarType::Byte;
			return 0;
		}
		else if (str == "MW")
		{
			*varType = VarType::Word;
			return 0;
		}
		else if (str == "MD")
		{
			*varType = VarType::DWord;
			return 0;
		}
		else if (str == "MX")
		{
			*bitNumber = ((QString)strlist[2]).toInt();
			if (*bitNumber > 7) 
			{
				return 0;
			}
			*varType = VarType::Bit;
			return 0;
		}
	}

	if (inputAddress.leftJustified(2, '.', true) == "MB")
	{
		*dbNumber = 0;
		*address = (((QString)strlist[0]).mid(2, 5)).toInt();
		*varType = VarType::Byte;
		return 0;
	}

	if (inputAddress.leftJustified(2, '.', true) == "MW")
	{
		*dbNumber = 0;
		*address = (((QString)strlist[0]).mid(2, 5)).toInt();
		*varType = VarType::Word;
		return 0;
	}

	if (inputAddress.leftJustified(2, '.', true) == "MD")
	{
		*dbNumber = 0;
		*address = (((QString)strlist[0]).mid(2, 5)).toInt();
		*varType = VarType::DWord;
		return 0;
	}
	return -1;
}


int ToolDialogImpl::WriteBoolVal(int dbNum, int offset, bool bVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		int res = m_pS7Client->DBWrite(dbNum, offset, 1, &bVal);	
		return res;
	}
	return  -1;
}


int ToolDialogImpl::WriteIntVal(int dbNum, int offset, int nVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[2] = { 0 };
		short nSpeed = (short)nVal;

		byData[0] = (qint8)(nSpeed >> 8 & 0xFF);
		byData[1] = (qint8)(nSpeed & 0xFF);

		int res = m_pS7Client->DBWrite(dbNum, offset, 2, &byData);
		return res;
	}
	return  -1;
}

int ToolDialogImpl::WriteFloatVal(int dbNum, int offset, float fVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[4] = { 0 };
		uint fSpeed = fVal;


		byData[0] = (qint8)((fSpeed >> 24) & 0xFF);
		byData[1] = (qint8)((fSpeed >> 16) & 0xFF);
		byData[2] = (qint8)((fSpeed >> 8) & 0xFF);
		byData[3] = (qint8)((fSpeed) & 0xFF);

		int res = m_pS7Client->DBWrite(dbNum, offset, 4, &byData);
		return res;
	}
	return  -1;
}


int ToolDialogImpl::WriteRealVal(int dbNum, int offset, double fVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[4] = { 0 };
		float fSpeed = fVal;

		byData[3] = *((byte*)&fSpeed + 0);
		byData[2] = *((byte*)&fSpeed + 1);
		byData[1] = *((byte*)&fSpeed + 2);
		byData[0] = *((byte*)&fSpeed + 3);

		int res = m_pS7Client->DBWrite(dbNum, offset, 4, &byData);
		return res;
	}
	return  -1;
}


int ToolDialogImpl::ReadBoolVal(int dbNum, int offset, bool* bVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[1] = { 0 };
		int res = m_pS7Client->DBRead(dbNum, offset, 1, &byData);

		*bVal = (bool)byData[0];
		return res;
	}
	return  -1;
}


int ToolDialogImpl::ReadIntVal(int dbNum, int offset, int* nVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[2] = { 0 };
		int res = m_pS7Client->DBRead(dbNum, offset, 2, &byData);

		*nVal = (int)((int)byData[1] | (int)byData[0] << 8);

		return res;
	}
	return  -1;
}


int ToolDialogImpl::ReadFloatVal(int dbNum, int offset, float* fVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[4] = { 0 };
		int res = m_pS7Client->DBRead(dbNum, offset, 4, &byData);
		if (res ==0)
		{
			float l_fSpeed1 = { 0 };

			*((byte*)&l_fSpeed1 + 0) = byData[3];
			*((byte*)&l_fSpeed1 + 1) = byData[2];
			*((byte*)&l_fSpeed1 + 2) = byData[1];
			*((byte*)&l_fSpeed1 + 3) = byData[0];

			

			*fVal = (float)((int)byData[0] << 24 | (int)byData[1] << 16 | (int)byData[2] << 8 | (int)byData[3]);
		}
		return res;
	}
	return  -1;
}


int ToolDialogImpl::ReadRealVal(int dbNum, int offset, double* fVal)
{
	QMutexLocker locker(&mutex);
	if (m_pS7Client->Connected())
	{
		byte byData[4] = { 0 };
		int res = m_pS7Client->DBRead(dbNum, offset, 4, &byData);
		if (res == 0)
		{
			unsigned long longdata = 0;
			longdata = (float)((int)byData[0] << 24 | (int)byData[1] << 16 | (int)byData[2] << 8 | (int)byData[3]);
			float float_data = *(float*)&longdata;
			*fVal = (double)float_data;
		}

		return res;
	}
	return  -1;
}


/// <summary>
/// 2022-10-30 增加了一个用于获取VARIABLE类型的值字符串的函数
/// </summary>
/// <returns></returns>
QString ToolDialogImpl::valueString(VARIABLE* var)
{
	if (var->value.Ptr != nullptr)
	{
		return Utility::getValueString(var->value.Ptr, var->value.type);
	}
	else
	{
		return QString("");
	}
}



//============================================================
//
//					Save 线程
//
//============================================================

/// <summary>
/// 线程函数
/// </summary>
void _ReadThread::run()
{
	// 调用函数执行任务
	while (m_pDialog->m_nThreadState)
	{
		m_pDialog->readValueByPLC();
		QThread::msleep(50);
	}
	return;
}

/// <summary>
/// 线程函数Variable:
/// </summary>
void _WriteThread::run()
{
	// 调用函数执行任务
	while (m_pDialog->m_nThreadState)
	{
		m_pDialog->writeValueToPLC();
		QThread::msleep(1);
	}
	return;
}