From 7b1e3a85f6f64690d96c87f9c2d8128c980ce17d Mon Sep 17 00:00:00 2001 From: WenG <450292408@qq.com> Date: Thu, 19 May 2022 13:09:49 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84mongo=E7=99=BB=E5=BD=95?= =?UTF-8?q?=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../login/mongo/IMongoLoginService.java | 16 +++++++ .../service/user/UserDetailServiceImpl.java | 2 +- mongo-login/pom.xml | 6 +++ .../service/impl/MongoLoginServiceImpl.java | 45 ++++++++++++++++++- 4 files changed, 66 insertions(+), 3 deletions(-) diff --git a/basic-interface/src/main/java/ink/wgink/interfaces/login/mongo/IMongoLoginService.java b/basic-interface/src/main/java/ink/wgink/interfaces/login/mongo/IMongoLoginService.java index abcffaba..f3f8c184 100644 --- a/basic-interface/src/main/java/ink/wgink/interfaces/login/mongo/IMongoLoginService.java +++ b/basic-interface/src/main/java/ink/wgink/interfaces/login/mongo/IMongoLoginService.java @@ -2,6 +2,8 @@ package ink.wgink.interfaces.login.mongo; import ink.wgink.pojo.pos.user.mongo.MongoUserPO; +import java.util.List; + /** * @ClassName: IMongoLoginService * @Description: mongo登录 @@ -11,6 +13,20 @@ import ink.wgink.pojo.pos.user.mongo.MongoUserPO; */ public interface IMongoLoginService { + /** + * 刷新mongo + * + * @param userId + */ + void update(String userId); + + /** + * 删除 + * + * @param userIds + */ + void delete(List userIds); + /** * 用户详情 * diff --git a/login-base/src/main/java/ink/wgink/login/base/service/user/UserDetailServiceImpl.java b/login-base/src/main/java/ink/wgink/login/base/service/user/UserDetailServiceImpl.java index e34089b5..c14dae4f 100644 --- a/login-base/src/main/java/ink/wgink/login/base/service/user/UserDetailServiceImpl.java +++ b/login-base/src/main/java/ink/wgink/login/base/service/user/UserDetailServiceImpl.java @@ -49,7 +49,7 @@ public class UserDetailServiceImpl implements UserDetailsService, IUserDetailChe username = userInfo; } // 通过用户名查询 - UserPO userPO = userService.getPOByUsername(username.toLowerCase());; + UserPO userPO = userService.getPOByUsername(username.toLowerCase()); if (null == userPO) { throw new UserAuthenticationException("账号不存在"); } diff --git a/mongo-login/pom.xml b/mongo-login/pom.xml index a91e9358..35847b99 100644 --- a/mongo-login/pom.xml +++ b/mongo-login/pom.xml @@ -18,6 +18,12 @@ spring-data-mongodb provided + + ink.wgink + service-user + 1.0-SNAPSHOT + provided + ink.wgink common diff --git a/mongo-login/src/main/java/ink/wgink/mongo/login/service/impl/MongoLoginServiceImpl.java b/mongo-login/src/main/java/ink/wgink/mongo/login/service/impl/MongoLoginServiceImpl.java index cd4a13f0..1352c3e9 100644 --- a/mongo-login/src/main/java/ink/wgink/mongo/login/service/impl/MongoLoginServiceImpl.java +++ b/mongo-login/src/main/java/ink/wgink/mongo/login/service/impl/MongoLoginServiceImpl.java @@ -1,14 +1,25 @@ package ink.wgink.mongo.login.service.impl; import ink.wgink.common.base.DefaultBaseService; +import ink.wgink.interfaces.department.IDepartmentUserBaseService; +import ink.wgink.interfaces.group.IGroupUserBaseService; import ink.wgink.interfaces.login.mongo.IMongoLoginService; +import ink.wgink.interfaces.position.IPositionUserBaseService; +import ink.wgink.interfaces.role.IRoleMenuBaseService; +import ink.wgink.interfaces.role.IRolePermissionBaseService; +import ink.wgink.interfaces.role.IRoleUserBaseService; import ink.wgink.pojo.pos.user.mongo.MongoUserPO; +import ink.wgink.service.user.pojo.pos.UserPO; +import ink.wgink.service.user.service.IUserService; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.stereotype.Service; +import java.util.List; + /** * @ClassName: MongoLoginServiceImpl * @Description: mongo登录 @@ -19,17 +30,47 @@ import org.springframework.stereotype.Service; @Service public class MongoLoginServiceImpl extends DefaultBaseService implements IMongoLoginService { + private static final String COLLECTION_NAME = "loginUser"; @Autowired private MongoTemplate mongoTemplate; + @Autowired + private IUserService userService; + @Autowired(required = false) + private IDepartmentUserBaseService departmentUserBaseService; + @Autowired(required = false) + private IRoleUserBaseService roleUserBaseService; + @Autowired(required = false) + private IRoleMenuBaseService roleMenuBaseService; + @Autowired(required = false) + private IRolePermissionBaseService rolePermissionService; + @Autowired(required = false) + private IGroupUserBaseService groupUserBaseService; + @Autowired(required = false) + private IPositionUserBaseService positionUserBaseService; + + @Override + public void update(String userId) { + UserPO userPO = userService.getPO(userId); + MongoUserPO mongoUserPO = new MongoUserPO(); + BeanUtils.copyProperties(userPO, mongoUserPO); + + + + } + + @Override + public void delete(List userIds) { + + } @Override public MongoUserPO getPO(String userId) { - return mongoTemplate.findOne(new Query().addCriteria(Criteria.where("userId").is(userId)), MongoUserPO.class); + return mongoTemplate.findOne(new Query().addCriteria(Criteria.where("userId").is(userId)), MongoUserPO.class, COLLECTION_NAME); } @Override public MongoUserPO getPOByUsername(String username) { - return mongoTemplate.findOne(new Query().addCriteria(Criteria.where("userUsername").is(username)), MongoUserPO.class); + return mongoTemplate.findOne(new Query().addCriteria(Criteria.where("userUsername").is(username)), MongoUserPO.class, COLLECTION_NAME); } }