| | |
|---|
| | | @Override public List<Map<String, Object>> records(Long testId) |
|---|
| | | { |
|---|
| | | requireTest(testId); |
|---|
| | | return applyEffectiveData(testId, "REALTIME", mapper.selectPersistedRecords(testId)); |
|---|
| | | List<Map<String, Object>> source = new java.util.ArrayList<>(); |
|---|
| | | List<Map<String, Object>> cabinet = mapper.selectPersistedRecords(testId); |
|---|
| | | List<Map<String, Object>> collector = mapper.selectPersistedCollectorRecords(testId); |
|---|
| | | if (cabinet != null) source.addAll(cabinet); |
|---|
| | | if (collector != null) source.addAll(collector); |
|---|
| | | return applyEffectiveData(testId, "REALTIME", source); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override public List<Map<String, Object>> steps(Long testId) |
|---|
| | |
|---|
| | | |
|---|
| | | private String stableIdentity(String dataType, Map<String, Object> row) |
|---|
| | | { |
|---|
| | | if ("REALTIME".equals(dataType) && "COLLECTOR".equals(String.valueOf(row.get("sourceType")))) |
|---|
| | | return String.join(":", "collector", identityPart(row, "collectorId"), |
|---|
| | | identityPart(row, "channelCode"), value(row, "sequenceId"), identityPart(row, "metricCode")); |
|---|
| | | String adapterId = identityPart(row, "adapterId"); |
|---|
| | | String devtype = identityPart(row, "devtype"); |
|---|
| | | String deviceId = identityPart(row, "deviceId"); |
|---|
