添加库存管理，入库、出库，收款、回款接口

2026-04-02 23:26:36 +08:00 · 2023-01-08 21:52:18 +08:00
parent 8077450be0
commit 27ca377762
28 changed files with 1285 additions and 10 deletions
--- a/Yi.Framework.Net6/Yi.Framework.Service/Base/Crud/AbstractKeyReadOnlyAppService.cs
+++ b/Yi.Framework.Net6/Yi.Framework.Service/Base/Crud/AbstractKeyReadOnlyAppService.cs
@@ -31,14 +31,14 @@ namespace Yi.Framework.Service.Base.Crud
        public IRepository<TEntity> Repository { get; set; }


-        public async Task<List<TGetListOutputDto>> GetListAsync()
+        public virtual async Task<List<TGetListOutputDto>> GetListAsync()
        {
            var entitys = await Repository.GetListAsync();
            var entityDtos = await MapToGetListOutputDtosAsync(entitys);
            return entityDtos;
        }

-        public async Task<TGetOutputDto> GetByIdAsync(TKey id)
+        public virtual async Task<TGetOutputDto> GetByIdAsync(TKey id)
        {
            var entity = await GetEntityByIdAsync(id);
            if (entity is null)
--- a/Yi.Framework.Net6/Yi.Framework.Service/ERP/StockDetailsService.cs
+++ b/Yi.Framework.Net6/Yi.Framework.Service/ERP/StockDetailsService.cs
@@ -0,0 +1,29 @@
+using AutoMapper;
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Yi.Framework.Common.Models;
+using Yi.Framework.DtoModel.ERP.StockDetails;
+using Yi.Framework.Interface.ERP;
+using Yi.Framework.Model.ERP.Entitys;
+using Yi.Framework.Repository;
+using Yi.Framework.Service.Base.Crud;
+
+namespace Yi.Framework.Service.ERP
+{
+    public class StockDetailsService : CrudAppService<StockDetailsEntity, StockDetailsGetListOutput, long, StockDetailsCreateUpdateInput>, IStockDetailsService
+    {
+        public async Task<PageModel<List<StockDetailsGetListOutput>>> PageListAsync(StockDetailsGetListInput input, PageParModel page)
+        {
+            RefAsync<int> totalNumber = 0;
+            var data = await Repository._DbQueryable
+                .Where(u => u.StockDetailsType == input.StockDetailsType)
+                .WhereIF(page.StartTime is not null && page.EndTime is not null, u => u.StockDetailsTime >= page.StartTime && u.StockDetailsTime <= page.EndTime)
+                .ToPageListAsync(page.PageNum, page.PageSize, totalNumber);
+            return new PageModel<List<StockDetailsGetListOutput>> { Total = totalNumber.Value, Data = await MapToGetListOutputDtosAsync(data) };
+        }
+    }
+}
--- a/Yi.Framework.Net6/Yi.Framework.Service/ERP/StockService.cs
+++ b/Yi.Framework.Net6/Yi.Framework.Service/ERP/StockService.cs
@@ -0,0 +1,188 @@
+using AutoMapper;
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Yi.Framework.Common.Exceptions;
+using Yi.Framework.Common.Models;
+using Yi.Framework.DtoModel.ERP.Stock;
+using Yi.Framework.Interface.ERP;
+using Yi.Framework.Model.ERP.Entitys;
+using Yi.Framework.Repository;
+using Yi.Framework.Service.Base.Crud;
+
+namespace Yi.Framework.Service.ERP
+{
+    public class StockService : CrudAppService<StockEntity, StockGetListOutput, long, StockCreateUpdateInput>, IStockService
+    {
+        private IRepository<StockDetailsEntity> _detailsRepository;
+        private ISugarUnitOfWork<UnitOfWork> _unitOfWork;
+        public StockService(IRepository<StockDetailsEntity> detailsRepository, ISugarUnitOfWork<UnitOfWork> unitOfWork)
+        {
+            _detailsRepository = detailsRepository;
+            _unitOfWork = unitOfWork;
+        }
+        public async Task<PageModel<List<StockGetListOutput>>> PageListAsync(StockGetListInput input, PageParModel page)
+        {
+            RefAsync<int> totalNumber = 0;
+            var data = await Repository._DbQueryable
+                   .LeftJoin<WarehouseEntity>((stock, warehouse) => stock.WarehouseId == warehouse.Id)
+                          .LeftJoin<MaterialEntity>((stock, warehouse, material) => stock.MaterialId == material.Id)
+                          .Select((stock, warehouse, material) => new StockGetListOutput
+                          {
+                              MaterialName = material.Name,
+                              WarehouseName = warehouse.Name,
+                              UnitName = material.UnitName
+                          }, true)
+                .ToPageListAsync(page.PageNum, page.PageSize, totalNumber);
+            return new PageModel<List<StockGetListOutput>> { Total = totalNumber.Value, Data = data };
+        }
+
+        public override async Task<StockGetListOutput> GetByIdAsync(long id)
+        {
+            return await Repository._DbQueryable
+                     .LeftJoin<WarehouseEntity>((stock, warehouse) => stock.WarehouseId == warehouse.Id)
+                            .LeftJoin<MaterialEntity>((stock, warehouse, material) => stock.MaterialId == material.Id)
+                            .Select((stock, warehouse, material) => new StockGetListOutput
+                            {
+                                MaterialName = material.Name,
+                                WarehouseName = warehouse.Name,
+                                UnitName = material.UnitName
+                            }, true)
+                  .FirstAsync(stock => stock.Id==id);
+        }
+
+
+
+
+
+        /// <summary>
+        /// 入库操作,需要工作单元事务操作
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        public async Task<StockGetListOutput> InputStockAsync(StockCreateUpdateInput input)
+        {
+            StockGetListOutput result = new();
+            using (var uow = _unitOfWork.CreateContext())
+            {
+                var entity = await MapToEntityAsync(input);
+                //先判断是否存在该物料，如果存在，直接添加数量
+                var entityData = await Repository.GetFirstAsync(u => u.MaterialId == entity.MaterialId);
+                if (entityData is not null)
+                {
+                    entityData.Number += input.Number;
+                    await Repository.UpdateIgnoreNullAsync(entityData);
+                }
+                //添加一条库存数据
+                else
+                {
+                    await Repository.InsertReturnSnowflakeIdAsync(entity);
+                }
+
+                result = await Repository._DbQueryable
+                          .LeftJoin<WarehouseEntity>((stock, warehouse) => stock.WarehouseId == warehouse.Id)
+                          .LeftJoin<MaterialEntity>((stock, warehouse, material) => stock.MaterialId == material.Id)
+                          .Select((stock, warehouse, material) => new StockGetListOutput
+                          {
+                              MaterialName = material.Name,
+                              WarehouseName = warehouse.Name,
+                              UnitName = material.UnitName
+                          }, true).FirstAsync();
+
+                //还需要进行入库明细的插入
+                StockDetailsEntity stockDetailsEntity = new();
+                stockDetailsEntity.StockId = result.Id;
+                stockDetailsEntity.WarehouseId = input.WarehouseId;
+                stockDetailsEntity.MaterialId = input.MaterialId;
+                stockDetailsEntity.WarehouseName = result.WarehouseName;
+                stockDetailsEntity.MaterialName = result.MaterialName;
+                stockDetailsEntity.StockDetailsTime = DateTime.Now;
+                stockDetailsEntity.Quality = input.Quality;
+                stockDetailsEntity.Number = input.Number;
+                stockDetailsEntity.StockDetailsType = StockDetailsTypeEnum.Input;
+
+                await _detailsRepository.InsertReturnSnowflakeIdAsync(stockDetailsEntity);
+
+                uow.Commit();
+
+            }
+
+            return result;
+        }
+
+        /// <summary>
+        /// 出库操作,需要工作单元事务操作
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        public async Task<StockGetListOutput> OutputStockAsync(StockCreateUpdateInput input)
+        {
+            StockGetListOutput result = new();
+            using (var uow = _unitOfWork.CreateContext())
+            {
+                var entity = await Repository.GetByIdAsync(input.Id);
+
+                if (entity is null)
+                {
+                    throw new ApplicationException("出库失败，该库存不存在");
+                }
+
+
+                //先判断是否存在该物料，如果存在，直接减去数量，如果减完数量=0，直接删除该条数据，如果小于零，库存不足
+                var entityData = await Repository.GetFirstAsync(u => u.MaterialId == entity.MaterialId);
+                if (entityData is not null)
+                {
+                    entityData.Number -= input.Number;
+
+                    if (entityData.Number < 0)
+                    {
+                        throw new UserFriendlyException("库存不足");
+                    }
+                    else if (entityData.Number == 0)
+                    {
+                        await Repository.DeleteAsync(u => u.MaterialId == input.MaterialId);
+                    }
+                    else
+                    {
+                        await Repository.UpdateIgnoreNullAsync(entityData);
+                    }
+
+                }
+                //不存在该物料
+                else
+                {
+                    throw new UserFriendlyException("库存未发现该物料");
+                }
+                result = await Repository._DbQueryable
+                          .LeftJoin<WarehouseEntity>((stock, warehouse) => stock.WarehouseId == warehouse.Id)
+                          .LeftJoin<MaterialEntity>((stock, warehouse, material) => stock.MaterialId == material.Id)
+                          .Select((stock, warehouse, material) => new StockGetListOutput
+                          {
+                              MaterialName = material.Name,
+                              WarehouseName = warehouse.Name,
+                              UnitName = material.UnitName
+                          }, true).FirstAsync();
+
+                //还需要进行入库明细的插入
+                StockDetailsEntity stockDetailsEntity = new();
+                stockDetailsEntity.StockId = result.Id;
+                stockDetailsEntity.WarehouseId = input.WarehouseId;
+                stockDetailsEntity.MaterialId = input.MaterialId;
+                stockDetailsEntity.WarehouseName = result.WarehouseName;
+                stockDetailsEntity.MaterialName = result.MaterialName;
+                stockDetailsEntity.StockDetailsTime = DateTime.Now;
+                stockDetailsEntity.Quality = input.Quality;
+                stockDetailsEntity.Number = input.Number;
+                stockDetailsEntity.StockDetailsType = StockDetailsTypeEnum.Output;
+                await _detailsRepository.InsertReturnSnowflakeIdAsync(stockDetailsEntity);
+                uow.Commit();
+            }
+
+            return result;
+        }
+
+    }
+}