1

huanghongfeng

2024-11-27 1dd9f4bf540a74a7de2daeeebf38491f86befa08

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs

@@ -20,6 +20,7 @@
using NetTaste;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using SqlSugar;
using System;
@@ -45,7 +46,6 @@
using WIDESEAWCS_ITaskInfoRepository;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.Models;
using WIDESEAWCS_QuartzJob.Service;

@@ -85,6 +85,9 @@
        public string urlWMSMovelibraryTask = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlWMSMovelibraryTask"];
        public string urlRelocationTaskCompleted = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlRelocationTaskCompleted"];
        public string urlQueryinventory = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlQueryinventory"];
        public string urlEmptyOutbound = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlEmptyOutbound"];
        public string urlRawmaterialout = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlRawmaterialout"];
        public string urlPalletQueryinventory = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlPalletQueryinventory"];
        /// <summary>
        /// æŽ¥æ”¶WMS任务信息
        /// </summary>
@@ -128,13 +131,30 @@
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public class GenerateInv
        {
            public string SourceAddress { get; set; }
            public string PalletCode { get; set; }
        }

        public class GenerateInv3
        {
            
            public string PalletCode { get; set; }
            public int outCount { get; set; }
            public string TargetAddress { get; set; }
        }
        public WebResponseContent RequestWMSTask(string palletCode, string sourceAddress)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                palletCode = "6431-jdsda-jjal333-300";
                content = HttpHelper.Get<WebResponseContent>($"{urlWMSTask}?sourceAddress={sourceAddress}&palletCode={palletCode}");
                GenerateInv generate = new GenerateInv()
                {
                    SourceAddress=sourceAddress,
                    PalletCode = palletCode
                };
                content = HttpHelper.Post<WebResponseContent>($"{urlWMSTask}", generate);
                Dt_Task task = new Dt_Task();
                if (content != null)
                {
@@ -144,37 +164,152 @@
                        task.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        BaseDal.AddData(task);
                    }
                    else
                    {

                        return null;
                        return content = WebResponseContent.Instance.Error();
                    }
                }
                else
                {
                    return null;
                }
                
                return content = WebResponseContent.Instance.Error();
            }
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// æŸ¥è¯¢åº“位
        /// è¿›è¡Œç»„盘
        /// </summary>
        /// <param name="palletCode"></param>
        /// <returns></returns>
        public WebResponseContent ToPlatform(string palletCode)
        {
            try
            {
                WebResponseContent content = new WebResponseContent();
                GenerateInv generate = new GenerateInv()
                {
                    SourceAddress = "",
                    PalletCode = palletCode
                };

                return content = HttpHelper.Post<WebResponseContent>($"{urlQueryinventory}", generate);
            }
            catch (Exception ex)
            {

                throw;
            }

            /*WebResponseContent content = new WebResponseContent();
            GenerateInv generate = new GenerateInv()
            {
                SourceAddress = "",
                PalletCode = palletCode
            };
            content = HttpHelper.Post<WebResponseContent>($"{urlQueryinventory}", generate);
            if (content != null)
            {
                if (content.Status)
                {
                    return content;
                }
            }
            return content = WebResponseContent.Instance.Error();*/
        }

        /// <summary>
        /// æ ¹æ®æ‰˜ç›˜å·ã€èµ·å§‹åœ°å€å‘WMS请求任务
        /// </summary>
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public WebResponseContent RequestWMSTask2(string palletCode,string sourceAddress)
        {
            WebResponseContent content = new WebResponseContent();
            return  content = HttpHelper.Get<WebResponseContent>($"{urlQueryinventory}?palletCode={palletCode}");
            try
            {
                GenerateInv generate = new GenerateInv()
                {
                    SourceAddress = sourceAddress,
                    PalletCode = palletCode
                };
                content = HttpHelper.Post<WebResponseContent>($"{urlEmptyOutbound}", generate);
                Dt_Task task = new Dt_Task();
                if (content != null)
                {
                    if (content.Status)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.TaskType = (int)TaskOutboundTypeEnum.Outbound;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        BaseDal.AddData(task);
                        return content = WebResponseContent.Instance.OK();
                    }
                }
                return content = WebResponseContent.Instance.Error();
            }
            catch (Exception ex)
            {
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
        }

        /// <summary>
        /// æ ¹æ®æ‰˜ç›˜å·ã€èµ·å§‹åœ°å€å‘WMS请求任务
        /// </summary>
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public WebResponseContent RequestWMSTask3(string palletCode, int outCount,string Loc)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                if (outCount==0)
                {
                    outCount = 1;
                }
                GenerateInv3 generate = new GenerateInv3()
                {
                    PalletCode = palletCode,
                    outCount = outCount,
                    TargetAddress= Loc
                };
                content = HttpHelper.Post<WebResponseContent>($"{urlRawmaterialout}", generate);
                Dt_Task task = new Dt_Task();
                if (content != null)
                {
                    if (content.Status)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.TaskType = (int)TaskOutboundTypeEnum.Outbound;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        BaseDal.AddData(task);
                        return content = WebResponseContent.Instance.OK();
                    }
                }
                return content = WebResponseContent.Instance.Error();
            }
            catch (Exception ex)
            {
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
        }


        public WebResponseContent RequestWMSTask4()
        {
            WebResponseContent content = new WebResponseContent();
            try
            {

                return content = HttpHelper.Get<WebResponseContent>($"{urlPalletQueryinventory}");
            }
            catch (Exception ex)
            {
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
        }
        /// <summary>
        /// æ ¹æ®æ·±åº“位向wms申请判断浅库位是否有货，是否需要进行移库操作
        /// </summary>
@@ -190,16 +325,21 @@
            {
                if (content.Status)
                {
                    if (Convert.ToInt32(content.Data) != _Task.TaskNum)
                    if(content.Data != null)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        task.TaskState = (int)TaskRelocationTypeEnum.Relocation;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        task.Grade = 3;
                        BaseDal.AddData(task);
                        return task;
                    }
                        if (task.TaskNum != _Task.TaskNum)
                        {

                            task.TaskState = (int)TaskRelocationTypeEnum.Relocation;
                            task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                            task.TaskNum = task.TaskNum;
                            task.Grade = 3;
                            task.TaskType= (int)TaskRelocationTypeEnum.Relocation;
                            BaseDal.AddData(task);
                            return task;
                        }
                    }
                }
            }

