Merge branch 'feature-kdsp-max-20220331' into 'master'

max会员

See merge request !57

src/main/java/cn/quantgroup/xyqb/controller/external/WeChatController.java

@@ -22,6 +22,8 @@ import com.google.common.base.Joiner;
 import com.google.common.collect.ImmutableList;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.binary.Base64;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.collections.MapUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.HttpStatus;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -471,6 +473,22 @@ public class WeChatController implements IBaseController {
         return JsonResult.buildSuccessResult("通过unionId查询的绑定微信相关信息", wechatUserInfoList);
     }
 
+    @PostMapping("/unionIdToUserIds")
+    public JsonResult unionIdToUserIds(@RequestBody Map<String, Object> params) {
+        List<WechatUserInfo> wechatUserInfoList = null;
+        if (MapUtils.isNotEmpty(params)) {
+            List<String> unionIds = (List<String>) params.get("unionIds");
+            if (CollectionUtils.isNotEmpty(unionIds)) {
+                if (unionIds.size() > 500) {
+                    unionIds = unionIds.subList(0,500);
+                }
+                wechatUserInfoList = wechatService.queryListByUnionIds(unionIds);
+            }
+        }
+
+        return JsonResult.buildSuccessResult("通过unionId查询的绑定微信相关信息", wechatUserInfoList);
+    }
+
     @PostMapping("/getByUnionIdsToUserIds")
     public JsonResult getByUnionIdsToUserIds(@RequestBody Map<String, Object> params) {
         log.info("根据unionIds获取企业绑定用户信息 {}", params);

src/main/java/cn/quantgroup/xyqb/repository/IWeChatUserRepository.java

@@ -100,4 +100,6 @@ public interface IWeChatUserRepository extends JpaRepository<WechatUserInfo, Lon
      * 通过unionId查询相关绑定微信记录
      */
     List<WechatUserInfo> findByUnionId(String unionId);
+
+    List<WechatUserInfo> findByUnionIdIn(List<String> unionIds);
 }

src/main/java/cn/quantgroup/xyqb/service/wechat/IWechatService.java

@@ -53,4 +53,6 @@ public interface IWechatService {
     List<WechatUserInfo> queryListByUserId(Long userId);
 
     List<WechatUserInfo> queryListByUnionId(String unionId);
+
+    List<WechatUserInfo> queryListByUnionIds(List<String> unionIds);
 }

src/main/java/cn/quantgroup/xyqb/service/wechat/impl/WechatServiceImpl.java

@@ -262,4 +262,9 @@ public class WechatServiceImpl implements IWechatService {
     public List<WechatUserInfo> queryListByUnionId(String unionId) {
         return weChatUserRepository.findByUnionId(unionId);
     }
+
+    @Override
+    public List<WechatUserInfo> queryListByUnionIds(List<String> unionIds) {
+        return weChatUserRepository.findByUnionIdIn(unionIds);
+    }
 }