diff --git a/dataConfig/homeQualitySet.json b/dataConfig/homeQualitySet.json index 5546fee..85331bd 100644 --- a/dataConfig/homeQualitySet.json +++ b/dataConfig/homeQualitySet.json @@ -12,7 +12,7 @@ //分类id "assortid":"批复文件", //系统id - "collectorid":"121212", + "collectorid":"14", //采集类型(文件来源 1:采集器;2:扫描生产软件) "filesource":0, //下载类型(1:服务器本地;2:ftp服务器;3:共享文件夹) diff --git a/src/main/java/com/docus/bgts/DemoApplication.java b/src/main/java/com/docus/bgts/DemoApplication.java index 14f8d6e..8f79215 100644 --- a/src/main/java/com/docus/bgts/DemoApplication.java +++ b/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 { diff --git a/src/main/java/com/docus/bgts/config/MyScheduling.java b/src/main/java/com/docus/bgts/config/MyScheduling.java new file mode 100644 index 0000000..8cae5ae --- /dev/null +++ b/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 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("-------------心跳结束---------------"); + } + } + +} diff --git a/src/main/java/com/docus/bgts/entity/AfCollectTask.java b/src/main/java/com/docus/bgts/entity/AfCollectTask.java index b57bbee..e6e7179 100644 --- a/src/main/java/com/docus/bgts/entity/AfCollectTask.java +++ b/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; } diff --git a/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java b/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java index b190c49..5f5d39d 100644 --- a/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java +++ b/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java @@ -65,16 +65,17 @@ public class AfCollectTaskServiceImpl extends ServiceImpl