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; + } +}