duheng
2024-11-29 5c14c9686d2bd7c99fdd6cc6fc19404e6e4b8e4d
BLL/HStation.BLL.WE.Core/03-localclient/01-utensil/UtensilMapping.cs
@@ -1,13 +1,15 @@
namespace HStation.CAL.WE.LocalClient
using Mapster;
using Yw.Dto;
namespace HStation.CAL.WE.LocalClient
{
    /// <summary>
    /// 用水器具映射
    ///</summary>
    ///</summary>
    public class UtensilMapping : IUtensilMapping
    {
    {
        private readonly Service.WE.UtensilMapping _service = new();
        #region Query
        /// <summary>
@@ -36,6 +38,20 @@
        }
        /// <summary>
        /// 通过 ItemID 获取
        /// </summary>
        public async Task<List<UtensilMappingDto>> GetByItemID(long ItemID)
        {
            return await Task.Factory.StartNew(() =>
            {
                var list = _service.GetAll();
                var select = list.Where(x => x.ItemID == ItemID).ToList();
                return select?.Select(x => new UtensilMappingDto(x)).ToList();
            }
            );
        }
        /// <summary>
        /// 通过 Ids 获取
        /// </summary>
        public async Task<List<UtensilMappingDto>> GetByIds(List<long> Ids)
@@ -48,7 +64,6 @@
            });
        }
        /// <summary>
        /// 获取最大排序码
        /// </summary>
@@ -60,8 +75,8 @@
                return sort_code;
            });
        }
        #endregion
        #endregion Query
        #region Insert
@@ -73,7 +88,7 @@
            return await Task.Factory.StartNew(() =>
            {
                var model = input.Adapt<AddUtensilMappingInput, Model.WE.UtensilMapping>();
                model.SortCode = _service.GetMaxSortCode() + 1;
                model.SortCode = _service.GetMaxSortCode() + 1;
                var id = _service.Insert(model);
                return id;
            });
@@ -86,13 +101,16 @@
        {
            return await Task.Factory.StartNew(() =>
            {
                return false;
                var list = inputList.Select(x => x.Adapt<AddUtensilMappingInput, Model.WE.UtensilMapping>()).ToList();
                list.ForEach(x => x.SortCode = _service.GetMaxSortCode() + 1);
                var id = _service.Inserts(list);
                return id;
            });
        }
        /// <summary>
        /// 大批量插入
        /// </summary>
        /// </summary>
        public async Task<bool> BulkInserts(List<AddUtensilMappingInput> list)
        {
            return await Task.Factory.StartNew(() =>
@@ -134,10 +152,10 @@
                return false;
            });
        }
        /// <summary>
        /// 大批量更新
        /// </summary>
        /// </summary>
        public async Task<bool> BulkUpdates(List<UpdateUtensilMappingInput> list)
        {
            return await Task.Factory.StartNew(() =>
@@ -145,8 +163,7 @@
                return false;
            });
        }
        /// <summary>
        /// 更新排序码
        /// </summary>
@@ -175,7 +192,7 @@
        #endregion Update
        #region Delete
        /// <summary>
        /// 通过 ID 删除
        /// </summary>
@@ -194,8 +211,24 @@
        /// <summary>
        /// 通过 Ids 删除
        /// </summary>
        /// </summary>
        public async Task<bool> DeleteByIds(List<long> Ids)
        {
            return await Task.Factory.StartNew(() =>
            {
                var bol = _service.DeleteByIds(Ids, out string msg);
                if (!bol)
                {
                    throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D999, msg);
                }
                return true;
            });
        }
        /// <summary>
        /// 全部删除
        /// </summary>
        public async Task<bool> DeleteAll()
        {
            return await Task.Factory.StartNew(() =>
            {
@@ -204,16 +237,15 @@
        }
        /// <summary>
        /// 全部删除
        /// </summary>
        public async Task<bool> DeleteAll()
        /// 通过  ItemID 删除所有
        /// </summary>
        public virtual async Task<bool> DeleteAllByItemID(long item)
        {
            return await Task.Factory.StartNew(() =>
            {
                return false;
            });
        }
        #endregion
            var alllist = await GetByItemID(item);
            var bol = await DeleteByIds(alllist.Select(x => x.ID).ToList());
            return bol;
        }
        #endregion Delete
    }
}