22

schangxiang@126.com

2024-12-23 164f2cf0a8d85a2ebd2955f8f322d5f6bb4d3857

 CC/iWareCC_ASRS/ThreadService/01_BZ01¹¤Î»£¨Çå»Ò£¬Ï´°åºó¹¤Î»£©/DataProcess_BZ01.cs

@@ -11,6 +11,7 @@
using System.Linq;
using System.Net.NetworkInformation;
using System.Reflection.Emit;
using System.Security.Cryptography.X509Certificates;
using System.ServiceModel.Configuration;
using System.Text;
using System.Threading;
@@ -24,6 +25,8 @@
    /// </summary>
    public static class DataProcess_BZ01
    {
        public static string timingForWait = "";//定时器，等待数据

        /// <summary>
        /// BZ01工位（清灰，洗板后工位）
        /// </summary>
@@ -31,6 +34,8 @@
        {
            var alertMsg = "";
            LogType logType = LogType.DataProcess_BZ01;
            string lastUpi = "";//最后记录的UPI数据

            while (true)
            {
                Thread.Sleep(1000);//休眠2秒，将休眠写到前面，是为了下面的continue方法执行后不显示错误信息的提示！！！【EditBy shaocx,2022-05-24】
@@ -44,6 +49,7 @@
                            SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"正在干出库模式，此方法暂停。。 ";
                            continue;
                        }


                        var rgvLocation = StationLocationEnum.BZ01.ToString();
                        /*
@@ -64,7 +70,49 @@
                                SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-请求了解码，但是结果是空的,此次循环结束";
                                continue;
                            }

                            if (lastUpi == result)
                            {
                                //寻找上次的BZ01验证记录 
                                using (WmsDBModel wmsDB = new WmsDBModel())
                                {
                                    var lastRecord = wmsDB.wms_record_upi_process.Where(x => x.Upi == lastUpi && x.Location == "BZ01").OrderByDescending(x => x.Id).FirstOrDefault();
                                    if (lastRecord != null)
                                    {
                                        //取是否 é½åŒ…
                                        bool my_qitaoReault = false;
                                        if (lastRecord.UpiStatus == (int)UpiStatusEnum.已齐包)
                                        {
                                            my_qitaoReault = true;
                                        }
                                        //推送PLC
                                        using (StationServiceClient client = new StationServiceClient())
                                        {
                                            var res = await client.WriteQiTaoInfoAsync((int)EDevice.Station, rgvLocation, my_qitaoReault);
                                            if (!res.result)
                                            {
                                                SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-【单独推送PLC】推送齐套结果失败,WriteQiTaoInfoAsync返回:{res.resMsg}";
                                                continue;
                                            }
                                            else
                                            {
                                                Log4NetHelper.WriteInfoLog(logType, $"{rgvLocation.ToString()}-【单独推送PLC】推送齐套结果成功,WriteQiTaoInfoAsync，参数: ç«™ç‚¹{rgvLocation},齐套结果:{my_qitaoReault}");
                                                SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-【单独推送PLC】推送齐套结果成功";
                                                continue;
                                            }
                                        }
                                    }
                                    else
                                    {
                                        SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-重复的UPI{result}";
                                        continue;
                                    }
                                }
                            }
                            //*/
                            var upiCode = result;


                            var qitaoReault = false;//齐包结果
                            using (WmsDBModel wmsDB = new WmsDBModel())
                            {
@@ -85,6 +133,97 @@
                                    continue;
                                }

                                //增加对参数配置的管理 ã€Editby shaocx,2024-12-13】
                                var sysConfig = wmsDB.SysConfig.Where(x => x.Code == "LastUpi_BZ01").FirstOrDefault();
                                if (sysConfig == null)
                                {
                                    SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"没有获取到 LastUpi_BZ01的配置信息 ";
                                    continue;
                                }
                                var config_value = sysConfig.Value;
                                if (config_value.IndexOf('|') > -1)
                                {//格式为  åŒ…号|UPI|次序|齐包状态
                                    var arr = config_value.Split('|');
                                    var lastPackageCode = arr[0];
                                    var lastUpi_BZ01 = arr[1];
                                    var lastShelf = Convert.ToInt32(arr[2]);
                                    var lastQitaoReault = arr[3];

                                    if (upiObj.PackageCode == lastPackageCode)
                                    {
                                        if (upiObj.Shelf == (lastShelf + 1))
                                        {
                                            //齐包状态
                                            if (lastQitaoReault == "齐包")
                                            {
                                                qitaoReault = true;
                                            }
                                            else
                                            {
                                                qitaoReault = false;
                                            }
                                        }
                                        else
                                        {//不齐包
                                            qitaoReault = false;
                                        }
                                    }
                                    else
                                    {//说明是换了包号，重新验证 é½åŒ…状态
                                        #region è®¡ç®—是否齐包
                                        qitaoReault = ValidateQiBao(wmsDB, upiObj);
                                        #endregion
                                    }
                                }
                                else
                                {//表示还没有配置 ï¼Œé‡æ–°éªŒè¯ é½åŒ…状态
                                    #region è®¡ç®—是否齐包
                                    qitaoReault = ValidateQiBao(wmsDB, upiObj);
                                    #endregion
                                }

                                //增加优化验证 ã€Editby shaocx,2024-12-16】
                                if (qitaoReault == false)
                                {
                                    var lastPackageUpi_269 = FormCC.Globle_269_LastPackageUpi;
                                    if (!string.IsNullOrEmpty(lastPackageUpi_269))
                                    {
                                        var arr = lastPackageUpi_269.Split('|');
                                        if (upiObj.PackageCode == arr[0])
                                        {//最后一次在269扫描的包号 è·Ÿ çŽ°åœ¨BZ01的包号一致,要等待
                                         //wait
                                            var isWaitOutTime = Wait269(wmsDB);
                                            if (isWaitOutTime == false)
                                            {
                                                continue;
                                            }
                                        }
                                        else
                                        {
                                            //继续往下走
                                        }
                                    }
                                    else
                                    {
                                        //wait
                                        var isWaitOutTime = Wait269(wmsDB);
                                        if (isWaitOutTime == false)
                                        {
                                            continue;
                                        }
                                    }
                                }

                                timingForWait = "";//重置数据
                                if (qitaoReault == false)
                                {
                                    upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区;
                                }
                                else
                                {
                                    upiObj.AreaCode = (int)AreaCodeEnum.码垛区域;
                                }
                                /*
                                //查询是否齐包
                                var allList = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == upiObj.PackageCode).ToList();
                                var isQiTaoList = allList.Where(x => x.AreaCode == (int)AreaCodeEnum.待缓存分拣区
@@ -119,15 +258,97 @@
                                        }
                                        else
                                        {
                                            qitaoReault = true;
                                            upiObj.AreaCode = (int)AreaCodeEnum.码垛区域;
                                            var isJiXuValidate = true;
                                            if (upiObj.Shelf != 1)
                                            {
                                                var qianmianList = allList.Where(x => x.Shelf < upiObj.Shelf).ToList();
                                                //看以前的板在哪里，必须都在 ç åž›åŒºåŸŸ
                                                var yiqianQuyu = AreaCodeEnum.码垛区域;
                                                var count_MD = qianmianList.Where(x => x.AreaCode == (int)yiqianQuyu).Count();
                                                if (count_MD != qianmianList.Count())
                                                {
                                                    isJiXuValidate = false;
                                                    qitaoReault = false;
                                                    upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区;
                                                }
                                            }

                                            if (isJiXuValidate)
                                            {//是否继续验证
                                                //还需要验证在这些区域中，是否正确排队，如果没有正确排队，那么就认为不齐套 ã€Editby shaocx,2024-12-12】
                                                var queueList = wmsDB.mes_upi_linequeue.Where(x => x.PackageCode == upiObj.PackageCode && x.AreaCode == queryAreaCode)
                                                    .OrderBy(x => x.Id).ToList();
                                                var fisrtId = queueList.OrderBy(x => x.Id).First().Id;
                                                var endId = queueList.OrderByDescending(x => x.Id).First().Id;
                                                //继续查询这个时间段内的队列数据
                                                //重写该队列
                                                queueList = wmsDB.mes_upi_linequeue.Where(x => x.Id >= fisrtId && x.Id <= endId).OrderBy(x => x.Id).ToList();
                                                var syCount = allList.Where(x => x.Shelf >= upiObj.Shelf).Count();
                                                if (queueList.Count() != syCount)
                                                {
                                                    qitaoReault = false;
                                                    upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区;
                                                }
                                                else
                                                {
                                                    //判断是否乱序
                                                    bool isLuanXuan = false;
                                                    int temp_shelf = 0;
                                                    for (int i = 0; i < queueList.Count; i++)
                                                    {
                                                        if (i == 0)
                                                        {
                                                            temp_shelf = queueList[i].Shelf;
                                                            if (temp_shelf != upiObj.Shelf)
                                                            {
                                                                qitaoReault = false;
                                                                isLuanXuan = true;
                                                                upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区;
                                                                break;//跳出循环
                                                            }
                                                            if (queueList[i].Upi != upiObj.UPI)
                                                            {
                                                                qitaoReault = false;
                                                                isLuanXuan = true;
                                                                upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区;
                                                                break;//跳出循环
                                                            }
                                                        }
                                                        else
                                                        {
                                                            temp_shelf = temp_shelf + 1;
                                                            if (temp_shelf != queueList[i].Shelf)
                                                            {//认为乱序了
                                                                qitaoReault = false;
                                                                isLuanXuan = true;
                                                                upiObj.AreaCode = (int)AreaCodeEnum.缓存分拣区;
                                                                break;//跳出循环
                                                            }
                                                        }
                                                    }

                                                    if (isLuanXuan == false)
                                                    {
                                                        qitaoReault = true;
                                                        upiObj.AreaCode = (int)AreaCodeEnum.码垛区域;
                                                    }
                                                }
                                            }
                                        }

                                        //注意：要删除该队列数据哦
                                        wmsDB.mes_upi_linequeue.Remove(lastUpiLineQueue);
                                    }
                                }
                                //*/
                                //if (qitaoReault == false) {
                                //    //临时
                                //    SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"模拟啊啊，暂停啊啊";
                                //    continue;
                                //}


                                lastUpi = upiCode;
                                using (StationServiceClient client = new StationServiceClient())
                                {
                                    var res = await client.WriteQiTaoInfoAsync((int)EDevice.Station, rgvLocation, qitaoReault);
@@ -140,6 +361,19 @@
                                    {
                                        Log4NetHelper.WriteInfoLog(logType, $"{rgvLocation.ToString()}-推送齐套结果成功,WriteQiTaoInfoAsync，参数: ç«™ç‚¹{rgvLocation},齐套结果:{qitaoReault}");
                                    }
                                }

                                var str_qitaoReault = (qitaoReault ? "齐包" : "不齐包");
                                //记录下结果
                                sysConfig.Value = upiObj.PackageCode + "|" + upiObj.UPI + "|" + upiObj.Shelf + "|" + str_qitaoReault;

                                //删除该UPI的缓存队列数据
                                int queryAreaCode2 = (int)AreaCodeEnum.待缓存分拣区;
                                var curUpiLineQueue = wmsDB.mes_upi_linequeue.Where(x => x.Upi == upiObj.UPI && x.AreaCode == queryAreaCode2)
                               .FirstOrDefault();
                                if (curUpiLineQueue != null)
                                {
                                    wmsDB.mes_upi_linequeue.Remove(curUpiLineQueue);
                                }

                                //更新UPI状态
@@ -155,19 +389,37 @@
                                        item.UpiStatus = (int)UpiStatusEnum.不齐包;
                                    }
                                }
                                //更新包状态 [Editby shaocx,2024-12-15]
                                var packageObj = wmsDB.mes_package_gather.Where(x => x.PackageCode == upiObj.PackageCode).FirstOrDefault();
                                if (packageObj != null)
                                {
                                    if (qitaoReault)
                                    {
                                        packageObj.UpiStatus = (int)UpiStatusEnum.已齐包;
                                        packageObj.IsQiBao = true;
                                    }
                                    else
                                    {
                                        packageObj.UpiStatus = (int)UpiStatusEnum.不齐包;
                                        packageObj.IsQiBao = false;
                                    }
                                }

                                //更新 æœ€åŽä¸€æ¬¡åœ¨ BZ_01的系统处理的板件 æ•°æ®
                                var rbRunMode = wmsDB.wms_rbline_runmode.FirstOrDefault();
                                rbRunMode.UPI = upiObj.UPI;
                                rbRunMode.PlanNo = upiObj.PlanNo;
                                rbRunMode.OrderId = upiObj.OrderId;
                                rbRunMode.PackageCode = upiObj.PackageCode;

                                WmsRecordUpiProcessHandler.SaveWmsRecordUpiProcess(wmsDB, upiObj, "BZ01", "齐包验证:" + (qitaoReault ? "齐包" : "不齐包"));
                                WmsRecordUpiProcessHandler.SaveWmsRecordUpiProcess(wmsDB, upiObj, "BZ01", "齐包验证:" + str_qitaoReault);

                                wmsDB.SaveChanges();
                            }
                        }
                        else
                        {
                            SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"{rgvLocation.ToString()}-没有要处理的数据";
                            using (WmsDBModel wmsDB = new WmsDBModel())
                            {
                                var isAllow = IsAllloRunOutTaskMode(wmsDB, null);
@@ -183,6 +435,46 @@
            }
        }

        /// <summary>
        /// è¶…时验证
        /// </summary>
        /// <param name="wmsDB"></param>
        /// <param name="time"></param>
        /// <returns>true:超时 false：未超时</returns>
        private static bool Wait269(WmsDBModel wmsDB)
        {
            var bz30Config = wmsDB.SysConfig.Where(x => x.Code == "Wait_269").FirstOrDefault();
            if (bz30Config == null)
            {
                SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"没有配置 Wait_269 å€¼";
                return false;
            }
            int i = 0;
            bool right = int.TryParse(bz30Config.Value, out i);
            if (right == false)
            {
                SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"配置 Wait_269 å€¼ä¸æ˜¯æ•´æ•°";
                return false;
            }

            if (string.IsNullOrEmpty(timingForWait))
            {
                timingForWait = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            }

            string time = timingForWait;
            //在269扫描的时间
            var time_269 = Convert.ToDateTime(time);
            TimeSpan ts = DateTime.Now - time_269;
            var sec = ts.Seconds;
            if (sec >= i)
            {
                //超时
                return true;
            }
            SystemWarningMsg._lbl_alert_DataProcess_BZ01 = $"配置 Wait_269 å€¼æ˜¯{i},当前间隔是{sec}秒,未超时。开始等待时间{timingForWait}";
            return false;
        }

        /// <summary>
        /// æ˜¯å¦å¯ä»¥æ‰§è¡Œå‡ºåº“模式
