REQ-2633,添加根据参数查询ThirdPartyUser接口

riven-api/src/main/java/cn/axzo/riven/client/feign/ThirdPartySyncApi.java

@@ -4,6 +4,7 @@ import cn.axzo.framework.domain.web.result.ApiResult;
 import cn.axzo.riven.client.domain.SyncInvokeReq;
 import cn.axzo.riven.client.domain.ThirdPartyDeptDTO;
 import cn.axzo.riven.client.domain.ThirdPartyUserDTO;
+import cn.axzo.riven.client.req.ThirdPartyUserReq;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -40,4 +41,13 @@ public interface ThirdPartySyncApi {
      */
     @GetMapping("api/sync/getUsersByPhone/{phone}")
     ApiResult<List<ThirdPartyUserDTO>> getUserInfosByPhone(@PathVariable String phone);
+
+    /**
+     * 根据参数查询用户信息
+     *
+     * @param req 请求参数
+     * @return 三方信息列表
+     */
+    @PostMapping("api/sync/getThirdPartyUsers")
+    ApiResult<List<ThirdPartyUserDTO>> getUserInfos(@RequestBody ThirdPartyUserReq req);
 }

riven-api/src/main/java/cn/axzo/riven/client/req/ThirdPartyUserReq.java

@@ -0,0 +1,24 @@
+package cn.axzo.riven.client.req;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class ThirdPartyUserReq {
+
+
+    /**
+     * 三方平台UID
+     */
+    private String unionId;
+
+    /**
+     * 三方用户ID
+     */
+    private String userId;
+}

riven-server/src/main/java/cn/axzo/riven/controller/ThirdPartySyncController.java

@@ -5,6 +5,7 @@ import cn.axzo.riven.client.domain.SyncInvokeReq;
 import cn.axzo.riven.client.domain.ThirdPartyDeptDTO;
 import cn.axzo.riven.client.domain.ThirdPartyUserDTO;
 import cn.axzo.riven.client.feign.ThirdPartySyncApi;
+import cn.axzo.riven.client.req.ThirdPartyUserReq;
 import cn.axzo.riven.service.ThirdPartySyncManageService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -46,4 +47,10 @@ public class ThirdPartySyncController implements ThirdPartySyncApi {
     public ApiResult<List<ThirdPartyUserDTO>> getUserInfosByPhone(String phone) {
         return ApiResult.ok(thirdPartySyncManageService.getUserInfosByPhone(phone));
     }
+
+    @Override
+    public ApiResult<List<ThirdPartyUserDTO>> getUserInfos(ThirdPartyUserReq req) {
+        return ApiResult.ok(thirdPartySyncManageService.getUserInfos(req));
+    }
+
 }

riven-server/src/main/java/cn/axzo/riven/service/ThirdPartySyncManageService.java

@@ -3,6 +3,7 @@ package cn.axzo.riven.service;
 import cn.axzo.riven.client.domain.SyncInvokeReq;
 import cn.axzo.riven.client.domain.ThirdPartyDeptDTO;
 import cn.axzo.riven.client.domain.ThirdPartyUserDTO;
+import cn.axzo.riven.client.req.ThirdPartyUserReq;
 
 import java.util.List;
 
@@ -21,4 +22,6 @@ public interface ThirdPartySyncManageService {
     ThirdPartyUserDTO getUserById(Long syncDataId);
 
     List<ThirdPartyUserDTO> getUserInfosByPhone(String phone);
+
+    List<ThirdPartyUserDTO> getUserInfos(ThirdPartyUserReq req);
 }

riven-server/src/main/java/cn/axzo/riven/service/impl/ThirdPartySyncManageServiceImpl.java

@@ -7,6 +7,7 @@ import cn.axzo.pokonyan.util.TraceSupplier;
 import cn.axzo.riven.client.domain.SyncInvokeReq;
 import cn.axzo.riven.client.domain.ThirdPartyDeptDTO;
 import cn.axzo.riven.client.domain.ThirdPartyUserDTO;
+import cn.axzo.riven.client.req.ThirdPartyUserReq;
 import cn.axzo.riven.common.util.Throws;
 import cn.axzo.riven.model.ThirdPartySyncContext;
 import cn.axzo.riven.repository.entity.ThirdPartyCredential;
@@ -22,6 +23,7 @@ import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -137,4 +139,18 @@ public class ThirdPartySyncManageServiceImpl implements ThirdPartySyncManageServ
         }
         return userList.stream().map(u -> BeanMapper.copyBean(u, ThirdPartyUserDTO.class)).collect(Collectors.toList());
     }
+
+    @Override
+    public List<ThirdPartyUserDTO> getUserInfos(ThirdPartyUserReq req) {
+        if (req == null) {
+            return new ArrayList<>(0);
+        }
+        List<ThirdPartyUser> userList = thirdPartyUserDao.list(new LambdaQueryWrapper<ThirdPartyUser>()
+                .eq(StringUtils.isNoneBlank(req.getUnionId()), ThirdPartyUser::getUnionId, req.getUnionId())
+                .eq(StringUtils.isNoneBlank(req.getUserId()), ThirdPartyUser::getUserId, req.getUserId()));
+        if (userList == null) {
+            return new ArrayList<>(0);
+        }
+        return userList.stream().map(u -> BeanMapper.copyBean(u, ThirdPartyUserDTO.class)).collect(Collectors.toList());
+    }
 }