diff --git a/ProductionMgr/Tnb.ProductionMgr.Entities/Dto/PrdManage/DeletePrdMoInput.cs b/ProductionMgr/Tnb.ProductionMgr.Entities/Dto/PrdManage/DeletePrdMoInput.cs new file mode 100644 index 00000000..ab9105ce --- /dev/null +++ b/ProductionMgr/Tnb.ProductionMgr.Entities/Dto/PrdManage/DeletePrdMoInput.cs @@ -0,0 +1,20 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace Tnb.ProductionMgr.Entities.Dto.PrdManage +{ + public class DeletePrdMoInput + { + /// + /// 工单代码 + /// + public string mo_code { get; set; } + /// + /// 行号 + /// + public string erp_lineno { get; set; } + } +} diff --git a/ProductionMgr/Tnb.ProductionMgr/MesForErpService.cs b/ProductionMgr/Tnb.ProductionMgr/MesForErpService.cs index 6eaf7475..b691c989 100644 --- a/ProductionMgr/Tnb.ProductionMgr/MesForErpService.cs +++ b/ProductionMgr/Tnb.ProductionMgr/MesForErpService.cs @@ -17,6 +17,7 @@ using SqlSugar; using Tnb.BasicData; using Tnb.BasicData.Entities; using Tnb.ProductionMgr.Entities; +using Tnb.ProductionMgr.Entities.Dto.PrdManage; using Tnb.ProductionMgr.Entities.Entity; using Tnb.WarehouseMgr.Entities.Consts; @@ -189,5 +190,210 @@ namespace Tnb.ProductionMgr return !result.IsSuccess ? result.ErrorMessage : "保存成功"; } + + + /// + /// 删除生产订单 + /// + /// + /// + [HttpPost] + [AllowAnonymous] + public async Task DelPrdMo(DeletePrdMoInput input) + { + Log.Information($"删除生产订单接收参数:{JsonConvert.SerializeObject(input)}"); + try + { + if (string.IsNullOrEmpty(input.mo_code)) + throw Oops.Bah("工单代码不能为空"); + if (string.IsNullOrEmpty(input.erp_lineno)) + throw Oops.Bah("行号不能为空"); + var mo_code= input.mo_code + "-" + input.erp_lineno; + await _db.Ado.BeginTranAsync(); + + PrdMo existMo = await _db.Queryable().Where(x => x.mo_code == mo_code).FirstAsync(); + if (existMo != null) + { + if (existMo.mo_status != DictConst.ToBeScheduledId) + { + throw Oops.Bah($"【DelPrdMo】生产工单{input.mo_code}状态不是待下发无法删除"); + } + + await _db.Deleteable().Where(r => r.id == existMo.id).ExecuteCommandAsync(); + } + else + { + throw Oops.Bah($"【DelPrdMo】生产工单{input.mo_code}数据不存在"); + } + + await _db.Ado.CommitTranAsync(); + } + catch (Exception e) + { + await _db.Ado.RollbackTranAsync(); + throw Oops.Bah($"{e.Message}"); + } + return "删除成功"; + } + + /// + /// 修改生产订单 + /// + /// + /// + [HttpPost] + [AllowAnonymous] + public async Task ModifyPrdMo(PrdMo input) + { + Log.Information($"删除生产订单接收参数:{JsonConvert.SerializeObject(input)}"); + try + { + if (string.IsNullOrEmpty(input.mo_code)) + { + Log.Error("【ModifyPrdMo】工单代码不能为空"); + throw Oops.Bah("工单代码不能为空"); + } + + if (string.IsNullOrEmpty(input.mo_type)) + { + Log.Error("【ModifyPrdMo】工单类型不能为空"); + throw Oops.Bah("工单类型不能为空"); + } + + if (input.plan_start_date == null) + { + Log.Error("【ModifyPrdMo】计划开始日期不能为空"); + throw Oops.Bah("计划开始日期不能为空"); + } + + if (input.plan_end_date == null) + { + Log.Error("【ModifyPrdMo】计划结束日期不能为空"); + throw Oops.Bah("计划结束日期不能为空"); + } + + if (string.IsNullOrEmpty(input.material_code)) + { + Log.Error("【ModifyPrdMo】物料编号不能为空"); + throw Oops.Bah("物料编号不能为空"); + } + + if (string.IsNullOrEmpty(input.unit_id)) + { + Log.Error("【ModifyPrdMo】单位不能为空"); + throw Oops.Bah("单位不能为空"); + } + + if (input.plan_qty == null || input.plan_qty <= 0) + { + Log.Error("【ModifyPrdMo】计划数量不能为空"); + throw Oops.Bah("计划数量不能为空"); + } + + if (string.IsNullOrEmpty(input.dept_id)) + { + Log.Error("【ModifyPrdMo】生产部门id不能为空"); + throw Oops.Bah("生产部门id不能为空"); + } + + if (input.ebom_version == null || input.ebom_version.IsEmpty()) + { + Log.Error("【ModifyPrdMo】物料清单版本不能为空"); + throw Oops.Bah("物料清单版本不能为空"); + } + + BasMaterial basMaterial = await _db.Queryable().SingleAsync(x => x.code == input.material_code); + if (basMaterial == null) + { + Log.Error($"【ModifyPrdMo】未找到物料编号为{input.material_code}的物料"); + throw Oops.Bah($"未找到物料编号为{input.material_code}的物料"); + } + + List basMaterialUnits = await _db.Queryable().Where(x => x.material_id == basMaterial.id).ToListAsync(); + List units = basMaterialUnits.Select(x => x.auxiliary_unit_id).Distinct().ToList(); + if (units != null && !string.IsNullOrEmpty(basMaterial.unit_id)) units.Add(basMaterial.unit_id); + + if (!units.Contains(input.unit_id)) + { + Log.Error($"【ModifyPrdMo】{basMaterial.name}不存在{input.unit_id}该单位"); + throw Oops.Bah($"{basMaterial.name}不存在{input.unit_id}该单位"); + } + + if (!await _db.Queryable().AnyAsync(x => x.material_id == basMaterial.id && x.version == input.ebom_version)) + { + Log.Error($"【ModifyPrdMo】系统中无法找到物料清单{input.ebom_version}版本"); + throw Oops.Bah($"系统中无法找到物料清单{input.ebom_version}版本"); + } + + DictionaryDataEntity unitDic = await _db.Queryable().Where(x => x.DictionaryTypeId == WmsWareHouseConst.UNITTYPEID && x.EnCode == input.unit_id).FirstAsync(); + + string mocode = input.mo_code + "-" + input.erp_lineno; + PrdMo existMo = await _db.Queryable().Where(x => x.mo_code == mocode).FirstAsync(); + if (existMo == null) + throw Oops.Bah($"【ModifyPrdMo】生产工单{mocode}数据不存在"); + if (existMo.mo_status != DictConst.ToBeScheduledId) + { + Log.Error($"【ModifyPrdMo】生产工单{mocode}状态不是待下发,无法修改"); + throw Oops.Bah($"【ModifyPrdMo】生产工单{mocode}状态不是待下发,无法修改"); + } + var unit_id= unitDic?.EnCode ?? input.unit_id; + + existMo.org_id=input.org_id; + existMo.material_code=input.material_code; + existMo.mo_type = moTypeDic[input.mo_type]; + existMo.mo_status = DictConst.ToBeScheduledId; + existMo.plan_qty=input.plan_qty; + existMo.input_qty=input.input_qty; + existMo.complete_qty=input.complete_qty; + existMo.reported_work_qty=input.reported_work_qty; + existMo.scrap_qty=input.scrap_qty; + existMo.plan_start_date=input.plan_start_date; + existMo.plan_end_date=input.plan_end_date; + existMo.act_start_date = input.act_start_date; + existMo.act_end_date = input.act_end_date; + existMo.dept_id=input.dept_id; + existMo.customer_code=input.customer_code; + existMo.order_no=input.order_no; + existMo.order_seq=input.order_seq; + existMo.bom_version=input.bom_version; + existMo.ebom_version=input.ebom_version; + existMo.relation_ratio=input.relation_ratio; + existMo.mo_down_user_id=input.mo_down_user_id; + existMo.mo_down_user_name=input.mo_down_user_name; + existMo.mo_down_date=input.mo_down_date; + existMo.remark=input.remark; + existMo.work_center_code=input.work_center_code; + existMo.parent_mo_code=input.parent_mo_code; + existMo.seduling_start_date=input.seduling_start_date; + existMo.seduling_end_date=input.seduling_end_date; + existMo.is_create_dispatch=input.is_create_dispatch; + existMo.seq=input.seq; + existMo.data_sources=input.data_sources; + existMo.production_linecode=input.production_linecode; + existMo.is_merge=input.is_merge; + existMo.combine_mo_code=existMo.combine_mo_code; + existMo.time_stamp=input.time_stamp; + existMo.extras=input.extras; + existMo.material_id = basMaterial.id; + existMo.scheduled_qty=input.scheduled_qty; + existMo.parent_id=input.parent_id; + existMo.unit_id = unit_id; + existMo.mo_source = "1"; + existMo.erp_lineno=input.erp_lineno; + existMo.erp_line_pk=input.erp_line_pk; + existMo.erp_mo_pk=input.erp_mo_pk; + existMo.mo_category=input.mo_category; + + await _db.Updateable(existMo).ExecuteCommandAsync(); + + await _db.Ado.CommitTranAsync(); + } + catch (Exception e) + { + await _db.Ado.RollbackTranAsync(); + throw Oops.Bah($"修改失败:{e.Message}"); + } + return "修改成功"; + } } } \ No newline at end of file diff --git a/WarehouseMgr/Tnb.WarehouseMgr.Entities/Dto/ErpInputs/TransferOrderInput.cs b/WarehouseMgr/Tnb.WarehouseMgr.Entities/Dto/ErpInputs/TransferOrderInput.cs index bb2e2269..fe178c4e 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr.Entities/Dto/ErpInputs/TransferOrderInput.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr.Entities/Dto/ErpInputs/TransferOrderInput.cs @@ -100,4 +100,12 @@ namespace Tnb.WarehouseMgr.Entities.Dto.ErpInputs public string? warehouse_instock_id { get; set; } } + + public class TransferOrderDelInput + { + /// + /// 主表主键 + /// + public string erp_pk { get; set; } + } } diff --git a/WarehouseMgr/Tnb.WarehouseMgr.Entities/Entity/WmsCarryStockReportH.cs b/WarehouseMgr/Tnb.WarehouseMgr.Entities/Entity/WmsCarryStockReportH.cs index f938dab5..433bdbbf 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr.Entities/Entity/WmsCarryStockReportH.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr.Entities/Entity/WmsCarryStockReportH.cs @@ -1,5 +1,6 @@ using JNPF.Common.Contracts; using JNPF.Common.Security; +using NPOI.OpenXmlFormats.Dml; using SqlSugar; namespace Tnb.WarehouseMgr.Entities; @@ -412,7 +413,14 @@ public partial class WmsCarryStockReportExcel /// 绑定时间 /// public string? bind_time { get; set; } - + /// + /// 物料规格 + /// + public string? material_specification { get; set; } + /// + /// 物料型号 + /// + public string? container_no { get;set; } } diff --git a/WarehouseMgr/Tnb.WarehouseMgr/ErpToWmsService.cs b/WarehouseMgr/Tnb.WarehouseMgr/ErpToWmsService.cs index be37cc48..39c71d9d 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/ErpToWmsService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/ErpToWmsService.cs @@ -2461,6 +2461,53 @@ namespace Tnb.WarehouseMgr } } + /// + /// 删除调拨订单 + /// + /// + /// + /// + [HttpPost, NonUnify, AllowAnonymous] + public async Task DelTransferOrder(TransferOrderDelInput input) + { + LoggerErp2Mes.LogInformation($"【TransferOrderDelInput】ERP传入数据:{JsonConvert.SerializeObject(input)}"); + var db = _repository.AsSugarClient(); + + try + { + if (string.IsNullOrEmpty(input.erp_pk)) + { + _LoggerErp2Mes.LogWarning($"【TransferOrderDelInput】主表主键不能为空!"); + throw new AppFriendlyException($@"主表主键不能为空!", 500); + } + + await db.Ado.BeginTranAsync(); + + // 判断调拨订单主表是否存在 + WmsTransferOrderH wmsTransferOrderH = await db.Queryable().Where(r => r.erp_pk == input.erp_pk).FirstAsync(); + if (wmsTransferOrderH != null) + { + await db.Deleteable().Where(r => r.id == wmsTransferOrderH.id).ExecuteCommandAsync(); + await db.Deleteable().Where(r => r.bill_id == wmsTransferOrderH.id).ExecuteCommandAsync(); + } + await db.Ado.CommitTranAsync(); + + return await ToApiResult(HttpStatusCode.OK, "成功"); + } + catch (Exception ex) + { + LoggerErp2Mes.LogError($"【TransferOrderDelInput】{ex.Message}"); + LoggerErp2Mes.LogError($"【TransferOrderDelInput】{ex.StackTrace}"); + await db.Ado.RollbackTranAsync(); + return await ToApiResult(HttpStatusCode.InternalServerError, ex.Message); + } + finally + { + + } + } + + /// /// 材料出库单 /// diff --git a/WarehouseMgr/Tnb.WarehouseMgr/WareHouseService.cs b/WarehouseMgr/Tnb.WarehouseMgr/WareHouseService.cs index ce716f49..ccdbdb3a 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/WareHouseService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/WareHouseService.cs @@ -3372,6 +3372,7 @@ namespace Tnb.WarehouseMgr ["cvendorvid"] = erpExtendFields.Find(x => x.table_id == wmsCarryCode?.auxprop_gys)?.supplier_vid ?? "", ["dbizdate"] = nowStr, ["nnum"] = item.qty, + ["nshouldnum"]=item.qty,//应发主数量 ["pk_group"] = erpOrg.pk_group, ["pk_org"] = erpOrg.pk_org, ["pk_org_v"] = erpOrg.pk_org_v, diff --git a/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryBindService.cs b/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryBindService.cs index 5bd924fa..7cb731e4 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryBindService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryBindService.cs @@ -290,6 +290,8 @@ namespace Tnb.WarehouseMgr WmsCarryCode.codeqty = detail.codeqty; WmsCarryCode.create_id = input.create_id; WmsCarryCode.create_time = DateTime.Now; + WmsCarryCode.auxprop_gys = auxprop_gys; + WmsCarryCode.auxprop_xph=auxprop_xph; WmsCarryCodes.Add(WmsCarryCode); WmsTempCode wmsTempCode = wmsTempCodes.Where(r => r.barcode == detail.barcode).First(); diff --git a/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryStockReportService.cs b/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryStockReportService.cs index 68dd19b3..3677c68c 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryStockReportService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryStockReportService.cs @@ -272,7 +272,9 @@ namespace Tnb.WarehouseMgr material_name = f.name, unit = e.unit_id, creator = e.create_id, - bind_time = e.create_time != null ? e.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss") : "" + bind_time = e.create_time != null ? e.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss") : "", + material_specification= f.material_specification, + container_no= f.material_standard, }) .OrderBy((a) => a.location_code) .ToListAsync(); @@ -314,7 +316,9 @@ namespace Tnb.WarehouseMgr material_name = g.name, unit = f.unit_id, creator = f.create_id, - bind_time = f.create_time != null ? f.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss") : "" + bind_time = f.create_time != null ? f.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss") : "", + material_specification=g.material_specification, + container_no=g.material_standard }) .OrderBy((a) => a.location_code) .ToListAsync(); @@ -345,6 +349,8 @@ namespace Tnb.WarehouseMgr wmsCarryStockReportCode.unit = x.unit; //wmsCarryStockReportCode.创建用户 = x.操作用户; wmsCarryStockReportCode.bind_time = x.bind_time; + wmsCarryStockReportCode.material_specification= x.material_specification; + wmsCarryStockReportCode.container_no = x.container_no; wmsCarryStockReportExcels.Add(wmsCarryStockReportCode); }); diff --git a/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialSignHService.cs b/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialSignHService.cs index eacc7c05..c1f2eaeb 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialSignHService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialSignHService.cs @@ -643,6 +643,7 @@ namespace Tnb.WarehouseMgr ["cvendorvid"] = erpExtendFields.Find(x => x.table_id == wmsCarryCodes[0]?.auxprop_gys)?.supplier_vid ?? "", ["dbizdate"] = nowStr, ["nnum"] = wmsMaterialTransferd.qty, + ["nshouldnum"] = wmsMaterialTransferd.qty,//应发主数量 ["pk_group"] = erpOrg.pk_group, ["pk_org"] = erpOrg.pk_org, ["pk_org_v"] = erpOrg.pk_org_v, diff --git a/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialTransferService.cs b/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialTransferService.cs index 63e6b47e..6e259c39 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialTransferService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/WmsMaterialTransferService.cs @@ -1378,6 +1378,7 @@ namespace Tnb.WarehouseMgr ["cvendorvid"] = erpExtendFields.Find(x => x.table_id == wmsCarryCodes[0]?.auxprop_gys)?.supplier_vid ?? "", ["dbizdate"] = nowStr, ["nnum"] = qty, + ["nshouldnum"] = wmsMaterialTransferd.qty,//应发主数量 ["pk_group"] = erpOrg.pk_group, ["pk_org"] = erpOrg.pk_org, ["pk_org_v"] = erpOrg.pk_org_v,