From a2798f7a1ffaae57a78ac6b9216b370a272cc3e7 Mon Sep 17 00:00:00 2001 From: czx <28353131@qq.com> Date: Thu, 26 Nov 2020 09:33:32 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E5=90=8C=E6=95=B0=E6=8D=AE=E6=BA=90?= =?UTF-8?q?=E5=88=87=E6=8D=A2=E5=90=8C=E6=AD=A5=E8=BF=9C=E7=A8=8B=E7=97=85?= =?UTF-8?q?=E6=82=A3=E5=88=B0=E6=9C=AC=E5=9C=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-quartz/pom.xml | 8 ++++ .../com/ruoyi/quartz/task/ftSyncPatient.java | 28 ++++++------ .../fantang/domain/FtRemotePatientDao.java | 2 +- .../fantang/domain/FtSyncPatientDao.java | 45 +++++++++++++++++++ .../fantang/mapper/FtFoodDaoMapper.java | 2 + ...per.java => FtRemotePatientDaoMapper.java} | 4 +- .../mapper/FtSyncPatientDaoMapper.java | 9 ++++ .../system/service/ISyncPatientService.java | 12 +++++ .../service/impl/SyncPatientServiceImpl.java | 26 +++++++++++ 9 files changed, 121 insertions(+), 15 deletions(-) create mode 100644 ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtSyncPatientDao.java rename ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/{ftRemotePatientDaoMapper.java => FtRemotePatientDaoMapper.java} (58%) create mode 100644 ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtSyncPatientDaoMapper.java create mode 100644 ruoyi-system/src/main/java/com/ruoyi/system/service/ISyncPatientService.java create mode 100644 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SyncPatientServiceImpl.java diff --git a/ruoyi-quartz/pom.xml b/ruoyi-quartz/pom.xml index 15a5bc200..a99af4626 100644 --- a/ruoyi-quartz/pom.xml +++ b/ruoyi-quartz/pom.xml @@ -34,6 +34,14 @@ com.ruoyi ruoyi-common + + com.ruoyi + ruoyi-system + + + com.ruoyi + ruoyi-system + diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/ftSyncPatient.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/ftSyncPatient.java index ae52bb013..8c6b978d3 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/ftSyncPatient.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/ftSyncPatient.java @@ -1,27 +1,29 @@ package com.ruoyi.quartz.task; -import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.common.annotation.DataSource; +import com.ruoyi.common.enums.DataSourceType; +import com.ruoyi.system.fantang.mapper.FtFoodDaoMapper; +import com.ruoyi.system.fantang.mapper.FtRemotePatientDaoMapper; +import com.ruoyi.system.service.impl.SyncPatientServiceImpl; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; /** * 定时任务调度测试 - * + * * @author ruoyi */ +@DataSource(value = DataSourceType.SLAVE) @Component("SyncPatient") -public class ftSyncPatient -{ - public void ryParams(String params) - { - System.out.println("执行有参方法：" + params); - } +public class ftSyncPatient { + @Autowired + private FtRemotePatientDaoMapper ftRemotePatientDaoMapper; - public void ryNoParams() - { - System.out.println("执行无参方法"); - } + @Autowired + private SyncPatientServiceImpl syncPatientService; public void ftGetRemotePatient() { - + System.out.println("执行同步远程病患数据"); + syncPatientService.insertToLocalSync(ftRemotePatientDaoMapper.selectList(null)); } } diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtRemotePatientDao.java b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtRemotePatientDao.java index 267c7f6e4..56f3b42a0 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtRemotePatientDao.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtRemotePatientDao.java @@ -38,7 +38,7 @@ private static final long serialVersionUID=1L; // 科室名称 @TableField("depart_name") - private String depart_name; + private String departName; // 床号 @TableField("bed_id") diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtSyncPatientDao.java b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtSyncPatientDao.java new file mode 100644 index 000000000..6a85f013c --- /dev/null +++ b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/domain/FtSyncPatientDao.java @@ -0,0 +1,45 @@ +package com.ruoyi.system.fantang.domain; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.ToString; +import lombok.experimental.Accessors; + +import java.io.Serializable; + +/** + * 远程病患数据实体类 + * + * @author 陈智兴 + * @date 2020-11-24 + */ +@Data +@ToString +@EqualsAndHashCode +@NoArgsConstructor +@Accessors(chain = true) +@TableName("ft_sync") +public class FtSyncPatientDao implements Serializable { + +private static final long serialVersionUID=1L; + + + /** 住院号 */ + @TableField(value = "hospital_id") + private String hospitalid; + + /** 姓名 */ + private String name; + + // 科室名称 + @TableField("depart_name") + private String departName; + + // 床号 + @TableField("bed_id") + private String bedId; + +} diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtFoodDaoMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtFoodDaoMapper.java index 3d0ee006f..ab347a719 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtFoodDaoMapper.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtFoodDaoMapper.java @@ -2,6 +2,7 @@ package com.ruoyi.system.fantang.mapper; import com.ruoyi.system.fantang.domain.FtFoodDao; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.springframework.stereotype.Repository; /** * 食品管理Mapper接口 @@ -9,6 +10,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; * @author ft * @date 2020-11-24 */ +@Repository public interface FtFoodDaoMapper extends BaseMapper { } diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/ftRemotePatientDaoMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtRemotePatientDaoMapper.java similarity index 58% rename from ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/ftRemotePatientDaoMapper.java rename to ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtRemotePatientDaoMapper.java index 40830b947..f1b70ba0a 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/ftRemotePatientDaoMapper.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtRemotePatientDaoMapper.java @@ -2,8 +2,10 @@ package com.ruoyi.system.fantang.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.ruoyi.system.fantang.domain.FtRemotePatientDao; +import org.springframework.stereotype.Repository; -public interface ftRemotePatientDaoMapper extends BaseMapper { +@Repository +public interface FtRemotePatientDaoMapper extends BaseMapper { } diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtSyncPatientDaoMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtSyncPatientDaoMapper.java new file mode 100644 index 000000000..bfd7078aa --- /dev/null +++ b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtSyncPatientDaoMapper.java @@ -0,0 +1,9 @@ +package com.ruoyi.system.fantang.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ruoyi.system.fantang.domain.FtRemotePatientDao; +import org.springframework.stereotype.Repository; + +@Repository +public interface FtSyncPatientDaoMapper extends BaseMapper { +} diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/ISyncPatientService.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/ISyncPatientService.java new file mode 100644 index 000000000..2d95a49c1 --- /dev/null +++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/ISyncPatientService.java @@ -0,0 +1,12 @@ +package com.ruoyi.system.service; + +import com.ruoyi.system.fantang.domain.FtRemotePatientDao; + +import java.util.List; + +/** + * 远程病患数据同步服务层接口 + */ +public interface ISyncPatientService { + public Integer insertToLocalSync(List remotePatientDaoList); +} diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SyncPatientServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SyncPatientServiceImpl.java new file mode 100644 index 000000000..dd3c87da5 --- /dev/null +++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SyncPatientServiceImpl.java @@ -0,0 +1,26 @@ +package com.ruoyi.system.service.impl; + +import com.ruoyi.common.annotation.DataSource; +import com.ruoyi.common.enums.DataSourceType; +import com.ruoyi.system.fantang.domain.FtRemotePatientDao; +import com.ruoyi.system.fantang.mapper.FtSyncPatientDaoMapper; +import com.ruoyi.system.service.ISyncPatientService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +@DataSource(value = DataSourceType.MASTER) +@Service +public class SyncPatientServiceImpl implements ISyncPatientService { + @Autowired + private FtSyncPatientDaoMapper syncPatientDaoMapper; + + @Override + public Integer insertToLocalSync(List remotePatientDaoList) { + for (FtRemotePatientDao dao : remotePatientDaoList) { + syncPatientDaoMapper.insert(dao); + } + return null; + } +}