From f5c4074f9cce6d18164c8da3c0a895066a7119c8 Mon Sep 17 00:00:00 2001 From: zhizhi wu <2377881365@qq.com> Date: Thu, 9 Sep 2021 17:42:05 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B7=B3=E8=BD=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ccsens/util/message/RecoveryWithStartRecipe.java | 1 + .../java/com/ccsens/util/message/SwitchoverProjectUtil.java | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/util/src/main/java/com/ccsens/util/message/RecoveryWithStartRecipe.java b/util/src/main/java/com/ccsens/util/message/RecoveryWithStartRecipe.java index d2a5c5e4..7dc39e9e 100644 --- a/util/src/main/java/com/ccsens/util/message/RecoveryWithStartRecipe.java +++ b/util/src/main/java/com/ccsens/util/message/RecoveryWithStartRecipe.java @@ -16,6 +16,7 @@ public class RecoveryWithStartRecipe extends BaseMessageDto{ @lombok.Data public static class Data{ private Long projectId; + private String url; } private Data data; diff --git a/util/src/main/java/com/ccsens/util/message/SwitchoverProjectUtil.java b/util/src/main/java/com/ccsens/util/message/SwitchoverProjectUtil.java index 306a77e6..bf9896cf 100644 --- a/util/src/main/java/com/ccsens/util/message/SwitchoverProjectUtil.java +++ b/util/src/main/java/com/ccsens/util/message/SwitchoverProjectUtil.java @@ -31,7 +31,7 @@ public class SwitchoverProjectUtil { util.amqpTemplate = this.amqpTemplate; } - public static void switchoverProject(Set userIdSet,Long projectId) throws JsonProcessingException { + public static void switchoverProject(Set userIdSet,Long projectId, String... params) throws JsonProcessingException { log.info("切换项目:{}--{}",projectId,userIdSet); //设定发送规则 MessageRule messageRule = MessageRule.defaultRule(MessageConstant.DomainType.User); @@ -39,6 +39,9 @@ public class SwitchoverProjectUtil { messageRule.setOfflineDiscard((byte) 1); //生成消息 RecoveryWithStartRecipe recoveryWithStartRecipe = new RecoveryWithStartRecipe(projectId); + if (params != null && params.length > 0) { + recoveryWithStartRecipe.getData().setUrl(params[0]); + } //封装成inMessage InMessage inMessage = new InMessage(); inMessage.setToDomain(MessageConstant.DomainType.User);