RIZO/zhuangpei-mesbackend
7
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://gitee.com/doan-tech/zhuangpei-mesbackend

Browse Source
This commit is contained in:
赵正易 2024-11-18 11:24:50 +08:00
commit 3203b5f9d7
9 changed files with 568 additions and 108 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
DOAN.Admin.WebApi/Controllers/JobKanban/WorkOrderProgressController.cs
View File

@ -77,21 +77,6 @@ public class WorkOrderProgressController : BaseController
return SUCCESS(response);
}
//TODO 获取不同状态的工单 (PDA用) (废弃)
//TODO 根据班组，日期
[HttpGet("get_workorder_status_list")]
public IActionResult GetWorkOrderStatusList(string group_code,int status, DateTime handleDate)
{
handleDate=DOANConvertDateTime.ConvertLocalDate(handleDate);
if (string.IsNullOrEmpty(group_code) || handleDate == DateTime.MinValue)
throw new CustomException("传入空值异常");
var response = workorderProgressService.GetWorkOrderStatusList(group_code, status, handleDate);
return SUCCESS(response);
}
// 获取工单详情
[HttpGet("get_workorder_detail")]
@ -183,21 +168,6 @@ public class WorkOrderProgressController : BaseController
return SUCCESS(response);
}
//TODO 无需防错就报工
/// <summary>
/// 无需防错就报工
/// </summary>
/// <param name="wokorder">工单</param>
/// <param name="reportNum">报工数</param>
/// <returns></returns>
[HttpGet("no_errorProofingAndReportingReport")]
public IActionResult NoErrorProofingAndReportingReport(string workorder,int reportNum)
{
if (string.IsNullOrEmpty(workorder) || reportNum<=0)
throw new CustomException("workorder或者报工数为0");
var response = workorderProgressService.NoErrorProofingAndReportingReport(workorder, reportNum);
return SUCCESS(response);
}
/// <summary>
/// TODO 完成 工单

23
DOAN.Admin.WebApi/Controllers/MES/mm/line_sider/MmLinesidebarInventoryCheckController.cs
View File

@ -35,6 +35,29 @@ namespace DOAN.Admin.WebApi.Controllers
var response = _mmLinesidebarInventoryCheckService.GetList(parm);
return SUCCESS(response);
}
//TODO 校正
[HttpGet("correcting")]
public IActionResult Correcting(string id)
{
if (string.IsNullOrEmpty(id)) throw new CustomException("id is empty");
var response = _mmLinesidebarInventoryCheckService.Correcting(id);
return SUCCESS(response);
}
//TODO 修改
[HttpPut]
[Log(Title = "线边库库存盘点", BusinessType = BusinessType.UPDATE)]
public IActionResult UpdateMmLinesidebarInventoryCheck([FromBody] MmInventoryCheckLogDto parm)
{
var modal = parm.Adapt<MmInventoryCheckLog>().ToUpdate(HttpContext);
var response = _mmLinesidebarInventoryCheckService.UpdateMmInventoryCheckLog(modal);
return ToResponse(response);
}
}
}

122
DOAN.Admin.WebApi/Controllers/Mobile/product/PADReportWorkController.cs
View File

