From b6fce30916b9c432df2a46a49e69b21be08b860b Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期五, 06 十一月 2026 10:36:03 +0800
Subject: [PATCH] 代码提交

---
 ruoyi-quartz/src/main/java/com/ruoyi/quartz/controller/CollectHISController.java |   24 +++++++++++++++---------
 1 files changed, 15 insertions(+), 9 deletions(-)

diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/controller/CollectHISController.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/controller/CollectHISController.java
index 0de0204..67b4806 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/controller/CollectHISController.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/controller/CollectHISController.java
@@ -5,9 +5,9 @@
 import com.ruoyi.common.core.domain.entity.SysDept;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.quartz.service.ICollectHISService;
-import com.smartor.domain.HnDataGatherVO;
-import com.smartor.domain.Icd10;
-import com.smartor.service.IHNGatherPatArchiveService;
+import com.ruoyi.datacollection.domain.HnDataGatherVO;
+import com.ruoyi.common.core.domain.entity.Icd10;
+import com.ruoyi.datacollection.service.IHNGatherPatArchiveService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
@@ -31,10 +31,13 @@
     @PostMapping("/collect")
     @ApiOperation("鍚屾鐥呬汉鐩稿叧鏁版嵁")
     public AjaxResult hnDataGather(@RequestBody HnDataGatherVO hnDataGatherVO) {
+        try {
+            Integer count =ichService.sync();
+            return AjaxResult.success(count);
+        } catch (Exception ex) {
+            return AjaxResult.error(ex.getMessage());
+        }
 
-        //Boolean aBoolean = ichService.hnDataGather(hnDataGatherVO);
-       Integer count= ichService.sync();
-        return AjaxResult.success(count);
     }
 
     /**
@@ -48,13 +51,16 @@
     }
 
     /**
-     * 鐢ㄦ埛淇℃伅闆嗗悎淇℃伅鏁版嵁閲囬泦
+     * 鐢ㄦ埛淇℃伅闆嗗悎淇℃伅鏁版嵁閲囬泦锛堝紓姝ユ墽琛岋紝鎺ュ彛绔嬪嵆杩斿洖锛�
      */
     @PostMapping("/collectUser")
     @ApiOperation("鍚屾鐢ㄦ埛淇℃伅")
     public AjaxResult selectUserList(@RequestBody SysUser sysUser) {
-        Integer integer = ichService.selectUserList(sysUser);
-        return AjaxResult.success(integer);
+        boolean submitted = ichService.selectUserListAsync(sysUser);
+        if (!submitted) {
+            return AjaxResult.warn("鐢ㄦ埛淇℃伅鍚屾浠诲姟姝e湪鎵ц涓紝璇峰嬁閲嶅鎻愪氦");
+        }
+        return AjaxResult.success("鐢ㄦ埛淇℃伅鍚屾浠诲姟宸叉彁浜わ紝鍚庡彴鎵ц涓紝璇烽�氳繃鏃ュ織鏌ョ湅杩涘害");
     }
 
     /**

--
Gitblit v1.9.3