SqlOperation.cpp 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705
  1. // *****************************************************************************
  2. // 版权所有(C)2023~2099 上海骄成超声波技术有限公司
  3. // 保留所有权利
  4. // *****************************************************************************
  5. // 作者 : 杨坚
  6. // 版本 : 1.0
  7. // 功能说明:
  8. // 数据库操作类
  9. // *****************************************************************************
  10. #include "SqlOperation.h"
  11. #include <QDir>
  12. #include <QCoreApplication>
  13. #include <QSqlDatabase>
  14. #include <QSqlError>
  15. #include <QString>
  16. #include <QTextCodec>
  17. #include <iostream>
  18. #include <string>
  19. #include "../common/JLogAllOutput.h"
  20. #include "../common/JMessageTip.h"
  21. #include "CManageDB.h"
  22. SqlOperation::SqlOperation()
  23. {
  24. m_pCViewInterface = ns_module::CViewInterface::GetInstance();
  25. if (m_pCViewInterface == nullptr)
  26. {
  27. ErrorInfo(QObject::tr("SqlOperation:Initialization failed, please check", "初始化失败,请检查"));
  28. return;
  29. }
  30. //注册回调
  31. DataNoticeCallbackFun fun = std::bind(&SqlOperation::DataChange, this, std::placeholders::_1, std::placeholders::_2);
  32. //模组
  33. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, BONDHEAD_CONFIG_TABLE_NAME, fun);
  34. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, WAFERHEAD_CONFIG_TABLE_NAME, fun);
  35. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, WAFFLEHEAD_CONFIG_TABLE_NAME, fun);
  36. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, EJECTOR_CONFIG_TABLE_NAME, fun);
  37. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, WAFERTABLE_CONFIG_TABLE_NAME, fun);
  38. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, WAFER_CALIB_TABLE_CONFIG_TABLE_NAME, fun);
  39. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, WAFFLE_CALIB_TABLE_CONFIG_TABLE_NAME, fun);
  40. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, BOND_TABLE_CONFIG_TABLE_NAME, fun);
  41. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, NOZZLE_TABLE_CONFIG_TABLE_NAME, fun);
  42. m_pCViewInterface->RecvDataChangNotice(MODULECONFIG_DATABASE_NAME, ULTRAHEAD_TABLE_NAME, fun);
  43. //标定
  44. m_pCViewInterface->RecvDataChangNotice(CALIBCONFIG_DATABASE_NAME, CALIB_CTD_TABLE_NAME, fun);
  45. m_pCViewInterface->RecvDataChangNotice(CALIBCONFIG_DATABASE_NAME, CALIB_XY_TABLE_NAME, fun);
  46. m_pCViewInterface->RecvDataChangNotice(CALIBCONFIG_DATABASE_NAME, CALIB_R_TABLE_NAME, fun);
  47. m_pCViewInterface->RecvDataChangNotice(CALIBCONFIG_DATABASE_NAME, FORCE_CONTROL_TABLE_NAME, fun);
  48. }
  49. SqlOperation& SqlOperation::GetInstance()
  50. {
  51. static SqlOperation instance;
  52. return instance;
  53. }
  54. int SqlOperation::LoadSql()
  55. {
  56. // 获取构建目录路径
  57. QString buildDirPath = QCoreApplication::applicationDirPath();
  58. QDir buildDirectory(buildDirPath);
  59. QString strError;
  60. QString destDbPath = buildDirectory.filePath("configurations.db");
  61. // 检查文件是否存在
  62. QFile databaseFile(destDbPath);
  63. if (!databaseFile.exists())
  64. {
  65. strError = QObject::tr("The database file does not exist:", "数据库文件不存在:") + destDbPath;
  66. ErrorInfo(strError);
  67. }
  68. else
  69. {
  70. // 创建数据库连接
  71. QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
  72. db.setDatabaseName(destDbPath);
  73. if (!db.open())
  74. {
  75. strError = QObject::tr("Database open failure:", "数据库打开失败:") + db.lastError().text();
  76. ErrorInfo(strError);
  77. }
  78. else
  79. {
  80. int rtn = loadMenu();
  81. if (rtn != 0)
  82. return rtn;
  83. rtn = loadAllDirectories();
  84. if (rtn != 0)
  85. return rtn;
  86. rtn = loadAllControlData();
  87. if (rtn != 0)
  88. return rtn;
  89. rtn = LoadAppConfig();
  90. if (rtn != 0)
  91. return rtn;
  92. return 0;
  93. }
  94. }
  95. return -1;
  96. }
  97. int SqlOperation::loadMenu()
  98. {
  99. QSqlDatabase db = QSqlDatabase::database();
  100. if (!db.isOpen())
  101. {
  102. qWarning() << "数据库未打开";
  103. return 0;
  104. }
  105. QSqlQuery query(db);
  106. QString sql = QString("SELECT Id, Name FROM %1").arg(MENU_TABLE_NAME);
  107. if (!query.exec(sql))
  108. {
  109. qWarning() << "查询 Mune 失败:" << query.lastQuery() << " " << query.lastError().text();
  110. return 0;
  111. }
  112. int id = 0;
  113. QString name = "";
  114. while (query.next())
  115. {
  116. id = query.value("Id").toInt();
  117. name = query.value("Name").toString();
  118. m_mapMenu[id] = name;
  119. }
  120. return 0;
  121. }
  122. int SqlOperation::loadAllDirectories()
  123. {
  124. QList<QJsonObject> dirs;
  125. int rtn = loadDirectories(Dir_Calibration_TABLE_NAME, dirs);
  126. if (rtn != 0)
  127. {
  128. return -1;
  129. }
  130. m_mapAllDirectories[Dir_Calibration_TABLE_NAME] = dirs;
  131. dirs.clear();
  132. rtn = loadDirectories(Dir_Diagnosis_TABLE_NAME, dirs);
  133. if (rtn != 0)
  134. {
  135. return -1;
  136. }
  137. m_mapAllDirectories[Dir_Diagnosis_TABLE_NAME] = dirs;
  138. dirs.clear();
  139. rtn = loadDirectories(Dir_Message_TABLE_NAME, dirs);
  140. if (rtn != 0)
  141. {
  142. return -1;
  143. }
  144. m_mapAllDirectories[Dir_Message_TABLE_NAME] = dirs;
  145. dirs.clear();
  146. rtn = loadDirectories(Dir_ModuleConfig_TABLE_NAME, dirs);
  147. if (rtn != 0)
  148. {
  149. return -1;
  150. }
  151. m_mapAllDirectories[Dir_ModuleConfig_TABLE_NAME] = dirs;
  152. dirs.clear();
  153. rtn = loadDirectories(Dir_ProductAssist_TABLE_NAME, dirs);
  154. if (rtn != 0)
  155. {
  156. return -1;
  157. }
  158. m_mapAllDirectories[Dir_ProductAssist_TABLE_NAME] = dirs;
  159. dirs.clear();
  160. rtn = loadDirectories(Dir_Programme_TABLE_NAME, dirs);
  161. if (rtn != 0)
  162. {
  163. return -1;
  164. }
  165. m_mapAllDirectories[Dir_Programme_TABLE_NAME] = dirs;
  166. dirs.clear();
  167. rtn = loadDirectories(Dir_SystemInfo_TABLE_NAME, dirs);
  168. if (rtn != 0)
  169. {
  170. return -1;
  171. }
  172. m_mapAllDirectories[Dir_SystemInfo_TABLE_NAME] = dirs;
  173. //for (auto it = m_mapMenu.begin(); it != m_mapMenu.end(); ++it)
  174. //{
  175. // if (it.value() == "Home")
  176. // {
  177. // continue;
  178. // }
  179. // QList<QJsonObject> dir;
  180. // QString tableName = "Dir_" + it.value();
  181. // int rtn = loadDirectories(tableName, dir);
  182. // if (rtn != 0)
  183. // {
  184. // return -1;
  185. // }
  186. // m_mapAllDirectories[it.value()] = dir;
  187. //}
  188. return 0;
  189. }
  190. int SqlOperation::loadDirectories(QString tableName, QList<QJsonObject>& directories)
  191. {
  192. QSqlDatabase db = QSqlDatabase::database();
  193. if (!db.isOpen())
  194. {
  195. qWarning() << "数据库未打开";
  196. return 0 ;
  197. }
  198. QSqlQuery query(db);
  199. QString sql = QString("SELECT Id, Name_Chs, ParentId, IsThirdLevel, Separator, UserGrade, TableName, Circle, ModuleType FROM %1").arg(tableName);
  200. //query.prepare(R"( SELECT Id, Name_Chs, ParentId, IsThirdLevel, Separator, UserGrade, Circle FROM :tableName )");
  201. //query.bindValue(":tableName", tableName);
  202. if (!query.exec(sql))
  203. {
  204. qWarning() << "查询 Directories 失败:" << query.lastQuery() << " " << query.lastError().text();
  205. return -1;
  206. }
  207. // 以 QJsonObject 保存所有目录
  208. //QList<QJsonObject> directories;
  209. while (query.next())
  210. {
  211. QJsonObject obj;
  212. int id = query.value("Id").toInt();
  213. obj["Id"] = id;
  214. obj["Name"] = query.value("Name_Chs").toString();
  215. obj["ParentId"] = query.value("ParentId").isNull() ? -1 : query.value("ParentId").toInt();
  216. obj["IsThirdLevel"] = query.value("IsThirdLevel").toBool();
  217. obj["Separator"] = query.value("Separator").toInt();
  218. obj["UserGrade"] = query.value("UserGrade").toString();
  219. obj["Circle"] = query.value("Circle").toInt();
  220. obj["TableName"] = query.value("TableName").toString();
  221. obj["Icon"] = query.value("Icon").toString();
  222. obj["Enabled"] = query.value("Enabled").toBool();
  223. obj["ModuleType"] = query.value("ModuleType").toString();
  224. qDebug() << "loadDirectories:" << obj["Name"].toString() << " ParentId:" << obj["ParentId"].toInt() << "UserGrade:" << obj["UserGrade"] << " Separator:" << obj["Separator"].toInt();
  225. qDebug() << " Circle:" << obj["Circle"].toInt();
  226. // 权限判断:只有当记录的 UserGrade 中包含当前用户权限时才加入
  227. //bool ok;
  228. //if (hasPrivilege(obj["UserGrade"].toString().toInt(&ok, 16), userPrivilege))
  229. directories.append(obj);
  230. // else
  231. // qDebug() << "目录跳过(权限不足):" << obj["Name"].toString();
  232. }
  233. return 0;
  234. }
  235. int SqlOperation::loadAllControlData()
  236. {
  237. QTextCodec* codec = QTextCodec::codecForName("GBK");
  238. if (!codec) {
  239. std::cerr << "不支持的编码" << std::endl;
  240. return -1;
  241. }
  242. m_allControlData.clear();
  243. QList<QString> moduleTableNameList;
  244. //moduleTableNameList.append(BONDHEAD_CONFIG_TABLE_NAME);
  245. moduleTableNameList.append(WAFERHEAD_CONFIG_TABLE_NAME);
  246. moduleTableNameList.append(WAFFLEHEAD_CONFIG_TABLE_NAME);
  247. moduleTableNameList.append(EJECTOR_CONFIG_TABLE_NAME);
  248. moduleTableNameList.append(WAFERTABLE_CONFIG_TABLE_NAME);
  249. moduleTableNameList.append(WAFER_CALIB_TABLE_CONFIG_TABLE_NAME);
  250. moduleTableNameList.append(WAFFLE_CALIB_TABLE_CONFIG_TABLE_NAME);
  251. moduleTableNameList.append(BOND_TABLE_CONFIG_TABLE_NAME);
  252. moduleTableNameList.append(NOZZLE_TABLE_CONFIG_TABLE_NAME);
  253. moduleTableNameList.append(ULTRAHEAD_TABLE_NAME);
  254. for (QString& dbName : moduleTableNameList)
  255. {
  256. ST_TABLE_CONTROL_DATA controlDatas_module;
  257. vector<int> iGroupId;
  258. vector<CONFIG_BASE_STRUCT> vecConfig;
  259. if (m_pCViewInterface)
  260. {
  261. m_pCViewInterface->LoadConfigDB(dbName.toStdString(), iGroupId, vecConfig);
  262. controlDatas_module.tableName = dbName;
  263. // 遍历 std::vector 并将元素添加到 QList 中
  264. for (CONFIG_BASE_STRUCT& element : vecConfig) {
  265. QString str;
  266. if (element.strDescribe.size() > 0)
  267. {
  268. str = codec->toUnicode(element.strDescribe.data(), element.strDescribe.size());
  269. element.strDescribe = str.toStdString();
  270. }
  271. /*if (element.strDescribe_Eng.size() > 0)
  272. {
  273. str = codec->toUnicode(element.strDescribe_Eng.data(), element.strDescribe_Eng.size());
  274. element.strDescribe_Eng = str.toStdString();
  275. }*/
  276. if (element.strUnit.size() > 0)
  277. {
  278. str = codec->toUnicode(element.strUnit.data(), element.strUnit.size());
  279. element.strUnit = str.toStdString();
  280. }
  281. // 给轴类型加入进去
  282. if (element.strAxisType.size() > 0)
  283. {
  284. str = codec->toUnicode(element.strAxisType.data(), element.strAxisType.size());
  285. element.strAxisType = str.toStdString();
  286. }
  287. controlDatas_module.controlDataList.append(element);
  288. }
  289. m_allControlData.append(controlDatas_module);
  290. }
  291. /*int rtn1 = loadGivenTableControlData_D_Config(dbName, controlDatas_module);
  292. if (rtn1 == 0)
  293. m_allControlData.append(controlDatas_module);*/
  294. }
  295. ST_TABLE_CONTROL_DATA controlData;
  296. int rtn = LoadControlDataFromModule(CALIB_XY_TABLE_NAME, controlData);
  297. if (rtn == 0) { m_allControlData.append(controlData); }
  298. rtn = LoadControlDataFromModule(CALIB_CTD_TABLE_NAME, controlData);
  299. if (rtn == 0) { m_allControlData.append(controlData); }
  300. rtn = LoadControlDataFromModule(CALIB_R_TABLE_NAME, controlData);
  301. if (rtn == 0) { m_allControlData.append(controlData); }
  302. for (auto it = m_mapAllDirectories.begin(); it != m_mapAllDirectories.end(); ++it)
  303. {
  304. for (int i = 0; i < it.value().size(); i++)
  305. {
  306. QJsonObject controlData = it.value()[i];
  307. if (controlData["IsThirdLevel"].toBool())
  308. {
  309. QStringList tableNames = controlData["TableName"].toString().split(";");
  310. for (const QString& tableAndGroup : tableNames)
  311. {
  312. QString name = tableAndGroup.split(",")[0];
  313. if (isModuleTable(name) || name.isEmpty())
  314. {
  315. continue;
  316. }
  317. ST_TABLE_CONTROL_DATA controlDatas;
  318. rtn = loadGivenTableControlData(name, controlDatas);
  319. if (rtn != 0)
  320. {
  321. qDebug() << "read table fail : " << name;
  322. continue;
  323. }
  324. m_allControlData.append(controlDatas);
  325. }
  326. }
  327. }
  328. }
  329. //另外加载HomeProduct的控件数据
  330. ST_TABLE_CONTROL_DATA controlDatas;
  331. rtn = loadGivenTableControlData(HOME_TABLE_NAME, controlDatas);
  332. if (rtn != 0) return rtn;
  333. m_allControlData.append(controlDatas);
  334. return 0;
  335. }
  336. int SqlOperation::loadGivenTableControlData(QString tableName, ST_TABLE_CONTROL_DATA& controlDatas)
  337. {
  338. QSqlDatabase db = QSqlDatabase::database();
  339. if (!db.isOpen())
  340. {
  341. qWarning() << "数据库未打开";
  342. return -1;
  343. }
  344. if (tableName.isEmpty())
  345. {
  346. qDebug() << "Encountered an empty string, stopping traversal.";
  347. return -1;
  348. } else
  349. {
  350. QString sql = QString("SELECT GroupId, Name, Describe, Describe_Eng, Type, Value, Defult, UpperLimit,LowerLimit,Unit, UserGrade, ChangeFlag, Icon, Enable, CallFun FROM %1 ").arg(tableName);
  351. QSqlQuery queryBond(db);
  352. queryBond.prepare(sql);
  353. if (queryBond.exec())
  354. {
  355. CONFIG_BASE_STRUCT value;
  356. QList<CONFIG_BASE_STRUCT> valueList;
  357. while (queryBond.next())
  358. {
  359. bool ok;
  360. value.iUserGrade = queryBond.value("UserGrade").toString().toInt(&ok, 16);
  361. value.strName = queryBond.value("Name").toString().toStdString();
  362. value.strDescribe = queryBond.value("Describe").toString().toStdString();
  363. //value.strDescribe_Eng = queryBond.value("Describe_Eng").toString().toStdString();
  364. value.strType = queryBond.value("Type").toString().toStdString();
  365. value.strValue = queryBond.value("Value").toString().toStdString();
  366. value.strDefult = queryBond.value("Defult").toString().toStdString();
  367. value.strUpperLimit = queryBond.value("UpperLimit").toString().toStdString();
  368. value.strLowerLimit = queryBond.value("LowerLimit").toString().toStdString();
  369. value.strUnit = queryBond.value("Unit").toString().toStdString();
  370. value.iGroupId = queryBond.value("GroupId").toInt();
  371. value.iChangeFlag = queryBond.value("ChangeFlag").toInt();
  372. value.sIcon = queryBond.value("Icon").toString().toStdString();
  373. value.bEnable = queryBond.value("Enable").toBool();
  374. value.strCallFun = queryBond.value("CallFun").toString().toStdString();
  375. valueList.append(value);
  376. }
  377. controlDatas.tableName = tableName;
  378. controlDatas.controlDataList = valueList;
  379. }
  380. else
  381. {
  382. qWarning() << "查询 BondHead 失败:" << queryBond.lastError().text();
  383. return -1;
  384. }
  385. }
  386. return 0;
  387. }
  388. int SqlOperation::updateDb(QString tableName, QString name, const QString currentValue)
  389. {
  390. QSqlDatabase db = QSqlDatabase::database();
  391. if (!db.isOpen())
  392. {
  393. qWarning() << "数据库未打开";
  394. }
  395. QString sql = QString("UPDATE %1 SET currentValue = :newValue WHERE Name = :name").arg(tableName);
  396. QSqlQuery query;
  397. query.prepare(sql);
  398. query.bindValue(":newValue", currentValue);
  399. query.bindValue(":name", name);
  400. // 执行更新操作
  401. if (!query.exec())
  402. {
  403. qWarning() << "Failed to update currentValue:" << query.lastError().text();
  404. } else
  405. {
  406. qDebug() << "currentValue updated successfully.";
  407. }
  408. return 0;
  409. }
  410. int SqlOperation::LoadAppConfig()
  411. {
  412. int nErr = -1;
  413. QSqlDatabase db = QSqlDatabase::database();
  414. if (!db.isOpen())
  415. {
  416. JLogAllOutput::cmd_Warning("数据库未打开");
  417. }
  418. else
  419. {
  420. QSqlQuery query(db);
  421. QString sql = QString("SELECT ID, SwitchWnd,GroupId_R,Index_R,GroupId_L,Index_L FROM %1").arg("AppConfig");
  422. if (!query.exec(sql))
  423. {
  424. QString strErr = "查询 Mune 失败:";
  425. strErr += query.lastQuery();
  426. strErr += " ";
  427. strErr += query.lastError().text();
  428. JLogAllOutput::cmd_Warning(strErr.toStdString());
  429. nErr = 1;
  430. }
  431. else
  432. {
  433. while (query.next())
  434. {
  435. m_appConifg.nID = query.value("Id").toInt();
  436. m_appConifg.nID = query.value("SwitchWnd").toInt();
  437. m_appConifg.nGroupId_R = query.value("GroupId_R").toInt();
  438. m_appConifg.nIndex_R = query.value("Index_R").toInt();
  439. m_appConifg.nGroupId_L = query.value("GroupId_L").toInt();
  440. m_appConifg.nIndex_L = query.value("Index_L").toInt();
  441. }
  442. nErr = 0;
  443. }
  444. }
  445. return nErr;
  446. }
  447. int SqlOperation::GetDirectories(QString tableName, const int& userPrivilege, QList<QJsonObject>& directories)
  448. {
  449. auto it = m_mapAllDirectories.find(tableName);
  450. if (it == m_mapAllDirectories.end())
  451. {
  452. qDebug() << "获取目录表名出错!";
  453. return false;
  454. }
  455. for (QJsonObject& dir : m_mapAllDirectories[tableName])
  456. {
  457. bool ok;
  458. if (dir["UserGrade"].toString().toInt(&ok, 16) == userPrivilege)
  459. {
  460. directories.append(dir);
  461. }
  462. }
  463. return true;
  464. }
  465. int SqlOperation::GetThirdDirControlData(QString multiTableName, const int& userPrivilege, QList<ST_TABLE_CONTROL_DATA>& data, bool& allChangeFlag)
  466. {
  467. allChangeFlag = true;
  468. QStringList tableNames = multiTableName.split(";");
  469. for (const QString& name : tableNames)
  470. {
  471. QStringList nameAndGroups = name.split(",");
  472. vector<int> vecGroup;
  473. for (int i = 1; i < nameAndGroups.size(); i++)
  474. {
  475. vecGroup.push_back(nameAndGroups[i].toInt());
  476. }
  477. ST_TABLE_CONTROL_DATA needControls;
  478. for (ST_TABLE_CONTROL_DATA& tableData : m_allControlData)
  479. {
  480. //寻找表格对应的所有控件
  481. if (tableData.tableName == nameAndGroups[0])
  482. {
  483. needControls.tableName = name;
  484. //寻找用户等级对应的控件
  485. for (CONFIG_BASE_STRUCT& value : tableData.controlDataList)
  486. {
  487. if (vecGroup.size() == 0)
  488. {
  489. needControls.controlDataList.append(value);
  490. if (value.iChangeFlag == false)
  491. {
  492. allChangeFlag = false;
  493. }
  494. } else
  495. {
  496. for (int& groupId : vecGroup)
  497. {
  498. //if (value.iUserGrade == userPrivilege)
  499. if (value.iGroupId == groupId)
  500. {
  501. needControls.controlDataList.append(value);
  502. if (value.iChangeFlag == false)
  503. {
  504. allChangeFlag = false;
  505. }
  506. }
  507. }
  508. }
  509. }
  510. }
  511. }
  512. data.append(needControls);
  513. }
  514. return 0;
  515. }
  516. int SqlOperation::updateControlData(QString tableName, QString name, const QString& currentValue)
  517. {
  518. if (m_pCViewInterface == nullptr)
  519. {
  520. //ErrorInfo(QObject::tr("SqlOperation:Initialization failed, please check", "初始化失败,请检查"));
  521. return -1;
  522. }
  523. vector<CONFIG_BASE_STRUCT> changeData;
  524. for (ST_TABLE_CONTROL_DATA &tableData: m_allControlData)
  525. {
  526. if (tableData.tableName == tableName)
  527. {
  528. for (CONFIG_BASE_STRUCT& controlData : tableData.controlDataList)
  529. {
  530. if (controlData.strName == name.toStdString())
  531. {
  532. controlData.strValue = currentValue.toStdString();
  533. changeData.push_back(controlData);
  534. m_pCViewInterface->SaveConfigDB(tableName.toStdString(), changeData);
  535. }
  536. }
  537. }
  538. }
  539. return 0;
  540. }
  541. int SqlOperation::GetThirdDirButtons(QString multiTableName, const int& userPrivilege, QList<CONFIG_BASE_STRUCT>& buttons)
  542. {
  543. QStringList tableNames = multiTableName.split(",");
  544. for (const QString& name : tableNames)
  545. {
  546. for (ST_TABLE_CONTROL_DATA& tableData : m_allControlData)
  547. {
  548. //寻找表格对应的所有控件
  549. if (tableData.tableName == name)
  550. {
  551. //寻找用户等级对应的控件
  552. for (CONFIG_BASE_STRUCT& value : tableData.controlDataList)
  553. {
  554. if (value.iUserGrade == userPrivilege)
  555. {
  556. buttons.append(value);
  557. }
  558. }
  559. }
  560. }
  561. }
  562. return 0;
  563. }
  564. int SqlOperation::GetMuneName(int id, QString& name)
  565. {
  566. return 0;
  567. }
  568. void SqlOperation::ErrorInfo(const QString& strError)
  569. {
  570. JMessageTip::Message_question(strError);
  571. JLogAllOutput::cmd_debug(strError.toStdString());
  572. //exit(0); //TODO: 关闭可以交给主界面
  573. }
  574. bool SqlOperation::isModuleTable(QString tableName)
  575. {
  576. if (tableName == BONDHEAD_CONFIG_TABLE_NAME ||
  577. tableName == WAFERHEAD_CONFIG_TABLE_NAME ||
  578. tableName == WAFFLEHEAD_CONFIG_TABLE_NAME ||
  579. tableName == EJECTOR_CONFIG_TABLE_NAME ||
  580. tableName == WAFERTABLE_CONFIG_TABLE_NAME ||
  581. tableName == WAFER_CALIB_TABLE_CONFIG_TABLE_NAME ||
  582. tableName == WAFFLE_CALIB_TABLE_CONFIG_TABLE_NAME ||
  583. tableName == BOND_TABLE_CONFIG_TABLE_NAME ||
  584. tableName == NOZZLE_TABLE_CONFIG_TABLE_NAME ||
  585. tableName == ULTRAHEAD_TABLE_NAME ||
  586. tableName == CALIB_CTD_TABLE_NAME ||
  587. tableName == CALIB_XY_TABLE_NAME ||
  588. tableName == CALIB_R_TABLE_NAME)
  589. {
  590. return true;
  591. }
  592. return false;
  593. }
  594. int SqlOperation::LoadControlDataFromModule(std::string tableName, ST_TABLE_CONTROL_DATA& controlData)
  595. {
  596. QTextCodec* codec = QTextCodec::codecForName("GBK");
  597. vector<int> vecCalibGroupId;
  598. vector<CONFIG_BASE_STRUCT> vecCalibConfig;
  599. if (m_pCViewInterface == nullptr)
  600. {
  601. //ErrorInfo(QObject::tr("SqlOperation:Initialization failed, please check", "初始化失败,请检查"));
  602. return -1;
  603. }
  604. int rtn = m_pCViewInterface->LoadConfigDB(tableName, vecCalibGroupId, vecCalibConfig);
  605. if (rtn != OK)
  606. {
  607. JLogAllOutput::cmd_debug("读取底层表格数据出错");
  608. return -1;
  609. }
  610. controlData.tableName = QString::fromStdString(tableName);
  611. controlData.controlDataList.clear();
  612. for (CONFIG_BASE_STRUCT& element : vecCalibConfig)
  613. {
  614. QString str;
  615. if (element.strDescribe.size() > 0)
  616. {
  617. str = codec->toUnicode(element.strDescribe.data(), element.strDescribe.size());
  618. element.strDescribe = str.toStdString();
  619. }
  620. if (element.strUnit.size() > 0)
  621. {
  622. str = codec->toUnicode(element.strUnit.data(), element.strUnit.size());
  623. element.strUnit = str.toStdString();
  624. }
  625. controlData.controlDataList.append(element);
  626. }
  627. return 0;
  628. //m_allControlData.append(controlData);
  629. }
  630. void SqlOperation::DataChange(string strDbName, string strTableName)
  631. {
  632. }