流程执行完再消费

AppStart/RabbitMQClient.cs

@@ -145,8 +145,10 @@ namespace MySystem
             {
                 string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
                 function.WriteLog(MsgContent, "接收mq数据队列");
-                SycnSpBindService.Instance.SimDo(MsgContent);
-                channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                if(SycnSpBindService.Instance.SimDo(MsgContent));
+                {
+                    channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                }
             };
             channel.BasicConsume(QueueName, false, consumer);
         }

AppStart/Service/SycnSpBindService.cs

@@ -14,7 +14,7 @@ namespace MySystem
         private SycnSpBindService()
         { }
 
-        public void SimDo(string content)
+        public bool SimDo(string content)
         {
             try
             {
@@ -173,10 +173,12 @@ namespace MySystem
                 spdb.Dispose();
                 db.SaveChanges();
                 db.Dispose();
+                return true;
             }
             catch (Exception ex)
             {
                 function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP绑定数据到MAIN异常");
+                return false;
             }
         }
     }