1

z8018

2025-06-10 e46aa927d231af83724683c7286d9db503e24cf7

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_ITaskInfoService/ITaskService.cs

@@ -23,11 +23,10 @@
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseServices;
using WIDESEAWCS_Core.Enums;
using WIDESEAWCS_DTO.TaskInfo;
using WIDESEAWCS_DTO.BasicInfo;
using WIDESEAWCS_Model.Models;

namespace WIDESEAWCS_ITaskInfoService
@@ -35,199 +34,126 @@
    public interface ITaskService : IService<Dt_Task>
    {
        /// <summary>
        /// ä»»åŠ¡æŽ’序
        /// æŸ¥è¯¢æŒ‡å®šé—¨æž¶è®¾å¤‡æœªæ‰§è¡Œçš„任务
        /// </summary>
        public Dictionary<string, OrderByType> TaskOrderBy { get; set; }
        /// <param name="gantryDeviceNo">门架设备编号</param>
        /// <returns>未执行的任务数据，若不存在则返回null</returns>
        Dt_Task? QueryAGantryUnExecuteTask(string gantryDeviceNo);

        /// <summary>
        /// æ‰€æœ‰å…¥åº“任务类型
        /// æ‰§è¡Œè®¢å•å—放置测试，根据订单行ID获取订单明细并计算放置位置
        /// </summary>
        public List<int> TaskInboundTypes { get; }
        /// <param name="orderRowId">订单行ID</param>
        /// <returns>包含放置块信息的Web响应内容。成功时返回放置块列表，失败时返回错误信息</returns>
        /// <remarks>
        /// 1. é€šè¿‡è®¢å•è¡ŒID查询订单明细数据 <br/>
        /// 2. å¯¹æ¯ä¸ªæœ‰æ•ˆè®¢å•æ˜Žç»†è®¡ç®—合适的放置位置 <br/>
        /// 3. åˆ›å»ºå®¹å™¨é¡¹å’Œä»»åŠ¡è®°å½• <br/>
        /// 4. é€šè¿‡WebSocket发布放置位置信息 <br/>
        /// 5. è¿”回所有成功放置的块信息
        /// </remarks>
        WebResponseContent PlaceBlockTest(int orderRowId);

        /// <summary>
        /// æ‰€æœ‰å‡ºåº“任务类型
        /// åˆ›å»ºä»»åŠ¡å¹¶è®¡ç®—物品放置位置
        /// </summary>
        public List<int> TaskOutboundTypes {  get; }
        /// <param name="takePosition">取货位置编码</param>
        /// <param name="putPosition">放货位置编码</param>
        /// <param name="deviceCode">设备编码</param>
        /// <param name="length">物品长度</param>
        /// <param name="width">物品宽度</param>
        /// <param name="height">物品高度</param>
        /// <returns>包含操作结果的Web响应内容</returns>
        /// <remarks>
        /// 1. éªŒè¯å–è´§/放货位置是否存在 <br/>
        /// 2. è®¡ç®—物品在容器中的最佳放置位置 <br/>
        /// 3. åˆ›å»ºå®¹å™¨ç‰©å“è®°å½•å’Œä»»åŠ¡è®°å½• <br/>
        /// 4. é€šè¿‡WebSocket通知客户端
        /// </remarks>
        WebResponseContent CreateTask(string takePosition, string putPosition, string deviceCode, int length, int width, int height);

        /// <summary>
        /// æŽ¥æ”¶WMS任务信息
        /// æ ¹æ®è®¢å•ä¿¡æ¯ç”Ÿæˆä»»åŠ¡
        /// </summary>
        /// <param name="taskDTOs">WMS任务对象集合</param>
        /// <returns>返回处理结果</returns>
        WebResponseContent ReceiveWMSTask(Dt_Task taskDTOs);
        
        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址查询输送线未执行的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns></returns>
        Dt_Task QueryConveyorLineTask(string deviceNo, string currentAddress);
        /// <summary>
        /// æŸ¥è¯¢å½“前地址是否有该任务
        /// </summary>
        /// <param name="deviceNo"></param>
        /// <param name="currentAddress"></param>
        /// <returns></returns>
        List<string> QueryConveyorLineTaskSourceAddress();
        /// <summary>
        /// æŸ¥æ‰¾ä»»åŠ¡æ˜¯å¦éœ€è¦åœ°å€
        /// </summary>
        /// <returns></returns>
        Dt_Task QueryConveyorLineTaskRoadway(int agvarea);
        /// <param name="orderInfo">订单信息</param>
        /// <returns>包含三个值的元组： <br/>
        /// Item1 - æ“ä½œæ˜¯å¦æˆåŠŸ (bool) <br/>
        /// Item2 - ç”Ÿæˆçš„任务对象 (Dt_Task)，失败时为null <br/>
        /// Item3 - é”™è¯¯æ¶ˆæ¯ (string)，成功时为空字符串
        /// </returns>
        /// <remarks>
        /// è¯¥æ–¹æ³•ä¼šï¼š <br/>
        /// 1. æ ¹æ®è®¢å•å°ºå¯¸èŽ·å–合适的货位 <br/>
        /// 2. åˆ›å»ºå®¹å™¨é¡¹å’Œä»»åŠ¡è®°å½• <br/>
        /// 3. æ›´æ–°ç›¸å…³å®¹å™¨çŠ¶æ€ <br/>
        /// 4. åœ¨äº‹åŠ¡ä¸­æ‰§è¡Œæ‰€æœ‰æ•°æ®åº“操作
        /// </remarks>
        (bool, Dt_Task?, string) GenerateTask(OrderInfo orderInfo);

        /// <summary>
        /// æŸ¥æ‰¾è¯¥åœ°å€æ˜¯å¦æœ‰èµ·ç‚¹è´§ç»ˆç‚¹ä»»åŠ¡
        /// é‡æ–°ç”Ÿæˆä»»åŠ¡
        /// </summary>
        /// <returns></returns>
        bool QueryConveyorLinetaeersuadd(string taeersuadd);
        /// <param name="task">原始任务对象</param>
        /// <param name="stationCode">工作站编码</param>
        /// <returns>
        /// åŒ…含三个值的元组： <br/>
        /// 1. bool - æ“ä½œæ˜¯å¦æˆåŠŸ <br/>
        /// 2. Dt_Task - æ›´æ–°åŽçš„任务对象（失败时为null） <br/>
        /// 3. string - é”™è¯¯æ¶ˆæ¯ï¼ˆæˆåŠŸæ—¶ä¸ºç©ºå­—符串）
        /// </returns>
        /// <remarks>
        /// è¯¥æ–¹æ³•ç”¨äºŽé‡æ–°ç”Ÿæˆä»»åŠ¡ä¿¡æ¯ï¼ŒåŒ…括： <br/>
        /// 1. è§£æžæ¿å­å°ºå¯¸ä¿¡æ¯ <br/>
        /// 2. éªŒè¯å–è´§/放货位置 <br/>
        /// 3. è®¡ç®—物品放置位置 <br/>
        /// 4. æ›´æ–°ä»»åŠ¡çŠ¶æ€å’Œä½ç½®ä¿¡æ¯ <br/>
        /// 5. åœ¨äº‹åŠ¡ä¸­æ›´æ–°æ•°æ®åº“记录
        /// </remarks>
        (bool, Dt_Task?, string) RegenerateTask(Dt_Task task, string stationCode);

        /// <summary>
        /// ä¿®æ”¹ä»»åŠ¡ä¿¡æ¯ï¼Œæ·»åŠ ç›®æ ‡åœ°å€
        /// ç”Ÿæˆå¼‚常任务
        /// </summary>
        /// <param name="TaskId"></param>
        /// <param name="TargetAddress"></param>
        /// <returns></returns>
        WebResponseContent UpdateTargetAddress(int TaskId, string TargetAddress);

        /// <param name="orderInfo">订单信息</param>
        /// <returns>元组包含三个值： <br/>
        /// Item1 - æ“ä½œæ˜¯å¦æˆåŠŸï¼ˆbool） <br/>
        /// Item2 - ç”Ÿæˆçš„任务对象（Dt_Task），失败时为null <br/>
        /// Item3 - é”™è¯¯æ¶ˆæ¯ï¼ˆstring），成功时为空字符串</returns>
        /// <remarks>
        /// è¯¥æ–¹æ³•ä¼šæ ¹æ®è®¢å•ä¿¡æ¯ç”Ÿæˆä¸€ä¸ªå¼‚常处理任务，包括： <br/>
        /// 1. èŽ·å–异常位置 <br/>
        /// 2. éªŒè¯æ”¾è´§/取货位置 <br/>
        /// 3. åˆ›å»ºå®¹å™¨é¡¹å’Œä»»åŠ¡è®°å½• <br/>
        /// 4. æäº¤äº‹åŠ¡
        /// </remarks>
        (bool, Dt_Task?, string) GenerateExceptionTask(OrderInfo orderInfo);

        /// <summary>
        /// æ ¹æ®ä»»åŠ¡å·ã€ä¸‹ä¸€åœ°å€æŸ¥è¯¢è¾“送线执行中的任务
        /// æ ¹æ®è®¾å¤‡ç¼–号获取取货位置
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <param name="nextAddress">下一地址</param>
        /// <returns></returns>
        Dt_Task QueryExecutingConveyorLineTask(int taskNum, string nextAddress);
        /// <param name="deviceCode">设备编号</param>
        /// <returns>符合条件的容器对象，若找不到则返回null</returns>
        /// <remarks>
        /// 1. é¦–先查询指定设备下所有可用的取货容器，并按ContainerSort升序排序 <br/>
        /// 2. æŸ¥æ‰¾è¯¥è®¾å¤‡æœ€è¿‘的任务记录 <br/>
        /// 3. å¦‚果找到任务记录，则根据任务源地址匹配容器，返回下一个容器(若已是最后一个则返回第一个) <br/>
        /// 4. å¦‚果出现异常或未找到匹配项，则返回第一个可用容器
        /// </remarks>
        Dt_Container? GetTakePosition(string deviceCode);

        /// <summary>
        /// æ ¹æ®ä»»åŠ¡å·ã€å½“前地址查询输送线完成的任务
        /// ä»»åŠ¡å®Œæˆå¤„理方法
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns></returns>
        Dt_Task QueryCompletedConveyorLineTask(int taskNum, string currentAddress);

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、任务类型分组(可选)按照优先级以及创建时间排序查询任务池新增的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="taskTypeGroup">任务类型分组(可选)</param>
        /// <returns></returns>
        Dt_Task? QuertStackerCraneTask(string deviceNo, TaskTypeGroup? taskTypeGroup = null);

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址按照优先级以及创建时间排序查询任务池新增的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns>返回任务实体对象，可能为null</returns>
        Dt_Task QueryStackerCraneTask(string deviceNo, string currentAddress = "");

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号查当前在做任务号
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns>返回任务实体对象，可能为null</returns>
        Dt_Task IngStackerCraneTask(string deviceNo);
        Dt_Task IngStackerCraneTask2(string deviceNo);

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址按照优先级以及创建时间排序查询任务池入库类型的新增的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns>返回任务实体对象，可能为null</returns>
        Dt_Task QueryStackerCraneInTask(string deviceNo, string currentAddress = "");


        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址按照优先级以及创建时间排序查询任务池出库类型的新增的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns>返回任务实体对象，可能为null</returns>
        Dt_Task QueryStackerCraneOutTask(string deviceNo, string currentAddress = "");

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址按照优先级以及创建时间排序查询任务池出库类型的新增的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="outStationCodes">当前地址</param>
        /// <returns>返回任务实体对象集合，可能为null</returns>
        List<Dt_Task> QueryStackerCraneOutTasks(string deviceNo, List<string> outStationCodes);

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址按照优先级以及创建时间排序查询任务池出库类型的新增的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="outStationCodes">当前地址</param>
        /// <returns>返回任务实体对象集合，可能为null</returns>
        List<Dt_Task> QueryStationIsOccupiedOutTasks(string deviceNo, string SourceAddress);

        
        /// <summary>
        /// æ›´æ–°ä»»åŠ¡å¼‚常信息显示
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <param name="message">异常信息</param>
        WebResponseContent UpdateTaskExceptionMessage(int taskNum, string message);

        /// <summary>
        /// æ›´æ–°ä»»åŠ¡çŠ¶æ€ä¿¡æ¯ï¼Œå¹¶åŒæ­¥è‡³WMS
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <param name="status">任务状态</param>
        void UpdateTaskStatus(int taskNum, int status);

        /// <summary>
        /// å°†ä»»åŠ¡çŠ¶æ€ä¿®æ”¹ä¸ºä¸‹ä¸€ä¸ªçŠ¶æ€
        /// </summary>
        /// <param name="taskNum">任务号</param>
        WebResponseContent UpdateTaskStatusToNext(int taskNum);

        /// <summary>
        /// å°†ä»»åŠ¡çŠ¶æ€ä¿®æ”¹ä¸ºä¸‹ä¸€ä¸ªçŠ¶æ€
        /// </summary>
        /// <param name="task">任务实体对象</param>
        /// <returns></returns>
        WebResponseContent UpdateTaskStatusToNext([NotNull] Dt_Task task);

        /// <summary>
        /// æ ¹æ®ä»»åŠ¡å·ã€å½“前地址更新任务位置信息
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns></returns>
        Dt_Task? UpdatePosition(int taskNum, string currentAddress);

        /// <summary>
        /// ä»»åŠ¡å®Œæˆ
        /// </summary>
        /// <param name="taskNum">任务编号</param>
        /// <returns>返回处理结果</returns>
        WebResponseContent StackCraneTaskCompleted(int taskNum);

        /// <summary>
        /// æ¢å¤æŒ‚起任务
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <returns>返回处理结果</returns>
        WebResponseContent TaskStatusRecovery(int taskNum);

        /// <summary>
        /// å›žæ»šä»»åŠ¡çŠ¶æ€
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <returns>返回处理结果</returns>
        WebResponseContent RollbackTaskStatusToLast(int taskNum);
        /// <summary>
        /// å‰ç«¯å±•ç¤º
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        WebResponseContent GetAgvStatusData();
        WebResponseContent GetAgvStatusData2();
        WebResponseContent GetAgvTaskData();
        /// <param name="task">任务实体</param>
        /// <returns>Web响应内容</returns>
        /// <remarks>
        /// 1. æ›´æ–°ä»»åŠ¡çŠ¶æ€ä¸º"龙门架完成" <br/>
        /// 2. æ›´æ–°ç›¸å…³è®¢å•è¯¦æƒ…状态为"码垛成功" <br/>
        /// 3. æ›´æ–°è®¢å•è¡Œä¸­çš„托盘数量 <br/>
        /// 4. æ ¹æ®ä»»åŠ¡å®Œæˆæƒ…况发送WebSocket通知 <br/>
        /// 5. è®°å½•æ“ä½œæ—¥å¿—并提交事务 <br/>
        /// 6. å¼‚常时回滚事务并返回错误信息
        /// </remarks>
        WebResponseContent TaskComplete(Dt_Task task);
    }
}