添加token信息

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/listener/PublicWorkFlowMessage.java

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgInstallationNoticeServiceImpl;
+import com.yeejoin.amos.component.robot.AmosRequestContext;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import com.yeejoin.amos.feign.systemctl.model.TaskV2Model;
@@ -14,6 +15,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.component.emq.EmqxListener;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
 
 import javax.annotation.PostConstruct;
 import java.util.List;
@@ -24,6 +26,10 @@ public class PublicWorkFlowMessage extends EmqxListener {
 
     @Autowired
     protected EmqKeeper emqKeeper;
+
+    @Autowired
+    AmosRequestContext amosAuth;
+
     /**
      * 创建任务主题
      */
@@ -53,6 +59,9 @@ public class PublicWorkFlowMessage extends EmqxListener {
 
     @Override
     public void processMessage(String topic, MqttMessage message) throws Exception {
+        RequestContext.setAppKey(amosAuth.getAppKey());
+        RequestContext.setProduct(amosAuth.getProduct());
+        RequestContext.setToken(amosAuth.getToken());
         JSONObject messageObject = JSON.parseObject(new String(message.getPayload()));
         String businessKey = messageObject.get("businessKey").toString();
         String[] s = businessKey.split("_");