| | |
|---|
| | | |
|---|
| | | private void saveRealtime(TTest test, TTestBattery battery) |
|---|
| | | { |
|---|
| | | // 柜端和采集器端分别判断成功；同一槽位只写一行，失败来源的身份、时间和指标保持为空。 |
|---|
| | | if (adapter == null) return; |
|---|
| | | TTestChannelBinding binding = battery.getBinding(); if (binding == null || binding.getDevid() == null || binding.getChlid() == null) return; |
|---|
| | | Instant now = clock.instant(); long interval = persistenceInterval(binding); String key = test.getTestId() + ":" + battery.getTestBatteryId(); |
|---|
| | |
|---|
| | | |
|---|
| | | private void saveDeviceAggregates(TTest test, TTestBattery battery) |
|---|
| | | { |
|---|
| | | // 工步、循环只接受设备直接返回的统计记录，并以来源编号或明确的时间组合执行幂等。 |
|---|
| | | if (adapter == null) return; TTestChannelBinding binding = battery.getBinding(); if (binding == null || binding.getDevid() == null || binding.getChlid() == null) return; |
|---|
| | | ChannelIdentity channel = new ChannelIdentity(binding.getAdapterCode(), binding.getDevtype(), binding.getDevid(), binding.getSubdevid(), binding.getChlid()); |
|---|
| | | List<StepRecord> steps; List<CycleRecord> cycles; try { steps = adapter.stepRecords(channel); cycles = adapter.cycleRecords(channel); } catch (RuntimeException ex) { return; } |
|---|
