优化通知

service-job/src/main/java/com/java110/job/task/wechat/WeChatPushMessageTemplate.java

@@ -66,6 +66,8 @@ public class WeChatPushMessageTemplate extends TaskSystemQuartz {
     public static final int DEFAULT_THREAD_NUM = 20;
     public static final int DEFAULT_SUBSCRIBE_PERSON = 100;
 
+    public static final int DEFAULT_QUERY_APP_OWNER_COUNT = 50;
+
     @Autowired
     private INoticeInnerServiceSMO noticeInnerServiceSMOImpl;
 
@@ -248,8 +250,19 @@ public class WeChatPushMessageTemplate extends TaskSystemQuartz {
         OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
         ownerAppUserDto.setAppType(OwnerAppUserDto.APP_TYPE_WECHAT);
         ownerAppUserDto.setCommunityId(noticeDto.getCommunityId());
-        List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
-        doSend(ownerAppUserDtos, noticeDto, templateId, accessToken, weChatDto);
+        int count = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsersCount(ownerAppUserDto);
+
+        double maxPage = Math.ceil(count/DEFAULT_QUERY_APP_OWNER_COUNT)+1;
+
+        for(int page = 0; page < maxPage; page++){
+            ownerAppUserDto.setPage(page+1);
+            ownerAppUserDto.setRow(DEFAULT_QUERY_APP_OWNER_COUNT);
+            List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
+            doSend(ownerAppUserDtos, noticeDto, templateId, accessToken, weChatDto);
+        }
+//
+//        List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
+//        doSend(ownerAppUserDtos, noticeDto, templateId, accessToken, weChatDto);
     }
 
     private void sendFloorOwner(NoticeDto noticeDto, String templateId, String accessToken, SmallWeChatDto weChatDto) {

service-job/src/main/resources/application-dev.yml

@@ -82,6 +82,14 @@ spring:
     encoding: UTF-8
     suffix: .html
     content-type: text/html
+
+feign:
+  client:
+    config:
+      default:
+        connect-timeout: 10000
+        read-timeout: 20000
+
 #  mvc:
 #    view:
 #      prefix: classpath:/templates/

service-job/src/main/resources/application-zihao.yml

@@ -82,6 +82,15 @@ spring:
     encoding: UTF-8
     suffix: .html
     content-type: text/html
+
+
+feign:
+  client:
+    config:
+      default:
+        connect-timeout: 10000
+        read-timeout: 20000
+
 #  mvc:
 #    view:
 #      prefix: classpath:/templates/