diff --git a/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java b/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java
index b735216..d058a24 100644
--- a/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java
+++ b/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java
@@ -145,9 +145,11 @@ public class AlertMessageService {
             );
             alertMessageMapper.insertAlertMessage(alertMessage);
             }
-        //发送指令新建信号
+        //发送指令新建信号...实时任务 isJudged=1 才首次立刻下发
         try {
-            stateHandler.sendCommandDistributeSignal(commandUUIDs);
+            if (isJudged){
+                stateHandler.sendCommandDistributeSignal(commandUUIDs);
+            }
         }catch (Exception e) {
             log.info(String.format("动态任务首次指令下发c3出错，任务id: %d,commandUUIDs: %s",
                     dynamicTaskCommandInfoList.get(0).getTaskId(),
@@ -257,6 +259,7 @@ public class AlertMessageService {
         command1.setMaskDestinationPort(protectObject.getMaskPort());
         if (templateProtectLevel.getHasProtocol()){
             command1.setProtocolNum(Integer.valueOf(fiveTupleWithMask.getProtocol()));
+            command1.setProtocol(fiveTupleWithMask.getProtocol());
             command1.setMaskProtocol(fiveTupleWithMask.getMaskProtocol());
         }
 //        newFiveTupleWithMask.add(command1);
@@ -273,6 +276,7 @@ public class AlertMessageService {
         command2.setDestinationPort(peer.getPort());
         command2.setMaskDestinationPort(peer.getMaskPort());
         if (templateProtectLevel.getHasProtocol()){
+            command2.setProtocol(fiveTupleWithMask.getProtocol());
             command2.setProtocol(fiveTupleWithMask.getProtocol());
             command2.setMaskProtocol(fiveTupleWithMask.getMaskProtocol());
         }
diff --git a/src/main/java/com/realtime/protection/server/command/CommandService.java b/src/main/java/com/realtime/protection/server/command/CommandService.java
index 45b9362..850ef75 100644
--- a/src/main/java/com/realtime/protection/server/command/CommandService.java
+++ b/src/main/java/com/realtime/protection/server/command/CommandService.java
@@ -7,12 +7,14 @@ import com.realtime.protection.configuration.entity.task.TaskCommandInfo;
 import com.realtime.protection.configuration.entity.whitelist.WhiteListObject;
 import com.realtime.protection.configuration.utils.Counter;
 import com.realtime.protection.configuration.utils.SqlSessionWrapper;
+import com.realtime.protection.server.task.status.StateHandler;
 import com.realtime.protection.server.whitelist.WhiteListMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.Collections;
 import java.util.List;
 import java.util.UUID;
 import java.util.function.Function;
@@ -27,12 +29,14 @@ public class CommandService {
     private final Counter counter;
     private final WhiteListMapper whiteListMapper;
     private static final int BatchSize = 100;
+    private final StateHandler stateHandler;
 
-    public CommandService(CommandMapper commandMapper, SqlSessionWrapper sqlSessionWrapper, Counter counter, WhiteListMapper whiteListMapper) {
+    public CommandService(CommandMapper commandMapper, SqlSessionWrapper sqlSessionWrapper, Counter counter, WhiteListMapper whiteListMapper, StateHandler stateHandler) {
         this.commandMapper = commandMapper;
         this.sqlSessionWrapper = sqlSessionWrapper;
         this.counter = counter;
         this.whiteListMapper = whiteListMapper;
+        this.stateHandler = stateHandler;
     }
 
     @DSTransactional
@@ -132,8 +136,23 @@ public class CommandService {
         return commandMapper.removeCommandsByTaskId(taskId);
     }
 
-    public Boolean setCommandJudged(String commandId, Boolean isValid) {
-        return commandMapper.setCommandJudged(commandId, isValid);
+    public Boolean setCommandJudged(String commandId, Boolean isJudged) {
+        //设置指令是否已经研判
+        Boolean success = commandMapper.setCommandJudged(commandId, isJudged);
+
+        //isJudged为true时，发送指令首次 下发信号
+        try {
+            List<String> commandUUIDs = Collections.singletonList(commandId);
+            if (isJudged){
+                stateHandler.sendCommandDistributeSignal(commandUUIDs);
+            }
+        }catch (Exception e) {
+            log.info(String.format("动态任务研判后任务首次指令下发c3出错，任务id: %d,commandUUIDs: %s",
+                    queryCommandInfoByUUID(commandId).getTaskId(),
+                    commandId));
+        }
+
+        return success;
     }
 
     public Integer queryCommandTotalNum(Long taskId, String sourceIP, String sourcePort,