From 42e89000b542530d846c98169235f822d40405b8 Mon Sep 17 00:00:00 2001 From: wyb <1977763549@qq.com> Date: Wed, 23 Apr 2025 17:33:19 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=B9=BF=E5=B7=9E=E5=B8=82=E4=B8=80?= =?UTF-8?q?=E5=9F=BA=E7=A1=80=E6=95=B0=E6=8D=AE=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../demo/job/GzFirstHospBasicSyncJob.java | 41 +++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 src/main/java/com/docus/demo/job/GzFirstHospBasicSyncJob.java diff --git a/src/main/java/com/docus/demo/job/GzFirstHospBasicSyncJob.java b/src/main/java/com/docus/demo/job/GzFirstHospBasicSyncJob.java new file mode 100644 index 0000000..382bf35 --- /dev/null +++ b/src/main/java/com/docus/demo/job/GzFirstHospBasicSyncJob.java @@ -0,0 +1,41 @@ +package com.docus.demo.job; + +import com.docus.demo.dto.SyncBasicDataDto; +import com.docus.demo.facade.ISyncBasicDataService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.time.LocalDate; +import java.time.temporal.TemporalAdjusters; + +/** + * @author YongBin Wen + * @date 2025/4/23 0023 17:13 + */ +@Component +@Slf4j +public class GzFirstHospBasicSyncJob { + + @Autowired + private ISyncBasicDataService syncBasicDataService; + + @Scheduled(cron = "0 0 0/12 * * ?") + public void syncOneMonthData() { + LocalDate today = LocalDate.now(); + LocalDate firstDayOfLastMonth = today.minusMonths(1).with(TemporalAdjusters.firstDayOfMonth()); + SyncBasicDataDto dto = new SyncBasicDataDto(); + dto.setStartDate(firstDayOfLastMonth.toString()); + dto.setEndDate(today.toString()); + dto.setLimit(1000); + log.info("广州市第一人民医院,同步省厅基础数据,日期:{} —— {}", firstDayOfLastMonth, today); + try { + syncBasicDataService.syncBasicData(dto); + log.info("广州市第一人民医院,同步省厅基础数据,日期:" + firstDayOfLastMonth + "—— " + today + ",同步完成!"); + } catch (Exception ex) { + log.info("广州市第一人民医院,同步省厅基础数据,日期:" + firstDayOfLastMonth + "—— " + today + ",出现异常:" + ex.getMessage(), ex); + } + } + +}