同步数据

boman-web-core/src/main/java/com/boman/web/core/service/vaccineInfo/impl/VaccineInfoUserServiceImpl.java

@@ -173,9 +173,9 @@ public class VaccineInfoUserServiceImpl implements IVaccineInfoUserService {
     public void syncData() throws Exception {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         // 获取疫苗信息，每次处理1000条
-//        int counts = syncMapper.selectCount("select count(1) from vaccine_info");
+        int counts = syncMapper.selectCount("select count(1) from vaccine_info");
         int count = 1;
-        int counts = 1;
+//        int counts = 1;
         int times = counts / 1000;
         int startPagte = 0;
         int endPage = 1000;
@@ -203,13 +203,13 @@ public class VaccineInfoUserServiceImpl implements IVaccineInfoUserService {
                 JSONObject userInfo = this.getvaccUser(icsard);
                 if (userInfo != null) {
                     if(progressMap.get(icsard).equals("否")) {
-                        update.put("shouldSlow", "是");
+                        update.put("should_slow", "是");
                     }else {
-                        update.put("shouldSlow", "否");
+                        update.put("should_slow", "否");
                     }
                     update.put("should_be", "否");
                 } else {
-                    update.put("shouldSlow", "否");
+                    update.put("should_slow", "否");
                     update.put("should_be", "是");
                 }
 
@@ -223,7 +223,7 @@ public class VaccineInfoUserServiceImpl implements IVaccineInfoUserService {
     }
 
     private List<JSONObject> getVaccInfo(int startPagte, int endPage) {
-        String sql = "select * from vaccine_info where id_card = '11010819710505603X' limit " + startPagte + ", " + endPage;
+        String sql = "select * from vaccine_info limit " + startPagte + ", " + endPage;
         List<JSONObject> objs = syncMapper.selectBySql(sql);
         return objs;
     }