Browse Source

Merge branch 'tall3' of dd.tall.wiki:ccsens_wiki/ccsenscloud into tall3

tall3
zy_Java 4 years ago
parent
commit
37c8a2977d
  1. 1
      util/src/main/java/com/ccsens/util/message/RecoveryWithStartRecipe.java
  2. 5
      util/src/main/java/com/ccsens/util/message/SwitchoverProjectUtil.java

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

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

Loading…
Cancel
Save