Bläddra i källkod

add user dubbo api

Mr.qian 2 veckor sedan
förälder
incheckning
270d744991

+ 4 - 0
cif-api/src/main/java/com/txz/cif/service/UserDubboService.java

@@ -4,6 +4,8 @@ package com.txz.cif.service;
 import com.txz.cif.dto.Result;
 import com.txz.cif.dto.UserDTO;
 
+import java.util.List;
+
 public interface UserDubboService {
 
     /**
@@ -16,5 +18,7 @@ public interface UserDubboService {
     UserDTO getUser(Long userId);
 
     void updateLastTime(Long userId);
+    
+    List<UserDTO> getUsersByIds(List<Long> userIds);
 
 }

+ 8 - 0
cif-service/src/main/java/com/txz/cif/dao/UserMapper.java

@@ -1,7 +1,15 @@
 package com.txz.cif.dao;
 
 import com.txz.cif.core.Mapper;
+import com.txz.cif.dao.impl.UserMapperImpl;
+import com.txz.cif.dto.UserDTO;
 import com.txz.cif.model.User;
+import org.apache.ibatis.annotations.SelectProvider;
+
+import java.util.List;
 
 public interface UserMapper extends Mapper<User> {
+    
+    @SelectProvider(type = UserMapperImpl.class, method = "getUsersByIds")
+    List<UserDTO> getUsersByIds(String userIds);
 }

+ 13 - 0
cif-service/src/main/java/com/txz/cif/dao/impl/UserMapperImpl.java

@@ -0,0 +1,13 @@
+package com.txz.cif.dao.impl;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/8/27
+ */
+
+public class UserMapperImpl {
+    
+    public String getUsersByIds(String userIds){
+        return "select head_pic , name from c_user where id in (${userIds})";
+    }
+}

+ 27 - 16
cif-service/src/main/java/com/txz/cif/dubbo/impl/UserDubboServiceImpl.java

@@ -1,6 +1,7 @@
 package com.txz.cif.dubbo.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
 import com.txz.cif.core.RedisUtil;
 import com.txz.cif.core.cache.CacheKey;
@@ -15,27 +16,29 @@ import org.apache.dubbo.config.annotation.DubboService;
 import org.apache.dubbo.config.annotation.Service;
 
 import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
 
 @Slf4j
 @DubboService(timeout = 1200000)
 public class UserDubboServiceImpl implements UserDubboService {
-
+    
     @Resource
     private RedisUtil redisUtil;
-
+    
     @Resource
     private UserService userService;
-
-
-
+    
+    
     @Override
     public Result<UserDTO> validateLogin(String token) {
         CacheKey key = CacheKey.generateKey(CacheType.UserToken, token);
         Object j = redisUtil.get(key.toString());
-        if (j  != null) {
-            User user = userService.findById(Long.parseLong( j.toString()));
-            if (user != null){
-                return Result.genSuccessResult(BeanUtil.toBean(user,UserDTO.class));
+        if (j != null) {
+            User user = userService.findById(Long.parseLong(j.toString()));
+            if (user != null) {
+                return Result.genSuccessResult(BeanUtil.toBean(user, UserDTO.class));
             } else {
                 return Result.genFailResult("用户未找到");
             }
@@ -43,25 +46,33 @@ public class UserDubboServiceImpl implements UserDubboService {
             return Result.genFailResult("用户未登录");
         }
     }
-
+    
     @Override
     public UserDTO getUser(Long userId) {
         User user = userService.findById(userId);
-        if (user == null){
+        if (user == null) {
             return null;
         }
-        UserDTO userDTO =  BeanUtil.toBean(user,UserDTO.class);
+        UserDTO userDTO = BeanUtil.toBean(user, UserDTO.class);
         userDTO.setHeadPic(user.getHeadPic());
         return userDTO;
     }
-
+    
     @Override
     public void updateLastTime(Long userId) {
         User user = userService.findById(userId);
-        if (user == null){
-            return ;
+        if (user == null) {
+            return;
         }
         userService.update(User.builder().id(userId).lastLoginTime(DateUtil.date()).build());
     }
-
+    
+    @Override
+    public List<UserDTO> getUsersByIds(List<Long> userIds) {
+        if (CollectionUtil.isEmpty(userIds)) {
+            return new ArrayList<>();
+        }
+        return userService.getUsersByIds(userIds);
+    }
+    
 }

+ 24 - 17
cif-service/src/main/java/com/txz/cif/service/UserService.java

@@ -1,41 +1,48 @@
 package com.txz.cif.service;
 
 import com.txz.cif.core.Service;
+import com.txz.cif.dto.UserDTO;
 import com.txz.cif.model.User;
 import com.txz.cif.web.para.UserAddParam;
 import com.txz.cif.core.Result;
 
+import java.util.List;
+
 /**
  * Created by CodeGenerator on 2019/11/18.
  */
 public interface UserService extends Service<User> {
-
-
+    
+    
     Boolean checkMail(String email);
-
-    Result<Object> sendCode(String phoneNo );
-
+    
+    Result<Object> sendCode(String phoneNo);
+    
     Boolean checkCode(String phoneNo, String code);
-
+    
     Result<Object> resetPwd(Long userId, String pwd, String newPwd);
-
+    
     Boolean resetPhoneNo(Long userId, String phoneNo);
-
+    
     Boolean resetLoginAccount(Long userId, String loginAccount);
-
-
-//    Boolean resetEmail(Long userId, String email);
+    
+    
+    //    Boolean resetEmail(Long userId, String email);
+    
     /**
      * 创建用户
-     * @param param 入参
+     *
+     * @param param    入参
      * @param userName 创建人
-     * @param type 类型 1群组 2专家  3医院
+     * @param type     类型 1群组 2专家  3医院
      */
     Long createUser(UserAddParam param, String userName, Integer type);
-
+    
     void add(User user);
-
+    
     Result<Object> resetPwdByCode(String phoneNo, String verifyCode, String newPwd);
-
-//    boolean sendMsg(MessageParam param);
+    
+    //    boolean sendMsg(MessageParam param);
+    
+    List<UserDTO> getUsersByIds(List<Long> userIds);
 }

+ 12 - 3
cif-service/src/main/java/com/txz/cif/service/impl/UserServiceImpl.java

@@ -6,8 +6,10 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.RandomUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
+import com.google.common.base.Joiner;
 import com.txz.cif.constants.RedisConstants;
 import com.txz.cif.core.*;
+import com.txz.cif.dto.UserDTO;
 import com.txz.cif.dubbo.client.OperatingConfigDubboServiceClient;
 import com.txz.cif.model.*;
 import com.txz.cif.dao.UserMapper;
@@ -20,7 +22,9 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.util.Collections;
 import java.util.Date;
+import java.util.List;
 
 import static java.util.regex.Pattern.compile;
 
@@ -35,7 +39,7 @@ public class UserServiceImpl extends AbstractService<User> implements UserServic
     private static Logger log = LoggerFactory.getLogger(UserServiceImpl.class);
 
     @Resource
-    private UserMapper cUserMapper;
+    private UserMapper userMapper;
 
 
     @Resource
@@ -206,8 +210,13 @@ public class UserServiceImpl extends AbstractService<User> implements UserServic
 
         return Result.success();
     }
-
-//    @Override
+    
+    @Override
+    public List<UserDTO> getUsersByIds(List<Long> userIds) {
+       return userMapper.getUsersByIds(Joiner.on(",").join(userIds));
+    }
+    
+    //    @Override
 //    public boolean sendMsg(MessageParam param) {
 //        if (param == null){
 //            return false;