From 55ede3cff5dbbbcb8675d1592a67f20d598d49e7 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期五, 18 四月 2025 14:21:28 +0800
Subject: [PATCH] 代码提交

---
 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java |   79 ++++++++++++++++++++++++++++++++++++---
 1 files changed, 72 insertions(+), 7 deletions(-)

diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
index ab247f4..347f135 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
@@ -22,6 +22,7 @@
 import com.smartor.mapper.ServiceTaskMapper;
 import com.smartor.mapper.SysUserImportMapper;
 import com.smartor.service.*;
+import com.sun.org.apache.bcel.internal.generic.NEW;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.ObjectUtils;
@@ -71,6 +72,12 @@
     private IPatMedInhospService iPatMedInhospService;
 
     @Autowired
+    private IPatMedOuthospService iPatMedOuthospService;
+
+    @Autowired
+    private IPatMedOperationService iPatMedOperationService;
+
+    @Autowired
     private IServiceSubtaskService iServiceSubtaskService;
 
     @Autowired
@@ -96,6 +103,9 @@
 
     @Value("${req_path}")
     private String req_path;
+
+    @Value("${visitHosp}")
+    private Integer visitHosp;
 
     @Autowired
     private ServiceTaskMapper serviceTaskMapper;
@@ -216,7 +226,7 @@
     public void dealHisData2() {
         //灏嗘偅鑰呬俊鎭�佸嚭闄€�侀棬璇婃暟鎹叏閮ㄩ噰闆�
         // 鎸囧畾鐨勫紑濮嬫棩鏈�
-        LocalDate endDate = LocalDate.of(2024, 9, 1);
+        LocalDate endDate = LocalDate.of(2025, 3, 3);
         // 褰撳墠鏃ユ湡
         LocalDate currentDate = LocalDate.now();
         // 瀹氫箟鏃ユ湡鏍煎紡
@@ -235,7 +245,12 @@
      * 澶勭悊鎮h�呬俊鎭紝杩涘叆瀛愪换鍔¤〃
      */
     public void dealOutHospInfo() {
+        //鍑洪櫌琛�
         iPatMedInhospService.dealOutHospInfo();
+        //闂ㄨ瘖琛�
+        if(visitHosp!=1) {
+            iPatMedOuthospService.dealOutpatientInfo();
+        }
     }
 
 
@@ -243,7 +258,7 @@
      * 澶勭悊鎵嬫湳淇℃伅锛岃繘鍏ュ瓙浠诲姟琛�
      */
     public void dealOperationInfo() {
-        iPatMedInhospService.dealOutHospInfo();
+        iPatMedOperationService.dealOperationInfo();
     }
 
     /**
@@ -331,6 +346,14 @@
                             //濡備綍浠诲姟琚�滄殏鍋溾�濇垨鈥滅粓姝⑩��
                             break;
                         }
+                        if (org.apache.commons.lang3.StringUtils.isEmpty(serviceSubtask.getPhone())) {
+                            serviceSubtask.setRemark("鎵嬫満鍙蜂负绌�");
+                            serviceSubtask.setSendstate(4L);
+                            serviceSubtask.setResult("error");
+                            serviceSubtask.setFinishtime(new Date());
+                            serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
+                            continue;
+                        }
                         boolean dateToday = isDateToday(serviceSubtask.getLongSendTime());
                         //璇存槑鏄珛鍗冲彂閫�(鍏堟妸娑堟伅鏀惧埌cache-0涓紝   displayNo涓嶇煡閬撴�庝箞閰嶇疆)
                         if (dateToday) {
@@ -366,8 +389,46 @@
                     //绾歌川
                 } else if (descByCode.equals("寰俊灏忕▼搴�")) {
                     //寰俊灏忕▼搴�
-                    for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) {
-                        log.error("寰俊灏忕▼搴忔湡浠诲姟鍙戦��---------杩涙潵浜嗗悧锛焮}", serviceSubtask);
+                    log.error("ivrTask1鐨勫�间负锛歿}", ivrTask1);
+                    if (ObjectUtils.isNotEmpty(ivrTask1) && ivrTask1.getPatCycle() == 1) {
+                        //璇存槑璇ヤ换鍔$殑鎮h�呮槸寰幆鎵ц鐨�
+                        ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO();
+                        serviceSubtaskVO.setTaskid(ivrTask1.getTaskid());
+                        List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO);
+                        //杩欓噷闇�瑕佹牴鎹韩浠借瘉鍘婚噸
+                        List<ServiceSubtask> serviceSubtaskListFilter = new ArrayList<>();
+                        aa:
+                        for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
+                            for (ServiceSubtask ss : serviceSubtaskListFilter) {
+                                if (ss.getSfzh().equals(serviceSubtask.getSfzh())) {
+                                    continue aa;
+                                }
+                            }
+                            serviceSubtaskListFilter.add(serviceSubtask);
+                        }
+                        for (ServiceSubtask serviceSubtask : serviceSubtaskListFilter) {
+                            //灏嗗瓙浠诲姟ID鍒犻櫎 銆乻endstate鏀规垚3
+                            serviceSubtask.setSendstate(3L);
+                            serviceSubtask.setId(null);
+                            serviceSubtask.setFinishtime(null);
+                            serviceSubtask.setCreateTime(new Date());
+                            serviceSubtask.setUpdateTime(new Date());
+                            //澶勭悊閲嶅鏂板闂锛屽厛鏌ヤ竴涓嬩粖澶╂槸涓嶆槸鏈夋柊澧炶繃锛屾柊澧炶繃灏变笉鏂板浜�
+                            ServiceSubtaskVO ssvo = new ServiceSubtaskVO();
+                            LocalDate today = LocalDate.now();
+                            LocalTime startOfDay = LocalTime.of(0, 0, 0);
+                            LocalTime endOfDay = LocalTime.of(23, 59, 59);
+                            Date startOfDayDate = Date.from(today.atTime(startOfDay).atZone(ZoneId.systemDefault()).toInstant());
+                            Date endOfDayDate = Date.from(today.atTime(endOfDay).atZone(ZoneId.systemDefault()).toInstant());
+                            ssvo.setCreateStartTime(startOfDayDate);
+                            ssvo.setCreateEndTime(endOfDayDate);
+                            ssvo.setCreateBy(serviceSubtask.getCreateBy());
+                            ssvo.setSendname(serviceSubtask.getSendname());
+                            ssvo.setSfzh(serviceSubtask.getSfzh());
+                            List<ServiceSubtask> serviceSubtaskListByCreateTime = serviceSubtaskMapper.selectServiceSubtaskListByCreateTime(ssvo);
+                            if (CollectionUtils.isEmpty(serviceSubtaskListByCreateTime))
+                                serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
+                        }
                     }
                 } else if (descByCode.equals("鐭俊")) {
                     RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
@@ -389,12 +450,14 @@
                                     continue;
                                 }
                                 String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);
+                                String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key);
                                 SendMagParam sendMagParam = new SendMagParam();
                                 sendMagParam.setType("4");
                                 ServiceOutPath serviceOutPath = new ServiceOutPath();
                                 serviceOutPath.setParam1(taskId);
                                 serviceOutPath.setParam2(patid);
                                 serviceOutPath.setParam3(ivrTask1.getTaskName());
+                                serviceOutPath.setParam6(subId);
                                 serviceOutPath.setCreateTime(new Date());
                                 iServiceOutPathService.insertServiceOutPath(serviceOutPath);
                                 String format = String.format("%03X", serviceOutPath.getId());
@@ -548,7 +611,7 @@
         String filename = null;
         if (cry.equals("0")) filename = "鍏ラ櫌淇℃伅" + System.currentTimeMillis();
         if (cry.equals("1")) filename = "鍑洪櫌淇℃伅" + System.currentTimeMillis();
-        File file = new File("D:\\public\\鍗庡崜闆嗘垚骞冲彴鏁版嵁\\" + filename);
+        File file = new File("D:\\public\\HIS鏁版嵁閲囬泦\\" + filename);
         if (!file.exists()) {
             // 濡傛灉鏂囦欢涓嶅瓨鍦紝鍒欏垱寤烘柊鏂囦欢
             try {
@@ -598,10 +661,10 @@
                     patArchive.setSex(thiedInhospInfo.getPatiRecordGender().equals("鐢�") ? 1L : 2L);
                     patArchive.setNation(thiedInhospInfo.getPatiNation());
                     patArchive.setNativePlace(thiedInhospInfo.getPatiNationality());
-                    patArchive.setPlaceOfResidence(thiedInhospInfo.getPatiHomeAddr());
+                    patArchive.setPlaceOfResidence(StringUtils.isNotEmpty(thiedInhospInfo.getPatiHomeAddr()) ? thiedInhospInfo.getPatiHomeAddr().replace("null", "") : "");
                     try {
                         if (StringUtils.isNotEmpty(thiedInhospInfo.getPatiBirthday()))
-                            patArchive.setBirthdate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(thiedInhospInfo.getPatiBirthday()));
+                            patArchive.setBirthdate(new SimpleDateFormat("yyyy-MM-dd").parse(thiedInhospInfo.getPatiBirthday()));
                     } catch (ParseException e) {
                         e.printStackTrace();
                     }
@@ -630,6 +693,7 @@
                 patMedInhosp.setNurseId(thiedInhospInfo.getNurseId());
                 patMedInhosp.setNurseName(thiedInhospInfo.getNurseName());
                 patMedInhosp.setSerialnum(thiedInhospInfo.getInpatientId());
+                patMedInhosp.setFuflag("1");
                 if (cry.equals("0")) {
                     patMedInhosp.setInhospstate("0");
                 } else if (cry.equals("1")) {
@@ -673,6 +737,7 @@
                 patMedInhosp.setLeavehospitaldistrictcode(thiedInhospInfo.getCurrWardId());
                 patMedInhosp.setLeavehospitaldistrictname(thiedInhospInfo.getCurrWardName());
                 patMedInhosp.setLeaveldeptid(thiedInhospInfo.getCurrDeptCode());
+                patMedInhosp.setOrgid("1");
                 //濡傛灉鏄嚭闄紝鍏堥�氳繃鎮h�呯紪鍙峰拰娴佹按鍙峰幓鏌ヤ竴涓嬶紝鎮h�呮槸鍚﹀瓨鍦紝濡傛灉瀛樺湪锛屽垯杩涜淇敼
                 PatMedInhosp inhosp = new PatMedInhosp();
                 inhosp.setPatno(patArchive.getPatientno());

--
Gitblit v1.9.3