新生儿信息数据

boman-web-core/src/main/java/com/boman/web/core/controller/TaskController.java

@@ -41,7 +41,7 @@ public class TaskController {
 
     @GetMapping("/getNewborn")
     private void getNewborn() {
-        //taskService.getNewborn();
+        taskService.getNewborn();
     }
 
     @GetMapping("/insertAccountingData")

boman-web-core/src/main/java/com/boman/web/core/service/TaskService.java

@@ -545,26 +545,50 @@ public class TaskService {
         return STS_CZRK_ + deptId + ":" + DateUtils.getDate();
     }
 
+    /***
+     * 新生儿（每天18点执行）
+     *
+     */
+    @Scheduled(cron = "0 0 18 * * ?")
     public void getNewborn() {
-        Map<String, String> paramMap = new HashMap<>();
-        paramMap.put("client_id", "acdf50bd13be4901b64c62b1fee862c0");
-        paramMap.put("client_secret", "a3650d67fc034b2d8ea259182b3d99f3");
-        String http = "http://172.27.189.244:9090/oauth/tocken";
-        try {
-            String data = HttpClientUtils.doGet(http, paramMap);
 
-            List<BirthRecords> birthRecordsList = JSONObject.parseArray(data, BirthRecords.class);
-            for (BirthRecords birthRecords : birthRecordsList) {
-                birthRecords.setIsDel("N");
-                birthRecords.setCreateBy("系统");
-                birthRecords.setUpdateBy("系统");
-                birthRecords.setStatus(1);
+        String token = getToken();
+
+
+        if (StringUtils.isNotBlank(token)) {
+
+            String startTime = redisService.getCacheObject("startTimeNew");
+            if(StringUtils.isEmpty(startTime)){
+                startTime = "2022-04-01 00:00:00.0";
+            }
+            String endTime = DateUtils.formatString(new Date());
+            redisService.setCacheObject("startTimeNew", endTime);
+            endTime = endTime.replace(" ", "%20");
+            startTime = startTime.replace(" ", "%20");
+
+            Map<String, String> paramMap = new HashMap<>();
+            paramMap.put("client_id", "acdf50bd13be4901b64c62b1fee862c0");
+            paramMap.put("access_token", token);
+            paramMap.put("xzqh", "潜山市");
+            paramMap.put("start_time", startTime);
+            paramMap.put("end_time", endTime);
+            String http = "http://60.171.171.235:9090/service/api/rkk/qxcsyxzmcx";
+            try {
+                String data = HttpClientUtils.doGet(http, paramMap);
+
+                List<BirthRecords> birthRecordsList = JSONObject.parseArray(data, BirthRecords.class);
+                for (BirthRecords birthRecords : birthRecordsList) {
+                    birthRecords.setIsDel("N");
+                    birthRecords.setCreateBy("系统");
+                    birthRecords.setUpdateBy("系统");
+                    birthRecords.setStatus(1);
+                }
+                //批量保存
+                birthRecordsService.insertListBirthRecords(birthRecordsList);
+                System.out.println(data);
+            } catch (IOException e) {
+                e.printStackTrace();
             }
-            //批量保存
-            birthRecordsService.insertListBirthRecords(birthRecordsList);
-            System.out.println(data);
-        } catch (IOException e) {
-            e.printStackTrace();
         }
     }
 
@@ -659,7 +683,7 @@ public class TaskService {
         System.out.println("batchInsert 查询数据开始========");
         long start1 = System.currentTimeMillis();
         //获取所有核酸数据源
-        List<TSampling514> TSampling514List = accountingDataService.getTSampling514AllData(startTime,endTime);
+        List<TSampling514> TSampling514List = accountingDataService.getTSampling514AllData(startTime, endTime);
         //获取所有户籍数据
         //List<Czrk> czrks = czrkMapper.listByCzrk(new Czrk());
 
@@ -670,7 +694,7 @@ public class TaskService {
         System.out.println("batchInsert 循环数据开始========");
         long start2 = System.currentTimeMillis();
         for (TSampling514 tSampling514 : TSampling514List) {
-            if(tSampling514.getCollectTime() != null){
+            if (tSampling514.getCollectTime() != null) {
                 Czrk czrk = new Czrk();
                 czrk.setNucleicAcidTime(String.valueOf(tSampling514.getCollectTime()));
                 czrk.setIdCard(tSampling514.getIdCard());
@@ -681,7 +705,7 @@ public class TaskService {
         }
 
         long end2 = System.currentTimeMillis();
-        System.out.println("---------------循环数据耗时"+(end2 -start2)+"---------------");
+        System.out.println("---------------循环数据耗时" + (end2 - start2) + "---------------");
     }
 
 
@@ -701,16 +725,16 @@ public class TaskService {
         System.out.println("batchInsert 循环数据开始========");
         long start2 = System.currentTimeMillis();
         for (TSampling514 tSampling514 : TSampling514List) {
-                Czrk czrk = new Czrk();
-                czrk.setNucleicAcidTime("-");
-                czrk.setIdCard(tSampling514.getIdCard());
-                czrkMapper.updateCzrkByNucleicAcid(czrk);
-                //czrkList.add(czrk);
+            Czrk czrk = new Czrk();
+            czrk.setNucleicAcidTime("-");
+            czrk.setIdCard(tSampling514.getIdCard());
+            czrkMapper.updateCzrkByNucleicAcid(czrk);
+            //czrkList.add(czrk);
 
         }
 
         long end2 = System.currentTimeMillis();
-        System.out.println("---------------循环数据耗时"+(end2 -start2)+"---------------");
+        System.out.println("---------------循环数据耗时" + (end2 - start2) + "---------------");
     }