1

czw

2025-06-20 a72fe8b0ad01c6586293340115655c080d005853

 HH.WCS.QingXiNongfu/core/TaskCore.cs

@@ -3,9 +3,11 @@
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;

@@ -199,6 +201,17 @@
            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();

                list.ForEach(task =>
                {
                    if (!TaskProcess.Intercept(task))
@@ -238,7 +251,279 @@
            }
        }

        /// <summary>
        /// 60分钟更新一次库容
        /// </summary>
        /// <param name="min"></param>
        public static void CheckKuRong(int min)
        {
            try
            {
                Console.WriteLine("CheckKurRong");
                //如果表内没有数据就初始化一下，有数据了modify时间和当前时间超过30min再统计一次
                var db = new SqlHelper<object>().GetInstance();
                var info = db.Queryable<KuRong>().First();
                if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min)
                {
                    //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();
                    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();
                        aresList.ForEach(a =>
                        {
                            //b => b.S_AREA_CODE == a + "_X"
                            Console.WriteLine("area:" + a);
                            // && b.S_AREA_CODE.EndsWith("X")
                            var rows = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(a)).Select(b => b.N_ROW).Distinct().ToList();
                            if (rows.Count > 0)
                            {
                                Console.WriteLine(string.Join(",", rows));
                                rows.ForEach(b =>
                                {
                                    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 count = db.Queryable<Location>().Count(c => c.S_AREA_CODE == a + "_X" && c.N_ROW == b) * 2 * 2;//2层2托
                                        kr.MaxCapacity = count;
                                        kr.AvailableCapacity = count;
                                        kr.ProductItem = "";
                                    }
                                    else
                                    {
                                        //有托盘 判断是叠2层还是3层，要获取物料信息
                                        var lcr = db.Queryable<LocCntrRel>().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == listLoc[0].S_LOC_CODE).First();
                                        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;  // 指定统计字段

                                            kr.ProductItem = lcr.CntrItemRel.S_ITEM_CODE;
                                            kr.MaxCapacity = total;
                                            kr.FilledCapacity = count;
                                            kr.AvailableCapacity = total - count;
                                        }
                                    }
                                    list.Add(kr);
                                });
                            }
                            else
                            {
                                Console.WriteLine("area:" + a + ":未获取到排");
                            }
                        });

                    });
                    var ordersCount = db.Queryable<WorkOrder>().Where(a => a.SQL_State == "执行中").Count();
                    var totalDesiredCapacity = ordersCount * 4 * 3 * (totalX / totalRows);
                    LogHelper.Error($"成品小板区总货位是{totalX},总排数是{totalRows},当前执行工单数量是{ordersCount}", null);
                    var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity);
                    var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity;
                    list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; });
                    if (info == null)
                    {
                        /*​SQL Server​   1000 条/批次   单个 INSERT 语句最多支持 1000 条 VALUES 子句，超出会报语法错误。*/
                        db.Insertable(list).ExecuteCommand();
                    }
                    else
                    {
                        //更新
                        list.ForEach(a =>
                        {
                            var old = db.Queryable<KuRong>().Where(b => b.StorageLoc == a.StorageLoc).First();
                            if (old != null)
                            {
                                old.MaxCapacity = a.MaxCapacity;
                                old.AvailableCapacity = a.AvailableCapacity;
                                old.FilledCapacity = a.FilledCapacity;
                                old.ProductItem = a.ProductItem;
                                old.DesiredCapacity = a.DesiredCapacity;
                                old.CRC = a.CRC;
                                old.RAC = a.RAC;
                                old.T_MODIFY = DateTime.Now;
                                db.Updateable(old).UpdateColumns(it => new { it.MaxCapacity, it.FilledCapacity, it.AvailableCapacity, it.ProductItem, it.T_MODIFY }).ExecuteCommand();
                            }
                            else
                            {
                                db.Insertable(a).ExecuteCommand();
                            }
                        });
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                LogHelper.Error(ex.Message, ex);
            }

            //统计当前产线
        }

        internal static void Kuronggg()
        {
            int min = 60;
            try
            {
                LogHelper.Info("Run>>CheckKurRong");
                //如果表内没有数据就初始化一下，有数据了modify时间和当前时间超过30min再统计一次
                var db = new SqlHelper<object>().GetInstance();
                var info = db.Queryable<KuRong>().First();
                if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min)
                {
                    //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 => 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"
                            Console.WriteLine("area:" + a);
                            // && b.S_AREA_CODE.EndsWith("X")
                            var rows = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(a)).Select(b => b.N_ROW).Distinct().ToList();
                            if (rows.Count > 0)
                            {
                                Console.WriteLine(string.Join(",", rows));
                                rows.ForEach(b =>
                                {
                                    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(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 == 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 == 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 ?? 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;
                                        }
                                    }
                                    list.Add(kr);
                                });
                            }
                            else
                            {
                                Console.WriteLine("area:" + a + ":未获取到排");
                            }
                        });

                    });

                    var ordersCount = 0;// db.Queryable<WorkOrder>().Where(a => a.SQL_State == "执行中").Count();
                    foreach (var pline in Settings.GetDeviceInfoList().FindAll(x => x.deviceType == 9))
                    {
                        ordersCount += db.Queryable<WorkOrder>().Where(a => a.SQL_PLineNo == pline.deviceName && a.SQL_State == "执行中").Count();
                    }
                    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; });
                    if (info == null)
                    {
                        /*​SQL Server​   1000 条/批次   单个 INSERT 语句最多支持 1000 条 VALUES 子句，超出会报语法错误。*/
                        for (int i = 0; i < list.Count; i += 1000)
                        {
                            db.Insertable(list.Skip(i).Take(1000).ToList()).ExecuteCommand();
                        }
                    }
                    else
                    {
                        //更新
                        list.ForEach(a =>
                        {
                            var old = db.Queryable<KuRong>().Where(b => b.StorageLoc == a.StorageLoc).First();
                            if (old != null)
                            {
                                old.MaxCapacity = a.MaxCapacity;
                                old.AvailableCapacity = a.AvailableCapacity;
                                old.FilledCapacity = a.FilledCapacity;
                                old.ProductItem = a.ProductItem;
                                old.DesiredCapacity = a.DesiredCapacity;
                                old.CRC = a.CRC;
                                old.RAC = a.RAC;
                                old.T_MODIFY = DateTime.Now;
                                db.Updateable(old).UpdateColumns(it => new { it.MaxCapacity, it.FilledCapacity, it.AvailableCapacity, it.ProductItem, it.T_MODIFY }).ExecuteCommand();
                            }
                            else
                            {
                                db.Insertable(a).ExecuteCommand();
                            }
                        });
                    }
                }

                LogHelper.Info("OVER<<CheckKurRong");
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                LogHelper.Error(ex.Message, ex);
            }

        }
    }
}