| | |
| | | //else |
| | | //{ |
| | | //判断冲销凭证编号 是否为空 如果为空 则为冲销(审核前才能冲销,非待执行状态提示执行中不可冲销) 不为空 则为外采入库 |
| | | |
| | | if ((items.ITEM.Where(s => s.CXPZH != null && s.CXPZH != "").Count() > 0)) |
| | | if (items.HEAD.YDLX != "124") |
| | | { |
| | | //判断冲销物料是否为同一个入库单 |
| | | if (items.ITEM.Select(s => s.CXPZH).Distinct().Count() > 1) |
| | | if ((items.ITEM.Where(s => s.CXPZH != null && s.CXPZH != "").Count() > 0)) |
| | | { |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 1; |
| | | result.resultMsg = "冲销物料不属于同一订单"; |
| | | result.resultMsg = "失败"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | //冲销凭证单号 |
| | | var cxpzbh = items.ITEM[0].CXPZH; |
| | | var po = WMSHelper.GetInboundOrder(cxpzbh); |
| | | //判断是否执行 执行中订单允许冲销 |
| | | if (po == null) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 1; |
| | | result.resultMsg = "未找到此订单"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | if (po.N_B_STATE != 0 && po.N_B_STATE != 7) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.resultCode = 1; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = "执行中订单不允许操作"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | foreach (var item in items.ITEM) |
| | | { |
| | | ///判断是否都有冲销凭证编号 |
| | | if (string.IsNullOrEmpty(item.CXPZH)) |
| | | //判断冲销物料是否为同一个入库单 |
| | | if (items.ITEM.Select(s => s.CXPZH).Distinct().Count() > 1) |
| | | { |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 1; |
| | | result.resultMsg = "冲销物料不属于同一订单"; |
| | | result.resultMsg = "失败"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | //冲销凭证单号 |
| | | var cxpzbh = items.ITEM[0].CXPZH; |
| | | var po = WMSHelper.GetInboundOrder(cxpzbh); |
| | | //判断是否执行 执行中订单允许冲销 |
| | | if (po == null) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 1; |
| | | result.resultMsg = "未找到此订单"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | if (po.N_B_STATE != 0 && po.N_B_STATE != 7) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.resultCode = 1; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = "冲销单有物料冲销编号为空"; |
| | | result.resultMsg = "执行中订单不允许操作"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | var rkdmx = po.Details.Where(s => s.S_ITEM_CODE == item.WLBM).ToList(); |
| | | if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//数量大于明细 |
| | | foreach (var item in items.ITEM) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = $"冲销物料{item.WLBM}数量{item.SL}大于存入数量"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//数量==明细 删除当下入库单物料数据 |
| | | { |
| | | db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//数量小于明细 |
| | | { |
| | | //当前物料明细 |
| | | var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); |
| | | rkd.F_QTY = rkd.F_QTY - item.SL; |
| | | db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); |
| | | int ssss = po1.Details.Count(); |
| | | if (po1.Details.Count() == 0) |
| | | { |
| | | po1.N_B_STATE = 7; |
| | | db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); |
| | | } |
| | | } |
| | | db.CommitTran(); |
| | | } |
| | | else if ( items.HEAD.YDLX == "124") |
| | | { |
| | | |
| | | //冲销凭证单号 |
| | | var cxpzbh = items.HEAD.WLPZH; |
| | | var po = WMSHelper.GetInboundOrder(cxpzbh); |
| | | //判断是否执行 执行中订单允许冲销 |
| | | if (po == null) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 1; |
| | | result.resultMsg = "未找到此订单"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | if (po.N_B_STATE != 0 && po.N_B_STATE != 7) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.resultCode = 1; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = "执行中订单不允许操作"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | foreach (var item in items.ITEM) |
| | | { |
| | | var rkdmx = po.Details.Where(s => s.S_ITEM_CODE == item.WLBM).ToList(); |
| | | if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//数量大于明细 |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = $"退货物料{item.WLBM}数量{item.SL}大于存入数量"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//数量==明细 删除当下入库单物料数据 |
| | | { |
| | | db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//数量小于明细 |
| | | { |
| | | //当前物料明细 |
| | | var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); |
| | | rkd.F_QTY = rkd.F_QTY - item.SL; |
| | | db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); |
| | | int ssss = po1.Details.Count(); |
| | | if (po1.Details.Count() == 0) |
| | | { |
| | | po1.N_B_STATE = 7; |
| | | db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); |
| | | } |
| | | } |
| | | db.CommitTran(); |
| | | } |
| | | else |
| | | { |
| | | //创建入库单主子表 |
| | | var po = WMSHelper.GetInboundOrder(items.HEAD.WLPZH); |
| | | if (po == null) |
| | | { |
| | | po = new TN_Inbound_Order { S_NO = items.HEAD.WLPZH, S_WLPZND = items.HEAD.WLPZND, S_FACTORY = items.HEAD.GC, S_IN_TYPE = "外采入库", S_BS_TYPE = items.HEAD.YDLX }; |
| | | po.Details = new List<TN_Inbound_Detail>(); |
| | | if (items.ITEM.Count > 0) |
| | | { |
| | | items.ITEM.ForEach(a => |
| | | ///判断是否都有冲销凭证编号 |
| | | if (string.IsNullOrEmpty(item.CXPZH)) |
| | | { |
| | | po.Details.Add(new TN_Inbound_Detail |
| | | { |
| | | S_IO_NO = items.HEAD.WLPZH, |
| | | N_ROW_NO = a.WLPZHXM, |
| | | S_ITEM_CODE = a.WLBM, |
| | | F_QTY = a.SL, |
| | | S_ITEM_STATE = "物料", |
| | | S_ITEM_NAME = "物料", |
| | | F_ACC_B_QTY = 0, |
| | | S_KCDD = a.KCDD, |
| | | S_UOM = a.DW,//计量单位 |
| | | //S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), |
| | | S_BATCH_NO = a.PC == null ? "" : a.PC, |
| | | S_CGPZH = a.CGPZH, |
| | | S_CGPZXMBH = a.CGPZXMBH, |
| | | S_CKPZKJND = a.CKPZKJND, |
| | | S_CKPZXM = a.CKPZHXM, |
| | | S_CXWLPZBH = a.CKPZH, |
| | | S_HWSJJYZT = a.HWSJJYZT, |
| | | S_GYSZHH = a.GYSZHH, |
| | | S_JYPBH = a.JYPBH, |
| | | S_KJPZSSRQ = a.KJPZSSRQ, |
| | | S_KJPZSRSJ = a.KJPZSRSJ, |
| | | }); |
| | | //} |
| | | |
| | | }); |
| | | db.Insertable<TN_Inbound_Order>(po).ExecuteCommand(); |
| | | db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand(); |
| | | db.CommitTran(); |
| | | |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.resultCode = 1; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = "冲销单有物料冲销编号为空"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | var rkdmx = po.Details.Where(s => s.S_ITEM_CODE == item.WLBM).ToList(); |
| | | if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//数量大于明细 |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = $"冲销物料{item.WLBM}数量{item.SL}大于存入数量"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//数量==明细 删除当下入库单物料数据 |
| | | { |
| | | db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//数量小于明细 |
| | | { |
| | | //当前物料明细 |
| | | var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); |
| | | rkd.F_QTY = rkd.F_QTY - item.SL; |
| | | db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); |
| | | int ssss = po1.Details.Count(); |
| | | if (po1.Details.Count() == 0) |
| | | { |
| | | po1.N_B_STATE = 7; |
| | | db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); |
| | | } |
| | | } |
| | | } |
| | | |
| | | else |
| | | { |
| | | var Details = new List<TN_Inbound_Detail>(); |
| | | if (items.ITEM.Count > 0) |
| | | //创建入库单主子表 |
| | | var po = WMSHelper.GetInboundOrder(items.HEAD.WLPZH); |
| | | if (po == null) |
| | | { |
| | | items.ITEM.ForEach(a => |
| | | po = new TN_Inbound_Order { S_NO = items.HEAD.WLPZH, S_WLPZND = items.HEAD.WLPZND, S_FACTORY = items.HEAD.GC, S_IN_TYPE = "外采入库", S_BS_TYPE = items.HEAD.YDLX }; |
| | | po.Details = new List<TN_Inbound_Detail>(); |
| | | if (items.ITEM.Count > 0) |
| | | { |
| | | if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).Count() > 0) |
| | | items.ITEM.ForEach(a => |
| | | { |
| | | var poq = po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).FirstOrDefault(); |
| | | poq.F_QTY = a.SL; |
| | | |
| | | db.Updateable(poq).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | else |
| | | { |
| | | Details.Add(new TN_Inbound_Detail |
| | | po.Details.Add(new TN_Inbound_Detail |
| | | { |
| | | S_IO_NO = items.HEAD.WLPZH, |
| | | N_ROW_NO = a.WLPZHXM, |
| | |
| | | F_ACC_B_QTY = 0, |
| | | S_KCDD = a.KCDD, |
| | | S_UOM = a.DW,//计量单位 |
| | | //S_UOM = a.JBJLDW,//计量单位 |
| | | //S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), |
| | | S_BATCH_NO = a.PC == null ? "" : a.PC, |
| | | S_CGPZH = a.CGPZH, |
| | |
| | | S_KJPZSSRQ = a.KJPZSSRQ, |
| | | S_KJPZSRSJ = a.KJPZSRSJ, |
| | | }); |
| | | } |
| | | //} |
| | | |
| | | }); |
| | | db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand(); |
| | | db.CommitTran(); |
| | | }); |
| | | db.Insertable<TN_Inbound_Order>(po).ExecuteCommand(); |
| | | db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand(); |
| | | |
| | | |
| | | } |
| | | } |
| | | //result.resultMsg = "成功"; |
| | | //result.WLPZBH = items.HEAD.WLPZH; |
| | | //result.WLPZND = items.HEAD.WLPZND; |
| | | //result.resultCode = 0; |
| | | //result.resultMsg = ""; |
| | | //simpleResults.Add(result); |
| | | //continue; |
| | | else |
| | | { |
| | | var Details = new List<TN_Inbound_Detail>(); |
| | | if (items.ITEM.Count > 0) |
| | | { |
| | | items.ITEM.ForEach(a => |
| | | { |
| | | if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).Count() > 0) |
| | | { |
| | | var poq = po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).FirstOrDefault(); |
| | | poq.F_QTY = a.SL; |
| | | |
| | | db.Updateable(poq).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | else |
| | | { |
| | | Details.Add(new TN_Inbound_Detail |
| | | { |
| | | S_IO_NO = items.HEAD.WLPZH, |
| | | N_ROW_NO = a.WLPZHXM, |
| | | S_ITEM_CODE = a.WLBM, |
| | | F_QTY = a.SL, |
| | | S_ITEM_STATE = "物料", |
| | | S_ITEM_NAME = "物料", |
| | | F_ACC_B_QTY = 0, |
| | | S_KCDD = a.KCDD, |
| | | S_UOM = a.DW,//计量单位 |
| | | //S_UOM = a.JBJLDW,//计量单位 |
| | | //S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), |
| | | S_BATCH_NO = a.PC == null ? "" : a.PC, |
| | | S_CGPZH = a.CGPZH, |
| | | S_CGPZXMBH = a.CGPZXMBH, |
| | | S_CKPZKJND = a.CKPZKJND, |
| | | S_CKPZXM = a.CKPZHXM, |
| | | S_CXWLPZBH = a.CKPZH, |
| | | S_HWSJJYZT = a.HWSJJYZT, |
| | | S_GYSZHH = a.GYSZHH, |
| | | S_JYPBH = a.JYPBH, |
| | | S_KJPZSSRQ = a.KJPZSSRQ, |
| | | S_KJPZSRSJ = a.KJPZSRSJ, |
| | | }); |
| | | } |
| | | |
| | | }); |
| | | db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand(); |
| | | |
| | | |
| | | } |
| | | //result.resultMsg = "成功"; |
| | | //result.WLPZBH = items.HEAD.WLPZH; |
| | | //result.WLPZND = items.HEAD.WLPZND; |
| | | //result.resultCode = 0; |
| | | //result.resultMsg = ""; |
| | | //simpleResults.Add(result); |
| | | //continue; |
| | | } |
| | | |
| | | } |
| | | }else |
| | | { |
| | | |
| | | //冲销凭证单号 |
| | | foreach (var item1 in items.ITEM) |
| | | { |
| | | var cxpzbh = item1.CKPZH; |
| | | var po = WMSHelper.GetInboundOrder(cxpzbh); |
| | | //判断是否执行 执行中订单允许冲销 |
| | | if (po == null) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 1; |
| | | result.resultMsg = "未找到此订单"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | if (po.N_B_STATE != 0 && po.N_B_STATE != 7) |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.resultCode = 1; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = "执行中订单不允许操作"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | |
| | | foreach (var item in items.ITEM) |
| | | { |
| | | //s.S_ITEM_CODE == item.WLBM&& |
| | | var rkdmx = po.Details.Where(s => s.S_CKPZXM == item.CKPZHXM).ToList(); |
| | | if (rkdmx.Where(s => s.F_QTY < item.SL).Count() > 0)//数量大于明细 |
| | | { |
| | | result.resultMsg = "失败"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultMsg = $"退货物料{item.WLBM}数量{item.SL}大于存入数量"; |
| | | simpleResults.Add(result); |
| | | continue; |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY == item.SL).Count() == 1)//数量==明细 删除当下入库单物料数据 |
| | | { |
| | | db.Deleteable<TN_Inbound_Detail>().Where(it => it.S_ITEM_CODE == item.WLBM && it.S_IO_NO == cxpzbh).ExecuteCommand(); |
| | | } |
| | | else if (rkdmx.Where(s => s.F_QTY > item.SL).Count() > 0)//数量小于明细 |
| | | { |
| | | //当前物料明细 |
| | | var rkd = rkdmx.Where(s => s.F_QTY > item.SL).FirstOrDefault(); |
| | | rkd.F_QTY = rkd.F_QTY - item.SL; |
| | | db.Updateable(rkd).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | var po1 = db.Queryable<TN_Inbound_Order>().Includes(a => a.Details).Where(a => a.S_NO == cxpzbh).First(); |
| | | int ssss = po1.Details.Count(); |
| | | if (po1.Details.Count() == 0) |
| | | { |
| | | po1.N_B_STATE = 7; |
| | | db.Updateable(po1).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | //} |
| | | |
| | | |
| | | result.resultMsg = "成功"; |
| | | result.WLPZBH = items.HEAD.WLPZH; |
| | | result.WLPZND = items.HEAD.WLPZND; |
| | | result.resultCode = 0; |
| | | result.resultMsg = ""; |
| | | db.CommitTran(); |
| | | simpleResults.Add(result); |
| | | } |
| | | |
| | |
| | | /// </summary> |
| | | /// <param name="model"></param> |
| | | /// <returns></returns> |
| | | internal static Orderback.Root GYS_In(GYSDto.Root model) |
| | | internal static GYSReturnRoot.Root GYS_In(GYSDto.Root model) |
| | | { |
| | | var orderResponse = new Orderback.Root |
| | | var orderResponse = new GYSReturnRoot.Root |
| | | { |
| | | ROOT = new Orderback.ROOT |
| | | ROOT = new GYSReturnRoot.ROOT |
| | | { |
| | | ITEM = new List<Orderback.ITEM> { } |
| | | ITEM = new List<GYSReturnRoot.ITEM> { } |
| | | |
| | | } |
| | | }; |
| | | |
| | | List<Orderback.ITEM> tEMs = new List<Orderback.ITEM>(); |
| | | List<GYSReturnRoot.ITEM> tEMs = new List<GYSReturnRoot.ITEM>(); |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | try |
| | | { |
| | | db.BeginTran(); |
| | | foreach (var item in model.ROOT.GYSXX) |
| | | { |
| | | Orderback.ITEM iTEM = new Orderback.ITEM(); |
| | | GYSReturnRoot.ITEM iTEM = new GYSReturnRoot.ITEM(); |
| | | |
| | | |
| | | |
| | | //创建入库单主子表 |
| | | var po = WMSHelper.GetGYSBMOrder(item.JBXX.GYSBM); |
| | | if (po == null) |
| | | { |
| | | po = new TN_Supplier { S_GYSBM= item.JBXX.GYSBM , S_MDMBM = item.JBXX.MDMBM, }; |
| | | po.Details = new List<TN_Supplier_detial>(); |
| | | if (item.GYSHB.Count > 0) |
| | | { |
| | | item.GYSHB.ForEach(a => |
| | | { |
| | | po.Details.Add(new TN_Supplier_detial |
| | | { |
| | | S_DO_GYSBM = a.GYSBM, |
| | | S_CGZZ = a.CGZZ, |
| | | S_HB = a.HB, |
| | | |
| | | }); |
| | | //} |
| | | }); |
| | | db.Insertable<TN_Supplier>(po).ExecuteCommand(); |
| | | db.Insertable<TN_Supplier_detial>(po.Details).ExecuteCommand(); |
| | | } |
| | | } |
| | | else |
| | | // var po = WMSHelper.GetGYSBMOrder(item.JBXX.GYSBM); |
| | | var po= db.Queryable<TN_Supplier>().Includes(a => a.Details).Where(a => a.S_GYSBM == item.JBXX.GYSBM).First(); |
| | | if (po != null) |
| | | { |
| | | db.Deleteable<TN_Supplier>().Where(it => it.S_GYSBM == po.S_GYSBM).ExecuteCommand(); |
| | | db.Deleteable<TN_Supplier_detial>().Where(it => it.S_DO_GYSBM == po.S_GYSBM).ExecuteCommand(); |
| | | //iTEM.SCDDH = item.JBXX.GYSBM; |
| | | //iTEM.MSGCODE = "1"; |
| | | //iTEM.MSGDESP = $"{item.JBXX.GYSBM}已存在"; |
| | | //tEMs.Add(iTEM); |
| | | |
| | | } |
| | | iTEM.SCDDH = item.JBXX.GYSBM; |
| | | iTEM.MSGCODE = "0"; |
| | | po = new TN_Supplier { S_GYSBM = item.JBXX.GYSBM, S_MDMBM = item.JBXX.MDMBM, S_GYSMC=item.JBXX.GYSMC, S_YHGJ=item.JBXX.YHGJ, S_YHDM = item.JBXX.YHDM , |
| | | S_KHH = item.JBXX.KHH, |
| | | S_YHJD = item.JBXX.YHJD, |
| | | S_YHCS = item.JBXX.YHCS, |
| | | S_KHHZH = item.JBXX.KHHZH, |
| | | S_DZ = item.JBXX.DZ, |
| | | S_YZBM = item.JBXX.YZBM, |
| | | S_CS = item.JBXX.CS, |
| | | S_GJDM = item.JBXX.GJDM, |
| | | S_GJ = item.JBXX.GJ, |
| | | S_DQDM = item.JBXX.DQDM, |
| | | S_DQMC = item.JBXX.DQMC, |
| | | S_SH = item.JBXX.SH, |
| | | S_ZZSDJH = item.JBXX.ZZSDJH, |
| | | }; |
| | | po.Details = new List<TN_Supplier_detial>(); |
| | | if (item.GYSHB.Count > 0) |
| | | { |
| | | item.GYSHB.ForEach(a => |
| | | { |
| | | po.Details.Add(new TN_Supplier_detial |
| | | { |
| | | S_DO_GYSBM = a.GYSBM, |
| | | S_CGZZ = a.CGZZ, |
| | | S_HB = a.HB, |
| | | |
| | | }); |
| | | //} |
| | | }); |
| | | db.Insertable<TN_Supplier>(po).ExecuteCommand(); |
| | | db.Insertable<TN_Supplier_detial>(po.Details).ExecuteCommand(); |
| | | } |
| | | iTEM.GYSBM = item.JBXX.GYSBM; |
| | | iTEM.MSGCODE = 0; |
| | | iTEM.MSGDESP = $"成功"; |
| | | tEMs.Add(iTEM); |
| | | } |
| | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | Orderback.ITEM iTEM = new Orderback.ITEM(); |
| | | iTEM.SCDDH = ""; |
| | | iTEM.GC = ""; |
| | | iTEM.MSGCODE = "1"; |
| | | GYSReturnRoot.ITEM iTEM = new GYSReturnRoot.ITEM(); |
| | | iTEM.GYSBM = ""; |
| | | iTEM.MSGCODE = 1; |
| | | iTEM.MSGDESP = e.Message; |
| | | tEMs.Add(iTEM); |
| | | orderResponse.ROOT.ITEM = tEMs; |
| | |
| | | { |
| | | TN_GENERATE_ORDER tnorder = new TN_GENERATE_ORDER(); |
| | | tnorder.S_GC = item.GC; |
| | | tnorder.S_SCDDH = item.SCDDH; |
| | | tnorder.S_SCDDH = item.SCDDH; |
| | | tnorder.S_DZMC = item.DZMC; |
| | | tnorder.S_SCDDCMS = item.SCDDCMS; |
| | |
| | | { |
| | | ITEM = new List<WLReturnRoot.ITEM> |
| | | { |
| | | |
| | | |
| | | } |
| | | } |
| | | }; |
| | |
| | | { |
| | | itemwlpz.ITEM.ForEach(a => |
| | | { |
| | | |
| | | |
| | | po.Details.Add(new TN_Inbound_Detail |
| | | { |
| | | S_IO_NO = itemwlpz.HEAD.WLPZH, |
| | |
| | | var po = WMSHelper.GetInboundOrder(itemwlpz.HEAD.WLPZBH); |
| | | if (po == null) |
| | | { |
| | | po = new TN_Inbound_Order { S_NO = itemwlpz.HEAD.WLPZBH, S_WLPZND=itemwlpz.HEAD.WLPZNF, S_WLPZNF = itemwlpz.HEAD.WLPZNF, S_FACTORY = itemwlpz.ITEM[0].GC, S_IN_TYPE = "其他入库", S_BS_TYPE = itemwlpz.ITEM[0].YDLX }; |
| | | po = new TN_Inbound_Order { S_NO = itemwlpz.HEAD.WLPZBH, S_WLPZND = itemwlpz.HEAD.WLPZNF, S_WLPZNF = itemwlpz.HEAD.WLPZNF, S_FACTORY = itemwlpz.ITEM[0].GC, S_IN_TYPE = "其他入库", S_BS_TYPE = itemwlpz.ITEM[0].YDLX }; |
| | | po.Details = new List<TN_Inbound_Detail>(); |
| | | if (itemwlpz.ITEM.Count > 0) |
| | | { |
| | |
| | | S_CXWLPZHXM = a.CXPZHXM, |
| | | S_CXPZNF = a.CXPZNF, |
| | | |
| | | S_SERIAL_NO = a.ITEM1==null?"": string.Join(",", a.ITEM1.XLH), |
| | | S_SERIAL_NO = a.ITEM1 == null ? "" : string.Join(",", a.ITEM1.XLH), |
| | | |
| | | }); |
| | | //} |
| | |
| | | result12.resultMsg = $"物料{a.WLBH}物料主数据不存在该物料"; |
| | | simples.Add(result12); |
| | | continue; |
| | | // throw new Exception($"物料{a.WLBH}物料主数据不存在该物料"); |
| | | // throw new Exception($"物料{a.WLBH}物料主数据不存在该物料"); |
| | | } |
| | | TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail |
| | | { |
| | |
| | | /// <returns></returns> |
| | | internal static async Task<SimpleResult> OutboundOrderSorting(FJSorting model) |
| | | { |
| | | var result = new SimpleResult(); |
| | | |
| | | var result = new SimpleResult(); |
| | | |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | | using (var db = new SqlHelper<object>().GetInstance()) |
| | |
| | | try |
| | | { |
| | | |
| | | |
| | | result.resultMsg = "成功"; |
| | | result.resultCode = 0; |
| | | if (string.IsNullOrEmpty(model.arrival_no)) |
| | | { |
| | | result.resultMsg = "出库单号不能为空"; |
| | | result.resultCode = 1; |
| | | return result; |
| | | } |
| | | |
| | | //人工分拣 容器货品表数量、分配量升降 |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == model.arrival_no).First(); |
| | | if (po == null) |
| | | { |
| | | result.resultMsg = "未找到此出库单"; |
| | | result.resultCode = 1; |
| | | return result; |
| | | |
| | | } |
| | | |
| | | //根据不同出库类型 回调sap |
| | | if (po.S_OUT_TYPE == "冲销出库") |
| | | { |
| | | result = await CXAddOutboundOrder(db,model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | else |
| | | if (po.S_OUT_TYPE == "出库")//普通出库 |
| | | { |
| | | |
| | | result = await AddOutboundOrder(db,model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | else if (po.S_OUT_TYPE == "计划外发料出库") |
| | | { |
| | | result = await jhwtlAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | else if (po.S_OUT_TYPE == "成本中心出库") |
| | | { |
| | | result = await CBAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | |
| | | //通用接口 对容器货品的删减 和生成回库单 都要用的接口 |
| | | result = await TYAddOutboundOrder(db,model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE); |
| | | #region 升降量 |
| | | |
| | | bool adds = true; |
| | | |
| | | //var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == model.cntr_code).ToList(); |
| | | if (model.MaterList.Count > 0) |
| | | { |
| | | var url = Settings.MoboxSeverUrl + "inventory/AddChange"; |
| | | //仓库量表升量 |
| | | var req = new AddChangeModel { op_type = 4 }; |
| | | //库区量表升量 |
| | | var req2 = new AddChangeModel { op_type = 7 }; |
| | | model.MaterList.ForEach(a => |
| | | result.resultMsg = "成功"; |
| | | result.resultCode = 0; |
| | | if (string.IsNullOrEmpty(model.arrival_no)) |
| | | { |
| | | LogHelper.Info($"填充数据"); |
| | | LogHelper.Info($"减仓库量表数据 仓库{po.S_WH_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}"); |
| | | req.item_info.Add(new AddChangeModel.itemModel |
| | | { |
| | | wh_code = po.S_WH_CODE, |
| | | item_code = a.item_code, |
| | | item_name = "", |
| | | qty = a.qty |
| | | }); |
| | | LogHelper.Info($"减库区量表数据 库区{po.S_AREA_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}"); |
| | | req2.item_info.Add(new AddChangeModel.itemModel |
| | | { |
| | | wh_code = po.S_WH_CODE, |
| | | area_code = po.S_AREA_CODE, |
| | | item_code = a.item_code, |
| | | item_name = "", |
| | | qty = a.qty |
| | | }); |
| | | }); |
| | | var reqData = JsonConvert.SerializeObject(req); |
| | | var AppKey = Settings.AppKey; |
| | | var AppSecret = Settings.AppSecret; |
| | | var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); |
| | | //var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); |
| | | LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}"); |
| | | var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime); |
| | | LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}"); |
| | | var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify); |
| | | if (!string.IsNullOrEmpty(res)) |
| | | result.resultMsg = "出库单号不能为空"; |
| | | result.resultCode = 1; |
| | | return result; |
| | | } |
| | | |
| | | //人工分拣 容器货品表数量、分配量升降 |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == model.arrival_no).First(); |
| | | if (po == null) |
| | | { |
| | | LogHelper.Info($"mobox 仓库降量接口返回 {res}"); |
| | | var moboxres = JsonConvert.DeserializeObject<moboxres>(res); |
| | | if (moboxres.err_code != 0) |
| | | { |
| | | adds = false; |
| | | } |
| | | result.resultMsg = "未找到此出库单"; |
| | | result.resultCode = 1; |
| | | return result; |
| | | |
| | | } |
| | | |
| | | //根据不同出库类型 回调sap |
| | | if (po.S_OUT_TYPE == "冲销出库") |
| | | { |
| | | result = await CXAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | else |
| | | if (po.S_OUT_TYPE == "出库")//普通出库 |
| | | { |
| | | LogHelper.Info($"mobox 仓库降量接口返回为空"); |
| | | |
| | | result = await AddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | var reqData2 = JsonConvert.SerializeObject(req2); |
| | | var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); |
| | | //var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); |
| | | LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}"); |
| | | var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2); |
| | | LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}"); |
| | | var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2); |
| | | if (!string.IsNullOrEmpty(res2)) |
| | | else if (po.S_OUT_TYPE == "计划外发料出库") |
| | | { |
| | | LogHelper.Info($"mobox 库区降量接口返回 {res2}"); |
| | | var moboxres = JsonConvert.DeserializeObject<moboxres>(res); |
| | | if (moboxres.err_code != 0) |
| | | result = await jhwtlAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | else if (po.S_OUT_TYPE == "成本中心出库") |
| | | { |
| | | result = await CBAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start); |
| | | } |
| | | |
| | | //通用接口 对容器货品的删减 和生成回库单 都要用的接口 |
| | | result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE); |
| | | #region 升降量 |
| | | |
| | | bool adds = true; |
| | | |
| | | //var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == model.cntr_code).ToList(); |
| | | if (model.MaterList.Count > 0) |
| | | { |
| | | var url = Settings.MoboxSeverUrl + "inventory/AddChange"; |
| | | //仓库量表升量 |
| | | var req = new AddChangeModel { op_type = 4 }; |
| | | //库区量表升量 |
| | | var req2 = new AddChangeModel { op_type = 7 }; |
| | | var S_WH_CODE = ""; |
| | | var S_AREA_CODE = ""; |
| | | if (string.IsNullOrEmpty(po.S_WH_CODE)) |
| | | { |
| | | adds = false; |
| | | S_WH_CODE = util.Settings.WHCode; |
| | | } |
| | | if (string.IsNullOrEmpty(po.S_AREA_CODE)) |
| | | { |
| | | S_AREA_CODE = util.Settings.AREACode; |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info($"mobox 库区降量接口返回为空"); |
| | | model.MaterList.ForEach(a => |
| | | { |
| | | LogHelper.Info($"填充数据{util.Settings.WHCode}"); |
| | | LogHelper.Info($"减仓库量{util.Settings.AREACode}表数据 仓库{po.S_WH_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}"); |
| | | req.item_info.Add(new AddChangeModel.itemModel |
| | | { |
| | | wh_code = S_WH_CODE, |
| | | item_code = a.item_code, |
| | | item_name = "", |
| | | qty = a.qty |
| | | }); |
| | | LogHelper.Info($"减库区量表数据 库区{po.S_AREA_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}"); |
| | | req2.item_info.Add(new AddChangeModel.itemModel |
| | | { |
| | | wh_code = S_WH_CODE, |
| | | area_code = S_AREA_CODE, |
| | | item_code = a.item_code, |
| | | item_name = "", |
| | | qty = a.qty |
| | | }); |
| | | }); |
| | | var reqData = JsonConvert.SerializeObject(req); |
| | | var AppKey = Settings.AppKey; |
| | | var AppSecret = Settings.AppSecret; |
| | | var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); |
| | | //var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); |
| | | LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime}"); |
| | | var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime); |
| | | LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={reqData}"); |
| | | var res = new HttpHelper().WebPost(url, reqData, "application/json", AppKey, ReqTime, ReqVerify); |
| | | if (!string.IsNullOrEmpty(res)) |
| | | { |
| | | LogHelper.Info($"mobox 仓库降量接口返回 {res}"); |
| | | var moboxres = JsonConvert.DeserializeObject<moboxres>(res); |
| | | if (moboxres.err_code != 0) |
| | | { |
| | | adds = false; |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info($"mobox 仓库降量接口返回为空"); |
| | | |
| | | } |
| | | var reqData2 = JsonConvert.SerializeObject(req2); |
| | | var ReqTime2 = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(); |
| | | //var ReqTime2 = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2); |
| | | LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2}"); |
| | | var ReqVerify2 = GetMd5FromString(AppKey + AppSecret + ReqTime2); |
| | | LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime2} ReqVerify={ReqVerify2} url={url} req={reqData2}"); |
| | | var res2 = new HttpHelper().WebPost(url, reqData2, "application/json", AppKey, ReqTime2, ReqVerify2); |
| | | if (!string.IsNullOrEmpty(res2)) |
| | | { |
| | | LogHelper.Info($"mobox 库区降量接口返回 {res2}"); |
| | | var moboxres = JsonConvert.DeserializeObject<moboxres>(res); |
| | | if (moboxres.err_code != 0) |
| | | |
| | | { |
| | | adds = false; |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info($"mobox 库区降量接口返回为空"); |
| | | |
| | | } |
| | | if (adds) addOnShelves(po, model.cntr_code, 2); |
| | | |
| | | } |
| | | if (adds) addOnShelves(po, model.cntr_code, 2); |
| | | |
| | | } |
| | | else LogHelper.Info($"托盘{model.cntr_code}无需要升降量的物料"); |
| | | else LogHelper.Info($"托盘{model.cntr_code}无需要升降量的物料"); |
| | | db.CommitTran(); |
| | | #endregion |
| | | return result; |
| | | |
| | | |
| | | } |
| | | catch (Exception e) |
| | | {result.resultMsg=e.Message; |
| | | { |
| | | result.resultMsg = e.Message; |
| | | db.RollbackTran(); |
| | | return result; |
| | | throw; |
| | |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | //using (var db = new SqlHelper<object>().GetInstance()) |
| | | //{ |
| | | var result = new SimpleResult(); |
| | | var result = new SimpleResult(); |
| | | |
| | | try |
| | | try |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | //分拣单 |
| | | //var popp = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_BS_NO == arrival_no&&a.S_SORT_TYPE=="未分类" && a.N_B_STATE == 2).First(); |
| | | |
| | | //回参物料信息 |
| | | List<OutboundRecord> records = new List<OutboundRecord>(); |
| | | var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); |
| | | foreach (var item in MaterList) |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | //分拣单 |
| | | //var popp = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_BS_NO == arrival_no&&a.S_SORT_TYPE=="未分类" && a.N_B_STATE == 2).First(); |
| | | |
| | | //回参物料信息 |
| | | List<OutboundRecord> records = new List<OutboundRecord>(); |
| | | var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); |
| | | foreach (var item in MaterList) |
| | | // 插入到托盘明细表 |
| | | var cntr = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code).ToList(); |
| | | if (cntr.Count() > 0) |
| | | { |
| | | // 插入到托盘明细表 |
| | | var cntr = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code).ToList(); |
| | | if (cntr.Count() > 0) |
| | | db.BeginTran(); |
| | | //1.查看是否有相同物料批次的信息,如果有要累减少,不同批次的可以分开&& a.N_BS_ROW_NO == item.N_ROW_NO |
| | | var cir = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code && a.S_ITEM_CODE == item.item_code).First();//&& a.S_BATCH_NO == item.S_BATCH_NO |
| | | if (cir != null) |
| | | { |
| | | db.BeginTran(); |
| | | //1.查看是否有相同物料批次的信息,如果有要累减少,不同批次的可以分开&& a.N_BS_ROW_NO == item.N_ROW_NO |
| | | var cir = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code && a.S_ITEM_CODE == item.item_code ).First();//&& a.S_BATCH_NO == item.S_BATCH_NO |
| | | if (cir != null) |
| | | cir.F_QTY -= item.qty; |
| | | cir.F_ALLOC_QTY -= item.qty; |
| | | cir.T_MODIFY = DateTime.Now; |
| | | if (cir.F_QTY == 0) |
| | | { |
| | | cir.F_QTY -= item.qty; |
| | | cir.F_ALLOC_QTY -= item.qty; |
| | | cir.T_MODIFY = DateTime.Now; |
| | | if (cir.F_QTY == 0) |
| | | { |
| | | db.Deleteable(cir).ExecuteCommand(); |
| | | } |
| | | else |
| | | { |
| | | db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand(); |
| | | //添加回库作业 |
| | | |
| | | |
| | | } |
| | | db.Deleteable(cir).ExecuteCommand(); |
| | | } |
| | | else |
| | | { |
| | | db.RollbackTran(); |
| | | result.resultCode = 1; |
| | | result.resultMsg = $"物料不存在{item.item_code}"; |
| | | LogHelper.Info($"物料不存在{item.item_code}"); |
| | | return result; |
| | | } |
| | | if (isHK) |
| | | { |
| | | var wmsTask = new WMSTask |
| | | { |
| | | S_CNTR_CODE = cntr_code, |
| | | S_CODE = WMSHelper.GenerateTaskNo(), |
| | | S_START_LOC = start, |
| | | S_START_AREA = startinfo.S_AREA_CODE, |
| | | S_START_WH = startinfo.S_WH_CODE, |
| | | S_END_LOC = startinfo.S_CODE, |
| | | S_END_AREA = startinfo.S_AREA_CODE, |
| | | S_END_WH = startinfo.S_WH_CODE, |
| | | db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand(); |
| | | //添加回库作业 |
| | | |
| | | N_TYPE = 1, |
| | | // S_TYPE = WMSTask.GetTypeStr(1), |
| | | S_TYPE = "回库", |
| | | S_OP_DEF_CODE = "", |
| | | S_OP_DEF_NAME = "pda入库" |
| | | }; |
| | | if (WMSHelper.CreateWmsTask(wmsTask)) |
| | | { |
| | | LocationHelper.LockLoc(start, 1); |
| | | result.resultMsg = $"创建作业成功,作业号{wmsTask.S_CODE}"; |
| | | } |
| | | } |
| | | OutboundRecord outboundRecord = new OutboundRecord(); |
| | | outboundRecord.S_WLPZBH = pz?.S_WLPZBH; |
| | | outboundRecord.S_WLPZND = pz?.S_WLPZND; |
| | | outboundRecord.S_TYPE = S_OUT_TYPE; |
| | | |
| | | outboundRecord.S_NO = arrival_no; |
| | | outboundRecord.S_WLBM = item.item_code; |
| | | outboundRecord.S_SL = item.qty; |
| | | outboundRecord.S_CNTR_CODE = cntr_code; |
| | | records.Add(outboundRecord); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | db.RollbackTran(); |
| | | result.resultCode = 1; |
| | | result.resultMsg = $"获取托盘信息失败{cntr_code}"; |
| | | LogHelper.Info($"获取托盘信息失败{cntr_code}"); |
| | | result.resultMsg = $"物料不存在{item.item_code}"; |
| | | LogHelper.Info($"物料不存在{item.item_code}"); |
| | | return result; |
| | | } |
| | | if (isHK) |
| | | { |
| | | var wmsTask = new WMSTask |
| | | { |
| | | S_CNTR_CODE = cntr_code, |
| | | S_CODE = WMSHelper.GenerateTaskNo(), |
| | | S_START_LOC = start, |
| | | S_START_AREA = startinfo.S_AREA_CODE, |
| | | S_START_WH = startinfo.S_WH_CODE, |
| | | S_END_LOC = startinfo.S_CODE, |
| | | S_END_AREA = startinfo.S_AREA_CODE, |
| | | S_END_WH = startinfo.S_WH_CODE, |
| | | |
| | | N_TYPE = 1, |
| | | // S_TYPE = WMSTask.GetTypeStr(1), |
| | | S_TYPE = "回库", |
| | | S_OP_DEF_CODE = "", |
| | | S_OP_DEF_NAME = "pda入库" |
| | | }; |
| | | if (WMSHelper.CreateWmsTask(wmsTask)) |
| | | { |
| | | LocationHelper.LockLoc(start, 1); |
| | | result.resultMsg = $"创建作业成功,作业号{wmsTask.S_CODE}"; |
| | | } |
| | | } |
| | | OutboundRecord outboundRecord = new OutboundRecord(); |
| | | outboundRecord.S_WLPZBH = pz?.S_WLPZBH; |
| | | outboundRecord.S_WLPZND = pz?.S_WLPZND; |
| | | outboundRecord.S_TYPE = S_OUT_TYPE; |
| | | |
| | | outboundRecord.S_NO = arrival_no; |
| | | outboundRecord.S_WLBM = item.item_code; |
| | | outboundRecord.S_SL = item.qty; |
| | | outboundRecord.S_CNTR_CODE = cntr_code; |
| | | records.Add(outboundRecord); |
| | | } |
| | | db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | |
| | | //db.CommitTran(); |
| | | else |
| | | { |
| | | result.resultCode = 1; |
| | | result.resultMsg = $"获取托盘信息失败{cntr_code}"; |
| | | LogHelper.Info($"获取托盘信息失败{cntr_code}"); |
| | | return result; |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("物料信息绑定到满容器上" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("物料信息绑定到满容器上" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | //} |
| | | |
| | |
| | | { |
| | | //using (var db = new SqlHelper<object>().GetInstance()) |
| | | //{ |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | var result = new SimpleResult(); |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | var result = new SimpleResult(); |
| | | |
| | | try |
| | | try |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); |
| | | //出库回调入参 |
| | | var cbCenterBackDto = new CBcenterBackDto.Root |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); |
| | | //出库回调入参 |
| | | var cbCenterBackDto = new CBcenterBackDto.Root |
| | | ROOT = new CBcenterBackDto.ROOT |
| | | { |
| | | ROOT = new CBcenterBackDto.ROOT |
| | | HEAD = new List<CBcenterBackDto.HEADItem> |
| | | { |
| | | HEAD = new List<CBcenterBackDto.HEADItem> |
| | | { |
| | | |
| | | } |
| | | } |
| | | }; |
| | | //回参物料信息 |
| | | List<CBcenterBackDto.HEADItem> iTEMs = new List<CBcenterBackDto.HEADItem>(); |
| | | List<OutboundRecord> records = new List<OutboundRecord>(); |
| | | string GZRQ = ""; |
| | | string PZZDRQ = ""; |
| | | if (po.BUDAT != null) |
| | | { |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | if (po.BLDAT != null) |
| | | { |
| | | PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); |
| | | }; |
| | | //回参物料信息 |
| | | List<CBcenterBackDto.HEADItem> iTEMs = new List<CBcenterBackDto.HEADItem>(); |
| | | List<OutboundRecord> records = new List<OutboundRecord>(); |
| | | string GZRQ = ""; |
| | | string PZZDRQ = ""; |
| | | if (po.BUDAT != null) |
| | | { |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | if (po.BLDAT != null) |
| | | { |
| | | PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); |
| | | |
| | | } |
| | | } |
| | | foreach (var item in MaterList) |
| | | { |
| | | var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); |
| | | CBcenterBackDto.HEADItem ckbitem = new CBcenterBackDto.HEADItem(); |
| | | ckbitem.KEY = arrival_no; |
| | | |
| | | ckbitem.CBZX = po.S_CBZX; |
| | | ckbitem.WLBH = item.item_code; |
| | | ckbitem.SL = item.qty; |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | ckbitem.LRZX = po.S_LRZX; |
| | | ckbitem.ZZKM = po.S_ZZKM; |
| | | ckbitem.GC = po.S_FACTORY; |
| | | ckbitem.GZRY = po.UNAME; |
| | | |
| | | ckbitem.PC = podetail?.S_BATCH_NO; |
| | | ckbitem.PZRQ = PZZDRQ; |
| | | ckbitem.GZRQ = GZRQ; |
| | | |
| | | |
| | | |
| | | CBcenterBackDto.ITEM listitem1 = new CBcenterBackDto.ITEM(); |
| | | // List<CBcenterBackDto.ITEM> listitem1 = new List<CBcenterBackDto.ITEM>(); |
| | | //string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | //var serialNos = string.Join(",", CntrItemRels |
| | | // .Where(s => s.S_ITEM_CODE == item.item_code) |
| | | // .Select(s => s.S_SERIAL_NO)); |
| | | //string[] xlhValues = serialNos.Split(','); |
| | | // string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | //foreach (var xlhValue in xlhValues) |
| | | //{ |
| | | // CBcenterBackDto.ITEM newItem = new CBcenterBackDto.ITEM { XLH = xlhValue }; |
| | | // listitem1.Add(newItem); |
| | | //} |
| | | ckbitem.ITEM = listitem1; |
| | | iTEMs.Add(ckbitem); |
| | | |
| | | |
| | | } |
| | | cbCenterBackDto.ROOT.HEAD = iTEMs; |
| | | //db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | #region wms-sap回调 |
| | | //类转json |
| | | var json = JsonConvert.SerializeObject(cbCenterBackDto.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"成本中心出库xml数据{xml}"); |
| | | //// 创建 StringContent 并指定媒体类型为 "text/xml" |
| | | //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); |
| | | //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; |
| | | //string responseXml = ""; |
| | | //using (HttpClient client = new HttpClient()) |
| | | //{ |
| | | // // 发送 POST 请求并接收响应 |
| | | // HttpResponseMessage responsess = await client.PostAsync(url, content); |
| | | // responseXml = await responsess.Content.ReadAsStringAsync(); |
| | | |
| | | //} |
| | | |
| | | #region sap回调 |
| | | // 创建Web Service代理类实例 |
| | | ZSCM2_CBZX service = new ZSCM2_CBZX(); |
| | | service.PreAuthenticate = true; |
| | | service.Url = service.Url + "?sap-language=ZH"; |
| | | // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); |
| | | // 准备请求参数 |
| | | ZfmScm2CbzxMm001 request = new ZfmScm2CbzxMm001(); |
| | | request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; |
| | | LogHelper.Info($"成本中心出库SAP回调"); |
| | | // 调用Web Service |
| | | ZfmScm2CbzxMm001Response responses = service.ZfmScm2CbzxMm001(request); |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("SAP返回结果: " + responses.Output); |
| | | |
| | | // 解析Output中的凭证号等信息 |
| | | |
| | | #endregion |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnWcBcak.Root>(jsonObject.ToString()); |
| | | |
| | | //添加凭证记录表 |
| | | result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | |
| | | foreach (var item in MaterList) |
| | | { |
| | | var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); |
| | | CBcenterBackDto.HEADItem ckbitem = new CBcenterBackDto.HEADItem(); |
| | | ckbitem.KEY = arrival_no; |
| | | |
| | | ckbitem.CBZX = po.S_CBZX; |
| | | ckbitem.WLBH = item.item_code; |
| | | ckbitem.SL = item.qty; |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | ckbitem.LRZX = po.S_LRZX; |
| | | ckbitem.ZZKM = po.S_ZZKM; |
| | | ckbitem.GC = po.S_FACTORY; |
| | | ckbitem.GZRY = po.UNAME; |
| | | |
| | | ckbitem.PC = podetail?.S_BATCH_NO; |
| | | ckbitem.PZRQ = PZZDRQ; |
| | | ckbitem.GZRQ = GZRQ; |
| | | |
| | | |
| | | |
| | | CBcenterBackDto.ITEM listitem1 = new CBcenterBackDto.ITEM(); |
| | | // List<CBcenterBackDto.ITEM> listitem1 = new List<CBcenterBackDto.ITEM>(); |
| | | //string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | //var serialNos = string.Join(",", CntrItemRels |
| | | // .Where(s => s.S_ITEM_CODE == item.item_code) |
| | | // .Select(s => s.S_SERIAL_NO)); |
| | | //string[] xlhValues = serialNos.Split(','); |
| | | // string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | listitem1.XLH= podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | //foreach (var xlhValue in xlhValues) |
| | | //{ |
| | | // CBcenterBackDto.ITEM newItem = new CBcenterBackDto.ITEM { XLH = xlhValue }; |
| | | // listitem1.Add(newItem); |
| | | //} |
| | | ckbitem.ITEM = listitem1; |
| | | iTEMs.Add(ckbitem); |
| | | |
| | | |
| | | } |
| | | cbCenterBackDto.ROOT.HEAD = iTEMs; |
| | | //db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | #region wms-sap回调 |
| | | //类转json |
| | | var json = JsonConvert.SerializeObject(cbCenterBackDto.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"成本中心出库xml数据{xml}"); |
| | | //// 创建 StringContent 并指定媒体类型为 "text/xml" |
| | | //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); |
| | | //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; |
| | | //string responseXml = ""; |
| | | //using (HttpClient client = new HttpClient()) |
| | | //{ |
| | | // // 发送 POST 请求并接收响应 |
| | | // HttpResponseMessage responsess = await client.PostAsync(url, content); |
| | | // responseXml = await responsess.Content.ReadAsStringAsync(); |
| | | |
| | | //} |
| | | |
| | | #region sap回调 |
| | | // 创建Web Service代理类实例 |
| | | ZSCM2_CBZX service = new ZSCM2_CBZX(); |
| | | service.PreAuthenticate = true; |
| | | service.Url = service.Url + "?sap-language=ZH"; |
| | | // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); |
| | | // 准备请求参数 |
| | | ZfmScm2CbzxMm001 request = new ZfmScm2CbzxMm001(); |
| | | request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; |
| | | LogHelper.Info($"成本中心出库SAP回调"); |
| | | // 调用Web Service |
| | | ZfmScm2CbzxMm001Response responses = service.ZfmScm2CbzxMm001(request); |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("SAP返回结果: " + responses.Output); |
| | | |
| | | // 解析Output中的凭证号等信息 |
| | | |
| | | #endregion |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnWcBcak.Root>(jsonObject.ToString()); |
| | | |
| | | //添加凭证记录表 |
| | | result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | |
| | | foreach (var item in MaterList) |
| | | { |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLBM = item.item_code; |
| | | materialVoucher.S_WLH = item.N_ROW_NO; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLBM = item.item_code; |
| | | materialVoucher.S_WLH = item.N_ROW_NO; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.F_QTY = item.qty; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | //MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | //materialVoucher.S_NO = po.S_NO; |
| | | //materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; |
| | | //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; |
| | | //materialVoucher.STATUS = 0; |
| | | //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | materialVoucher.S_GZRQ = po.BUDAT; |
| | | materialVoucher.UNAME = po.UNAME; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | #endregion |
| | | |
| | | //db.CommitTran(); |
| | | //MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | //materialVoucher.S_NO = po.S_NO; |
| | | //materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; |
| | | //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; |
| | | //materialVoucher.STATUS = 0; |
| | | //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("成本中心回调报错" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | #endregion |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("成本中心回调报错" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | //} |
| | | /// <summary> |
| | |
| | | { |
| | | //using (var db = new SqlHelper<object>().GetInstance()) |
| | | //{ |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | var result = new SimpleResult(); |
| | | try |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | var result = new SimpleResult(); |
| | | try |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | |
| | | var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); |
| | | //出库回调入参 |
| | | |
| | | DateTime dateTime; |
| | | DateTime dateTime1; |
| | | string GZRQ = ""; |
| | | string PZZDRQ = ""; |
| | | if (po.BUDAT != null) |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | if (po.BLDAT != null) |
| | | { |
| | | PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); |
| | | |
| | | var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == arrival_no).ToList(); |
| | | //出库回调入参 |
| | | |
| | | DateTime dateTime; |
| | | DateTime dateTime1; |
| | | string GZRQ = ""; |
| | | string PZZDRQ = ""; |
| | | if (po.BUDAT != null) |
| | | } |
| | | JHWBackDto.Root myRoot = new JHWBackDto.Root |
| | | { |
| | | ROOT = new JHWBackDto.ROOT |
| | | { |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | if (po.BLDAT != null) |
| | | { |
| | | PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); |
| | | |
| | | } |
| | | JHWBackDto.Root myRoot = new JHWBackDto.Root |
| | | { |
| | | ROOT = new JHWBackDto.ROOT |
| | | HEAD = new JHWBackDto.HEAD |
| | | { |
| | | HEAD = new JHWBackDto.HEAD |
| | | { |
| | | |
| | | KEY = po.S_NO, |
| | | GZRQ = GZRQ, |
| | | PZZDRQ = PZZDRQ, |
| | | YHM = po.UNAME, |
| | | PZTTWB = po.BKTXT, |
| | | YDLX = po.S_BS_TYPE, |
| | | TSKCBS = po.SOBKZ, |
| | | ITEM = new List<JHWBackDto.ITEM> |
| | | { |
| | | |
| | | } |
| | | }, |
| | | |
| | | } |
| | | }; |
| | | //回参物料信息 |
| | | List<JHWBackDto.ITEM> iTEMs = new List<JHWBackDto.ITEM>(); |
| | | KEY = po.S_NO, |
| | | GZRQ = GZRQ, |
| | | PZZDRQ = PZZDRQ, |
| | | YHM = po.UNAME, |
| | | PZTTWB = po.BKTXT, |
| | | YDLX = po.S_BS_TYPE, |
| | | TSKCBS = po.SOBKZ, |
| | | ITEM = new List<JHWBackDto.ITEM> |
| | | { |
| | | |
| | | } |
| | | }, |
| | | |
| | | } |
| | | }; |
| | | //回参物料信息 |
| | | List<JHWBackDto.ITEM> iTEMs = new List<JHWBackDto.ITEM>(); |
| | | foreach (var item in MaterList) |
| | | { |
| | | var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); |
| | | JHWBackDto.ITEM ckbitem = new JHWBackDto.ITEM(); |
| | | ckbitem.WLBH = item.item_code; |
| | | ckbitem.GC = po.S_FACTORY; |
| | | //ckbitem.PH = podetail?.S_PH; |
| | | //ckbitem.TSKCBS = podetail?.S_TSKCBS; |
| | | ckbitem.XSDD = podetail?.S_XSDD; |
| | | ckbitem.XSDDHXM = podetail?.S_XSDDXMBH; |
| | | ckbitem.SL = item.qty; |
| | | ckbitem.DW = podetail?.S_UOM; |
| | | ckbitem.DDH = podetail?.S_DDH; |
| | | //ckbitem.DDHXM = (podetail?.N_ROW_NO); |
| | | ckbitem.WBS = podetail?.S_WBS; |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | ckbitem.PC = podetail?.S_BATCH_NO; |
| | | JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1(); |
| | | //string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | //var serialNos = string.Join(",", CntrItemRels |
| | | // .Where(s => s.S_ITEM_CODE == item.item_code) |
| | | // .Select(s => s.S_SERIAL_NO)); |
| | | //string[] xlhValues = serialNos.Split(','); |
| | | string[] xlhValues = podetail?.S_SERIAL_NO.Split(','); |
| | | //foreach (var xlhValue in xlhValues) |
| | | //{ |
| | | // JHWBackDto.ITEM1 newItem = new JHWBackDto.ITEM1 { XLH = xlhValue }; |
| | | // listitem1.Add(newItem); |
| | | //} |
| | | listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | ckbitem.ITEM1 = listitem1; |
| | | iTEMs.Add(ckbitem); |
| | | |
| | | //添加出库录凭证表 |
| | | //var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); |
| | | //OutboundRecord outboundRecord = new OutboundRecord(); |
| | | //outboundRecord.S_WLPZBH = pz.S_WLPZBH; |
| | | //outboundRecord.S_WLPZND = pz.S_WLPZND; |
| | | //outboundRecord.S_TYPE = "计划外退料"; |
| | | |
| | | //outboundRecord.S_NO = arrival_no; |
| | | //outboundRecord.S_WLBM = item.item_code; |
| | | //outboundRecord.S_SL = item.qty; |
| | | //outboundRecord.S_CNTR_CODE = cntr_code; |
| | | //records.Add(outboundRecord); |
| | | |
| | | } |
| | | myRoot.ROOT.HEAD.ITEM = iTEMs; |
| | | //db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | #region wms-sap回调 |
| | | //类转json |
| | | |
| | | var json = JsonConvert.SerializeObject(myRoot.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"计划外发料出库xml数据{xml}"); |
| | | // 创建 StringContent 并指定媒体类型为 "text/xml" |
| | | //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); |
| | | //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; |
| | | //string responseXml = ""; |
| | | //using (HttpClient client = new HttpClient()) |
| | | //{ |
| | | // // 发送 POST 请求并接收响应 |
| | | // HttpResponseMessage responsess = await client.PostAsync(url, content); |
| | | // responseXml = await responsess.Content.ReadAsStringAsync(); |
| | | |
| | | //} |
| | | #region sap回调 |
| | | // 创建Web Service代理类实例 |
| | | ZSCM2_SCFLJHW service = new ZSCM2_SCFLJHW(); |
| | | service.PreAuthenticate = true; |
| | | service.Url = service.Url + "?sap-language=ZH"; |
| | | // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); |
| | | // 准备请求参数 |
| | | ZscmScflJhw request = new ZscmScflJhw(); |
| | | request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; |
| | | LogHelper.Info($"计划外SAP回调"); |
| | | // 调用Web Service |
| | | ZscmScflJhwResponse responses = service.ZscmScflJhw(request); |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("SAP返回结果: " + responses.Output); |
| | | |
| | | // 解析Output中的凭证号等信息 |
| | | |
| | | #endregion |
| | | |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); |
| | | //添加凭证记录表 |
| | | result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | foreach (var item in MaterList) |
| | | { |
| | | var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); |
| | | JHWBackDto.ITEM ckbitem = new JHWBackDto.ITEM(); |
| | | ckbitem.WLBH = item.item_code; |
| | | ckbitem.GC = po.S_FACTORY; |
| | | //ckbitem.PH = podetail?.S_PH; |
| | | //ckbitem.TSKCBS = podetail?.S_TSKCBS; |
| | | ckbitem.XSDD = podetail?.S_XSDD; |
| | | ckbitem.XSDDHXM = podetail?.S_XSDDXMBH; |
| | | ckbitem.SL = item.qty; |
| | | ckbitem.DW = podetail?.S_UOM; |
| | | ckbitem.DDH = podetail?.S_DDH; |
| | | //ckbitem.DDHXM = (podetail?.N_ROW_NO); |
| | | ckbitem.WBS = podetail?.S_WBS; |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | ckbitem.PC = podetail?.S_BATCH_NO; |
| | | JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1(); |
| | | //string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | //var serialNos = string.Join(",", CntrItemRels |
| | | // .Where(s => s.S_ITEM_CODE == item.item_code) |
| | | // .Select(s => s.S_SERIAL_NO)); |
| | | //string[] xlhValues = serialNos.Split(','); |
| | | string[] xlhValues = podetail?.S_SERIAL_NO.Split(','); |
| | | //foreach (var xlhValue in xlhValues) |
| | | //{ |
| | | // JHWBackDto.ITEM1 newItem = new JHWBackDto.ITEM1 { XLH = xlhValue }; |
| | | // listitem1.Add(newItem); |
| | | //} |
| | | listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | ckbitem.ITEM1 = listitem1; |
| | | iTEMs.Add(ckbitem); |
| | | |
| | | //添加出库录凭证表 |
| | | //var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First(); |
| | | //OutboundRecord outboundRecord = new OutboundRecord(); |
| | | //outboundRecord.S_WLPZBH = pz.S_WLPZBH; |
| | | //outboundRecord.S_WLPZND = pz.S_WLPZND; |
| | | //outboundRecord.S_TYPE = "计划外退料"; |
| | | |
| | | //outboundRecord.S_NO = arrival_no; |
| | | //outboundRecord.S_WLBM = item.item_code; |
| | | //outboundRecord.S_SL = item.qty; |
| | | //outboundRecord.S_CNTR_CODE = cntr_code; |
| | | //records.Add(outboundRecord); |
| | | |
| | | } |
| | | myRoot.ROOT.HEAD.ITEM = iTEMs; |
| | | //db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | #region wms-sap回调 |
| | | //类转json |
| | | |
| | | var json = JsonConvert.SerializeObject(myRoot.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"计划外发料出库xml数据{xml}"); |
| | | // 创建 StringContent 并指定媒体类型为 "text/xml" |
| | | //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); |
| | | //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; |
| | | //string responseXml = ""; |
| | | //using (HttpClient client = new HttpClient()) |
| | | //{ |
| | | // // 发送 POST 请求并接收响应 |
| | | // HttpResponseMessage responsess = await client.PostAsync(url, content); |
| | | // responseXml = await responsess.Content.ReadAsStringAsync(); |
| | | |
| | | //} |
| | | #region sap回调 |
| | | // 创建Web Service代理类实例 |
| | | ZSCM2_SCFLJHW service = new ZSCM2_SCFLJHW(); |
| | | service.PreAuthenticate = true; |
| | | service.Url = service.Url + "?sap-language=ZH"; |
| | | // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); |
| | | // 准备请求参数 |
| | | ZscmScflJhw request = new ZscmScflJhw(); |
| | | request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; |
| | | LogHelper.Info($"计划外SAP回调"); |
| | | // 调用Web Service |
| | | ZscmScflJhwResponse responses = service.ZscmScflJhw(request); |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("SAP返回结果: " + responses.Output); |
| | | |
| | | // 解析Output中的凭证号等信息 |
| | | |
| | | #endregion |
| | | |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); |
| | | //添加凭证记录表 |
| | | result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | foreach (var item in MaterList) |
| | | { |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLBM = item.item_code; |
| | | materialVoucher.S_WLH = item.N_ROW_NO; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLBM = item.item_code; |
| | | materialVoucher.S_WLH = item.N_ROW_NO; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.S_GZRQ = po.BUDAT; |
| | | materialVoucher.UNAME = po.UNAME; |
| | | materialVoucher.F_QTY = item.qty; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | #endregion |
| | | |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("计划外退料回调报错" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | #endregion |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("计划外退料回调报错" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | //} |
| | | /// <summary> |
| | |
| | | public static async Task<SimpleResult> CXAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, string start) |
| | | { |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | | var result = new SimpleResult(); |
| | | |
| | | var result = new SimpleResult(); |
| | | |
| | | |
| | | try |
| | | try |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | |
| | | string GZRQ = ""; |
| | | if (po.BUDAT != null) |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | |
| | | string GZRQ = ""; |
| | | if (po.BUDAT != null) |
| | | //来源冲销凭证对应的物料凭证信息 |
| | | //var poIn = db.Queryable<TN_Inbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == po.S_BS_NO).First(); |
| | | //根据入库查看凭证编号信息 |
| | | //var poIPz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == poIn.S_NO).First(); |
| | | //出库回调入参 |
| | | CXCkBackDto.Root myRoot = new CXCkBackDto.Root |
| | | { |
| | | ROOT = new CXCkBackDto.ROOT |
| | | { |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | |
| | | //来源冲销凭证对应的物料凭证信息 |
| | | //var poIn = db.Queryable<TN_Inbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == po.S_BS_NO).First(); |
| | | //根据入库查看凭证编号信息 |
| | | //var poIPz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == poIn.S_NO).First(); |
| | | //出库回调入参 |
| | | CXCkBackDto.Root myRoot = new CXCkBackDto.Root |
| | | { |
| | | ROOT = new CXCkBackDto.ROOT |
| | | HEAD = new List<CXCkBackDto.HEAD> |
| | | { |
| | | HEAD = new List<CXCkBackDto.HEAD> |
| | | { |
| | | |
| | | //GZRQ = GZRQ, |
| | | //SRRQ = PZZDRQ, |
| | | //WLPZ = po.S_WLPZ, |
| | | //WLPZNF = po.S_WLPZNF, |
| | | //WLPZXM = MaterList[0].N_ROW_NO, |
| | | //GZRQ = GZRQ, |
| | | //SRRQ = PZZDRQ, |
| | | //WLPZ = po.S_WLPZ, |
| | | //WLPZNF = po.S_WLPZNF, |
| | | //WLPZXM = MaterList[0].N_ROW_NO, |
| | | |
| | | //GZRY = po.UNAME |
| | | } |
| | | //GZRY = po.UNAME |
| | | } |
| | | }; |
| | | List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>(); |
| | | //出库单详情 |
| | | var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO).ToList(); |
| | | foreach (var item in MaterList) |
| | | { |
| | | CXCkBackDto.HEAD hEAD = new CXCkBackDto.HEAD(); |
| | | hEAD.GZRQ = GZRQ; |
| | | hEAD.SRSJ = DateTime.Now.ToString("yyyyMMdd"); |
| | | } |
| | | }; |
| | | List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>(); |
| | | //出库单详情 |
| | | var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList(); |
| | | foreach (var item in MaterList) |
| | | { |
| | | CXCkBackDto.HEAD hEAD = new CXCkBackDto.HEAD(); |
| | | hEAD.GZRQ = GZRQ; |
| | | hEAD.SRSJ = DateTime.Now.ToString("yyyyMMdd"); |
| | | |
| | | //hEAD.WLPZ = porecord.Where(s => s.S_WLBM == item.item_code && s.S_WLH == item.N_ROW_NO).First()?.S_WLPZBH; |
| | | //hEAD.WLPZNF = porecord.Where(s=>s.S_WLBM==item.item_code&&s.S_WLH==item.N_ROW_NO).First()?.S_WLPZND; |
| | |
| | | //hEAD.WLPZ = porecord.First()?.S_WLPZBH; |
| | | //hEAD.WLPZNF = porecord.First()?.S_WLPZND; |
| | | |
| | | hEAD.WLPZ = po.S_WLPZ; |
| | | hEAD.WLPZNF = po.S_WLPZND; |
| | | hEAD.WLPZ = porecord.FirstOrDefault()?.S_WLPZBH; |
| | | hEAD.WLPZNF = porecord.FirstOrDefault()?.S_WLPZND; |
| | | hEAD.WLPZXM = item.N_ROW_NO; |
| | | hEAD.GZRY = po.UNAME; |
| | | listhead.Add(hEAD); |
| | | } |
| | | myRoot.ROOT.HEAD = listhead; |
| | | |
| | | #region wms-sap回调 |
| | | |
| | | |
| | | |
| | | //类转json |
| | | var json = JsonConvert.SerializeObject(myRoot.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"冲销出库回调xml数据{xml}"); |
| | | |
| | | ZSCM2_CXPZ service = new ZSCM2_CXPZ(); |
| | | service.PreAuthenticate = true; |
| | | service.Url = service.Url + "?sap-language=ZH"; |
| | | // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); |
| | | // 准备请求参数 |
| | | ZfmScm2CxpzMm001 request = new ZfmScm2CxpzMm001(); |
| | | request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; |
| | | LogHelper.Info($"通用冲销SAP回调"); |
| | | // 调用Web Service |
| | | ZfmScm2CxpzMm001Response responses = service.ZfmScm2CxpzMm001(request); |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("通用冲销SAP返回结果: " + responses.Output); |
| | | |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString()); |
| | | var resmeg = ""; |
| | | int rescode = 0; |
| | | //添加凭证记录表 |
| | | if (data!=null) |
| | | { |
| | | List<MaterialVoucher> materiallist = new List<MaterialVoucher>(); |
| | | foreach (var item in data.ROOT.ITEM) |
| | | { |
| | | if (item.MSGCODE == 0) |
| | | { |
| | | |
| | | var onr = MaterList.Where(s => s.N_ROW_NO == item.WLPZHXM).First(); |
| | | |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLPZBH = item?.WLPZBH; |
| | | materialVoucher.S_WLPZND = item?.WLPZND; |
| | | materialVoucher.S_WLPZHXM = item?.WLPZHXM; |
| | | |
| | | materialVoucher.S_YWLPZBH = item?.YWLPZBH; |
| | | materialVoucher.S_YWLPZND = item?.YWLPZND; |
| | | materialVoucher.S_YWLPZHXM = item?.YWLPZHXM; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.F_QTY = onr.qty; |
| | | //materialVoucher.STATUS = 0; |
| | | resmeg += item?.MSGDESP; |
| | | materiallist.Add(materialVoucher); |
| | | |
| | | |
| | | } |
| | | else { |
| | | rescode = 1; |
| | | } |
| | | |
| | | |
| | | } |
| | | if (materiallist.Count()>0) |
| | | { |
| | | |
| | | db.Insertable<MaterialVoucher>(materiallist).ExecuteCommand(); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | result.resultMsg = resmeg; |
| | | result.resultCode = rescode; |
| | | #endregion |
| | | |
| | | //db.CommitTran(); |
| | | hEAD.GZRY = po.UNAME; |
| | | listhead.Add(hEAD); |
| | | } |
| | | catch (Exception ex) |
| | | myRoot.ROOT.HEAD = listhead; |
| | | |
| | | #region wms-sap回调 |
| | | |
| | | |
| | | |
| | | //类转json |
| | | var json = JsonConvert.SerializeObject(myRoot.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"冲销出库回调xml数据{xml}"); |
| | | |
| | | ZSCM2_CXPZ service = new ZSCM2_CXPZ(); |
| | | service.PreAuthenticate = true; |
| | | service.Url = service.Url + "?sap-language=ZH"; |
| | | // service.Credentials = new NetworkCredential("CONN_RFC", "Init.1234"); |
| | | // 准备请求参数 |
| | | ZfmScm2CxpzMm001 request = new ZfmScm2CxpzMm001(); |
| | | request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml; |
| | | LogHelper.Info($"通用冲销SAP回调"); |
| | | // 调用Web Service |
| | | ZfmScm2CxpzMm001Response responses = service.ZfmScm2CxpzMm001(request); |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("通用冲销SAP返回结果: " + responses.Output); |
| | | |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | EnsureArrayFormat(jsonObject, "ITEM", ""); |
| | | var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString()); |
| | | var resmeg = ""; |
| | | int rescode = 0; |
| | | //添加凭证记录表 |
| | | if (data != null) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("通用冲销回调报错" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | List<MaterialVoucher> materiallist = new List<MaterialVoucher>(); |
| | | foreach (var item in data.ROOT.ITEM) |
| | | { |
| | | if (item.MSGCODE == 0) |
| | | { |
| | | |
| | | throw; |
| | | var onr = MaterList.Where(s => s.N_ROW_NO == item.WLPZHXM).FirstOrDefault(); |
| | | |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLPZBH = item?.WLPZBH; |
| | | materialVoucher.S_WLPZND = item?.WLPZND; |
| | | materialVoucher.S_WLPZHXM = item?.WLPZHXM; |
| | | |
| | | materialVoucher.S_YWLPZBH = item?.YWLPZBH; |
| | | materialVoucher.S_YWLPZND = item?.YWLPZND; |
| | | materialVoucher.S_YWLPZHXM = item?.YWLPZHXM; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.S_GZRQ = po.BUDAT; |
| | | materialVoucher.UNAME = po.UNAME; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | |
| | | materialVoucher.F_QTY = onr == null ? 0 : onr.qty; |
| | | //materialVoucher.STATUS = 0; |
| | | resmeg += item?.MSGDESP; |
| | | materiallist.Add(materialVoucher); |
| | | |
| | | |
| | | } |
| | | else |
| | | { |
| | | rescode = 1; |
| | | resmeg += item?.MSGDESP; |
| | | } |
| | | |
| | | |
| | | } |
| | | if (materiallist.Count() > 0) |
| | | { |
| | | |
| | | db.Insertable<MaterialVoucher>(materiallist).ExecuteCommand(); |
| | | } |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | result.resultMsg = resmeg; |
| | | result.resultCode = rescode; |
| | | #endregion |
| | | |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("通用冲销回调报错" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | |
| | | |
| | | /// <summary> |
| | | /// 普通回调接口 |
| | |
| | | { |
| | | //using (var db = new SqlHelper<object>().GetInstance()) |
| | | //{ |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | var result = new SimpleResult(); |
| | | |
| | | try |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | var result = new SimpleResult(); |
| | | |
| | | try |
| | | { |
| | | //库位信息 |
| | | var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == start).First(); |
| | | //出库单详情 |
| | | var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First(); |
| | | string GZRQ = ""; |
| | | string PZZDRQ = ""; |
| | | if (po.BUDAT != null) |
| | |
| | | |
| | | //回参物料信息 |
| | | List<CkBcakDto.ITEM> iTEMs = new List<CkBcakDto.ITEM>(); |
| | | foreach (var item in MaterList) |
| | | { |
| | | |
| | | db.BeginTran(); |
| | | |
| | | foreach (var item in MaterList) |
| | | { |
| | | |
| | | var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); |
| | | CkBcakDto.ITEM ckbitem = new CkBcakDto.ITEM(); |
| | | ckbitem.SCDD = podetail?.S_SCDD; |
| | | ckbitem.ZJBM = podetail?.S_ZJBM; |
| | | ckbitem.FHSL = item.qty; |
| | | ckbitem.DW = podetail?.S_UOM; |
| | | ckbitem.YLBH = podetail?.S_YLBH; |
| | | ckbitem.YLXMH = podetail?.S_YLXMH; |
| | | ckbitem.GC = po.S_FACTORY; |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | db.BeginTran(); |
| | | |
| | | CkBcakDto.ITEM1 listitem1 = new CkBcakDto.ITEM1(); |
| | | //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.item_code&&a.N_ROW_NO==item.N_ROW_NO).ToList(); |
| | | ////string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | //var serialNos = string.Join(",", CntrItemRels |
| | | // .Where(s => s.S_ITEM_CODE == item.item_code) |
| | | // .Select(s => s.S_SERIAL_NO)); |
| | | listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | //foreach (var xlhValue in xlhValues) |
| | | //{ |
| | | // CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue }; |
| | | // listitem1.Add(newItem); |
| | | //} |
| | | ckbitem.ITEM1 = listitem1; |
| | | iTEMs.Add(ckbitem); |
| | | } |
| | | |
| | | var podetail = po.Details.Where(s => s.S_ITEM_CODE == item.item_code).FirstOrDefault(); |
| | | CkBcakDto.ITEM ckbitem = new CkBcakDto.ITEM(); |
| | | ckbitem.SCDD = podetail?.S_SCDD; |
| | | ckbitem.ZJBM = podetail?.S_ZJBM; |
| | | ckbitem.FHSL = item.qty; |
| | | ckbitem.DW = podetail?.S_UOM; |
| | | ckbitem.YLBH = podetail?.S_YLBH; |
| | | ckbitem.YLXMH = podetail?.S_YLXMH; |
| | | ckbitem.GC = po.S_FACTORY; |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | |
| | | CkBcakDto.ITEM1 listitem1 = new CkBcakDto.ITEM1(); |
| | | //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.item_code&&a.N_ROW_NO==item.N_ROW_NO).ToList(); |
| | | ////string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | | //var serialNos = string.Join(",", CntrItemRels |
| | | // .Where(s => s.S_ITEM_CODE == item.item_code) |
| | | // .Select(s => s.S_SERIAL_NO)); |
| | | listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | //foreach (var xlhValue in xlhValues) |
| | | //{ |
| | | // CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue }; |
| | | // listitem1.Add(newItem); |
| | | //} |
| | | ckbitem.ITEM1 = listitem1; |
| | | iTEMs.Add(ckbitem); |
| | | } |
| | | myRoot.ROOT.WLPZ.ITEM = iTEMs; |
| | | //db.Insertable<OutboundRecord>(records).ExecuteCommand(); |
| | | #region wms-sap回调 |
| | | //类转json |
| | | var json = JsonConvert.SerializeObject(myRoot.ROOT); |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | //json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"出库xml数据{xml}"); |
| | | //// 创建 StringContent 并指定媒体类型为 "text/xml" |
| | |
| | | LogHelper.Info("出库SAP返回结果: " + responses.Output); |
| | | |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); |
| | | //添加凭证记录表 |
| | | result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | foreach (var item in MaterList) |
| | | { |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLBM = item.item_code; |
| | | materialVoucher.S_WLH = item.N_ROW_NO; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.F_QTY = item.qty; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | } |
| | | ////添加凭证记录表 |
| | | //result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | //result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | //MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | //materialVoucher.S_NO = po.S_NO; |
| | | //materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | //materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; |
| | | //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | //materialVoucher.STATUS = 0; |
| | | //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | #endregion |
| | | |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); |
| | | //添加凭证记录表 |
| | | result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("普通出库回调" + |
| | | "" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | |
| | | throw; |
| | | foreach (var item in MaterList) |
| | | { |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | materialVoucher.S_WLBM = item.item_code; |
| | | materialVoucher.S_WLH = item.N_ROW_NO; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZ; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.F_QTY = item.qty; |
| | | materialVoucher.S_GZRQ = po.BUDAT; |
| | | materialVoucher.UNAME = po.UNAME; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | } |
| | | return result; |
| | | ////添加凭证记录表 |
| | | //result.resultMsg = data.ROOT.ITEM.MSGDESP; |
| | | //result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | //MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | //materialVoucher.S_NO = po.S_NO; |
| | | //materialVoucher.S_TYPE = po.S_OUT_TYPE; |
| | | //materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; |
| | | //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | //materialVoucher.STATUS = 0; |
| | | //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | #endregion |
| | | |
| | | //db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //db.RollbackTran(); |
| | | LogHelper.Info("普通出库回调" + |
| | | "" + ex.Message); |
| | | Console.WriteLine(ex.Message); |
| | | |
| | | throw; |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | //} |
| | | |
| | |
| | | |
| | | try |
| | | { |
| | | if (MaterList.Count()<1) |
| | | if (MaterList.Count() < 1) |
| | | { |
| | | throw new Exception("累计码盘数量物料数据为空"); |
| | | } |
| | |
| | | else |
| | | { |
| | | //2.插入新的容器物料信息(容器号不变S_SERIAL_NO = item.S_SERIAL_NO,) |
| | | cir = new CntrItemRel { S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM=info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no }; |
| | | cir = new CntrItemRel { S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM = info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no }; |
| | | db.Insertable<CntrItemRel>(cir).ExecuteCommand(); |
| | | } |
| | | var count = db.Queryable<CntrItemRel>().Count(a => a.S_CNTR_CODE == cntr.S_CODE); |
| | |
| | | else |
| | | { |
| | | //var az = db.Queryable<AZInventory>().ToList(); |
| | | var po1 = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(),UNAME=po.UNAME, S_FACTORY = po.S_FACTORY,S_CBZX=po.S_CBZX,S_ZZKM=po.S_ZZKM,S_LRZX=po.S_LRZX, BLDAT = po.BLDAT, BUDAT=po.BUDAT, S_OUT_TYPE = po.S_OUT_TYPE, S_BS_TYPE = po.S_BS_TYPE, S_AREA_CODE = po.S_AREA_CODE, S_BS_NO = po.S_NO }; |
| | | var po1 = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(), UNAME = po.UNAME, S_FACTORY = po.S_FACTORY, S_CBZX = po.S_CBZX, S_ZZKM = po.S_ZZKM, S_LRZX = po.S_LRZX, BLDAT = po.BLDAT, BUDAT = po.BUDAT, S_OUT_TYPE = po.S_OUT_TYPE, S_BS_TYPE = po.S_BS_TYPE, S_AREA_CODE = po.S_AREA_CODE, S_BS_NO = po.S_NO }; |
| | | |
| | | po1.Details = new List<TN_Outbound_Detail>(); |
| | | if (po.Details.Count() > 0) |
| | |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = model.S_NO; |
| | | materialVoucher.S_TYPE = po.S_IN_TYPE; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | |
| | | } |
| | | else LogHelper.Info($"入库单明细无值"); |
| | | #endregion |
| | | |
| | | var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_BS_NO == model.S_NO).ToList(); |
| | | if (po == null) |
| | | { |
| | |
| | | { |
| | | materialVoucher.S_NO = model.S_NO; |
| | | materialVoucher.S_TYPE = po.S_IN_TYPE; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | |
| | | if (po.S_IN_TYPE == "计划外退料入库") |
| | | { |
| | | DateTime dateTime; |
| | | DateTime dateTime1 ; |
| | | DateTime dateTime1; |
| | | string GZRQ = ""; |
| | | string PZZDRQ = ""; |
| | | if (po.BUDAT!=null) |
| | | if (po.BUDAT != null) |
| | | { |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | if (po.BLDAT != null) |
| | | { |
| | | PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd"); |
| | | |
| | | |
| | | } |
| | | JHWBackDto.Root myRoot = new JHWBackDto.Root |
| | | { |
| | |
| | | |
| | | } |
| | | }, |
| | | |
| | | |
| | | } |
| | | }; |
| | | //回参物料信息 |
| | |
| | | ckbitem.KCDD = podetail?.S_KCDD; |
| | | ckbitem.PC = podetail?.S_BATCH_NO; |
| | | #region MyRegion |
| | | // List<JHWBackDto.ITEM1> listitem1 = new List<JHWBackDto.ITEM1>(); |
| | | // List<JHWBackDto.ITEM1> listitem1 = new List<JHWBackDto.ITEM1>(); |
| | | JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1(); |
| | | listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList(); |
| | | ////string[] xlhValues = item.S_SERIAL_NO.Split(','); |
| | |
| | | ////类转json |
| | | var json = JsonConvert.SerializeObject(myRoot.ROOT); |
| | | ////json转xml |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml; |
| | | |
| | | LogHelper.Info($"计划外退料xml数据{xml}"); |
| | | LogHelper.Info($"计划外退料xml数据{xml}"); |
| | | //// 创建 StringContent 并指定媒体类型为 "text/xml" |
| | | //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml"); |
| | | //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData"; |
| | |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | | materialVoucher.S_TYPE = po.S_IN_TYPE; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH; |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = model.S_NO; |
| | | materialVoucher.S_TYPE = po.S_IN_TYPE; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZBH; |
| | | materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH; |
| | | LogHelper.Info("值1: " + data.ROOT.ITEM?.WLPZH); |
| | | LogHelper.Info("值2: " + materialVoucher.S_WLPZBH); |
| | | materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND; |
| | | materialVoucher.STATUS = 0; |
| | | db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | |
| | | else if (po.S_IN_TYPE == "冲销入库") |
| | | { |
| | | |
| | | //var materpz = db.Queryable<TN_Inbound_Order>().Where(s => s.S_NO == po.S_NO).First(); |
| | | var materpz = db.Queryable<TN_Inbound_Order>().Where(s => s.S_NO == po.S_NO).First(); |
| | | string GZRQ = ""; |
| | | LogHelper.Info($"冲销入库入库{po.BUDAT}"); |
| | | if (po.BUDAT != null) |
| | | { |
| | | GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd"); |
| | | } |
| | | |
| | | |
| | | //出库回调入参 |
| | | CXCkBackDto.Root roots = new CXCkBackDto.Root |
| | | { |
| | |
| | | List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>(); |
| | | //出库单详情 |
| | | LogHelper.Info($"冲销入库入库{GZRQ}"); |
| | | var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList(); |
| | | var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO && a.STATUS == 0).ToList(); |
| | | //var podet = db.Queryable<tn_i>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList(); |
| | | LogHelper.Info($"数量{porecord.Count()}"); |
| | | LogHelper.Info($"数量{po.Details.Count()}"); |
| | |
| | | // 确保HTTP成功状态值 |
| | | response.EnsureSuccessStatusCode(); |
| | | LogHelper.Info($"冲销入库xml数据{xml}"); |
| | | |
| | | |
| | | |
| | | ZSCM2_CXPZ service = new ZSCM2_CXPZ(); |
| | | service.PreAuthenticate = true; |
| | |
| | | LogHelper.Info($"通用冲销SAP回调"); |
| | | // 调用Web Service |
| | | ZfmScm2CxpzMm001Response responses = service.ZfmScm2CxpzMm001(request); |
| | | |
| | | |
| | | |
| | | // 处理响应 |
| | | LogHelper.Info("通用冲销SAP返回结果: " + responses.Output); |
| | | |
| | | |
| | | |
| | | //string xmlqqq = "<ROOT>\r\n\t<ITEM>\r\n\t\t<YWLPZBH>490062947</YWLPZBH>\r\n\t\t<YWLPZND>2025</YWLPZND>\r\n\t\t<YWLPZHXM>001</YWLPZHXM>\r\n\t\t<WLPZBH>490062949</WLPZBH>\r\n\t\t<WLPZND>\r\n\t\t</WLPZND>\r\n\t\t<WLPZHXM>D0001</WLPZHXM>\r\n\t\t<MSGCODE>0</MSGCODE>\r\n\t\t<MSGDESP>数据接收成功,并冲中销成功!</MSGDESP>\r\n\t</ITEM>\r\n</ROOT>"; |
| | | // 将 XmlDocument 转换为 JSON 字符串 |
| | | //JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | |
| | | XmlDocument xmlDoc = new XmlDocument(); |
| | | xmlDoc.LoadXml(responses.Output.ToString()); |
| | | JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc)); |
| | | |
| | | EnsureArrayFormat(jsonObject, "ITEM", ""); |
| | | //var data = JsonConvert.DeserializeObject<ReturnJHWBcak.Root>(jsonObject.ToString()); |
| | | var data = JsonConvert.DeserializeObject<ReturnTYBcak.Root>(jsonObject.ToString()); |
| | | var resmeg = ""; |
| | |
| | | if (item.MSGCODE == 0) |
| | | { |
| | | |
| | | var onr = po.Details.Where(s => s.N_ROW_NO == item.WLPZHXM).First(); |
| | | var onr = po.Details.Where(s => s.N_ROW_NO == item.WLPZHXM).FirstOrDefault(); |
| | | |
| | | MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | materialVoucher.S_NO = po.S_NO; |
| | |
| | | materialVoucher.S_YWLPZHXM = item?.YWLPZHXM; |
| | | materialVoucher.S_WH_CODE = po.S_WH_CODE; |
| | | materialVoucher.S_AREA_CODE = po.S_AREA_CODE; |
| | | materialVoucher.F_QTY = onr.F_QTY; |
| | | materialVoucher.F_QTY = onr != null ? onr.F_QTY : 0; |
| | | //materialVoucher.STATUS = 0; |
| | | resmeg += item?.MSGDESP; |
| | | materiallist.Add(materialVoucher); |
| | |
| | | } |
| | | else |
| | | { |
| | | rescode = 1; |
| | | rescode = 1; resmeg += item?.MSGDESP; |
| | | } |
| | | |
| | | |