From b78295e8da96c3e5e76befeef9582ce5273dbb74 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期二, 29 九月 2026 13:10:23 +0800
Subject: [PATCH] 按代码规范检查整改实体注释、Service Javadoc 与分层边界
---
battery-business/src/main/java/com/battery/business/service/impl/PushIngestAdapter.java | 12 +++++++++++-
1 files changed, 11 insertions(+), 1 deletions(-)
diff --git a/battery-business/src/main/java/com/battery/business/service/impl/PushIngestAdapter.java b/battery-business/src/main/java/com/battery/business/service/impl/PushIngestAdapter.java
index 167a78f..7645d61 100644
--- a/battery-business/src/main/java/com/battery/business/service/impl/PushIngestAdapter.java
+++ b/battery-business/src/main/java/com/battery/business/service/impl/PushIngestAdapter.java
@@ -83,12 +83,14 @@
this.clock = clock;
}
+ /** 返回本实例登记的适配器编码；推送端点与通道身份都用它定位来源。 */
@Override
public String adapterCode()
{
return config.adapterCode();
}
+ /** 返回本实例登记的能力标记；推式来源同样只观测，不提供控制能力。 */
@Override
public AdapterCapabilities capabilities()
{
@@ -135,6 +137,12 @@
return Map.copyOf(result);
}
+ /**
+ * 返回该通道在落地表里最近一条采样行投影成的实时观测。
+ *
+ * @param channel 检测柜通道身份
+ * @return 最近一条采样行的实时观测；该通道还没有采样行时为空
+ */
@Override
public CabinetRealtime latestCabinet(ChannelIdentity channel)
{
@@ -169,6 +177,7 @@
return List.of();
}
+ /** 返回推式来源固定的持久化槽位间隔；采样行按来源自己的落库节奏到达。 */
@Override
public long persistenceIntervalMillis(ChannelIdentity channel)
{
@@ -213,7 +222,8 @@
java.util.Date receivedAt = records.selectHeartbeatAt(config.adapterCode());
if (receivedAt == null)
throw new DeviceAdapterException("SOURCE_OFFLINE",
- "尚未收到取数程序的推送：请确认程序已启动并指向 " + config.host() + ":" + config.port(), null);
+ "尚未收到取数程序的推送：请确认 " + config.host()
+ + " 那台机器上的取数程序已启动，并指向本系统的接收端点", null);
Duration staleAfter = staleAfter();
Duration silent = Duration.between(receivedAt.toInstant(), clock.instant());
if (silent.compareTo(staleAfter) > 0)
--
Gitblit v1.7.1