@ -1,9 +1,12 @@
using DOAN.Admin.WebApi.Filters;
using DOAN.Model.MES.product;
using DOAN.Model.MES.product.Dto;
using DOAN.Service.Mobile;
using Microsoft.AspNetCore.Mvc;
using DOAN.Service.Mobile.IService;
using DOAN.Model.Mobile.Dto;
using DOAN.Service.MES.product.IService;
using Infrastructure.Converter;
namespace DOAN.Admin.Mobile.Controllers
{
@ -17,12 +20,125 @@ namespace DOAN.Admin.Mobile.Controllers
/// <summary>
/// 报工表接口
/// </summary>
private readonly IProReportworkService _ProReportworkService;
private readonly IPADReportWorkService padReportWorkService;
public PADReportWorkController(IProReportworkService _ProReportworkService)
public PADReportWorkController(IPADReportWorkService padReportWorkService)
{
this._ProReportworkService = _ProReportworkService;
this.padReportWorkService = padReportWorkService;
}
//TODO 无需防错就报工
/// <summary>
/// 无需防错就报工
/// </summary>
/// <param name="wokorder">工单</param>
/// <param name="reportNum">报工数</param>
/// <returns></returns>
[HttpGet("no_errorProofingAndReportingReport")]
public IActionResult NoErrorProofingAndReportingReport(string workorder,int reportNum)
{
if (string.IsNullOrEmpty(workorder) || reportNum<=0)
throw new CustomException("workorder或者报工数为0");
var response = padReportWorkService.NoErrorProofingAndReportingReport(workorder, reportNum);
return SUCCESS(response);
}
//TODO 获取全部工艺路线
[HttpGet("get_all_route")]
public IActionResult GetAllRoute()
{
var response = padReportWorkService.GetAllRoute();
return SUCCESS(response);
}
//TODO 获取全部组
[HttpGet("get_groups")]
public IActionResult GetGroupList()
{
var response = padReportWorkService.GetGroupList();
return SUCCESS(response);
}
//TODO 获取报工工单列表
[HttpPost("list")]
[ActionPermissionFilter(Permission = "productManagement:proreportwork:list")]
public IActionResult QueryProReportwork([FromBody] ProReportworkQueryDto parm)
{
if(parm==null&&string.IsNullOrEmpty(parm.FkWorkorder))
{
SUCCESS(null);
}
var response = padReportWorkService.GetList(parm);
return SUCCESS(response);
}
//获取工单列表PDA
//TODO 获取不同状态的工单 (PDA用)
//TODO 根据班组，日期
[HttpGet("get_workorder_status_list")]
public IActionResult GetWorkOrderStatusList(string group_code,int status, DateTime handleDate)
{
handleDate=DOANConvertDateTime.ConvertLocalDate(handleDate);
if (string.IsNullOrEmpty(group_code) || handleDate == DateTime.MinValue)
throw new CustomException("传入空值异常");
var response = padReportWorkService.GetWorkOrderStatusList(group_code, status, handleDate);
return SUCCESS(response);
}
/// <summary>
/// 更新报工表
/// </summary>
/// <returns></returns>
[HttpPut]
[Log(Title = "报工表", BusinessType = BusinessType.UPDATE)]
public IActionResult UpdateProReportwork([FromBody] ProReportworkDto parm)
{
var modal = parm.Adapt<ProReportwork>().ToUpdate(HttpContext);
var response = padReportWorkService.UpdateProReportwork(modal);
return ToResponse(response);
}
//TODO 获取工单详情
// 获取工单详情
[HttpGet("get_workorder_detail")]
public IActionResult GetWorkOrderDetail(string workorder)
{
if (string.IsNullOrEmpty(workorder)) return SUCCESS(null);
var response = padReportWorkService.GetWorkOrderDetail(workorder);
return SUCCESS(response);
}
//TODO 开始某个工单
[HttpGet("start_workorder")]
public IActionResult StartWorkOrder(string workorder)
{
if (string.IsNullOrEmpty(workorder)) return SUCCESS(null);
var response = padReportWorkService.StartWorkOrder(workorder);
return SUCCESS(response);
}
//TODO 完成某一个工单
[HttpGet("finish_workorder")]
public IActionResult FinishWorkOrder(string workorder)
{
if (string.IsNullOrEmpty(workorder)) return SUCCESS(null);
var response = padReportWorkService.FinishWorkOrder(workorder);
return SUCCESS(response);
}
// TODO 如果没有id 传入工单 手动生成报工记录 沿用之前路由 /mes/productManagement/ProReportwork/manual_generation_reportwork
}
}

3
DOAN.Service/JobKanban/IService/IWorkorderProgressService.cs
View File

@ -21,8 +21,6 @@ namespace DOAN.Service.JobKanban.IService
List<ProWorkorder> GetWorkOrderList(string group_code, string line_code, DateTime handleDate);
List<ProWorkorder> GetWorkOrderStatusList(string group_code, int status, DateTime handleDate);
ProWorkorderDto4 GetWorkOrderDetail(string workorder);
@ -37,7 +35,6 @@ namespace DOAN.Service.JobKanban.IService
int ErrorProofingAndReportingWork(string workorder, string labelContext);
int NoErrorProofingAndReportingReport(string wokorder, int reportNum);
int FinishWorkorder(string workorder, int finish_num);

51
DOAN.Service/JobKanban/WorkorderProgressService.cs
View File

