| | |
| | | /// <summary> |
| | | /// 报警等级 |
| | | /// </summary> |
| | | public class ThreeLinkSeries : IThreeLinkSeries |
| | | public class AssetsThreelinkSeries : IAssetsThreelinkSeries |
| | | { |
| | | private readonly HStation.Service.ThreeLinkSeries _service = new(); |
| | | private readonly HStation.Service.AssetsThreelinkSeries _service = new(); |
| | | |
| | | #region Query |
| | | |
| | | /// <summary> |
| | | /// 获取所有 |
| | | /// </summary> |
| | | public async Task<List<ThreeLinkSeriesDto>> GetAll() |
| | | public async Task<List<AssetsThreelinkSeriesDto>> GetAll() |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var list = _service.GetAll(); |
| | | var vm_list = list?.Select(x => new ThreeLinkSeriesDto(x)).ToList(); |
| | | var vm_list = list?.Select(x => new AssetsThreelinkSeriesDto(x)).ToList(); |
| | | return vm_list; |
| | | }); |
| | | } |
| | |
| | | /// <summary> |
| | | /// 通过 ID 获取 |
| | | /// </summary> |
| | | public async Task<ThreeLinkSeriesDto> GetByID(long ID) |
| | | public async Task<AssetsThreelinkSeriesDto> GetByID(long ID) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var model = _service.GetByID(ID); |
| | | return model == null ? null : new ThreeLinkSeriesDto(model); |
| | | return model == null ? null : new AssetsThreelinkSeriesDto(model); |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 通过 Ids 获取 |
| | | /// </summary> |
| | | public async Task<List<ThreeLinkSeriesDto>> GetByIds(List<long> Ids) |
| | | public async Task<List<AssetsThreelinkSeriesDto>> GetByIds(List<long> Ids) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var list = _service.GetByIds(Ids); |
| | | var vm_list = list?.Select(x => new ThreeLinkSeriesDto(x)).ToList(); |
| | | var vm_list = list?.Select(x => new AssetsThreelinkSeriesDto(x)).ToList(); |
| | | return vm_list; |
| | | }); |
| | | } |
| | |
| | | /// <summary> |
| | | /// 插入一条 |
| | | /// </summary> |
| | | public async Task<long> Insert(AddThreeLinkSeriesInput input) |
| | | public async Task<long> Insert(AddAssetsThreelinkSeriesInput input) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var model = input.Adapt<AddThreeLinkSeriesInput, Model.ThreeLinkSeries>(); |
| | | var model = input.Adapt<AddAssetsThreelinkSeriesInput, Model.AssetsThreelinkSeries>(); |
| | | model.SortCode = _service.GetMaxSortCode() + 1; |
| | | var id = _service.Insert(model); |
| | | return id; |
| | |
| | | /// <summary> |
| | | /// 批量插入 |
| | | /// </summary> |
| | | public async Task<bool> Inserts(List<AddThreeLinkSeriesInput> inputList) |
| | | public async Task<bool> Inserts(List<AddAssetsThreelinkSeriesInput> inputList) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var list = inputList.Select(x => x.Adapt<AddThreeLinkSeriesInput, Model.ThreeLinkSeries>()).ToList(); |
| | | var list = inputList.Select(x => x.Adapt<AddAssetsThreelinkSeriesInput, Model.AssetsThreelinkSeries>()).ToList(); |
| | | list.ForEach(x => |
| | | { |
| | | x.SortCode = _service.GetMaxSortCode() + 1 + list.IndexOf(x); |
| | |
| | | /// <summary> |
| | | /// 大批量插入 |
| | | /// </summary> |
| | | public async Task<bool> BulkInserts(List<AddThreeLinkSeriesInput> list) |
| | | public async Task<bool> BulkInserts(List<AddAssetsThreelinkSeriesInput> list) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | |
| | | /// <summary> |
| | | /// 更新一条 |
| | | /// </summary> |
| | | public async Task<bool> Update(UpdateThreeLinkSeriesInput input) |
| | | public async Task<bool> Update(UpdateAssetsThreelinkSeriesInput input) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D001, $"ID:{input.ID} 数据不存在"); |
| | | } |
| | | |
| | | var rhs = new Model.ThreeLinkSeries(model); |
| | | var rhs = new Model.AssetsThreelinkSeries(model); |
| | | input.Adapt(rhs); |
| | | var bol = _service.Update(rhs); |
| | | return bol; |
| | |
| | | /// <summary> |
| | | /// 批量更新 |
| | | /// </summary> |
| | | public async Task<bool> Updates(List<UpdateThreeLinkSeriesInput> inputList) |
| | | public async Task<bool> Updates(List<UpdateAssetsThreelinkSeriesInput> inputList) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | |
| | | { |
| | | return false; |
| | | } |
| | | var list = inputList.Select(x => x.Adapt<UpdateThreeLinkSeriesInput, Model.ThreeLinkSeries>()).ToList(); |
| | | var list = inputList.Select(x => x.Adapt<UpdateAssetsThreelinkSeriesInput, Model.AssetsThreelinkSeries>()).ToList(); |
| | | var bol = _service.Updates(list); |
| | | return bol; |
| | | }); |
| | |
| | | /// <summary> |
| | | /// 大批量更新 |
| | | /// </summary> |
| | | public async Task<bool> BulkUpdates(List<UpdateThreeLinkSeriesInput> list) |
| | | public async Task<bool> BulkUpdates(List<UpdateAssetsThreelinkSeriesInput> list) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |