FromWebAPI.cpp 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856
  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. LH_WRITE_LOG(QString("获取tExecPlan表格数据成功,数据数目:%1").arg(list.size()));
  295. } catch (const nJson::parse_error& e) {
  296. LH_WRITE_ERROR(QString("解析tExecPlan表格数据失败:%1").arg(e.what()));
  297. return false;
  298. }
  299. catch (const nJson::exception& e)
  300. {
  301. LH_WRITE_ERROR(QString("解析tExecPlan表格数据失败:%1").arg(e.what()));
  302. return false;
  303. }
  304. catch(...)
  305. {
  306. LH_WRITE_ERROR("解析tExecPlan表格数据失败");
  307. return false;
  308. }
  309. LH_WRITE_LOG_DEBUG(QString("从EQM.tExecPlan表格获取数据成功,计划数目:%1").arg(list.size()));
  310. return true;
  311. }
  312. /* 将页面的配置写入数据库 */
  313. bool FromWebAPI::insertConfigData(QMap<int, int>& mapConfig)
  314. {
  315. if(m_httpApi == nullptr)
  316. {
  317. LH_WRITE_ERROR("WebAPI is nullptr");
  318. return false;
  319. }
  320. deleteConfigData(mapConfig);
  321. nJson json0 = nJson::array();
  322. try{
  323. for(auto begin = mapConfig.begin(), end = mapConfig.end(); begin != end; begin++)
  324. {
  325. nJson json1;
  326. json1["opName"] = "ESM8C_InsertExecPlanConfig";
  327. json1["Key"] = QUuid::createUuid().toString().toStdString();
  328. nJson json2;
  329. json2["keyWord"] = begin.key();
  330. json2["value1"] = begin.value();
  331. json1["paramList"] = json2;
  332. json0.push_back(json1);
  333. }
  334. }catch (const nJson::parse_error& e) {
  335. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  336. return false;
  337. }
  338. catch (const nJson::exception& e)
  339. {
  340. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  341. return false;
  342. }
  343. catch (...)
  344. {
  345. SPDLOG_ERROR("生成json数据失败");
  346. return false;
  347. }
  348. /* 写入EQM数据库 */
  349. QString strCmd = QString::fromStdString(json0.dump());
  350. QString strRet;
  351. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  352. if(ret < 0)
  353. {
  354. LH_WRITE_ERROR(QString("写入tExecPlanConfig失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  355. return false;
  356. }
  357. LH_WRITE_LOG(QString("页面配置写入tExecPlanConfig成功, 计划数目:%1").arg(QString::number(mapConfig.size())));
  358. return true;
  359. }
  360. /* 删除配置数据 */
  361. bool FromWebAPI::deleteConfigData(QMap<int, int>& mapConfig)
  362. {
  363. if(m_httpApi == nullptr)
  364. {
  365. LH_WRITE_ERROR("WebAPI is nullptr");
  366. return false;
  367. }
  368. nJson json0 = nJson::array();
  369. try{
  370. for(auto begin = mapConfig.begin(), end = mapConfig.end(); begin != end; begin++)
  371. {
  372. nJson json1;
  373. json1["opName"] = "ESM8C_DeleteExecPlanConfig";
  374. json1["Key"] = QUuid::createUuid().toString().toStdString();
  375. nJson json2;
  376. json2["keyWord"] = begin.key();
  377. json1["paramList"] = json2;
  378. json0.push_back(json1);
  379. }
  380. }catch (const nJson::parse_error& e) {
  381. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  382. return false;
  383. }
  384. catch (const nJson::exception& e)
  385. {
  386. SPDLOG_ERROR("生成json数据失败:{}", e.what());
  387. return false;
  388. }
  389. catch (...)
  390. {
  391. SPDLOG_ERROR("生成json数据失败");
  392. return false;
  393. }
  394. /* 写入EQM数据库 */
  395. QString strCmd = QString::fromStdString(json0.dump());
  396. QString strRet;
  397. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  398. if(ret < 0)
  399. {
  400. LH_WRITE_ERROR(QString("删除tExecPlanConfig表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  401. return false;
  402. }
  403. LH_WRITE_LOG_DEBUG(QString("删除tExecPlanConfig表格数据成功, 计划数目:%1").arg(QString::number(mapConfig.size())));
  404. return true;
  405. }
  406. /* 获取配置数据 */
  407. bool FromWebAPI::getConfigData(QMap<int, int>& mapConfig)
  408. {
  409. if(m_httpApi == nullptr)
  410. {
  411. LH_WRITE_ERROR("WebAPI is nullptr");
  412. return false;
  413. }
  414. nJson json0;
  415. json0["opName"] = "ESMC_GetExecPlanConfig";
  416. QString strCmd = QString::fromStdString(json0.dump());
  417. QString strRet;
  418. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  419. if(ret < 0)
  420. {
  421. LH_WRITE_ERROR(QString("获取tExecPlanConfig表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  422. return false;
  423. }
  424. /* 解析获取到的JSON数据 */
  425. LH_WRITE_LOG_DEBUG(strRet);
  426. try{
  427. nJson json1 = nJson::parse(strRet.toStdString());
  428. int retCode = json1["code"].get<int>();
  429. if(retCode != 0)
  430. {
  431. LH_WRITE_ERROR("获取tExecPlanConfig失败");
  432. return false;
  433. }
  434. nJson result = json1["result"];
  435. for(auto& it : result)
  436. {
  437. int keyWord = it["keyWord"].get<int>();
  438. int value1 = it["value1"].get<int>();
  439. mapConfig.insert(keyWord, value1);
  440. }
  441. } catch (const nJson::parse_error& e) {
  442. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  443. return false;
  444. }
  445. catch (const nJson::exception& e)
  446. {
  447. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  448. return false;
  449. }
  450. catch(...)
  451. {
  452. LH_WRITE_ERROR("解析模版编号失败");
  453. return false;
  454. }
  455. LH_WRITE_LOG_DEBUG(QString("获取tExecPlanConfig表格数据成功,数据数目:%1").arg(mapConfig.size()));
  456. return true;
  457. }
  458. /* 获取EQM数据库中的模版编号 */
  459. bool FromWebAPI::getEQMTemplateID(QList<int>& listId)
  460. {
  461. if(m_httpApi == nullptr)
  462. {
  463. LH_WRITE_ERROR("WebAPI is nullptr");
  464. return false;
  465. }
  466. nJson json0;
  467. json0["opName"] = "ESMC_GetTemplateNumFromExecPlan";
  468. QString strCmd = QString::fromStdString(json0.dump());
  469. QString strRet;
  470. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  471. if(ret < 0)
  472. {
  473. LH_WRITE_ERROR(QString("从EQM获取模版编号失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  474. return false;
  475. }
  476. /* 解析获取到的JSON数据 */
  477. LH_WRITE_LOG_DEBUG(strRet);
  478. try
  479. {
  480. nJson json1 = nJson::parse(strRet.toStdString());
  481. int retCode = json1["code"].get<int>();
  482. if(retCode != 0)
  483. {
  484. LH_WRITE_ERROR("获取模版编号失败");
  485. return false;
  486. }
  487. nJson result = json1["result"];
  488. for(auto& it : result)
  489. {
  490. if(it["templateNum"].is_null())
  491. {
  492. LH_WRITE_ERROR("模版编号为空");
  493. continue;
  494. }
  495. auto id = it["templateNum"].get<int>();
  496. if(listId.contains(id))
  497. {
  498. continue;
  499. }
  500. listId.append(id);
  501. }
  502. } catch (const nJson::parse_error& e) {
  503. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  504. return false;
  505. }
  506. catch (const nJson::exception& e)
  507. {
  508. LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
  509. return false;
  510. }
  511. catch(...)
  512. {
  513. LH_WRITE_ERROR("解析模版编号失败");
  514. return false;
  515. }
  516. return true;
  517. }
  518. /* 删除所有行 */
  519. bool FromWebAPI::deleteAllRow()
  520. {
  521. if(m_httpApi == nullptr)
  522. {
  523. LH_WRITE_ERROR("WebAPI is nullptr");
  524. return false;
  525. }
  526. nJson json0;
  527. json0["opName"] = "ESM8C_DeleteAllRow";
  528. QString strCmd = QString::fromStdString(json0.dump());
  529. QString strRet;
  530. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
  531. if(ret < 0)
  532. {
  533. LH_WRITE_ERROR(QString("删除所有行失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  534. return false;
  535. }
  536. return true;
  537. }
  538. /* 删除所有的发射机计划 */
  539. bool FromWebAPI::deleteAllTransmitterPlan()
  540. {
  541. if(m_httpApi == nullptr)
  542. {
  543. LH_WRITE_ERROR("WebAPI is nullptr");
  544. return false;
  545. }
  546. /* 查找出有多少发射机类型 */
  547. QList<int> listPttypeCodeID;
  548. for(auto& it : DevTypeContainer.getMapDevType())
  549. {
  550. listPttypeCodeID.append(it.PTTypeCode);
  551. }
  552. nJson json0;
  553. json0["opName"] = "ESM8C_DeleteRowBasePTTypeCode";
  554. for(const auto& it : listPttypeCodeID)
  555. {
  556. json0["paramList"].clear();
  557. nJson json1;
  558. json1["PTTypeCode"] = it;
  559. json0["paramList"].push_back(json1);
  560. QString strCmd = QString::fromStdString(json0.dump());
  561. QString strRet;
  562. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
  563. if(ret < 0)
  564. {
  565. LH_WRITE_ERROR(QString("删除发射机(%3)计划失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)).arg(it));
  566. }else {
  567. LH_WRITE_LOG(QString("删除发射机(%1)计划成功!").arg(it));
  568. }
  569. }
  570. return true;
  571. }
  572. /* 保存到模板 */
  573. bool FromWebAPI::saveTemplate(const QString& templateName, const int type, QList<ExecPlanItemInfo>& list)
  574. {
  575. if(m_httpApi == nullptr)
  576. {
  577. LH_WRITE_ERROR("WebAPI is nullptr");
  578. return false;
  579. }
  580. nJson json0 = nJson::array();
  581. for(const auto& it : list)
  582. {
  583. nJson json1;
  584. json1["opName"] = "TMS_ExecPlanSaveToTemplate";
  585. json1["Key"] = QUuid::createUuid().toString().toStdString();
  586. nJson json2;
  587. json2["templateName"] = templateName.toStdString();
  588. json2["templateType"] = type;
  589. json2["execDate"] = it.date.toString("yyyy-MM-dd").toStdString();
  590. json2["execTime"] = it.execTime.toString("hh:mm:ss").toStdString();
  591. json2["deviceName"] = it.devName.toStdString();
  592. json2["actionName"] = it.actionName.toStdString();
  593. json2["actionID"] = static_cast<int>(it.actionID);
  594. json1["paramList"] = json2;
  595. json0.push_back(json1);
  596. }
  597. /* 将json写入本地文件 */
  598. #ifdef C_DEBUG
  599. // QString fileJson(QString::fromStdString(json0.dump(4)));
  600. // LH_WRITE_LOG_DEBUG("\n" + fileJson);
  601. #endif
  602. /* 写入EQM数据库 */
  603. QString strCmd = QString::fromStdString(json0.dump());
  604. QString strRet;
  605. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
  606. if(ret < 0)
  607. {
  608. LH_WRITE_ERROR(QString("保存到模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  609. return false;
  610. }
  611. LH_WRITE_LOG("保存到模板成功,模板名称:" + templateName + ", 类型:" + QString::number(type) + ", 计划数目:" + QString::number(list.size()));
  612. return true;
  613. }
  614. /* 获取模板内容 */
  615. bool FromWebAPI::getTemplate(QString templateName, QList<ExecPlanItemInfo>& list)
  616. {
  617. if(m_httpApi == nullptr)
  618. {
  619. LH_WRITE_ERROR("WebAPI is nullptr");
  620. return false;
  621. }
  622. nJson json0;
  623. json0["opName"] = "TMS_GetExecPlanTemplateData";
  624. nJson json1;
  625. json1["templateName"] = templateName.toStdString();
  626. json0["paramList"] = json1;
  627. QString strCmd = QString::fromStdString(json0.dump());
  628. QString strRet;
  629. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  630. if(ret < 0)
  631. {
  632. LH_WRITE_ERROR(QString("获取模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  633. return false;
  634. }
  635. /* 解析获取到的JSON数据 */
  636. try
  637. {
  638. nJson json2 = nJson::parse(strRet.toStdString());
  639. int retCode = json2["code"].get<int>();
  640. if(retCode != 0)
  641. {
  642. LH_WRITE_ERROR("获取模板失败");
  643. return false;
  644. }
  645. nJson result = json2["result"];
  646. for(auto& it : result)
  647. {
  648. ExecPlanItemInfo info;
  649. info.devName = QString::fromStdString(it["deviceName"].get<std::string>());
  650. if(!DeviceContainer.findDevice(info.devName))
  651. {
  652. LH_WRITE_LOG(QString("未找到设备:%1").arg(info.devName));
  653. continue;
  654. }
  655. auto tmpDate = it["execDate"].is_null() ? "" : it["execDate"].get<std::string>();
  656. if(!tmpDate.empty())
  657. {
  658. info.date = QDate::fromString(QString::fromStdString(tmpDate),"yyyy-MM-dd");
  659. }
  660. info.execTime = QTime::fromString(QString::fromStdString(it["execTime"].get<std::string>()),"hh:mm:ss");
  661. info.actionName = QString::fromStdString(it["actionName"].get<std::string>());
  662. info.actionID = it["actionID"].get<int>();
  663. list.append(info);
  664. }
  665. LH_WRITE_LOG(QString("获取模板成功,数据数目:%1").arg(list.size()));
  666. }
  667. catch (const nJson::parse_error& e)
  668. {
  669. LH_WRITE_ERROR(QString("解析模板失败:%1").arg(e.what()));
  670. return false;
  671. }
  672. catch (const nJson::exception& e)
  673. {
  674. LH_WRITE_ERROR(QString("解析模板失败:%1").arg(e.what()));
  675. return false;
  676. }
  677. catch(...)
  678. {
  679. LH_WRITE_ERROR("解析模板失败");
  680. return false;
  681. }
  682. return true;
  683. }
  684. /* 获取模板列表 */
  685. bool FromWebAPI::getTemplateList(QMap<QString, int>& list)
  686. {
  687. if(m_httpApi == nullptr)
  688. {
  689. LH_WRITE_ERROR("WebAPI is nullptr");
  690. return false;
  691. }
  692. nJson json0;
  693. json0["opName"] = "TMS_GetExecPlanTemplateList";
  694. QString strCmd = QString::fromStdString(json0.dump());
  695. QString strRet;
  696. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
  697. if(ret < 0)
  698. {
  699. LH_WRITE_ERROR(QString("获取模板列表失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  700. return false;
  701. }
  702. /* 解析获取到的JSON数据 */
  703. // LH_WRITE_LOG_DEBUG(strRet);
  704. try
  705. {
  706. nJson json1 = nJson::parse(strRet.toStdString());
  707. int retCode = json1["code"].get<int>();
  708. if(retCode != 0)
  709. {
  710. LH_WRITE_ERROR("获取模板列表失败");
  711. return false;
  712. }
  713. nJson result = json1["result"];
  714. for(auto& it : result)
  715. {
  716. if(it["templateName"].is_null())
  717. {
  718. LH_WRITE_ERROR("模板名称为空");
  719. continue;
  720. }
  721. auto name = QString::fromStdString(it["templateName"].get<std::string>());
  722. int type = it["templateType"].is_null() ? -1 : it["templateType"].get<int>();
  723. if(list.contains(name))
  724. {
  725. continue;
  726. }
  727. list.insert(name, type);
  728. }
  729. } catch (const nJson::parse_error& e) {
  730. LH_WRITE_ERROR(QString("解析模板列表失败:%1").arg(e.what()));
  731. return false;
  732. }
  733. catch (const nJson::exception& e)
  734. {
  735. LH_WRITE_ERROR(QString("解析模板列表失败:%1").arg(e.what()));
  736. return false;
  737. }
  738. catch(...)
  739. {
  740. LH_WRITE_ERROR("解析模板列表失败");
  741. return false;
  742. }
  743. // for(auto it = list.begin(); it != list.end(); it++)
  744. // {
  745. // LH_WRITE_LOG_DEBUG(QString("模板名称:%1, 类型:%2").arg(it.key()).arg(it.value()));
  746. // }
  747. return true;
  748. }
  749. /* 删除一个模板 */
  750. bool FromWebAPI::deleteTemplate(const QString& name)
  751. {
  752. if(m_httpApi == nullptr)
  753. {
  754. LH_WRITE_ERROR("WebAPI is nullptr");
  755. return false;
  756. }
  757. nJson json0;
  758. json0["opName"] = "TMS_DeleteExecPlanTemplate";
  759. nJson json1;
  760. json1["templateName"] = name.toStdString();
  761. json0["paramList"] = json1;
  762. QString strCmd = QString::fromStdString(json0.dump());
  763. QString strRet;
  764. auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
  765. if(ret < 0)
  766. {
  767. LH_WRITE_ERROR(QString("删除模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
  768. return false;
  769. }
  770. return true;
  771. }