cimforreduceloss/cimparser/cimparserbatch.cpp

#include "cimparserbatch.h"
#include "derivedqthread.h"
#include <QtDebug>
int callmain(char *arg);
CIMParserBatch::CIMParserBatch()
{
}

void CIMParserBatch::parser(const QString& dir, const QString &scadaDataFilePath)
{
	QDir qdir(dir);
	QStringList filter;
	filter<<"*";
	this->mdirList=qdir.entryInfoList(filter,QDir::NoDotAndDotDot | QDir::AllDirs);
    this->mite=this->mdirList.constBegin();//后面会用到，就是dir文件下的所有文件
	this->ReadscadaData(scadaDataFilePath);
    //this->ExecuteParserApp(NULL);
	//this->GenerateBatchFile("c:/parser.bat");
    this->CallFunParser();
}

QString CIMParserBatch::FindXML(const QString& dir)
{

	QDir qdir(dir);
	QStringList filter;
	filter<<"*.xml";
	QFileInfoList xmlList;
	xmlList=qdir.entryInfoList(filter);
	if(xmlList.size()>1)
	{
		std::cout<<dir.toStdString()<<"has more than one xml file."<<std::endl;
		return "";
	}
	if(xmlList.size()==0)
	{
		std::cout<<"could not find any xml in "<<dir.toStdString()<<std::endl;
		return "";
	}
	return xmlList.at(0).absoluteFilePath();
}

void CIMParserBatch::ExecuteParserApp(QThread *thread)
{
	if(thread!=NULL)
	{
		thread->deleteLater();
		//先把上一次解析得到的文件拷回去
		QFileInfoList fileList=this->FindiPsoPrefixedFile("c:/parser");
		QFileInfo info;
		info=*(this->mite);//原始文件的路径
		if(fileList.size()<6)
		{

            std::cout<<info.baseName().toStdString()<<"parsed, but got fewer files."<<std::endl;
		}
		QString fileName;
		QString desFilePath;
		fileName=info.fileName();//原始文件的文件名，其实是文件夹名
		desFilePath=info.absoluteFilePath();
		desFilePath.replace('/','\\');
		QString parseFileName;
		QFileInfo parseFileInfo;
		QString transNoLoad;
		QString parsedFile;//计算文件
		for(QFileInfoList::const_iterator ite=fileList.constBegin();
		        ite!=fileList.constEnd();
		        ite++
		   )
		{
			parseFileInfo=*ite;
			parseFileName=parseFileInfo.fileName();

            if(parseFileName.contains("TransformerNoLoad"))
			{
                transNoLoad=desFilePath+"\\iPso_"+fileName+"_TransformerNoLoad.txt";
				QFile::remove(transNoLoad);
				QFile::copy(parseFileInfo.absoluteFilePath(),transNoLoad);
				continue;
			}
            if(parseFileName.contains("TransformerNoResistance"))
			{
				continue;
			}
            if(parseFileName.contains("TransformerInfor"))
			{
				continue;
			}
            if(parseFileName.contains("LineInfor"))
			{
				continue;
			}
            if(parseFileName.contains("lineZeroResistance"))
			{
				continue;
			}

			parsedFile=desFilePath+"\\iPso_"+fileName+".txt";
			QFile::remove(parsedFile);
			QFile::copy(parseFileInfo.absoluteFilePath(),parsedFile);//TODO:这里会多拷贝一次
			//开始安放pqi.txt文件
			QFile::remove(desFilePath+"\\pqi.txt");
			QFile pqi(desFilePath+"\\pqi.txt");
			QString lineName;
			if(pqi.open(QIODevice::WriteOnly))
			{
				lineName=fileName.section('_',0,0);

				if(this->mScada.contains(lineName))
				{
					QTextStream stream(&pqi);
					FeederData feederData=this->mScada[lineName];
					stream<<feederData.p<<" "<<feederData.q<<" "<<0<<endl;
				}
				else
				{
					std::cout<<"pqi of "<<lineName.toStdString()<<" not found."<<std::endl;
				}
				pqi.close();
			}

		}
		this->mite++;


	}
	if(this->mite==this->mdirList.constEnd())
	{
		std::cout<<"job finished."<<std::endl;
		return;
	}
	QString xmlFile;
	QString dir;//有xml文件的dir
	QFileInfo fileInfo=*(this->mite);
	dir=fileInfo.absoluteFilePath();
	xmlFile=this->FindXML(dir);
	if(xmlFile=="")
	{
		return;
	}
	QFile::remove("c:/parser/parser.xml");
	QFile::copy(xmlFile,"c:/parser/parser.xml");
	std::cout<<"prepare to parse "<<xmlFile.toStdString()<<std::endl;
	QFileInfo sizeInfo;
	DerivedQThread *_thread;
	sizeInfo=QFileInfo(xmlFile);
	_thread=new DerivedQThread("E:/lineloss/console/run.bat c:/parser/parser.xml",this);
	_thread->connect(_thread,SIGNAL(finishedptr(QThread*)),this,SLOT(ExecuteParserApp(QThread*)));
	_thread->start();


}

