综合平台编程器项目的远程存储
Nie możesz wybrać więcej, niż 25 tematów Tematy muszą się zaczynać od litery lub cyfry, mogą zawierać myślniki ('-') i mogą mieć do 35 znaków.
 
 
 
 

954 wiersze
43 KiB

  1. #include "domain/project_storage.h"
  2. #include "domain/hmi_model.h"
  3. #include "infrastructure/json_project_storage.h"
  4. #include "support/test_support.h"
  5. #include "services/register_comment_service.h"
  6. #include "services/project_service.h"
  7. #include "domain/project_limits.h"
  8. #include <QFile>
  9. #include <QJsonArray>
  10. #include <QJsonDocument>
  11. #include <QJsonObject>
  12. #include <QTemporaryDir>
  13. #include <exception>
  14. #include <iostream>
  15. #include <stdexcept>
  16. #include <string>
  17. #include <utility>
  18. namespace {
  19. using TestSupport::require;
  20. Project makeExampleProject()
  21. {
  22. // 构造覆盖 HMI 控件和梯形图串并联结构的完整 JSON 往返样本
  23. HmiControl start_button;
  24. start_button.id = "start-button";
  25. start_button.type = HmiControlType::Button;
  26. start_button.bounds = {10, 20, 120, 48};
  27. start_button.text = "Start";
  28. start_button.binding = RegisterAddress{RegisterArea::M, 0};
  29. start_button.buttonOperation = HmiButtonOperation::SetOn;
  30. start_button.properties.emplace("color", "green");
  31. start_button.properties.emplace(HmiAppearanceProperty::kTextColor, "#E53935");
  32. start_button.properties.emplace(HmiAppearanceProperty::kFontSize, "18");
  33. start_button.properties.emplace(HmiAppearanceProperty::kFontBold, "true");
  34. start_button.properties.emplace(HmiAppearanceProperty::kFontItalic, "false");
  35. HmiControl running_indicator;
  36. running_indicator.id = "running-indicator";
  37. running_indicator.type = HmiControlType::Indicator;
  38. running_indicator.bounds = {150, 20, 64, 64};
  39. running_indicator.text = "Running";
  40. running_indicator.binding = RegisterAddress{RegisterArea::M, 1};
  41. running_indicator.properties.emplace("activeColor", "#24a148");
  42. HmiControl temperature_display;
  43. temperature_display.id = "temperature-display";
  44. temperature_display.type = HmiControlType::NumericDisplay;
  45. temperature_display.bounds = {10, 90, 120, 40};
  46. temperature_display.text = "Temperature";
  47. temperature_display.binding = RegisterAddress{RegisterArea::D, 2};
  48. temperature_display.properties.emplace("format", "decimal");
  49. HmiControl target_input;
  50. target_input.id = "target-input";
  51. target_input.type = HmiControlType::NumericInput;
  52. target_input.bounds = {150, 90, 120, 40};
  53. target_input.text = "Target";
  54. target_input.binding = RegisterAddress{RegisterArea::D, 3};
  55. target_input.properties.emplace("minimum", "-100");
  56. HmiControl title_label;
  57. title_label.id = "title-label";
  58. title_label.type = HmiControlType::Label;
  59. title_label.bounds = {10, 145, 180, 32};
  60. title_label.text = "Production line";
  61. HmiControl settings_jump;
  62. settings_jump.id = "settings-jump";
  63. settings_jump.type = HmiControlType::PageJump;
  64. settings_jump.bounds = {210, 145, 120, 40};
  65. settings_jump.text = "Settings";
  66. settings_jump.pageJump = HmiPageJumpConfig{"settings-page"};
  67. HmiControl alarm_list;
  68. alarm_list.id = "alarm-list";
  69. alarm_list.type = HmiControlType::AlarmList;
  70. alarm_list.bounds = {10, 200, 360, 180};
  71. alarm_list.text = "Alarms";
  72. HmiControl progress_bar;
  73. progress_bar.id = "progress-bar";
  74. progress_bar.type = HmiControlType::ProgressBar;
  75. progress_bar.bounds = {400, 20, 240, 36};
  76. progress_bar.text = "Completion";
  77. progress_bar.binding = RegisterAddress{RegisterArea::D, 4};
  78. progress_bar.progressBar = HmiProgressBarConfig{-20, 80, true};
  79. HmiPage page;
  80. page.id = "main-page";
  81. page.name = "Main";
  82. page.controls.push_back(start_button);
  83. page.controls.push_back(running_indicator);
  84. page.controls.push_back(temperature_display);
  85. page.controls.push_back(target_input);
  86. page.controls.push_back(title_label);
  87. page.controls.push_back(settings_jump);
  88. page.controls.push_back(alarm_list);
  89. page.controls.push_back(progress_bar);
  90. HmiPage settings_page;
  91. settings_page.id = "settings-page";
  92. settings_page.name = "Settings";
  93. LogicNode contact;
  94. contact.id = "start-contact";
  95. contact.config = ContactNodeConfig{
  96. RegisterAddress{RegisterArea::M, 0},
  97. ContactMode::NormallyOpen};
  98. LogicNode compare;
  99. compare.id = "temperature-check";
  100. compare.config = CompareNodeConfig{
  101. RegisterAddress{RegisterArea::D, 2},
  102. ComparisonOperator::GreaterThanOrEqual,
  103. static_cast<std::int16_t>(100)};
  104. LogicNode hold_contact;
  105. hold_contact.id = "hold-contact";
  106. hold_contact.config = ContactNodeConfig{
  107. RegisterAddress{RegisterArea::M, 1},
  108. ContactMode::NormallyOpen};
  109. LogicNode coil;
  110. coil.id = "run-coil";
  111. coil.config = CoilNodeConfig{
  112. RegisterAddress{RegisterArea::M, 1},
  113. CoilMode::Set};
  114. ControlLogic logic;
  115. logic.id = "start-logic";
  116. logic.name = "Start logic";
  117. logic.enabled = false;
  118. LadderRung rung;
  119. rung.id = "rung-1";
  120. rung.name = "Network 1";
  121. rung.comment = "启动条件与温度检查";
  122. ConditionExpression parallel;
  123. parallel.id = "parallel-start";
  124. parallel.kind = ConditionExpressionKind::Parallel;
  125. parallel.children = {
  126. ConditionExpression::fromNode(contact),
  127. ConditionExpression::fromNode(hold_contact)};
  128. ConditionExpression series;
  129. series.id = "series-root";
  130. series.kind = ConditionExpressionKind::Series;
  131. series.children = {
  132. std::move(parallel),
  133. ConditionExpression::fromWire("start-wire", 2),
  134. ConditionExpression::fromNode(compare)};
  135. rung.condition = std::move(series);
  136. rung.output = coil;
  137. logic.rungs.push_back(rung);
  138. LogicNode rising_edge;
  139. rising_edge.id = "rising-edge";
  140. rising_edge.config = EdgeContactNodeConfig{
  141. RegisterAddress{RegisterArea::M, 4}, EdgeMode::Rising};
  142. LogicNode edge_output;
  143. edge_output.id = "edge-output";
  144. edge_output.config = CoilNodeConfig{
  145. RegisterAddress{RegisterArea::M, 6}, CoilMode::Normal};
  146. LadderRung edge_rung;
  147. edge_rung.id = "edge-rung";
  148. edge_rung.name = "Edge network";
  149. edge_rung.comment = "上升沿输出";
  150. edge_rung.condition = ConditionExpression::fromNode(rising_edge);
  151. edge_rung.output = edge_output;
  152. logic.rungs.push_back(edge_rung);
  153. const auto addDataRung = [&logic](
  154. const std::string &rung_id,
  155. const std::string &input_id,
  156. int input_address,
  157. LogicNode output)
  158. {
  159. LogicNode input;
  160. input.id = input_id;
  161. input.config = ContactNodeConfig{
  162. RegisterAddress{RegisterArea::M, input_address},
  163. ContactMode::NormallyOpen};
  164. LadderRung data_rung;
  165. data_rung.id = rung_id;
  166. data_rung.name = rung_id;
  167. data_rung.condition = ConditionExpression::fromNode(input);
  168. data_rung.output = std::move(output);
  169. logic.rungs.push_back(std::move(data_rung));
  170. };
  171. addDataRung(
  172. "move-rung",
  173. "move-input",
  174. 20,
  175. LogicNode{
  176. "move-output",
  177. MoveNodeConfig{
  178. WordOperand{
  179. WordOperandKind::Constant,
  180. RegisterAddress{RegisterArea::D, 0},
  181. 25},
  182. RegisterAddress{RegisterArea::D, 20}},
  183. true});
  184. addDataRung(
  185. "add-rung",
  186. "add-input",
  187. 21,
  188. LogicNode{
  189. "add-output",
  190. ArithmeticNodeConfig{
  191. ArithmeticOperation::Add,
  192. WordOperand{
  193. WordOperandKind::Register,
  194. RegisterAddress{RegisterArea::D, 20},
  195. 0},
  196. WordOperand{
  197. WordOperandKind::Constant,
  198. RegisterAddress{RegisterArea::D, 0},
  199. 1},
  200. RegisterAddress{RegisterArea::D, 21}},
  201. true});
  202. addDataRung(
  203. "sub-rung",
  204. "sub-input",
  205. 22,
  206. LogicNode{
  207. "sub-output",
  208. ArithmeticNodeConfig{
  209. ArithmeticOperation::Subtract,
  210. WordOperand{
  211. WordOperandKind::Register,
  212. RegisterAddress{RegisterArea::D, 21},
  213. 0},
  214. WordOperand{
  215. WordOperandKind::Constant,
  216. RegisterAddress{RegisterArea::D, 0},
  217. 1},
  218. RegisterAddress{RegisterArea::D, 22}},
  219. true});
  220. Project project;
  221. project.metadata = {"example-project", "Example project", "1.0"};
  222. project.hmiPages.push_back(page);
  223. project.hmiPages.push_back(settings_page);
  224. project.initialHmiPageId = page.id;
  225. project.alarmDefinitions.push_back(
  226. {"alarm-emergency",
  227. RegisterAddress{RegisterArea::M, 10},
  228. AlarmCondition::MOn,
  229. 0,
  230. "Emergency stop"});
  231. project.alarmDefinitions.push_back(
  232. {"alarm-temperature",
  233. RegisterAddress{RegisterArea::D, 2},
  234. AlarmCondition::DHigh,
  235. 80,
  236. "Temperature high"});
  237. project.registerComments = {
  238. {RegisterAddress{RegisterArea::M, 0}, "启动按钮"},
  239. {RegisterAddress{RegisterArea::D, 2}, "当前温度"}};
  240. project.controlLogics.push_back(logic);
  241. ControlLogic draft_logic;
  242. draft_logic.id = "draft-logic";
  243. draft_logic.name = "Draft logic";
  244. draft_logic.enabled = false;
  245. draft_logic.rungs.push_back(
  246. {"rung-1", "Draft network", {}, std::nullopt, std::nullopt});
  247. project.controlLogics.push_back(draft_logic);
  248. return project;
  249. }
  250. void writeText(const QString &path, const QByteArray &content)
  251. {
  252. // 直接写入故障样本文件,以验证加载失败时的保护行为
  253. QFile file(path);
  254. require(file.open(QIODevice::WriteOnly), "test file must be writable");
  255. require(file.write(content) == content.size(), "test file must be written completely");
  256. }
  257. QByteArray readBytes(const QString &path)
  258. {
  259. QFile file(path);
  260. require(file.open(QIODevice::ReadOnly), "saved project must be readable");
  261. return file.readAll();
  262. }
  263. void testEmptyProjectRoundTrip()
  264. {
  265. // 空工程是合法工程,保存再加载后不应凭空产生页面或逻辑
  266. QTemporaryDir directory;
  267. require(directory.isValid(), "temporary directory must be valid");
  268. JsonProjectStorage storage;
  269. ProjectService service(storage);
  270. require(service.createNewProject("Empty project").succeeded,
  271. "empty project creation must succeed");
  272. const QString path = directory.filePath("empty.json");
  273. require(service.saveAs(path.toStdString()).succeeded,
  274. "empty project save must succeed");
  275. require(!service.isModified(), "saved project must not be marked modified");
  276. require(service.load(path.toStdString()).succeeded,
  277. "empty project load must succeed");
  278. require(service.project().metadata.name == "Empty project",
  279. "empty project name must survive round trip");
  280. require(service.project().hmiPages.empty(), "empty project must have no HMI pages");
  281. require(service.project().controlLogics.empty(),
  282. "empty project must have no control logics");
  283. require(service.project().alarmDefinitions.empty(),
  284. "empty project must have no alarm definitions");
  285. }
  286. void testUnconditionalOutputRoundTrip()
  287. {
  288. QTemporaryDir directory;
  289. require(directory.isValid(), "temporary directory must be valid");
  290. JsonProjectStorage storage;
  291. ProjectService service(storage);
  292. require(service.createNewProject("Unconditional output").succeeded,
  293. "unconditional output project creation must succeed");
  294. LadderRung rung;
  295. rung.id = "unconditional-rung";
  296. rung.name = "Unconditional rung";
  297. LogicNode coil;
  298. coil.id = "unconditional-coil";
  299. coil.config = CoilNodeConfig{
  300. RegisterAddress{RegisterArea::M, 10}, CoilMode::Normal};
  301. rung.output = coil;
  302. service.editProject().controlLogics.push_back(
  303. ControlLogic{"logic-1", "Logic 1", {rung}, true});
  304. require(service.project().validateForRunning(),
  305. "an output-only project must be runnable before saving");
  306. const QString path = directory.filePath("unconditional-output.json");
  307. require(service.saveAs(path.toStdString()).succeeded,
  308. "an output-only project must save successfully");
  309. require(service.load(path.toStdString()).succeeded,
  310. "an output-only project must load successfully");
  311. const LadderRung &loaded = service.project().controlLogics.front().rungs.front();
  312. require(!loaded.condition.has_value() && loaded.output.has_value()
  313. && loaded.validateForRunning(),
  314. "JSON round trip must preserve unconditional output semantics");
  315. }
  316. void testExampleProjectRoundTrip()
  317. {
  318. // 验证各层嵌套字段往返后保持不变且序列化结果稳定
  319. QTemporaryDir directory;
  320. require(directory.isValid(), "temporary directory must be valid");
  321. JsonProjectStorage storage;
  322. ProjectService service(storage);
  323. service.editProject() = makeExampleProject();
  324. const QString first_path = directory.filePath("example.json");
  325. const QString second_path = directory.filePath("example-copy.json");
  326. const QString invalid_operation_path = directory.filePath("invalid-operation.json");
  327. const QString missing_initial_path = directory.filePath("missing-initial.json");
  328. const QString missing_target_path = directory.filePath("missing-target.json");
  329. const QString missing_progress_range_path = directory.filePath(
  330. "missing-progress-range.json");
  331. const QString missing_alarms_path = directory.filePath("missing-alarms.json");
  332. const QString missing_register_comments_path = directory.filePath(
  333. "missing-register-comments.json");
  334. const QString missing_rung_comment_path = directory.filePath(
  335. "missing-rung-comment.json");
  336. const QString multiline_register_comment_path = directory.filePath(
  337. "multiline-register-comment.json");
  338. const QString multiline_rung_comment_path = directory.filePath(
  339. "multiline-rung-comment.json");
  340. require(service.saveAs(first_path.toStdString()).succeeded,
  341. "example project save must succeed");
  342. const QByteArray saved_json = readBytes(first_path);
  343. require(saved_json.contains("\"rungs\"")
  344. && saved_json.contains("\"condition\"")
  345. && saved_json.contains("\"children\"")
  346. && saved_json.contains("\"output\""),
  347. "saved project must use structured ladder expressions");
  348. require(!saved_json.contains("\"dataPoints\""),
  349. "saved project must not contain the removed data point model");
  350. require(saved_json.contains("\"formatVersion\": \"1.0\"")
  351. && saved_json.contains("\"buttonOperation\": \"setOn\"")
  352. && saved_json.contains("\"initialHmiPageId\": \"main-page\"")
  353. && saved_json.contains("\"targetPageId\": \"settings-page\"")
  354. && saved_json.contains("\"alarmDefinitions\"")
  355. && saved_json.contains("\"registerComments\"")
  356. && saved_json.contains("\"text\": \"启动按钮\"")
  357. && saved_json.contains("\"type\": \"edgeContact\"")
  358. && saved_json.contains("\"type\": \"move\"")
  359. && saved_json.contains("\"type\": \"arithmetic\"")
  360. && saved_json.contains("\"operation\": \"add\"")
  361. && saved_json.contains("\"operation\": \"subtract\"")
  362. && saved_json.contains("\"comment\": \"启动条件与温度检查\"")
  363. && saved_json.contains("\"type\": \"alarmList\"")
  364. && saved_json.contains("\"type\": \"progressBar\"")
  365. && saved_json.contains("\"minimumValue\": -20")
  366. && saved_json.contains("\"maximumValue\": 80")
  367. && saved_json.contains("\"showValue\": true"),
  368. "version 1.0 projects must persist pages and alarm definitions");
  369. require(!saved_json.contains("\"stages\"")
  370. && !saved_json.contains("\"branches\""),
  371. "current project format must not contain the removed stage model");
  372. require(!saved_json.contains("\"position\"")
  373. && !saved_json.contains("\"connections\""),
  374. "saved ladder logic must not contain free-graph fields");
  375. require(service.load(first_path.toStdString()).succeeded,
  376. "example project load must succeed");
  377. const Project &project = service.project();
  378. require(project.metadata.id == "example-project", "project id must survive round trip");
  379. require(project.hmiPages.size() == 2, "HMI page count must survive round trip");
  380. require(project.initialHmiPageId == "main-page",
  381. "the initial HMI page id must survive round trip");
  382. require(project.hmiPages.front().controls.size() == 8,
  383. "register, navigation, AlarmList and ProgressBar controls must survive round trip");
  384. require(project.hmiPages.front().controls.front().binding->area()
  385. == RegisterArea::M,
  386. "HMI M binding must survive round trip");
  387. require(project.hmiPages.front().controls.front().buttonOperation
  388. == HmiButtonOperation::SetOn,
  389. "HMI button operation must survive round trip");
  390. require(project.hmiPages.front().controls.front().properties.at("color") == "green",
  391. "HMI properties must survive round trip");
  392. require(project.hmiPages.front().controls.front().properties.at(
  393. HmiAppearanceProperty::kTextColor) == "#E53935"
  394. && project.hmiPages.front().controls.front().properties.at(
  395. HmiAppearanceProperty::kFontSize) == "18"
  396. && project.hmiPages.front().controls.front().properties.at(
  397. HmiAppearanceProperty::kFontBold) == "true"
  398. && project.hmiPages.front().controls.front().properties.at(
  399. HmiAppearanceProperty::kFontItalic) == "false",
  400. "HMI appearance properties must survive round trip");
  401. require(project.hmiPages.front().controls.at(1).type == HmiControlType::Indicator,
  402. "indicator control type must survive round trip");
  403. require(project.hmiPages.front().controls.at(2).binding->area() == RegisterArea::D,
  404. "numeric display D binding must survive round trip");
  405. require(project.hmiPages.front().controls.at(3).bounds.x == 150,
  406. "numeric input bounds must survive round trip");
  407. require(project.hmiPages.front().controls.at(4).type == HmiControlType::Label
  408. && project.hmiPages.front().controls.at(5).pageJump->targetPageId
  409. == "settings-page",
  410. "Label and PageJump typed data must survive round trip");
  411. require(project.hmiPages.front().controls.at(6).type
  412. == HmiControlType::AlarmList,
  413. "AlarmList control type must survive round trip");
  414. require(project.hmiPages.front().controls.at(7).type
  415. == HmiControlType::ProgressBar
  416. && project.hmiPages.front().controls.at(7).progressBar.has_value()
  417. && project.hmiPages.front().controls.at(7).progressBar->minimumValue == -20
  418. && project.hmiPages.front().controls.at(7).progressBar->maximumValue == 80
  419. && project.hmiPages.front().controls.at(7).progressBar->showValue,
  420. "ProgressBar configuration must survive round trip");
  421. require(project.alarmDefinitions.size() == 2
  422. && project.alarmDefinitions.front().condition
  423. == AlarmCondition::MOn
  424. && project.alarmDefinitions.at(1).threshold == 80,
  425. "M and D alarm definitions must survive round trip");
  426. require(project.registerComments.size() == 2
  427. && project.registerComments.front().address.area() == RegisterArea::M
  428. && project.registerComments.front().text == "启动按钮"
  429. && project.registerComments.at(1).address.area() == RegisterArea::D,
  430. "M/D register comments must survive round trip");
  431. require(project.controlLogics.size() == 2,
  432. "control logic count must survive round trip");
  433. require(!project.controlLogics.front().enabled,
  434. "control logic enabled state must survive round trip");
  435. const LadderRung &rung = project.controlLogics.front().rungs.front();
  436. require(rung.comment == "启动条件与温度检查",
  437. "rung comments must survive round trip");
  438. require(rung.condition.has_value()
  439. && rung.condition->kind == ConditionExpressionKind::Series,
  440. "series root expression must survive round trip");
  441. require(rung.condition->children.front().kind
  442. == ConditionExpressionKind::Parallel
  443. && rung.condition->children.front().children.size() == 2U,
  444. "parallel expression branches must survive round trip");
  445. require(rung.condition->children.at(1).kind == ConditionExpressionKind::Wire
  446. && rung.condition->children.at(1).wire->columnSpan == 2,
  447. "horizontal wire span must survive JSON round trip");
  448. require(rung.output.has_value(),
  449. "ladder output must survive round trip");
  450. const LadderRung &edge_rung = project.controlLogics.front().rungs.at(1);
  451. require(edge_rung.output.has_value()
  452. && std::holds_alternative<CoilNodeConfig>(edge_rung.output->config)
  453. && std::get<CoilNodeConfig>(edge_rung.output->config).address
  454. == RegisterAddress{RegisterArea::M, 6},
  455. "edge network output must survive round trip");
  456. require(std::holds_alternative<EdgeContactNodeConfig>(
  457. edge_rung.condition->node->config)
  458. && std::get<EdgeContactNodeConfig>(edge_rung.condition->node->config).mode
  459. == EdgeMode::Rising,
  460. "rising edge configuration must survive round trip");
  461. require(std::get<MoveNodeConfig>(
  462. project.controlLogics.front().rungs.at(2).output->config)
  463. .source.constant == 25,
  464. "MOVE operands must survive round trip");
  465. require(std::get<ArithmeticNodeConfig>(
  466. project.controlLogics.front().rungs.at(3).output->config)
  467. .operation == ArithmeticOperation::Add
  468. && std::get<ArithmeticNodeConfig>(
  469. project.controlLogics.front().rungs.at(4).output->config)
  470. .operation == ArithmeticOperation::Subtract,
  471. "ADD and SUB operations must survive round trip");
  472. const auto &compare = std::get<CompareNodeConfig>(
  473. rung.condition->children.at(2).node->config);
  474. require(compare.address.index() == 2 && compare.value == 100,
  475. "comparison configuration must survive round trip");
  476. require(service.saveAs(second_path.toStdString()).succeeded,
  477. "save as must succeed after load");
  478. require(readBytes(first_path) == readBytes(second_path),
  479. "save and save as must produce stable JSON");
  480. QByteArray invalid_operation = saved_json;
  481. invalid_operation.replace(
  482. "\"buttonOperation\": \"setOn\"",
  483. "\"buttonOperation\": \"unsupported\"");
  484. writeText(invalid_operation_path, invalid_operation);
  485. require(!service.load(invalid_operation_path.toStdString()).succeeded,
  486. "unsupported HMI button operations must be rejected");
  487. QJsonObject missing_initial = QJsonDocument::fromJson(saved_json).object();
  488. missing_initial.remove(QStringLiteral("initialHmiPageId"));
  489. writeText(
  490. missing_initial_path,
  491. QJsonDocument(missing_initial).toJson(QJsonDocument::Compact));
  492. ProjectOperationResult missing_result = service.load(
  493. missing_initial_path.toStdString());
  494. require(!missing_result.succeeded
  495. && missing_result.storageError == ProjectStorageError::MissingField,
  496. "the 1.0 schema must require initialHmiPageId without migration defaults");
  497. QJsonObject missing_alarms = QJsonDocument::fromJson(saved_json).object();
  498. missing_alarms.remove(QStringLiteral("alarmDefinitions"));
  499. writeText(
  500. missing_alarms_path,
  501. QJsonDocument(missing_alarms).toJson(QJsonDocument::Compact));
  502. missing_result = service.load(missing_alarms_path.toStdString());
  503. require(!missing_result.succeeded
  504. && missing_result.storageError == ProjectStorageError::MissingField,
  505. "the 1.0 schema must require alarmDefinitions without migration defaults");
  506. QJsonObject missing_register_comments = QJsonDocument::fromJson(saved_json).object();
  507. missing_register_comments.remove(QStringLiteral("registerComments"));
  508. writeText(
  509. missing_register_comments_path,
  510. QJsonDocument(missing_register_comments).toJson(QJsonDocument::Compact));
  511. missing_result = service.load(missing_register_comments_path.toStdString());
  512. require(!missing_result.succeeded
  513. && missing_result.storageError == ProjectStorageError::MissingField,
  514. "the 1.0 schema must require registerComments without migration defaults");
  515. QJsonObject missing_rung_comment = QJsonDocument::fromJson(saved_json).object();
  516. QJsonArray missing_comment_logics = missing_rung_comment.value(
  517. QStringLiteral("controlLogics")).toArray();
  518. QJsonObject first_logic = missing_comment_logics.at(0).toObject();
  519. QJsonArray first_rungs = first_logic.value(QStringLiteral("rungs")).toArray();
  520. QJsonObject first_rung = first_rungs.at(0).toObject();
  521. first_rung.remove(QStringLiteral("comment"));
  522. first_rungs.replace(0, first_rung);
  523. first_logic.insert(QStringLiteral("rungs"), first_rungs);
  524. missing_comment_logics.replace(0, first_logic);
  525. missing_rung_comment.insert(QStringLiteral("controlLogics"), missing_comment_logics);
  526. writeText(
  527. missing_rung_comment_path,
  528. QJsonDocument(missing_rung_comment).toJson(QJsonDocument::Compact));
  529. missing_result = service.load(missing_rung_comment_path.toStdString());
  530. require(!missing_result.succeeded
  531. && missing_result.storageError == ProjectStorageError::MissingField,
  532. "the 1.0 schema must require rung comments without migration defaults");
  533. QJsonObject multiline_register_comment = QJsonDocument::fromJson(
  534. saved_json).object();
  535. QJsonArray comments = multiline_register_comment.value(
  536. QStringLiteral("registerComments")).toArray();
  537. QJsonObject first_comment = comments.at(0).toObject();
  538. first_comment.insert(QStringLiteral("text"), QStringLiteral("第一行\n第二行"));
  539. comments.replace(0, first_comment);
  540. multiline_register_comment.insert(QStringLiteral("registerComments"), comments);
  541. writeText(
  542. multiline_register_comment_path,
  543. QJsonDocument(multiline_register_comment).toJson(QJsonDocument::Compact));
  544. missing_result = service.load(multiline_register_comment_path.toStdString());
  545. require(!missing_result.succeeded
  546. && missing_result.storageError == ProjectStorageError::InvalidProject,
  547. "JSON loading must reject multiline register comments");
  548. QJsonObject multiline_rung_comment = QJsonDocument::fromJson(saved_json).object();
  549. QJsonArray multiline_logics = multiline_rung_comment.value(
  550. QStringLiteral("controlLogics")).toArray();
  551. first_logic = multiline_logics.at(0).toObject();
  552. first_rungs = first_logic.value(QStringLiteral("rungs")).toArray();
  553. first_rung = first_rungs.at(0).toObject();
  554. first_rung.insert(QStringLiteral("comment"), QStringLiteral("第一行\n第二行"));
  555. first_rungs.replace(0, first_rung);
  556. first_logic.insert(QStringLiteral("rungs"), first_rungs);
  557. multiline_logics.replace(0, first_logic);
  558. multiline_rung_comment.insert(QStringLiteral("controlLogics"), multiline_logics);
  559. writeText(
  560. multiline_rung_comment_path,
  561. QJsonDocument(multiline_rung_comment).toJson(QJsonDocument::Compact));
  562. missing_result = service.load(multiline_rung_comment_path.toStdString());
  563. require(!missing_result.succeeded
  564. && missing_result.storageError == ProjectStorageError::InvalidProject,
  565. "JSON loading must reject multiline rung comments");
  566. QJsonObject missing_target = QJsonDocument::fromJson(saved_json).object();
  567. QJsonArray pages = missing_target.value(QStringLiteral("hmiPages")).toArray();
  568. QJsonObject main_page = pages.at(0).toObject();
  569. QJsonArray controls = main_page.value(QStringLiteral("controls")).toArray();
  570. QJsonObject jump = controls.at(5).toObject();
  571. jump.remove(QStringLiteral("targetPageId"));
  572. controls.replace(5, jump);
  573. main_page.insert(QStringLiteral("controls"), controls);
  574. pages.replace(0, main_page);
  575. missing_target.insert(QStringLiteral("hmiPages"), pages);
  576. writeText(
  577. missing_target_path,
  578. QJsonDocument(missing_target).toJson(QJsonDocument::Compact));
  579. missing_result = service.load(missing_target_path.toStdString());
  580. require(!missing_result.succeeded
  581. && missing_result.storageError == ProjectStorageError::MissingField,
  582. "the 1.0 schema must require PageJump targetPageId");
  583. QJsonObject missing_progress_range = QJsonDocument::fromJson(saved_json).object();
  584. pages = missing_progress_range.value(QStringLiteral("hmiPages")).toArray();
  585. main_page = pages.at(0).toObject();
  586. controls = main_page.value(QStringLiteral("controls")).toArray();
  587. QJsonObject progress = controls.at(7).toObject();
  588. progress.remove(QStringLiteral("maximumValue"));
  589. controls.replace(7, progress);
  590. main_page.insert(QStringLiteral("controls"), controls);
  591. pages.replace(0, main_page);
  592. missing_progress_range.insert(QStringLiteral("hmiPages"), pages);
  593. writeText(
  594. missing_progress_range_path,
  595. QJsonDocument(missing_progress_range).toJson(QJsonDocument::Compact));
  596. missing_result = service.load(missing_progress_range_path.toStdString());
  597. require(!missing_result.succeeded
  598. && missing_result.storageError == ProjectStorageError::MissingField,
  599. "the 1.0 schema must require the ProgressBar value range");
  600. }
  601. void testInvalidFiles()
  602. {
  603. // 非法文件必须被拒绝,并且不得覆盖服务中当前工程
  604. QTemporaryDir directory;
  605. require(directory.isValid(), "temporary directory must be valid");
  606. JsonProjectStorage storage;
  607. ProjectService service(storage);
  608. service.editProject().metadata.name = "Current project";
  609. const QString invalid_json = directory.filePath("invalid-json.json");
  610. const QString missing_field = directory.filePath("missing-field.json");
  611. const QString unsupported_version = directory.filePath("unsupported-version.json");
  612. writeText(invalid_json, "{");
  613. auto result = service.load(invalid_json.toStdString());
  614. require(!result.succeeded
  615. && result.storageError == ProjectStorageError::InvalidJson,
  616. "invalid JSON must be rejected");
  617. require(service.project().metadata.name == "Current project",
  618. "invalid load must keep current project");
  619. writeText(missing_field, R"({"formatVersion":"1.0"})");
  620. result = service.load(missing_field.toStdString());
  621. require(!result.succeeded
  622. && result.storageError == ProjectStorageError::MissingField,
  623. "missing fields must be rejected");
  624. writeText(unsupported_version, R"({"formatVersion":"2.0"})");
  625. result = service.load(unsupported_version.toStdString());
  626. require(!result.succeeded
  627. && result.storageError == ProjectStorageError::UnsupportedVersion,
  628. "unsupported versions must be rejected");
  629. }
  630. void testQuantityFileLimits()
  631. {
  632. QTemporaryDir directory;
  633. require(directory.isValid(), "temporary directory must be valid");
  634. JsonProjectStorage storage;
  635. ProjectService service(storage);
  636. require(service.createNewProject("Quantity limits").succeeded,
  637. "the quantity-limit fixture project must be created");
  638. const QString oversized_path = directory.filePath("oversized.json");
  639. const QByteArray oversized(
  640. static_cast<int>(ProjectLimits::kMaximumProjectFileBytes + 1U), ' ');
  641. writeText(oversized_path, oversized);
  642. const ProjectLoadResult oversized_result =
  643. storage.load(oversized_path.toStdString());
  644. require(!oversized_result.succeeded
  645. && oversized_result.error == ProjectStorageError::InvalidJson,
  646. "a JSON file over 16 MiB must be rejected before parsing");
  647. const QString valid_path = directory.filePath("fixture.json");
  648. require(service.saveAs(valid_path.toStdString()).succeeded,
  649. "the quantity-limit fixture must be saved");
  650. QJsonObject root = QJsonDocument::fromJson(readBytes(valid_path)).object();
  651. QJsonArray too_many_pages;
  652. for (int index = 0;
  653. index <= static_cast<int>(ProjectLimits::kMaximumHmiPages);
  654. ++index)
  655. {
  656. too_many_pages.append(QJsonObject{});
  657. }
  658. root.insert(QStringLiteral("hmiPages"), too_many_pages);
  659. const QString too_many_pages_path = directory.filePath("too-many-pages.json");
  660. writeText(
  661. too_many_pages_path,
  662. QJsonDocument(root).toJson(QJsonDocument::Compact));
  663. const ProjectLoadResult too_many_pages_result =
  664. storage.load(too_many_pages_path.toStdString());
  665. require(!too_many_pages_result.succeeded
  666. && too_many_pages_result.error == ProjectStorageError::InvalidField,
  667. "a JSON page array over the configured limit must be rejected");
  668. service.editProject() = makeExampleProject();
  669. require(service.saveAs(valid_path.toStdString()).succeeded,
  670. "the nested-expression fixture must be saved");
  671. root = QJsonDocument::fromJson(readBytes(valid_path)).object();
  672. QJsonArray logics = root.value(QStringLiteral("controlLogics")).toArray();
  673. QJsonObject logic = logics.at(0).toObject();
  674. QJsonArray rungs = logic.value(QStringLiteral("rungs")).toArray();
  675. QJsonObject rung = rungs.at(0).toObject();
  676. QJsonObject leaf = rung.value(QStringLiteral("condition")).toObject();
  677. while (leaf.value(QStringLiteral("kind")).toString() != QStringLiteral("node"))
  678. {
  679. leaf = leaf.value(QStringLiteral("children")).toArray().at(0).toObject();
  680. }
  681. QJsonObject nested = leaf;
  682. for (int depth = 1;
  683. depth <= static_cast<int>(ProjectLimits::kMaximumExpressionDepth) + 1;
  684. ++depth)
  685. {
  686. QJsonObject sibling = leaf;
  687. sibling.insert(
  688. QStringLiteral("id"),
  689. QStringLiteral("json-depth-sibling-") + QString::number(depth));
  690. QJsonArray children;
  691. children.append(nested);
  692. children.append(sibling);
  693. QJsonObject parent;
  694. parent.insert(
  695. QStringLiteral("id"),
  696. QStringLiteral("json-depth-") + QString::number(depth));
  697. parent.insert(
  698. QStringLiteral("kind"),
  699. depth % 2 == 0 ? QStringLiteral("parallel") : QStringLiteral("series"));
  700. parent.insert(QStringLiteral("children"), children);
  701. nested = parent;
  702. }
  703. rung.insert(QStringLiteral("condition"), nested);
  704. rungs[0] = rung;
  705. logic.insert(QStringLiteral("rungs"), rungs);
  706. logics[0] = logic;
  707. root.insert(QStringLiteral("controlLogics"), logics);
  708. const QString deep_path = directory.filePath("too-deep.json");
  709. writeText(deep_path, QJsonDocument(root).toJson(QJsonDocument::Compact));
  710. const ProjectLoadResult deep_result = storage.load(deep_path.toStdString());
  711. require(!deep_result.succeeded
  712. && deep_result.error == ProjectStorageError::InvalidField,
  713. "a condition expression deeper than the configured limit must be rejected while parsing");
  714. }
  715. void testHmiPageJsonBoundaries()
  716. {
  717. // JSON 入口必须和页面领域校验使用同一组业务边界
  718. QTemporaryDir directory;
  719. require(directory.isValid(), "temporary directory must be valid");
  720. JsonProjectStorage storage;
  721. ProjectService service(storage);
  722. Project boundary_project = makeExampleProject();
  723. boundary_project.hmiPages.front().controls.clear();
  724. service.editProject() = std::move(boundary_project);
  725. const QString fixture_path = directory.filePath("hmi-page-boundary-fixture.json");
  726. require(service.saveAs(fixture_path.toStdString()).succeeded,
  727. "the HMI boundary fixture must be saved");
  728. const QJsonObject original_root =
  729. QJsonDocument::fromJson(readBytes(fixture_path)).object();
  730. const auto loadWithSize = [&](int width, int height, const QString &name)
  731. {
  732. QJsonObject root = original_root;
  733. QJsonArray pages = root.value(QStringLiteral("hmiPages")).toArray();
  734. QJsonObject page = pages.at(0).toObject();
  735. page.insert(QStringLiteral("width"), width);
  736. page.insert(QStringLiteral("height"), height);
  737. pages.replace(0, page);
  738. root.insert(QStringLiteral("hmiPages"), pages);
  739. const QString path = directory.filePath(name);
  740. writeText(path, QJsonDocument(root).toJson(QJsonDocument::Compact));
  741. return storage.load(path.toStdString());
  742. };
  743. require(!loadWithSize(
  744. ProjectLimits::kMinimumHmiPageWidth - 1,
  745. ProjectLimits::kDefaultHmiPageHeight,
  746. QStringLiteral("width-below-minimum.json"))
  747. .succeeded,
  748. "JSON must reject an HMI page width below 320");
  749. require(!loadWithSize(
  750. ProjectLimits::kMaximumHmiPageWidth + 1,
  751. ProjectLimits::kDefaultHmiPageHeight,
  752. QStringLiteral("width-above-maximum.json"))
  753. .succeeded,
  754. "JSON must reject an HMI page width above 1600");
  755. require(!loadWithSize(
  756. ProjectLimits::kDefaultHmiPageWidth,
  757. ProjectLimits::kMinimumHmiPageHeight - 1,
  758. QStringLiteral("height-below-minimum.json"))
  759. .succeeded,
  760. "JSON must reject an HMI page height below 200");
  761. require(!loadWithSize(
  762. ProjectLimits::kDefaultHmiPageWidth,
  763. ProjectLimits::kMaximumHmiPageHeight + 1,
  764. QStringLiteral("height-above-maximum.json"))
  765. .succeeded,
  766. "JSON must reject an HMI page height above 800");
  767. const ProjectLoadResult minimum_result = loadWithSize(
  768. ProjectLimits::kMinimumHmiPageWidth,
  769. ProjectLimits::kMinimumHmiPageHeight,
  770. QStringLiteral("minimum-size.json"));
  771. require(minimum_result.succeeded
  772. && minimum_result.project.hmiPages.front().width
  773. == ProjectLimits::kMinimumHmiPageWidth
  774. && minimum_result.project.hmiPages.front().height
  775. == ProjectLimits::kMinimumHmiPageHeight,
  776. "JSON must accept the minimum HMI page size 320x200");
  777. const ProjectLoadResult maximum_result = loadWithSize(
  778. ProjectLimits::kMaximumHmiPageWidth,
  779. ProjectLimits::kMaximumHmiPageHeight,
  780. QStringLiteral("maximum-size.json"));
  781. require(maximum_result.succeeded
  782. && maximum_result.project.hmiPages.front().width
  783. == ProjectLimits::kMaximumHmiPageWidth
  784. && maximum_result.project.hmiPages.front().height
  785. == ProjectLimits::kMaximumHmiPageHeight,
  786. "JSON must accept the maximum HMI page size 1600x800");
  787. }
  788. void testServiceStateAndSaveErrors()
  789. {
  790. // 保存路径和修改标记只在成功持久化后更新
  791. QTemporaryDir directory;
  792. require(directory.isValid(), "temporary directory must be valid");
  793. JsonProjectStorage storage;
  794. ProjectService service(storage);
  795. require(service.save().error == ProjectServiceError::FilePathRequired,
  796. "save without a current path must be rejected");
  797. require(service.createNewProject(" ").error
  798. == ProjectServiceError::InvalidProjectName,
  799. "blank project names must be rejected");
  800. const QString path = directory.filePath("state.json");
  801. service.editProject().metadata.name = "State project";
  802. require(service.saveAs(path.toStdString()).succeeded,
  803. "state project save must succeed");
  804. service.editProject().metadata.name = "Changed project";
  805. require(service.isModified(), "editing the project must mark it modified");
  806. require(service.save().succeeded, "save must use the current file path");
  807. require(!service.isModified(), "successful save must clear modified state");
  808. const QString failed_path = directory.filePath("missing/subdir/state.json");
  809. require(!service.saveAs(failed_path.toStdString()).succeeded,
  810. "save to an unavailable path must fail");
  811. require(service.currentFilePath() == path.toStdString(),
  812. "failed save as must keep the previous current path");
  813. }
  814. void testRegisterCommentService()
  815. {
  816. JsonProjectStorage storage;
  817. ProjectService project_service(storage);
  818. RegisterCommentService service(project_service);
  819. require(service.setComment(
  820. RegisterAddress{RegisterArea::D, 3}, " 目标温度 ").succeeded,
  821. "register comment service must create a trimmed D comment");
  822. require(service.setComment(
  823. RegisterAddress{RegisterArea::M, 2}, "启动信号").succeeded,
  824. "register comment service must create an M comment");
  825. require(service.comments().size() == 2U
  826. && service.comments().front().address.area() == RegisterArea::M
  827. && service.comments().front().address.index() == 2
  828. && service.comments().back().text == "目标温度",
  829. "register comments must be sorted by area and address");
  830. require(service.setComment(
  831. RegisterAddress{RegisterArea::M, 2}, "新的启动信号").succeeded
  832. && service.comments().size() == 2U
  833. && service.findComment(RegisterAddress{RegisterArea::M, 2})->text
  834. == "新的启动信号",
  835. "setting an existing address must update instead of duplicating it");
  836. require(!service.setComment(RegisterAddress{RegisterArea::M, 4}, " \t").succeeded,
  837. "blank register comments must be rejected by the service");
  838. require(service.setComment(
  839. RegisterAddress{RegisterArea::M, 4},
  840. std::string(ProjectLimits::kMaximumRegisterCommentBytes, 'a'))
  841. .succeeded,
  842. "a register comment at the byte limit must be accepted");
  843. require(!service.setComment(
  844. RegisterAddress{RegisterArea::M, 5},
  845. std::string(ProjectLimits::kMaximumRegisterCommentBytes + 1U, 'a'))
  846. .succeeded,
  847. "an oversized register comment must be rejected by the service");
  848. require(!service.setComment(
  849. RegisterAddress{RegisterArea::M, 5}, "第一行\n第二行").succeeded,
  850. "a multiline register comment must be rejected by the service");
  851. require(service.removeComment(RegisterAddress{RegisterArea::M, 2}).succeeded
  852. && service.findComment(RegisterAddress{RegisterArea::M, 2}) == nullptr,
  853. "register comments must be removable");
  854. require(!service.removeComment(RegisterAddress{RegisterArea::M, 2}).succeeded,
  855. "removing a missing register comment must fail explicitly");
  856. }
  857. } // namespace
  858. int main()
  859. {
  860. try
  861. {
  862. // 工程服务和 JSON 存储在同一测试进程中验证完整闭环
  863. testEmptyProjectRoundTrip();
  864. testUnconditionalOutputRoundTrip();
  865. testExampleProjectRoundTrip();
  866. testRegisterCommentService();
  867. testInvalidFiles();
  868. testQuantityFileLimits();
  869. testHmiPageJsonBoundaries();
  870. testServiceStateAndSaveErrors();
  871. }
  872. catch (const std::exception &error)
  873. {
  874. std::cerr << "project management tests failed: " << error.what() << '\n';
  875. return 1;
  876. }
  877. std::cout << "project management tests passed\n";
  878. return 0;
  879. }