FromWebAPI.cpp 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854
  1. #include "FromWebAPI.h"
  2. #include <QVector>
  3. #include <QString>
  4. #include <QUuid>
  5. #include <QApplication>
  6. #include "LHQLogAPI.h"
  7. #include "TransmitterSwitchInfo.h"
  8. FromWebAPI::FromWebAPI()
  9. {
  10. }
  11. FromWebAPI::~FromWebAPI()
  12. {
  13. if(m_httpApi != nullptr)
  14. {
  15. delete m_httpApi;
  16. m_httpApi = nullptr;
  17. }
  18. }
  19. /* 初始化WebApi */
  20. bool FromWebAPI::initWebApi(const QString& url, const QString& serverID, const QString& serverKey)
  21. {
  22. if(m_httpApi == nullptr)
  23. {
  24. m_httpApi = new lhhttpapi;
  25. }
  26. #if defined(Q_OS_WIN)
  27. #ifdef QT_DEBUG
  28. QString libFile = QString("%1/LHSqlWebInterface.dll").arg(QApplication::applicationDirPath());
  29. #else
  30. QString libFile = QString("%1/LHSqlWebInterface.dll").arg(QApplication::applicationDirPath());
  31. #endif
  32. #elif defined(Q_OS_LINUX)
  33. #ifdef QT_DEBUG
  34. QString libFile = QString("%1/libLHSqlWebInterface.so").arg(QApplication::applicationDirPath());
  35. #else
  36. QString libFile = QString("%1/libLHSqlWebInterface.so").arg(QApplication::applicationDirPath());
  37. #endif
  38. #endif
  39. if(!m_httpApi->Load(libFile))
  40. {
  41. LH_WRITE_ERROR("Load WebAPI failed");
  42. return false;
  43. }
  44. LH_WRITE_LOG_DEBUG(QString("URL:%1").arg(url));
  45. LH_WRITE_LOG_DEBUG(QString("ServerID:%1").arg(serverID));
  46. LH_WRITE_LOG_DEBUG(QString("ServerKey:%1").arg(serverKey));
  47. auto pHttp = m_httpApi->DBInit(url.toStdString().c_str());
  48. int ret = 0;
  49. #ifdef QT_DEBUG
  50. /* 获取服务器列表 */
  51. char serverList[8192];
  52. ret = m_httpApi->DBGetServerList(serverList, 8192);
  53. if(ret < 0)
  54. {
  55. LH_WRITE_ERROR(QString("Get server list failed:%1, error info:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  56. return false;
  57. }
  58. // LH_WRITE_LOG(QString("\nGet server list success:%1").arg(serverList));
  59. #endif
  60. /* 登录,第二个参数是限制的服务 */
  61. ret = m_httpApi->DBLogin("", serverID, serverKey, m_userToken, true, pHttp);
  62. if(ret < 0)
  63. {
  64. LH_WRITE_ERROR(QString("Login failed:%1, error info:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  65. return false;
  66. }
  67. LH_WRITE_LOG("Login success!");
  68. return true;
  69. }
  70. /* 获取设备信息 */
  71. bool FromWebAPI::getDeviceInfo(QMap<QString, DeviceInfo>& mapDevice)
  72. {
  73. if(m_httpApi == nullptr)
  74. {
  75. LH_WRITE_ERROR("WebAPI is nullptr");
  76. return false;
  77. }
  78. nJson json0;
  79. json0["opName"] = "ESM8C_GetDevice";
  80. QString strCmd = QString::fromStdString(json0.dump());
  81. QString strRet;
  82. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  83. if(ret < 0)
  84. {
  85. LH_WRITE_ERROR(QString("从数据库获取设备失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  86. return false;
  87. }
  88. /* 解析获取到的JSON数据 */
  89. // LH_WRITE_LOG_DEBUG(strRet);
  90. try
  91. {
  92. nJson json1 = nJson::parse(strRet.toStdString());
  93. int retCode = json1["code"].get<int>();
  94. if(retCode != 0)
  95. {
  96. LH_WRITE_ERROR("获取设备数据失败");
  97. return false;
  98. }
  99. nJson result = json1["result"];
  100. for(auto& it : result)
  101. {
  102. DeviceInfo DevInfo;
  103. QString devName = QString::fromStdString(it["dname"].get<std::string>());
  104. DevInfo.devName = devName;
  105. DevInfo.DID = it["did"].is_null() ? -1 : it["did"].get<int>();
  106. DevInfo.DTID = it["dtid"].is_null() ? -1 : it["dtid"].get<int>();
  107. DevInfo.MPID = it["mpid"].is_null() ? -1 : it["mpid"].get<int>();
  108. DevInfo.PTTypeCode = it["pttypecode"].is_null() ? -1 : it["pttypecode"].get<int>();
  109. DevInfo.ChannelID = it["chnid"].is_null() ? -1 : it["chnid"].get<int>();
  110. if(DevInfo.ChannelID <= 0)
  111. {
  112. LH_WRITE_LOG_DEBUG(QString("通道ID错误:%1").arg(DevInfo.ChannelID));
  113. continue;
  114. }
  115. /* 查找对应的设备类型,根据PTTypeCode来查找,这个是唯一的 */
  116. auto devType = DevTypeContainer.getDevType(DevInfo.PTTypeCode);
  117. if(devType.PTTypeCode < 0)
  118. {
  119. LH_WRITE_LOG_DEBUG(QString("未找到设备类型:%1").arg(DevInfo.PTTypeCode));
  120. continue;
  121. }
  122. DevInfo.DevType = devType;
  123. /* 检查有没有设置主备 */
  124. int devMB = it["dClass"].is_null() ? -1 : it["dClass"].get<int>();
  125. if(devMB < 0)
  126. {
  127. LH_WRITE_ERROR(QString("设备类型:%1《主/备》 类型为空").arg(DevInfo.DevType.PTTypeCode));
  128. continue;
  129. }
  130. mapDevice.insert(DevInfo.devName, DevInfo);
  131. }
  132. LH_WRITE_LOG(QString("获取设备数据成功,设备数目:%1").arg(mapDevice.size()));
  133. } catch (const nJson::parse_error& e) {
  134. LH_WRITE_ERROR("解析ESM-8C设备数据失败");
  135. return false;
  136. }
  137. catch (const nJson::exception& e)
  138. {
  139. LH_WRITE_ERROR("解析ESM-8C设备数据失败");
  140. return false;
  141. }
  142. catch(...)
  143. {
  144. LH_WRITE_ERROR("解析ESM-8C设备数据失败");
  145. return false;
  146. }
  147. return true;
  148. }
  149. /**
  150. * @brief 将数据写入EQM数据库,这里不需要模版编号和名称,编号都设置成0
  151. *
  152. * @param list
  153. * @return true
  154. * @return false
  155. */
  156. bool FromWebAPI::insertData(QList<ExecPlanItemInfo>& list)
  157. {
  158. if(m_httpApi == nullptr)
  159. {
  160. LH_WRITE_ERROR("WebAPI is nullptr");
  161. return false;
  162. }
  163. /* 先删除表格中的数据 */
  164. deleteAllTransmitterPlan();
  165. QDate zeroDate(1970,1,1);
  166. /* 写入数据 */
  167. nJson json0 = nJson::array();
  168. try{
  169. for(auto& it : list)
  170. {
  171. nJson json1;
  172. json1["opName"] = "ESM8C_InsertDataToExecPlan";
  173. json1["Key"] = QUuid::createUuid().toString().toStdString();
  174. nJson json2;
  175. json2["ExecType"] = it.ExecType;
  176. json2["WeekDay"] = it.WeekDay;
  177. json2["Date"] = it.date.toString("yyyy-MM-dd").toStdString();
  178. json2["ExecTime"] = it.execTime.toString("hh:mm:ss").toStdString();
  179. json2["DeviceName"] = it.devName.toStdString();
  180. json2["ActionName"] = it.actionName.toStdString();
  181. json2["ActionID"] = static_cast<int>(it.actionID);
  182. /* 根据设备名称找到设备信息 */
  183. auto devInfo = DeviceContainer.getDevice(it.devName);
  184. if(devInfo.PTTypeCode < 0)
  185. {
  186. LH_WRITE_ERROR(QString("未找到设备:%1").arg(it.devName));
  187. continue;
  188. }
  189. json2["PTTypeCode"] = devInfo.PTTypeCode;
  190. json2["DID"] = devInfo.DID;
  191. json2["MPID"] = devInfo.MPID;
  192. json2["ChannelID"] = devInfo.ChannelID;
  193. json1["paramList"] = json2;
  194. json0.push_back(json1);
  195. }
  196. }catch (const nJson::parse_error& e) {
  197. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  198. return false;
  199. }
  200. catch (const nJson::exception& e)
  201. {
  202. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  203. return false;
  204. }
  205. catch (...)
  206. {
  207. SPDLOG_ERROR("生成json数据失败");
  208. return false;
  209. }
  210. /* 将json写入本地文件 */
  211. #ifdef C_DEBUG
  212. QString fileJson(QString::fromStdString(json0.dump(4)));
  213. // LH_WRITE_LOG_DEBUG("\n" + fileJson);
  214. // QString filePath = QApplication::applicationDirPath() + QString("ExecPlanData.json");
  215. // SPDLOG_LOGGER_DEBUG(m_logger,"To EQM Json写入文件:{}", filePath.toStdString());
  216. // QFile file(filePath);
  217. // if(file.open(QIODevice::WriteOnly | QIODevice::Truncate))
  218. // {
  219. // file.write(fileJson.toUtf8());
  220. // file.close();
  221. // }else {
  222. // SPDLOG_LOGGER_ERROR(m_logger,"打开文件失败:{}", filePath.toStdString());
  223. // }
  224. #endif
  225. /* 写入EQM数据库 */
  226. QString strCmd = QString::fromStdString(json0.dump());
  227. QString strRet;
  228. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  229. if(ret < 0)
  230. {
  231. LH_WRITE_ERROR(QString("写入EQM数据库失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  232. return false;
  233. }
  234. LH_WRITE_LOG(QString("计划写入EQM数据库成功, 计划数目:%1").arg(QString::number(list.size())));
  235. return true;
  236. }
  237. /**
  238. * @brief 获取tExecPlan表格数据,获取到的数据会根据设备名查找对应的设备信息,如果没有查找到,就抛弃这个计划
  239. *
  240. * @param list
  241. * @return true
  242. * @return false
  243. */
  244. bool FromWebAPI::getExecPlanData(QList<ExecPlanItemInfo>& list)
  245. {
  246. if(m_httpApi == nullptr)
  247. {
  248. LH_WRITE_ERROR("WebAPI is nullptr");
  249. return false;
  250. }
  251. nJson json0;
  252. json0["opName"] = "ESM8C_GetExecPlan";
  253. QString strCmd = QString::fromStdString(json0.dump());
  254. QString strRet;
  255. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  256. if(ret < 0)
  257. {
  258. LH_WRITE_ERROR(QString("从EQM获取tExecPlan表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  259. return false;
  260. }
  261. /* 解析获取到的JSON数据 */
  262. // SPDLOG_LOGGER_DEBUG(m_logger,"获取执行计划:\n{}",strRet.toStdString());
  263. try
  264. {
  265. nJson json1 = nJson::parse(strRet.toStdString());
  266. int retCode = json1["code"].get<int>();
  267. if(retCode != 0)
  268. {
  269. LH_WRITE_ERROR("获取tExecPlan表格数据失败");
  270. return false;
  271. }
  272. nJson result = json1["result"];
  273. for(auto& it : result)
  274. {
  275. ExecPlanItemInfo info;
  276. info.devName = QString::fromStdString(it["deviceName"].get<std::string>());
  277. if(!DeviceContainer.findDevice(info.devName))
  278. {
  279. LH_WRITE_LOG(QString("未找到设备:%1").arg(info.devName));
  280. continue;
  281. }
  282. info.ExecType = it["execType"].get<int>();
  283. info.WeekDay = it["weekDay"].get<int>();
  284. auto tmpDate = it["date"].is_null() ? "" : it["date"].get<std::string>();
  285. if(!tmpDate.empty())
  286. {
  287. info.date = QDate::fromString(QString::fromStdString(tmpDate),"yyyy-MM-dd");
  288. }
  289. info.execTime = QTime::fromString(QString::fromStdString(it["execTime"].get<std::string>()),"hh:mm:ss");
  290. info.actionName = QString::fromStdString(it["actionName"].get<std::string>());
  291. info.actionID = it["actionID"].get<int>();
  292. list.append(info);
  293. }
  294. } catch (const nJson::parse_error& e) {
  295. LH_WRITE_ERROR(QString("解析tExecPlan表格数据失败:%1").arg(e.what()));
  296. return false;
  297. }
  298. catch (const nJson::exception& e)
  299. {
  300. LH_WRITE_ERROR(QString("解析tExecPlan表格数据失败:%1").arg(e.what()));
  301. return false;
  302. }
  303. catch(...)
  304. {
  305. LH_WRITE_ERROR("解析tExecPlan表格数据失败");
  306. return false;
  307. }
  308. LH_WRITE_LOG_DEBUG(QString("从EQM.tExecPlan表格获取数据成功,计划数目:%1").arg(list.size()));
  309. return true;
  310. }
  311. /* 将页面的配置写入数据库 */
  312. bool FromWebAPI::insertConfigData(QMap<int, int>& mapConfig)
  313. {
  314. if(m_httpApi == nullptr)
  315. {
  316. LH_WRITE_ERROR("WebAPI is nullptr");
  317. return false;
  318. }
  319. deleteConfigData(mapConfig);
  320. nJson json0 = nJson::array();
  321. try{
  322. for(auto begin = mapConfig.begin(), end = mapConfig.end(); begin != end; begin++)
  323. {
  324. nJson json1;
  325. json1["opName"] = "ESM8C_InsertExecPlanConfig";
  326. json1["Key"] = QUuid::createUuid().toString().toStdString();
  327. nJson json2;
  328. json2["keyWord"] = begin.key();
  329. json2["value1"] = begin.value();
  330. json1["paramList"] = json2;
  331. json0.push_back(json1);
  332. }
  333. }catch (const nJson::parse_error& e) {
  334. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  335. return false;
  336. }
  337. catch (const nJson::exception& e)
  338. {
  339. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  340. return false;
  341. }
  342. catch (...)
  343. {
  344. SPDLOG_ERROR("生成json数据失败");
  345. return false;
  346. }
  347. /* 写入EQM数据库 */
  348. QString strCmd = QString::fromStdString(json0.dump());
  349. QString strRet;
  350. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  351. if(ret < 0)
  352. {
  353. LH_WRITE_ERROR(QString("写入tExecPlanConfig失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  354. return false;
  355. }
  356. LH_WRITE_LOG(QString("页面配置写入tExecPlanConfig成功, 计划数目:%1").arg(QString::number(mapConfig.size())));
  357. return true;
  358. }
  359. /* 删除配置数据 */
  360. bool FromWebAPI::deleteConfigData(QMap<int, int>& mapConfig)
  361. {
  362. if(m_httpApi == nullptr)
  363. {
  364. LH_WRITE_ERROR("WebAPI is nullptr");
  365. return false;
  366. }
  367. nJson json0 = nJson::array();
  368. try{
  369. for(auto begin = mapConfig.begin(), end = mapConfig.end(); begin != end; begin++)
  370. {
  371. nJson json1;
  372. json1["opName"] = "ESM8C_DeleteExecPlanConfig";
  373. json1["Key"] = QUuid::createUuid().toString().toStdString();
  374. nJson json2;
  375. json2["keyWord"] = begin.key();
  376. json1["paramList"] = json2;
  377. json0.push_back(json1);
  378. }
  379. }catch (const nJson::parse_error& e) {
  380. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  381. return false;
  382. }
  383. catch (const nJson::exception& e)
  384. {
  385. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  386. return false;
  387. }
  388. catch (...)
  389. {
  390. SPDLOG_ERROR("生成json数据失败");
  391. return false;
  392. }
  393. /* 写入EQM数据库 */
  394. QString strCmd = QString::fromStdString(json0.dump());
  395. QString strRet;
  396. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  397. if(ret < 0)
  398. {
  399. LH_WRITE_ERROR(QString("删除tExecPlanConfig表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  400. return false;
  401. }
  402. LH_WRITE_LOG_DEBUG(QString("删除tExecPlanConfig表格数据成功, 计划数目:%1").arg(QString::number(mapConfig.size())));
  403. return true;
  404. }
  405. /* 获取配置数据 */
  406. bool FromWebAPI::getConfigData(QMap<int, int>& mapConfig)
  407. {
  408. if(m_httpApi == nullptr)
  409. {
  410. LH_WRITE_ERROR("WebAPI is nullptr");
  411. return false;
  412. }
  413. nJson json0;
  414. json0["opName"] = "ESMC_GetExecPlanConfig";
  415. QString strCmd = QString::fromStdString(json0.dump());
  416. QString strRet;
  417. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  418. if(ret < 0)
  419. {
  420. LH_WRITE_ERROR(QString("获取tExecPlanConfig表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  421. return false;
  422. }
  423. /* 解析获取到的JSON数据 */
  424. LH_WRITE_LOG_DEBUG(strRet);
  425. try{
  426. nJson json1 = nJson::parse(strRet.toStdString());
  427. int retCode = json1["code"].get<int>();
  428. if(retCode != 0)
  429. {
  430. LH_WRITE_ERROR("获取tExecPlanConfig失败");
  431. return false;
  432. }
  433. nJson result = json1["result"];
  434. for(auto& it : result)
  435. {
  436. int keyWord = it["keyWord"].get<int>();
  437. int value1 = it["value1"].get<int>();
  438. mapConfig.insert(keyWord, value1);
  439. }
  440. } catch (const nJson::parse_error& e) {
  441. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  442. return false;
  443. }
  444. catch (const nJson::exception& e)
  445. {
  446. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  447. return false;
  448. }
  449. catch(...)
  450. {
  451. LH_WRITE_ERROR("解析模版编号失败");
  452. return false;
  453. }
  454. LH_WRITE_LOG_DEBUG(QString("获取tExecPlanConfig表格数据成功,数据数目:%1").arg(mapConfig.size()));
  455. return true;
  456. }
  457. /* 获取EQM数据库中的模版编号 */
  458. bool FromWebAPI::getEQMTemplateID(QList<int>& listId)
  459. {
  460. if(m_httpApi == nullptr)
  461. {
  462. LH_WRITE_ERROR("WebAPI is nullptr");
  463. return false;
  464. }
  465. nJson json0;
  466. json0["opName"] = "ESMC_GetTemplateNumFromExecPlan";
  467. QString strCmd = QString::fromStdString(json0.dump());
  468. QString strRet;
  469. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  470. if(ret < 0)
  471. {
  472. LH_WRITE_ERROR(QString("从EQM获取模版编号失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  473. return false;
  474. }
  475. /* 解析获取到的JSON数据 */
  476. LH_WRITE_LOG_DEBUG(strRet);
  477. try
  478. {
  479. nJson json1 = nJson::parse(strRet.toStdString());
  480. int retCode = json1["code"].get<int>();
  481. if(retCode != 0)
  482. {
  483. LH_WRITE_ERROR("获取模版编号失败");
  484. return false;
  485. }
  486. nJson result = json1["result"];
  487. for(auto& it : result)
  488. {
  489. if(it["templateNum"].is_null())
  490. {
  491. LH_WRITE_ERROR("模版编号为空");
  492. continue;
  493. }
  494. auto id = it["templateNum"].get<int>();
  495. if(listId.contains(id))
  496. {
  497. continue;
  498. }
  499. listId.append(id);
  500. }
  501. } catch (const nJson::parse_error& e) {
  502. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  503. return false;
  504. }
  505. catch (const nJson::exception& e)
  506. {
  507. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  508. return false;
  509. }
  510. catch(...)
  511. {
  512. LH_WRITE_ERROR("解析模版编号失败");
  513. return false;
  514. }
  515. return true;
  516. }
  517. /* 删除所有行 */
  518. bool FromWebAPI::deleteAllRow()
  519. {
  520. if(m_httpApi == nullptr)
  521. {
  522. LH_WRITE_ERROR("WebAPI is nullptr");
  523. return false;
  524. }
  525. nJson json0;
  526. json0["opName"] = "ESM8C_DeleteAllRow";
  527. QString strCmd = QString::fromStdString(json0.dump());
  528. QString strRet;
  529. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
  530. if(ret < 0)
  531. {
  532. LH_WRITE_ERROR(QString("删除所有行失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  533. return false;
  534. }
  535. return true;
  536. }
  537. /* 删除所有的发射机计划 */
  538. bool FromWebAPI::deleteAllTransmitterPlan()
  539. {
  540. if(m_httpApi == nullptr)
  541. {
  542. LH_WRITE_ERROR("WebAPI is nullptr");
  543. return false;
  544. }
  545. /* 查找出有多少发射机类型 */
  546. QList<int> listPttypeCodeID;
  547. for(auto& it : DevTypeContainer.getMapDevType())
  548. {
  549. listPttypeCodeID.append(it.PTTypeCode);
  550. }
  551. nJson json0;
  552. json0["opName"] = "ESM8C_DeleteRowBasePTTypeCode";
  553. for(const auto& it : listPttypeCodeID)
  554. {
  555. json0["paramList"].clear();
  556. nJson json1;
  557. json1["PTTypeCode"] = it;
  558. json0["paramList"].push_back(json1);
  559. QString strCmd = QString::fromStdString(json0.dump());
  560. QString strRet;
  561. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
  562. if(ret < 0)
  563. {
  564. LH_WRITE_ERROR(QString("删除发射机(%3)计划失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)).arg(it));
  565. }else {
  566. LH_WRITE_LOG(QString("删除发射机(%1)计划成功!").arg(it));
  567. }
  568. }
  569. return true;
  570. }
  571. /* 保存到模板 */
  572. bool FromWebAPI::saveTemplate(const QString& templateName, const int type, QList<ExecPlanItemInfo>& list)
  573. {
  574. if(m_httpApi == nullptr)
  575. {
  576. LH_WRITE_ERROR("WebAPI is nullptr");
  577. return false;
  578. }
  579. nJson json0 = nJson::array();
  580. for(const auto& it : list)
  581. {
  582. nJson json1;
  583. json1["opName"] = "TMS_ExecPlanSaveToTemplate";
  584. json1["Key"] = QUuid::createUuid().toString().toStdString();
  585. nJson json2;
  586. json2["templateName"] = templateName.toStdString();
  587. json2["templateType"] = type;
  588. json2["execDate"] = it.date.toString("yyyy-MM-dd").toStdString();
  589. json2["execTime"] = it.execTime.toString("hh:mm:ss").toStdString();
  590. json2["deviceName"] = it.devName.toStdString();
  591. json2["actionName"] = it.actionName.toStdString();
  592. json2["actionID"] = static_cast<int>(it.actionID);
  593. json1["paramList"] = json2;
  594. json0.push_back(json1);
  595. }
  596. /* 将json写入本地文件 */
  597. #ifdef C_DEBUG
  598. // QString fileJson(QString::fromStdString(json0.dump(4)));
  599. // LH_WRITE_LOG_DEBUG("\n" + fileJson);
  600. #endif
  601. /* 写入EQM数据库 */
  602. QString strCmd = QString::fromStdString(json0.dump());
  603. QString strRet;
  604. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  605. if(ret < 0)
  606. {
  607. LH_WRITE_ERROR(QString("保存到模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  608. return false;
  609. }
  610. LH_WRITE_LOG("保存到模板成功,模板名称:" + templateName + ", 类型:" + QString::number(type) + ", 计划数目:" + QString::number(list.size()));
  611. return true;
  612. }
  613. /* 获取模板内容 */
  614. bool FromWebAPI::getTemplate(QString templateName, QList<ExecPlanItemInfo>& list)
  615. {
  616. if(m_httpApi == nullptr)
  617. {
  618. LH_WRITE_ERROR("WebAPI is nullptr");
  619. return false;
  620. }
  621. nJson json0;
  622. json0["opName"] = "TMS_GetExecPlanTemplateData";
  623. nJson json1;
  624. json1["templateName"] = templateName.toStdString();
  625. json0["paramList"] = json1;
  626. QString strCmd = QString::fromStdString(json0.dump());
  627. QString strRet;
  628. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  629. if(ret < 0)
  630. {
  631. LH_WRITE_ERROR(QString("获取模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  632. return false;
  633. }
  634. /* 解析获取到的JSON数据 */
  635. try
  636. {
  637. nJson json2 = nJson::parse(strRet.toStdString());
  638. int retCode = json2["code"].get<int>();
  639. if(retCode != 0)
  640. {
  641. LH_WRITE_ERROR("获取模板失败");
  642. return false;
  643. }
  644. nJson result = json2["result"];
  645. for(auto& it : result)
  646. {
  647. ExecPlanItemInfo info;
  648. info.devName = QString::fromStdString(it["deviceName"].get<std::string>());
  649. if(!DeviceContainer.findDevice(info.devName))
  650. {
  651. LH_WRITE_LOG(QString("未找到设备:%1").arg(info.devName));
  652. continue;
  653. }
  654. auto tmpDate = it["execDate"].is_null() ? "" : it["execDate"].get<std::string>();
  655. if(!tmpDate.empty())
  656. {
  657. info.date = QDate::fromString(QString::fromStdString(tmpDate),"yyyy-MM-dd");
  658. }
  659. info.execTime = QTime::fromString(QString::fromStdString(it["execTime"].get<std::string>()),"hh:mm:ss");
  660. info.actionName = QString::fromStdString(it["actionName"].get<std::string>());
  661. info.actionID = it["actionID"].get<int>();
  662. list.append(info);
  663. }
  664. LH_WRITE_LOG(QString("获取模板成功,数据数目:%1").arg(list.size()));
  665. }
  666. catch (const nJson::parse_error& e)
  667. {
  668. LH_WRITE_ERROR(QString("解析模板失败:%1").arg(e.what()));
  669. return false;
  670. }
  671. catch (const nJson::exception& e)
  672. {
  673. LH_WRITE_ERROR(QString("解析模板失败:%1").arg(e.what()));
  674. return false;
  675. }
  676. catch(...)
  677. {
  678. LH_WRITE_ERROR("解析模板失败");
  679. return false;
  680. }
  681. return true;
  682. }
  683. /* 获取模板列表 */
  684. bool FromWebAPI::getTemplateList(QMap<QString, int>& list)
  685. {
  686. if(m_httpApi == nullptr)
  687. {
  688. LH_WRITE_ERROR("WebAPI is nullptr");
  689. return false;
  690. }
  691. nJson json0;
  692. json0["opName"] = "TMS_GetExecPlanTemplateList";
  693. QString strCmd = QString::fromStdString(json0.dump());
  694. QString strRet;
  695. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  696. if(ret < 0)
  697. {
  698. LH_WRITE_ERROR(QString("获取模板列表失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  699. return false;
  700. }
  701. /* 解析获取到的JSON数据 */
  702. // LH_WRITE_LOG_DEBUG(strRet);
  703. try
  704. {
  705. nJson json1 = nJson::parse(strRet.toStdString());
  706. int retCode = json1["code"].get<int>();
  707. if(retCode != 0)
  708. {
  709. LH_WRITE_ERROR("获取模板列表失败");
  710. return false;
  711. }
  712. nJson result = json1["result"];
  713. for(auto& it : result)
  714. {
  715. if(it["templateName"].is_null())
  716. {
  717. LH_WRITE_ERROR("模板名称为空");
  718. continue;
  719. }
  720. auto name = QString::fromStdString(it["templateName"].get<std::string>());
  721. int type = it["templateType"].is_null() ? -1 : it["templateType"].get<int>();
  722. if(list.contains(name))
  723. {
  724. continue;
  725. }
  726. list.insert(name, type);
  727. }
  728. } catch (const nJson::parse_error& e) {
  729. LH_WRITE_ERROR(QString("解析模板列表失败:%1").arg(e.what()));
  730. return false;
  731. }
  732. catch (const nJson::exception& e)
  733. {
  734. LH_WRITE_ERROR(QString("解析模板列表失败:%1").arg(e.what()));
  735. return false;
  736. }
  737. catch(...)
  738. {
  739. LH_WRITE_ERROR("解析模板列表失败");
  740. return false;
  741. }
  742. // for(auto it = list.begin(); it != list.end(); it++)
  743. // {
  744. // LH_WRITE_LOG_DEBUG(QString("模板名称:%1, 类型:%2").arg(it.key()).arg(it.value()));
  745. // }
  746. return true;
  747. }
  748. /* 删除一个模板 */
  749. bool FromWebAPI::deleteTemplate(const QString& name)
  750. {
  751. if(m_httpApi == nullptr)
  752. {
  753. LH_WRITE_ERROR("WebAPI is nullptr");
  754. return false;
  755. }
  756. nJson json0;
  757. json0["opName"] = "TMS_DeleteExecPlanTemplate";
  758. nJson json1;
  759. json1["templateName"] = name.toStdString();
  760. json0["paramList"] = json1;
  761. QString strCmd = QString::fromStdString(json0.dump());
  762. QString strRet;
  763. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
  764. if(ret < 0)
  765. {
  766. LH_WRITE_ERROR(QString("删除模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  767. return false;
  768. }
  769. return true;
  770. }