From ac4209926b9d911988be67a8957d5a7a53ec2ce8 Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周二, 02 9月 2025 14:55:39 +0800
Subject: [PATCH] 222

---
 wcs/yunneiWCS/yunneiWCS/SystemInteraction/mes2/PushMesHandler.cs |   75 +++++++++++++++++++++++++++++++++++--
 1 files changed, 70 insertions(+), 5 deletions(-)

diff --git a/wcs/yunneiWCS/yunneiWCS/SystemInteraction/mes2/PushMesHandler.cs b/wcs/yunneiWCS/yunneiWCS/SystemInteraction/mes2/PushMesHandler.cs
index 40821d8..81d256e 100644
--- a/wcs/yunneiWCS/yunneiWCS/SystemInteraction/mes2/PushMesHandler.cs
+++ b/wcs/yunneiWCS/yunneiWCS/SystemInteraction/mes2/PushMesHandler.cs
@@ -1,4 +1,5 @@
-锘縰sing Newtonsoft.Json;
+锘縰sing iWareCommon.Utils;
+using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -6,6 +7,7 @@
 using System.Text;
 using System.Threading.Tasks;
 using yunneiWCS.EnumDefine;
+using yunneiWCS.ExtendFunction;
 using yunneiWCS.SystemInteraction.mes2.dto;
 
 namespace yunneiWCS.mes
@@ -23,9 +25,72 @@
         /// </summary>
         /// <param name="pushData"></param>
         /// <returns></returns>
-        public static ApiResponse<object> Mes_InStockSend(List<InboundStockInfoToMes> pushData)
+        public static ApiResponse<object> Mes_InStockSend(List<InboundStockInfoToMes> pushData, string _identifier, LogType _logType)
         {
             ApiResponse<object> res = null;
+            var funName = "Mes_InStockSend";
+            try
+            {
+                MesRequest<List<InboundStockInfoToMes>> mesRequest = new MesRequest<List<InboundStockInfoToMes>>();
+                mesRequest.data = pushData;
+                mesRequest.identifier = _identifier;
+
+                string paprm = JsonConvert.SerializeObject(mesRequest);
+                Log4NetHelper.WriteInfoLog(_logType, $"{funName},鍑嗗鍙傛暟:{paprm}");
+                Guid guid = System.Guid.NewGuid();
+                res = JsonConvert.DeserializeObject<ApiResponse<object>>(mes_api.postContentForString("T_WMS_Inbound_Record", paprm, guid));
+                Log4NetHelper.WriteInfoLog(_logType, $"{funName},鍙傛暟:{paprm},杩斿洖:{res}");
+            }
+            catch (Exception ex)
+            {
+                Log4NetHelper.WriteErrorLog(_logType, $"{funName},寮傚父:" + ex.Message, ex);
+                res.Message = "鍙戦�佸紓甯�:" + ex.Message;
+            }
+            return res;
+
+        }
+
+
+        /// <summary>
+        /// 缁橫ES鎺ㄩ�佸嚭搴撲俊鎭�
+        /// </summary>
+        /// <param name="pushData"></param>
+        /// <returns></returns>
+        public static ApiResponse<object> Mes_OutStockSend(List<InboundStockInfoToMes> pushData, string _identifier, LogType _logType)
+        {
+            ApiResponse<object> res = null;
+            var funName = "Mes_OutStockSend";
+            try
+            {
+                MesRequest<List<InboundStockInfoToMes>> mesRequest = new MesRequest<List<InboundStockInfoToMes>>();
+                mesRequest.data = pushData;
+                mesRequest.identifier = _identifier;
+
+                string paprm = JsonConvert.SerializeObject(mesRequest);
+                Log4NetHelper.WriteInfoLog(_logType, $"{funName},鍑嗗鍙傛暟:{paprm}");
+                Guid guid = System.Guid.NewGuid();
+                res = JsonConvert.DeserializeObject<ApiResponse<object>>(mes_api.postContentForString("T_WMS_Outbound_Record", paprm, guid));
+                Log4NetHelper.WriteInfoLog(_logType, $"{funName},鍙傛暟:{paprm},杩斿洖:{res}");
+            }
+            catch (Exception ex)
+            {
+                Log4NetHelper.WriteErrorLog(_logType, $"{funName},寮傚父:" + ex.Message, ex);
+                res.Message = "鍙戦�佸紓甯�:" + ex.Message;
+            }
+            return res;
+
+        }
+
+
+        /// <summary>
+        /// 缁橫ES鎺ㄩ�佸簱瀛樹俊鎭�
+        /// </summary>
+        /// <param name="pushData"></param>
+        /// <returns></returns>
+        public static ApiResponse<object> Mes_StockSend(List<InboundStockInfoToMes> pushData, LogType _logType)
+        {
+            ApiResponse<object> res = null;
+            var funName = "Mes_StockSend";
             try
             {
                 MesRequest<List<InboundStockInfoToMes>> mesRequest = new MesRequest<List<InboundStockInfoToMes>>();
@@ -33,12 +98,12 @@
 
                 string paprm = JsonConvert.SerializeObject(mesRequest);
                 Guid guid = System.Guid.NewGuid();
-                res = JsonConvert.DeserializeObject<ApiResponse<object>>(mes_api.postContentForString("T_WMS_Inbound_Record", paprm, guid));
-                WZ.Useful.Commons.LogTextHelper.WriteLine("PushMesHandler", "Mes_InStockSend 杩斿洖鐘舵�佺爜:", res.Code + " 杩斿洖淇℃伅:" + res.Message);
+                res = JsonConvert.DeserializeObject<ApiResponse<object>>(mes_api.postContentForString("T_WMS_Realtime_Data", paprm, guid));
+                Log4NetHelper.WriteInfoLog(_logType, $"{funName},鍙傛暟:{paprm},杩斿洖:{res}");
             }
             catch (Exception ex)
             {
-                WZ.Useful.Commons.LogTextHelper.WriteLine("PushMesHandler", "Mes_InStockSend ", " 鍙戦�佸紓甯�:" + JsonConvert.SerializeObject(ex));
+                Log4NetHelper.WriteErrorLog(_logType, $"{funName},寮傚父:" + ex.Message, ex);
                 res.Message = "鍙戦�佸紓甯�:" + ex.Message;
             }
             return res;

--
Gitblit v1.9.3