|
|
@ -38,7 +38,10 @@ public class RelevanceUserService implements IRelevanceUserService { |
|
|
|
//传入手机号和userId,循环调用每个域内关联成员的接口
|
|
|
|
domainList.forEach(domain -> { |
|
|
|
try { |
|
|
|
RestTemplateUtil.postBody(domain + "/user/memberWithPhone", new UserDto.PhoneAndUserId(phone,userId)); |
|
|
|
String url = domain + "/user/memberWithPhone"; |
|
|
|
UserDto.PhoneAndUserId phoneAndUserId = new UserDto.PhoneAndUserId(phone, userId); |
|
|
|
log.info("调用业务系统的接口关联成员:{}--{}",url,phoneAndUserId); |
|
|
|
RestTemplateUtil.postBody(url, phoneAndUserId); |
|
|
|
}catch (Exception e){ |
|
|
|
log.error("接口调用异常",e); |
|
|
|
} |
|
|
@ -56,7 +59,10 @@ public class RelevanceUserService implements IRelevanceUserService { |
|
|
|
//传入手机号和userId,循环调用每个域内关联成员的接口
|
|
|
|
domainList.forEach(domain -> { |
|
|
|
try { |
|
|
|
RestTemplateUtil.postBody(domain + "/user/mergeUser", new UserDto.MergeUser(oldUserId,newUserId)); |
|
|
|
String url = domain + "/user/mergeUser"; |
|
|
|
UserDto.MergeUser mergeUser = new UserDto.MergeUser(oldUserId, newUserId); |
|
|
|
log.info("调用业务系统的接口合并用户:{}--{}",url,mergeUser); |
|
|
|
RestTemplateUtil.postBody(url, mergeUser); |
|
|
|
}catch (Exception e){ |
|
|
|
log.error("接口调用异常",e); |
|
|
|
} |
|
|
|