@ -34,13 +34,6 @@ public class WorkorderProgressService : BaseService<ProWorkorder>, IWorkorderPro
.ToList();
}
public List<ProWorkorder> GetWorkOrderStatusList(string group_code, int status, DateTime handleDate)
{
return Context.Queryable<ProWorkorder>().Where(it => it.GroupCode == group_code)
.Where(it => it.Status == status)
.Where(it => it.WorkorderDate == handleDate)
.ToList();
}
public List<ProReportwork> GetReportWorkRecord(string group_code, string line_code, DateTime handleDate)
{
@ -259,50 +252,6 @@ public class WorkorderProgressService : BaseService<ProWorkorder>, IWorkorderPro
}
public int NoErrorProofingAndReportingReport(string wokorder, int reportNum)
{
int result = 0;
var selected_workorder = Context.Queryable<ProWorkorder>().Where(it => it.Workorder == wokorder)
.First();
if (selected_workorder != null)
{
//修改
result = Context.Updateable<ProReportwork>().Where(it => it.FkWorkorder == wokorder)
.SetColumns(it => it.FinishedNum == reportNum)
.SetColumns(it => it.UpdatedTime == DateTime.Now)
.SetColumns(it => it.UpdatedBy == "PDA")
.ExecuteCommand();
}
else
{
//新增
var reportWork = new ProReportwork();
reportWork.Id = XueHua;
reportWork.FkWorkorder = wokorder;
reportWork.DispatchNum = selected_workorder.DeliveryNum;
reportWork.FinishedNum = reportNum;
reportWork.GroupCode = selected_workorder.GroupCode;
reportWork.LineCode = selected_workorder.LineCode;
reportWork.CreatedTime = DateTime.Now;
reportWork.CreatedBy = "kanban";
reportWork.UpdatedBy = "kanban";
reportWork.UpdatedTime = DateTime.Now;
result = Context.Insertable(reportWork).ExecuteCommand();
}
#region 线边库出库
linesideInventoryDeductions(wokorder, reportNum);
#endregion
return result;
}
public int FinishWorkorder(string workorder, int finish_num)
{
var result = 0;

5
DOAN.Service/MES/mm/IService/IMmLinesidebarInventoryCheckService.cs
View File

@ -9,6 +9,11 @@ namespace DOAN.Service.MES.mm.IService
public interface IMmLinesidebarInventoryCheckService : IBaseService<MmInventoryCheckLog>
{
PagedInfo<MmInventoryCheckLogDto> GetList(MmInventoryCheckLogQueryDto parm);
bool Correcting(string id);
int UpdateMmInventoryCheckLog(MmInventoryCheckLog model);
}
}

72
DOAN.Service/MES/mm/MmLinesidebarInventoryCheckServcie.cs
View File

