Commit b73a6588 by 墨竹

fix:改为分批

parent 428a9f2d
...@@ -149,6 +149,7 @@ public class QywxClerkSyncOperation implements BaseSyncOperation { ...@@ -149,6 +149,7 @@ public class QywxClerkSyncOperation implements BaseSyncOperation {
logger.info("转换完成,为最后一个"); logger.info("转换完成,为最后一个");
break; break;
} }
pageNum++;
logger.info("useridToOpenuserid请求:corpid:{}", corpid); logger.info("useridToOpenuserid请求:corpid:{}", corpid);
List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, tabHaobanWxApplication.getSiteId(), staffDTOS.stream().map(StaffDTO::getWxUserId).collect(Collectors.toList())); List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, tabHaobanWxApplication.getSiteId(), staffDTOS.stream().map(StaffDTO::getWxUserId).collect(Collectors.toList()));
if (CollectionUtils.isNotEmpty(qywxNewUseridDTOS)) { if (CollectionUtils.isNotEmpty(qywxNewUseridDTOS)) {
...@@ -156,7 +157,6 @@ public class QywxClerkSyncOperation implements BaseSyncOperation { ...@@ -156,7 +157,6 @@ public class QywxClerkSyncOperation implements BaseSyncOperation {
staffApiService.updateOpenUserIdsByUserId(wxEnterpriseId, qywxNewUseridDTO.getUserid(), qywxNewUseridDTO.getOpen_userid()); staffApiService.updateOpenUserIdsByUserId(wxEnterpriseId, qywxNewUseridDTO.getUserid(), qywxNewUseridDTO.getOpen_userid());
} }
} }
pageNum++;
} }
} }
} }
......
...@@ -265,6 +265,7 @@ public class TestController extends WebBaseController { ...@@ -265,6 +265,7 @@ public class TestController extends WebBaseController {
if (CollectionUtils.isEmpty(staffDTOS)) { if (CollectionUtils.isEmpty(staffDTOS)) {
break; break;
} }
pageNum++;
logger.info("useridToOpenuserid请求:corpid:{}", corpid); logger.info("useridToOpenuserid请求:corpid:{}", corpid);
List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, suiteId, staffDTOS.stream().map(StaffDTO::getWxUserId).collect(Collectors.toList())); List<QywxNewUseridDTO> qywxNewUseridDTOS = qywxUserApiService.useridToOpenuserid(corpid, suiteId, staffDTOS.stream().map(StaffDTO::getWxUserId).collect(Collectors.toList()));
if (CollectionUtils.isNotEmpty(qywxNewUseridDTOS)) { if (CollectionUtils.isNotEmpty(qywxNewUseridDTOS)) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment