From 732024c03df1d810b8f5a8a526066967f1bfbb5d Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期五, 26 六月 2026 17:53:27 +0800
Subject: [PATCH] 南华部分功能提交

---
 smartor/src/main/java/com/smartor/service/impl/ServiceSubtaskServiceImpl.java |  176 ++++++++++++++++++++++++++++++++++++++--------------------
 1 files changed, 116 insertions(+), 60 deletions(-)

diff --git a/smartor/src/main/java/com/smartor/service/impl/ServiceSubtaskServiceImpl.java b/smartor/src/main/java/com/smartor/service/impl/ServiceSubtaskServiceImpl.java
index b4d9b1c..9c5449b 100644
--- a/smartor/src/main/java/com/smartor/service/impl/ServiceSubtaskServiceImpl.java
+++ b/smartor/src/main/java/com/smartor/service/impl/ServiceSubtaskServiceImpl.java
@@ -12,7 +12,10 @@
 import com.ruoyi.common.utils.*;
 import com.ruoyi.common.core.service.IConfigService;
 import com.ruoyi.common.utils.spring.SpringUtils;
+import com.ruoyi.system.domain.SysConfig;
+import com.ruoyi.system.mapper.SysConfigMapper;
 import com.smartor.common.FtpService;
+import com.smartor.common.MtSubmitSmUtil;
 import com.smartor.config.PhoneUtils;
 import com.smartor.domain.DTO.ServiceSubtaskDetailDTO;
 import com.smartor.domain.*;
@@ -135,6 +138,12 @@
 
     @Value("${ASRCallBackPath}")
     private String ASRCallBackPath;
+
+    @Autowired
+    private MtSubmitSmUtil mtSubmitSmUtil;
+
+    @Autowired
+    private SysConfigMapper sysConfigMapper;
 
     @Autowired
     private RedisTemplate redisTemplate;
@@ -343,18 +352,17 @@
 //            serviceTaskVO.setPreachform(result);
         }
 
-        if(StringUtils.isNotEmpty(serviceTaskVO.getPreachformDesc())){
+        if (StringUtils.isNotEmpty(serviceTaskVO.getPreachformDesc())) {
             //鐩存帴閫氳繃PreachformDesc鐢熸垚List杩斿洖
             try {
                 List<Map<String, Object>> mapList = objectMapper.readValue(serviceTaskVO.getPreachformDesc(), List.class);
                 serviceTaskVO.setPreachformList(mapList);
-            }catch (Exception e) {
+            } catch (Exception e) {
             }
-        }else {
-            if(CollectionUtils.isNotEmpty(list)){
+        } else {
+            if (CollectionUtils.isNotEmpty(list)) {
                 //鑾峰彇璇ユ偅鑰呮墍鏈夌殑鎵ц鐘舵��
-                List<ServiceSubtaskPreachform> serviceSubtaskPreachformList = serviceSubtaskPreachformLists.stream()
-                        .filter((item -> item.getSubid().equals(list.get(0).getId()) && item.getTaskid().equals(serviceTask.getTaskid()))).collect(Collectors.toList());
+                List<ServiceSubtaskPreachform> serviceSubtaskPreachformList = serviceSubtaskPreachformLists.stream().filter((item -> item.getSubid().equals(list.get(0).getId()) && item.getTaskid().equals(serviceTask.getTaskid()))).collect(Collectors.toList());
                 List<Map<String, Object>> resultList = serviceSubtaskPreachformList.stream().map(item -> {
                     Map<String, Object> map = new HashMap<>();
                     map.put("sort", item.getSort());
@@ -372,16 +380,12 @@
     @Override
     public List<ServiceSubtaskRes> patItem(ServiceSubtaskEntity serviceSubtaskEntity) {
         if (serviceSubtaskEntity.getSendstateView() != null) {
-            //            1锛氬緟闅忚锛�2 寰呭彂閫侊級锛�2锛氶殢璁夸腑锛�3 宸插彂閫併��1 琚鍙栵級銆�3锛氭湭瀹屾垚锛�5 鍙戦�佸け璐ャ��7銆佽秴鏃讹級銆�4锛氬凡瀹屾垚锛� 6 宸插畬鎴愶級銆�5锛氭棤闇�闅忚锛�4 涓嶆墽琛岋級
+            //            1锛氬緟闅忚锛�1 琚鍙栥��2 寰呭彂閫併��3 宸插彂閫併��5 鍙戦�佸け璐ャ��7銆佽秴鏃讹級锛�2锛氬凡瀹屾垚锛� 6 宸插畬鎴愶級銆�3锛氭棤闇�闅忚锛�4 涓嶆墽琛岋級
             if (serviceSubtaskEntity.getSendstateView() == 1)
-                serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(2L)));
+                serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(1L, 2L, 3L, 5L, 7L)));
             if (serviceSubtaskEntity.getSendstateView() == 2)
-                serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(1L, 3L)));
-            if (serviceSubtaskEntity.getSendstateView() == 3)
-                serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(5L, 7L)));
-            if (serviceSubtaskEntity.getSendstateView() == 4)
                 serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(6L)));
