#ifndef COUNTDATA_H
#define COUNTDATA_H

#include <QObject>
#include "databasesql.h"
#include "QSqlQuery"
#pragma execution_character_set("utf-8")
class CountData : public QObject
{
	Q_OBJECT

public:
	CountData(QObject *parent = 0){ m_pDb = NULL; };
	~CountData(){};
	void setDB(class DataBaseSql *pDb){ m_pDb = pDb; };
public slots:
	void doWork(QVariantMap m_Map) {
		QMap<QString, int> *m_counter=new QMap<QString, int>();
		QVariantMap m_proMap;
		m_proMap.insert("Type", "start");
		emit sgShowProgress(m_proMap);

		QString result;
		QSqlQuery sqlCount;
		QSqlQuery sql;
		/* ... here is the expensive or blocking operation ... */

		QString strSql_Count = m_Map.value("SqlCount").toString();
		QString strSql_Check = m_Map.value("SqlCheck").toString();
		
		if (m_pDb){
			//m_counter->clear();
			m_proMap.insert("msg", "正在获取数量...");
			emit sgShowProgress(m_proMap);
			m_pDb->checkoutData(strSql_Count, sqlCount);
			//emit sgShowMsg("正在查询数据");
			int sum = 0;
			int m_size = 0;
			while (sqlCount.next())
			{
				m_size = sqlCount.value(0).toInt();
			}

			QString strname = QString("select model,count(model) from (%1) GROUP BY model ;").arg(strSql_Check);
			m_pDb->checkoutData(strname, sql);
			//m_pDb->checkoutData(strSql_Check, sql);
			//emit sgShowMsg("正在统计中");

			m_proMap.remove("msg");
			m_proMap.insert("msg", QString("共%1条记录，正在分类核算数据，请稍后").arg(m_size));
			emit sgShowProgress(m_proMap);
			
			while (sql.next())
			{
				/*这里下面是统计查询到的通道对应的产品总数*/
				
				QString model = sql.value(0).toString();
				int nValue = sql.value(1).toInt();
				if (m_counter->contains(model))
				{
					(*m_counter)[model]++;
				}
				else
				{
					m_counter->insert(model, nValue);
				}
			}
			result = QString("%1").arg(m_size);
			emit sgShowMsg("统计完成");
		}
		m_proMap.remove("Type");
		m_proMap.insert("Type", "stop");
		emit sgShowProgress(m_proMap);
		emit resultReady(result, m_counter);
	}
signals:
	void resultReady(const QString &result, const QMap<QString, int> *p);
	void sgShowMsg(QString str);
	void sgShowProgress(QVariantMap m_map);
private:
	class DataBaseSql *m_pDb;
};

#endif // COUNTDATA_H