15 changed files with 165 additions and 13 deletions
@ -0,0 +1,4 @@ |
|||
package com.ccsens.signin.service; |
|||
|
|||
public interface IRelevanceUser { |
|||
} |
@ -0,0 +1,45 @@ |
|||
package com.ccsens.signin.service; |
|||
|
|||
import com.ccsens.signin.bean.dto.UserDto; |
|||
import com.ccsens.signin.persist.dao.ProjectDao; |
|||
import com.ccsens.util.RestTemplateUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.transaction.annotation.Propagation; |
|||
import org.springframework.transaction.annotation.Transactional; |
|||
|
|||
import javax.annotation.Resource; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
@Service |
|||
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class) |
|||
public class RelevanceUser implements IRelevanceUser{ |
|||
@Resource |
|||
private ProjectDao projectDao; |
|||
|
|||
/** |
|||
* 查询所有域名 |
|||
*/ |
|||
public List<String> queryDomain() { |
|||
return projectDao.queryDomain(); |
|||
} |
|||
|
|||
/** |
|||
* 调用业务系统关联成员 |
|||
*/ |
|||
public void relevancePhone(String phone, Long userId) { |
|||
//查询所有的域连接
|
|||
List<String> domainList = queryDomain(); |
|||
//传入手机号和userId,循环调用每个域内关联成员的接口
|
|||
UserDto.PhoneAndUserId phoneAndUserId = new UserDto.PhoneAndUserId(); |
|||
phoneAndUserId.setPhone(phone); |
|||
phoneAndUserId.setUserId(userId); |
|||
domainList.forEach(domain -> { |
|||
RestTemplateUtil.postBody(domain + "/memberWithPhone", phoneAndUserId); |
|||
}); |
|||
} |
|||
} |
@ -1,5 +1,5 @@ |
|||
spring: |
|||
profiles: |
|||
active: dev |
|||
include: util-dev,common |
|||
active: prod |
|||
include: util-prod,common |
|||
|
|||
|
Loading…
Reference in new issue