add batch 获取微信用户信息

client/pom.xml

@@ -11,7 +11,7 @@
 
     <groupId>com.pica.cloud.account</groupId>
     <artifactId>pica-cloud-account-client</artifactId>
-    <version>1.0.3.8</version>
+    <version>1.0.3.9</version>
     <name>pica-cloud-account-client</name>
     <packaging>jar</packaging>
 

client/src/main/java/com/pica/cloud/account/account/client/AccountInfoClient.java

@@ -6,6 +6,7 @@ import org.springframework.cloud.netflix.feign.FeignClient;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * @author andong
@@ -25,4 +26,7 @@ public interface AccountInfoClient {
                                            @RequestHeader(value = "sourceType") Integer sourceType,
                                            @RequestParam(value = "seconds", required = false) Integer seconds);
 
+    @PostMapping("/account/info/wechat/batch")
+    PicaResponse<Map<Integer,String>> getWechatInfoBatch(@RequestBody List<Integer> docIds, @RequestHeader String token);
+
 }

server/src/main/java/com/pica/cloud/account/account/server/controller/AccountInfoController.java

@@ -8,11 +8,13 @@ import com.pica.cloud.foundation.entity.PicaResponse;
 import com.pica.cloud.foundation.service.starter.interceptor.EnabledLoginValidate;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import io.swagger.models.auth.In;
 import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import java.util.Collections;
 import java.util.List;
+import java.util.Map;
 
 /**
  * @author andong
@@ -57,4 +59,12 @@ public class AccountInfoController extends AccountBaseController {
         return PicaResponse.toResponse(wechatService.getAccountWechatInfo(fetchPicaUser()));
     }
 
+    @ApiOperation("批量获取医生wechat信息")
+    @PostMapping("/wechat/batch")
+    @EnabledLoginValidate
+    public PicaResponse<Map<Integer,String>> getWechatInfoBatch(@RequestBody List<Integer> docIds, @RequestHeader String token) {
+
+        return PicaResponse.toResponse(wechatService.getAccountWechatInfoBatch(docIds,fetchPicaUser()));
+    }
+
 }

server/src/main/java/com/pica/cloud/account/account/server/service/WechatService.java

@@ -3,8 +3,13 @@ package com.pica.cloud.account.account.server.service;
 import com.pica.cloud.account.account.server.entity.AccountWeChatInfoEntity;
 import com.pica.cloud.foundation.utils.entity.PicaUser;
 
+import java.util.List;
+import java.util.Map;
+
 public interface WechatService {
 
     AccountWeChatInfoEntity getAccountWechatInfo(PicaUser user);
 
+    Map<Integer,String> getAccountWechatInfoBatch(List<Integer> docIds , PicaUser user);
+
 }

server/src/main/java/com/pica/cloud/account/account/server/service/impl/WechatServiceImpl.java

@@ -9,6 +9,10 @@ import com.pica.cloud.foundation.utils.utils.StringUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
 
 @Service
 public class WechatServiceImpl implements WechatService {
@@ -28,4 +32,23 @@ public class WechatServiceImpl implements WechatService {
             return weChatInfoMapper.selectByUnionId(unionId);
         }
     }
+
+    @Override
+    public Map<Integer, String> getAccountWechatInfoBatch(List<Integer> docIds, PicaUser user) {
+        Map<Integer, String> rtnMap = new HashMap<>();
+        for(Integer i : docIds){
+            String openId = "";
+            String unionId = doctorMapper.getUnionIdByDoctorId(user.getId());
+            if(StringUtil.isEmpty(unionId)){
+                rtnMap.put(i,"");
+            }else {
+                AccountWeChatInfoEntity rs = weChatInfoMapper.selectByUnionId(unionId);
+                if(null != rs){
+                    openId = rs.getOpenid();
+                }
+                rtnMap.put(i,openId);
+            }
+        }
+        return rtnMap;
+    }
 }