blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
hudong
2025-05-30 1db2dcbec358ed43724e8621d7d99981ba4c1ad2 
 api/WmsSpaHelper.cs


@@ -30,7 +30,6 @@


using System.Security.Policy;


using HH.WCS.Mobox3.pinggao.models;


using static HH.WCS.Mobox3.pinggao.wms.WMSHelper;


using WHTest;


using System.Net;


using SqlSugar;


using static HH.WCS.Mobox3.pinggao.models.SapRoot.GYSDto;


@@ -46,6 +45,34 @@




        }




        public static bool MaterPanduan(string ItemCode,double count) {


            bool panduan = true;


            var db = new SqlHelper<object>().GetInstance();




            var po = db.Queryable<TN_Material_KC>().Where(a => a.S_ITEM_CODE == ItemCode).First();




            var po1 = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == ItemCode).First();


            if (po != null)


            {


                if (po1!=null)


                {


                    double sl= po1.F_QTY + count;


                    if (sl>po.N_COUNT)


                    {


                        panduan = false;


                    }


                }


                if (count > po.N_COUNT)


                {


                    panduan = false;


                }


            }


            else


            {


                panduan = false;


            }


            return panduan;


        }


        /// <summary>


        /// 数据


        /// </summary>


@@ -424,6 +451,17 @@


                            }


                            foreach (var item in items.ITEM)


                            {


                              //bool v=  MaterPanduan(item.WLBM, item.SL);


                              //  if (!v)


                              //  {


                              //      result.resultMsg = "失败";


                              //      result.WLPZBH = items.HEAD.WLPZH;


                              //      result.resultCode = 1;


                              //      result.WLPZND = items.HEAD.WLPZND;


                              //      result.resultMsg = $"物料{item.WLBM}数量超过 库存总数";


                              //      simpleResults.Add(result);


                              //      continue;


                              //  }


                                ///判断是否都有冲销凭证编号


                                if (string.IsNullOrEmpty(item.CXPZH))


                                {


@@ -1134,9 +1172,9 @@




                                            result.resultCode = 1;


                                            result.resultMsg = $"物料{a.WLBM}物料主数据不存在该物料";


                                            result.resultMsg = "失败";


                                            result.WLPZBH = itemwlpz.HEAD.WLPZH;


                                            result.WLPZND = itemwlpz.HEAD.ND;


                                            simpleResults.Add(result);


                                            continue;


                                            /*  throw new Exception($"物料{a.WLH}物料主数据不存在该物料")*/


                                            ;


@@ -1261,12 +1299,13 @@


                            }


                        }


                    }


                    result.resultMsg = "成功";


                    result.WLPZBH = itemwlpz.HEAD.WLPZH;


                    result.WLPZND = itemwlpz.HEAD.ND;


                    result.resultCode = 0;


                    result.resultMsg = "";


                    simpleResults.Add(result);




                    var result2 = new SimpleResult();


                    result2.resultMsg = "成功";


                    result2.WLPZBH = itemwlpz.HEAD.WLPZH;


                    result2.WLPZND = itemwlpz.HEAD.ND;


                    result2.resultCode = 0;


                    simpleResults.Add(result2);


                    db.CommitTran();


                }


            }


@@ -1756,7 +1795,7 @@


                result.resultMsg = "成功";


                result.resultCode = 0;


                //校验入库单数量，不可以超，成功后插入托盘物料表，更新入库单累计数量


                result = AddInboundOrder(model.MaterList, model.cntr_code);


                result = AddInboundOrder(model.MaterList, model.cntr_code,model.cntr_type);


                #region MyRegion






@@ -1854,13 +1893,17 @@


                        return result;


                    }


                    //判断托盘是否已经生成任务，如果没有则生成


                    var wmsTaskcs = WMSHelper.GetWmsTaskByCntr(model.cntr_code);


                    if (wmsTaskcs != null)


                    if (!string.IsNullOrEmpty(model.cntr_code))


                    {


                        result.resultCode = 3;


                        result.resultMsg = $"起点{model.start} 托盘{model.cntr_code}已经创建任务，请勿重复申请";


                        return result;


                        var wmsTaskcs = WMSHelper.GetWmsTaskByCntr(model.cntr_code);


                        if (wmsTaskcs != null)


                        {


                            result.resultCode = 3;


                            result.resultMsg = $"起点{model.start} 托盘{model.cntr_code}已经创建任务，请勿重复申请";


                            return result;


                        }


                    }


                   


                    //出库


                    if (model.Type==2)


                    {


@@ -1881,6 +1924,15 @@


                            {


                                start= db.Queryable<Location>().Where(it => it.S_CODE == loc.S_LOC_CODE).First();


                            }


                        }


                        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")


                                   .Select((lcr, cir, loc) => loc).ToList()  // 返回 Location 对象


                                   .FirstOrDefault();  // 或者 Take(1).ToList()[0]


                        }


                        else


                        {


@@ -1908,7 +1960,7 @@


                            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")


                                    .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]


                        }


