feat: 增加LG-AGV接口并完善物料校验与报工逻辑

2026-07-16 16:46:06 +08:00
parent 7303ddde9a
commit dcec36611d
36 changed files with 1274 additions and 36 deletions
--- a/Interface_WebAPI/SlMesDbIterface/WebAPI/WEB/LGWEB_BusinessLogic.cs
+++ b/Interface_WebAPI/SlMesDbIterface/WebAPI/WEB/LGWEB_BusinessLogic.cs
@@ -0,0 +1,319 @@
+using System;
+using System.Data;
+using System.Data.SqlClient;
+using System.Web.Http;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using MisDataSaveDate.Helper;
+using static MisDataSaveDate.Helper.ApiLogHelper;
+
+namespace MisDataSaveDate
+{
+    /// <summary>
+    /// 临工AGV网页按钮业务处理。
+    /// </summary>
+    public class LGWEB_BusinessLogic
+    {
+        /// <summary>
+        /// 网页按钮下发临工AGV搬运任务。
+        /// </summary>
+        public static string WEB_DispatchAGV(string url, [FromBody] JObject jobj)
+        {
+            var result = new MsgResHeader<object>
+            {
+                code = 200,
+                message = "",
+                Data = null
+            };
+
+            if (jobj == null)
+            {
+                result.code = 500;
+                result.message = "参数格式不正确！";
+                return JsonConvert.SerializeObject(result);
+            }
+
+            string requestText = jobj.ToString();
+            SaveLog_Interface_Request(url, 2, requestText, out int aid);
+
+            try
+            {
+                LGWEB_DispatchRequest request = JsonConvert.DeserializeObject<LGWEB_DispatchRequest>(requestText);
+                if (request == null)
+                {
+                    throw new Exception("请求参数格式不正确");
+                }
+                if (string.IsNullOrWhiteSpace(request.routeCode))
+                {
+                    throw new Exception("路线编码(routeCode)不能为空");
+                }
+
+                LGWEB_RouteInfo route = GetRouteInfo(request.routeCode);
+                string startPosition = string.IsNullOrWhiteSpace(request.startPosition) ? route.StartPosition : request.startPosition;
+                string midPosition = string.IsNullOrWhiteSpace(request.midPosition) ? route.MidPosition : request.midPosition;
+                string endPosition = route.ActualEndPosition;
+                string requestTaskId = string.IsNullOrWhiteSpace(request.requestTaskId) ? Guid.NewGuid().ToString() : request.requestTaskId;
+                string materialCode = FirstText(request.materialCode, request.productCode, request.containerNo);
+
+                if (string.IsNullOrWhiteSpace(startPosition))
+                {
+                    throw new Exception("起点位置不能为空，请检查路线配置或请求参数");
+                }
+                if (string.IsNullOrWhiteSpace(endPosition))
+                {
+                    throw new Exception("终点位置不能为空，请检查路线配置");
+                }
+
+                LGAGV_CallResult agvResult;
+                if (string.Equals(route.InterfaceName, "AddTaskFromMes2", StringComparison.OrdinalIgnoreCase))
+                {
+                    agvResult = LGAGV_BusinessLogic.CallAddTask2(new LGAGV_AddTask2Request
+                    {
+                        requestTaskId = requestTaskId,
+                        startPosition = startPosition,
+                        midPosition = midPosition,
+                        endPosition = endPosition,
+                        materialCode = materialCode
+                    });
+                }
+                else
+                {
+                    agvResult = LGAGV_BusinessLogic.CallAddTask(new LGAGV_AddTaskRequest
+                    {
+                        requestTaskId = requestTaskId,
+                        startPosition = startPosition,
+                        endPosition = endPosition,
+                        materialCode = materialCode
+                    });
+                }
+
+                SaveDispatchResult(request, route, requestTaskId, startPosition, midPosition, endPosition, materialCode, agvResult);
+
+                result.code = agvResult.Success ? 200 : 500;
+                result.message = agvResult.Success ? "AGV调度成功" : $"AGV调度失败：{agvResult.Message}";
+                result.Data = new
+                {
+                    requestTaskId = requestTaskId,
+                    routeCode = request.routeCode,
+                    startPosition = startPosition,
+                    midPosition = midPosition,
+                    endPosition = endPosition,
+                    originalEndPosition = route.OriginalEndPosition,
+                    routeMessage = route.RouteMessage,
+                    agvResponse = agvResult.Response
+                };
+            }
+            catch (Exception ex)
+            {
+                result.code = 500;
+                result.message = ex.Message;
+                SaveMesLog("LGWEB_DispatchAGV", ex.Message, MesLogType.ERROR);
+            }
+
+            string responseText = JsonConvert.SerializeObject(result);
+            SaveLog_Interface_Response(responseText, aid);
+            return responseText;
+        }
+
+        /// <summary>
+        /// 网页按钮放行临工AGV离开。
+        /// </summary>
+        public static string WEB_AllowLeave(string url, [FromBody] JObject jobj)
+        {
+            var result = new MsgResHeader<object>
+            {
+                code = 200,
+                message = "",
+                Data = null
+            };
+
+            if (jobj == null)
+            {
+                result.code = 500;
+                result.message = "参数格式不正确！";
+                return JsonConvert.SerializeObject(result);
+            }
+
+            string requestText = jobj.ToString();
+            SaveLog_Interface_Request(url, 2, requestText, out int aid);
+
+            try
+            {
+                LGWEB_AllowLeaveRequest request = JsonConvert.DeserializeObject<LGWEB_AllowLeaveRequest>(requestText);
+                if (request == null)
+                {
+                    throw new Exception("请求参数格式不正确");
+                }
+                if (string.IsNullOrWhiteSpace(request.requestId))
+                {
+                    throw new Exception("请求ID(requestId)不能为空");
+                }
+                if (string.IsNullOrWhiteSpace(request.position))
+                {
+                    throw new Exception("位置(position)不能为空");
+                }
+
+                LGAGV_CallResult agvResult = LGAGV_BusinessLogic.CallAllowLeave(new LGAGV_AllowLeaveRequest
+                {
+                    requestId = request.requestId,
+                    position = request.position,
+                    agvNo = request.agvNo,
+                    allowLeave = 1
+                });
+
+                var param = new SqlParameter[]
+                {
+                    new SqlParameter("@requestId", request.requestId ?? ""),
+                    new SqlParameter("@position", request.position ?? ""),
+                    new SqlParameter("@agvNo", request.agvNo ?? ""),
+                    new SqlParameter("@操作人工号", request.operatorCode ?? ""),
+                    new SqlParameter("@操作人姓名", request.operatorName ?? ""),
+                    new SqlParameter("@备注", request.remark ?? ""),
+                    new SqlParameter("@是否成功", agvResult.Success ? 1 : 2),
+                    new SqlParameter("@错误信息", agvResult.Success ? "" : (agvResult.Message ?? ""))
+                };
+                ExecuteResultProcedure("LG_AGV_库位Moby_允许离开", ref param);
+
+                result.code = agvResult.Success ? 200 : 500;
+                result.message = agvResult.Success ? "AGV放行成功" : $"AGV放行失败：{agvResult.Message}";
+                result.Data = new
+                {
+                    requestId = request.requestId,
+                    position = request.position,
+                    agvResponse = agvResult.Response
+                };
+            }
+            catch (Exception ex)
+            {
+                result.code = 500;
+                result.message = ex.Message;
+                SaveMesLog("LGWEB_AllowLeave", ex.Message, MesLogType.ERROR);
+            }
+
+            string responseText = JsonConvert.SerializeObject(result);
+            SaveLog_Interface_Response(responseText, aid);
+            return responseText;
+        }
+
+        private static LGWEB_RouteInfo GetRouteInfo(string routeCode)
+        {
+            var param = new SqlParameter[]
+            {
+                new SqlParameter("@路线编码", routeCode ?? "")
+            };
+            DataLinkMesWork2.DataAccess2.ExecuteStoredProcedure("LG_AGV_路线_实际终点解析", ref param, out DataTable dt, out string errMessage);
+            if (!string.IsNullOrEmpty(errMessage))
+            {
+                throw new Exception(errMessage);
+            }
+            if (dt == null || dt.Rows.Count == 0)
+            {
+                throw new Exception("路线解析无返回结果");
+            }
+
+            DataRow row = dt.Rows[0];
+            string resultText = row.Table.Columns.Contains("result") ? row["result"].ToString() : "2";
+            if (resultText != "1")
+            {
+                string msg = ReadColumn(row, "msg", "message");
+                throw new Exception(string.IsNullOrWhiteSpace(msg) ? "路线不可用" : msg);
+            }
+
+            return new LGWEB_RouteInfo
+            {
+                RouteCode = ReadColumn(row, "路线编码"),
+                StartPosition = ReadColumn(row, "起点位置"),
+                MidPosition = ReadColumn(row, "中间位置"),
+                OriginalEndPosition = ReadColumn(row, "原终点位置", "终点位置"),
+                ActualEndPosition = ReadColumn(row, "实际终点位置"),
+                InterfaceName = FirstText(ReadColumn(row, "调用接口"), "AddTaskFromMes"),
+                BusinessType = ReadColumn(row, "业务类型"),
+                TriggerMode = ReadColumn(row, "触发方式"),
+                SourceWorkStation = ReadColumn(row, "源工位号"),
+                TargetWorkStation = ReadColumn(row, "目标工位号"),
+                RouteMessage = ReadColumn(row, "msg", "message")
+            };
+        }
+
+        private static void SaveDispatchResult(LGWEB_DispatchRequest request, LGWEB_RouteInfo route, string requestTaskId,
+            string startPosition, string midPosition, string endPosition, string materialCode, LGAGV_CallResult agvResult)
+        {
+            var param = new SqlParameter[]
+            {
+                new SqlParameter("@路线编码", request.routeCode ?? ""),
+                new SqlParameter("@业务类型", route.BusinessType ?? ""),
+                new SqlParameter("@触发方式", string.IsNullOrWhiteSpace(route.TriggerMode) ? "WEB" : route.TriggerMode),
+                new SqlParameter("@订单号", request.orderNo ?? ""),
+                new SqlParameter("@产品编码", FirstText(request.productCode, request.materialCode)),
+                new SqlParameter("@产品型号", request.productModel ?? ""),
+                new SqlParameter("@器具号", request.containerNo ?? ""),
+                new SqlParameter("@requestTaskId", requestTaskId ?? ""),
+                new SqlParameter("@起点位置", startPosition ?? ""),
+                new SqlParameter("@中间位置", midPosition ?? ""),
+                new SqlParameter("@终点位置", endPosition ?? ""),
+                new SqlParameter("@原终点位置", route.OriginalEndPosition ?? ""),
+                new SqlParameter("@materialCode", materialCode ?? ""),
+                new SqlParameter("@调用接口", route.InterfaceName ?? ""),
+                new SqlParameter("@操作人工号", request.operatorCode ?? ""),
+                new SqlParameter("@操作人姓名", request.operatorName ?? ""),
+                new SqlParameter("@备注", request.remark ?? ""),
+                new SqlParameter("@是否成功", agvResult.Success ? 1 : 2),
+                new SqlParameter("@错误信息", agvResult.Success ? "" : (agvResult.Message ?? ""))
+            };
+            ExecuteResultProcedure("LG_AGV_库位Moby_下发任务", ref param);
+        }
+
+        private static string ReadColumn(DataRow row, params string[] columnNames)
+        {
+            foreach (string columnName in columnNames)
+            {
+                if (row.Table.Columns.Contains(columnName))
+                {
+                    return row[columnName]?.ToString() ?? "";
+                }
+            }
+            return "";
+        }
+
+        private static string FirstText(params string[] values)
+        {
+            foreach (string value in values)
+            {
+                if (!string.IsNullOrWhiteSpace(value))
+                {
+                    return value;
+                }
+            }
+            return "";
+        }
+
+        private static void ExecuteResultProcedure(string procedureName, ref SqlParameter[] param)
+        {
+            DataLinkMesWork2.DataAccess2.ExecuteStoredProcedure(procedureName, ref param, out DataTable dt, out string errMessage);
+            if (!string.IsNullOrEmpty(errMessage))
+            {
+                throw new Exception(errMessage);
+            }
+            if (dt != null && dt.Rows.Count > 0 && dt.Columns.Contains("result") && dt.Rows[0]["result"].ToString() != "1")
+            {
+                string msg = dt.Columns.Contains("msg") ? dt.Rows[0]["msg"].ToString() : "存储过程执行失败";
+                throw new Exception(msg);
+            }
+        }
+
+        private class LGWEB_RouteInfo
+        {
+            public string RouteCode { get; set; }
+            public string StartPosition { get; set; }
+            public string MidPosition { get; set; }
+            public string OriginalEndPosition { get; set; }
+            public string ActualEndPosition { get; set; }
+            public string InterfaceName { get; set; }
+            public string BusinessType { get; set; }
+            public string TriggerMode { get; set; }
+            public string SourceWorkStation { get; set; }
+            public string TargetWorkStation { get; set; }
+            public string RouteMessage { get; set; }
+        }
+    }
+}
--- a/Interface_WebAPI/SlMesDbIterface/WebAPI/WEB/LGWEB_Models.cs
+++ b/Interface_WebAPI/SlMesDbIterface/WebAPI/WEB/LGWEB_Models.cs
@@ -0,0 +1,34 @@
+namespace MisDataSaveDate
+{
+    /// <summary>
+    /// 临工AGV网页按钮调度请求。
+    /// </summary>
+    public class LGWEB_DispatchRequest
+    {
+        public string routeCode { get; set; }
+        public string requestTaskId { get; set; }
+        public string startPosition { get; set; }
+        public string midPosition { get; set; }
+        public string materialCode { get; set; }
+        public string productCode { get; set; }
+        public string productModel { get; set; }
+        public string containerNo { get; set; }
+        public string orderNo { get; set; }
+        public string operatorCode { get; set; }
+        public string operatorName { get; set; }
+        public string remark { get; set; }
+    }
+
+    /// <summary>
+    /// 临工AGV网页按钮放行请求。
+    /// </summary>
+    public class LGWEB_AllowLeaveRequest
+    {
+        public string requestId { get; set; }
+        public string position { get; set; }
+        public string agvNo { get; set; }
+        public string operatorCode { get; set; }
+        public string operatorName { get; set; }
+        public string remark { get; set; }
+    }
+}
--- a/Interface_WebAPI/SlMesDbIterface/WebAPI/WEB/WEB_BusinessLogic.cs
+++ b/Interface_WebAPI/SlMesDbIterface/WebAPI/WEB/WEB_BusinessLogic.cs
@@ -80,7 +80,7 @@ namespace MisDataSaveDate
                            throw new Exception("OperAtion_JobStart 缺少必要参数：工位号、订单号或工件编号");
                        }

-                        CALL_Inerface_DataHandle.CALL_Inerface_JobStart(workStation1, orderNo1, workpieceNo1);
+                        CALL_Inerface_DataHandle.CALL_Inerface_JobStart(workStation1, workpieceNo1, orderNo1);
                        break;

                    case "OperAtion_JobFinished":
@@ -98,7 +98,7 @@ namespace MisDataSaveDate
                            throw new Exception("OperAtion_JobFinished 缺少必要参数：工位号、订单号或工件编号");
                        }

-                        CALL_Inerface_DataHandle.CALL_Inerface_JobFinished(workStation2, orderNo2, workpieceNo2);
+                        CALL_Inerface_DataHandle.CALL_Inerface_JobFinished(workStation2, workpieceNo2, orderNo2);
                        break;

                    default:
@@ -408,4 +408,4 @@ namespace MisDataSaveDate
            return retString;
        }
    }
-}
+}