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 + "¶m2=" + patid + "¶m3=" + URLEncoder.encode(ivrTask1.getTaskName(), StandardCharsets.UTF_8.toString()) + "¶m5=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