|
|
@ -31,7 +31,7 @@ public class SwitchoverProjectUtil { |
|
|
|
util.amqpTemplate = this.amqpTemplate; |
|
|
|
} |
|
|
|
|
|
|
|
public static void switchoverProject(Set<String> userIdSet,Long projectId) throws JsonProcessingException { |
|
|
|
public static void switchoverProject(Set<String> 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); |
|
|
|