diff --git a/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java b/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java
index f4500301..45db3a1b 100644
--- a/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java
+++ b/das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java
@@ -9,8 +9,12 @@ import com.das.modules.node.domain.bo.TerminalMessage;
 import com.fasterxml.jackson.databind.JsonNode;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
 import org.springframework.stereotype.Service;
 
+import java.util.concurrent.TimeUnit;
+
 @Slf4j
 @Service(value = NodeConstant.HEARTBEAT)
 public class HeartbeatCommand implements BaseCommand{
@@ -18,7 +22,7 @@ public class HeartbeatCommand implements BaseCommand{
     public static final long HEARTBEAT_TTL = 12L;
 
     @Autowired
-    AdminRedisTemplate adminRedisTemplate;
+    RedisTemplate<String,Object> redisTemplate;
 
     @Autowired
     CacheService cacheService;
@@ -35,16 +39,28 @@ public class HeartbeatCommand implements BaseCommand{
         // 解析心跳报文中的数据信息
         JsonNode dataInfo = data.getData();
         if (!dataInfo.isEmpty()) {
+            ValueOperations<String,Object> ops = redisTemplate.opsForValue();
             // 处理链路信息
             JsonNode links = data.getData().get("links");
             if (links != null && links.isArray()) {
                 for (JsonNode linkNode : links) {
                     String linkId = linkNode.get("linkId").asText();
                     boolean online = linkNode.get("online").asBoolean();
+                    JsonNode modbusNode = linkNode.get("modbus");
+                    if (modbusNode != null){
+                        boolean modbus = modbusNode.asBoolean();
+                        String key = String.format("link:%s:modbus", linkId);
+                        ops.set(key, modbus, HEARTBEAT_TTL, TimeUnit.SECONDS);
+                    }
+                    JsonNode ftpNode = linkNode.get("ftp");
+                    if (ftpNode != null){
+                        boolean ftp = ftpNode.asBoolean();
+                        String key = String.format("link:%s:ftp", linkId);
+                        ops.set(key, ftp, HEARTBEAT_TTL, TimeUnit.SECONDS);
+                    }
                     String key = String.format("link:%s:online", linkId);
                     // 更新链路在线状态到Redis
-                    adminRedisTemplate.set(key, online ? 1 : 0);
-                    adminRedisTemplate.expire(key, HEARTBEAT_TTL);
+                    ops.set(key, online?1:0, HEARTBEAT_TTL, TimeUnit.SECONDS);
                 }
             }
 
@@ -62,19 +78,18 @@ public class HeartbeatCommand implements BaseCommand{
                     // 判断是不是风机
                     String keyDeviceOnline = String.format("device:%d:online", deviceId);
                     // 更新设备在线状态到Redis
-                    adminRedisTemplate.set(keyDeviceOnline, online ? 1 : 0);
-                    adminRedisTemplate.expire(keyDeviceOnline, HEARTBEAT_TTL);
+                    ops.set(keyDeviceOnline, online ? 1 : 0, HEARTBEAT_TTL, TimeUnit.SECONDS);
 
                     String keyPLCDeviceStatus = String.format("RT:%d:iturbineoperationmode", deviceId);
                     String keyCommFaultState = String.format("RT:%d:commfaultstate",deviceId);
-                    Integer plcDeviceStatus = adminRedisTemplate.get(keyPLCDeviceStatus);
+                    Integer plcDeviceStatus = (Integer) ops.get(keyPLCDeviceStatus);
                     log.debug("设备ID:{},在线状态:{},通讯状态: {}", deviceId, online, plcDeviceStatus);
                     // 根据设备在线状态和通讯状态更新通讯故障状态
                     if (plcDeviceStatus == null){
-                        adminRedisTemplate.set(keyCommFaultState, online ? 0 : 1);
+                        ops.set(keyCommFaultState, online ? 0 : 1);
                     }
                     else{
-                        adminRedisTemplate.set(keyCommFaultState, online && (plcDeviceStatus != 0) ? 0 : 1);
+                        ops.set(keyCommFaultState, online && (plcDeviceStatus != 0) ? 0 : 1);
                     }
                 }
             }