소스 검색

对接上mq数据

lcl 1 년 전
부모
커밋
62f8e46e12
2개의 변경된 파일4개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 1
      AppStart/RabbitMQClient.cs
  2. 2 1
      AppStart/Service/SycnSpBindService.cs

+ 2 - 1
AppStart/RabbitMQClient.cs

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

+ 2 - 1
AppStart/Service/SycnSpBindService.cs

@@ -14,10 +14,11 @@ namespace MySystem
         private SycnSpBindService()
         { }
 
-        public void SimDo(RadioCardItem Bind)
+        public void SimDo(string content)
         {
             try
             {
+                RadioCardItem Bind = Newtonsoft.Json.JsonConvert.DeserializeObject<RadioCardItem>(content);
                 WebCMSEntities spdb = new WebCMSEntities();
                 PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
                 DateTime start = DateTime.Now.AddDays(-60);