增加 对选住推送日志的监控

本质上就是自己用mongodb记录一下日志。

BLWLogServer/Services/KafkaConsume.cs

@@ -6,6 +6,7 @@ using Confluent.Kafka;
 using MongoDB.Driver;
 using NLog;
 using System.Collections.Generic;
+using BLWData.Entity;
 
 namespace BLWLogServer.Services
 {
@@ -308,6 +309,27 @@ namespace BLWLogServer.Services
                                 us.ZhiJieData = UDPPPP.ZhiJieData;
                                 await collection.InsertOneAsync(us);
                             }
+                            else if (k.Equals(KafkaKey.UDPPackageDeviceStatus))
+                            {
+                                DeviceActionChangeDataPush e = new DeviceActionChangeDataPush();
+                                e = DeviceActionChangeDataPush.Parser.ParseFrom(v);
+
+                                var collection = client.GetDatabase("udppackage").GetCollection<XuanZhuRequest_db>("xuanzhudevicestatuschanges");
+                                XuanZhuRequest_db us = new XuanZhuRequest_db();
+                                us.code = e.Code.ToString();
+                                us.roomNumber = e.RoomNumber;
+                                us.devicetype = e.Devicetype;
+                                us.address = e.Address;
+                                us.status = e.Status;
+                                us.name = e.Name;
+                                us.currentTemp = e.CurrentTemp;
+                                us.settingTemp = e.SettingTemp;
+                                us.fanSpeed = e.FanSpeed;
+                                us.mode = e.Mode;
+                                us.valve = e.Valve;
+                                us.timestamp = e.Createtime;
+                                await collection.InsertOneAsync(us);
+                            }
 
 
                             #region 新版协议记录