@ -1,7 +1,4 @@
using DOAN.Repository;
using System.Linq;
using System.Runtime.InteropServices.JavaScript;
using DOAN.Model;
@ -17,7 +14,8 @@ namespace DOAN.Service.MES.mm
/// 线边库出入库日志Service业务层处理
/// </summary>
[AppService(ServiceType = typeof(IMmLinesidebarInventoryCheckService), ServiceLifetime = LifeTime.Transient)]
public class MmLinesidebarInventoryCheckServcie : BaseService<MmInventoryCheckLog>, IMmLinesidebarInventoryCheckService
public class MmLinesidebarInventoryCheckServcie : BaseService<MmInventoryCheckLog>,
IMmLinesidebarInventoryCheckService
{
/// <summary>
/// 查询线边库库存列表
@ -26,16 +24,17 @@ namespace DOAN.Service.MES.mm
/// <returns></returns>
public PagedInfo<MmInventoryCheckLogDto> GetList(MmInventoryCheckLogQueryDto parm)
{
DateTime SearchDate = DateTime.Today;
DateTime SearchDate = DateTime.Today;
// 1 查询这个日期 是否存在盘点记录 ，存在直接查询 ，不存在 ，先生成 再查询
bool isExist= Context.Queryable<MmInventoryCheckLog>().Where(it => it.CreatedTime>SearchDate&&it.CreatedTime<=SearchDate.AddDays(1)).Any();
if (!isExist)
{
List<MmInventoryCheckLog> newMmInventoryCheckLogList= Context.Queryable<MmLinesidebarInventory>().Where(it => it.CreatedTime >= SearchDate)
.Where(it => it.CreatedTime <= SearchDate.AddDays(1)).ToList()
.Adapt<List<MmInventoryCheckLog>>();
bool isExist = Context.Queryable<MmInventoryCheckLog>()
.Where(it => it.CreatedTime > SearchDate && it.CreatedTime <= SearchDate.AddDays(1)).Any();
if (!isExist)
{
List<MmInventoryCheckLog> newMmInventoryCheckLogList = Context.Queryable<MmLinesidebarInventory>()
.Where(it => it.CreatedTime >= SearchDate)
.Where(it => it.CreatedTime <= SearchDate.AddDays(1)).ToList()
.Adapt<List<MmInventoryCheckLog>>();
if (newMmInventoryCheckLogList.Count() > 0)
{
@ -44,21 +43,17 @@ namespace DOAN.Service.MES.mm
item.Id = XueHua;
item.CreatedTime = DateTime.Now;
item.IsCorrecting = 0;
}
}
Context.Insertable(newMmInventoryCheckLogList).ExecuteCommand();
}
}
var predicate = Expressionable.Create<MmInventoryCheckLog>()
.AndIF(!string.IsNullOrEmpty(parm.LineCode),it=>it.LineCode==parm.LineCode)
.AndIF(SearchDate>DateTime.MinValue,it=>it.CreatedTime>=SearchDate&&it.CreatedTime<=SearchDate)
.AndIF(!string.IsNullOrEmpty(parm.LineCode), it => it.LineCode == parm.LineCode)
.AndIF(SearchDate > DateTime.MinValue,
it => it.CreatedTime >= SearchDate && it.CreatedTime <= SearchDate.AddDays(1))
;
var response = Queryable()
@ -67,5 +62,40 @@ namespace DOAN.Service.MES.mm
return response;
}
/// <summary>
/// 校正
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public bool Correcting(string id)
{
bool result = false;
UseTran2(() =>
{
Context.Updateable<MmInventoryCheckLogDto>().Where(it => it.LineCode == id)
.SetColumns(it => it.IsCorrecting == 1)
.ExecuteCommand();
result = Context.Updateable<MmLinesidebarInventory>().Where(it =>
it.LineCode == SqlFunc.Subqueryable<MmInventoryCheckLogDto>().Where(it => it.Id == id)
.Select(it => it.LineCode))
.Where(it => it.MaterialCode == SqlFunc.Subqueryable<MmInventoryCheckLogDto>()
.Where(it => it.Id == id)
.Select(it => it.MaterialCode))
.SetColumns(it => it.LogicQuantity == SqlFunc.Subqueryable<MmInventoryCheckLogDto>()
.Where(it => it.Id == id).Select(it => it.ActualQuantity))
.ExecuteCommandHasChange();
});
return result;
}
public int UpdateMmInventoryCheckLog(MmInventoryCheckLog model)
{
return Update(model, true);
}
}
}

26
DOAN.Service/Mobile/IService/IPADReportWorkService.cs Normal file
View File

@ -0,0 +1,26 @@
using DOAN.Model;
using DOAN.Model.MES.base_;
using DOAN.Model.MES.product;
using DOAN.Model.MES.product.Dto;
namespace DOAN.Service.Mobile.IService;
public interface IPADReportWorkService
{
int NoErrorProofingAndReportingReport(string wokorder, int reportNum);
List<BaseWorkRoute> GetAllRoute();
List<BaseGroup> GetGroupList();
PagedInfo<ProReportworkDto> GetList(ProReportworkQueryDto parm);
ProWorkorderDto4 GetWorkOrderDetail(string workorder);
List<ProWorkorder> GetWorkOrderStatusList(string group_code, int status, DateTime handleDate);
int UpdateProReportwork(ProReportwork parm);
int StartWorkOrder(string workorder);
int FinishWorkOrder(string workorder);
}

344
DOAN.Service/Mobile/PADReportWorkService.cs Normal file
View File

