diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
index 5a73219b..959993e5 100644
--- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
+++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
@@ -52,30 +52,17 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
             for (Device device : deviceList) {
                 if (device.getOpMode() != GnssDevice.OP_MODE_USE) continue;
                 String deviceId = device.getDeviceId();
-                /*if(deviceId.equals("2419385")){
-                    DeviceChannel channel = OnlineChannels.INSTANCE.getConfigChannel(deviceId);
-                    if(channel != null && channel.isOnline()){
-                        if (logger.isDebugEnabled()) {
-                            logger.debug("forward d331 rtcm message to device {} tcp", deviceId);
-                        }
-                        ByteBuf buf = Unpooled.buffer();
-                        buf.writeBytes(forwardBytes);
-                        channel.writeAndFlush(buf);
+                OnlineChannels.INSTANCE.get(deviceId).ifPresent(deviceChannel -> {
+                    if (logger.isDebugEnabled()) {
+                        logger.debug("forward d331 rtcm message to device {}", deviceId);
                     }
-                }
-                else {*/
-                    OnlineChannels.INSTANCE.get(deviceId).ifPresent(deviceChannel -> {
-                        if (logger.isDebugEnabled()) {
-                            logger.debug("forward d331 rtcm message to device {}", deviceId);
-                        }
-                        if (deviceId.startsWith("2307")) {
-                            forwardBytes[2] = (byte) (forwardBytes[2] & 0x07);//兼容不带序号的测站
-                        }
-                        ByteBuf buf = Unpooled.buffer();
-                        buf.writeBytes(forwardBytes);
-                        deviceChannel.writeAndFlush(buf);
-                    });
-                //}
+                    if (deviceId.startsWith("2307")) {
+                        forwardBytes[2] = (byte) (forwardBytes[2] & 0x07);//兼容不带序号的测站
+                    }
+                    ByteBuf buf = Unpooled.buffer();
+                    buf.writeBytes(forwardBytes);
+                    deviceChannel.writeAndFlush(buf);
+                });
             }
         }