suyu
/
suyu_two
1
0
Форк 0
Код Проблеми 0 Запити на злиття 0 Релізи 0 Вікі Активність
综合平台编程器项目的远程存储
Ви не можете вибрати більше 25 тем Теми мають розпочинатися з літери або цифри, можуть містити дефіси (-) і не повинні перевищувати 35 символів.
148 Коміти
1 Гілка
183 MiB
 
 
 
 
Дерево: e6c1666fd4
Гілки Теги
${ item.name }
Створити гілку ${ searchTerm }
з 'e6c1666fd4'
${ noResults }
suyu_two/app/tests/runtime_mode_service_tests.cpp

486 рядки
19 KiB
Неформатований Звинувачення Історія 

  1. #include "services/runtime_mode_service.h"

  2. #include "services/logic_editor_service.h"

  3. #include "services/offline_simulation_service.h"

  4. #include "services/project_service.h"

  5. #include "domain/active_register_repository.h"

  6. #include "domain/project_storage.h"

  7. #include "domain/register_repository.h"

  8. #include "domain/virtual_register_repository.h"

  9. #include "support/test_support.h"

  10. 

  11. #include <functional>

  12. #include <iostream>

  13. #include <stdexcept>

  14. #include <string>

  15. #include <utility>

  16. 

  17. namespace {

  18. 

  19. using TestProjectStorage = TestSupport::InMemoryProjectStorage;

  20. 

  21. class ReadyPlcGateway final : public PlcCommunicationGateway

  22. {

  23. public:

  24.     PlcCommunicationResult connectDevice(const PlcSerialConfiguration &) override

  25.     {

  26.         connection_state = PlcConnectionState::Connected;

  27.         if (state_changed)

  28.         {

  29.             state_changed();

  30.         }

  31.         return {true, {}};

  32.     }

  33. 

  34.     void disconnectDevice() override

  35.     {

  36.         connection_state = PlcConnectionState::Disconnected;

  37.         initial_read = false;

  38.     }

  39. 

  40.     PlcCommunicationResult setPollAddresses(

  41.         const std::vector<RegisterAddress> &addresses) override

  42.     {

  43.         return setPollAddresses(addresses, {});

  44.     }

  45. 

  46.     PlcCommunicationResult setPollAddresses(

  47.         const std::vector<RegisterAddress> &addresses,

  48.         const std::vector<RegisterWordRange> &ranges) override

  49.     {

  50.         if (reject_poll_configuration)

  51.         {

  52.             return {false, "poll configuration rejected"};

  53.         }

  54.         poll_addresses = addresses;

  55.         poll_ranges = ranges;

  56.         return {true, {}};

  57.     }

  58.     PlcConnectionState state() const override { return connection_state; }

  59.     bool initialReadCompleted() const override { return initial_read; }

  60.     PlcCommunicationError lastErrorType() const override

  61.     {

  62.         return PlcCommunicationError::None;

  63.     }

  64.     const std::string &lastError() const override { return last_error; }

  65. 

  66.     void setCallbacks(

  67.         std::function<void()> state_callback,

  68.         std::function<void(bool)> initial_callback,

  69.         std::function<void()> cache_callback,

  70.         std::function<void()> poll_cycle_callback,

  71.         std::function<void(const std::string &)> error_callback) override

  72.     {

  73.         state_changed = std::move(state_callback);

  74.         initial_read_changed = std::move(initial_callback);

  75.         cache_updated = std::move(cache_callback);

  76.         poll_cycle_completed = std::move(poll_cycle_callback);

  77.         error_reported = std::move(error_callback);

  78.     }

  79. 

  80.     void completeInitialRead()

  81.     {

  82.         initial_read = true;

  83.         if (initial_read_changed)

  84.         {

  85.             initial_read_changed(true);

  86.         }

  87.     }

  88. 

  89.     void completePollCycle()

  90.     {

  91.         if (poll_cycle_completed)

  92.         {

  93.             poll_cycle_completed();

  94.         }

  95.     }

  96. 

  97.     const std::vector<RegisterAddress> &pollAddresses() const

  98.     {

  99.         return poll_addresses;

  100.     }

  101. 

  102.     const std::vector<RegisterWordRange> &pollRanges() const

  103.     {

  104.         return poll_ranges;

  105.     }

  106. 

  107.     bool reject_poll_configuration = false;

  108. 

  109. private:

  110.     PlcConnectionState connection_state = PlcConnectionState::Disconnected;

  111.     bool initial_read = false;

  112.     std::string last_error;

  113.     std::function<void()> state_changed;

  114.     std::function<void(bool)> initial_read_changed;

  115.     std::function<void()> cache_updated;

  116.     std::function<void()> poll_cycle_completed;

  117.     std::function<void(const std::string &)> error_reported;

  118.     std::vector<RegisterAddress> poll_addresses;

  119.     std::vector<RegisterWordRange> poll_ranges;

  120. };

  121. 

  122. using TestSupport::require;

  123. 

  124. void setConditionPath(LadderRung *rung, LogicNode node)

  125. {

  126.     for (int column = 0;

  127.          column < ProjectLimits::kMaximumConditionColumns;

  128.          ++column)

  129.     {

  130.         rung->cells.push_back({

  131.             rung->id + "-cell-" + std::to_string(column),

  132.             column == 0 ? LadderCellKind::Node : LadderCellKind::Wire,

  133.             column == 0 ? std::optional<LogicNode>{node} : std::nullopt});

  134.     }

  135. }

  136. 

  137. void testModeTransitions()

  138. {

  139.     // 验证服务将 PLC 首读状态与领域模式切换规则正确组合

  140.     TestProjectStorage storage;

  141.     ProjectService project_service(storage, defaultProjectLimitSettings());

  142.     VirtualRegisterRepository virtual_repository;

  143.     VirtualRegisterRepository plc_repository;

  144.     ActiveRegisterRepository active_repository(virtual_repository);

  145.     OfflineSimulationService simulation_service(virtual_repository);

  146.     OnlineLogicMonitorService online_monitor_service(plc_repository);

  147.     LogicEditorService logic_editor_service(project_service);

  148.     ReadyPlcGateway gateway;

  149.     RuntimeModeService service(

  150.         project_service,

  151.         logic_editor_service,

  152.         simulation_service,

  153.         online_monitor_service);

  154.     service.configurePlc(

  155.         gateway, active_repository, virtual_repository, plc_repository);

  156. 

  157.     Project &project = project_service.editProject();

  158.     HmiPage page;

  159.     page.id = "runtime-page";

  160.     page.name = "Runtime";

  161.     HmiControl int32_display;

  162.     int32_display.id = "runtime-int32";

  163.     int32_display.type = HmiControlType::NumericDisplay;

  164.     int32_display.bounds = {0, 0, 100, 40};

  165.     int32_display.binding = RegisterAddress{RegisterArea::D, 50};

  166.     int32_display.dataType = RegisterDataType::Int32;

  167.     page.controls.push_back(int32_display);

  168.     HmiControl double_display = int32_display;

  169.     double_display.id = "runtime-double";

  170.     double_display.bounds = {120, 0, 100, 40};

  171.     double_display.binding = RegisterAddress{RegisterArea::D, 60};

  172.     double_display.dataType = RegisterDataType::Float64;

  173.     page.controls.push_back(double_display);

  174.     HmiControl double_status = int32_display;

  175.     double_status.id = "runtime-double-status";

  176.     double_status.type = HmiControlType::StatusText;

  177.     double_status.bounds = {240, 0, 140, 40};

  178.     double_status.binding = RegisterAddress{RegisterArea::D, 70};

  179.     double_status.dataType = RegisterDataType::Float64;

  180.     double_status.statusText = HmiStatusWordTextConfig{{

  181.         {std::nullopt, 0.0, "Low"},

  182.         {0.0, std::nullopt, "High"}}};

  183.     page.controls.push_back(double_status);

  184.     project.initialHmiPageId = page.id;

  185.     project.hmiPages.push_back(page);

  186.     project.alarmDefinitions.push_back(

  187.         {"alarm-m", {RegisterArea::M, 12}, AlarmCondition::MOn, 0, "M alarm"});

  188.     project.alarmDefinitions.push_back(

  189.         {"alarm-d", {RegisterArea::D, 34}, AlarmCondition::DHigh, 100, "D alarm"});

  190.     project.registerComments = {

  191.         {RegisterAddress{RegisterArea::M, 3999}, "只用于说明"},

  192.         {RegisterAddress{RegisterArea::D, 3999}, "只用于说明"}};

  193. 

  194.     ControlLogic logic;

  195.     logic.id = "poll-logic";

  196.     logic.name = "Poll logic";

  197.     LogicNode edge;

  198.     edge.id = "poll-edge";

  199.     edge.config = EdgeContactNodeConfig{

  200.         RegisterAddress{RegisterArea::M, 20}, EdgeMode::Rising};

  201.     LogicNode edge_coil;

  202.     edge_coil.id = "poll-edge-coil";

  203.     edge_coil.config = CoilNodeConfig{

  204.         RegisterAddress{RegisterArea::M, 21}, CoilMode::Normal};

  205.     LadderRung edge_rung;

  206.     edge_rung.id = "poll-edge-rung";

  207.     edge_rung.name = "Poll edge";

  208.     setConditionPath(&edge_rung, edge);

  209.     edge_rung.output = edge_coil;

  210.     logic.rungs.push_back(edge_rung);

  211.     LogicNode comparison;

  212.     comparison.id = "poll-comparison";

  213.     comparison.config = CompareNodeConfig{

  214.         RegisterAddress{RegisterArea::D, 35}, ComparisonOperator::GreaterThan, 0};

  215.     LogicNode comparison_coil;

  216.     comparison_coil.id = "poll-comparison-coil";

  217.     comparison_coil.config = CoilNodeConfig{

  218.         RegisterAddress{RegisterArea::M, 22}, CoilMode::Normal};

  219.     LadderRung comparison_rung;

  220.     comparison_rung.id = "poll-comparison-rung";

  221.     comparison_rung.name = "Poll comparison";

  222.     setConditionPath(&comparison_rung, comparison);

  223.     comparison_rung.output = comparison_coil;

  224.     logic.rungs.push_back(comparison_rung);

  225.     LogicNode move_input;

  226.     move_input.id = "poll-move-input";

  227.     move_input.config = ContactNodeConfig{

  228.         RegisterAddress{RegisterArea::M, 27}, ContactMode::NormallyOpen};

  229.     LogicNode move_output;

  230.     move_output.id = "poll-move";

  231.     move_output.config = MoveNodeConfig{

  232.         WordOperand{

  233.             WordOperandKind::Register,

  234.             RegisterAddress{RegisterArea::D, 38},

  235.             0},

  236.         RegisterAddress{RegisterArea::D, 39}};

  237.     LadderRung move_rung;

  238.     move_rung.id = "poll-move-rung";

  239.     move_rung.name = "Poll MOVE";

  240.     setConditionPath(&move_rung, move_input);

  241.     move_rung.output = move_output;

  242.     logic.rungs.push_back(move_rung);

  243.     LogicNode add_input;

  244.     add_input.id = "poll-add-input";

  245.     add_input.config = ContactNodeConfig{

  246.         RegisterAddress{RegisterArea::M, 28}, ContactMode::NormallyOpen};

  247.     LogicNode add_output;

  248.     add_output.id = "poll-add";

  249.     add_output.config = ArithmeticNodeConfig{

  250.         ArithmeticOperation::Add,

  251.         WordOperand{

  252.             WordOperandKind::Register,

  253.             RegisterAddress{RegisterArea::D, 40},

  254.             0},

  255.         WordOperand{

  256.             WordOperandKind::Constant,

  257.             RegisterAddress{RegisterArea::D, 0},

  258.             1},

  259.         RegisterAddress{RegisterArea::D, 41}};

  260.     LadderRung add_rung;

  261.     add_rung.id = "poll-add-rung";

  262.     add_rung.name = "Poll ADD";

  263.     setConditionPath(&add_rung, add_input);

  264.     add_rung.output = add_output;

  265.     logic.rungs.push_back(add_rung);

  266.     project.controlLogics.push_back(logic);

  267. 

  268.     require(service.mode() == ApplicationMode::Editing,

  269.             "service must start in editing mode");

  270.     require(service.policy().allowsProjectEditing,

  271.             "editing mode must allow project editing");

  272. 

  273.     require(service.enterOfflineRunning().succeeded,

  274.             "editing mode must enter offline running");

  275.     require(service.simulationState() == SimulationState::Running,

  276.             "offline mode must start the software executor");

  277.     require(service.policy().usesVirtualRegisters,

  278.             "offline running must use virtual registers");

  279.     require(service.enterOnlineRunning().error

  280.                 == ModeTransitionError::MustReturnToEditing,

  281.             "running modes must not switch directly");

  282. 

  283.     require(service.enterEditing().succeeded,

  284.             "offline running must return to editing");

  285.     require(service.simulationState() == SimulationState::Stopped,

  286.             "returning to editing must stop the software executor first");

  287.     require(service.enterOnlineRunning().error

  288.                 == ModeTransitionError::InitialPlcReadRequired,

  289.             "online running must require an initial PLC read");

  290. 

  291.     require(service.connectPlc(

  292.                 {"COM9", 1, 9600, 8, 2, 1, 1000, 2, 200}).succeeded,

  293.             "PLC connection must be established before its initial read can complete");

  294.     require(gateway.pollAddresses()

  295.                 == std::vector<RegisterAddress>({

  296.                     {RegisterArea::M, 12}, {RegisterArea::M, 20},

  297.                     {RegisterArea::M, 21}, {RegisterArea::M, 22},

  298.                     {RegisterArea::M, 27}, {RegisterArea::M, 28},

  299.                     {RegisterArea::D, 34}, {RegisterArea::D, 35},

  300.                     {RegisterArea::D, 38}, {RegisterArea::D, 39},

  301.                     {RegisterArea::D, 40}, {RegisterArea::D, 41},

  302.                     {RegisterArea::D, 50}, {RegisterArea::D, 51},

  303.                     {RegisterArea::D, 60}, {RegisterArea::D, 61},

  304.                     {RegisterArea::D, 62}, {RegisterArea::D, 63},

  305.                     {RegisterArea::D, 70}, {RegisterArea::D, 71},

  306.                     {RegisterArea::D, 72}, {RegisterArea::D, 73}})

  307.                 && gateway.pollRanges()

  308.                     == std::vector<RegisterWordRange>({

  309.                         {{RegisterArea::D, 50}, 2},

  310.                         {{RegisterArea::D, 60}, 4},

  311.                         {{RegisterArea::D, 70}, 4}}),

  312.             "instructions and multi-word status text must be fully polled while comments stay metadata-only");

  313.     gateway.completeInitialRead();

  314.     require(service.initialPlcReadCompleted(),

  315.             "service must retain the initial PLC read state");

  316.     plc_repository.writeBit({RegisterArea::M, 20}, true);

  317.     require(service.enterOnlineRunning().succeeded,

  318.             "online running must start after an initial PLC read");

  319.     require(service.simulationState() == SimulationState::Stopped,

  320.             "online running must keep the offline executor stopped");

  321.     require(service.onlineLogicMonitorService().state()

  322.                 == OnlineLogicMonitorState::Running,

  323.             "online running must start the local read-only trace executor");

  324.     require(!plc_repository.readBit({RegisterArea::M, 21}).value,

  325.             "the local trace output must not change the PLC source repository");

  326.     require(service.policy().usesPlcRegisters,

  327.             "online running must use PLC registers");

  328.     require(service.policy().runsLogicExecutor,

  329.             "online running must advertise the local read-only trace executor");

  330.     const std::uint64_t scan_count = service.onlineLogicMonitorService()

  331.         .successfulScanCount();

  332.     gateway.completePollCycle();

  333.     require(service.onlineLogicMonitorService().successfulScanCount()

  334.                 == scan_count + 1U,

  335.             "a completed PLC poll cycle must trigger one new local trace scan");

  336. }

  337. 

  338. void testMonitorPollRangeRollback()

  339. {

  340.     TestProjectStorage storage;

  341.     ProjectService project_service(storage, defaultProjectLimitSettings());

  342.     VirtualRegisterRepository virtual_repository;

  343.     VirtualRegisterRepository plc_repository;

  344.     ActiveRegisterRepository active_repository(virtual_repository);

  345.     OfflineSimulationService simulation_service(virtual_repository);

  346.     OnlineLogicMonitorService online_monitor_service(plc_repository);

  347.     LogicEditorService logic_editor_service(project_service);

  348.     ReadyPlcGateway gateway;

  349.     RuntimeModeService service(

  350.         project_service,

  351.         logic_editor_service,

  352.         simulation_service,

  353.         online_monitor_service);

  354.     service.configurePlc(

  355.         gateway, active_repository, virtual_repository, plc_repository);

  356. 

  357.     gateway.reject_poll_configuration = true;

  358.     const PlcCommunicationResult rejected = service.setMonitorAddresses(

  359.         {{RegisterArea::D, 100}, {RegisterArea::D, 101},

  360.          {RegisterArea::D, 102}, {RegisterArea::D, 103}},

  361.         {{{RegisterArea::D, 100}, 4}});

  362.     require(!rejected.succeeded,

  363.             "a gateway-rejected Double monitor range must fail atomically");

  364. 

  365.     gateway.reject_poll_configuration = false;

  366.     require(service.refreshPlcPollAddresses().succeeded

  367.                 && gateway.pollAddresses().empty()

  368.                 && gateway.pollRanges().empty(),

  369.             "a rejected monitor candidate must not remain in runtime poll state");

  370. }

  371. 

  372. void testDisconnectedOutputBlocksOfflineAndOnlineRuntime()

  373. {

  374.     TestProjectStorage storage;

  375.     ProjectService project_service(storage, defaultProjectLimitSettings());

  376.     VirtualRegisterRepository virtual_repository;

  377.     VirtualRegisterRepository plc_repository;

  378.     ActiveRegisterRepository active_repository(virtual_repository);

  379.     OfflineSimulationService simulation_service(virtual_repository);

  380.     OnlineLogicMonitorService online_monitor_service(plc_repository);

  381.     LogicEditorService logic_editor_service(project_service);

  382.     ReadyPlcGateway gateway;

  383.     RuntimeModeService service(

  384.         project_service,

  385.         logic_editor_service,

  386.         simulation_service,

  387.         online_monitor_service);

  388.     service.configurePlc(

  389.         gateway, active_repository, virtual_repository, plc_repository);

  390. 

  391.     ControlLogic logic;

  392.     logic.id = "broken-logic";

  393.     logic.name = "断路逻辑";

  394.     LadderRung rung;

  395.     rung.id = "broken-rung";

  396.     rung.name = "行 1";

  397.     for (int column = 0;

  398.          column < ProjectLimits::kMaximumConditionColumns;

  399.          ++column)

  400.     {

  401.         rung.cells.push_back({

  402.             "broken-cell-" + std::to_string(column),

  403.             LadderCellKind::Gap,

  404.             std::nullopt});

  405.     }

  406.     rung.output = LogicNode{

  407.         "broken-output",

  408.         CoilNodeConfig{

  409.             RegisterAddress{RegisterArea::M, 60}, CoilMode::Normal},

  410.         true};

  411.     logic.rungs.push_back(rung);

  412.     LadderRung unused;

  413.     unused.id = "unused-rung";

  414.     unused.name = "行 2";

  415.     for (int column = 0;

  416.          column < ProjectLimits::kMaximumConditionColumns;

  417.          ++column)

  418.     {

  419.         unused.cells.push_back({

  420.             "unused-cell-" + std::to_string(column),

  421.             column >= 3 && column <= 5

  422.                 ? LadderCellKind::Wire : LadderCellKind::Gap,

  423.             std::nullopt});

  424.     }

  425.     logic.rungs.push_back(unused);

  426.     project_service.editProject().controlLogics.push_back(logic);

  427.     logic_editor_service.clearHistory();

  428. 

  429.     const ModeTransitionResult offline = service.enterOfflineRunning();

  430.     require(

  431.         !offline.succeeded

  432.             && offline.error == ModeTransitionError::ProjectNotReady

  433.             && offline.detail.find("断路逻辑") != std::string::npos

  434.             && offline.detail.find("第 11 列") != std::string::npos

  435.             && offline.detail.find("第 1 列") != std::string::npos

  436.             && service.mode() == ApplicationMode::Editing

  437.             && simulation_service.state() == SimulationState::Stopped

  438.             && service.lastSyntaxCheck().changed

  439.             && service.lastSyntaxCheck().removedWireCells == 3U

  440.             && logic_editor_service.findCell(

  441.                 "broken-logic", "unused-rung", 3)->kind

  442.                 == LadderCellKind::Gap

  443.             && logic_editor_service.canUndo(),

  444.         "runtime preflight must normalize unused lines before rejecting a broken output");

  445. 

  446.     require(service.connectPlc(

  447.                 {"COM9", 1, 9600, 8, 2, 1, 1000, 2, 200}).succeeded,

  448.             "the online connectivity check requires a ready PLC cache");

  449.     gateway.completeInitialRead();

  450.     const ModeTransitionResult online = service.enterOnlineRunning();

  451.     require(

  452.         !online.succeeded

  453.             && online.error == ModeTransitionError::ProjectNotReady

  454.             && online.detail == offline.detail

  455.             && service.mode() == ApplicationMode::Editing

  456.             && online_monitor_service.state()

  457.                 == OnlineLogicMonitorState::Stopped

  458.             && !service.lastSyntaxCheck().changed

  459.             && logic_editor_service.undo().succeeded

  460.             && logic_editor_service.findCell(

  461.                 "broken-logic", "unused-rung", 3)->kind

  462.                 == LadderCellKind::Wire,

  463.         "the same disconnected output validation must block online runtime");

  464. }

  465. 

  466. } // namespace

  467. 

  468. int main()

  469. {

  470.     try

  471.     {

  472.         // 运行模式只有这一组状态机边界测试

  473.         testModeTransitions();

  474.         testMonitorPollRangeRollback();

  475.         testDisconnectedOutputBlocksOfflineAndOnlineRuntime();

  476.     }

  477.     catch (const std::exception &error)

  478.     {

  479.         std::cerr << "runtime mode service tests failed: " << error.what() << '\n';

  480.         return 1;

  481.     }

  482. 

  483.     std::cout << "runtime mode service tests passed\n";

  484.     return 0;

  485. }