1

HuBingJie

2025-11-13 d58196721475e968769d708d9c14f60dd8d5671f

 ÏîÄ¿´úÂë/WMS/WIDESEA_WMSServer/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs

@@ -1,4 +1,4 @@
#region << ç‰ˆ æœ¬ æ³¨ é‡Š >>
#region << ç‰ˆ æœ¬ æ³¨ é‡Š >>
/*----------------------------------------------------------------
 * å‘½åç©ºé—´ï¼šWIDESEA_TaskInfoService
 * åˆ›å»ºè€…：胡童庆
@@ -193,11 +193,11 @@
                        NextAddress = Nextlocation.LocationCode,
                        Grade = 1,
                        Creater = "WMS",
                        Depth = ShallowLocation.Depth,
                        Depth = Nextlocation.Depth,
                        CreateDate = DateTime.Now,
                    };

                    _locationInfoRepository.AddData(loca);
                    _locationInfoRepository.UpdateData(loca);
                    BaseDal.AddData(dt_Task);   //新增任务
                    _unitOfWorkManage.CommitTran();

@@ -267,6 +267,8 @@
                BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateTypeEnum.自动完成 : OperateTypeEnum.人工完成);

                WebResponseContent content=MES_TransferCompletionFeedback(task);
                //content.Status = true;

                if (!content.Status)
                {
                    _unitOfWorkManage.RollbackTran();
@@ -321,12 +323,15 @@
                BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? OperateTypeEnum.人工完成 : OperateTypeEnum.自动完成);


                /*WebResponseContent content = TaskCompletionFeedback(task);
                WebResponseContent content = TaskCompletionFeedback(task);
                //content.Status = true;
                if (!content.Status)
                {
                    _unitOfWorkManage.RollbackTran();
                    return content;
                }*/
                }

                //Thread.Sleep(5000);

                _unitOfWorkManage.CommitTran();
            }
@@ -367,13 +372,15 @@

                BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateTypeEnum.自动完成 : OperateTypeEnum.人工完成);
                _locationStatusChangeRecordService.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockStatusEmun.出库完成.ObjToInt(), "1", task.TaskNum);
                /*WebResponseContent content = TaskCompletionFeedback(task);
                WebResponseContent content = TaskCompletionFeedback(task);
                //content.Status = true;

                if (!content.Status)
                {
                    _unitOfWorkManage.RollbackTran();
                    return content;
                }*/

                }
                //Thread.Sleep(5000);
                _unitOfWorkManage.CommitTran();
                return webResponse.OK();
            }
