代码提交

wankeda

2025-03-13 a6a33f6916afbf1fc629baecb772939cda2ee981

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs

@@ -16,6 +16,7 @@
#endregion << ç‰ˆ æœ¬ æ³¨ é‡Š >>

using AutoMapper;
using Magicodes.IE.Core;
using MailKit.Search;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
@@ -31,6 +32,8 @@
using System.Reflection.Metadata;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Common.AGVEunm;
using WIDESEA_Core;
using WIDESEA_Core.BaseRepository;
using WIDESEA_Core.BaseServices;
@@ -83,7 +86,7 @@
        }

        /// <summary>
        /// ä»»åŠ¡å®Œæˆ
        /// æ‰‹åŠ¨ä»»åŠ¡å®Œæˆ
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <returns>返回处理结果</returns>
@@ -97,29 +100,36 @@
                {
                    return WebResponseContent.Instance.Error("未找到任务信息");
                }
                _unitOfWorkManage.BeginTran();
                MethodInfo? methodInfo = GetType().GetMethod(((TaskTypeEnum)task.TaskType) + "TaskCompleted");
                if (methodInfo != null)
                {
                    WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { task });
                    if (responseContent != null)
                    {
                        if (App.User.UserId > 0)
                        {
                            var response = HttpHelper.Post<WebResponseContent>(url + "StackCraneTaskCompleted?taskNum=" + task.TaskNum, "", "任务完成");
                            if (!response.Status)
                            {
                                _unitOfWorkManage.RollbackTran();
                                return WebResponseContent.Instance.Error(response.Message);
                            }
                            _unitOfWorkManage.CommitTran();
                            return content = responseContent;
                        }
                        _unitOfWorkManage.CommitTran();
                        return content = responseContent;
                    }
                }
                return content = WebResponseContent.Instance.Error("未找到任务类型对应业务处理逻辑");
                //_unitOfWorkManage.BeginTran();
                int TaskStatus = AGVTaskStatusEnum.AGV_Completion.ObjToInt();
                _taskHtyService.AddTaskHty(task, TaskStatus);
                HCJFree(task, TaskStatus);
                BaseDal.DeleteData(task);
                #region
                //MethodInfo? methodInfo = GetType().GetMethod(((TaskTypeEnum)task.TaskType) + "TaskCompleted");
                //if (methodInfo != null)
                //{
                //    WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { task });
                //    if (responseContent != null)
                //    {
                //        if (App.User.UserId > 0)
                //        {
                //            var response = HttpHelper.Post<WebResponseContent>(url + "StackCraneTaskCompleted?taskNum=" + task.TaskNum, "", "任务完成");
                //            if (!response.Status)
                //            {
                //                _unitOfWorkManage.RollbackTran();
                //                return WebResponseContent.Instance.Error(response.Message);
                //            }
                //            _unitOfWorkManage.CommitTran();
                //            return content = responseContent;
                //        }
                //        _unitOfWorkManage.CommitTran();
                //        return content = responseContent;
                //    }

                //}
                #endregion
                return content = WebResponseContent.Instance.OK();
            }
            catch (Exception ex)
            {
@@ -128,7 +138,7 @@
            }
            finally
            {
                WriteLog.GetLog("任务完成").Write($"操作人：{(App.User.UserId>0? App.User.UserName: "System")}{ Environment.NewLine}任务号：{taskNum}{Environment.NewLine}{ JsonConvert.SerializeObject(content)}", "任务完成");
                WriteLog.GetLog("任务完成").Write($"操作人：{(App.User.UserId > 0 ? App.User.UserName : "System")}{Environment.NewLine}任务号：{taskNum}{Environment.NewLine}{JsonConvert.SerializeObject(content)}", "任务完成");
            }
        }
        public WebResponseContent TaskCancel(int taskNum)
