|
@@ -48,11 +48,12 @@ public class RenKeColdChainDataHandler extends AbstractColdChainDataHandler<RenK
|
|
|
public void heartbeat(RenKeColdChainMessageData data) {
|
|
|
processMonitorData(data, "heartbeat");
|
|
|
}
|
|
|
+
|
|
|
// 公共的处理方法
|
|
|
private void processMonitorData(RenKeColdChainMessageData data, String action) {
|
|
|
if (!monitorDataProcessorMap.isEmpty()) {
|
|
|
- AbsRenkeMonitorDataProcessor monitorDataProcessor = (AbsRenkeMonitorDataProcessor) monitorDataProcessorMap.get(0);
|
|
|
- if (monitorDataProcessor != null) {
|
|
|
+ MonitorDataProcessor<?> monitorDataProcessor1 = monitorDataProcessorMap.get(monitorDataProcessorMap.keySet().iterator().next());
|
|
|
+ if (monitorDataProcessor1 instanceof AbsRenkeMonitorDataProcessor monitorDataProcessor) {
|
|
|
// 根据 action 调用相应的方法
|
|
|
switch (action) {
|
|
|
case "login":
|
|
@@ -65,8 +66,6 @@ public class RenKeColdChainDataHandler extends AbstractColdChainDataHandler<RenK
|
|
|
log.error("Unsupported action: {}", action);
|
|
|
break;
|
|
|
}
|
|
|
- } else {
|
|
|
- log.error("No valid processor found.");
|
|
|
}
|
|
|
} else {
|
|
|
log.warn("Monitor data processor map is empty.");
|