@@ -192,6 +484,10 @@
        /// <returns></returns>
        private static bool IsAllloRunOutTaskMode(WmsDBModel wmsDB, mes_batchOrderUPI_new curUpiObj)
        {
            //不再判断 ã€Editby shaocx,2024-12-14】
            return false;

            /*
            //首先查询数据库中是否有 è¦å‡ºåº“的数据
            var isExistOutTaskForNewCreated = wmsDB.wms_rbline_task.Where(x =>
            (x.RbTaskType == (int)RbTaskTypeEnum.齐包出库任务 || x.RbTaskType == (int)RbTaskTypeEnum.强制出库任务)
@@ -259,7 +555,123 @@

            FormCC.IsAllowRunOutMode = true;
            return true;

            //*/
        }

        /// <summary>
        /// åˆ¤æ–­æ˜¯å¦é½åŒ…
        /// </summary>
        /// <param name="wmsDB"></param>
        /// <param name="upiObj"></param>
        /// <returns></returns>
        private static bool ValidateQiBao(WmsDBModel wmsDB, mes_batchOrderUPI_new upiObj)
        {
            if (upiObj.Shelf != 1)
            {
                return false;
            }
            //查询是否齐包
            var allList = wmsDB.mes_batchOrderUPI_new.Where(x => x.PackageCode == upiObj.PackageCode).ToList();
            var isQiTaoList = allList.Where(x => x.AreaCode == (int)AreaCodeEnum.待缓存分拣区
            ||
            x.AreaCode == (int)AreaCodeEnum.码垛区域
            ).ToList();
            if (isQiTaoList.Count() != allList.Count())
            {//不齐包
                return false;
            }
            else
            {//齐包
             //这里再增加个逻辑，必须是按照次序进入的才真正的算齐包 [Editby shaocx,2024-12-06]
             //寻找本包内的前一块板的位置
                int queryAreaCode = (int)AreaCodeEnum.待缓存分拣区;
                var lastUpiLineQueue = wmsDB.mes_upi_linequeue.Where(x => x.PackageCode == upiObj.PackageCode && x.AreaCode == queryAreaCode)
                    .OrderBy(x => x.Id).FirstOrDefault();//查询该包队列的第一块板
                if (lastUpiLineQueue == null)
                {//说明 é˜Ÿåˆ—中没有该包的数据
                    return false;
                }
                else
                {
                    if (lastUpiLineQueue.Shelf != upiObj.Shelf)
                    {
                        return false;
                    }
                    else
                    {
                        var isJiXuValidate = true;
                        if (upiObj.Shelf != 1)
                        {
                            var qianmianList = allList.Where(x => x.Shelf < upiObj.Shelf).ToList();
                            //看以前的板在哪里，必须都在 ç åž›åŒºåŸŸ
                            var yiqianQuyu = AreaCodeEnum.码垛区域;
                            var count_MD = qianmianList.Where(x => x.AreaCode == (int)yiqianQuyu).Count();
                            if (count_MD != qianmianList.Count())
                            {
                                isJiXuValidate = false;
                                return false;
                            }
                        }

                        if (isJiXuValidate)
                        {//是否继续验证
                         //还需要验证在这些区域中，是否正确排队，如果没有正确排队，那么就认为不齐套 ã€Editby shaocx,2024-12-12】
                            var queueList = wmsDB.mes_upi_linequeue.Where(x => x.PackageCode == upiObj.PackageCode && x.AreaCode == queryAreaCode)
                                .OrderBy(x => x.Id).ToList();
                            var fisrtId = queueList.OrderBy(x => x.Id).First().Id;
                            var endId = queueList.OrderByDescending(x => x.Id).First().Id;
                            //继续查询这个时间段内的队列数据
                            //重写该队列
                            queueList = wmsDB.mes_upi_linequeue.Where(x => x.Id >= fisrtId && x.Id <= endId).OrderBy(x => x.Id).ToList();
                            var syCount = allList.Where(x => x.Shelf >= upiObj.Shelf).Count();
                            if (queueList.Count() != syCount)
                            {
                                return false;
                            }
                            else
                            {
                                //判断是否乱序
                                bool isLuanXuan = false;
                                int temp_shelf = 0;
                                for (int i = 0; i < queueList.Count; i++)
                                {
                                    if (i == 0)
                                    {
                                        temp_shelf = queueList[i].Shelf;
                                        if (temp_shelf != upiObj.Shelf)
                                        {
                                            isLuanXuan = true;
                                            return false;
                                        }
                                        if (queueList[i].Upi != upiObj.UPI)
                                        {
                                            isLuanXuan = true;
                                            return false;
                                        }
                                    }
                                    else
                                    {
                                        temp_shelf = temp_shelf + 1;
                                        if (temp_shelf != queueList[i].Shelf)
                                        {//认为乱序了
                                            isLuanXuan = true;
                                            return false;
                                        }
                                    }
                                }

                                if (isLuanXuan == false)
                                {
                                    return true;
                                }
                            }
                        }
                    }
                }
            }

            return false;
        }
    }
}