From ef81a5cbfbb98974ed1ba54d0e47b7e74a9b96b9 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期四, 06 六月 2024 15:33:55 +0800
Subject: [PATCH] 代码提交

---
 ruoyi-admin/src/main/java/com/ruoyi/web/component/RabbitMqReceiver.java |   19 ++++++++++++++-----
 1 files changed, 14 insertions(+), 5 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/component/RabbitMqReceiver.java b/ruoyi-admin/src/main/java/com/ruoyi/web/component/RabbitMqReceiver.java
index 8f5dcf8..58c5b8c 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/component/RabbitMqReceiver.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/component/RabbitMqReceiver.java
@@ -34,6 +34,7 @@
 import java.util.Map;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 
 @Slf4j
 @Component//鐩戝惉姝ら槦鍒�
@@ -107,13 +108,12 @@
      */
     @RabbitListener(queues = "task_queue", concurrency = "50")
     public void phoneVisit(String content, Message message, Channel channel) throws IOException {
-        log.error("娑堟伅杩涙潵浜�--------------");
+        System.out.println("娑堟伅杩涙潵浜�----------------");
+        IvrTaskcallMQ ivrTaskcallMQ = null;
         try {
-            IvrTaskcallMQ ivrTaskcallMQ = null;
-
             ObjectMapper mapper = new ObjectMapper();
             try {
-                if (!content.contains("{")) {
+                if (!content.startsWith("{")) {
                     ivrTaskcallMQ = mapper.readValue("{" + content + "}", IvrTaskcallMQ.class);
                 } else {
                     ivrTaskcallMQ = mapper.readValue(content, IvrTaskcallMQ.class);
@@ -171,7 +171,7 @@
                             String patid = rsaPublicKeyExample.encryptedData(ivrTaskSingle.getPatid().toString(), pub_key);
                             SendMagParam sendMagParam = new SendMagParam();
                             sendMagParam.setType("4");
-                            sendMagParam.setUrl("192.168.2.10:8099/followvisit/particty?param1=" + taskId + "&param2=" + patid);
+                            sendMagParam.setUrl(req_path + "/followvisit/particty?param1=" + taskId + "&param2=" + patid);
                             sendService.sendMsg(sendMagParam);
                         }
                     } else if (descByCode.equals("鍏紬鍙�")) {
@@ -197,6 +197,15 @@
                 }
             }
         } catch (Exception e) {
+            Integer integer = redisCache.getCacheObject(ivrTaskcallMQ.getTaskid().toString());
+            if (integer != null && integer == 2) {
+                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            } else if (integer == null) {
+                redisCache.setCacheObject(ivrTaskcallMQ.getTaskid().toString(), 1, 120, TimeUnit.MINUTES);
+            } else {
+                redisCache.setCacheObject(ivrTaskcallMQ.getTaskid().toString(), integer + 1, 120, TimeUnit.MINUTES);
+            }
+
             log.error("============娑堣垂澶辫触,灏濊瘯娑堟伅琛ュ彂鍐嶆娑堣垂!==============");
             log.error(e.getMessage());
             channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);

--
Gitblit v1.9.3