|
@@ -4,9 +4,11 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.diagbot.client.AuthServiceClient;
|
|
import com.diagbot.client.AuthServiceClient;
|
|
|
|
+import com.diagbot.client.DiagbotmanClient;
|
|
import com.diagbot.dto.GetConsoleUserInfoDTO;
|
|
import com.diagbot.dto.GetConsoleUserInfoDTO;
|
|
import com.diagbot.dto.LoginDTO;
|
|
import com.diagbot.dto.LoginDTO;
|
|
import com.diagbot.dto.RespDTO;
|
|
import com.diagbot.dto.RespDTO;
|
|
|
|
+import com.diagbot.dto.UserAndProdutUDTO;
|
|
import com.diagbot.dto.UserInfoDTO;
|
|
import com.diagbot.dto.UserInfoDTO;
|
|
import com.diagbot.dto.UserInfoExportDTO;
|
|
import com.diagbot.dto.UserInfoExportDTO;
|
|
import com.diagbot.dto.UserOrgDTO;
|
|
import com.diagbot.dto.UserOrgDTO;
|
|
@@ -40,14 +42,9 @@ import com.diagbot.vo.UserInfoAuditVO;
|
|
import com.diagbot.vo.UserInfoOrganizationsVO;
|
|
import com.diagbot.vo.UserInfoOrganizationsVO;
|
|
import com.diagbot.vo.UserSaveVO;
|
|
import com.diagbot.vo.UserSaveVO;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
-import org.springframework.cache.annotation.CacheEvict;
|
|
|
|
-import org.springframework.cache.annotation.CachePut;
|
|
|
|
-import org.springframework.cache.annotation.Cacheable;
|
|
|
|
import org.springframework.security.crypto.factory.PasswordEncoderFactories;
|
|
import org.springframework.security.crypto.factory.PasswordEncoderFactories;
|
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
-import org.springframework.web.bind.annotation.RequestBody;
|
|
|
|
-import org.springframework.web.bind.annotation.RequestParam;
|
|
|
|
|
|
|
|
import java.io.Serializable;
|
|
import java.io.Serializable;
|
|
import java.util.ArrayList;
|
|
import java.util.ArrayList;
|
|
@@ -56,8 +53,6 @@ import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Map;
|
|
|
|
|
|
-import javax.validation.Valid;
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* @Description: 用户业务层
|
|
* @Description: 用户业务层
|
|
* @author: gaodm
|
|
* @author: gaodm
|
|
@@ -84,6 +79,8 @@ public class UserFacade extends UserServiceImpl {
|
|
UserAuthenticationFacade userAuthenticationFacade;
|
|
UserAuthenticationFacade userAuthenticationFacade;
|
|
@Autowired
|
|
@Autowired
|
|
PermissionFacade permissionFacade;
|
|
PermissionFacade permissionFacade;
|
|
|
|
+ @Autowired
|
|
|
|
+ DiagbotmanClient diagbotmanService;
|
|
|
|
|
|
/**
|
|
/**
|
|
* 注册
|
|
* 注册
|
|
@@ -351,7 +348,7 @@ public class UserFacade extends UserServiceImpl {
|
|
* @param user 新建用户信息输入参数
|
|
* @param user 新建用户信息输入参数
|
|
* @return 用户信息
|
|
* @return 用户信息
|
|
*/
|
|
*/
|
|
- @CachePut(value = CACHE_NAME, key = "'user:'+#p0['id']")
|
|
|
|
|
|
+ //@CachePut(value = CACHE_NAME, key = "'user:'+#p0['id']")
|
|
public User saveUser(User user) {
|
|
public User saveUser(User user) {
|
|
PasswordEncoder passwordEncoder = PasswordEncoderFactories.createDelegatingPasswordEncoder();
|
|
PasswordEncoder passwordEncoder = PasswordEncoderFactories.createDelegatingPasswordEncoder();
|
|
String entryPassword = passwordEncoder.encode(user.getPassword());
|
|
String entryPassword = passwordEncoder.encode(user.getPassword());
|
|
@@ -368,7 +365,7 @@ public class UserFacade extends UserServiceImpl {
|
|
* @param user 更新用户信息输入参数
|
|
* @param user 更新用户信息输入参数
|
|
* @return 用户信息
|
|
* @return 用户信息
|
|
*/
|
|
*/
|
|
- @CachePut(value = CACHE_NAME, key = "'user:'+#p0['id']")
|
|
|
|
|
|
+ //@CachePut(value = CACHE_NAME, key = "'user:'+#p0['id']")
|
|
public User updateUser(User user) {
|
|
public User updateUser(User user) {
|
|
PasswordEncoder passwordEncoder = PasswordEncoderFactories.createDelegatingPasswordEncoder();
|
|
PasswordEncoder passwordEncoder = PasswordEncoderFactories.createDelegatingPasswordEncoder();
|
|
String entryPassword = passwordEncoder.encode(user.getPassword());
|
|
String entryPassword = passwordEncoder.encode(user.getPassword());
|
|
@@ -386,7 +383,7 @@ public class UserFacade extends UserServiceImpl {
|
|
* @return 用户信息
|
|
* @return 用户信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Cacheable(value = CACHE_NAME, key = "'user:'+#p0")
|
|
|
|
|
|
+ //@Cacheable(value = CACHE_NAME, key = "'user:'+#p0")
|
|
public User getById(Serializable id) {
|
|
public User getById(Serializable id) {
|
|
return super.getById(id);
|
|
return super.getById(id);
|
|
}
|
|
}
|
|
@@ -398,7 +395,7 @@ public class UserFacade extends UserServiceImpl {
|
|
* @return 是否成功
|
|
* @return 是否成功
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @CacheEvict(value = CACHE_NAME, key = "'user:'+#p0")
|
|
|
|
|
|
+ //@CacheEvict(value = CACHE_NAME, key = "'user:'+#p0")
|
|
public boolean removeById(Serializable id) {
|
|
public boolean removeById(Serializable id) {
|
|
return super.removeById(id);
|
|
return super.removeById(id);
|
|
}
|
|
}
|
|
@@ -554,6 +551,7 @@ public class UserFacade extends UserServiceImpl {
|
|
auditMap.put("isReject", userInfoAuditVO.getIsReject());
|
|
auditMap.put("isReject", userInfoAuditVO.getIsReject());
|
|
auditMap.put("rejectComment", userInfoAuditVO.getRejectComment());
|
|
auditMap.put("rejectComment", userInfoAuditVO.getRejectComment());
|
|
auditMap.put("rejectType", userInfoAuditVO.getRejectType());
|
|
auditMap.put("rejectType", userInfoAuditVO.getRejectType());
|
|
|
|
+ auditMap.put("status", userInfoAuditVO.getStatus());
|
|
// TODO 审核前先验证该用户的的认证状态
|
|
// TODO 审核前先验证该用户的的认证状态
|
|
boolean res = auditUserInfoAll(auditMap);
|
|
boolean res = auditUserInfoAll(auditMap);
|
|
|
|
|
|
@@ -668,4 +666,46 @@ public class UserFacade extends UserServiceImpl {
|
|
}
|
|
}
|
|
return RespDTO.onSuc(res);
|
|
return RespDTO.onSuc(res);
|
|
}
|
|
}
|
|
|
|
+ /**
|
|
|
|
+ *
|
|
|
|
+ * @param page
|
|
|
|
+ * @param orgName
|
|
|
|
+ * @param autStatus
|
|
|
|
+ * @return 分页查询用户信息和机构信息开通产品
|
|
|
|
+ */
|
|
|
|
+ public RespDTO<UserInfoDTO> getUserOrganProductAlls(Page page, String orgName, Integer autStatus){
|
|
|
|
+
|
|
|
|
+ UserInfoDTO userInfo = new UserInfoDTO();
|
|
|
|
+ userInfo.setOrgName(orgName);
|
|
|
|
+ userInfo.setAutStatus(autStatus);
|
|
|
|
+ IPage<UserInfoDTO> user = selectUserInfoListPage(page, userInfo);
|
|
|
|
+ List<UserInfoDTO> userData = user.getRecords();
|
|
|
|
+ List<Long> userIds = new ArrayList<>();
|
|
|
|
+ for (UserInfoDTO userInfoDTO: userData){
|
|
|
|
+ Long userInfoId = userInfoDTO.getUserId();
|
|
|
|
+ userIds.add(userInfoId);
|
|
|
|
+ }
|
|
|
|
+ RespDTO<List<UserAndProdutUDTO>> InformationData = diagbotmanService.getInformationAvailableAll(userIds);
|
|
|
|
+
|
|
|
|
+ if(InformationData == null || !"0".equals(InformationData.code) ) {
|
|
|
|
+ throw new CommonException(CommonErrorCode.SERVER_IS_ERROR,
|
|
|
|
+ "获取所有开通信息失败");
|
|
|
|
+ }
|
|
|
|
+ Map<Long, List<UserAndProdutUDTO>> map = new HashMap<>();
|
|
|
|
+ //获取所有用户开通的产品信息
|
|
|
|
+ List<UserAndProdutUDTO> dataList = InformationData.data;
|
|
|
|
+ map = EntityUtil.makeEntityListMap(dataList,"userId");
|
|
|
|
+ if(map.size()>0){
|
|
|
|
+ for (UserInfoDTO userInfoDTO: userData){
|
|
|
|
+ List<UserAndProdutUDTO> userAndProdutUDTO = map.get(userInfoDTO.getUserId());
|
|
|
|
+ if(ListUtil.isNotEmpty(userAndProdutUDTO)){
|
|
|
|
+ userInfoDTO.setUserAndProdutUDTO(userAndProdutUDTO);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ System.out.println("===================="+GsonUtil.toJson(userData));
|
|
|
|
+ user.setRecords(userData);
|
|
|
|
+ return RespDTO.onSuc(user);
|
|
|
|
+ }
|
|
}
|
|
}
|