1
pulg
4 天以前 dc600c6298a3231e05875813ec0fa2fa18151d84
HH.WCS.QingXiNongfu/core/TaskCore.cs
@@ -91,6 +91,61 @@
                                TaskProcess.OperateStatus(wmsTask, 7);
                                wmsTask.T_END_TIME = DateTime.Now;
                                TaskHelper.UpdateStatus(wmsTask, "取消");
                                try
                                {
                                    if (wmsTask.S_TYPE.Contains("注塑满托-入库"))
                                    {
                                        var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_START_LOC)).FirstOrDefault();
                                        if (plc != null)
                                        {
                                            for (var i = 0; i < plc.location.Length; i++)
                                            {
                                                if (wmsTask.S_START_LOC == plc.location[i])
                                                {
                                                    PlcHelper.SendHex(plc.address, "3F00" + (i + 1) + "0" + "0d0a");
                                                    break;
                                                }
                                            }
                                        }
                                    }
                                    else if (wmsTask.S_TYPE.Contains("注塑空拖-出库"))
                                    {
                                        var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_END_LOC)).FirstOrDefault();
                                        if (plc != null)
                                        {
                                            for (var i = 0; i < plc.location.Length; i++)
                                            {
                                                if (wmsTask.S_END_LOC == plc.location[i])
                                                {
                                                    PlcHelper.SendHex(plc.address, "3F00" + (i + 1) + "0" + "0d0a");
                                                    break;
                                                }
                                            }
                                        }
                                    }
                                    else if (wmsTask.S_TYPE.Contains("瓶坯翻斗机满托-出库"))
                                    {
                                        var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_END_LOC)).FirstOrDefault();
                                        if (plc != null)
                                        {
                                            PlcHelper.SendHex(plc.address, "3F00110D0A");
                                        }
                                    }
                                    else if (wmsTask.S_TYPE.Contains("瓶坯翻斗机空托-入库"))
                                    {
                                        var plc = Settings.GetDeviceInfoList().Where(a => a.location.Any(str => str == wmsTask.S_START_LOC)).FirstOrDefault();
                                        if (plc != null)
                                        {
                                            PlcHelper.SendHex(plc.address, "3F00110D0A");
                                        }
                                    }
                                }
                                catch (Exception ex)
                                {
                                    throw;
                                }
                                break;
                            case 8://强制完成  -  未使用
                                r = TaskProcess.OperateStatus(wmsTask, 8);
@@ -98,7 +153,7 @@
                                    TaskHelper.BeEnd(wmsTask);
                                break;
                            case 9://强制取消  //起点解绑锁释放 终点锁释放
                                   // var R = NDCHelper.CancelS(model.No);
                                r = TaskProcess.OperateStatus(wmsTask, 9);
                                if (r.ResultCode != -1)
                                {
@@ -389,6 +444,9 @@
                var info = db.Queryable<KuRong>().First();
                if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min)
                {
                    db.Deleteable<KuRong>().ExecuteCommand();
                    info = null;
                    //1、查到小板库区下面所有的库位
                    var totalX = 0;
                    var totalRows = 0;
@@ -486,9 +544,21 @@
                    }
                    var totalDesiredCapacity = ordersCount * 4 * 3 * (totalX / totalRows);
                    LogHelper.Error($"成品小板区总货位是{totalX},总排数是{totalRows},当前执行工单数量是{ordersCount}", new Exception("Kurong"));
                    var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity);
                    var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity;
                    list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; });
                    //var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity);
                    //var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity;
                    //list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; });
                    var totalAvailableCapacity = list.Sum(a => a.MaxCapacity);// AvailableCapacity);
                    var DRC = list.Sum(x => x.FilledCapacity);
                    var totalAssignableCapacity = totalAvailableCapacity - DRC - totalDesiredCapacity;
                    var BAC = list.Sum(x => x.AvailableCapacity);
                    list.ForEach(a =>
                    {
                        a.DesiredCapacity = totalDesiredCapacity;
                        a.CRC = totalAvailableCapacity;
                        a.RAC = totalAssignableCapacity;
                        a.BAC = BAC;
                        a.DRC = DRC;
                    });
                    if (info == null)
                    {
                        /*​SQL Server​   1000 条/批次   单个 INSERT 语句最多支持 1000 条 VALUES 子句,超出会报语法错误。*/