-            if (serviceSubtaskEntity.getSendstateView() == 5)
+            if (serviceSubtaskEntity.getSendstateView() == 3)
                 serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(4L)));
         }
 
@@ -394,13 +398,10 @@
                 serviceSubtaskRes.setContinueContent(serviceSubtask.getContinueContent());
             }
 //            1锛氬緟闅忚锛�2 寰呭彂閫侊級锛�2锛氶殢璁夸腑锛�3 宸插彂閫併��1 琚鍙栵級銆�3锛氭湭瀹屾垚锛�5 鍙戦�佸け璐ャ��7銆佽秴鏃讹級銆�4锛氬凡瀹屾垚锛� 6 宸插畬鎴愶級銆�5锛氭棤闇�闅忚锛�4 涓嶆墽琛岋級
-            if (serviceSubtaskRes.getSendstate() == 2) serviceSubtaskRes.setSendstateView(1L);
-            if (serviceSubtaskRes.getSendstate() == 1 || serviceSubtaskRes.getSendstate() == 3L)
-                serviceSubtaskRes.setSendstateView(2L);
-            if (serviceSubtaskRes.getSendstate() == 5 || serviceSubtaskRes.getSendstate() == 7L)
-                serviceSubtaskRes.setSendstateView(3L);
-            if (serviceSubtaskRes.getSendstate() == 6) serviceSubtaskRes.setSendstateView(4L);
-            if (serviceSubtaskRes.getSendstate() == 4) serviceSubtaskRes.setSendstateView(5L);
+            if (serviceSubtaskRes.getSendstate() == 1 || serviceSubtaskRes.getSendstate() == 2L || serviceSubtaskRes.getSendstate() == 3L || serviceSubtaskRes.getSendstate() == 5 || serviceSubtaskRes.getSendstate() == 7L)
+                serviceSubtaskRes.setSendstateView(1L);
+            if (serviceSubtaskRes.getSendstate() == 6) serviceSubtaskRes.setSendstateView(2L);
+            if (serviceSubtaskRes.getSendstate() == 4) serviceSubtaskRes.setSendstateView(3L);
             serviceSubtaskResList.add(serviceSubtaskRes);
         }
         return serviceSubtaskResList;
@@ -475,13 +476,16 @@
             // MyBatis 鐨� SUM 鍦ㄦ病鏈夊尮閰嶈鏃朵細杩斿洖 null
             result.putIfAbsent("wzx", 0);
             result.putIfAbsent("ysf", 0);
-            result.putIfAbsent("yc", 0);
-            result.putIfAbsent("jg", 0);
             result.putIfAbsent("fssb", 0);
             result.putIfAbsent("yfs", 0);
             result.putIfAbsent("blq", 0);
-            result.putIfAbsent("dsf", 0);
             result.putIfAbsent("total", 0);
+            result.putIfAbsent("wxsf", 0);
+            result.putIfAbsent("xsf", 0);
+            result.putIfAbsent("dsf", 0);
+            result.putIfAbsent("ywc", 0);
+            result.putIfAbsent("yc", 0);
+            result.putIfAbsent("jg", 0);
         }
         return result;
     }