@@ -271,8 +411,14 @@
        }
        public Dt_Task IngStackerCraneTask(string deviceNo)
        {
            string deviceNot = deviceNo == "SC01" ? "1" : "2";
            return BaseDal.QueryFirst(x => x.Roadway == deviceNot && x.TaskState == (int)TaskInStatusEnum.SC_InExecuting);
            //string deviceNot = deviceNo == "SC01" ? "1" : "2";
            return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.TaskState == (int)TaskInStatusEnum.SC_InExecuting);
        }

        public Dt_Task IngStackerCraneTask2(string deviceNo)
        {
            //string deviceNot = deviceNo == "SC01" ? "1" : "2";
            return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting);
        }

        /// <summary>
@@ -322,7 +468,7 @@
        /// <returns>返回任务实体对象集合，可能为null</returns>
        public List<Dt_Task> QueryStationIsOccupiedOutTasks(string deviceNo, string SourceAddress)
        {
            return BaseDal.QueryData(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew && SourceAddress.Contains(x.SourceAddress), TaskOrderBy);
            return BaseDal.QueryData(x => x.Roadway == deviceNo && SourceAddress.Contains(x.SourceAddress), TaskOrderBy);
        }

        /// <summary>
@@ -522,6 +668,12 @@
        /// </summary>
        /// <param name="taskNum">任务编号</param>
        /// <returns>返回处理结果</returns>
        public class GenerateInv2
        {
            public string PalletCode { get; set; }
            public string SourceAddress { get; set; }
            public string TargetAddress { get; set; }
        }
        public WebResponseContent StackCraneTaskCompleted(int taskNum)
        {
            WebResponseContent content = new WebResponseContent();
@@ -560,7 +712,14 @@
                }
                else if (task.TaskType == (int)TaskRelocationTypeEnum.Relocation)
                {
                    content = HttpHelper.Get<WebResponseContent>($"{urlRelocationTaskCompleted}?PalletCode={task.PalletCode}&SourceAddress ={ task.SourceAddress}TargetAddress ={task.TargetAddress}");
                    GenerateInv2 generate = new GenerateInv2()
                    {
                        PalletCode = task.PalletCode,
                        SourceAddress = task.SourceAddress,
                        TargetAddress = task.TargetAddress

                    };
                    content = HttpHelper.Post<WebResponseContent>($"{urlRelocationTaskCompleted}", generate);
                    task.TaskState = (int)TaskOutStatusEnum.SC_OutFinish;
                    task.ModifyDate = DateTime.Now;
                    BaseDal.DeleteData(task);