fix：判断空

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/QywxClerkSyncOperation.java

@@ -24,8 +24,8 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.Arrays;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * Created 2020/4/13.
@@ -130,7 +130,8 @@ public class QywxClerkSyncOperation implements BaseSyncOperation {
                 if (corpid.length() > 20) {
                     //批量处理wx_user_id to wx_open_user_id
                     List<StaffDTO> staffDTOS = staffApiService.listUserIdByWxEnterpriseId(wxEnterpriseId);
-                    List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, config.getWxSuiteid(), Arrays.toString(staffDTOS.stream().map(StaffDTO::getWxUserId).toArray()));
+                    logger.info("useridToOpenuserid请求：corpid：{}", corpid);
+                    List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, config.getWxSuiteid(), staffDTOS.stream().map(StaffDTO::getWxUserId).collect(Collectors.toList()));
                     if (CollectionUtils.isNotEmpty(qywxNewUseridDTOS)) {
                         for (QywxNewUseridDTO qywxNewUseridDTO : qywxNewUseridDTOS) {
                             staffService.updateOpenUserIdsByUserId(wxEnterpriseId, qywxNewUseridDTO.getUserid(), qywxNewUseridDTO.getOpen_userid());

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/TestController.java

@@ -13,8 +13,10 @@ import com.gic.haoban.manage.web.errCode.HaoBanErrCode;
 import com.gic.haoban.manage.web.qo.QywxXcxSendMessageQo;
 import com.gic.redis.data.util.GicRateLimiter;
 import com.gic.redis.data.util.RedisUtil;
+import com.gic.wechat.api.dto.qywx.QywxNewUseridDTO;
 import com.gic.wechat.api.dto.qywx.QywxXcxSendMessageDTO;
 import com.gic.wechat.api.service.qywx.QywxSuiteApiService;
+import com.gic.wechat.api.service.qywx.QywxUserApiService;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -24,6 +26,7 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 import java.util.TreeMap;
 import java.util.concurrent.ExecutorService;
@@ -67,6 +70,8 @@ public class TestController extends WebBaseController {
     private ExternalClerkRelatedApiService externalClerkRelatedApiService;
     @Autowired
     private WxEnterpriseApiService wxEnterpriseApiService;
+    @Autowired
+    private QywxUserApiService qywxUserApiService;
 
     @RequestMapping("/send-message-test")
     public HaobanResponse testSendMessage(QywxXcxSendMessageQo qo) {
@@ -230,4 +235,13 @@ public class TestController extends WebBaseController {
         wxEnterpriseApiService.callbackReviceEnterprise(qywxCorpInfoSimpleDTO);
         return resultResponse(HaoBanErrCode.ERR_1);
     }
+
+
+    @RequestMapping("/useridToOpenuserid")
+    public HaobanResponse useridToOpenuserid(String corpid, String suiteId, String userids) {
+        String[] split = userids.split(",");
+        List<String> useridList = Arrays.stream(split).collect(Collectors.toList());
+        List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, suiteId, useridList);
+        return resultResponse(HaoBanErrCode.ERR_1, qywxNewUseridDTOS);
+    }
 }