下载文件

src/main/java/com/izouma/wenlvju/repo/TrainingInstitutionRepo.java

@@ -15,7 +15,7 @@ public interface TrainingInstitutionRepo extends JpaRepository<TrainingInstituti
     @Transactional
     void softDelete(Long id);
 
-    @Query(nativeQuery = true, value = "select phone from training_institution where submit = false and phone REGEXP '^[1][35678][0-9]{9}$'")
+    @Query(nativeQuery = true, value = "select phone from training_institution where submit = false and phone REGEXP '^[1][35678][0-9]{9}$' and id > 4807")
     List<String> findAllBySubmitFalseAndPhoneIsNotNull();
 
     @Query(nativeQuery = true, value = "select phone from training_institution where submit = false and phone REGEXP '^[1][35678][0-9]{9}$' limit 2000,2000")

src/main/java/com/izouma/wenlvju/service/TrainingInstitutionService.java

@@ -36,12 +36,12 @@ public class TrainingInstitutionService {
 
     public void batchSend(List<String> phones) throws InterruptedException {
 
-        int count = phones.size() / 950;
+        int count = phones.size() / 1000;
         String body = "尊敬的调研对象：\n" +
                 "您好，为贯彻落实国家、省、市关于“双减”工作相关文件精神，了解和掌握我市文化艺术类校外培训机构相关情况，市文旅局决定开展全市文化艺术类校外培训机构网上问卷调查，如从事文化艺术类校外培训，请登录：http://wljtest.izouma.com/h5/trainingInstitution，填写调查问卷，如不从事文化艺术类校外培训，请忽略本条信息，谢谢。\n";
         for (int i = 0; i <= count; i++) {
-            int start = i * 950;
-            int end = start + 950;
+            int start = i * 1000;
+            int end = start + 1000;
             if (end > phones.size()) {
                 end = phones.size();
             }
@@ -51,7 +51,7 @@ public class TrainingInstitutionService {
             njwlSmsService.sendSms(sendPhone, body);
 //            System.out.println("start:" + start + ",end:" + end);
             // 睡眠5分钟
-            Thread.sleep(30 * 1000);
+            Thread.sleep(2 * 60 * 1000);
         }
 
     }

src/test/java/com/izouma/wenlvju/web/TrainingInstitutionControllerTest.java

@@ -52,7 +52,7 @@ public class TrainingInstitutionControllerTest extends ApplicationTests {
 
     @Test
     public void test1() throws InterruptedException {
-        List<String> phones = trainingInstitutionRepo.findAllBySubmitFalseAndPhoneIsNotNullLimit();
+        List<String> phones = trainingInstitutionRepo.findAllBySubmitFalseAndPhoneIsNotNull();
         trainingInstitutionService.batchSend(phones);
 
     }