@@ -139,39 +149,45 @@
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
                if (task == null)
                {
                    return content=WebResponseContent.Instance.Error("未找到任务信息");
                    return content = WebResponseContent.Instance.Error("未找到任务信息");
                }
                _unitOfWorkManage.BeginTran();
                MethodInfo? methodInfo = GetType().GetMethod(((TaskTypeEnum)task.TaskType) + "TaskCancel");
                if (methodInfo != null)
                {
                    WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { task });
                    if (responseContent != null)
                    {
                        if (responseContent != null)
                        {
                            if (App.User.UserId > 0)
                            {
                                var response = HttpHelper.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "任务取消");
                                if (!response.Status)
                                {
                                    _unitOfWorkManage.RollbackTran();
                                    return content=WebResponseContent.Instance.Error(response.Message);
                                }
                                _unitOfWorkManage.CommitTran();
                                return content=responseContent;
                            }
                            _unitOfWorkManage.CommitTran();
                            return content=responseContent;
                        }
                    }
                }
                return content=WebResponseContent.Instance.Error("未找到任务类型对应业务处理逻辑");
                //_unitOfWorkManage.BeginTran();
                int TaskStatus = AGVTaskStatusEnum.AGV_ManuallyCancel.ObjToInt();
                _taskHtyService.AddTaskHty(task, TaskStatus);
                //HCJFree(task, TaskStatus);
                BaseDal.DeleteData(task);
                #region
                //MethodInfo? methodInfo = GetType().GetMethod(((TaskTypeEnum)task.TaskType) + "TaskCancel");
                //if (methodInfo != null)
                //{
                //    WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { task });
                //    if (responseContent != null)
                //    {
                //        if (responseContent != null)
                //        {
                //            if (App.User.UserId > 0)
                //            {
                //                var response = HttpHelper.Post<WebResponseContent>(url + "TaskCancel?taskNum=" + task.TaskNum, "", "任务取消");
                //                if (!response.Status)
                //                {
                //                    _unitOfWorkManage.RollbackTran();
                //                    return content = WebResponseContent.Instance.Error(response.Message);
                //                }
                //                _unitOfWorkManage.CommitTran();
                //                return content = responseContent;
                //            }
                //            _unitOfWorkManage.CommitTran();
                //            return content = responseContent;
                //        }
                //    }
                //}
                #endregion
                return content = WebResponseContent.Instance.OK();
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                return content=WebResponseContent.Instance.Error(ex.Message);
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
            finally
            {
@@ -211,7 +227,7 @@
                task.Modifier = App.User.UserId > 0 ? App.User.UserName : "System";
                BaseDal.UpdateData(task);
                _unitOfWorkManage.CommitTran();
                 return content = WebResponseContent.Instance.OK();
                return content = WebResponseContent.Instance.OK();
            }
            catch (Exception ex)
            {
@@ -248,7 +264,7 @@
                BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);

                _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Inbound.ObjToInt(), stockInfo.Details.FirstOrDefault()?.OrderNo ?? "", task.TaskNum);
                _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfo.Details, beforeQuantity, stockInfo.Details.Sum(x => x.StockQuantity) + beforeQuantity, StockChangeType.Inbound,task.TaskNum);
                _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfo.Details, beforeQuantity, stockInfo.Details.Sum(x => x.StockQuantity) + beforeQuantity, StockChangeType.Inbound, task.TaskNum);
                _unitOfWorkManage.CommitTran();
                return WebResponseContent.Instance.OK();
            }
@@ -257,7 +273,7 @@
                _unitOfWorkManage.RollbackTran();
                return WebResponseContent.Instance.Error(ex.Message);
            }
            

        }

        /// <summary>
@@ -538,7 +554,7 @@
            }
        }

        

        public WebResponseContent OutboundTaskCancel(Dt_Task task)
        {
            try
@@ -617,7 +633,7 @@

                task.TaskStatus = OutTaskStatusEnum.OutCancel.ObjToInt();
                BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
                

                _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Outbound.ObjToInt(), stockInfo.Details.FirstOrDefault()?.OrderNo ?? "", task.TaskNum);

                _unitOfWorkManage.CommitTran();
@@ -643,7 +659,7 @@
                stockInfo.StockStatus = StockStatusEmun.已入库.ObjToInt();
                _stockService.StockInfoService.Repository.UpdateData(stockInfo);

                locationEnd.LocationStatus= LocationStatusEnum.Free.ObjToInt();
                locationEnd.LocationStatus = LocationStatusEnum.Free.ObjToInt();
                _basicService.LocationInfoService.RelocationFree(locationStart, task.TaskNum);
                _basicService.LocationInfoService.Repository.UpdateData(locationEnd);

