优化成行二取

tangxu

2022-11-14 91a89e128005b5d6460f61b743654e42585429c3

 Api/IStation.DataDockingApi4Ys/HandleHelper.cs

@@ -25,7 +25,7 @@
            var appParas = AppParasHelper.Get();
            if (appParas == null)
            {
                LogHelper.Info("上海城投原水 Api 数据对接中，缺少对接配置文件");
                LogHelper.Error("上海城投原水 Api 数据对接中，缺少对接配置文件");
                return;
            }
            var url = appParas.url + Guid.NewGuid().ToString("N");
@@ -60,11 +60,11 @@
                    }
                    else
                    {
                        var record_list = dict.Select(x => x.Value).ToList();
                        var receive_list = new List<Model.MonitorDataDockingReceiveRecord>();
                        var recordList = dict.Select(x => x.Value).ToList();
                        var receiveList = new List<Model.MonitorDataDockingReceiveRecord>();
                        foreach (var mapper in mappers)
                        {
                            var src = record_list.Find(x=>x.key==mapper.SignId);
                            var src = recordList.Find(x=>x.key==mapper.SignId);
                            if (src != null)
                            {
                                var recordContent = JsonHelper.Json2Object<RecordContent>(src.vals);
@@ -72,29 +72,27 @@
                                {
                                    if (DateTime.TryParse(recordContent.time, out DateTime time_result))
                                    {
                                        if (double.TryParse(recordContent.value, out double value_result))
                                        var receiveRecord = new Model.MonitorDataDockingReceiveRecord()
                                        {
                                            var receiveRecord = new Model.MonitorDataDockingReceiveRecord()
                                            {
                                                SysId = mapper.SysId,
                                                RecordType = Model.eMonitorType.General,
                                                SrcTime = time_result,
                                                SrcValue = value_result.ToString(),
                                            };
                                            receive_list.Add(receiveRecord);
                                        }
                                            SysId = mapper.SysId,
                                            RecordType = Model.eMonitorType.General,
                                            SrcTime = time_result,
                                            SrcValue = recordContent.value
                                        };
                                        receiveList.Add(receiveRecord);
                                    }

                                }
                            }
                        }
                        receive(receive_list);
                        receive(receiveList);

                        #region 生成调试记录

                        if (appParas.debug)
                        {
                            DebugHelper.Debug(record_list);
                            DebugHelper.Debug(recordList);
                        }

                        #endregion
                    }
                    webSocket4Net.Close();