Merge branch 'bugfix-20231225' into 'master'

企微接口1000批次发送

See merge request !1595

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/notify/out/NoticeMessageApiServiceImpl.java

@@ -332,15 +332,19 @@ public class NoticeMessageApiServiceImpl implements NoticeMessageApiService {
             if (ObjectUtil.isNull(noticeMessageTypeEnum)) {
                 return ServiceResponse.failure("-1", "模版枚举不存在");
             }
-            noticeMessageHandler.sendMessage(NoticeMessageForm.builder()
-                    .messageCode(noticeMessageTypeEnum.getMessageCode())
-                    .mqRouterCode(noticeMessageTypeEnum.getRouterCode())
-                    .businessId(notifyMessageBatchQDTO.getOptTargetId())
-                    .createTime(new Date())
-                    .enterpriseId(notifyMessageBatchQDTO.getEnterpriseId())
-                    .uniqueKey(UniqueIdUtils.uniqueLongHex())
-                    .userIdList(relationList.stream().map(StaffClerkRelationDTO::getClerkId).distinct().collect(Collectors.toList()))
-                    .variableMap(variableMap).build());
+            List<String> userIdList = relationList.stream().map(StaffClerkRelationDTO::getClerkId).distinct().collect(Collectors.toList());
+            List<List<String>> listList = ListUtil.split(userIdList, 1000);
+            for (List<String> list : listList) {
+                noticeMessageHandler.sendMessage(NoticeMessageForm.builder()
+                        .messageCode(noticeMessageTypeEnum.getMessageCode())
+                        .mqRouterCode(noticeMessageTypeEnum.getRouterCode())
+                        .businessId(notifyMessageBatchQDTO.getOptTargetId())
+                        .createTime(new Date())
+                        .enterpriseId(notifyMessageBatchQDTO.getEnterpriseId())
+                        .uniqueKey(UniqueIdUtils.uniqueLongHex())
+                        .userIdList(list)
+                        .variableMap(variableMap).build());
+            }
         } catch (Exception e) {
             logger.error("发送消息通知失败",e);
         }