OA2023/OASystem/OASystem.Infrastructure/Repositories/PersonnelModule/GoodsRepository.cs

using OASystem.Domain.Entities.PersonnelModule;
using OASystem.Domain.ViewModels.PersonnelModule;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using AutoMapper;
using OASystem.Domain.Dtos.PersonnelModule;
using SqlSugar;

namespace OASystem.Infrastructure.Repositories.PersonnelModule
{
    /// <summary>
    /// 物品进销存 
    /// 仓储
    /// </summary>
    public class GoodsRepository:BaseRepository<Pm_GoodsInfo,GoodsInfoView>
    {
        private readonly IMapper _mapper;
        private JsonView _jv;
        public GoodsRepository(SqlSugarClient sqlSugar,IMapper mapper):base(sqlSugar)
        {
            _mapper = mapper;
            _jv = new JsonView() { Code = StatusCodes.Status400BadRequest, Msg = "无效请求!" };
        }

        /// <summary>
        /// 基础数据
        /// </summary>
        /// <returns></returns>
        public async Task<JsonView> InitDataSource()
        {

            var typeData = await _sqlSugar.Queryable<GoodsTypeView>()
                                          .Includes(x => x.SubTypeItems.Where(z => z.IsDel == 0)
                                                                       //.Select(z => new {
                                                                       //     z.Id,
                                                                       //     z.STid,
                                                                       //     z.Name
                                                                       //})
                                                                       .ToList())
                                          .Where(x => x.IsDel == 0 &&
                                                      x.Remark.Equals("GoodsType"))
                                          //.Select(x => new { 
                                          //        x.Id,
                                          //        x.Name,
                                          //        x.SubTypeItems
                                          //})
                                          .ToListAsync();

            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = typeData;
            _jv.Msg = $"操作成功";
            return _jv;
        }

       /// <summary>
       /// 物品列表
       /// </summary>
       /// <param name="_dto"></param>
       /// <returns></returns>
        public async Task<JsonView> GoodsList(GoodsListDTO _dto)
        {
            var ids = new List<int>();
            if (!string.IsNullOrEmpty(_dto.TypeIds))
            {
                var strArray = _dto.TypeIds.Split(',');
                foreach (var str in strArray)
                {
                    if (int.TryParse(str, out int id))
                    {
                        ids.Add(id);
                    }
                }
            }

            RefAsync<int> total = 0;
            var data = await _sqlSugar.Queryable<Pm_GoodsInfo>()
                                      .LeftJoin<Sys_SetData>((gi, sd) => gi.Type == sd.Id)
                                      .LeftJoin<Sys_Users>((gi, sd, u) => gi.LastUpdateUserId == u.Id)
                                      .Where((gi, sd, u) => gi.IsDel == 0)
                                      .WhereIF(ids.Count > 0, (gi, sd, u) => ids.Contains(gi.Type))
                                      .WhereIF(!string.IsNullOrEmpty(_dto.GoodsName), (gi, sd, u) => gi.Name.Contains(_dto.GoodsName))
                                      .Select((gi, sd, u) => new
                                      {
                                          gi.Id,
                                          gi.Name,
                                          gi.Type,
                                          TypeName = sd.Name,
                                          gi.StockQuantity,
                                          LastUpdateUserName = u.CnName,
                                          gi.LastUpdateTime,
                                          gi.Remark,
                                      })
                                      .OrderByDescending(gi => gi.LastUpdateTime)
                                      .ToPageListAsync(_dto.PageIndex, _dto.PageSize, total);


            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            _jv.Count = total;
            _jv.Msg = $"操作成功";
            return _jv;
        }

        /// <summary>
        /// 物品Info
        /// </summary>
        /// <param name="_dto"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsInfo(int portType,int id)
        {
            var data = await _sqlSugar.Queryable<Pm_GoodsInfo>()
                                      .LeftJoin<Sys_SetData>((gi, sd) => gi.Type == sd.Id)
                                      .LeftJoin<Sys_Users>((gi, sd, u1) => gi.LastUpdateUserId == u1.Id)
                                      .LeftJoin<Sys_Users>((gi, sd, u1 ,u2) => gi.CreateUserId == u2.Id)
                                      .Where((gi, sd, u1, u2) => gi.IsDel == 0 && gi.Id == id)
                                      .Select((gi, sd, u1, u2) => new
                                      {
                                          gi.Id,
                                          gi.Name,
                                          gi.Type,
                                          TypeName = sd.Name,
                                          gi.SQ_Total,
                                          gi.OQ_Total,
                                          gi.PriceTotal,
                                          gi.StockQuantity,
                                          gi.Remark,
                                          LastUpdateUserName = u1.CnName,
                                          gi.LastUpdateTime,
                                          CreateUserName = u2.CnName,
                                          gi.CreateTime,
                                      })
                                      .FirstAsync();

            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            _jv.Msg = $"操作成功";
            return _jv;
        }

