Yi.Admin/Yi.Framework.Net6/Yi.Framework.Service/ERP/StockService.cs

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>
        /// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>,<2C><>Ҫ<EFBFBD><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ԫ<EFBFBD><D4AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
        /// </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);
                //<2F><><EFBFBD>ж<EFBFBD><D0B6>Ƿ<EFBFBD><C7B7><EFBFBD><EFBFBD>ڸ<EFBFBD><DAB8><EFBFBD><EFBFBD>ϣ<EFBFBD><CFA3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڣ<EFBFBD>ֱ<EFBFBD><D6B1><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
                var entityData = await Repository.GetFirstAsync(u => u.MaterialId == entity.MaterialId);
                if (entityData is not null)
                {
                    entityData.Number += input.Number;
                    await Repository.UpdateIgnoreNullAsync(entityData);
                }
                //<2F><><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
                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();

                //<2F><><EFBFBD><EFBFBD>Ҫ<EFBFBD><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ϸ<EFBFBD>IJ<EFBFBD><C4B2><EFBFBD>
                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>
        /// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>,<2C><>Ҫ<EFBFBD><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ԫ<EFBFBD><D4AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
        /// </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("<22><><EFBFBD><EFBFBD>ʧ<EFBFBD>ܣ<EFBFBD><DCA3>ÿ<EFBFBD><C3BF>治<EFBFBD><E6B2BB><EFBFBD><EFBFBD>");
                }


                //<2F><><EFBFBD>ж<EFBFBD><D0B6>Ƿ<EFBFBD><C7B7><EFBFBD><EFBFBD>ڸ<EFBFBD><DAB8><EFBFBD><EFBFBD>ϣ<EFBFBD><CFA3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڣ<EFBFBD>ֱ<EFBFBD>Ӽ<EFBFBD>ȥ<EFBFBD><C8A5><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>=0<><30>ֱ<EFBFBD><D6B1>ɾ<EFBFBD><C9BE><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݣ<EFBFBD><DDA3><EFBFBD><EFBFBD><EFBFBD>С<EFBFBD><D0A1><EFBFBD>㣬<EFBFBD><E3A3AC><EFBFBD>治<EFBFBD><E6B2BB>
                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("<22><><EFBFBD>治<EFBFBD><E6B2BB>");
                    }
                    else if (entityData.Number == 0)
                    {
                        await Repository.DeleteAsync(u => u.MaterialId == input.MaterialId);
                    }
                    else
                    {
                        await Repository.UpdateIgnoreNullAsync(entityData);
                    }

                }
                //<2F><><EFBFBD><EFBFBD><EFBFBD>ڸ<EFBFBD><DAB8><EFBFBD><EFBFBD><EFBFBD>
                else
                {
                    throw new UserFriendlyException("<22><><EFBFBD><EFBFBD>δ<EFBFBD><CEB4><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD>");
                }
                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();

                //<2F><><EFBFBD><EFBFBD>Ҫ<EFBFBD><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ϸ<EFBFBD>IJ<EFBFBD><C4B2><EFBFBD>
                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;
        }

    }
}