|
@@ -7,6 +7,7 @@ using System.Text;
|
|
|
using System.Threading.Tasks;
|
|
|
using AutoMapper;
|
|
|
using OASystem.Domain.Dtos.PersonnelModule;
|
|
|
+using SqlSugar;
|
|
|
|
|
|
namespace OASystem.Infrastructure.Repositories.PersonnelModule
|
|
|
{
|
|
@@ -103,6 +104,104 @@ namespace OASystem.Infrastructure.Repositories.PersonnelModule
|
|
|
return _jv;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ 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;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ 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)
|
|
|
+ {
|
|
|
+ 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;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
|
|
@@ -142,6 +241,80 @@ namespace OASystem.Infrastructure.Repositories.PersonnelModule
|
|
|
return _jv;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ 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;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ 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;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
|
|
@@ -184,6 +357,43 @@ namespace OASystem.Infrastructure.Repositories.PersonnelModule
|
|
|
return _jv;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ 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;
|
|
|
+ }
|
|
|
}
|
|
|
}
|