From 0b5ccdca6263cf7a2cee460f30c76ef1efea2811 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期六, 27 四月 2024 17:47:27 +0800
Subject: [PATCH] 人工出库,人工入库,人工移库,PDA扫码确认外协物料已被取走接口

---
 代码管理/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs |   35 ++++++++++++++++++++++++++++++-----
 1 files changed, 30 insertions(+), 5 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs"
index 8680c72..9c9d9dc 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/RestockHCJ.cs"
@@ -9,12 +9,15 @@
 using WIDESEA_Core.BaseProvider;
 using WIDESEA_Core.EFDbContext;
 using WIDESEA_Entity.DomainModels;
+using WIDESEA_Entity.ToAGV;
 using WIDESEA_WCS.IRepositories;
 using WIDESEA_WCS.Repositories;
 using WIDESEA_WCS.WCSClient;
 using WIDESEA_WMS.IRepositories;
 using WIDESEA_WMS.IServices;
 using WIDESEA_WMS.Repositories;
+using static FreeSql.Internal.GlobalFilter;
+using static System.Collections.Specialized.BitVector32;
 
 namespace WIDESEA_WCS.JobsPart.Common
 {
@@ -29,19 +32,19 @@
             {
                 VOLContext Context = new VOLContext();
                 Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);
-
+                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);
                 Idt_agvtaskRepository agvtaskService = new dt_agvtaskRepository(Context);
                 var tasks = agvtaskService.Find(x => x.agv_taskstate == "Queue").OrderByDescending(x => x.agv_grade).ThenBy(x => x.agv_createtime).ToList();
                 foreach (var task in tasks)
                 {
                     if (task.agv_tasktype == "TaskType_EmptyPallet")//绌烘墭浠诲姟
                     {
-                        if (task.agv_fromaddress == "" && DateTime.Now - task.agv_createtime >= TimeSpan.FromMinutes(1))
+                        if (task.agv_fromaddress == "" && DateTime.Now - task.agv_createtime >= TimeSpan.FromMinutes(2))
                         {
                             if (task.agv_tasknum.Contains("_"))
                             {
                                 string mainTaskNum = task.agv_tasknum.Split('_')[0];
-                                if (agvtaskService.Find(x => x.agv_tasknum == mainTaskNum && (task.agv_taskstate == "Executing1" || task.agv_taskstate == "Complete1")).Any())
+                                if (agvtaskService.Find(x => x.agv_tasknum == mainTaskNum && task.agv_taskstate != "Executing" && task.agv_taskstate != "Create").Any() || !agvtaskService.Find(x => x.agv_tasknum == mainTaskNum).Any())
                                     GetStation.EmptyPalletStation(task);
                             }
                             else
@@ -100,11 +103,33 @@
                             #endregion
                         }
                     }
+                    else if (task.agv_tasktype == "TaskType_OutsourceInbound" || task.agv_tasktype == "TaskType_Inbound")//澶栧崗搴撳叆搴�/AB搴撳叆搴�
+                    {
+                        if (task.agv_toaddress == "")
+                        {
+                            var stationinfo = stationinfoRepository.Find(x => x.stationCode == task.agv_fromaddress).FirstOrDefault();
+                            var work = workinfoRepository.Find(x => x.workOrder == stationinfo.Number && x.drawingNo == stationinfo.stationType && x.heatID == stationinfo.heatNumber && x.processCode == "17").FirstOrDefault();
+                            var TargetLocation = task.agv_tasktype == "TaskType_Inbound" ? GetLocation.GetEmptyLocation(stationinfoRepository, work, stationinfo) : StationTask.GetEmptyLocation(stationinfoRepository);
+                            if (TargetLocation != null)
+                            {
+                                if (agvtaskService.Find(x => x.agv_toaddress == TargetLocation.stationCode).Any()) continue;
+                                task.agv_taskstate = "Create";
+                                task.agv_toaddress = TargetLocation.stationCode;
+                                TargetLocation.location_state = LocationStateEnum.InBusy.ToString();
+                                TargetLocation.billetID = stationinfo.billetID;
+                                TargetLocation.stationType = task.agv_materielid;
+                                TargetLocation.heatNumber = stationinfo.heatNumber;
+                                TargetLocation.Number = task.jobID;
+                                stationinfoRepository.Update(TargetLocation, true);
+                                agvtaskService.Update(task, true);
+                            }
+                        }
+                    }
                     else if (task.agv_tasktype == "TaskType_OutsourceOutbound" || task.agv_tasktype == "TaskType_Outbound")//澶栧崗搴撳嚭搴�/AB搴撳嚭搴�
                     {
                         if (task.agv_toaddress == "")
                         {
-                            var EmptyStations = stationinfoRepository.Find(x => x.stationCode.Contains("S01001") && x.location_state == "Empty" && x.enable).ToList();
+                            var EmptyStations = stationinfoRepository.Find(x => x.stationCode.Contains("S01001") && x.tray_status == "EmptyTray" /*x.location_state == "Empty"*/ && x.enable).ToList();
                             foreach (var EmptyStation in EmptyStations)
                             {
                                 if (agvtaskService.Find(x => x.agv_toaddress == EmptyStation.stationCode).Any()) continue;
@@ -118,7 +143,7 @@
                             }
                         }
                     }
-                    else if (task.agv_tasktype == "TaskType_OutsourceCarry")//澶栧崗绉诲簱
+                    else if (task.agv_tasktype == "TaskType_OutsourceCarry")//绉诲簱澶栧崗
                     {
                         if (task.agv_toaddress == "")
                         {

--
Gitblit v1.9.3