@@ -1952,6 +2004,7 @@


                        Location end = new Location();


                        if (!string.IsNullOrEmpty(model.cntr_code))


                        {


                          


                            #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();


@@ -2087,7 +2140,11 @@


                    }




                    //通用接口 对容器货品的删减 和生成回库单 都要用的接口


                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE);


                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE,model.cntr_type);


                    if (result.resultCode==1)


                    {


                        return result;


                    }


                    #region 升降量




                    bool adds = true;


@@ -2184,7 +2241,7 @@


                            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}无需要升降量的物料");


@@ -2195,6 +2252,7 @@


                }


                catch (Exception e)


                {


                    LogHelper.Info($"报错{e.Message}");


                    result.resultMsg = e.Message;


                    db.RollbackTran();


                    return result;


@@ -2203,7 +2261,7 @@


            }




        }


        public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE)


        public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE,string cntr_type)


        {


            // var db = new SqlHelper<object>().GetInstance();


            //using (var db = new SqlHelper<object>().GetInstance())


@@ -2234,6 +2292,7 @@


                        if (cir != null)


                        {


                            cir.F_QTY -= item.qty;


                            cir.S_CNTR_TYPE = cntr_type;


                            cir.F_ALLOC_QTY -= item.qty;


                            cir.T_MODIFY = DateTime.Now;


                            if (cir.F_QTY == 0)


@@ -2242,10 +2301,8 @@


                            }


                            else


                            {


                                db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();


                                db.Updateable(cir).UpdateColumns(it => new { it.F_QTY,it.S_CNTR_TYPE, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();


                                //添加回库作业






                            }


                        }


                        else


@@ -2256,31 +2313,7 @@


                            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;


@@ -2300,14 +2333,65 @@


                        return result;


                    }


                }


                db.Insertable<OutboundRecord>(records).ExecuteCommand();


                if (isHK)


                {


                    var locs= db.Queryable<WCSTask>().Where(a =>a.S_TYPE.Contains("出库")&& a.S_CNTR_CODE == cntr_code&&a.N_B_STATE==3).OrderByDescending(s=>s.T_END_TIME).First();


                    if (locs!=null)


                    {


                        var cntr= db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_DC_NO== locs.S_BS_NO).First();


                        if (cntr!=null)


                        {


                            cntr.S_SORT_TYPE = "已分拣";


                            db.Updateable(cntr).UpdateColumns(it => new { it.S_SORT_TYPE }).ExecuteCommand();


                        }


                        else


                        {


                            result.resultCode = 1;


                            result.resultMsg += $"任务{locs.S_CODE}来源号{locs.S_BS_NO}找不到配盘信息";


                            return result;


                        }


                            //var location = db.Queryable<Location>().Where(a => a.S_CODE == locs.S_LOC_CODE).First();


                            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 = locs?.S_START_LOC,


                                S_END_AREA = locs?.S_START_AREA,


                                S_END_WH = locs?.S_START_WH,




                                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}";


                        }


                    }


                    else


                    {


                        result.resultCode = 1;


                        result.resultMsg += $"找不到容器对应任务信息{cntr_code}";


                        return result;


                    }


                  


                }


               var sss= db.Insertable<OutboundRecord>(records).ExecuteCommand();


              


                //db.CommitTran();


            }


            catch (Exception ex)


            {


                //db.RollbackTran();


                LogHelper.Info("物料信息绑定到满容器上" + ex.Message);


                result.resultCode = 1;


                result.resultMsg += ex.Message;


                Console.WriteLine(ex.Message);




                throw;


@@ -3055,7 +3139,7 @@


        /// <param name="cntr_code"></param>


        /// <returns></returns>


        [ApiExplorerSettings(IgnoreApi = true)]


        public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code)


        public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code,string S_CNTR_TYPE)


        {


            var result = new SimpleResult();


            //  var db = new SqlHelper<object>().GetInstance();


@@ -3100,12 +3184,13 @@


                                    if (cir != null)


                                    {


                                        cir.F_QTY += item.qty;


                                        db.Updateable(cir).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();


                                        cir.S_CNTR_TYPE = S_CNTR_TYPE;


                                        db.Updateable(cir).UpdateColumns(it => new { it.F_QTY,it.S_CNTR_TYPE }).ExecuteCommand();


                                    }


                                    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_TYPE= S_CNTR_TYPE, 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);


@@ -4071,7 +4156,7 @@


                        // 准备请求参数


                        ZscmNc request = new ZscmNc();


                        request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml;


                        LogHelper.Info($"内采SAP回调");


                        LogHelper.Info($"内采SAP回调{service.Url}");


                        // 调用Web Service


                        ZscmNcResponse responses = service.ZscmNc(request);