@@ -404,17 +411,26 @@

            try
            {
                string locationCode = null;
                if (dt_Task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                {
                    locationCode = dt_Task.SourceAddress;
                }
                else
                {
                    locationCode = dt_Task.TargetAddress;
                }
                TransferRequest transferRequest = new TransferRequest()
                {
                    //业务id，任务id后续进行更改
                    businessId = "1",
                    TaskId = "1",
                    SourceLocationCode = dt_Task.SourceAddress,
                    LocationCode = dt_Task.TargetAddress,
                    PalletCode = dt_Task.PalletCode,
                    Status = "FINISH",
                    ErrorStatus = "NORMAL",
                    ErrorInfo = "",
                    taskId = dt_Task.MEStaskId,   //任务id
                    businessId = dt_Task.MESbusinessId,   //业务id
                    sourceLocationCode = dt_Task.SourceAddress,
                    locationCode = locationCode,
                    palletCode = dt_Task.PalletCode,
                    status = "FINISH",
                    errorStatus = "NORMAL",
                    errorInfo = "",
                };

                //获取接口进行调取
@@ -422,25 +438,27 @@
                string WCSReceiveTaskAPI = ConfigsAPIInfo.ApiAddress + ConfigsAPIInfo.ApiName;
                if (WCSReceiveTaskAPI == null)
                {
                    return webResponse.Error($"出库失败，未配置MES移库完成反馈接口");
                   return webResponse.Error($"出库失败，未配置MES移库完成反馈接口");
                }
                var respon = HttpHelper.Post(WCSReceiveTaskAPI, JsonConvert.SerializeObject(transferRequest));
                if (respon != null)
                {
                    var response = JsonConvert.DeserializeObject<ApiResponse<object>>(respon);
                    if (response.Success)
                    {
                        return webResponse.OK();
                    }
                    else
                    {
                        return webResponse.Error($"调取接口失败，反馈参数原因：{response.Message}");
                    }
                   var response = JsonConvert.DeserializeObject<ApiResponse<object>>(respon);
                   if (response.Success)
                   {
                       return webResponse.OK();
                   }
                   else
                   {
                       return webResponse.Error($"调取接口失败，反馈参数原因：{response.Message}");
                   }
                }
                else
                {
                    return webResponse.Error($"调取接口失败，反馈参数为空");
                   return webResponse.Error($"调取接口失败，反馈参数为空");
                }

                return webResponse.OK();
            }
            catch (Exception ex)
            {
@@ -461,17 +479,26 @@

            try
            {
                TaskNotification transferRequest = new TaskNotification()
                string locationCode = null;
                if (dt_Task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                {
                    //业务id，任务id后续进行更改
                    TaskId = "1",   //任务id
                    BusinessId = "1",   //业务id
                    PalletCode = dt_Task.PalletCode,
                    SubPalletCode = "",//子托盘编码
                    LocationCode = dt_Task.SourceAddress,
                    ErrorStatus = "NORMAL",
                    ErrorInfo = "",
                };
                    locationCode = dt_Task.SourceAddress;
                }
                else
                {
                    locationCode = dt_Task.TargetAddress;
                }
                TaskNotification transferRequest = new TaskNotification()
                    {
                        //业务id，任务id后续进行更改
                        taskId = dt_Task.MEStaskId,   //任务id
                        businessId = dt_Task.MESbusinessId,   //业务id
                        palletCode = dt_Task.PalletCode,
                        subPalletCode = dt_Task.MESsubPalletCode,//子托盘编码
                        locationCode = locationCode,
                        errorStatus = "NORMAL",
                        errorInfo = "",
                    };

                //获取接口进行调取
                var ConfigsAPIInfo = _dt_ApiInfoService.GetConfigsByAPIInfo(CateGoryConst.CONFIG_MES_IPAddress, SysConfigConst.MESTaskFeedback);      //获取到wcs全部类型的接口
@@ -480,7 +507,14 @@
                {
                    return webResponse.Error($"任务反馈MES失败，未配置MES任务完成反馈接口");
                }
                var respon = HttpHelper.Post(WCSReceiveTaskAPI, JsonConvert.SerializeObject(transferRequest));
                
                // æ·»åŠ è°ƒè¯•ä¿¡æ¯
                string requestJson = JsonConvert.SerializeObject(transferRequest);
                //Console.WriteLine($"MES反馈接口URL: {WCSReceiveTaskAPI}");
                //Console.WriteLine($"MES反馈请求数据: {requestJson}");
                
                // ä½¿ç”¨ä¿®å¤åŽçš„PostSync方法（已在PostSync中设置默认请求头）
                var respon = HttpHelper.Post(WCSReceiveTaskAPI, requestJson);
                if (respon != null)
                {
                    var response = JsonConvert.DeserializeObject<ApiResponse<object>>(respon);
@@ -505,7 +539,7 @@
            }
        }

        public ApiResponse<object> MESresponse(string Message, bool Success)
        public ApiResponse<object> MESresponse(string Message, bool Success,int  Code)
        {
            ApiResponse<object> apiResponse = new ApiResponse<object>();
            apiResponse.Message = Message;
@@ -514,8 +548,33 @@
            return apiResponse;
        }

        /// <summary>
        /// å–消任务接口
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <returns></returns>
        public WebResponseContent Cancelinventory(int taskNum)
        {
            WebResponseContent webResponse = new WebResponseContent();
            try
            {
                // æŸ¥æ‰¾ä»»åŠ¡
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.TaskStatus == TaskOutStatusEnum.OutFinish.ObjToInt());
                if (task == null)
                {
                    return webResponse.Error($"未找到任务号为【{taskNum}】的任务信息");
                }


                // TODO: è¿™é‡ŒåŽç»­éœ€è¦æ·»åŠ å…·ä½“的取消任务业务逻辑
                // ä¾‹å¦‚：更新任务状态、释放货位、通知WCS等
                
                return webResponse.OK("任务取消成功");
            }
            catch (Exception ex)
            {
                return webResponse.Error($"取消任务失败，原因：{ex.Message}");
            }
        }

        /// <summary>
        /// åˆ›å»ºè´§ä½
@@ -603,5 +662,92 @@
            }
            return MESresponse($"", true);
        }


        public static string GetLastPart(string locationCode)
        {
            string[] parts = locationCode.Split('-');
            return parts[parts.Length - 1];
        }


        /// <summary>
        /// å‡ºåº“
        /// </summary>
        /// <param name="locationCode"></param>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public WebResponseContent chuku(string locationCode)
        {

            try
            {
                int result = GetLastPart(locationCode).ObjToInt(); // è¿”回 "C03"
                List<Dt_Task> dt_s = new List<Dt_Task>();
                //生成移动任务
                Dt_Task dt_Task = new()
                {
                    PalletCode = "1111",
                    TaskNum = 111,
                    Roadway = "SC01",
                    TaskType = TaskOutboundTypeEnum.Outbound.ObjToInt(),
                    TaskStatus = TaskOutStatusEnum.OutNew.ObjToInt(),
                    SourceAddress = locationCode,
                    TargetAddress = "1002",
                    CurrentAddress = locationCode,
                    NextAddress = "1002",
                    Grade = 1,
                    Creater = "MES",
                    Depth = result,
                    CreateDate = DateTime.Now,
                    MEStaskId = "111",
                    MESbusinessId = "123456",
                    MESsubPalletCode = "",
                    OutboundPlatform = "1001"
                };

                //创建组盘信息
                var dt_Stock = new Dt_StockInfo
                {
                    PalletCode = dt_Task.PalletCode,
                    PalletType = 1,
                    LocationCode = locationCode,
                    StockStatus = 6,
                    Creater = "WMS",
                    CreateDate = DateTime.Now,
                    MESsubPalletCode = dt_Task.MESsubPalletCode,
                };

                Dt_LocationInfo dt_LocationInfo = _locationInfoRepository.QueryFirst(x => x.LocationCode == locationCode);
                dt_LocationInfo.LocationStatus = (int)LocationStatusEnum.InStockLock;

                bool l = _locationInfoRepository.UpdateData(dt_LocationInfo);
                int s = _stockRepository.AddData(dt_Stock);
                int t = BaseDal.AddData(dt_Task);
                bool ss = s.ObjToBool();
                bool tt = t.ObjToBool();


                if (!l && !ss && tt)
                {
                    _unitOfWorkManage.RollbackTran();
                }

                dt_s.Add(dt_Task);
                var respon = PushTasksToWCS(dt_s, "");
                if (respon.Status)
                {
                    _unitOfWorkManage.CommitTran();  //提交事务
                    return WebResponseContent.Instance.OK();
                }
                return WebResponseContent.Instance.Error();
            }
            catch
            {
                _unitOfWorkManage.RollbackTran();
                return WebResponseContent.Instance.Error();

            }
        }
    }
}