测试

Common/RabbitMQClient.cs

@@ -62,10 +62,17 @@ 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, false); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
+                Function.WriteLog(DateTime.Now.ToString() + "\n" + MsgContent + "\n\n", "接收mq数据队列");
+                try
+                {
+                    PrizeDo.sendPrize(MsgContent);
+                    channel.BasicAck(e.DeliveryTag, false); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                }
+                catch(Exception ex)
+                {
+                    Function.WriteLog(DateTime.Now + "\n" + ex.ToString(), "发奖异常");
+                }
             };
             channel.BasicConsume(QueueName, false, consumer);
         }

Util/PrizeDo.cs

@@ -15,23 +15,16 @@ namespace Util
         //发奖入口
         public static void sendPrize(string content)
         {
-            try
+            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))
             {
-                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(), "发奖异常");
+                string[] priObjData = priObjString.Split('|');
+                string priListIds = priObjData[0];
+                int projectId = int.Parse(priObjData[1]);
+                prizeSend(projectId, priListIds, content);
             }
         }