| | |
| | | using HStation.Dto; |
| | | using Yw.Dto; |
| | | using Mapster; |
| | | |
| | | namespace HStation.CAL.LocalClient |
| | | { |
| | | /// <summary> |
| | | /// 消火栓 |
| | | ///</summary> |
| | | /// 换热器型号 |
| | | /// </summary> |
| | | public class AssetsHydrantMain : IAssetsHydrantMain |
| | | { |
| | | private readonly Service.AssetsHydrantMain _service = new(); |
| | | private readonly HStation.Service.AssetsHydrantMain _service = new(); |
| | | |
| | | #region Query |
| | | |
| | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取最大排序码 |
| | | /// 获取数量 |
| | | /// </summary> |
| | | public async Task<int> GetMaxSortCode() |
| | | public async Task<int> GetCount() |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var sort_code = _service.GetMaxSortCode(); |
| | | return sort_code; |
| | | return _service.GetCount(); |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 通过 SeriesID 获取 |
| | | /// </summary> |
| | | public async Task<List<AssetsHydrantMainDto>> GetBySeriesID(long SeriesID) |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var list = _service.GetBySeriesID(SeriesID); |
| | | var vm_list = list?.Select(x => new AssetsHydrantMainDto(x)).ToList(); |
| | | return vm_list; |
| | | }); |
| | | } |
| | | |
| | |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | var series = new HStation.Service.AssetsHydrantSeries().GetByID(input.SeriesID); |
| | | if (series == null) |
| | | { |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D001, $"SeriesID:{input.SeriesID} 数据不存在"); |
| | | } |
| | | if (!string.IsNullOrEmpty(input.TagName)) |
| | | { |
| | | if (_service.IsExistTagName(input.TagName)) |
| | | { |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, $"TagName:{input.TagName}", "标记已存在"); |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, $"TagName:{input.TagName} 标记已存在"); |
| | | } |
| | | } |
| | | var model = input.Adapt<AddAssetsHydrantMainInput, Model.AssetsHydrantMain>(); |
| | | model.SortCode = _service.GetMaxSortCode() + 1; |
| | | model.SortCode = _service.GetMaxSortCode(input.SeriesID) + 1; |
| | | var id = _service.Insert(model); |
| | | return id; |
| | | }); |
| | |
| | | { |
| | | return await Task.Factory.StartNew(() => |
| | | { |
| | | return false; |
| | | var list = inputList.Select(x => x.Adapt<AddAssetsHydrantMainInput, Model.AssetsHydrantMain>()).ToList(); |
| | | list.ForEach(x => |
| | | { |
| | | x.SortCode = _service.GetMaxSortCode(x.SeriesID) + 1 + list.IndexOf(x); |
| | | }); |
| | | var bol = _service.Inserts(list); |
| | | return bol; |
| | | }); |
| | | } |
| | | |
| | |
| | | { |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D001, $"ID:{input.ID} 数据不存在"); |
| | | } |
| | | |
| | | if (!string.IsNullOrEmpty(input.TagName)) |
| | | { |
| | | if (_service.IsExistTagNameExceptID(input.TagName, input.ID)) |
| | | { |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, $"TagName:{input.TagName}", "标记已存在"); |
| | | throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, $"TagName:{input.TagName} 标记已存在"); |
| | | } |
| | | } |
| | | var rhs = new Model.AssetsHydrantMain(model); |
| | |
| | | #region Exist |
| | | |
| | | /// <summary> |
| | | /// 判断TagName是否存在 |
| | | /// |
| | | /// </summary> |
| | | public async Task<bool> IsExistTagName(string TagName) |
| | | { |
| | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 判断TagName是否存在 ExceptID |
| | | /// |
| | | /// </summary> |
| | | public async Task<bool> IsExistTagNameExceptID(string TagName, long ExceptID) |
| | | { |
| | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 全部删除 |
| | | /// 删除全部 |
| | | /// </summary> |
| | | /// <returns></returns> |
| | | public async Task<bool> DeleteAll() |
| | | { |
| | | return await Task.Factory.StartNew(() => |