@@ -699,8 +703,8 @@
                     //鍗楀崕闄勪竴鐨刬cd10code鏄湁閲嶅鐨勶紝鎵�浠ヤ笉鑳界敤鍗楀崕闄勪竴鐨刬cd10code鍘绘煡璇�
                     log.info("----serviceTaskdiag鐨勫�间负锛歿}", serviceTaskdiag);
                     if (!StringUtils.isEmpty(serviceTaskVO.getIcd10name())) {
-                        String[] Icd10Names = serviceTaskVO.getIcd10name().split(",");
-                        String[] Icd10codes = serviceTaskVO.getIcd10code().split(",");
+                        String[] Icd10Names = serviceTaskVO.getIcd10name().split("$");
+                        String[] Icd10codes = serviceTaskVO.getIcd10code().split("$");
                         for (int i = 0; i < Icd10Names.length; i++) {
                             serviceTaskdiag.setIcd10code(Icd10codes[i]);
                             serviceTaskdiag.setIcd10name(Icd10Names[i]);
@@ -778,8 +782,8 @@
                     serviceSubtask.setInhospid(patTaskRelevance.getHospid());
                     //鏂板缓瀹屾垚灏辨槸寰呭彂閫佺姸鎬�
                     serviceSubtask.setSendstate(2L);
-                    serviceSubtask.setDeptcode(StringUtils.isNotEmpty(patTaskRelevance.getDeptcode())?patTaskRelevance.getDeptcode():serviceTaskVO.getDeptcode());
-                    serviceSubtask.setDeptname(StringUtils.isNotEmpty(patTaskRelevance.getDeptName())?patTaskRelevance.getDeptName():serviceTaskVO.getDeptname());
+                    serviceSubtask.setDeptcode(StringUtils.isNotEmpty(patTaskRelevance.getDeptcode()) ? patTaskRelevance.getDeptcode() : serviceTaskVO.getDeptcode());
+                    serviceSubtask.setDeptname(StringUtils.isNotEmpty(patTaskRelevance.getDeptName()) ? patTaskRelevance.getDeptName() : serviceTaskVO.getDeptname());
                     serviceSubtask.setLeavehospitaldistrictcode(patTaskRelevance.getLeavehospitaldistrictcode());
                     serviceSubtask.setLeavehospitaldistrictname(patTaskRelevance.getLeavehospitaldistrictname());
                     serviceSubtask.setType(serviceTaskVO.getType());
@@ -802,7 +806,8 @@
                     serviceSubtask.setUpdateBy(serviceTask.getCreateBy());
                     serviceSubtask.setVisitTime(DateUtils.parseDate(serviceTaskVO.getShowTimeMorn()));
                     //濡傛灉绔嬪嵆鎵ц锛屾椂闂村氨鏄綋鍓嶆椂闂�
-                    if(serviceTaskVO.getSendType()!=null&&serviceTaskVO.getSendType()==2) serviceSubtask.setVisitTime(new Date());
+                    if (serviceTaskVO.getSendType() != null && serviceTaskVO.getSendType() == 2)
+                        serviceSubtask.setVisitTime(new Date());
                     if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1) {
                         serviceSubtask.setLongSendTime(patTaskRelevance.getLongSendTime());
                         serviceSubtask.setVisitTime(patTaskRelevance.getVisittime());
@@ -957,7 +962,7 @@
                     if (StringUtils.isNotEmpty(serviceTaskVO.getIcd10code())) {
                         String[] icd10codes = serviceTaskVO.getIcd10code().split(",");
                         String[] icd10names = serviceTaskVO.getIcd10name().split(",");
-                        if(!active.equals("nhfy")&&!active.equals("druid")){
+                        if (!active.equals("nhfy") && !active.equals("druid")) {
                             if (icd10codes.length != icd10names.length) {
                                 throw new BaseException("鐤剧梾缂栫爜鍜岀柧鐥呭悕绉版暟閲忎笉涓�鑷�");
                             }
@@ -988,43 +993,38 @@
 //                    }
 //                serviceTaskoper.setOpcode(serviceTaskVO.getOpcode());
                     serviceTaskoper.setOpdesc(serviceTaskVO.getOpdesc());
-                    serviceTaskoper.setOplevelcode(serviceTaskVO.getOplevelcode());
+//                    serviceTaskoper.setOplevelcode(serviceTaskVO.getOplevelcode());
                     serviceTaskoper.setTaskId(serviceTask.getTaskid());
                     serviceTaskoper.setTaskName(serviceTask.getTaskName());
                     serviceTaskoper.setLongtask(Long.valueOf(serviceTask.getLongTask()));
                     serviceTaskoper.setGuid(serviceTask.getGuid());
                     serviceTaskoper.setOrgid(serviceTask.getOrgid());
-                    serviceTaskoper.setCreateTime(new Date());
-//                    if (StringUtils.isNotEmpty(serviceTaskVO.getOpcode())) {
-//                        String[] opcodes = serviceTaskVO.getOpcode().split(",");
-//                        for (String opcode : opcodes) {
-//                            //鍏堟煡璇竴涓嬫槸鍚﹀瓨鍦�
-//                            ServiceTaskoper serviceTaskoper2 = new ServiceTaskoper();
-//                            serviceTaskoper2.setTaskId(serviceTaskVO.getTaskid());
-//                            serviceTaskoper2.setOpcode(serviceTaskVO.getOpcode());
-//                            List<ServiceTaskoper> serviceTaskopers = serviceTaskoperService.selectServiceTaskoperList(serviceTaskoper2);
-//
-//                            serviceTaskoper.setOpcode(opcode);
-//                            log.info("----serviceTaskoper鐨勫�间负锛歿}", serviceTaskoper);
-//                            if (CollectionUtils.isNotEmpty(serviceTaskopers)) {
-//                                serviceTaskoper.setId(serviceTaskopers.get(0).getId());
-//                                serviceTaskoperService.updateServiceTaskoper(serviceTaskoper);
-//                            } else {
-//                                serviceTaskoperService.insertServiceTaskoper(serviceTaskoper);
-//                            }
-//                        }
-//                    }
-                    ServiceTaskoper serviceTaskoper2 = new ServiceTaskoper();
-                    serviceTaskoper2.setTaskId(serviceTaskVO.getTaskid());
-                    serviceTaskoper2.setOrgid(serviceTask.getOrgid());
-//                    serviceTaskoper2.setOplevelcode(serviceTaskVO.getOplevelcode());
-                    List<ServiceTaskoper> serviceTaskopers = serviceTaskoperService.selectServiceTaskoperList(serviceTaskoper2);
 
-                    if (CollectionUtils.isNotEmpty(serviceTaskopers)) {
-                        serviceTaskoper.setId(serviceTaskopers.get(0).getId());
-                        serviceTaskoperService.updateServiceTaskoper(serviceTaskoper);
-                    } else {
-                        serviceTaskoperService.insertServiceTaskoper(serviceTaskoper);
+                    serviceTaskoper.setDeptCode(serviceTask1.getDeptcode());
+                    serviceTaskoper.setDeptName(serviceTask1.getDeptname());
+                    serviceTaskoper.setWardCode(serviceTask1.getLeavehospitaldistrictcode());
+                    serviceTaskoper.setWardName(serviceTask1.getLeavehospitaldistrictname());
+
+                    serviceTaskoper.setCreateTime(new Date());
+                    if (StringUtils.isNotEmpty(serviceTaskVO.getOplevelcode())) {
+                        String[] opLevelcodes = serviceTaskVO.getOplevelcode().split(",");
+                        for (String opLevelcode : opLevelcodes) {
+                            //鍏堟煡璇竴涓嬫槸鍚﹀瓨鍦�
+                            log.info("----serviceTaskoper鐨勫�间负锛歿}", serviceTaskoper);
+                            ServiceTaskoper serviceTaskoper2 = new ServiceTaskoper();
+                            serviceTaskoper2.setTaskId(serviceTaskVO.getTaskid());
+                            serviceTaskoper2.setOrgid(serviceTask.getOrgid());
+                            serviceTaskoper2.setOplevelcode(opLevelcode);
+                            List<ServiceTaskoper> serviceTaskopers = serviceTaskoperService.selectServiceTaskoperList(serviceTaskoper2);
+
+                            serviceTaskoper.setOplevelcode(opLevelcode);
+                            if (CollectionUtils.isNotEmpty(serviceTaskopers)) {
+                                serviceTaskoper.setId(serviceTaskopers.get(0).getId());
+                                serviceTaskoperService.updateServiceTaskoper(serviceTaskoper);
+                            } else {
+                                serviceTaskoperService.insertServiceTaskoper(serviceTaskoper);
+                            }
+                        }
                     }
                 }
             }
@@ -3049,6 +3049,7 @@
         }
         return serviceSubtaskStatistic;
     }
+
     /**
      * 棣栨闅忚缁熻
      *
@@ -3643,6 +3644,7 @@
         serviceOutPath.setParam2(patid);
         serviceOutPath.setCreateTime(new Date());
         serviceOutPath.setParam6(subId);
+        serviceOutPath.setOrgid(serviceSubtask.getOrgid());
         iServiceOutPathService.insertServiceOutPath(serviceOutPath);
         //杞垚16杩涘埗
         String format = String.format("%03X", serviceOutPath.getId());
@@ -4490,6 +4492,60 @@
         return resultMap;
     }
 
+    @Override
+    public Map<String, Object> smsSubTask(Long subid) {
+        log.info("smsSubTask鐨勫叆鍙備负锛歿}", subid);
+        Map<String, Object> resultMap = new HashMap<>();
+        resultMap.put("code", "500");
+        resultMap.put("msg", "鍙戦�佸け璐�");
+
+        //鑾峰彇鎮h�呯殑鍩烘湰淇℃伅
+        ServiceSubtask serviceSubtask = selectServiceSubtaskById(subid);
+        RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
+        String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);
+        String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key);
+        String taskId = rsaPublicKeyExample.encryptedData(serviceSubtask.getTaskid().toString(), pub_key);
+
+        //鍙戦�佹暟鎹殑灏佽
+        ServiceOutPath serviceOutPath = new ServiceOutPath();
+        serviceOutPath.setParam1(taskId);
+        serviceOutPath.setParam2(patid);
+        serviceOutPath.setParam3(serviceSubtask.getTaskName());
+        serviceOutPath.setParam6(subId);
+        serviceOutPath.setCreateTime(new Date());
+        serviceOutPath.setOrgid(serviceSubtask.getOrgid());
+        iServiceOutPathService.insertServiceOutPath(serviceOutPath);
+        String format = String.format("%03X", serviceOutPath.getId());
+        serviceOutPath.setRadix(format);
+        serviceOutPath.setUpdateTime(new Date());
+        iServiceOutPathService.updateServiceOutPath(serviceOutPath);
+
+        SendMagParam sendMagParam = new SendMagParam();
+        sendMagParam.setType("4");
+        sendMagParam.setPhone(serviceSubtask.getPhone());
+        sendMagParam.setUrl(StringUtils.isNotEmpty(req_path) ? localIP + ":" + req_path + "/wt?p=" + format : localIP + "/wt?p=" + format);
+
+        SysConfig sysConfig = new SysConfig();
+
+        sysConfig = sysConfigMapper.checkConfigKeyUnique("wj.sms.template");
+
+        if (!Objects.isNull(sysConfig)) {
+            String smsContemt = sysConfig.getConfigValue();
+            sendMagParam.setContent(smsContemt.replace("${wjurl}", sendMagParam.getUrl()));
+        }
+
+        if (active.equals("nhfy")) {
+            Map<String, Object> smsResult = mtSubmitSmUtil.submitSm(sendMagParam.getPhone(), sendMagParam.getContent());
+            if (smsResult != null && smsResult.get("result") != null && smsResult.get("result").toString().equals("0")) {
+                resultMap.put("code", "200");
+                resultMap.put("msg", "鍙戦�佹垚鍔�");
+                serviceSubtask.setRemark(StringUtils.isNotEmpty(serviceSubtask.getRemark()) ? serviceSubtask.getRemark() + ";鐭俊鍙戦�佹垚鍔�" : "鐭俊鍙戦�佹垚鍔�");
+                log.info("鏄惁鍙戦�佹垚鍔燂細{}", serviceSubtask.getRemark());
+                updateServiceSubtask(serviceSubtask);
+            }
+        }
+        return resultMap;
+    }
 
     private Boolean saveServiceSubtaskDetail(ServiceSubtask serviceSubtask) {
         Boolean result = true;

--
Gitblit v1.9.3