        /// <summary>
        /// 物品 OP(Create Or Edit)
        /// </summary>
        /// <param name="_dto"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsOP(GoodsOPDTO _dto)
        {
            var info = new Pm_GoodsInfo()
            {
                Id = _dto.Id,
                Name = _dto.Name,
                Type = _dto.Type,
                SQ_Total = 0,
                OQ_Total = 0,
                PriceTotal = 0,
                StockQuantity = 0,
                Remark = _dto.Remark,
                LastUpdateUserId = _dto.CurrUserId,
                LastUpdateTime = DateTime.Now,
                CreateUserId = _dto.CurrUserId
            };

            if (_dto.Id > 0) //Edit
            {
                var upd = await _sqlSugar.Updateable<Pm_GoodsInfo>(info)
                                         .UpdateColumns(x => new
                                         {
                                             x.Name,
                                             x.Type,
                                             x.Remark,
                                             x.LastUpdateUserId,
                                             x.LastUpdateTime,
                                         })
                                         .ExecuteCommandAsync();
                if (upd > 0)
                {
                    _jv.Msg = $"修改成功!"; 
                    _jv.Code = StatusCodes.Status200OK;
                    return _jv;
                }
            }
            else if (_dto.Id < 1) //添加
            {
                var selectInfo = await _sqlSugar.Queryable<Pm_GoodsInfo>().FirstAsync(x => x.Name.Equals(info.Name));
                if (selectInfo != null)
                {
                    _jv.Msg = $"“{info.Name}”该物品已存在,请勿重新添加!";
                    return _jv;
                }

                var add = await _sqlSugar.Insertable<Pm_GoodsInfo>(info).ExecuteCommandAsync();
                if (add > 0)
                {
                    _jv.Msg = $"添加成功!";
                    _jv.Code = StatusCodes.Status200OK;
                    return _jv;
                }
            }
            return _jv;
        }


        /// <summary>
        /// 物品入库列表
        /// </summary>
        /// <param name="_dto"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsStorageList(GoodsStorageListDTO _dto)
        {
            RefAsync<int> total = 0;
            var data = await _sqlSugar.Queryable<Pm_GoodsStorage>()
                                      .LeftJoin<Pm_GoodsInfo>((gs, gi) => gs.GoodsId == gi.Id)
                                      .LeftJoin<Sys_Users>((gs, gi, u) => gs.CreateUserId == u.Id)
                                      .Where((gs, gi, u) => gs.IsDel == 0)
                                      .WhereIF(_dto.GoodsId > 0, (gs, gi, u) => gs.GoodsId == _dto.GoodsId)
                                      .Select((gs, gi, u) => new
                                      {
                                          gs.Id,
                                          gs.GoodsId,
                                          GoodsName = gi.Name,
                                          gs.Quantity,
                                          gs.UnitPrice,
                                          gs.TotalPrice,
                                          gs.SupplierName,
                                          gs.SupplierTel,
                                          gs.SupplierAddress,
                                          gs.SupplierSource,
                                          CreateUserName = u.CnName,
                                          gs.CreateTime,
                                      })
                                      .OrderByDescending(gs => gs.CreateTime)
                                      .ToPageListAsync(_dto.PageIndex, _dto.PageSize, total);


            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            _jv.Count = total;
            _jv.Msg = $"操作成功";
            return _jv;
        }

        /// <summary>
        /// 物品入库详情
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsStorageInfo(int portType, int id)
        {
            var data = await _sqlSugar.Queryable<Pm_GoodsStorage>()
                                      .LeftJoin<Pm_GoodsInfo>((gs, gi) => gs.GoodsId == gi.Id)
                                      .LeftJoin<Sys_Users>((gs, gi, u) => gs.CreateUserId == u.Id)
                                      .Where((gs, gi, u) => gs.IsDel == 0)
                                      .WhereIF(id > 0, (gs, gi, u) => gs.GoodsId == id)
                                      .Select((gs, gi, u) => new
                                      {
                                          gs.Id,
                                          gs.GoodsId,
                                          GoodsName = gi.Name,
                                          gs.Quantity,
                                          gs.UnitPrice,
                                          gs.TotalPrice,
                                          gs.SupplierName,
                                          gs.SupplierTel,
                                          gs.SupplierAddress,
                                          gs.SupplierSource,
                                          CreateUserName = u.CnName,
                                          gs.CreateTime,
                                          gs.Remark
                                      })
                                      .FirstAsync();

            _jv.Msg = $"操作成功!";
            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            return _jv;
        }


