新增心跳

dataConfig/homeQualitySet.json

@@ -12,7 +12,7 @@
   //分类id
   "assortid":"批复文件",
   //系统id
-  "collectorid":"121212",
+  "collectorid":"14",
   //采集类型(文件来源 1:采集器；2：扫描生产软件)
   "filesource":0,
   //下载类型(1:服务器本地；2：ftp服务器；3：共享文件夹)

src/main/java/com/docus/bgts/DemoApplication.java

@@ -2,7 +2,9 @@ package com.docus.bgts;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableScheduling
 @SpringBootApplication
 public class DemoApplication {
 

src/main/java/com/docus/bgts/config/MyScheduling.java

@@ -0,0 +1,38 @@
+package com.docus.bgts.config;
+
+import com.docus.bgts.utils.FileUtils;
+import com.docus.bgts.utils.HttpUtils;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.net.URISyntaxException;
+import java.util.HashMap;
+import java.util.Map;
+
+@Component
+public class MyScheduling {
+    @Value("${beat.url}")
+    private String beatUrl;
+
+    private Logger logger= LogManager.getLogger(MyScheduling.class);
+
+    //5分钟执行一次
+    @Scheduled(fixedRate = 1000*60*1)
+    public void beat(){
+        logger.info("------------心跳开始---------------");
+        Map<String,String> params=new HashMap<>();
+        params.put("code",String.valueOf(FileUtils.getJsonByName("collectorid")));
+        try {
+            HttpUtils.get(beatUrl,params);
+        } catch (URISyntaxException e) {
+            e.printStackTrace();
+            logger.info("心跳推送出错，可能是住院服务没有开启");
+        }finally {
+            logger.info("-------------心跳结束---------------");
+        }
+    }
+
+}

src/main/java/com/docus/bgts/entity/AfCollectTask.java

@@ -63,4 +63,6 @@ public class AfCollectTask implements Serializable {
     private String c1;
     @ApiModelProperty("文件标题")
     private String c2;
+    @ApiModelProperty("记账号")
+    private String c3;
 }

src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java

@@ -65,16 +65,17 @@ public class AfCollectTaskServiceImpl extends ServiceImpl<AfCollectTaskMapper, A
                 afCollectTask.setSyncTime(date);
                 afCollectTask.setC1(scanfile.getSerialnum());
                 afCollectTask.setC2(scanfile.getFiletitle());
+                afCollectTask.setC3(reportDownDto.getPatient().getJzh());
                 save = afCollectTaskMapper.insert(afCollectTask);
             } else {
                 //存在就修改
-                afCollectTask.setPatientId(patientId);
-                afCollectTask.setSysflag(reportDownDto.getCollectorid());
-                afCollectTask.setState("0");
-                afCollectTask.setSyncTime(date);
-                afCollectTask.setC1(scanfile.getSerialnum());
-                afCollectTask.setC2(scanfile.getFiletitle());
-                save = afCollectTaskMapper.updateById(afCollectTask);
+//                afCollectTask.setPatientId(patientId);
+//                afCollectTask.setSysflag(reportDownDto.getCollectorid());
+//                afCollectTask.setState("0");
+//                afCollectTask.setSyncTime(date);
+//                afCollectTask.setC1(scanfile.getSerialnum());
+//                afCollectTask.setC2(scanfile.getFiletitle());
+//                save = afCollectTaskMapper.updateById(afCollectTask);
             }
 
             if (save <= 0) {

src/main/resources/application.yml

@@ -11,7 +11,8 @@ mybatis-plus:
     db-config:
       field-strategy: NOT_EMPTY
       db-type: MYSQL
-
+beat:
+  url: http://localhost:9399/beat
 ws:
   url: http://192.168.1.115:8010/ws_server/weather?wsdl
   localMethod: OperationA