fixed 产品修改

jetlinks-core/src/main/java/org/jetlinks/core/message/Message.java

@@ -44,6 +44,8 @@ public interface Message extends Jsonable, Serializable {
      */
     String getMessageId();
 
+
+    String setMessageId(String messageId);
     /**
      * @return 毫秒时间戳
      * @see System#currentTimeMillis()

jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/web/DeviceDirectiveController.java

@@ -71,6 +71,7 @@ public class DeviceDirectiveController implements
                     .flatMap(operator -> Mono.just(operator.messageSender()))
                     .flatMap(sender->{
                             directive.getDownstream().addHeader(Headers.async,true);
+                            directive.getDownstream().setMessageId(IdUtils.newUUID());
                             return sender.send(directive.getDownstream())
                                 .onErrorContinue((e,obj)->log.warn("指令重新发送失败{}",directive))
                                 .then();