network.cpp 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319
  1. #include "app.h"
  2. #include "filesystem.h"
  3. #include <QtNetwork/QNetworkAccessManager>
  4. #include <QUrl>
  5. #include <QUrlQuery>
  6. #include <QNetworkRequest>
  7. #include <QNetworkReply>
  8. #include <QObject>
  9. #include <QEventLoop>
  10. #include <QDir>
  11. #include <QMap>
  12. ANetwork::ANetwork() {
  13. }
  14. ANetwork::ANetwork(const ANetwork&) {
  15. throw QException(); // Выкидываем QException, в случае если
  16. // вообще попытались скопировать объект
  17. }
  18. ANetwork& ANetwork::operator=(ANetwork&) {
  19. throw QException(); // Выкидываем QException, в случае если
  20. // вообще попытались скопировать объект
  21. }
  22. QString ANetwork::query(QUrl url){
  23. App *app = &App::getInstance();
  24. QNetworkAccessManager* manager = new QNetworkAccessManager(app->window);
  25. QNetworkRequest request(url);
  26. QNetworkReply* reply = manager->get(request);
  27. QEventLoop loop;
  28. QObject::connect(reply, SIGNAL(finished()), &loop, SLOT(quit()));
  29. loop.exec();
  30. QString content = reply->readAll();
  31. if (reply->error() != QNetworkReply::NoError){
  32. content = "error";
  33. // пишем в лог
  34. qDebug() << reply->errorString();
  35. }
  36. reply->deleteLater();
  37. return content;
  38. }
  39. QByteArray ANetwork::query_binary(QUrl url){
  40. App *app = &App::getInstance();
  41. QNetworkAccessManager* manager = new QNetworkAccessManager(app->window);
  42. QNetworkRequest request(url);
  43. QNetworkReply* reply = manager->get(request);
  44. QEventLoop loop;
  45. QObject::connect(reply, SIGNAL(finished()), &loop, SLOT(quit()));
  46. loop.exec();
  47. QByteArray bytes = reply->readAll();
  48. return bytes;
  49. }
  50. QString ANetwork::getCoupon(){
  51. App *app = &App::getInstance();
  52. app->logSectionStart("Код купона");
  53. QString content = this->query(app->config->getValue("Network", "coupon") + ".txt");
  54. if (content != "error"){
  55. app->config->setValue("Values", "coupon", content);
  56. qInfo("%s:%i: %s%s", __FILE__, __LINE__, "Ответ сервера: ", app->helper->stringToChar(content));
  57. qInfo("%s:%i: %s", __FILE__, __LINE__, "Данные получены. Производим установку значений.");
  58. } else {
  59. qWarning("%s:%i: %s", __FILE__, __LINE__, "Не удалось получить информацию с сервера");
  60. content = app->config->getValue("Values", "coupon");
  61. }
  62. app->window->ui->couponButton->setText(content);
  63. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выполнено.");
  64. app->logSectionEnd();
  65. return content;
  66. }
  67. QString ANetwork::getFootMessage(){
  68. App *app = &App::getInstance();
  69. app->logSectionStart("Информация о профилактике");
  70. // app->window->ui->footRed->setText("Профилактика. Все сервера отключены. Примерное время окончания работ - 40:00 (МСК).");
  71. QString content = this->query(app->config->getValue("Network", "foot") + ".txt");
  72. if (content != "error"){
  73. qInfo("%s:%i: %s", __FILE__, __LINE__, "Данные получены");
  74. app->config->setValue("Values", "foot", content);
  75. qInfo("%s:%i: %s%s", __FILE__, __LINE__, "Ответ сервера: ", app->helper->stringToChar(content));
  76. } else {
  77. qWarning("%s:%i: %s", __FILE__, __LINE__, "Не удалось получить информацию с сервера");
  78. content = app->config->getValue("Values", "foot");
  79. app->logSectionEnd();
  80. return content;
  81. }
  82. if(content != ""){
  83. qInfo("%s:%i: %s", __FILE__, __LINE__, "Есть сообщения о профилактике. Производим разбор и установку значений");
  84. QStringList list = content.split(":::");
  85. //QStringList date = list[2].split(" ");
  86. QString day = list[2];
  87. QString month = " " + list[3];
  88. app->window->ui->footYellow->show();
  89. app->window->ui->footYellow->setText("Профилактика игровых серверов состоится " + day + month + " с " + list[0] +" до " + list[1] + " (МСК).");
  90. } else {
  91. qInfo("%s:%i: %s", __FILE__, __LINE__, "Сообщения о профилактике отсутствуют.");
  92. }
  93. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выполнено.");
  94. app->logSectionEnd();
  95. return content;
  96. }
  97. QString ANetwork::getServers(){
  98. App *app = &App::getInstance();
  99. QString time = "";
  100. app->logSectionStart("Статусы серверов");
  101. QString content = this->query(app->config->getValue("Network", "servers") + ".txt");
  102. if (content != "error"){
  103. qInfo("%s:%i: %s%s", __FILE__, __LINE__, "Ответ сервера: ", app->helper->stringToChar(content));
  104. qInfo("%s:%i: %s", __FILE__, __LINE__, "Данные получены. Производим установку значений.");
  105. app->config->setValue("Values", "servers", content);
  106. qDebug() << content;
  107. } else {
  108. qWarning("%s:%i: %s", __FILE__, __LINE__, "Не удалось получить информацию с сервера.");
  109. content = app->config->getValue("Values", "servers");
  110. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выполнено.");
  111. app->logSectionEnd();
  112. return content;
  113. }
  114. if(content == "profilaktika"){
  115. qInfo("%s:%i: %s", __FILE__, __LINE__, "По данным сервера в данный момент идут техработы.");
  116. foreach(QObject * obj, app->window->ui->serversbox->children()){
  117. if (obj != nullptr && obj->objectName() != ""){
  118. QLabel * label = dynamic_cast<QLabel*>(obj);
  119. label->setStyleSheet("QLabel{ background-color:#8A0808; }");
  120. }
  121. }
  122. qInfo("%s:%i: %s", __FILE__, __LINE__, "Парсим данные о профилактике.");
  123. content = app->config->getValue("Values", "foot");
  124. if(content != ""){
  125. QStringList list = content.split(":::");
  126. time = "Примерное время окончания работ - " + list[1] + " (МСК)";
  127. }
  128. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выводим сообщение о профилактике.");
  129. app->window->ui->footRed->show();
  130. app->window->ui->footRed->setText("Профилактика. Все сервера отключены. " + time);
  131. if(app->window->ui->footYellow->text() != "") app->window->ui->footYellow->setText("");
  132. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выполнено.");
  133. app->logSectionEnd();
  134. return content;
  135. }
  136. qInfo("%s:%i: %s", __FILE__, __LINE__, "Раскрашиваем индикаторы серверов.");
  137. QStringList data = content.split("|||");
  138. foreach(QString item, data){
  139. QStringList server = item.split(":::");
  140. QString color = server[1] == "on" ? "#173B0B" : "#8A0808";
  141. QLabel* obj = app->window->ui->serversbox->findChild<QLabel*>(server[0]);
  142. if (obj != nullptr){
  143. obj->setStyleSheet("QLabel{ background-color:" + color + "; }");
  144. }
  145. }
  146. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выполнено.");
  147. app->logSectionEnd();
  148. return content;
  149. }
  150. void ANetwork::getPaths(){
  151. App *app = &App::getInstance();
  152. QUrlQuery query;
  153. QStringList names;
  154. QString version;
  155. qInfo("%s:%i: %s", __FILE__, __LINE__, "Начинаем проверку актуальности патчей.");
  156. names << "sound" << "text" << "image" << "video" << "screen" << "texture" << "font";
  157. QUrl url(app->config->getValue("Network", "releases"));
  158. QString datafolder = QApplication::applicationDirPath() + "/data";
  159. QDir dir(datafolder);
  160. if(!dir.exists()) QDir().mkdir(datafolder);
  161. foreach(QString s, names){
  162. if(app->config->getValue("Editor", s + "s") == "true"){
  163. if(s == "screen") s = "loadscreen";// поправка для заставок
  164. QStringList paths = dir.entryList(QStringList(s + "*"));
  165. if(!paths.empty()) {
  166. version = QString::number(app->helper->getVersion(paths.first()));
  167. QString hash = FileSystem::fileHash(datafolder + "/" + paths.first(), QCryptographicHash::Md5);
  168. if(hash != app->config->getValue("Hashes", s + "s")){
  169. qDebug("%s:%i: %s%s", __FILE__, __LINE__, "Эталон хэша отсутствует (удаляю файл): ", app->helper->stringToChar(paths.first()));
  170. QFile base(datafolder + "/" + paths.first());
  171. base.remove();
  172. version="100";
  173. }
  174. QString dateline = app->config->getValue("Datetime", s + "s");
  175. if(dateline != "-1"){
  176. qDebug("%s:%i: %s", __FILE__, __LINE__, "Проставляем даты патчей.");
  177. QLabel* obj = app->window->ui->mainbox->findChild<QLabel*>(s + "sStatus");
  178. if (obj != nullptr){
  179. QStringList date = dateline.split(" ");
  180. obj->setText(date[0]);
  181. }
  182. }
  183. } else {
  184. qDebug("%s:%i: %s%s", __FILE__, __LINE__, "Патч отсутствует: ", app->helper->stringToChar(s));
  185. version = "100";
  186. QLabel* obj = app->window->ui->mainbox->findChild<QLabel*>(s + "sStatus");
  187. if (obj != nullptr) {
  188. obj->setText("Оригинал");
  189. }
  190. }
  191. query.addQueryItem(s, version);
  192. }
  193. }
  194. url.setQuery(query.query());
  195. qDebug("%s:%i: %s%s", __FILE__, __LINE__, "Запрашиваем информацию о патчах: ", app->helper->stringToChar(url.fileName()));
  196. QString content = this->query(url);
  197. if(content == "error"){
  198. qInfo("%s:%i: %s", __FILE__, __LINE__, "Отсутствует связь с сервером. Прервано.");
  199. app->logSectionEnd();
  200. return;
  201. }
  202. qDebug() << content;
  203. if(content == "") {
  204. qInfo("%s:%i: %s", __FILE__, __LINE__, "Все версии патчей соответствуют актуальным.");
  205. app->helper->setState("busy");
  206. app->helper->applyGlobal();
  207. app->helper->setState("free");
  208. return;
  209. }
  210. qInfo("%s:%i: %s", __FILE__, __LINE__, "Составляем список загрузок.");
  211. QStringList downloads = content.split( "|" );
  212. foreach (QString item, downloads){
  213. QStringList values = item.split( ":::" );
  214. QStringList pathline = values[0].split( "_" );
  215. pathline = pathline[0].split( "/" );
  216. QUrl url = app->config->getValue("Network", "server") + values[0];
  217. app->config->setValue("Hashes", pathline[3], values[1]);
  218. app->config->setValue("Datetime", pathline[3], values[2]);
  219. // Удаляем устаревшие патчи
  220. QStringList old = dir.entryList(QStringList(pathline[3] + "*"));
  221. if(old.count() > 0){
  222. foreach(QString filename, old){
  223. QFile::remove(QApplication::applicationDirPath() + "/data/" + filename);
  224. }
  225. }
  226. // Добавляем новый файл в список закачек
  227. app->downloader->append(url);
  228. }
  229. qInfo("%s:%i: %s", __FILE__, __LINE__, "Начинаем загрузку патчей.");
  230. app->downloader->startNextDownload();
  231. }
  232. QString ANetwork::getMicroPath(int timestamp){
  233. App *app = &App::getInstance();
  234. app->logSectionStart("Загрузка последних обновлений");
  235. qInfo("%s:%i: %s", __FILE__, __LINE__, "Уточняем наличие обновлений");
  236. QString microfolder = QApplication::applicationDirPath() + "/data/micro/";
  237. QDir dir(microfolder);
  238. if(!dir.exists()) QDir().mkdir(microfolder);
  239. QString baseurl = app->config->getValue("Network", "update");
  240. QString url = baseurl + "/1/" + QString::number(timestamp);
  241. qInfo("%s:%i: %s%s", __FILE__, __LINE__, "Стартуем загрузку ", url.toStdString().c_str());
  242. QNetworkAccessManager m_NetworkMngr;
  243. QNetworkReply *reply= m_NetworkMngr.get(QNetworkRequest(url));
  244. QEventLoop loop;
  245. QObject::connect(reply, SIGNAL(finished()),&loop, SLOT(quit()));
  246. loop.exec();
  247. QUrl aUrl(url);
  248. QFileInfo fileInfo=aUrl.path();
  249. QString filename = micropatch;
  250. QFile file(filename);
  251. file.open(QIODevice::WriteOnly);
  252. file.write(reply->readAll());
  253. delete reply;
  254. qInfo("%s:%i: %s", __FILE__, __LINE__, "Загрузка микропатча завершена.");
  255. app->db->InitDatabase(app->helper->stringToChar(filename));
  256. int indb = app->db->CountRows();
  257. qInfo("%s:%i: %s%i", __FILE__, __LINE__, "Патч содержит строк: ", indb);
  258. for(int i = 0; i<=indb; i++) app->helper->processFile();
  259. qInfo("%s:%i: %s", __FILE__, __LINE__, "Выполнено.");
  260. app->config->saveAllDatFiles();
  261. app->db->CloseDatabase();
  262. app->logSectionEnd();
  263. return filename;
  264. }