agv接口迁移到WCS，新增接口表

wangxinhui

2024-12-23 369b0450f83c4efaee4efec7a1356d16c790a722

agv接口迁移到WCS，新增接口表

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/.vs/WIDESEAWCS_Server/FileContentIndex/00a56665-6752-4d06-b9b6-0852d20709ee.vsidx

Binary files differ

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/.vs/WIDESEAWCS_Server/FileContentIndex/7a005823-c1a7-4703-9472-7a90323886f9.vsidx

Binary files differ

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/.vs/WIDESEAWCS_Server/FileContentIndex/read.lock

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_Common/APIEnum/APIEnum.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEAWCS_Common.APIEnum
{
    public enum APIEnum
    {
        [Description("AGV发送任务接口")]
        AgvSendTask,
        [Description("AGV安全信号回复")]
        AgvSecureReply
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_DTO/Agv/AgvResponseContent.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEA_DTO.Agv
{
    public class AgvResponseContent
    {
        /// <summary>
        /// è¿”回码
        /// </summary>
        public string Code { get; set; }
        /// <summary>
        /// è¿”回消息
        /// </summary>
        public string Message { get; set; }
        /// <summary>
        /// è¯·æ±‚编号
        /// </summary>
        public string ReqCode { get; set; }
        /// <summary>
        /// è‡ªå®šä¹‰è¿”回（返回任务单号）
        /// </summary>
        public string Data { get; set; }
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_DTO/Agv/AgvSecureApplyDTO.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEA_DTO.Agv
{
    public class AgvSecureApplyDTO
    {
        /// <summary>
        /// è¯·æ±‚编号 æ¯ä¸ªè¯·æ±‚都要一个唯一编号,同一个请求重复提交使用同一编号
        /// </summary>
        public string ReqCode { get; set; }
        /// <summary>
        /// ç›®æ ‡ä½
        /// </summary>
        public string WbCode { get; set; }
        /// <summary>
        /// ä»»åŠ¡å•å·
        /// </summary>
        public string TaskCode { get; set; }
        /// <summary>
        /// æ‰¹æ¬¡
        /// </summary>
        public string MaterialLot { get; set; }
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_DTO/Agv/AgvSecureReplyDTO.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,56 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEA_DTO.Agv
{
    public class AgvSecureReplyDTO
    {
        /// <summary>
        /// è¯·æ±‚编号 æ¯ä¸ªè¯·æ±‚都要一个唯一编号,同一个请求重复提交,使用同一编号
        /// </summary>
        public string ReqCode { get; set; }
        /// <summary>
        /// è¯·æ±‚时间 æ ¼å¼:yyyy-MM-dd HH:mm:ss
        /// </summary>
        public string ReqTime { get; set; }
        /// <summary>
        /// å®¢æˆ·ç«¯ç¼–号 
        /// </summary>
        public string ClientCode { get; set; }
        /// <summary>
        /// ä»¤ç‰Œå· ç”±è°ƒåº¦ç³»ç»Ÿé¢å‘
        /// </summary>
        public string TokenCode { get; set; }
        /// <summary>
        /// å·¥ä½œä½ ä¸ŽRCS-2000端配置的位置名称一致
        /// </summary>
        public string WbCode { get; set; }
        /// <summary>
        /// è½½å…·ç¼–号
        /// </summary>
        public string podCode { get; set; }
        /// <summary>
        /// AGV编号
        /// </summary>
        public string agvCode { get; set; }
        /// <summary>
        /// ä»»åŠ¡å· 
        /// </summary>
        public string taskCode { get; set; }
        /// <summary>
        /// ä¸‹ä¸€ä¸ªå­ä»»åŠ¡åºåˆ— æŒ‡å®šç¬¬å‡ ä¸ªå­ä»»åŠ¡å¼€å§‹æ‰§è¡Œ,校验子任务执行是否正确,不填默认执行下一个子任务。
        /// </summary>
        public string taskSeq { get; set; }
        /// <summary>
        /// ä¸‹ä¸€ä¸ªä½ç½®ä¿¡æ¯
        /// positionCode:位置编号
        /// type:对象类型定义:
        /// 00:代表 nextPositionCode是一个位置
        /// 02:代表 nextPositionCode是一个策略
        /// </summary>
        public object nextPositionCode { get; set; }
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_DTO/Agv/AgvTaskDTO.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,72 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEA_DTO.Agv
{
    /// <summary>
    /// AGV任务
    /// </summary>
    public class AgvTaskDTO
    {
        /// <summary>
        /// è¯·æ±‚编号 æ¯ä¸ªè¯·æ±‚都要一个唯一编号,同一个请求重复提交,使用同一编号
        /// </summary>
        public string ReqCode { get; set; }
        /// <summary>
        /// ä»»åŠ¡ç±»åž‹
        /// </summary>
        public string TaskTyp { get; set; }
        /// <summary>
        /// å·¥ä½œä½
        /// </summary>
        public string WbCode { get; set; }
        /// <summary>
        /// ä½ç½®è·¯å¾„
        /// </summary>
        public List<object> PositionCodePath { get; set; }
        /// <summary>
        /// è½½å…·ç¼–号
        /// </summary>
        public string PodCode { get; set; }
        /// <summary>
        /// è½½å…·ç±»åž‹
        /// </summary>
        public string PodTyp { get; set; }
        /// <summary>
        /// ç‰©æ–™æ‰¹æ¬¡
        /// </summary>
        public string MaterialLot { get; set; }
        /// <summary>
        /// ä¼˜å…ˆçº§(1~127)最大优先级最高 ä¸ºç©ºæ—¶,采用任务模板的优先级
        /// </summary>
        public string Priority { get; set; }
        /// <summary>
        /// AGV任务号
        /// </summary>
        public string TaskCode { get; set; }
        /// <summary>
        /// AGV设备编号 å¡«å†™å¯æŒ‡å®šæŸä¸€ç¼–号的AGV执行该任务
        /// </summary>
        public string AgvCode { get; set; }
        /// <summary>
        /// AGV设备类型
        /// </summary>
        public string AgvTyp { get; set; }
        /// <summary>
        /// åŒºåŸŸ/策略<br/>
        /// æŒ‘选货架以及根据物料批次挑选货架时的先进先出规则，支持以下4个值：<br/>
        /// 1：按照货架到达储位的时间顺序，先进先出<br/>
        /// 2：按照货架到达储位的时间顺序，先进后出<br/>
        /// 9：按照货架绑定物料批次的时间顺序，先进先出<br/>
        /// 10：按照货架绑定物料批次的时间顺序，先进后出<br/>
        /// </summary>
        public string PositionSelStrategy { get; set; }
        /// <summary>
        /// è‡ªå®šä¹‰å­—段
        /// </summary>
        public string Data { get; set; }
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_DTO/Agv/AgvUpdateDTO.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,111 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WIDESEA_DTO.Agv
{
    public class AgvUpdateDTO
    {
        /// <summary>
        /// è¯·æ±‚编号 æ¯ä¸ªè¯·æ±‚都要一个唯一编号,同一个请求重复提交使用同一编号
        /// </summary>
        public string ReqCode { get; set; }
        /// <summary>
        /// è¯·æ±‚时间 æ ¼å¼:yyyy-MM-dd HH:mm:ss
        /// </summary>
        public string ReqTime { get; set; }
        /// <summary>
        /// ä½ç½®X坐标 ä»»åŠ¡å®Œæˆæ—¶æœ‰å€¼
        /// </summary>
        public int CooX { get; set; }
        /// <summary>
        /// ä½ç½®Y坐标 ä»»åŠ¡å®Œæˆæ—¶æœ‰å€¼
        /// </summary>
        public int CooY { get; set; }
        /// <summary>
        /// å½“前位置编号<br/>
        /// ä»»åŠ¡å¼€å§‹ï¼šè¯¥ä½ç½®ä¸ºä»»åŠ¡èµ·ç‚¹<br/>
        /// èµ°å‡ºå‚¨ä½ï¼šè¯¥ä½ç½®ä¸ºä»»åŠ¡èµ·ç‚¹<br/>
        /// ä»»åŠ¡å•å–消：该位置为工作位编号<br/>
        /// ä»»åŠ¡ç»“束：该位置为任务终点<br/>
        /// å–放申请：取放料箱的点<br/>
        /// </summary>
        public string CurrentPositionCode { get; set; }
        /// <summary>
        /// è‡ªå®šä¹‰å­—段
        /// </summary>
        public string Data { get; set; }
        /// <summary>
        /// åœ°å›¾ç¼–号 
        /// </summary>
        public string MapCode { get; set; }
        /// <summary>
        /// åœ°ç ç¼–号 ä»»åŠ¡å®Œæˆæ—¶æœ‰å€¼
        /// </summary>
        public string MapDataCode { get; set; }
        /// <summary>
        /// ä»“位编码 å‰è½¦ä¸ŽCTU任务时有值
        /// </summary>
        public string StgBinCode { get; set; }
        /// <summary>
        /// æ–¹æ³•å<br/>
        /// start : ä»»åŠ¡å¼€å§‹<br/>
        ///  outbin : èµ°å‡ºå‚¨ä½<br/>
        ///  end : ä»»åŠ¡ç»“束<br/>
        ///  cancel : ä»»åŠ¡å•å–消<br/>
        ///  apply：CTU料箱取放申请<br/>
        /// </summary>
        public string Method { get; set; }
        /// <summary>
        /// è½½å…·ç¼–号
        /// </summary>
        public string PodCode { get; set; }
        /// <summary>
        /// è½½å…·æ–¹å‘
        /// </summary>
        public string PodDir { get; set; }
        /// <summary>
        /// ç‰©æ–™æ‰¹æ¬¡å·
        /// </summary>
        public string MaterialLot { get; set; }
        /// <summary>
        /// ç‰©æ–™ç±»åž‹
        /// </summary>
        public string MaterialType { get; set; }
        /// <summary>
        /// AGV编号
        /// </summary>
        public string RobotCode { get; set; }
        /// <summary>
        /// ä»»åŠ¡å•å·
        /// </summary>
        public string TaskCode { get; set; }
        /// <summary>
        /// å·¥ä½œå°ç¼–号 ä»»åŠ¡å®Œæˆæ—¶æœ‰å€¼,与生成任务单接口中的wbCode一致
        /// </summary>
        public string WbCode { get; set; }
        /// <summary>
        /// å®¹å™¨ç¼–号
        /// </summary>
        public string CtnrCode { get; set; }
        /// <summary>
        /// å®¹å™¨ç±»åž‹
        /// </summary>
        public string CtnrType { get; set; }
        /// <summary>
        /// å··é“编号
        /// </summary>
        public string RoadWayCode { get; set; }
        /// <summary>
        /// å··é“内顺序号<br/>
        /// å··é“尾是0依次到巷道头依次递增1
        /// </summary>
        public string Seq { get; set; }
        /// <summary>
        /// è®¾å¤‡ç¼–号
        /// </summary>
        public string EqpCode { get; set; }
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_ITaskInfoService/ITaskService.cs

@@ -22,6 +22,7 @@
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_DTO.Agv;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseServices;
@@ -118,12 +119,35 @@
        /// <param name="taskNum">任务号</param>
        /// <returns>返回处理结果</returns>
        WebResponseContent TaskStatusRecovery(int taskNum);

        /// <summary>
        /// å›žæ»šä»»åŠ¡çŠ¶æ€
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <returns>返回处理结果</returns>
        WebResponseContent RollbackTaskStatusToLast(int taskNum);
        /// <summary>
        /// å‘送AGV任务
        /// </summary>
        /// <param name="taskModel"></param>
        /// <returns></returns>
        WebResponseContent AgvSendTask(AgvTaskDTO taskModel);
        /// <summary>
        /// å®‰å…¨ä¿¡å·ç”³è¯·
        /// </summary>
        /// <param name="secureApplyModel"></param>
        /// <returns></returns>
        AgvResponseContent AgvSecureApply(AgvSecureApplyDTO secureApplyModel);
        /// <summary>
        /// å®‰å…¨ä¿¡å·å›žå¤ WCS-AGV
        /// </summary>
        /// <param name="secureModel"></param>
        /// <returns></returns>
        WebResponseContent AgvSecureReply(AgvSecureReplyDTO secureReplyModel);
        /// <summary>
        /// AGV任务状态刷新
        /// </summary>
        /// <param name="agvUpdateModel"></param>
        /// <returns></returns>
        AgvResponseContent AgvUpdateTask(AgvUpdateDTO agvUpdateModel);
    }
}

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_Model/Models/BasicInfo/Dt_ApiInfo.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,40 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Core.DB.Models;

namespace WIDESEAWCS_Model.Models
{
    [SugarTable(nameof(Dt_ApiInfo), "接口信息")]
    public class Dt_ApiInfo : BaseEntity
    {
        /// <summary>
        /// ä¸»é”®
        /// </summary>
        [SugarColumn(IsPrimaryKey = true, IsIdentity = true, ColumnDescription = "主键")]
        public int Id { get; set; }
        /// <summary>
        /// æŽ¥å£ç¼–号
        /// </summary>
        [SugarColumn(IsNullable = false, Length = 50, ColumnDescription = "接口编号")]
        public string ApiCode { get; set; }
        /// <summary>
        /// æŽ¥å£åç§°
        /// </summary>
        [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "接口名称")]
        public string ApiName { get; set; }
        /// <summary>
        /// æŽ¥å£åœ°å€
        /// </summary>
        [SugarColumn(IsNullable = true, Length = 200, ColumnDescription = "接口地址")]
        public string ApiAddress { get; set; }
        /// <summary>
        /// å¤‡æ³¨
        /// </summary>
        [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "备注")]
        public string Remark { get; set; }
    }
}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,91 @@
using Autofac.Core;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_DTO.Agv;
using WIDESEAWCS_Common.APIEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.Helper;

namespace WIDESEAWCS_TaskInfoService
{
    public partial class TaskService
    {
        /// <summary>
        /// å‘送AGV任务 
        /// </summary>
        /// <param name="taskModel"></param>
        /// <returns></returns>
        public WebResponseContent AgvSendTask(AgvTaskDTO taskModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                string apiAddress = AppSettings.Get(APIEnum.AgvSendTask.ToString());
                string response = HttpHelper.Post(apiAddress, taskModel.Serialize());
                AgvResponseContent agvContent= response.DeserializeObject<AgvResponseContent>();
                if (agvContent.Code=="200")
                {
                    content.OK(agvContent.Message);
                }
                else
                {
                    content.Error(agvContent.Message);
                }
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// å®‰å…¨ä¿¡å·ç”³è¯· AGV-WCS
        /// </summary>
        public AgvResponseContent AgvSecureApply(AgvSecureApplyDTO secureApplyModel)
        {

            return new AgvResponseContent();
        }
        /// <summary>
        /// å®‰å…¨ä¿¡å·å›žå¤ WCS-AGV
        /// </summary>
        /// <param name="secureModel"></param>
        /// <returns></returns>
        public WebResponseContent AgvSecureReply(AgvSecureReplyDTO secureReplyModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                string apiAddress = AppSettings.Get(APIEnum.AgvSecureReply.ToString());
                string response = HttpHelper.Post(apiAddress, secureReplyModel.Serialize());
                AgvResponseContent agvContent = response.DeserializeObject<AgvResponseContent>();
                if (agvContent.Code == "200")
                {
                    content.OK(agvContent.Message);
                }
                else
                {
                    content.Error(agvContent.Message);
                }
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// AGV任务状态刷新
        /// </summary>
        /// <param name="agvUpdateModel"></param>
        /// <returns></returns>
        public AgvResponseContent AgvUpdateTask(AgvUpdateDTO agvUpdateModel)
        {

            return new AgvResponseContent();
        }
    }
}

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

@@ -41,7 +41,7 @@

namespace WIDESEAWCS_TaskInfoService
{
    public class TaskService : ServiceBase<Dt_Task, ITaskRepository>, ITaskService
    public partial class TaskService : ServiceBase<Dt_Task, ITaskRepository>, ITaskService
    {
        private readonly IRouterService _routerService;
        private readonly ITaskExecuteDetailService _taskExecuteDetailService;

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/FileContentIndex/2c5380f0-67c1-41e2-940e-3a1dd36603f2.vsidx

Binary files differ

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/FileContentIndex/7a833a68-07df-4786-a4b8-e9726236f98d.vsidx

Binary files differ

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/FileContentIndex/94b1eced-02e0-42fa-a704-73db3cda704b.vsidx

Binary files differ

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/FileContentIndex/fde68f49-1fc8-44c8-8785-4d80e9e536c1.vsidx

Binary files differ

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/FileContentIndex/read.lock

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/WIDESEA_Model/Models/Basic/Dt_ApiInfo.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,40 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Core.DB.Models;

namespace WIDESEA_Model.Models
{
    [SugarTable(nameof(Dt_ApiInfo), "接口信息")]
    public class Dt_ApiInfo : BaseEntity
    {
        /// <summary>
        /// ä¸»é”®
        /// </summary>
        [SugarColumn(IsPrimaryKey = true, IsIdentity = true, ColumnDescription = "主键")]
        public int Id { get; set; }
        /// <summary>
        /// æŽ¥å£ç¼–号
        /// </summary>
        [SugarColumn(IsNullable = false, Length = 50, ColumnDescription = "接口编号")]
        public string ApiCode { get; set; }
        /// <summary>
        /// æŽ¥å£åç§°
        /// </summary>
        [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "接口名称")]
        public string ApiName { get; set; }
        /// <summary>
        /// æŽ¥å£åœ°å€
        /// </summary>
        [SugarColumn(IsNullable = true, Length = 200, ColumnDescription = "接口地址")]
        public string ApiAddress { get; set; }
        /// <summary>
        /// å¤‡æ³¨
        /// </summary>
        [SugarColumn(IsNullable = true, Length = 50, ColumnDescription = "备注")]
        public string Remark { get; set; }
    }
}