@ -0,0 +1,344 @@
using DOAN.Model;
using DOAN.Model.MES.base_;
using DOAN.Model.MES.mm;
using DOAN.Model.MES.product;
using DOAN.Model.MES.product.Dto;
using DOAN.Repository;
using DOAN.Service.Mobile.IService;
using Infrastructure.Attribute;
namespace DOAN.Service.Mobile
{
[AppService(ServiceType = typeof(IPADReportWorkService), ServiceLifetime = LifeTime.Transient)]
public class PADReportWorkService : BaseService<ProReportwork>, IPADReportWorkService
{
/// <summary>
/// 不防错直接报工
/// </summary>
/// <param name="wokorder"></param>
/// <param name="reportNum"></param>
/// <returns></returns>
public int NoErrorProofingAndReportingReport(string wokorder, int reportNum)
{
int result = 0;
var selected_workorder = Context.Queryable<ProWorkorder>().Where(it => it.Workorder == wokorder)
.First();
if (selected_workorder != null)
{
//修改
result = Context.Updateable<ProReportwork>().Where(it => it.FkWorkorder == wokorder)
.SetColumns(it => it.FinishedNum == reportNum)
.SetColumns(it => it.UpdatedTime == DateTime.Now)
.SetColumns(it => it.UpdatedBy == "PDA")
.ExecuteCommand();
}
else
{
//新增
var reportWork = new ProReportwork();
reportWork.Id = XueHua;
reportWork.FkWorkorder = wokorder;
reportWork.DispatchNum = selected_workorder.DeliveryNum;
reportWork.FinishedNum = reportNum;
reportWork.GroupCode = selected_workorder.GroupCode;
reportWork.LineCode = selected_workorder.LineCode;
reportWork.CreatedTime = DateTime.Now;
reportWork.CreatedBy = "kanban";
reportWork.UpdatedBy = "kanban";
reportWork.UpdatedTime = DateTime.Now;
result = Context.Insertable(reportWork).ExecuteCommand();
}
#region 线边库出库
linesideInventoryDeductions(wokorder, reportNum);
#endregion
return result;
}
public List<BaseWorkRoute> GetAllRoute()
{
return Context.Queryable<BaseWorkRoute>().ToList();
}
public List<BaseGroup> GetGroupList()
{
return Context.Queryable<BaseGroup>().Where(it => it.Status == 1).ToList();
}
/// <summary>
/// 查询报工表列表
/// </summary>
/// <param name="parm"></param>
/// <returns></returns>
public PagedInfo<ProReportworkDto> GetList(ProReportworkQueryDto parm)
{
if (parm.TimeRange != null && parm.TimeRange.Length == 2)
{
parm.TimeRange[0] = parm.TimeRange[0].Date;
// parm.TimeRange[1] = parm.TimeRange[1].Date.AddDays(1);
parm.TimeRange[1] = parm.TimeRange[1].Date;
}
var predicate = Expressionable.Create<ProWorkorder, ProReportwork>()
.AndIF(!string.IsNullOrEmpty(parm.FkWorkorder), (w, r) => w.Workorder.Contains(parm.FkWorkorder))
.AndIF(!string.IsNullOrEmpty(parm.GroupCode), (w, r) => w.GroupCode == parm.GroupCode)
.AndIF(!string.IsNullOrEmpty(parm.LineCode), (w, r) => w.LineCode == parm.LineCode)
.AndIF(parm.WarehouseconfirmationNum > 0, (w, r) => r.QualifiedNumber > 0)
.AndIF(
parm.TimeRange != null && parm.TimeRange.Length == 2 && parm.TimeRange[0] > DateTime.MinValue,
(w, r) => w.WorkorderDate >= parm.TimeRange[0])
.AndIF(
parm.TimeRange != null && parm.TimeRange.Length == 2 && parm.TimeRange[1] > DateTime.MinValue,
(w, r) => w.WorkorderDate <= parm.TimeRange[1])
.AndIF(parm.Status > 0, (w, r) => w.Status == parm.Status)
;
var response = Context.Queryable<ProWorkorder>()
.LeftJoin<ProReportwork>((w, r) => w.Workorder == r.FkWorkorder)
.Where(predicate.ToExpression())
.Select((w, r) => new ProReportworkDto
{
Id = r.Id,
ProductionCode = w.ProductionCode,
ProductionName = w.ProductionName,
Specification = w.Specification,
QualifiedNumber = r.QualifiedNumber,
UnqualifiedNumber = r.UnqualifiedNumber,
ReworkNumber = r.ReworkNumber,
ScrapNumber = r.ScrapNumber,
Remark = r.Remark,
Difference = r.QualifiedNumber - r.FinishedNum ?? 0,
FkWorkorder = w.Workorder,
GroupCode = w.GroupCode,
LineCode = w.LineCode,
DispatchNum = w.DeliveryNum ?? 0,
Priority = w.Priority,
Status = w.Status,
Beat = w.Beat
}, true).ToPage_NO_Convert<ProReportworkDto>(parm);
return response;
}
public ProWorkorderDto4 GetWorkOrderDetail(string workorder)
{
var query = Context.Queryable<ProWorkorder>()
.Where(it => it.Workorder == workorder);
return Context.Queryable(query)
.LeftJoin<ProReportwork>((q, r) => q.Workorder == r.FkWorkorder)
.Select((q, r) => new ProWorkorderDto4
{
FinishNum = r.FinishedNum
}, true).First();
}
public List<ProWorkorder> GetWorkOrderStatusList(string group_code, int status, DateTime handleDate)
{
return Context.Queryable<ProWorkorder>().Where(it => it.GroupCode == group_code)
.Where(it => it.Status == status)
.Where(it => it.WorkorderDate == handleDate)
.ToList();
}
/// <summary>
/// 修改报工表
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public int UpdateProReportwork(ProReportwork model)
{
// 更新线边库
if (model.FinishedNum != null&&string.IsNullOrEmpty(model.FkWorkorder))
{
linesideInventoryRecovery(model.FkWorkorder, model.CreatedBy);
linesideInventoryDeductions(model.FkWorkorder, model.FinishedNum??0);
}
//var response = Update(w => w.Id == model.Id, it => new ProReportwork()
//{
// FkWorkorder = model.FkWorkorder,
// DispatchNum = model.DispatchNum,
// FinishedNum = model.FinishedNum,
// GroupCode = model.GroupCode,
// LineCode = model.LineCode,
// CreatedBy = model.CreatedBy,
// CreatedTime = model.CreatedTime,
// UpdatedBy = model.UpdatedBy,
// UpdatedTime = model.UpdatedTime,
//});
//return response;
return Update(model, true);
}
public int StartWorkOrder(string workorder)
{
var result = 0;
// 获取同一天 同一组 同一线 的所有工单 把状态2 设为init 1
var handleWorkorder =
Context.Queryable<ProWorkorder>().Where(it => it.Workorder == workorder).First();
UseTran2(() =>
{
Context.Updateable<ProWorkorder>().SetColumns(it => it.Status == 1)
.Where(it => it.Status == 2)
.Where(it => it.WorkorderDate == handleWorkorder.WorkorderDate)
.Where(it => it.GroupCode == handleWorkorder.GroupCode)
.Where(it => it.LineCode == handleWorkorder.LineCode)
.ExecuteCommand();
result = Context.Updateable<ProWorkorder>().SetColumns(it => it.Status == 2)
.SetColumns(it => it.StartTime == DateTime.Now)
.Where(it => it.Workorder == workorder).ExecuteCommand();
});
return result;
}
public int FinishWorkOrder(string workorder)
{
return Context.Updateable<ProWorkorder>()
.SetColumns(it => it.Status == 3)
.SetColumns(it => it.EndTime == DateTime.Now)
.Where(it => it.Workorder == workorder).ExecuteCommand();
}
/// <summary>
/// 线边库 库存扣除
/// </summary>
/// <param name="workorder"></param>
private void linesideInventoryDeductions(string workorder, int reportNum)
{
var selected_workorder = Context.Queryable<ProWorkorder>().Where(it => it.Workorder == workorder).First();
if (selected_workorder == null)
{
return;
}
//TODO 获取实际报工数量 作为线边库库存 出库
// 查询这个工单的BOM
List<BaseMaterialBom> SubMaterialList = Context.Queryable<BaseMaterialBom>()
.Where(it => it.InvCode == selected_workorder.ProductionCode)
.ToList();
if (SubMaterialList.Count > 0)
{
List<MmLinesidebarInventoryOutboundAndInbound> InsertedSubMaterialOutboundAndInboundList =
new List<MmLinesidebarInventoryOutboundAndInbound>();
List<MmLinesidebarInventory> needReduceLinesidebarInventories = new List<MmLinesidebarInventory>();
// 添加出库记录
// 扣除库存记录
string[] SubMaterialArray = SubMaterialList.Select(it => it.InvCode).ToArray();
//线边库存
List<MmLinesidebarInventory> SideInventoryList = Context.Queryable<MmLinesidebarInventory>()
.Where(it => it.LineCode == selected_workorder.LineCode)
.Where(it => SubMaterialArray.Contains(it.MaterialCode)).ToList();
foreach (var subMaterial in SubMaterialList)
{
//物料在线边库存
if (SideInventoryList.Where(it => it.MaterialCode == subMaterial.SubInvCode).Any())
{
// 记录需要扣除的线边库存
MmLinesidebarInventory sideInventory = new MmLinesidebarInventory();
sideInventory.LineCode = selected_workorder.LineCode;
sideInventory.MaterialCode = subMaterial.SubInvCode;
var seleced = SideInventoryList.Where(it => it.MaterialCode == subMaterial.SubInvCode).First();
sideInventory.LogicQuantity =
seleced.LogicQuantity -
reportNum * Convert.ToDecimal(subMaterial.Iusequantity); //库存------需要扣减的数量
needReduceLinesidebarInventories.Add(sideInventory);
MmLinesidebarInventoryOutboundAndInbound outbound =
new MmLinesidebarInventoryOutboundAndInbound();
outbound.Id = XueHua;
outbound.LineCode = selected_workorder.LineCode;
outbound.MaterialCode = subMaterial.SubInvCode;
outbound.MaterialName = subMaterial.SubInvName;
outbound.Action = 1;
outbound.Quantity = reportNum * Convert.ToDecimal(subMaterial.Iusequantity);
outbound.Remark = $"(正常)触摸屏报工，工单号为{workorder}";
outbound.CreatedBy = "kanban";
outbound.CreatedTime = DateTime.Now;
InsertedSubMaterialOutboundAndInboundList.Add(outbound);
}
else
{
MmLinesidebarInventoryOutboundAndInbound outbound =
new MmLinesidebarInventoryOutboundAndInbound();
outbound.Id = XueHua;
outbound.LineCode = selected_workorder.LineCode;
outbound.MaterialCode = subMaterial.SubInvCode;
outbound.MaterialName = subMaterial.SubInvName;
outbound.Action = 1;
outbound.Quantity = reportNum * Convert.ToDecimal(subMaterial.Iusequantity);
outbound.Remark = $"(异常)触摸屏报工，工单号为{workorder}，物料不在这个线边库";
outbound.CreatedBy = "kanban";
outbound.CreatedTime = DateTime.Now;
InsertedSubMaterialOutboundAndInboundList.Add(outbound);
}
}
UseTran2(() =>
{
Context.Updateable(needReduceLinesidebarInventories).UpdateColumns(it => new { it.LogicQuantity })
.WhereColumns(it => new { it.LineCode, it.MaterialCode }).ExecuteCommand();
Context.Insertable(InsertedSubMaterialOutboundAndInboundList).ExecuteCommand();
});
}
}
/// <summary>
/// 取消出库
/// </summary>
/// <param name="workorder"></param>
/// <param name="CreatedBy"></param>
private void linesideInventoryRecovery(string workorder, string CreatedBy)
{
// 取消报工 出库
var cancal = Context.Queryable<MmLinesidebarInventoryOutboundAndInbound>()
.Where(it => it.WorkOrder == workorder).OrderByDescending(it => it.CreatedTime).First();
// 取消 报工库存日志
MmLinesidebarInventoryOutboundAndInbound log = new MmLinesidebarInventoryOutboundAndInbound();
log.Id = XueHua;
log.LineCode = cancal.LineCode;
log.MaterialCode = cancal.MaterialCode;
log.MaterialName = cancal.MaterialName;
log.Action = 2;
log.Quantity = cancal.Quantity;
log.Remark = $"取消这个工单{cancal.WorkOrder}的报工消耗，恢复库存;{cancal.Remark}";
log.CreatedBy = CreatedBy;
log.CreatedTime = DateTime.Now;
UseTran2(() =>
{
// 增加库存
Context.Updateable<MmLinesidebarInventory>()
.Where(it => it.LineCode == cancal.LineCode)
.Where(it => it.MaterialCode == cancal.MaterialCode)
.SetColumns(it => it.LogicQuantity == it.LogicQuantity + cancal.Quantity);
Context.Insertable(log).ExecuteCommand();
});
}
}
}