suyu
/
suyu_two
1
0
Forkuj 0
Kod Zgłoszenia 0 Oczekujące zmiany 0 Wydania 0 Wiki Aktywność
综合平台编程器项目的远程存储
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.
141 Commity
1 Gałąź
183 MiB
 
 
 
 
Drzewo: 4b2c8da7f2
Gałęzie Tagi
${ item.name }
Utwórz gałąź ${ searchTerm }
z '4b2c8da7f2'
${ noResults }
suyu_two/app/tests/runtime_mode_service_tests.cpp

473 wiersze
18 KiB
Czysty Wina Historia 

  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);

  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.     project.initialHmiPageId = page.id;

  175.     project.hmiPages.push_back(page);

  176.     project.alarmDefinitions.push_back(

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

  178.     project.alarmDefinitions.push_back(

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

  180.     project.registerComments = {

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

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

  183. 

  184.     ControlLogic logic;

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

  186.     logic.name = "Poll logic";

  187.     LogicNode edge;

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

  189.     edge.config = EdgeContactNodeConfig{

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

  191.     LogicNode edge_coil;

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

  193.     edge_coil.config = CoilNodeConfig{

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

  195.     LadderRung edge_rung;

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

  197.     edge_rung.name = "Poll edge";

  198.     setConditionPath(&edge_rung, edge);

  199.     edge_rung.output = edge_coil;

  200.     logic.rungs.push_back(edge_rung);

  201.     LogicNode comparison;

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

  203.     comparison.config = CompareNodeConfig{

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

  205.     LogicNode comparison_coil;

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

  207.     comparison_coil.config = CoilNodeConfig{

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

  209.     LadderRung comparison_rung;

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

  211.     comparison_rung.name = "Poll comparison";

  212.     setConditionPath(&comparison_rung, comparison);

  213.     comparison_rung.output = comparison_coil;

  214.     logic.rungs.push_back(comparison_rung);

  215.     LogicNode move_input;

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

  217.     move_input.config = ContactNodeConfig{

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

  219.     LogicNode move_output;

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

  221.     move_output.config = MoveNodeConfig{

  222.         WordOperand{

  223.             WordOperandKind::Register,

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

  225.             0},

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

  227.     LadderRung move_rung;

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

  229.     move_rung.name = "Poll MOVE";

  230.     setConditionPath(&move_rung, move_input);

  231.     move_rung.output = move_output;

  232.     logic.rungs.push_back(move_rung);

  233.     LogicNode add_input;

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

  235.     add_input.config = ContactNodeConfig{

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

  237.     LogicNode add_output;

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

  239.     add_output.config = ArithmeticNodeConfig{

  240.         ArithmeticOperation::Add,

  241.         WordOperand{

  242.             WordOperandKind::Register,

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

  244.             0},

  245.         WordOperand{

  246.             WordOperandKind::Constant,

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

  248.             1},

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

  250.     LadderRung add_rung;

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

  252.     add_rung.name = "Poll ADD";

  253.     setConditionPath(&add_rung, add_input);

  254.     add_rung.output = add_output;

  255.     logic.rungs.push_back(add_rung);

  256.     project.controlLogics.push_back(logic);

  257. 

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

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

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

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

  262. 

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

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

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

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

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

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

  269.     require(service.enterOnlineRunning().error

  270.                 == ModeTransitionError::MustReturnToEditing,

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

  272. 

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

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

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

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

  277.     require(service.enterOnlineRunning().error

  278.                 == ModeTransitionError::InitialPlcReadRequired,

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

  280. 

  281.     require(service.connectPlc(

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

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

  284.     require(gateway.pollAddresses()

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

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

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

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

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

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

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

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

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

  294.                     {RegisterArea::D, 62}, {RegisterArea::D, 63}})

  295.                 && gateway.pollRanges()

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

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

  298.                         {{RegisterArea::D, 60}, 4}}),

  299.             "all instruction M/D references must be polled while comments stay metadata-only");

  300.     gateway.completeInitialRead();

  301.     require(service.initialPlcReadCompleted(),

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

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

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

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

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

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

  308.     require(service.onlineLogicMonitorService().state()

  309.                 == OnlineLogicMonitorState::Running,

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

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

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

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

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

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

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

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

  318.         .successfulScanCount();

  319.     gateway.completePollCycle();

  320.     require(service.onlineLogicMonitorService().successfulScanCount()

  321.                 == scan_count + 1U,

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

  323. }

  324. 

  325. void testMonitorPollRangeRollback()

  326. {

  327.     TestProjectStorage storage;

  328.     ProjectService project_service(storage);

  329.     VirtualRegisterRepository virtual_repository;

  330.     VirtualRegisterRepository plc_repository;

  331.     ActiveRegisterRepository active_repository(virtual_repository);

  332.     OfflineSimulationService simulation_service(virtual_repository);

  333.     OnlineLogicMonitorService online_monitor_service(plc_repository);

  334.     LogicEditorService logic_editor_service(project_service);

  335.     ReadyPlcGateway gateway;

  336.     RuntimeModeService service(

  337.         project_service,

  338.         logic_editor_service,

  339.         simulation_service,

  340.         online_monitor_service);

  341.     service.configurePlc(

  342.         gateway, active_repository, virtual_repository, plc_repository);

  343. 

  344.     gateway.reject_poll_configuration = true;

  345.     const PlcCommunicationResult rejected = service.setMonitorAddresses(

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

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

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

  349.     require(!rejected.succeeded,

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

  351. 

  352.     gateway.reject_poll_configuration = false;

  353.     require(service.refreshPlcPollAddresses().succeeded

  354.                 && gateway.pollAddresses().empty()

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

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

  357. }

  358. 

  359. void testDisconnectedOutputBlocksOfflineAndOnlineRuntime()

  360. {

  361.     TestProjectStorage storage;

  362.     ProjectService project_service(storage);

  363.     VirtualRegisterRepository virtual_repository;

  364.     VirtualRegisterRepository plc_repository;

  365.     ActiveRegisterRepository active_repository(virtual_repository);

  366.     OfflineSimulationService simulation_service(virtual_repository);

  367.     OnlineLogicMonitorService online_monitor_service(plc_repository);

  368.     LogicEditorService logic_editor_service(project_service);

  369.     ReadyPlcGateway gateway;

  370.     RuntimeModeService service(

  371.         project_service,

  372.         logic_editor_service,

  373.         simulation_service,

  374.         online_monitor_service);

  375.     service.configurePlc(

  376.         gateway, active_repository, virtual_repository, plc_repository);

  377. 

  378.     ControlLogic logic;

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

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

  381.     LadderRung rung;

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

  383.     rung.name = "行 1";

  384.     for (int column = 0;

  385.          column < ProjectLimits::kMaximumConditionColumns;

  386.          ++column)

  387.     {

  388.         rung.cells.push_back({

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

  390.             LadderCellKind::Gap,

  391.             std::nullopt});

  392.     }

  393.     rung.output = LogicNode{

  394.         "broken-output",

  395.         CoilNodeConfig{

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

  397.         true};

  398.     logic.rungs.push_back(rung);

  399.     LadderRung unused;

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

  401.     unused.name = "行 2";

  402.     for (int column = 0;

  403.          column < ProjectLimits::kMaximumConditionColumns;

  404.          ++column)

  405.     {

  406.         unused.cells.push_back({

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

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

  409.                 ? LadderCellKind::Wire : LadderCellKind::Gap,

  410.             std::nullopt});

  411.     }

  412.     logic.rungs.push_back(unused);

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

  414.     logic_editor_service.clearHistory();

  415. 

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

  417.     require(

  418.         !offline.succeeded

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

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

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

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

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

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

  425.             && service.lastSyntaxCheck().changed

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

  427.             && logic_editor_service.findCell(

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

  429.                 == LadderCellKind::Gap

  430.             && logic_editor_service.canUndo(),

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

  432. 

  433.     require(service.connectPlc(

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

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

  436.     gateway.completeInitialRead();

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

  438.     require(

  439.         !online.succeeded

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

  441.             && online.detail == offline.detail

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

  443.             && online_monitor_service.state()

  444.                 == OnlineLogicMonitorState::Stopped

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

  446.             && logic_editor_service.undo().succeeded

  447.             && logic_editor_service.findCell(

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

  449.                 == LadderCellKind::Wire,

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

  451. }

  452. 

  453. } // namespace

  454. 

  455. int main()

  456. {

  457.     try

  458.     {

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

  460.         testModeTransitions();

  461.         testMonitorPollRangeRollback();

  462.         testDisconnectedOutputBlocksOfflineAndOnlineRuntime();

  463.     }

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

  465.     {

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

  467.         return 1;

  468.     }

  469. 

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

  471.     return 0;

  472. }