@@ -661,7 +677,7 @@
        }
        public bool DepthTask(Dt_LocationInfo location)
        {
            if (location != null )
            if (location != null)
            {
                Dt_LocationInfo locations = _locationInfoService.Repository.QueryFirst(x => x.RoadwayNo == location.RoadwayNo && x.Column == location.Column && x.Layer == location.Layer && x.Depth != location.Depth && x.Row != location.Row && (SqlFunc.Abs(x.Row - location.Row) == 1));
                if (locations != null)
@@ -682,7 +698,7 @@
                {
                    expression = x => x.Creater == App.User.UserName;
                }
                var task = BaseDal.Db.Queryable<Dt_Task>().OrderByDescending(x => x.CreateDate).Take(10).Select(x => new Dt_Task { TaskNum = x.TaskNum, PalletCode=x.PalletCode, TaskType=x.TaskType,SourceAddress=x.SourceAddress,TargetAddress=x.TargetAddress }).ToList();
                var task = BaseDal.Db.Queryable<Dt_Task>().OrderByDescending(x => x.CreateDate).Take(10).Select(x => new Dt_Task { TaskNum = x.TaskNum, PalletCode = x.PalletCode, TaskType = x.TaskType, SourceAddress = x.SourceAddress, TargetAddress = x.TargetAddress }).ToList();
                content = WebResponseContent.Instance.OK(data: task);
            }
            catch (Exception ex)
@@ -691,5 +707,174 @@
            }
            return content;
        }
        /// <summary>
        /// åŽŸææ–™åº“大屏任务显示
        /// </summary>
        /// <param name="saveModel"></param>
        /// <returns></returns>
        public WebResponseContent GetAGVTaskData(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                string type = saveModel.MainData["AGVName"].ToString();
                List<Dt_Task> agvtask = new List<Dt_Task>();
                agvtask = BaseDal.QueryData(x => x.TaskStatus == AGVTaskStatusEnum.AGV_Query.ObjToInt()).ToList();
                if (agvtask.Count <= 0) return content.Error("未找到任务");
                foreach (var item in agvtask)
                {
                    item.Remark = item.TaskStatus == AGVTaskStatusEnum.AGV_New.ObjToInt() ? "新建" : item.TaskStatus == AGVTaskStatusEnum.AGV_Query.ObjToInt() ? "队列中" : item.TaskStatus == AGVTaskStatusEnum.AGV_Executing.ObjToInt() ? "执行中" : item.TaskStatus == AGVTaskStatusEnum.AGV_SendOut.ObjToInt() ? "已下发" : "";
                }
                return content.OK(data: agvtask);
            }
            catch (Exception)
            {

                throw;
            }
        }
        /// <summary>
        /// æˆå“åº“大屏任务显示
        /// </summary>
        /// <param name="saveModel"></param>
        /// <returns></returns>
        public WebResponseContent GetAGVTaskDataCP(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                string type = saveModel.MainData["AGVName"].ToString();
                List<Dt_Task> agvtask = new List<Dt_Task>();
                agvtask = BaseDal.QueryData(x => x.TaskType == TaskTypeEnum.Inbound.ObjToInt()).ToList();
                if (agvtask.Count <= 0) return content.Error("未找到任务");
                foreach (var item in agvtask)
                {
                    item.Remark = item.TaskStatus == AGVTaskStatusEnum.AGV_New.ObjToInt() ? "新建" : item.TaskStatus == AGVTaskStatusEnum.AGV_Query.ObjToInt() ? "队列中" : item.TaskStatus == AGVTaskStatusEnum.AGV_Executing.ObjToInt() ? "执行中" : item.TaskStatus == AGVTaskStatusEnum.AGV_SendOut.ObjToInt() ? "已下发" : "";
                }
                return content.OK(data: agvtask);
            }
            catch (Exception)
            {

                throw;
            }
        }

        public WebResponseContent HCJLock(Dt_Task task)
        {
            WebResponseContent content = new WebResponseContent();
            Dt_CachePoint source = _basicService.CachePointService.Repository.QueryFirst(x => x.PointCode == task.SourceAddress);
            Dt_CachePoint target = _basicService.CachePointService.Repository.QueryFirst(x => x.PointCode == task.TargetAddress);
            if (target != null && source != null)
            {
                source.PointStatus = LocationStatusEnum.Lock.ObjToInt();
                _basicService.CachePointService.Repository.UpdateData(source);
                target.PointStatus = LocationStatusEnum.Lock.ObjToInt();
                _basicService.CachePointService.Repository.UpdateData(target);
            }
            return content;
        }

        public WebResponseContent HCJFree(Dt_Task task, int TaskStatus)
        {
            WebResponseContent content = new WebResponseContent();
            Dt_CachePoint source = _basicService.CachePointService.Repository.QueryFirst(x => x.PointCode == task.SourceAddress);
            Dt_CachePoint target = _basicService.CachePointService.Repository.QueryFirst(x => x.PointCode == task.TargetAddress);
            var toaddress = JsonConvert.SerializeObject(target);
            if (target != null && source != null)
            {
                if (toaddress.Contains("成品库"))
                {
                    source.PointStatus = LocationStatusEnum.Free.ObjToInt();
                    _basicService.CachePointService.Repository.UpdateData(source);
                    target.PointStatus = LocationStatusEnum.InStock.ObjToInt();
                    _basicService.CachePointService.Repository.UpdateData(target);
                }
                else
                {
                    source.PointStatus = LocationStatusEnum.Free.ObjToInt();
                    _basicService.CachePointService.Repository.UpdateData(source);
                    //target.PointStatus = LocationStatusEnum.Free.ObjToInt();
                    //_basicService.CachePointService.Repository.UpdateData(target);
                }
            }
            return content;
        }
        public WebResponseContent CacheStatus(SaveModel saveModel)
        {
            WebResponseContent response = new WebResponseContent();
            List<object> list = new List<object>();
            try
            {
                List<Dt_CachePoint> cachePoints = _basicService.CachePointService.Repository.QueryData(x => x.PointCode.Contains("成品库")).ToList();
                foreach (var cachePoint in cachePoints)
                {
                    bool isState = (cachePoint.PointStatus == LocationStatusEnum.Free.ObjToInt());
                    string stateName = "";
                    switch (cachePoint.PointStatus)
                    {
                        case 0:
                            stateName = "空闲";
                            break;
                        case 1:
                            stateName = "锁定";
                            break;
                        case 2:
                            stateName = "有货";
                            break;
                        default:
                            break;
                    }
                    list.Add(new { name = cachePoint.Depth, state = isState, statename = stateName });
                }

                response.OK(data: new { list });
            }
            catch (Exception ex)
            {
                response.Error(ex.Message);
            }
            return response;
        }
        public WebResponseContent LEDloctionList()
        {
            WebResponseContent content = new WebResponseContent();
            {
                //List<areaLocation> areaBucket = new List<areaLocation>();
                List<areaLocation> areaProduct = new List<areaLocation>();
                ////成品总货位
                //List<Dt_locationinfo> productCount = locationinfoRepository.Find(x => x.location_areaid != "3" && x.location_areaid != "4");
                ////成品空货位
                //List<Dt_locationinfo> emptyProductCount = locationinfoRepository.Find(x => x.location_areaid != "3" && x.location_areaid != "4" && x.location_state == LocationState.LocationState_Empty.ToString());
                ////成品有货货位
                //List<Dt_locationinfo> storedyProductCount = locationinfoRepository.Find(x => x.location_areaid != "3" && x.location_areaid != "4" && x.location_state == LocationState.LocationState_Stored.ToString());
                ////成品锁定货位
                //List<Dt_locationinfo> lockedProductCount = locationinfoRepository.Find(x => x.location_areaid != "3" && x.location_areaid != "4"
                //&& x.location_state != LocationState.LocationState_Empty.ToString() && x.location_state != LocationState.LocationState_Stored.ToString());
                //areaProduct.Add(new areaLocation { name = "空货位", count = emptyProductCount.Count });
                //areaProduct.Add(new areaLocation { name = "总货位", count = productCount.Count });
                //areaProduct.Add(new areaLocation { name = "执行货位", count = lockedProductCount.Count });
                //areaProduct.Add(new areaLocation { name = "有货货位", count = storedyProductCount.Count });
                //content.OK(data: new { areaBucket, areaProduct });
                //成品总货位
                List<Dt_CachePoint> productCount = _basicService.CachePointService.Repository.QueryData(x => x.PointCode.Contains("成品库"));
                //成品空货位
                List<Dt_CachePoint> emptyProductCount = _basicService.CachePointService.Repository.QueryData(x => x.PointCode.Contains("成品库") && x.PointStatus == LocationStatusEnum.Free.ObjToInt());
                //成品有货货位
                List<Dt_CachePoint> storedyProductCount = _basicService.CachePointService.Repository.QueryData(x => x.PointCode.Contains("成品库") && x.PointStatus == LocationStatusEnum.InStock.ObjToInt());
                //成品锁定货位
                List<Dt_CachePoint> lockedProductCount = _basicService.CachePointService.Repository.QueryData(x => x.PointCode.Contains("成品库") && x.PointStatus == LocationStatusEnum.Lock.ObjToInt());
                areaProduct.Add(new areaLocation { name = "空货位", count = emptyProductCount.Count });
                areaProduct.Add(new areaLocation { name = "总货位", count = productCount.Count });
                areaProduct.Add(new areaLocation { name = "执行货位", count = lockedProductCount.Count });
                areaProduct.Add(new areaLocation { name = "有货货位", count = storedyProductCount.Count });
                return content.OK(data: new { areaProduct });
            }
        }
        private class areaLocation
        {
            public string name { get; set; }
            public int count { get; set; }
        }
    }
}