From 2e952232f71eae1bf92590471fc7f5d20a1af873 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期四, 31 七月 2025 11:30:48 +0800
Subject: [PATCH] 代码提交

---
 ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java |   43 ++++++++++++++++++++++++-------------------
 1 files changed, 24 insertions(+), 19 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java b/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java
index 21b1153..00b0e56 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java
@@ -16,6 +16,7 @@
 import com.ruoyi.common.utils.http.HttpUtils;
 import com.smartor.common.LSHospTokenUtil;
 import com.smartor.domain.*;
+import com.smartor.mapper.HeLibraryMapper;
 import com.smartor.mapper.PatArchiveMapper;
 import com.smartor.mapper.ServiceSubtaskMapper;
 import com.smartor.mapper.ServiceTaskMapper;
@@ -62,6 +63,9 @@
 
     @Autowired
     private ServiceSubtaskMapper ivrTaskcallMapper;
+
+    @Autowired
+    private HeLibraryMapper heLibraryMapper;
 
     @Autowired
     private ServiceTaskMapper ivrTaskMapper;
@@ -275,16 +279,13 @@
                     subIds.clear();
                     subIds.addAll(lssubIds);
                     lssubIds.clear();
-                }
-                else if (descByCode.equals("澶氬獟浣�")) {
+                } else if (descByCode.equals("澶氬獟浣�")) {
                     //澶氬獟浣�
                     continue;
-                }
-                else if (descByCode.equals("绾歌川")) {
+                } else if (descByCode.equals("绾歌川")) {
                     //绾歌川
                     continue;
-                }
-                else if (descByCode.equals("鐭俊")) {
+                } else if (descByCode.equals("鐭俊")) {
                     //鐭俊
                     //瀵箄rl涓袱涓弬鏁板姞瀵�
                     RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
@@ -354,7 +355,6 @@
                                 serviceOutPath.setParam1(taskId);
                                 serviceOutPath.setParam2(patid);
                                 serviceOutPath.setParam6(subId);
-//                                serviceOutPath.setParam3(URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()));
                                 serviceOutPath.setParam3(ivrTask1.getTaskName());
                                 serviceOutPath.setCreateTime(new Date());
                                 iServiceOutPathService.insertServiceOutPath(serviceOutPath);
@@ -362,15 +362,22 @@
                                 serviceOutPath.setRadix(format);
                                 serviceOutPath.setUpdateTime(new Date());
                                 iServiceOutPathService.updateServiceOutPath(serviceOutPath);
-//                                sendMagParam.setUrl(ip + ":" + req_path + "/outsideChainxj?param1=" + taskId + "&param2=" + patid + "&param3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "&param5=false");
-                                sendMagParam.setPhone(serviceSubtask.getPhone());
-                                sendMagParam.setUrl(ip + ":" + req_path + "/xj?p=" + format);
-                                if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) {
-                                    sendMagParam.setContent("銆愭櫙瀹佺暡鏃忚嚜娌诲幙浜烘皯鍖婚櫌銆戞偍濂斤紝閭�璇锋偍濉啓鍑洪櫌瀹f暀璋冩煡琛紝璇风偣鍑�" + sendMagParam.getUrl() + "鏌ョ湅銆傛劅璋㈡偍閰嶅悎锛�");
-                                } else if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) {
-                                    sendMagParam.setContent("銆愪附姘翠腑鍖婚櫌銆戞偍濂斤紝閭�璇锋偍濉啓鍑洪櫌瀹f暀璋冩煡琛紝璇风偣鍑�" + sendMagParam.getUrl() + "鏌ョ湅銆傛劅璋㈡偍閰嶅悎锛�");
-                                } else
-                                    sendMagParam.setContent("銆愭柊鍗庡尰闄€�戞偍濂斤紝閭�璇锋偍濉啓鍑洪櫌瀹f暀璋冩煡琛紝璇风偣鍑�" + sendMagParam.getUrl() + "鏌ョ湅銆傛劅璋㈡偍閰嶅悎锛�");
+                                //闇�瑕侀�氳繃妯℃澘ID鍘诲垽鏂鍙戠殑鍐呭鏄鏁欒繕鏄�氱煡
+                                HeLibrary heLibrary = heLibraryMapper.selectHeLibraryById(serviceSubtask.getLibtemplateid());
+                                if (heLibrary.getHetype().equals("1")) {
+                                    sendMagParam.setPhone(serviceSubtask.getPhone());
+                                    sendMagParam.setUrl(ip + ":" + req_path + "/xj?p=" + format);
+                                    if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) {
+                                        sendMagParam.setContent("銆愭櫙瀹佺暡鏃忚嚜娌诲幙浜烘皯鍖婚櫌銆戞偍濂斤紝閭�璇锋偍濉啓鍑洪櫌瀹f暀璋冩煡琛紝璇风偣鍑�" + sendMagParam.getUrl() + "鏌ョ湅銆傛劅璋㈡偍閰嶅悎锛�");
+                                    } else if (serviceSubtask.getOrgid().equals("47255004333112711A1001")) {
+                                        sendMagParam.setContent("銆愪附姘翠腑鍖婚櫌銆戞偍濂斤紝閭�璇锋偍濉啓鍑洪櫌瀹f暀璋冩煡琛紝璇风偣鍑�" + sendMagParam.getUrl() + "鏌ョ湅銆傛劅璋㈡偍閰嶅悎锛�");
+                                    } else
+                                        sendMagParam.setContent("銆愭柊鍗庡尰闄€�戞偍濂斤紝閭�璇锋偍濉啓鍑洪櫌瀹f暀璋冩煡琛紝璇风偣鍑�" + sendMagParam.getUrl() + "鏌ョ湅銆傛劅璋㈡偍閰嶅悎锛�");
+                                } else {
+                                    //閫氱煡
+                                    sendMagParam.setPhone(serviceSubtask.getPhone());
+                                    sendMagParam.setContent(heLibrary.getPreachcontent());
+                                }
                             }
                             //鐭俊杩橀渶瑕佹ā鏉�
                             String s = null;
@@ -409,7 +416,6 @@
                             }
                             if (s.equals("true")) {
                                 //鍦ㄥ瓙浠诲姟琛ㄩ噷璁板綍涓�涓�
-                                log.error("serviceSubtask淇濆瓨鎴愬姛浜嗗悧锛燂細{}", s);
                                 String uuid = UUID.randomUUID().toString();
                                 serviceSubtask.setResult("success");
                                 serviceSubtask.setRemark("鐭俊鍙戦�佹垚鍔�");
@@ -457,8 +463,7 @@
                     subIds.clear();
                     subIds.addAll(lssubIds);
                     lssubIds.clear();
-                }
-                else if (descByCode.equals("鍏紬鍙�")) {
+                } else if (descByCode.equals("鍏紬鍙�")) {
                     //鍏紬鍙�
                     RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
                     String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key);

--
Gitblit v1.9.3