fix

Projects/永冠OPP/WCS.Service/ProtocolProxy.cs

@@ -97,7 +97,8 @@ namespace WCS.Service
 
         private static RedisClient Redis;
 
-        //public static RedisClient YG150Redis;
+        public static RedisClient LiaotcRedis;
+
         //public static RedisClient YGWMS150Redis;
         public static RedisClient YGWCS150Redis;
 
@@ -105,6 +106,9 @@ namespace WCS.Service
         {
             MessagePackSerializer.DefaultOptions = StandardResolver.Options.WithCompression(MessagePackCompression.Lz4Block);
             //Redis = new RedisClient("192.168.249.120,password=123456,database=11");
+
+            #region 公用云服务器
+
             Redis = new RedisClient("212.64.66.35,database=10");
             Redis.Serialize = obj =>
             {
@@ -117,6 +121,26 @@ namespace WCS.Service
                 return obj;
             };
 
+            #endregion 公用云服务器
+
+            #region 私用云服务器
+
+            LiaotcRedis = new RedisClient("liaotc.com,database=10");
+            LiaotcRedis.Serialize = obj =>
+            {
+                var bytes = MessagePackSerializer.Serialize(obj);
+                return bytes;
+            };
+            LiaotcRedis.DeserializeRaw = (bytes, type) =>
+            {
+                var obj = MessagePackSerializer.Deserialize(type, bytes);
+                return obj;
+            };
+
+            #endregion 私用云服务器
+
+            #region 永冠服务
+
             YGWCS150Redis = new RedisClient("192.168.249.150,password=123456,database=10");
             YGWCS150Redis.Serialize = obj =>
             {
@@ -128,6 +152,8 @@ namespace WCS.Service
                 var obj = MessagePackSerializer.Deserialize(type, bytes);
                 return obj;
             };
+
+            #endregion 永冠服务
         }
 
         public override void Publish(string code, WCS_PROTOCOLDATA obj)
@@ -198,6 +224,7 @@ namespace WCS.Service
                     var coll = Activator.CreateInstance(type, LogicHandler.Frame, value);
                     Redis.Set(etype.Name, coll);
                     YGWCS150Redis.Set(etype.Name, coll);
+                    LiaotcRedis.Set(etype.Name, coll);
                 });
                 DeviceDataPack pack = new DeviceDataPack();
                 pack.Frame = LogicHandler.Frame;
@@ -215,6 +242,7 @@ namespace WCS.Service
                 sw.Start();
                 Redis.Set(nameof(DeviceDataPack), pack);
                 YGWCS150Redis.Set(nameof(DeviceDataPack), pack);
+                LiaotcRedis.Set(nameof(DeviceDataPack), pack);
                 sw.Stop();
                 Console.ForegroundColor = ConsoleColor.Blue;
                 Console.WriteLine($"Redis耗时{sw.ElapsedMilliseconds}");
@@ -222,6 +250,7 @@ namespace WCS.Service
 
                 Redis.RPush("Packs", pack);
                 YGWCS150Redis.RPush("Packs", pack);
+                LiaotcRedis.RPush("Packs", pack);
 
                 var len = Redis.LLen("Packs");
                 if (len > 150000)
@@ -235,6 +264,12 @@ namespace WCS.Service
                     YGWCS150Redis.LTrim("Packs", 20000, len1);
                 }
 
+                var len2 = LiaotcRedis.LLen("Packs");
+                if (len2 > 150000)
+                {
+                    LiaotcRedis.LTrim("Packs", 20000, len2);
+                }
+
                 foreach (var data in AllDatas)
                 {
                     LastInfo[data.Key] = data.Value.Info;