        /// <summary>
        /// 物品入库 操作(Create Or Edit)
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsStorageOP(int portType, int id)
        {
            var data = await _sqlSugar.Queryable<Pm_GoodsStorage>()
                                      .LeftJoin<Pm_GoodsInfo>((gs, gi) => gs.GoodsId == gi.Id)
                                      .LeftJoin<Sys_Users>((gs, gi, u) => gs.CreateUserId == u.Id)
                                      .Where((gs, gi, u) => gs.IsDel == 0)
                                      .WhereIF(id > 0, (gs, gi, u) => gs.GoodsId == id)
                                      .Select((gs, gi, u) => new
                                      {
                                          gs.Id,
                                          gs.GoodsId,
                                          GoodsName = gi.Name,
                                          gs.Quantity,
                                          gs.UnitPrice,
                                          gs.TotalPrice,
                                          gs.SupplierName,
                                          gs.SupplierTel,
                                          gs.SupplierAddress,
                                          gs.SupplierSource,
                                          CreateUserName = u.CnName,
                                          gs.CreateTime,
                                          gs.Remark
                                      })
                                      .FirstAsync();

            _jv.Msg = $"操作成功!";
            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            return _jv;
        }


        /// <summary>
        /// 物品领用列表
        /// </summary>
        /// <param name="_dto"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsReceiveList(GoodsReceiveListDTO _dto)
        {
            RefAsync<int> total = 0;
            var data = await _sqlSugar.Queryable<Pm_GoodsReceive>()
                                      .LeftJoin<Pm_GoodsInfo>((gr, gi) => gr.GoodsId == gi.Id)
                                      .LeftJoin<Sys_Users>((gr, gi, u1) => gr.AuditUserId == u1.Id)
                                      .LeftJoin<Sys_Users>((gr, gi, u1,u2) => gr.CreateUserId == u2.Id)
                                      .Where((gr, gi, u1, u2) => gr.IsDel == 0)
                                      .WhereIF(_dto.GoodsId > 0, (gr, gi, u1, u2u) => gr.GoodsId == _dto.GoodsId)
                                      .Select((gr, gi, u1, u2) => new
                                      {
                                          gr.Id,
                                          gr.GroupId,
                                          gr.GoodsId,
                                          GoodsName = gi.Name,
                                          gr.Quantity,
                                          gr.Reason,
                                          gr.Remark,
                                          gr.AuditStatus,
                                          AuditStatusText = gr.AuditStatus.GetDescription(),
                                          gr.AuditUserId,
                                          AuditUserName = u1.CnName,
                                          gr.AuditTime,
                                          CreateUserName = u2.CnName,
                                          gr.CreateTime
                                      })
                                      .OrderByDescending(gs => gs.CreateTime)
                                      .ToPageListAsync(_dto.PageIndex, _dto.PageSize, total);


            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            _jv.Count = total;
            _jv.Msg = $"操作成功";
            return _jv;
        }

        /// <summary>
        /// 物品领用详情
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<JsonView> GoodsReceiveInfo(int portType, int id)
        {
            var data = await _sqlSugar.Queryable<Pm_GoodsReceive>()
                                      .LeftJoin<Pm_GoodsInfo>((gr, gi) => gr.GoodsId == gi.Id)
                                      .LeftJoin<Sys_Users>((gr, gi, u1) => gr.AuditUserId == u1.Id)
                                      .LeftJoin<Sys_Users>((gr, gi, u1, u2) => gr.CreateUserId == u2.Id)
                                      .Where((gr, gi, u1, u2) => gr.IsDel == 0)
                                      .WhereIF(id > 0, (gr, gi, u1, u2u) => gr.GoodsId == id)
                                      .Select((gr, gi, u1, u2) => new
                                      {
                                          gr.Id,
                                          gr.GroupId,
                                          gr.GoodsId,
                                          GoodsName = gi.Name,
                                          gr.Quantity,
                                          gr.Reason,
                                          gr.Remark,
                                          gr.AuditStatus,
                                          AuditStatusText = gr.AuditStatus.GetDescription(),
                                          gr.AuditUserId,
                                          AuditUserName = u1.CnName,
                                          gr.AuditTime,
                                          CreateUserName = u2.CnName,
                                          gr.CreateTime
                                      })
                                      .FirstAsync();


            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = data;
            _jv.Msg = $"操作成功";
            return _jv;
        }
    }
}