测试

Common/RabbitMQClient.cs

@@ -62,10 +62,10 @@ namespace MySystem
             EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
             consumer.Received += (a, e) =>
             {
-                string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
-                Function.WriteLog(DateTime.Now.ToString() + "\n" + MsgContent + "\n\n", "接收mq数据队列");
-                PrizeDo.sendPrize(MsgContent);
-                channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                // string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
+                // Function.WriteLog(DateTime.Now.ToString() + "\n" + MsgContent + "\n\n", "接收mq数据队列");
+                // PrizeDo.sendPrize(MsgContent);
+                channel.BasicAck(e.DeliveryTag, false); //收到回复后，RabbitMQ会直接在队列中删除这条消息
             };
             channel.BasicConsume(QueueName, false, consumer);
         }

Program.cs

@@ -129,7 +129,7 @@ app.MapControllers();
 // PrizeDo.sendPrize(7, "{\"OrderNo\":\"BM2024090817330511847441249\"}");
 // PrizeDo.sendPrize(7, "{\"OrderNo\":\"BM2024090817360962275551251\"}");
 
-// RabbitMQClient.Instance.StartReceive("PRIZE_SEND_QUEUE", "PRIZE_SEND_QUEUE", "/");
+RabbitMQClient.Instance.StartReceive("PRIZE_SEND_QUEUE", "PRIZE_SEND_QUEUE", "/");
 
 // PrizeDo.sendPrize("{\"prize_tag\":\"1\",\"content\":\"{\\\"PosSn\\\":\\\"00002402045980195457\\\"}\"}");
 

Util/PrizeDo.cs

@@ -15,16 +15,23 @@ namespace Util
         //发奖入口
         public static void sendPrize(string content)
         {
-            batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + Function.get_Random(3);
-            JsonData jsonObj = JsonMapper.ToObject(content);
-            string priObjString = prizeInSet(int.Parse(Function.CheckInt(jsonObj["prize_tag"].ToString())));
-            content = jsonObj["content"].ToString();
-            if(!string.IsNullOrEmpty(priObjString))
+            try
             {
-                string[] priObjData = priObjString.Split('|');
-                string priListIds = priObjData[0];
-                int projectId = int.Parse(priObjData[1]);
-                prizeSend(projectId, priListIds, content);
+                batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + Function.get_Random(3);
+                JsonData jsonObj = JsonMapper.ToObject(content);
+                string priObjString = prizeInSet(int.Parse(Function.CheckInt(jsonObj["prize_tag"].ToString())));
+                content = jsonObj["content"].ToString();
+                if(!string.IsNullOrEmpty(priObjString))
+                {
+                    string[] priObjData = priObjString.Split('|');
+                    string priListIds = priObjData[0];
+                    int projectId = int.Parse(priObjData[1]);
+                    prizeSend(projectId, priListIds, content);
+                }
+            }
+            catch(Exception ex)
+            {
+                Function.WriteLog(DateTime.Now + "\n" + ex.ToString(), "发奖异常");
             }
         }