QFileInfoList CIMParserBatch::FindiPsoPrefixedFile(const QString& dir)
{
	QDir qdir(dir);
	QStringList filter;
	filter<<"iPso_*";
    return qdir.entryInfoList(filter);//如果找不到iPso开头的文件，返回的QFileInfoList长度为0。
}
void CIMParserBatch::ReadscadaData(const QString& dataPath)
{
	QString line;
	QStringList sep;
	QFile file(dataPath);
	if(file.open(QIODevice::ReadOnly))
	{
		QTextStream stream(&file);
		while(!stream.atEnd())
		{
			line=stream.readLine();
			line=line.simplified();
			line.trimmed();
			sep=line.split(' ');
			if(sep.size()<3)
			{
				std::cout<<"scada file format error!"<<std::endl;
				qApp->exit();
			}
			FeederData feederData;
			feederData.p=sep.at(1).toDouble();
			feederData.q=sep.at(2).toDouble();
			this->mScada.insert(sep.at(0),feederData);

		}
		file.close();
	}
	else
	{
		std::cout<<"scada File not open. This file may not exist."<<std::endl;
	}
}

void CIMParserBatch::GenerateBatchFile(const QString& batFilePath)
{
	QFile bat(batFilePath);
	QString fullFilePath;
	QFileInfo info;
	QString xmlFile;
	if(bat.open(QIODevice::WriteOnly))
	{
		QTextStream stream(&bat);
		while(this->mite!=this->mdirList.constEnd())
		{
			info=*(this->mite);
			fullFilePath=info.absoluteFilePath();
			xmlFile=this->FindXML(fullFilePath);
			//stream<<"call ";
			stream<<"E:/lineloss/console/readxml1.exe ";
			stream<<xmlFile<<"\n\r";
			this->mite++;
		}
		bat.close();
	}
	std::cout<<"job finished."<<std::endl;
}

void CIMParserBatch::CallFunParser()
{
	while(this->mite!=this->mdirList.constEnd())
	{

		QString xmlFile;
		QString dir;//有xml文件的dir
		QFileInfo fileInfo=*(this->mite);
		dir=fileInfo.absoluteFilePath();
		xmlFile=this->FindXML(dir);
		if(xmlFile=="")
		{
			return;
		}
		//QFile::remove("c:/parser/parser.xml");
		//QFile::copy(xmlFile,"c:/parser/parser.xml");
        std::cout<<"prepare to parse "<<xmlFile.toLocal8Bit().data()<<std::endl;
        //qDebug()<<xmlFile<<"\n";
        callmain(const_cast<char *>(xmlFile.toStdString().c_str()));
		//先把上一次解析得到的文件拷回去
		//QFileInfoList fileList=this->FindiPsoPrefixedFile("c:/parser");
		QFileInfo info(xmlFile);
//	info=*(this->mite);//原始文件的路径
//	if(fileList.size()<6)
//	{

//		std::cout<<info.baseName().toStdString()<<"parserd, but got fewer files."<<std::endl;
//	}
//	QString fileName;
		QString desFilePath;
        desFilePath=info.absolutePath();
//	fileName=info.fileName();//原始文件的文件名，其实是文件夹名
//	desFilePath=info.absoluteFilePath();
		desFilePath.replace('/','\\');
//	QString parseFileName;
//	QFileInfo parseFileInfo;
//	QString transNoLoad;
//	QString parsedFile;//计算文件
//	for(QFileInfoList::const_iterator ite=fileList.constBegin();
//	        ite!=fileList.constEnd();
//	        ite++
//	   )
//	{
//		parseFileInfo=*ite;
//		parseFileName=parseFileInfo.fileName();

//		if(parseFileName.contains("变压器无负载"))
//		{
//			transNoLoad=desFilePath+"\\iPso_"+fileName+"_变压器无负载.txt";
//			QFile::remove(transNoLoad);
//			QFile::copy(parseFileInfo.absoluteFilePath(),transNoLoad);
//			continue;
//		}
//		if(parseFileName.contains("变压器无阻抗"))
//		{
//			continue;
//		}
//		if(parseFileName.contains("变压器信息"))
//		{
//			continue;
//		}
//		if(parseFileName.contains("线路信息"))
//		{
//			continue;
//		}
//		if(parseFileName.contains("线路零阻抗"))
//		{
//			continue;
//		}

//		parsedFile=desFilePath+"\\iPso_"+fileName+".txt";
//		QFile::remove(parsedFile);
//		QFile::copy(parseFileInfo.absoluteFilePath(),parsedFile);//TODO:这里会多拷贝一次
		//开始安放pqi.txt文件
		QFile::remove(desFilePath+"\\pqi.txt");
		QFile pqi(desFilePath+"\\pqi.txt");
		QString lineName;
        lineName=info.fileName();
		if(pqi.open(QIODevice::WriteOnly))
		{
            lineName=lineName.section('_',0,0);

			if(this->mScada.contains(lineName))
			{
				QTextStream stream(&pqi);
				FeederData feederData=this->mScada[lineName];
				stream<<feederData.p<<" "<<feederData.q<<" "<<0<<endl;
			}
			else
			{
				std::cout<<"pqi of "<<lineName.toStdString()<<" not found."<<std::endl;
			}
			pqi.close();
		}
        this->mite++;
	}


	std::cout<<"job finished."<<std::endl;
}