| | |
| | | using static HH.WCS.Mobox3.pinggao.models.SapRoot.GYSDto; |
| | | using System.Web.Services.Protocols; |
| | | using System.Web.Http.ValueProviders; |
| | | using System.Diagnostics; |
| | | using System.Data.SqlClient; |
| | | using System.Data.Common; |
| | | using System.Data; |
| | | using System.Runtime.ConstrainedExecution; |
| | | using HH.WCS.Mobox3.pinggao.core; |
| | | |
| | | namespace HH.WCS.Mobox3.pinggao.api |
| | | { |
| | |
| | | |
| | | } |
| | | |
| | | public static bool MaterPanduan(string ItemCode,double count) { |
| | | public static bool MaterPanduan(string ItemCode, double count) |
| | | { |
| | | bool panduan = true; |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | |
| | | } |
| | | |
| | | } |
| | | }else |
| | | } |
| | | else |
| | | { |
| | | |
| | | //冲销凭证单号 |
| | |
| | | db.Deleteable<TN_Supplier_detial>().Where(it => it.S_DO_GYSBM == po.S_GYSBM).ExecuteCommand(); |
| | | |
| | | } |
| | | 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 , |
| | | 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, |
| | |
| | | }; |
| | | db.BeginTran(); |
| | | List<WLReturnRoot.ITEM> list = new List<WLReturnRoot.ITEM>(); |
| | | |
| | | |
| | | var itemCodes = model.ROOT.ITEM.Select(item => item.WLBM).ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => itemCodes.Contains(it.S_ITEM_CODE)) |
| | | .ToList(); |
| | | |
| | | foreach (var item in model.ROOT.ITEM) |
| | | { |
| | | try |
| | |
| | | |
| | | var result = new WLReturnRoot.ITEM(); |
| | | |
| | | var materlist = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == item.WLBM).First(); |
| | | var materlist = itemlist.Where(it => it.S_ITEM_CODE == item.WLBM).First(); |
| | | if (materlist == null) |
| | | { |
| | | TN_Material tN_Material = new TN_Material(); |
| | |
| | | po.Details = new List<TN_Ll_detail>(); |
| | | if (itemwlpz.ITEM.Count() > 0) |
| | | { |
| | | var itemCodes = itemwlpz.ITEM.Select(items => items.WLBM).ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => itemCodes.Contains(it.S_ITEM_CODE)) |
| | | .ToList(); |
| | | foreach (var a in itemwlpz.ITEM) |
| | | { |
| | | var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First(); |
| | | |
| | | |
| | | |
| | | var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).First(); |
| | | if (item == null) |
| | | { |
| | | |
| | |
| | | List<TN_Ll_detail> listtn = new List<TN_Ll_detail>(); |
| | | if (po.N_B_STATE != 0) |
| | | { |
| | | var itemCodes = itemwlpz.ITEM.Select(items => items.WLBM).ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => itemCodes.Contains(it.S_ITEM_CODE)) |
| | | .ToList(); |
| | | foreach (var a in itemwlpz.ITEM) |
| | | { |
| | | |
| | | |
| | | |
| | | //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断 |
| | | //{ |
| | | // result.resultCode = 1; |
| | |
| | | var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList(); |
| | | if (po1.Count() == 0) //无则新增物料明细 |
| | | { |
| | | var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First(); |
| | | var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).First(); |
| | | if (item == null) |
| | | { |
| | | |
| | |
| | | }//执行中订单 |
| | | else if (po.N_B_STATE == 0)//未执行 执行增删改操作 |
| | | { |
| | | var itemCodes = itemwlpz.ITEM.Select(items => items.WLBM).ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => itemCodes.Contains(it.S_ITEM_CODE)) |
| | | .ToList(); |
| | | foreach (var a in itemwlpz.ITEM) |
| | | { |
| | | //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断 |
| | | //{ |
| | | // var po1 = po.Details.Where(s => a.WLH == s.S_ITEM_CODE).ToList(); |
| | | // if (po1.Count() > 0) //无则新增物料明细 |
| | | // { |
| | | // db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLH && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand(); |
| | | // } |
| | | // else |
| | | // { |
| | | // result.resultCode = 1; |
| | | // result.resultMsg = $"物料{a.WLH}物料数据不存在 无法删除"; |
| | | // throw new Exception($"物料{a.WLH}物料数据不存在 无法删除"); |
| | | // } |
| | | //} |
| | | //else |
| | | //{ |
| | | var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList(); |
| | | if (po1.Count() == 0) //无则新增物料明细 |
| | | { |
| | | var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First(); |
| | | var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).First(); |
| | | if (item == null) |
| | | { |
| | | |
| | |
| | | /// <returns></returns> |
| | | internal static List<SimpleResult> Otherbound_Order_In(otherDto.Root model) |
| | | { |
| | | Stopwatch sw = new Stopwatch(); |
| | | sw.Start(); |
| | | LogHelper.Info($"其他出入库调试"); |
| | | List<SimpleResult> simples = new List<SimpleResult>(); |
| | | using (var db = new SqlHelper<object>().GetInstance()) |
| | |
| | | |
| | | try |
| | | { |
| | | var itemlist = db.Queryable<TN_Material>().ToList(); |
| | | List<TN_Inbound_Detail> tN_Inbound_Details = new List<TN_Inbound_Detail>(); |
| | | List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>(); |
| | | |
| | | foreach (var itemwlpz in model.ROOT.WLPZ) |
| | | { |
| | | |
| | | var itemCodes = itemwlpz.ITEM.Select(item => item.WLBH).ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => itemCodes.Contains(it.S_ITEM_CODE)) |
| | | .ToList(); |
| | | var result = new SimpleResult(); |
| | | |
| | | db.BeginTran(); |
| | |
| | | |
| | | { |
| | | |
| | | #region 不需要 |
| | | //if (a.ITEM1.Select(s => s.XLH).Count() > 0)//判断序列号是否为多个 |
| | | //{ |
| | | // foreach (var item in a.ITEM1.Select(s => s.XLH)) |
| | | // { |
| | | // po.Details.Add(new TN_Inbound_Detail |
| | | // { |
| | | // S_IO_NO = model.ROOT.WLPZ.HEAD.WLPZBH, |
| | | // N_ROW_NO = po.Details.Count + 1, |
| | | // S_ITEM_CODE = a.WLH, |
| | | // F_QTY = a.SL, |
| | | // S_ITEM_STATE = "物料", |
| | | // S_ITEM_NAME = "物料", |
| | | // F_ACC_B_QTY = 0, |
| | | // S_KCDD = a.KCDD, |
| | | // S_UOM = a.JBJLDW,//计量单位 |
| | | // S_SERIAL_NO = item, |
| | | // S_BATCH_NO = a.PC, |
| | | // }); |
| | | // } |
| | | //} |
| | | //else |
| | | //{ |
| | | #endregion |
| | | LogHelper.Info($"效验{a.ITEM1}"); |
| | | po.Details.Add(new TN_Inbound_Detail |
| | | { |
| | |
| | | else |
| | | { |
| | | |
| | | #region |
| | | ////创建入库单主子表 |
| | | //var po = WMSHelper.GetOutboundOrder(model.ROOT.WLPZ.HEAD.WLPZBH); |
| | | //if (po == null) |
| | | //{ |
| | | // po = new TN_Outbound_Order { S_NO = model.ROOT.WLPZ.HEAD.WLPZBH, S_AREA_CODE = "HJQ", S_BS_NO = model.ROOT.WLPZ.HEAD.WLPZBH, S_WLPZNF = model.ROOT.WLPZ.HEAD.WLPZNF, S_FACTORY = model.ROOT.WLPZ.ITEM[0].GC, S_OUT_TYPE = "其他出库", S_BS_TYPE = model.ROOT.WLPZ.ITEM[0].YDLX }; |
| | | // po.Details = new List<TN_Outbound_Detail>(); |
| | | // if (model.ROOT.WLPZ.ITEM.Count > 0) |
| | | // { |
| | | // model.ROOT.WLPZ.ITEM.ForEach(a => |
| | | // { |
| | | // //if (a.ITEM1.Select(s => s.XLH).Count() > 0)//判断序列号是否为多个 |
| | | // //{ |
| | | // // foreach (var item in a.ITEM1.Select(s => s.XLH)) |
| | | // // { |
| | | // // po.Details.Add(new TN_Inbound_Detail |
| | | // // { |
| | | // // S_IO_NO = model.ROOT.WLPZ.HEAD.WLPZBH, |
| | | // // N_ROW_NO = po.Details.Count + 1, |
| | | // // S_ITEM_CODE = a.WLH, |
| | | // // F_QTY = a.SL, |
| | | // // S_ITEM_STATE = "物料", |
| | | // // S_ITEM_NAME = "物料", |
| | | // // F_ACC_B_QTY = 0, |
| | | // // S_KCDD = a.KCDD, |
| | | // // S_UOM = a.JBJLDW,//计量单位 |
| | | // // S_SERIAL_NO = item, |
| | | // // S_BATCH_NO = a.PC, |
| | | // // }); |
| | | // // } |
| | | // //} |
| | | // //else |
| | | // //{ |
| | | // po.Details.Add(new TN_Outbound_Detail |
| | | // { |
| | | // S_DO_NO = model.ROOT.WLPZ.HEAD.WLPZBH, |
| | | // N_ROW_NO = a.WLPZHXM, |
| | | // S_ITEM_CODE = a.WLBH, |
| | | // F_QTY = a.SL, |
| | | // S_AREA_CODE = "测试", |
| | | // S_ITEM_NAME = "物料", |
| | | // S_KCDD = a.KCDD, |
| | | // S_UOM = a.JLDW,//计量单位 |
| | | // S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)), |
| | | // S_BATCH_NO = a.PC, |
| | | |
| | | // S_ERP_WH_CODE = a.KCDD, |
| | | // N_ITEM_STATE = 1 |
| | | // }); |
| | | // //} |
| | | |
| | | // }); |
| | | // db.Insertable<TN_Outbound_Order>(po).ExecuteCommand(); |
| | | // db.Insertable<TN_Outbound_Detail>(po.Details).ExecuteCommand(); |
| | | // db.CommitTran(); |
| | | |
| | | // } |
| | | //} |
| | | //else |
| | | //{ |
| | | // result.resultCode = 1; |
| | | // result.resultMsg = "已经有重复单号,不可重复传输"; |
| | | // return result; |
| | | //} |
| | | #endregion |
| | | sw.Stop(); |
| | | LogHelper.Info("第一次" + sw.ElapsedMilliseconds); |
| | | |
| | | #region 创建领料单 |
| | | var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == itemwlpz.HEAD.WLPZBH).First(); |
| | |
| | | N_ROW_NO = a.WLPZHXM, |
| | | S_JDBS = a.JDBS, |
| | | S_ITEM_CODE = a.WLBH, |
| | | S_ITEM_NAME = item.S_ITEM_NAME, |
| | | S_ITEM_NAME = item?.S_ITEM_NAME, |
| | | F_QTY = a.SL, |
| | | S_BATCH_NO = a.PC, |
| | | S_ERP_WH_CODE = a.KCDD, |
| | |
| | | } |
| | | |
| | | var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0; |
| | | db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand(); |
| | | using (var bulkCopy = new SqlBulkCopy(util.Settings.SqlServer)) |
| | | { |
| | | bulkCopy.DestinationTableName = "TN_Picking_Detail"; |
| | | bulkCopy.BatchSize = 500; |
| | | var dataTable = new DataTable(); |
| | | dataTable = po.Details.ToDataTable(); |
| | | // 添加列映射(确保名称匹配) |
| | | foreach (DataColumn col in dataTable.Columns) |
| | | { |
| | | bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName); |
| | | } |
| | | bulkCopy.WriteToServer(po.Details.ToDataTable()); |
| | | } |
| | | //db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand(); |
| | | |
| | | } |
| | | } |
| | |
| | | { |
| | | foreach (var a in itemwlpz.ITEM) |
| | | { |
| | | //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断 |
| | | //{ |
| | | // result.resultCode = 1; |
| | | // result.resultMsg = $"执行中领料单,物料{a.WLH}物料不允许删除"; |
| | | // throw new Exception($"执行中领料单,物料{a.WLH}物料不允许删除"); |
| | | //} |
| | | |
| | | var po1 = po.Details.Where(s => a.WLBH == s.S_ITEM_CODE).ToList(); |
| | | if (po1.Count() == 0) //无则新增物料明细 |
| | | { |
| | |
| | | { |
| | | foreach (var a in itemwlpz.ITEM) |
| | | { |
| | | //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断 |
| | | //{ |
| | | // var po1 = po.Details.Where(s => a.WLH == s.S_ITEM_CODE).ToList(); |
| | | // if (po1.Count() > 0) //无则新增物料明细 |
| | | // { |
| | | // db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLH && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand(); |
| | | // } |
| | | // else |
| | | // { |
| | | // result.resultCode = 1; |
| | | // result.resultMsg = $"物料{a.WLH}物料数据不存在 无法删除"; |
| | | // throw new Exception($"物料{a.WLH}物料数据不存在 无法删除"); |
| | | // } |
| | | //} |
| | | //else |
| | | //{ |
| | | |
| | | var po1 = po.Details.Where(s => a.WLBH == s.S_ITEM_CODE).ToList(); |
| | | if (po1.Count() == 0) //无则新增物料明细 |
| | | { |
| | |
| | | db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand(); |
| | | } |
| | | } |
| | | |
| | | sw.Restart(); |
| | | sw.Stop(); |
| | | LogHelper.Info("第二次" + sw.ElapsedMilliseconds); |
| | | #endregion |
| | | } |
| | | result.WLPZBH = itemwlpz.HEAD.WLPZBH; |
| | |
| | | db.Updateable(tN_Inbound_Details).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | } |
| | | db.CommitTran(); |
| | | |
| | | sw.Restart(); |
| | | sw.Stop(); |
| | | LogHelper.Info("第三次" + sw.ElapsedMilliseconds); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | if (!string.IsNullOrEmpty(model.cntr_code)) |
| | | { |
| | | var loc= db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntr_code).First(); |
| | | |
| | | |
| | | if (loc==null) |
| | | { |
| | | LogHelper.Info($"容器{model.cntr_code}找不到对应货位"); |
| | |
| | | } |
| | | else if (!string.IsNullOrEmpty(model.item_code)) |
| | | { |
| | | start = db.Queryable<LocCntrRel>() |
| | | .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE&&cir.S_CNTR_TYPE=="半托") |
| | | .Where((lcr, cir) => cir.S_CNTR_CODE != null) |
| | | .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE && loc.S_AREA_CODE == "HJQ") |
| | | .OrderBy((lcr, cir) => cir.T_CREATE) |
| | | .Select((lcr, cir, loc) => loc).ToList() // 返回 Location 对象 |
| | | .FirstOrDefault(); // 或者 Take(1).ToList()[0] |
| | | var starts = db.Queryable<CntrItemRel>().Where(cir => cir.S_CNTR_TYPE == "半托" && cir.S_ITEM_CODE == model.item_code).OrderBy(cir => cir.T_CREATE).ToList().FirstOrDefault(); |
| | | LogHelper.Info($"starts{starts}"); |
| | | var starts12 = db.Queryable<LocCntrRel>().Where(lcr => lcr.S_CNTR_CODE== starts.S_CNTR_CODE).ToList().FirstOrDefault(); |
| | | LogHelper.Info($"starts1{starts12}"); |
| | | start = db.Queryable<Location>().Where(loc => loc.S_AREA_CODE == "HJQ" && loc.S_CODE== starts12.S_LOC_CODE).ToList().FirstOrDefault(); |
| | | LogHelper.Info($"starts2{start}"); |
| | | |
| | | model.cntr_code = starts12?.S_CNTR_CODE; |
| | | } |
| | | else |
| | | { |
| | | #region MyRegion |
| | | //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray(); |
| | | //var S_LOC_CODElist = db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray(); |
| | | //start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).First(); |
| | | |
| | | //// 获取所有被占用的容器编码 |
| | | //var usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList(); |
| | | |
| | | //// 获取未被占用的容器对应的货位编码 |
| | | //var availableLocationCodes = db.Queryable<LocCntrRel>() |
| | | // .Where(s => !usedContainerCodes.Contains(s.S_CNTR_CODE)) |
| | | // .Select(s => s.S_LOC_CODE) |
| | | // .ToList(); |
| | | |
| | | //// 获取第一个可用货位(如果没有则返回null) |
| | | //var startLocation = db.Queryable<Location>() |
| | | // .Where(it => availableLocationCodes.Contains(it.S_CODE)) |
| | | // .ToList().FirstOrDefault(); |
| | | var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray(); |
| | | var S_LOC_CODElist = db.Queryable<LocCntrRel>().Where(s => !list.Contains(s.S_CNTR_CODE)).Select(s => s.S_LOC_CODE).ToArray(); |
| | | start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).ToList().FirstOrDefault(); |
| | | |
| | | |
| | | |
| | | |
| | | var starts12 = db.Queryable<LocCntrRel>().Where(lcr => lcr.S_CNTR_CODE == start.S_CODE).ToList().FirstOrDefault(); |
| | | |
| | | |
| | | model.cntr_code = starts12?.S_CNTR_CODE; |
| | | #endregion |
| | | start = db.Queryable<LocCntrRel>() |
| | | .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE) |
| | | .Where((lcr, cir) => cir.S_CNTR_CODE == null) // 找出未被占用的容器 |
| | | .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE && loc.S_AREA_CODE == "HJQ") |
| | | .Select((lcr, cir, loc) => loc).ToList() // 返回 Location 对象 |
| | | .FirstOrDefault(); // 或者 Take(1).ToList()[0] |
| | | } |
| | | if (start==null) |
| | | { |
| | |
| | | return result; |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 创建领料单 |
| | | /// </summary> |
| | | /// <param name="model"></param> |
| | | /// <returns></returns> |
| | | public static LLDReturnRoot.Root Out_Order_In1s(CKDdto.Root model) |
| | | { |
| | | LLDReturnRoot.Root finalRoot = new LLDReturnRoot.Root |
| | | { |
| | | ROOT = new LLDReturnRoot.ROOT |
| | | { |
| | | ITEM = new List<LLDReturnRoot.ITEM> |
| | | { |
| | | |
| | | } |
| | | } |
| | | }; |
| | | List<LLDReturnRoot.ITEM> iTEMs = new List<LLDReturnRoot.ITEM>(); |
| | | var result = new WeiLiResult(); |
| | | using (var db = new SqlHelper<object>().GetInstance()) |
| | | { |
| | | //创建领料单 |
| | | try |
| | | { |
| | | List<WcReturnRoot.ITEM> wcReturnRoots = new List<WcReturnRoot.ITEM>(); |
| | | //删除的集合 |
| | | List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>(); |
| | | List<TN_Ll_detail> iuptN_Ll_Details = new List<TN_Ll_detail>(); |
| | | //db.BeginTran(); |
| | | foreach (var itemscddll in model.ROOT.SCDDLL) |
| | | { |
| | | |
| | | LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM(); |
| | | |
| | | #region |
| | | var po = db.Queryable<TN_Ll_Order>() |
| | | .Includes(a => a.Details) |
| | | .Where(s => s.S_NO == itemscddll.LLDH) |
| | | .First(); |
| | | |
| | | #endregion |
| | | if (po == null) |
| | | { |
| | | po = new TN_Ll_Order { S_NO = itemscddll.LLDH, S_FACTORY = itemscddll.GC, S_OUT_TYPE = "出库", S_BS_TYPE = "出库", S_AREA_CODE = "HJQ", S_BS_NO = itemscddll.LLDH }; |
| | | po.Details = new List<TN_Ll_detail>(); |
| | | if (itemscddll.ITEM.Count() > 0) |
| | | { |
| | | Stopwatch sw = new Stopwatch(); |
| | | sw.Start(); |
| | | foreach (var a in itemscddll.ITEM) |
| | | { |
| | | po.Details.Add(new TN_Ll_detail |
| | | { |
| | | S_DO_NO = itemscddll.LLDH, |
| | | S_AREA_CODE = "HJQ", |
| | | N_ROW_NO = "", |
| | | S_ITEM_CODE = a.WLBM, |
| | | S_ITEM_NAME = "", |
| | | F_QTY = a.XQSL, |
| | | S_ZJBM = a.ZJBM, |
| | | S_YLBH = a.YLBH, |
| | | S_YLXMH = a.YLHXM, |
| | | S_BATCH_NO = "", |
| | | S_ERP_WH_CODE = a.KCDD, |
| | | S_ZJWLTH = a.ZJWLTH, |
| | | S_ZJWLMS = a.ZJWLMS, |
| | | S_ZHFHBS = a.ZHFHBS, |
| | | S_CJRQ = a.CJRQ, |
| | | S_LLDSCBS = a.LLDSCBS, |
| | | S_SCGLY = a.SCGLY, |
| | | S_GXH = a.GXH, |
| | | S_XQRQ = a.XQRQ, |
| | | N_ITEM_STATE = 1 |
| | | }); |
| | | } |
| | | |
| | | |
| | | var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0; |
| | | if (po.Details.Count() > 0) |
| | | { |
| | | using (var bulkCopy = new SqlBulkCopy(util.Settings.SqlServer)) |
| | | { |
| | | bulkCopy.DestinationTableName = "TN_Picking_Detail"; |
| | | bulkCopy.BatchSize = 500; |
| | | var dataTable = new DataTable(); |
| | | dataTable = po.Details.ToDataTable(); |
| | | // 添加列映射(确保名称匹配) |
| | | foreach (DataColumn col in dataTable.Columns) |
| | | { |
| | | bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName); |
| | | } |
| | | bulkCopy.WriteToServer(po.Details.ToDataTable()); |
| | | } |
| | | } |
| | | sw.Stop(); |
| | | long elapsedMilliseconds = sw.ElapsedMilliseconds; |
| | | LogHelper.Info($"生产订单领料单无数据{po.Details.Count()}(生成领料单)添加数据返回时长:" + elapsedMilliseconds); |
| | | } |
| | | } |
| | | } |
| | | |
| | | //db.CommitTran(); |
| | | |
| | | return finalRoot; |
| | | |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM(); |
| | | lLDReturnRoots.GC = ""; |
| | | lLDReturnRoots.LLDH = ""; |
| | | lLDReturnRoots.MSGCODE = 1; |
| | | lLDReturnRoots.MSGDESP = ex.Message; |
| | | iTEMs.Add(lLDReturnRoots); |
| | | finalRoot.ROOT.ITEM = iTEMs; |
| | | db.RollbackTran(); |
| | | |
| | | return finalRoot; |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 创建领料单 |
| | | /// </summary> |
| | |
| | | } |
| | | }; |
| | | List<LLDReturnRoot.ITEM> iTEMs = new List<LLDReturnRoot.ITEM>(); |
| | | |
| | | var result = new WeiLiResult(); |
| | | |
| | | using (var db = new SqlHelper<object>().GetInstance()) |
| | | { |
| | | |
| | | //创建领料单 |
| | | try |
| | | { |
| | | var itemlist = db.Queryable<TN_Material>().ToList(); |
| | | Stopwatch s1w = new Stopwatch(); |
| | | s1w.Start(); |
| | | List<WcReturnRoot.ITEM> wcReturnRoots = new List<WcReturnRoot.ITEM>(); |
| | | |
| | | //删除的集合 |
| | | List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>(); |
| | | List<TN_Ll_detail> iuptN_Ll_Details = new List<TN_Ll_detail>(); |
| | | foreach (var itemscddll in model.ROOT.SCDDLL) |
| | | { |
| | | LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM(); |
| | | |
| | | db.BeginTran(); |
| | | // 预先缓存物料数据(优化点1:批量查询减少数据库访问) |
| | | foreach (var itemscddll in model.ROOT.SCDDLL) |
| | | { |
| | | var wlbmList = itemscddll.ITEM.Select(x => x.WLBM).Distinct().ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => wlbmList.Contains(it.S_ITEM_CODE)) // 使用 IN 查询 |
| | | .ToList(); |
| | | LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM(); |
| | | |
| | | var materialCache = new Dictionary<string, TN_Material>(); |
| | | #region 创建领料单 |
| | | //var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == itemscddll.LLDH).First(); |
| | | var po = db.Queryable<TN_Ll_Order>() |
| | | .Includes(a => a.Details) |
| | | .Where(s => s.S_NO == itemscddll.LLDH) |
| | | .First(); |
| | | |
| | | #endregion |
| | | //var po = WMSHelper.GetOutboundOrder(model.ROOT.SCDDLL.LLDH); |
| | | if (po == null) |
| | |
| | | S_XQRQ = a.XQRQ, |
| | | N_ITEM_STATE = 1 |
| | | }); |
| | | |
| | | } |
| | | |
| | | Stopwatch sw = new Stopwatch(); |
| | | sw.Start(); |
| | | |
| | | if (po.Details.Count() > 0) |
| | | { |
| | | LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM(); |
| | |
| | | lLDReturnRoot1.MSGDESP = $"成功"; |
| | | iTEMs.Add(lLDReturnRoot1); |
| | | var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0; |
| | | db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand(); |
| | | //db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand(); |
| | | using (var bulkCopy = new SqlBulkCopy(util.Settings.SqlServer)) |
| | | { |
| | | bulkCopy.DestinationTableName = "TN_Picking_Detail"; |
| | | bulkCopy.BatchSize = 500; |
| | | var dataTable = new DataTable(); |
| | | dataTable = po.Details.ToDataTable(); |
| | | // 添加列映射(确保名称匹配) |
| | | foreach (DataColumn col in dataTable.Columns) |
| | | { |
| | | bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName); |
| | | } |
| | | bulkCopy.WriteToServer(po.Details.ToDataTable()); |
| | | } |
| | | } |
| | | else |
| | | { |
| | |
| | | lLDReturnRoot1.MSGDESP = $"成功,无数据添加"; |
| | | iTEMs.Add(lLDReturnRoot1); |
| | | } |
| | | |
| | | sw.Stop(); |
| | | long elapsedMilliseconds = sw.ElapsedMilliseconds; |
| | | LogHelper.Info($"生产订单领料单无数据{po.Details.Count()}(生成领料单)添加数据返回时长:" + elapsedMilliseconds); |
| | | } |
| | | } |
| | | else |
| | |
| | | { |
| | | if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断 |
| | | { |
| | | //result.code = 1; |
| | | //result.msg = $"执行中领料单,物料{a.WLBM}物料不允许删除"; |
| | | //throw new Exception($"执行中领料单,物料{a.WLBM}物料不允许删除"); |
| | | lLDReturnRoots.GC = itemscddll.GC; |
| | | lLDReturnRoots.LLDH = itemscddll.LLDH; |
| | | lLDReturnRoots.MSGCODE = 1; |
| | |
| | | var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).FirstOrDefault(); |
| | | if (item == null) |
| | | { |
| | | //result.code = 1; |
| | | //result.msg = $"物料{a.WLBM}物料主数据不存在该物料"; |
| | | //throw new Exception($"物料{a.WLBM}物料主数据不存在该物料"); |
| | | ; |
| | | lLDReturnRoots.GC = itemscddll.GC; |
| | | lLDReturnRoots.LLDH = itemscddll.LLDH; |
| | | lLDReturnRoots.MSGCODE = 1; |
| | |
| | | } |
| | | else //返回失败 |
| | | { |
| | | //result.code = 1; |
| | | //result.msg = $"更新失败,更新数量必须大于当前物料数量{a.WLBM}"; |
| | | //throw new Exception($"更新失败,更新数量必须大于当前物料数量{a.WLBM}"); |
| | | lLDReturnRoots.GC = itemscddll.GC; |
| | | lLDReturnRoots.LLDH = itemscddll.LLDH; |
| | | lLDReturnRoots.MSGCODE = 1; |
| | |
| | | { |
| | | if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断 |
| | | { |
| | | var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList(); |
| | | if (po1.Count() > 0) //无则新增物料明细 |
| | | var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).FirstOrDefault(); |
| | | if (po1 != null) //无则新增物料明细 |
| | | { |
| | | tN_Ll_Details.AddRange(po1); |
| | | tN_Ll_Details.Add(po1); |
| | | // db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLBM && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand(); |
| | | } |
| | | else |
| | |
| | | if (tN_Ll_Details.Count()>0) |
| | | { |
| | | db.Deleteable<TN_Ll_detail>(tN_Ll_Details).ExecuteCommand(); |
| | | |
| | | } |
| | | if (iuptN_Ll_Details.Count() > 0) |
| | | { |
| | | db.Updateable(iuptN_Ll_Details).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand(); |
| | | |
| | | } |
| | | |
| | | ; |
| | | } |
| | | Stopwatch sw1 = new Stopwatch(); |
| | | sw1.Start(); |
| | | //添加数据 |
| | | if (listtn.Count() > 0) |
| | | { |
| | |
| | | lLDReturnRoot1.MSGDESP = $"成功"; |
| | | iTEMs.Add(lLDReturnRoot1); |
| | | db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand(); |
| | | |
| | | } |
| | | else |
| | | { |
| | |
| | | lLDReturnRoot1.MSGDESP = $"成功,无数据添加"; |
| | | iTEMs.Add(lLDReturnRoot1); |
| | | } |
| | | |
| | | sw1.Stop(); |
| | | long elapsedMilliseconds2 = sw1.ElapsedMilliseconds; |
| | | LogHelper.Info("生产订单领料单有数据(生成领料单)添加数据返回时长:" + elapsedMilliseconds2); |
| | | } |
| | | |
| | | } |
| | | |
| | | db.CommitTran(); |
| | | } |
| | | |
| | | |
| | | finalRoot.ROOT.ITEM = iTEMs; |
| | | |
| | | |
| | | s1w.Stop(); |
| | | long elapsedMillisecond1s = s1w.ElapsedMilliseconds; |
| | | LogHelper.Info("生产订单finalRoot.ROOT.ITEM" + elapsedMillisecond1s); |
| | | |
| | | |
| | | |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | finalRoot.ROOT.ITEM = iTEMs; |
| | | db.RollbackTran(); |
| | | |
| | | //result.msg = $"出库单接口异常,异常信息={ex.Message}"; |
| | | //var jsons = CkGetJsonResult(model.ROOT.SCDDLL.LLDH, model.ROOT.SCDDLL.GC, result.code.ToString(), result.msg); |
| | | return finalRoot; |
| | | } |
| | | //LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM(); |
| | | //lLDReturnRoots.GC = model.ROOT.SCDDLL.GC; |
| | | //lLDReturnRoots.LLDH = model.ROOT.SCDDLL.LLDH; |
| | | //lLDReturnRoots.MSGCODE = 0; |
| | | //lLDReturnRoots.MSGDESP = "添加成功"; |
| | | //finalRoot.ROOT.ITEM = lLDReturnRoots; |
| | | |
| | | //var json = CkGetJsonResult(model.ROOT.SCDDLL.LLDH, model.ROOT.SCDDLL.GC, result.code.ToString(), result.msg); |
| | | |
| | | return finalRoot; |
| | | } |
| | | return finalRoot; |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | using (var db = new SqlHelper<object>().GetInstance()) |
| | | { |
| | | |
| | | //创建领料单 |
| | | //mobox创建出库单 |
| | | try |
| | | { |
| | | db.BeginTran(); |
| | | |
| | | #region 创建领料单 |
| | | #region mobox创建出库单 |
| | | var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == S_NO).First(); |
| | | |
| | | #endregion |
| | |
| | | { |
| | | var result1 = db.Insertable<TN_Outbound_Order>(po1).ExecuteCommand() > 0; |
| | | db.Insertable<TN_Outbound_Detail>(po1.Details).ExecuteCommand(); |
| | | po1.Details.Clear(); |
| | | } |
| | | else |
| | | { |
| | |
| | | result.resultMsg = "数据不存在"; |
| | | return result; |
| | | } |
| | | |
| | | List<TN_Inbound_Detail> tN_Inbound_Details = new List<TN_Inbound_Detail>(); |
| | | po.Details= po.Details.Where(d => model.Wlist.Any(w => |
| | | w.S_ITEM_CODE == d.S_ITEM_CODE && |
| | | w.N_ROW_NO == d.N_ROW_NO)) |
| | |
| | | //} |
| | | //wcbkbcitem.ITEM1 = listitem1; |
| | | listitem.Add(wcbkbcitem); |
| | | item.N_B_STATE = 1; |
| | | tN_Inbound_Details.Add(item); |
| | | |
| | | } |
| | | NcRkDto.Root roots = new NcRkDto.Root |
| | |
| | | |
| | | iTEMs.Add(ckbitem); |
| | | |
| | | |
| | | item.N_B_STATE = 1; |
| | | tN_Inbound_Details.Add(item); |
| | | } |
| | | myRoot.ROOT.HEAD.ITEM = iTEMs; |
| | | #region wms-sap回调 |
| | |
| | | } |
| | | wcbkbcitem.ITEM1 = listitem1; |
| | | listitem.Add(wcbkbcitem); |
| | | item.N_B_STATE = 1; |
| | | tN_Inbound_Details.Add(item); |
| | | |
| | | } |
| | | WcRkBc.Root roots = new WcRkBc.Root |
| | |
| | | result.resultCode = data.ROOT.ITEM.MSGCODE; |
| | | if (data.ROOT.ITEM.MSGCODE == 0) |
| | | { |
| | | //MaterialVoucher materialVoucher = new MaterialVoucher(); |
| | | //materialVoucher.S_NO = model.S_NO; |
| | | //materialVoucher.S_TYPE = po.S_IN_TYPE; |
| | | //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(); |
| | | ; |
| | | List<MaterialVoucher> materials = new List<MaterialVoucher>(); |
| | | foreach (var item in model.Wlist) |
| | | { |
| | |
| | | } |
| | | |
| | | } |
| | | //else |
| | | //{ |
| | | // SapReturn sapReturn = new SapReturn(); |
| | | // sapReturn.N_STATUS = 0; |
| | | // sapReturn.S_NO = model.S_NO; |
| | | // sapReturn.S_TYPE = po.S_IN_TYPE; |
| | | // sapReturn.S_JSON = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>"+ xml; |
| | | // db.Insertable<SapReturn>(sapReturn).ExecuteCommand(); |
| | | //} |
| | | |
| | | } |
| | | |
| | |
| | | hEAD.WLPZXM = item.N_ROW_NO; |
| | | hEAD.GZRY = po.UNAME; |
| | | listhead.Add(hEAD); |
| | | item.N_B_STATE = 1; |
| | | tN_Inbound_Details.Add(item); |
| | | } |
| | | roots.ROOT.HEAD = listhead; |
| | | |
| | |
| | | //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand(); |
| | | } |
| | | |
| | | if (tN_Inbound_Details.Count() > 0) |
| | | { |
| | | db.Updateable(tN_Inbound_Details).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); |
| | | } |
| | | var newpodetai= db.Queryable<TN_Inbound_Detail>().Where(a => a.S_IO_NO == model.S_NO).ToList(); |
| | | int cout = newpodetai.Where(s => s.N_B_STATE != 1).Count(); |
| | | if (cout==0) |
| | | { |
| | | po.N_B_STATE = 1; |
| | | db.Updateable(po).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand(); |
| | | } |
| | | |
| | | db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | |
| | | List<OutboundRecord> records = new List<OutboundRecord>(); |
| | | foreach (var item in po) |
| | | { |
| | | var pz= pzs.Where(s=>s.S_WLBM==item.S_ITEM_CODE&&s.S_WLH==item.N_BS_ROW_NO).First(); |
| | | var pz = pzs.Where(s => s.S_WLBM == item.S_ITEM_CODE && s.S_WLH == item.N_BS_ROW_NO).ToList().FirstOrDefault(); |
| | | |
| | | OutboundRecord outboundRecord = new OutboundRecord(); |
| | | outboundRecord.S_NO = item.S_BS_NO; |
| | |
| | | { |
| | | db.BeginTran(); |
| | | List<TN_Material> list = new List<TN_Material>(); |
| | | |
| | | |
| | | var itemCodes = model.ITEM.Select(item => item.WLBM).ToList(); |
| | | var itemlist = db.Queryable<TN_Material>() |
| | | .Where(it => itemCodes.Contains(it.S_ITEM_CODE)) |
| | | .ToList(); |
| | | foreach (var item in model.ITEM) |
| | | { |
| | | var materlist = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == item.WLBM).First(); |
| | | var materlist = itemlist.Where(it => it.S_ITEM_CODE == item.WLBM).First(); |
| | | if (materlist == null) |
| | | { |
| | | TN_Material tN_Material = new TN_Material(); |