first commit

2016-10-18 17:27:42 +02:00
commit b63f168fb6
49 changed files with 10135 additions and 0 deletions
@@ -0,0 +1,71 @@
+#include "cupdatethread.h"
+#include "cserie.h"
+#include "cseason.h"
+#include "cepisode.h"
+#include "cthetvdb.h"
+#include "cmessagedialog.h"
+
+#include <QDebug>
+#include <QTime>
+
+
+cUpdateThread::cUpdateThread() :
+	m_bStop(false)
+{
+}
+
+void cUpdateThread::stop()
+{
+	QMutexLocker	locker(&m_mutex);
+	m_bStop	= true;
+	emit updateAppendMessage(" - cancel pending ...");
+}
+
+void cUpdateThread::run()
+{
+	QTime	timer;
+	timer.restart();
+
+	for(int x = 0;x < m_items.count();x++)
+	{
+		cSerie*	lpSerie	= m_items.at(x)->data(0, Qt::UserRole).value<cSerie*>();
+		if(lpSerie)
+		{
+			emit updateMessage(lpSerie->seriesName(), x);
+			cTheTVDB		tvDB;
+			cSerie*			lpSerieNew;
+
+			if(lpSerie->seriesID() != -1)
+			{
+				lpSerieNew	= tvDB.load(lpSerie->id(), "de");
+
+				lpSerieNew->setDownload(lpSerie->download());
+				for(int x = 0;x < lpSerieNew->seasonList().count();x++)
+				{
+					cSeason*	lpSeasonNew	= lpSerieNew->seasonList().at(x);
+					for(int y = 0;y < lpSeasonNew->episodeList().count();y++)
+					{
+						cEpisode*	lpEpisodeNew	= lpSeasonNew->episodeList().at(y);
+						cEpisode*	lpEpisode		= lpSerie->findEpisode(lpEpisodeNew->id());
+						if(lpEpisode)
+							lpEpisodeNew->setState(lpEpisode->state());
+					}
+				}
+				lpSerie->del(m_db);
+				lpSerieNew->save(m_db);
+			}
+		}
+
+		QMutexLocker	locker(&m_mutex);
+		if(m_bStop)
+			break;
+		msleep(10);
+	}
+}
+
+void cUpdateThread::setData(cMessageDialog* lpMessageDialog, const QList<QTreeWidgetItem*>& items, const QSqlDatabase& db)
+{
+	connect(lpMessageDialog->cancelButton(), SIGNAL(clicked()), this, SLOT(stop()));
+	m_items		= items;
+	m_db		= db;
+}