Teams/shgx_tz_mes_backend_sync
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

仓库-毛坯仓库记录功能完成

Browse Source
This commit is contained in:
赵正易
2024-05-14 18:07:10 +08:00
parent 1f8d860379
commit 522cba1fbd
5 changed files with 141 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ZR.Service/mes/wms/IService/IWmBlankRecordService.cs
View File

@@ -20,8 +20,8 @@ namespace ZR.Service.mes.wms.IService
int UpdateWmBlankRecord(WmBlankRecord parm);
int AddInventory(string id, string fk_blank_inventory_id, int change_quantity,string username);
int DeleteInventory(string id, string fk_blank_inventory_id, int change_quantity, string username);
int AddInventory(string fkBlankInventoryId, string blankNum, int changeQuantity, string username, string remark);
int DeleteInventory(string fkBlankInventoryId, string blankNum, int changeQuantity, string username, string remark);
}
}

92
ZR.Service/mes/wms/WmBlankRecordService.cs
View File

@@ -26,12 +26,41 @@ namespace ZR.Service.mes.wms
/// <returns></returns>
public PagedInfo<WmBlankRecordDto> GetList(WmBlankRecordQueryDto parm)
{
var predicate = Expressionable.Create<WmBlankRecord>();
DateTime startTime = parm.CreatedTimeStart ?? new DateTime(1999, 1, 1, 0, 0, 0);
DateTime endTime = parm.CreatedTimeEnd ?? new DateTime(1999, 1, 1, 0, 0, 0);
var predicate = Expressionable.Create<WmBlankRecord>()
.AndIF(!string.IsNullOrEmpty(parm.FkBlankInventoryId), it => it.FkBlankInventoryId == parm.FkBlankInventoryId)
.AndIF(!string.IsNullOrEmpty(parm.BlankNum), it => it.BlankNum.Contains(parm.BlankNum))
// .AndIF(parm.Status > -1, it => it.Status == parm.Status)
.AndIF(parm.Type > 0, it => it.Type == parm.Type)
.AndIF(parm.CreatedTimeStart > new DateTime(1999, 1, 1, 0, 0, 0), it => it.CreatedTime >= startTime.ToLocalTime())
.AndIF(parm.CreatedTimeEnd > new DateTime(1999, 1, 1, 0, 0, 0), it => it.CreatedTime <= endTime.ToLocalTime())
;
var response = Queryable()
.Where(predicate.ToExpression())
.OrderByDescending(it=>it.CreatedTime)
.ToPage<WmBlankRecord, WmBlankRecordDto>(parm);
if (response.Result.Count > 0)
{
foreach (WmBlankRecordDto item in response.Result)
{
WmMaterial material = Context.Queryable<WmMaterial>()
.Where(it => it.BlankNum == item.BlankNum)
.Where(it => it.Remarks == "毛坯")
.First();
if (material == null)
{
item.Description = "此毛坯号不在物料清单内！";
continue;
}
item.Color = material.Color;
item.Unit = material.Unit;
item.Version = material.Version;
item.Specification = material.Specification;
item.Description = !string.IsNullOrEmpty(material.Description) ? material.Description : material.ProductName;
}
}
return response;
}
@@ -57,6 +86,7 @@ namespace ZR.Service.mes.wms
/// <returns></returns>
public WmBlankRecord AddWmBlankRecord(WmBlankRecord model)
{
model.Id = SnowFlakeSingle.Instance.NextId().ToString();
return Context.Insertable(model).ExecuteReturnEntity();
}
@@ -90,22 +120,29 @@ namespace ZR.Service.mes.wms
/// <param name="fk_blank_inventory_id"></param>
/// <param name="change_quantity"></param>
/// <returns></returns>
public int AddInventory(string id, string fk_blank_inventory_id, int change_quantity,string username)
public int AddInventory(string fkBlankInventoryId, string blankNum, int changeQuantity, string username, string remark)
{
bool hasRecord = Context.Queryable<WmBlankInventory>()
.Where(it => it.Id == fkBlankInventoryId).Any();
if (!hasRecord)
{
throw new Exception("无此毛坯号记录！");
}
// 增加库存
int result=Context.Updateable<WmBlankInventory>()
.SetColumns(it => it.Quantity == it.Quantity + change_quantity)
.Where(it => it.Id == id)
.Where(it => it.BlankNum == fk_blank_inventory_id)
int result = Context.Updateable<WmBlankInventory>()
.SetColumns(it => it.Quantity == it.Quantity + changeQuantity)
.Where(it => it.Id == fkBlankInventoryId)
.ExecuteCommand();
if(result==1)
if (result == 1)
{
WmBlankRecord res = new WmBlankRecord();
res.Id= SnowFlakeSingle.Instance.NextId().ToString();
res.FkBlankInventoryId=fk_blank_inventory_id;
res.ChangeQuantity = change_quantity;
res.Id = SnowFlakeSingle.Instance.NextId().ToString();
res.FkBlankInventoryId = fkBlankInventoryId;
res.BlankNum = blankNum;
res.ChangeQuantity = changeQuantity;
res.Type = 1;
res.Status = 1;
res.Remark = remark;
res.CreatedBy = username;
res.CreatedTime = DateTime.Now;
@@ -113,7 +150,7 @@ namespace ZR.Service.mes.wms
Context.Insertable(res).ExecuteCommand();
}
return result;
}
@@ -125,40 +162,41 @@ namespace ZR.Service.mes.wms
/// <param name="fk_blank_inventory_id"></param>
/// <param name="change_quantity"></param>
/// <returns></returns>
public int DeleteInventory(string id, string fk_blank_inventory_id, int change_quantity, string username)
public int DeleteInventory(string fkBlankInventoryId, string blankNum, int changeQuantity, string username, string remark)
{
int resut = 0;
UseTran2(() =>
bool tranReuslt = UseTran2(() =>
{
WmBlankInventory record = Context.Queryable<WmBlankInventory>()
.Where(it => it.Id == id)
.Where(it => it.BlankNum == fk_blank_inventory_id).First();
if (record != null && record.Quantity < change_quantity)
.Where(it => it.Id == fkBlankInventoryId)
.Where(it => it.BlankNum == blankNum).First();
if (record != null && record.Quantity < changeQuantity)
{
resut = 0 - change_quantity;
resut = 0 - changeQuantity;
throw new Exception("所填变动数字大于库存，无法减少！");
}
else if (record == null)
{
resut = -1;
throw new Exception("无此毛坯号记录！");
}
else
{
resut = Context.Updateable<WmBlankInventory>()
.SetColumns(it => it.Quantity == it.Quantity - change_quantity)
.Where(it => it.Id == id)
.Where(it => it.FkPaintId == fk_blank_inventory_id)
.SetColumns(it => it.Quantity == it.Quantity - changeQuantity)
.Where(it => it.Id == fkBlankInventoryId)
.ExecuteCommand();
if (resut == 1)
{
WmBlankRecord res = new WmBlankRecord();
res.Id = SnowFlakeSingle.Instance.NextId().ToString();
res.FkBlankInventoryId = fk_blank_inventory_id;
res.ChangeQuantity = change_quantity;
res.FkBlankInventoryId = fkBlankInventoryId;
res.BlankNum = blankNum;
res.ChangeQuantity = changeQuantity;
res.Type = 2;
res.Status = 1;
res.Remark = remark;
res.CreatedBy = username;
res.CreatedTime = DateTime.Now;
@@ -171,6 +209,10 @@ namespace ZR.Service.mes.wms
}
});
if (!tranReuslt)
{
throw new Exception("操作执行失败，事务失败！");
}
return resut;
}