From 63d72d7f51df3e5bd360698766c2746919eb063f Mon Sep 17 00:00:00 2001
From: czx <28353131@qq.com>
Date: Thu, 26 Nov 2020 11:29:02 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E5=90=8C=E6=AD=A5=E8=BF=9C?=
 =?UTF-8?q?=E7=A8=8B=E7=97=85=E6=82=A3=E6=95=B0=E6=8D=AE=E5=88=B0=E6=9C=AC?=
 =?UTF-8?q?=E5=9C=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../fantang/mapper/FtPatientDaoMapper.java    | 16 ++++++++++
 .../service/impl/SyncPatientServiceImpl.java  | 30 ++++++++++++++++++-
 2 files changed, 45 insertions(+), 1 deletion(-)

diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtPatientDaoMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtPatientDaoMapper.java
index 7bc928821..06625a91b 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtPatientDaoMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/fantang/mapper/FtPatientDaoMapper.java
@@ -2,6 +2,9 @@ package com.ruoyi.system.fantang.mapper;
 
 import com.ruoyi.system.fantang.domain.FtPatientDao;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Update;
+import org.springframework.stereotype.Repository;
 
 /**
  * 病人管理Mapper接口
@@ -9,6 +12,19 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  * @author ft
  * @date 2020-11-24
  */
+@Repository
 public interface FtPatientDaoMapper extends BaseMapper<FtPatientDao> {
+    @Update("update ft_patient set sync_flag = 0 where off_flag = 0")
+    public int initForSync();
+
+    @Update("update ft_patient a, ft_sync b set a.name= b.name, a.bed_id = b.bed_id,  a.sync_flag = 1 where a.hospital_id = b.hospital_id")
+    public int syncEqualHospitalId();
+
+    @Insert("Insert into ft_patient (name, bed_id, hospital_id, sync_flag) select name, bed_id, hospital_id, 2 from ft_sync where hospital_id not in (select hospital_id from ft_patient)")
+    public int syncNewHospitalId();
+
+    @Update("update ft_patient set off_flag = 1 where sync_flag = 0")
+    public int updateOffHospitalFlag();
+
 
 }
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
index dd3c87da5..664d7760e 100644
--- 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
@@ -3,6 +3,7 @@ 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.FtPatientDaoMapper;
 import com.ruoyi.system.fantang.mapper.FtSyncPatientDaoMapper;
 import com.ruoyi.system.service.ISyncPatientService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,11 +17,38 @@ public class SyncPatientServiceImpl implements ISyncPatientService {
     @Autowired
     private FtSyncPatientDaoMapper syncPatientDaoMapper;
 
+    @Autowired
+    private FtPatientDaoMapper patientDaoMapper;
+
+    // 从远程数据源插上病患数据
     @Override
     public Integer insertToLocalSync(List<FtRemotePatientDao> remotePatientDaoList) {
+        // 情况本地中间表数据
+        syncPatientDaoMapper.delete(null);
+
+        // 遍历数据源，逐条插入本地中间表
         for (FtRemotePatientDao dao : remotePatientDaoList) {
             syncPatientDaoMapper.insert(dao);
         }
-        return null;
+
+        // 初始化本地病患表准备同步，将标志位置“0”
+        int ret = patientDaoMapper.initForSync();
+
+        // 更新住院号相同的记录，并标注
+        ret = patientDaoMapper.syncEqualHospitalId();
+        System.out.println(ret);
+
+        // 从中间表添加新增病患数据
+        ret = patientDaoMapper.syncNewHospitalId();
+        System.out.println(ret);
+
+        // 将没有同步的病患数据设置为出院状态
+        patientDaoMapper.updateOffHospitalFlag();
+
+
+
+
+
+        return remotePatientDaoList.size();
     }
 }