using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.Service
|
{
|
/// <summary>
|
/// 仪器仪表
|
/// </summary>
|
public partial class Meter
|
{
|
|
|
/// <summary>
|
/// 获取所有仪器仪表
|
/// </summary>
|
/// <returns></returns>
|
private List<Model.MeterBaseInfo> GetAll()
|
{
|
string cache_name = string.Format("AllInstrumentBase");
|
return Eventech.Lxj.Untity.MemoryCacheHelper.GetSet<List<IStation.Model.MeterBaseInfo>>(cache_name, () =>
|
{
|
return GetInstrumentCore();
|
}, 350);
|
}
|
|
/// <summary>
|
/// 根据 CorpID 获取流量计
|
/// </summary>
|
/// <param name="CorpID"></param>
|
/// <returns></returns>
|
public List<Model.MeterBaseInfo> GetByCorpID(long CorpID)
|
{
|
var list = GetAll();
|
|
return (from x in list where x.CorpID == CorpID select x).ToList();
|
}
|
|
/// <summary>
|
/// 根据 CorpID 获取流量计
|
/// </summary>
|
/// <param name="CorpID"></param>
|
/// <returns></returns>
|
public List<Model.FlowMeterBaseInfo> GetFixFlowMeterByCorpID(long CorpID)
|
{
|
string cache_name = string.Format("AllFlowMeter.Corp{0}", CorpID);
|
return Eventech.Lxj.Untity.MemoryCacheHelper.GetSet<List<IStation.Model.FlowMeterBaseInfo>>(cache_name, () =>
|
{
|
return GetFlowMeterCore(CorpID);
|
}, 301);
|
}
|
|
/// <summary>
|
/// 根据 CorpID 获取压力计
|
/// </summary>
|
/// <param name="CorpID"></param>
|
/// <returns></returns>
|
public List<Model.PressureMeterBaseInfo> GetFixPressureMeterByCorpID(long CorpID)
|
{
|
string cache_name = string.Format("AllPressureMeter.Corp{0}", CorpID);
|
return Eventech.Lxj.Untity.MemoryCacheHelper.GetSet<List<IStation.Model.PressureMeterBaseInfo>>(cache_name, () =>
|
{
|
return GetPressureMeterCore(CorpID);
|
}, 302);
|
}
|
|
|
/// <summary>
|
/// 根据 CorpID 获取水质仪
|
/// </summary>
|
/// <param name="CorpID"></param>
|
/// <returns></returns>
|
public List<Model.QualityMeterBaseInfo> GetFixQualityMeterByCorpID(long CorpID)
|
{
|
string cache_name = string.Format("AllQualityMeterBase.Corp{0}", CorpID);
|
return Eventech.Lxj.Untity.MemoryCacheHelper.GetSet<List<IStation.Model.QualityMeterBaseInfo>>(cache_name, () =>
|
{
|
return GetQualityMeterCore(CorpID);
|
}, 303);
|
|
}
|
|
|
|
private List<IStation.Model.MeterBaseInfo> GetInstrumentCore()
|
{
|
var service_product = new Product();
|
var service_dma = new DmaArea();
|
var service_pipeSite = new DmaPipeSite();
|
var service_manufacturer = new Service.Manufacturer();
|
var service_mapinfo = new Service.MapInfoBase();
|
var service_mapinfoMapping = new Service.MapInfoMapping();
|
|
var catalogList =new ProductCatalog().GetChildsAndSelfByIdentifier(Model.ProductCatalog.仪器仪表)?.Select(x=>x.Identifier).Distinct().ToList();
|
|
IStation.Service.Product series_product = new Product();
|
var allProduct = series_product.GetAll();
|
var allMeter = from x in allProduct
|
where catalogList.Contains(x.Catalog)
|
select x;
|
|
var allManufacotry = service_manufacturer.GetAll();
|
var allPipeSites =service_pipeSite.GetAll();
|
var allDmaSiteMapper = new DmaAreaMapping().GetAll();
|
var allMapInfo = service_mapinfo.GetAll();
|
var allMapMapperInfo = service_mapinfoMapping.GetAll();
|
var allDma = service_dma.GetAll();
|
var allPipeSiteInstrument = new DmaPipeSiteMapping().GetAll();
|
|
List<IStation.Model.MeterBaseInfo> all_Instrument_meters = new List<Model.MeterBaseInfo>();
|
foreach (var meter in allMeter)
|
{
|
var siteMapper = allPipeSiteInstrument.Find(x => x.InstrumentID == meter.ID);
|
if (siteMapper == null )
|
continue;
|
|
var pipeSite = allPipeSites.Find(x => x.ID == siteMapper.PipeSiteID);
|
if (pipeSite == null || pipeSite.UseStatus == Model.eUseStatus.Disable)
|
continue;
|
|
var DmaSiteMapper = allDmaSiteMapper.Find(x => x.PipeSiteID == pipeSite.ID);
|
if (DmaSiteMapper == null)
|
continue;
|
|
var dmaArea = allDma.Find(x => x.ID == DmaSiteMapper.AreaID);
|
if (dmaArea == null)
|
continue;
|
|
/*var dmaMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == dmaArea.ID && x.ObjectType == IStation.ObjectType.DmaArea_分区);
|
if (dmaMapInfoMapper == null)
|
continue;*/
|
|
var pipeSiteMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == pipeSite.ID && x.ObjectType == IStation.ObjectType.PipeSite_管路点);
|
if (pipeSiteMapInfoMapper == null)
|
continue;
|
|
/* var dmaMapInfo = allMapInfo.Find(x=>x.ID== dmaMapInfoMapper.MapInfoID);*/
|
|
var pipeSiteMapInfo = allMapInfo.Find(x => x.ID == pipeSiteMapInfoMapper.MapInfoID);
|
|
IStation.Model.MeterBaseInfo model = new Model.MeterBaseInfo(meter, pipeSite, pipeSiteMapInfo);
|
// model.DmaAreaName = dmaArea.Name;
|
|
if (meter.ManufacturerID > 0)
|
{
|
var manufacotry = allManufacotry.Find(x => x.ID == meter.ManufacturerID);
|
if (manufacotry != null)
|
model.ManufacturerName = manufacotry.Name;
|
}
|
|
|
all_Instrument_meters.Add(model);
|
}
|
|
|
return (from x in all_Instrument_meters orderby x.SortCode select x).ToList();
|
}
|
|
private List<IStation.Model.FlowMeterBaseInfo> GetFlowMeterCore(long CorpID)
|
{
|
var service_product = new Product();
|
var service_dma = new DmaArea();
|
var service_pipeSite = new DmaPipeSite();
|
var service_manufacturer = new Service.Manufacturer();
|
var service_mapinfo = new Service.MapInfoBase();
|
var service_mapinfoMapping = new Service.MapInfoMapping();
|
|
var allProduct = service_product.GetAll();
|
var allMeter = from x in allProduct
|
where x.Catalog==Model.ProductCatalog.流量计
|
select x;
|
|
var allManufacotry = service_manufacturer.GetAll();
|
var allPipeSites = service_pipeSite.GetAll();
|
var allDmaSiteMapper = new DmaAreaMapping().GetAll();
|
var allMapInfo = service_mapinfo.GetAll();
|
var allDma = service_dma.GetAll();
|
var allPipeSiteInstrument = new DmaPipeSiteMapping().GetAll();
|
var allMapMapperInfo = service_mapinfoMapping.GetAll();
|
|
List<IStation.Model.FlowMeterBaseInfo> all_flow_meters = new List<Model.FlowMeterBaseInfo>();
|
foreach (var meter in allMeter)
|
{
|
var siteMapper = allPipeSiteInstrument.Find(x => x.InstrumentID == meter.ID);
|
if (siteMapper == null )
|
continue;
|
|
var pipeSite = allPipeSites.Find(x => x.ID == siteMapper.PipeSiteID);
|
if (pipeSite == null || pipeSite.UseStatus == Model.eUseStatus.Disable)
|
continue;
|
|
/*var dmaArea = allDmaSiteMapper.Find(x => x.PipeSiteID == pipeSite.ID);
|
if (dmaArea == null)
|
continue;*/
|
|
/*var dmaMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == dmaArea.ID && x.ObjectType == IStation.ObjectType.DmaArea_分区);
|
if (dmaMapInfoMapper == null)
|
continue;*/
|
|
var pipeSiteMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == pipeSite.ID && x.ObjectType == IStation.ObjectType.PipeSite_管路点);
|
if (pipeSiteMapInfoMapper == null)
|
continue;
|
|
/* var dmaMapInfo = allMapInfo.Find(x=>x.ID== dmaMapInfoMapper.MapInfoID);*/
|
|
var papInfo = allMapInfo.Find(x => x.ID == pipeSiteMapInfoMapper.MapInfoID);
|
|
IStation.Model.FlowMeterBaseInfo model = new Model.FlowMeterBaseInfo(meter, pipeSite, papInfo);
|
|
|
if (meter.ManufacturerID > 0)
|
{
|
var manufacotry = allManufacotry.Find(x => x.ID == meter.ManufacturerID);
|
if (manufacotry != null)
|
model.ManufacturerName = manufacotry.Name;
|
}
|
|
|
var flag_DmaSite = allDmaSiteMapper.FindAll(x => x.PipeSiteID == pipeSite.ID);
|
|
if (flag_DmaSite != null)
|
{
|
var inFlag = flag_DmaSite.Find(x => x.Flag == Model.FlagHelper.进口);
|
if (inFlag != null)
|
{
|
var inlet = allDma.Find(d => d.ID == inFlag.AreaID);
|
if (inlet != null)
|
{
|
model.InletDmaID = inlet.ID;
|
model.InletDmaSiteMapperID = inFlag.ID;
|
model.InletDmaName = inlet.Name;
|
}
|
}
|
|
var outFlag = flag_DmaSite.Find(x => x.Flag == Model.FlagHelper.出口);
|
if (outFlag != null)
|
{
|
var outlet = allDma.Find(d => d.ID == outFlag.AreaID);
|
if (outlet != null)
|
{
|
model.OutletDmaID = outlet.ID;
|
model.OutletDmaSiteMapperID = outlet.ID;
|
model.OutletDmaName = outlet.Name;
|
}
|
}
|
}
|
all_flow_meters.Add(model);
|
}
|
|
return (from x in all_flow_meters where x.CorpID == CorpID orderby x.SortCode select x).ToList();
|
}
|
|
private List<IStation.Model.PressureMeterBaseInfo> GetPressureMeterCore(long CorpID)
|
{
|
var service_product = new Product();
|
var service_dma = new DmaArea();
|
var service_pipeSite = new DmaPipeSite();
|
var service_manufacturer = new Service.Manufacturer();
|
var service_mapinfo = new Service.MapInfoBase();
|
var service_mapinfoMapping = new Service.MapInfoMapping();
|
|
var allProduct = service_product.GetAll();
|
var allMeter = from x in allProduct
|
where x.Catalog == Model.ProductCatalog.压力计
|
select x;
|
|
var allManufacotry = service_manufacturer.GetAll();
|
var allPipeSites = service_pipeSite.GetAll();
|
var allDmaSiteMapper = new DmaAreaMapping().GetAll();
|
var allMapInfo = service_mapinfo.GetAll();
|
var allDma = service_dma.GetAll();
|
var allPipeSiteInstrument = new DmaPipeSiteMapping().GetAll();
|
var allMapMapperInfo = service_mapinfoMapping.GetAll();
|
|
List<IStation.Model.PressureMeterBaseInfo> all_Pressure_meters = new List<Model.PressureMeterBaseInfo>();
|
foreach (var meter in allMeter)
|
{
|
var siteMapper = allPipeSiteInstrument.Find(x => x.InstrumentID == meter.ID);
|
if (siteMapper == null )
|
continue;
|
|
var pipeSite = allPipeSites.Find(x => x.ID == siteMapper.PipeSiteID);
|
if (pipeSite == null || pipeSite.UseStatus == Model.eUseStatus.Disable)
|
continue;
|
|
var DmaSiteMapper = allDmaSiteMapper.Find(x => x.PipeSiteID == pipeSite.ID);
|
if (DmaSiteMapper == null)
|
continue;
|
|
var dmaArea = allDma.Find(x => x.ID == DmaSiteMapper.AreaID);
|
|
|
|
/* var dmaMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == dmaArea.ID && x.ObjectType == IStation.ObjectType.DmaArea_分区);
|
if (dmaMapInfoMapper == null)
|
continue;*/
|
|
var pipeSiteMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == pipeSite.ID && x.ObjectType == IStation.ObjectType.PipeSite_管路点);
|
if (pipeSiteMapInfoMapper == null)
|
continue;
|
|
/*var dmaMapInfo = allMapInfo.Find(x => x.ID == dmaMapInfoMapper.MapInfoID);*/
|
|
var pipeSiteMapInfo = allMapInfo.Find(x => x.ID == pipeSiteMapInfoMapper.MapInfoID);
|
|
IStation.Model.PressureMeterBaseInfo model = new Model.PressureMeterBaseInfo(meter, pipeSite, pipeSiteMapInfo);
|
|
if (dmaArea != null)
|
model.DmaAreaName = dmaArea.Name;
|
|
if (meter.ManufacturerID > 0)
|
{
|
var manufacotry = allManufacotry.Find(x => x.ID == meter.ManufacturerID);
|
if (manufacotry != null)
|
model.ManufacturerName = manufacotry.Name;
|
}
|
|
|
all_Pressure_meters.Add(model);
|
}
|
|
|
return (from x in all_Pressure_meters where x.CorpID == CorpID orderby x.SortCode select x).ToList();
|
}
|
|
private List<IStation.Model.QualityMeterBaseInfo> GetQualityMeterCore(long CorpID)
|
{
|
var service_product = new Product();
|
var service_dma = new DmaArea();
|
var service_pipeSite = new DmaPipeSite();
|
var service_manufacturer = new Service.Manufacturer();
|
var service_mapinfo = new Service.MapInfoBase();
|
var service_mapinfoMapping = new Service.MapInfoMapping();
|
|
var allProduct = service_product.GetAll();
|
var allMeter = from x in allProduct
|
where x.Catalog == Model.ProductCatalog.水质仪
|
select x;
|
|
var allManufacotry = service_manufacturer.GetAll();
|
var allPipeSites = service_pipeSite.GetAll();
|
var allDmaSiteMapper = new DmaAreaMapping().GetAll();
|
var allMapInfo = service_mapinfo.GetAll();
|
var allDma = service_dma.GetAll();
|
var allPipeSiteInstrument = new DmaPipeSiteMapping().GetAll();
|
var allMapMapperInfo = service_mapinfoMapping.GetAll();
|
|
List<IStation.Model.QualityMeterBaseInfo> all_waterMonitor_meters = new List<Model.QualityMeterBaseInfo>();
|
foreach (var meter in allMeter)
|
{
|
var siteMapper = allPipeSiteInstrument.Find(x => x.InstrumentID == meter.ID);
|
if (siteMapper == null )
|
continue;
|
|
var pipeSite = allPipeSites.Find(x => x.ID == siteMapper.PipeSiteID);
|
if (pipeSite == null || pipeSite.UseStatus == Model.eUseStatus.Disable)
|
continue;
|
|
var DmaSiteMapper = allDmaSiteMapper.Find(x => x.PipeSiteID == pipeSite.ID);
|
if (DmaSiteMapper == null)
|
continue;
|
|
|
|
|
|
/* var dmaMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == dmaArea.ID && x.ObjectType == IStation.ObjectType.DmaArea_分区);
|
if (dmaMapInfoMapper == null)
|
continue;*/
|
|
var pipeSiteMapInfoMapper = allMapMapperInfo.Find(x => x.ObjectID == pipeSite.ID && x.ObjectType == IStation.ObjectType.PipeSite_管路点);
|
if (pipeSiteMapInfoMapper == null)
|
continue;
|
|
/*var dmaMapInfo = allMapInfo.Find(x => x.ID == dmaMapInfoMapper.MapInfoID);*/
|
|
var pipeSiteMapInfo = allMapInfo.Find(x => x.ID == pipeSiteMapInfoMapper.MapInfoID);
|
|
IStation.Model.QualityMeterBaseInfo model = new Model.QualityMeterBaseInfo(meter, pipeSite, pipeSiteMapInfo);
|
|
var dmaArea = allDma.Find(x => x.ID == DmaSiteMapper.AreaID);
|
if (dmaArea != null)
|
model.DmaAreaName = dmaArea.Name;
|
|
if (meter.ManufacturerID > 0)
|
{
|
var manufacotry = allManufacotry.Find(x => x.ID == meter.ManufacturerID);
|
if (manufacotry != null)
|
model.ManufacturerName = manufacotry.Name;
|
}
|
|
all_waterMonitor_meters.Add(model);
|
}
|
|
|
return (from x in all_waterMonitor_meters where x.CorpID == CorpID orderby x.SortCode select x).ToList();
|
}
|
|
}
|
}
|
