From f2cc333b963cb0de81aebc5ae3a8c247e99243d8 Mon Sep 17 00:00:00 2001
From: 陈昶聿 <chychen@nbjetron.com>
Date: 星期二, 02 六月 2026 18:21:27 +0800
Subject: [PATCH] 【市一】同步手术视图

---
 ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/CollectHISServiceImpl.java |   82 +++++++++++++++++++++++++++++++++++++++++
 1 files changed, 82 insertions(+), 0 deletions(-)

diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/CollectHISServiceImpl.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/CollectHISServiceImpl.java
index 3c5eef3..5569719 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/CollectHISServiceImpl.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/CollectHISServiceImpl.java
@@ -74,7 +74,11 @@
 
     @Value("${spring.profiles.active}")
     private String active;
+    @Autowired
+    private PatMedOperationMapper patMedOperationMapper;
 
+    @Autowired
+    private PatMedOperationItemMapper patMedOperationItemMapper;
 
     @Override
     public List<PatArchive> selectPatArchiveList(PatArchive patArchive) {
@@ -115,6 +119,7 @@
             //鍚屾浣忛櫌鐥呬汉淇℃伅
             List<Map<String, Object>> syncTemp = syncList.stream().filter(row -> row.get("syncName").equals("pat_med_inhosp")).collect(Collectors.toList());
             if (syncTemp.size() > 0) {
+                log.info("startTime:" + syncTemp.get(0).get("startTime") + ", endTime: ", endTime);
                 count += syncMedInhosp(syncTemp.get(0).get("startTime") + "", endTime);
                 utilsMapper.updateSql("update sys_sync_time set startTime='" + endTime + "' where syncName='pat_med_inhosp' ");
             }
@@ -126,6 +131,12 @@
                 utilsMapper.updateSql("update sys_sync_time set startTime='" + endTime + "' where syncName='pat_med_outhosp' ");
             }
 
+            //鍚屾鎵嬫湳淇℃伅
+            syncTemp = syncList.stream().filter(row -> row.get("syncName").equals("pat_med_operation")).collect(Collectors.toList());
+            if (syncTemp.size() > 0) {
+                count += syncOper(syncTemp.get(0).get("startTime") + "", endTime);
+                utilsMapper.updateSql("update sys_sync_time set startTime='" + endTime + "' where syncName='pat_med_operation' ");
+            }
 
         } else {
             log.info("鍚屾浠诲姟鏃堕棿sys_sync_time琛ㄤ腑娌℃湁闇�瑕佸悓姝ョ殑浠诲姟");
@@ -310,6 +321,77 @@
         return count;
     }
 
+    /**
+     * 鍚屾鎵嬫湳淇℃伅
+     *
+     * @param
+     * @return
+     */
+    @Override
+    public Integer syncOper(String startTime, String endTime) {
+        Integer count = 0;
+        PatMedOperation patMedOperation = new PatMedOperation();
+        patMedOperation.setLastStartTime(startTime);
+        patMedOperation.setLastEndTime(endTime);
+        List<PatMedOperation> patMedOperations = chMapper.selectOperList(patMedOperation);
+        log.info("鍚屾鎵嬫湳淇℃伅鏁伴噺" + patMedOperations.size());
+        for (PatMedOperation operation : patMedOperations) {
+            try {
+                PatMedOperation oper = new PatMedOperation();
+                oper.setOpid(operation.getOpid());
+                List<PatMedOperation> patMedOperations1 = patMedOperationMapper.selectPatMedOperationList(oper);
+                if (CollectionUtils.isNotEmpty(patMedOperations1)) {
+                    operation.setId(patMedOperations1.get(0).getId());
+                    operation.setUpdateTime(new Date());
+                    count += patMedOperationMapper.updatePatMedOperation(patMedOperations1.get(0));
+                    syncOperItem(operation);
+                } else {
+                    operation.setCreateTime(new Date());
+                    count += patMedOperationMapper.insertPatMedOperation(operation);
+                    syncOperItem(operation);
+                }
+            } catch (Exception ex) {
+                log.info("鍚屾鎵嬫湳淇℃伅:" + ex.getMessage());
+            }
+        }
+        return count;
+    }
+
+    /**
+     * 鍚屾鎵嬫湳淇℃伅
+     *
+     * @param
+     * @return
+     */
+    private Integer syncOperItem(PatMedOperation operation) {
+        Integer count = 0;
+        PatMedOperationItem patMedOperationItem = new PatMedOperationItem();
+        patMedOperationItem.setOrgid(operation.getOrgid());
+        if(StringUtils.isNotEmpty(operation.getOpid())){
+            patMedOperationItem.setOpid(Long.valueOf(operation.getOpid()));
+            List<PatMedOperationItem> patMedOperationItems = chMapper.selectOperItemList(patMedOperationItem);
+            log.info("鍚屾鎵嬫湳璇︽儏淇℃伅鏁伴噺" + patMedOperationItems.size());
+            for (PatMedOperationItem operationItem : patMedOperationItems) {
+                try {
+                    PatMedOperationItem operItem = new PatMedOperationItem();
+                    operItem.setOpid(operationItem.getOpid());
+                    operItem.setOperationid(operationItem.getOperationid());
+                    List<PatMedOperationItem> patMedOperationItems1 = patMedOperationItemMapper.selectPatMedOperationItemList(operItem);
+                    if (CollectionUtils.isNotEmpty(patMedOperationItems1)) {
+                        operationItem.setId(patMedOperationItems1.get(0).getId());
+                        operationItem.setUpdateTime(new Date());
+                        count += patMedOperationItemMapper.updatePatMedOperationItem(operationItem);
+                    } else {
+                        operation.setCreateTime(new Date());
+                        count += patMedOperationItemMapper.insertPatMedOperationItem(operationItem);
+                    }
+                } catch (Exception ex) {
+                    log.info("鍚屾鎵嬫湳璇︽儏淇℃伅:" + ex.getMessage());
+                }
+            }
+        }
+        return count;
+    }
     @Override
     public Integer selectPatMedInhospList(PatMedInhosp patMedInhosp) {
         List<PatMedInhosp> patMedInhospList = chMapper.selectPatMedInhospList(patMedInhosp);

--
Gitblit v1.9.3