lss
2025-05-20 fe442ab8c9ba6648b140f253902b4ef24c5618bf
HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/process/DeviceProcess.cs
@@ -47,13 +47,13 @@
        /// <summary>
        /// 叠盘机空托返回
        /// </summary>    
        internal static void Traystacker(string loc, int qty)
        internal static void Traystacker(string loc, int qty, int type)
        {
            try
            {
                //上传数据
                Traystacker result1 = new Traystacker(){ station = loc, taskSource = 1, Qty = qty };
                Traystacker result1 = new Traystacker() { station = loc, taskSource = 1, Qty = qty, dpType = type };
                HttpHelper httpHelper = new HttpHelper();
                Result result = new Result();
                string date = JsonConvert.SerializeObject(result1);
@@ -81,7 +81,7 @@
            }
            catch (Exception ex)
            {
                LogHelper.Info($"叠盘机空托返回  Error=>{ex.ToString()}");
                LogHelper.Error($"叠盘机空托返回  Error=>{ex.ToString()}", ex);
            }
        }
@@ -148,7 +148,7 @@
                        var mst = WCSHelper.GetTaskByStartloc(item.S_CODE);
                        if (mst == null)
                        {
                            Traystacker(item.S_CODE, item.N_CURRENT_NUM);
                            Traystacker(item.S_CODE, item.N_CURRENT_NUM, 1);
                        }
                    }
                }
@@ -161,25 +161,44 @@
        internal static void DpjTraffic()
        {
            string startBti = "CMB17-DP-001";
            var value = S7Helper.ReadDpj(2014, S7.Net.VarType.Int);
            if (value >= 7)
            try
            {
                //var cntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == item.S_CODE).ToList();
                //if (cntr.Count > 0)
                //{
                //    var cntrcodes = cntr.Select(a => a.S_CNTR_CODE).ToArray();
                //    cntrcode = string.Join(",", cntrcodes);
                //}
                var IsDp = S7Helper.ReadDpj(2001, S7.Net.VarType.Byte);
                var value = S7Helper.ReadDpj(2014, S7.Net.VarType.Int);
                //创建过未完成的任务不发起请求
                var mst = WCSHelper.GetTaskByStartloc(startBti);
                if (mst == null)
                if (value >= 1 && IsDp == 1)
                {
                    Traystacker(startBti, value);
                    //var cntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == item.S_CODE).ToList();
                    //if (cntr.Count > 0)
                    //{
                    //    var cntrcodes = cntr.Select(a => a.S_CNTR_CODE).ToArray();
                    //    cntrcode = string.Join(",", cntrcodes);
                    //}
                    //创建过未完成的任务不发起请求
                    var mst = WCSHelper.GetTaskByStartloc(startBti);
                    if (mst == null)
                    {
                        Traystacker(startBti, value, 2);
                    }
                    else
                    {
                        LogHelper.Info($"有执行中的叠盘回库任务{mst.S_CODE},不触发叠盘任务");
                    }
                }
                else
                {
                    LogHelper.Info($"叠盘机数量:{value},叠盘信号:{IsDp},不触发叠盘任务");
                }
                Thread.Sleep(8000);
            }
            catch (Exception ex)
            {
                LogHelper.Error($"ReadDpj DpjTraffic:{ex}", ex);
            }
        }
        /// <summary>
        /// 原材料库接口访问