blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
czw
2025-07-04 2e5f13ec5bbb47ec3462ee8060d9484691808ae1 
 HH.WCS.QingXiNongfu/core/TaskCore.cs


@@ -3,11 +3,10 @@


using HH.WCS.QingXigongchang.process;


using HH.WCS.QingXigongchang.util;


using HH.WCS.QingXigongchang.wms;


using Newtonsoft.Json;


using System;


using System.Collections.Generic;


using System.Linq;


using System.Web.Configuration;


using System.Xml.Schema;


using static HH.WCS.QingXigongchang.api.ApiModel;




namespace HH.WCS.QingXigongchang.core


@@ -35,7 +34,7 @@


                    && wmsTask.S_B_STATE.Trim() != "强制完成"


                    && wmsTask.S_B_STATE.Trim() != "取消")


                {


                    if (model.State < 8 || model.State > 1000)


                    if (model.State < 10 || model.State > 1000)


                    {


                        if (model.State < 7 && string.IsNullOrEmpty(model.ForkliftNo))


                        {


@@ -97,6 +96,15 @@


                                r = TaskProcess.OperateStatus(wmsTask, 8);


                                if (r.ResultCode != -1)


                                    TaskHelper.BeEnd(wmsTask);


                                break;


                            case 9://强制取消  //起点解绑锁释放 终点锁释放


                                var R = NDCHelper.CancelS(model.No);


                                r = TaskProcess.OperateStatus(wmsTask, 9);


                                if (r.ResultCode != -1)


                                {


                                    wmsTask.T_END_TIME = DateTime.Now;


                                    TaskHelper.UpdateStatus(wmsTask, "取消");


                                }


                                break;






@@ -200,16 +208,16 @@


            var list = TaskHelper.GetTaskListByState("未执行");


            if (list.Count > 0)


            {


                foreach (var mst in list)


                {


                    var dinfo = Settings.GetDeviceInfoList().FindAll(x => x.deviceType == 13);


                    if (dinfo.Find(x => x.location.Contains(mst.S_START_LOC)) != null)


                        mst.N_PRIORITY = 99;


                    else


                    if (dinfo.Find(x => x.location.Contains(mst.S_END_LOC)) != null)


                        mst.N_PRIORITY = 98;


                }


                list = list.OrderByDescending(x => x.N_PRIORITY).ToList();


                //foreach (var mst in list)


                //{


                //    var dinfo = Settings.GetDeviceInfoList().FindAll(x => x.deviceType == 13);


                //    if (dinfo.Find(x => x.location.Contains(mst.S_START_LOC)) != null)


                //        mst.N_PRIORITY = 99;


                //    else


                //    if (dinfo.Find(x => x.location.Contains(mst.S_END_LOC)) != null)


                //        mst.N_PRIORITY = 98;


                //}


                //list = list.OrderByDescending(x => x.N_PRIORITY).ToList();




                list.ForEach(task =>


                {


@@ -381,17 +389,22 @@


                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;


                    var list = new List<KuRong>();


                    var areas = db.Queryable<Location>().Select(x => x.S_AREA_CODE).ToList().FindAll(x => System.Text.RegularExpressions.Regex.IsMatch(x, @"QX-\d+_[A-Z]+")).Select(x => x.Split('_')[0]).Distinct().ToList(); //GetAreas();


                    var areas = db.Queryable<Location>().Select(x => x.S_AREA_CODE).ToList().FindAll(x => x != null && System.Text.RegularExpressions.Regex.IsMatch(x, @"QX-\d+_[A-Z]+")).Select(x => x.Split('_')[0]).Distinct().ToList(); //GetAreas();


                    LogHelper.Info($"KurRongCalc List {JsonConvert.SerializeObject(areas)}");


                    areas.ForEach(area =>


                    {


                        totalX += db.Queryable<Location>().Count(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X"));


                        totalRows += db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")).Select(b => b.N_ROW).Distinct().Count();


                        var aresList = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_")).Select(b => b.S_AREA_CODE).Distinct().ToList();


                        aresList = aresList.Select(a => a.Split('_')[0]).Distinct().ToList();


                        LogHelper.Info($"KurRongCalc aresList {JsonConvert.SerializeObject(aresList)}");


                        aresList.ForEach(a =>


                        {


                            //b => b.S_AREA_CODE == a + "_X"


@@ -406,26 +419,53 @@


                                    var kr = new KuRong() { StorageLoc = a.Split('-')[1] + "-" + b, T_MODIFY = DateTime.Now };


                                    Console.WriteLine(kr.StorageLoc);


                                    //每一排要查一下有没有托盘


                                    var listLoc = db.Queryable<Location>().Where(c => c.S_AREA_CODE.Contains(c.S_AREA_CODE) && c.N_ROW == b && c.N_CURRENT_NUM > 0).ToList();


                                    if (!listLoc.Any())


                                    var listLoc = db.Queryable<Location>().Where(c => c.S_AREA_CODE.Contains(a) && c.N_ROW == b).ToList();//&& c.N_CURRENT_NUM > 0




                                    //如果有正常物料排，就用， 没有或者 空排 ，就用小板


                                    var norAreacode = "";


                                    foreach (var arl in listLoc.GroupBy(x => x.S_AREA_CODE))


                                    {


                                        if (arl.ToList().Find(x => x.S_LOCK_STATE.Contains("空间锁")) == null)


                                        {


                                            if (arl.ToList().Find(x => x.N_CURRENT_NUM > 0) != null)


                                            {


                                                norAreacode = arl.Key;


                                                break;


                                            }


                                        }


                                    }


                                    LogHelper.Info($"KurRongCalc [{a}]-{b} 统计是否正常{norAreacode}");


                                    if (string.IsNullOrEmpty(norAreacode))


                                    {


                                        norAreacode = a + "_X";


                                        //没托盘，默认最大容量是小板的数量


                                        var count = db.Queryable<Location>().Count(c => c.S_AREA_CODE == a + "_X" && c.N_ROW == b) * 2 * 2;//2层2托


                                        var count = db.Queryable<Location>().Count(c => c.S_AREA_CODE == norAreacode && c.N_ROW == b) * 2 * 2;//2层2托


                                        kr.MaxCapacity = count;


                                        kr.AvailableCapacity = count;


                                        kr.ProductItem = "";


                                    }


                                    else


                                    {


                                        var locode = listLoc.Find(x => x.S_AREA_CODE == norAreacode && x.N_CURRENT_NUM > 0);


                                        //有托盘 判断是叠2层还是3层，要获取物料信息


                                        var lcr = db.Queryable<LocCntrRel>().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == listLoc[0].S_LOC_CODE).First();


                                        var lcr = db.Queryable<LocCntrRel>().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == locode.S_LOC_CODE).First();


                                        LogHelper.Info($"KurRongCalc {norAreacode}-{locode.S_LOC_CODE}-获取到托盘物料信息？：{lcr != null}");


                                        if (lcr != null && lcr.CntrItemRel != null)


                                        {


                                            var maxLayer = ContainerHelper.GetItem(ass => ass.S_ITEM_NAME == lcr.CntrItemRel.S_ITEM_NAME && ass.S_ITEM_CODE == lcr.CntrItemRel.S_ITEM_CODE)?.MaxLayer ?? listLoc[0].N_CAPACITY;


                                            var total = db.Queryable<Location>().Count(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b) * maxLayer * 2;


                                            var count = db.Queryable<Location>().Where(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b && c.N_CURRENT_NUM > 0).Sum(c => c.N_CURRENT_NUM) * 2;  // 指定统计字段


                                            var maxLayer = ContainerHelper.GetItem(ass => ass.S_ITEM_NAME == lcr.CntrItemRel.S_ITEM_NAME && ass.S_ITEM_CODE == lcr.CntrItemRel.S_ITEM_CODE)?.MaxLayer ?? 0;




                                            //LogHelper.Info($"KurRongCalc {norAreacode}-{lcr.CntrItemRel.S_ITEM_NAME}-{lcr.CntrItemRel.S_ITEM_CODE}-maxlayer:{maxLayer}-{locode.S_LOC_CODE}-{locode.N_CAPACITY}");


                                            if (maxLayer <= 0)


                                            {


                                                maxLayer = locode.N_CAPACITY;


                                            }


                                            var total = db.Queryable<Location>().Count(c => c.S_AREA_CODE == norAreacode && c.N_ROW == b) * maxLayer * 2;


                                            //LogHelper.Info($"KurRongCalc {norAreacode}-{locode.S_LOC_CODE}");


                                            var count = db.Queryable<Location>().Where(c => c.S_AREA_CODE == norAreacode && c.N_ROW == b && c.N_CURRENT_NUM > 0).Sum(c => c.N_CURRENT_NUM) * 2;  // 指定统计字段




                                            kr.ProductItem = lcr.CntrItemRel.S_ITEM_CODE;


                                            if (!string.IsNullOrEmpty(lcr.CntrItemRel.S_ITEM_NAME))


                                                kr.ProductItem = lcr.CntrItemRel.S_ITEM_NAME;


                                            kr.MaxCapacity = total;


                                            kr.FilledCapacity = count;


                                            kr.AvailableCapacity = total - count;


@@ -449,9 +489,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 子句，超出会报语法错误。*/