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);