From 8fd37f3264769033beed4129647d553e006a30ea Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期三, 11 六月 2025 15:08:38 +0800
Subject: [PATCH] 更新数据库连接和任务处理逻辑

---
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/appsettings.json                                     |    2 +-
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs             |    8 ++++++--
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StoragIntegrationServices/MCS/Partial/RequestChangeLocation.cs |   11 ++++++++---
 3 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/appsettings.json b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/appsettings.json
index 5a35f91..94f23b4 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/appsettings.json
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/appsettings.json
@@ -11,7 +11,7 @@
   "ConnectionStringsEncryption": false,
   "MainDB": "DB_WIDESEA", //褰撳墠椤圭洰鐨勪富搴擄紝鎵�瀵瑰簲鐨勮繛鎺ュ瓧绗︿覆鐨凟nabled蹇呴』涓簍rue
   //杩炴帴瀛楃涓�
-  "ConnectionString": "Data Source=.;Initial Catalog=WIDESEA_WCSDB_BBMain;User ID=sa;Password=P@ssw0rd;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
+  "ConnectionString": "Data Source=.\\LIULEI;Initial Catalog=WIDESEA_WCSDBB2F;User ID=sa;Password=123456;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
   //"ConnectionString": "Data Source=127.0.0.1;Initial Catalog=WIDESEA_WCSDB_BB3F;User ID=sa;Password=P@ssw0rd;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
   //璺ㄥ煙
   "Cors": {
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StoragIntegrationServices/MCS/Partial/RequestChangeLocation.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StoragIntegrationServices/MCS/Partial/RequestChangeLocation.cs
index f9c547c..9e4ae38 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StoragIntegrationServices/MCS/Partial/RequestChangeLocation.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StoragIntegrationServices/MCS/Partial/RequestChangeLocation.cs
@@ -222,7 +222,7 @@
                 throw new Exception("娑堥槻绔欏彴鏈厤缃�!");
             }
             //鏌ユ壘搴撳瓨淇℃伅
-            var barcodeData = _stockInfoRepository.QueryFirst(t => t.LocationCode == location.LocationCode);
+            var barcodeData = _stockInfoRepository.QueryFirst(t => t.LocationCode == location.LocationCode && t.LocationInfo.RoadwayNo == location.RoadwayNo);
             //鎵樼洏鐮�
             string barcode = string.Empty;
             if (barcodeData != null)
@@ -267,16 +267,21 @@
                 TaskType = 500,
             };
 
+
+
             var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
             var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;
-            var ReceiveByWMSTask = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveByWMSTask)?.ConfigValue;
+            var ReceiveByWMSTask = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveTask)?.ConfigValue;
             if (ReceiveByWMSTask == null || ipAddress == null)
             {
                 throw new Exception("WMS IP 鏈厤缃�");
             }
             var wmsIpAddrss = ipAddress + ReceiveByWMSTask;
 
-            var respon = HttpHelper.Post(wmsIpAddrss, JsonConvert.SerializeObject(taskDTO));   //http://localhost:9291/api/Task/ReceiveTask,
+            List<WMSTaskDTO> fireTaskDTO = new List<WMSTaskDTO>();
+            fireTaskDTO.Add(taskDTO);
+
+            var respon = HttpHelper.Post(wmsIpAddrss, JsonConvert.SerializeObject(fireTaskDTO));   //http://localhost:9291/api/Task/ReceiveTask,
             if (respon != null)
             {
                 WebResponseContent respone = JsonConvert.DeserializeObject<WebResponseContent>(respon.ToString());
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
index 95b907c..d44432e 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
@@ -1144,6 +1144,7 @@
         var emergencyTask = new DTSEmergencyTask();
         try
         {
+            Console.WriteLine($"鐏鍙傛暟:{obj.ToString()}");
             emergencyTask = JsonConvert.DeserializeObject<DTSEmergencyTask>(obj.ToString());
             if (emergencyTask == null) throw new Exception("鐏鍙傛暟涓虹┖");
             string[] strings = emergencyTask.LocationCode.Split("-");
@@ -1234,16 +1235,19 @@
                     TaskType = task.TaskType,
                 };
 
+                List<WMSTaskDTO> taskDTOs = new List<WMSTaskDTO>();
+                taskDTOs.Add(taskDTO);
+
                 var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
                 var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;
-                var ReceiveByWMSTask = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveByWMSTask)?.ConfigValue;
+                var ReceiveByWMSTask = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveTask)?.ConfigValue;
                 if (ReceiveByWMSTask == null || ipAddress == null)
                 {
                     throw new Exception("WMS IP 鏈厤缃�");
                 }
                 var wmsIpAddrss = ipAddress + ReceiveByWMSTask;
 
-                var respon = HttpHelper.Post(wmsIpAddrss, JsonConvert.SerializeObject(taskDTO));
+                var respon = HttpHelper.Post(wmsIpAddrss, JsonConvert.SerializeObject(taskDTOs));
                 if (respon != null)
                 {
                     WebResponseContent respone = JsonConvert.DeserializeObject<WebResponseContent>(respon.ToString());

--
Gitblit v1.9.3