|
@@ -216,16 +216,16 @@ namespace WCS.Service
|
|
|
{
|
|
|
var gs = AllDatas.GroupBy(v => v.Value.GetType());
|
|
|
|
|
|
- Parallel.ForEach(gs, g =>
|
|
|
- {
|
|
|
- var value = g.Select(v => v.Value).ToArray();
|
|
|
- var etype = g.Key;
|
|
|
- var type = typeof(DeviceDataCollection<>).MakeGenericType(etype);
|
|
|
- var coll = Activator.CreateInstance(type, LogicHandler.Frame, value);
|
|
|
- Redis.Set(etype.Name, coll);
|
|
|
- YGWCS150Redis.Set(etype.Name, coll);
|
|
|
- LiaotcRedis.Set(etype.Name, coll);
|
|
|
- });
|
|
|
+ //Parallel.ForEach(gs, g =>
|
|
|
+ //{
|
|
|
+ // var value = g.Select(v => v.Value).ToArray();
|
|
|
+ // var etype = g.Key;
|
|
|
+ // var type = typeof(DeviceDataCollection<>).MakeGenericType(etype);
|
|
|
+ // 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;
|
|
|
foreach (var g in gs)
|