11

jinxin

2025-06-11 6325ef722e9f6a47779054aecb46025fdc864a9a

 C#/HH.WCS.Mobox3.WeiLi/process/TaskProcess.cs

@@ -51,6 +51,7 @@
        /// <param name="mst"></param>
        internal static void CacheBitCancelUpdate(WCSTask mst)
        {
            LogHelper.Info($"任务取消 任务调度类型{mst.S_SCHEDULE_TYPE}");
            var db = new SqlHelper<object>().GetInstance();
            //任务取消，取货完成前的，起点的loadingCount和终点unLoadingCount都清除，取货完成的只处理终点
            if (mst.S_SCHEDULE_TYPE == "WCS")
@@ -86,12 +87,11 @@
                    //终点数量置0
                    db.Updateable<Location>().SetColumns(it => new Location() { N_CURRENT_NUM = 0 }).Where(a => a.S_CODE == mst.S_END_LOC).ExecuteCommand();
                }
                else 
                else
                {
                    db.Updateable<Location>().SetColumns(it => new Location() { N_CURRENT_NUM = 0 }).Where(a => a.S_CODE == mst.S_START_LOC).ExecuteCommand();
                }
                db.Deleteable<LocCntrRel>().Where(a => a.S_CNTR_CODE == mst.S_CNTR_CODE).ExecuteCommand();
                db.Deleteable<CntrItemRel>().Where(a => a.S_CNTR_CODE == mst.S_CNTR_CODE).ExecuteCommand();
               

                LocationHelper.UnLockLoc(mst.S_START_LOC);
                LocationHelper.UnLockLoc(mst.S_END_LOC);
@@ -99,12 +99,52 @@
                if (wmsTask != null)
                {
                    LocationHelper.UnLockLoc(wmsTask.S_END_LOC);
                    Reducequantity(wmsTask);
                }
                db.Deleteable<LocCntrRel>().Where(a => a.S_CNTR_CODE == mst.S_CNTR_CODE).ExecuteCommand();
                db.Deleteable<CntrItemRel>().Where(a => a.S_CNTR_CODE == mst.S_CNTR_CODE).ExecuteCommand();

            }




        }

        public static void Reducequantity(WMSTask wmsTask)
        {
            var db = new SqlHelper<object>().GetInstance();
            if (wmsTask.S_OP_DEF_NAME == "码盘入库")
            {
                //降入库单明细的分配量
                var itemlist = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == wmsTask.S_CNTR_CODE).ToList();
                if (itemlist.Count > 0)
                {
                    LogHelper.Info($"查找到物料明细{itemlist.Count}条");
                    foreach (var item in itemlist)
                    {
                        var exp = Expressionable.Create<TN_Inbound_Detail>();
                        exp.And(it => it.S_IO_NO == item.S_BS_NO);
                        exp.And(it => it.N_BS_ROW_NO == item.S_WU);
                        exp.And(it => it.S_ITEM_CODE == item.S_ITEM_CODE);
                        exp.AndIF(!string.IsNullOrEmpty(item.S_BATCH_NO), it => it.S_BATCH_NO == item.S_BATCH_NO);
                        exp.AndIF(!string.IsNullOrEmpty(item.S_ERP_WH_CODE), it => it.S_ERP_WH_CODE == item.S_ERP_WH_CODE);
                        exp.AndIF(!string.IsNullOrEmpty(item.S_OWNER), it => it.S_OWNER == item.S_OWNER);
                        exp.AndIF(!string.IsNullOrEmpty(item.S_SUPPLIER_NO), it => it.S_SUPPLIER_NO == item.S_SUPPLIER_NO);
                        var InWorkOrder = db.Queryable<TN_Inbound_Detail>().Where(exp.ToExpression()).First();
                        InWorkOrder.F_ACC_B_QTY = InWorkOrder.F_ACC_B_QTY - item.F_QTY;
                        db.Updateable(InWorkOrder).UpdateColumns(it => new { it.F_ACC_B_QTY }).ExecuteCommand();
                    }
                }
                else 
                {
                    LogHelper.Info($"未找到托盘{wmsTask.S_CNTR_CODE}的物料明细");
                }
            }
            else 
            {
                LogHelper.Info($"作业类型为{wmsTask.S_OP_DEF_NAME} 无须降量");
            }
        }

        /// <summary>
@@ -190,6 +230,8 @@
                            mst.S_ERR_LOC = "";
                            db.Updateable(mst).UpdateColumns(a => new { a.S_END_LOC, a.S_END_AREA, a.S_END_WH, a.S_START_LOC, a.S_START_AREA, a.S_START_WH, a.S_ERR_LOC }).ExecuteCommand();


                            TaskProcess.Reducequantity(wmsTask);
                            //NDCApi.ChangeOrderParam(mst.S_CODE, 1, startLoc.S_AGV_SITE);
                            //NDCApi.ChangeOrderParam(mst.S_CODE, 2, endLoc.S_AGV_SITE);
                            //NDCApi.ChangeOrderParam(mst.S_CODE, 4, "0");
@@ -873,6 +915,7 @@
        /// <param name="mst"></param>
        internal static bool SendTask(WCSTask mst)
        {
            var db = new SqlHelper<object>().GetInstance();
            var result = false;
            var start = "0"; var end = "0";
            var Trow = "0";
@@ -887,6 +930,13 @@
                    Trow = "1024";
                }

                var wmsTask = db.Queryable<WMSTask>().Where(a => a.S_CODE == mst.S_OP_CODE).First();
                if (wmsTask != null && wmsTask.N_TRAY_WEIGHT > 0) 
                {
                    // 1000 2000 3000 4000 5000
                    Trow = (wmsTask.N_TRAY_WEIGHT * 4096).ToString();
                }
                

                Console.WriteLine($"SendTask {mst.S_CODE}");
                Console.WriteLine("start=" + start);