1

xiazhengtongxue

15 小时以前 4ecfe88d40b1a4f42cd8bc569b679768806e289f

 Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService/TaskService.Complete.cs

@@ -1,6 +1,7 @@
using MapsterMapper;
using SqlSugar;
using System.Diagnostics.CodeAnalysis;
using System.Threading.Tasks;
using WIDESEA_Core;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
@@ -176,5 +177,37 @@
        List<Dt_Task> tasks = BaseDal.QueryData(x => taskKeys.Contains(x.TaskId));
        BaseDal.DeleteAndMoveIntoHty(tasks, OperateTypeEnum.人工删除);
        return WebResponseContent.Instance.OK($"成功删除{tasks.Count}条数据");
    }



    /// <summary>
    /// 任务取消
    /// </summary>
    /// <param name="taskNum"></param>
    /// <returns></returns>
    public WebResponseContent CancelTask(int taskNum)
    {
        WebResponseContent content = new WebResponseContent();
        try

        {

            if (taskNum <= 0) return content.Error("任务编号无效");



            Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);

            if (task == null) return content.OK("任务不存在，强制取消");



            task.TaskStatus = (int)TaskOutStatusEnum.OutCancel;



            if (task.TaskStatus == (int)TaskInStatusEnum.InNew || task.TaskStatus == (int)TaskOutStatusEnum.OutNew)

            {

                bool deleteResult = BaseDal.DeleteAndMoveIntoHty(task, OperateTypeEnum.自动删除);

                if (!deleteResult) return content.Error("删除任务失败");

                return content.OK();

            }

            
        }

        catch (Exception ex)

        {

            content.Error($"WCS任务取消接口失败，{ex.Message}");

        }
        return content.Error("当前任务在执行中！");
    }
}