| | |
| | | { |
| | | return SignalCacheHelper.GetSet(projectId, () => |
| | | { |
| | | var entities = _dal.QueryAll(projectId); |
| | | var entities = _dal.GetAll(projectId); |
| | | var models = Entity2Models(entities); |
| | | if (models == null) |
| | | { |
| | |
| | | //根据 Id 更新缓存 |
| | | private void UpdateProjectCache(long projectId, long Id) |
| | | { |
| | | var entity_ds = _dal.QueryById(projectId, Id); |
| | | var entity_ds = _dal.GetById(projectId, Id); |
| | | var model_ds = Entity2Model(entity_ds); |
| | | var all = GetProjectCache(projectId); |
| | | var model = all.Find(x => x.Id == Id); |
| | |
| | | { |
| | | if (Ids == null || Ids.Count() < 1) |
| | | return; |
| | | var entities = _dal.QueryByIds(projectId, Ids); |
| | | var entities = _dal.GetByIds(projectId, Ids); |
| | | var models = Entity2Models(entities); |
| | | var all = GetProjectCache(projectId); |
| | | all.RemoveAll(x => Ids.Contains(x.Id)); |
| | |
| | | |
| | | #endregion |
| | | |
| | | #region Query |
| | | #region Get |
| | | |
| | | /// <summary> |
| | | /// 查询全部 |
| | | /// </summary> |
| | | public List<Model.Signal> QueryAll(long projectId) |
| | | public List<Model.Signal> GetAll(long projectId) |
| | | { |
| | | var all = GetProjectCache(projectId); |
| | | return all.OrderBy(x => x.SortCode).ToList(); |
| | |
| | | /// <summary> |
| | | /// 根据 Id查询 |
| | | /// </summary> |
| | | public Model.Signal QueryById(long projectId, long Id) |
| | | public Model.Signal GetById(long projectId, long Id) |
| | | { |
| | | var all = QueryAll(projectId); |
| | | var all = GetAll(projectId); |
| | | return all.Find(x => x.Id == Id); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据 Ids 查询 |
| | | /// </summary> |
| | | public List<Model.Signal> QueryByIds(long projectId, IEnumerable<long> Ids) |
| | | public List<Model.Signal> GetByIds(long projectId, IEnumerable<long> Ids) |
| | | { |
| | | if (Ids == null || Ids.Count() < 1) |
| | | return default; |
| | | var all = QueryAll(projectId); |
| | | var all = GetAll(projectId); |
| | | return all.Where(x => Ids.Contains(x.Id)).ToList(); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据 monitorPointId 查询 |
| | | /// </summary> |
| | | public List<Model.Signal> QueryByMonitorPointId(long projectId, long monitorPointId) |
| | | public List<Model.Signal> GetByMonitorPointId(long projectId, long monitorPointId) |
| | | { |
| | | var all = GetProjectCache(projectId); |
| | | all = all.Where(x => monitorPointId == x.MonitorPointId).ToList(); |
| | |
| | | /// <summary> |
| | | /// 根据 monitorPointIds 查询 |
| | | /// </summary> |
| | | public List<Model.Signal> QueryByMonitorPointIds(long projectId, IEnumerable<long> monitorPointIds) |
| | | public List<Model.Signal> GetByMonitorPointIds(long projectId, IEnumerable<long> monitorPointIds) |
| | | { |
| | | if (monitorPointIds == null || monitorPointIds.Count() < 1) |
| | | return default; |
| | |
| | | /// <summary> |
| | | /// 根据 monitorPointId 查询 信号+信号类型 |
| | | /// </summary> |
| | | public List<Model.Signal_SignalType> QueryExSignalTypeByMonitorPointId(long projectId, long monitorPointId) |
| | | public List<Model.Signal_SignalType> GetExSignalTypeByMonitorPointId(long projectId, long monitorPointId) |
| | | { |
| | | var list = QueryByMonitorPointId(projectId, monitorPointId); |
| | | var list = GetByMonitorPointId(projectId, monitorPointId); |
| | | if (list == null || list.Count < 1) |
| | | return default; |
| | | var identifiers = list.Select(x => x.SignalType).Distinct().ToList(); |
| | | var typeList = new SignalType().QueryByIdentifiers(projectId,identifiers); |
| | | var typeList = new SignalType().GetByIdentifiers(projectId,identifiers); |
| | | if (typeList == null || typeList.Count < 1) |
| | | return default; |
| | | var vmList = (from x in list |
| | |
| | | /// <summary> |
| | | /// 根据 monitorPointId 查询第一条 信号+信号类型 |
| | | /// </summary> |
| | | public Model.Signal_SignalType QueryFirstExSignalTypeByMonitorPointId(long projectId, long monitorPointId) |
| | | public Model.Signal_SignalType GetFirstExSignalTypeByMonitorPointId(long projectId, long monitorPointId) |
| | | { |
| | | var first = GetFirstByMonitorPointId(projectId, monitorPointId); |
| | | if (first == null) |
| | | return default; |
| | | var signalType = new SignalType().QueryByIdentifier(projectId,first.SignalType); |
| | | var signalType = new SignalType().GetByIdentifier(projectId,first.SignalType); |
| | | if (signalType == null) |
| | | return default; |
| | | return new Model.Signal_SignalType(first, signalType); |
| | |
| | | /// <summary> |
| | | /// 根据 MonitorPointIds 查询 信号+信号类型 |
| | | /// </summary> |
| | | public List<Model.Signal_SignalType> QueryExSignalTypeByMonitorPointIds(long projectId, IEnumerable<long> monitorPointIds) |
| | | public List<Model.Signal_SignalType> GetExSignalTypeByMonitorPointIds(long projectId, IEnumerable<long> monitorPointIds) |
| | | { |
| | | if (monitorPointIds == null || monitorPointIds.Count() < 1) |
| | | return default; |
| | | var list = QueryByMonitorPointIds(projectId, monitorPointIds); |
| | | var list = GetByMonitorPointIds(projectId, monitorPointIds); |
| | | if (list == null || list.Count < 1) |
| | | return default; |
| | | var identifiers = list.Select(x => x.SignalType).Distinct().ToList(); |
| | | var typeList = new SignalType().QueryByIdentifiers(projectId, identifiers); |
| | | var typeList = new SignalType().GetByIdentifiers(projectId, identifiers); |
| | | if (typeList == null || typeList.Count < 1) |
| | | return default; |
| | | var vmList = (from x in list |
| | |
| | | /// </summary> |
| | | public bool IsExistById(long projectId, long Id) |
| | | { |
| | | var all = QueryAll(projectId); |
| | | var all = GetAll(projectId); |
| | | return all.Exists(x => x.Id == Id); |
| | | } |
| | | #endregion |