fix

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

@@ -76,10 +76,6 @@ namespace WCS.Service
             newobj.UPDATEUSER = user;
             newobj.FRAME = LogicHandler.Frame;
             var typeName = newobj.GetType().Name;
-            if (!typeName.Contains("SRM") && !typeName.Contains("RGV"))
-            {
-                var f = 0;
-            }
 
             var dc1 = TypeExtension.EntityClassToDictionary((object)newobj);
             db.Default.Insertable(dc1).AS($"{typeName}").ExecuteCommand();
@@ -94,7 +90,7 @@ namespace WCS.Service
         static ProtocolProxy()
         {
             MessagePackSerializer.DefaultOptions = StandardResolver.Options.WithCompression(MessagePackCompression.Lz4Block);
-            Redis = new RedisClient("127.0.0.1,database=2");
+            Redis = new RedisClient("127.0.0.1,database=10");
             Redis.Serialize = obj =>
             {
                 var bytes = MessagePackSerializer.Serialize(obj);
@@ -105,23 +101,8 @@ namespace WCS.Service
                 var obj = MessagePackSerializer.Deserialize(type, bytes);
                 return obj;
             };
-
-            Yg150Redis = new RedisClient("127.0.0.1,database=1");
-            Ygwms150Redis = new RedisClient("127.0.0.1,database=0");
-            Ygwcs150Redis = new RedisClient("127.0.0.1,database=3");
-            Ygwcs150Redis.Serialize = obj =>
-            {
-                var bytes = MessagePackSerializer.Serialize(obj);
-                return bytes;
-            };
-            Ygwcs150Redis.DeserializeRaw = (bytes, type) =>
-            {
-                var obj = MessagePackSerializer.Deserialize(type, bytes);
-                return obj;
-            };
         }
 
-        //static ConcurrentDictionary<string, DeviceData> Datas = new ConcurrentDictionary<string, DeviceData>();
         public override void Publish(string code, WCS_PROTOCOLDATA obj)
         {
             try