增加取消任务接口

WCS.BLL/Services/IService/IMXL4Service.cs

@@ -17,6 +17,8 @@ namespace WCS.BLL.Services.IService
     {
         public Task<ResponseCommon<object>> sysOrderMXL4(SysOrderMXL4Request request);
 
+        public Task<ResponseCommon<object>> cancelOrderMXL4(CancelRequest request);
+
         public Task<ResponseCommon> refreshInventoryRequest(RefreshInventoryRequest request);
 
         #region 调试用的APi

WCS.BLL/Services/Service/MXL4Service.cs

@@ -175,6 +175,63 @@ namespace WCS.BLL.Services.Service
             }
         }
 
+        /// <summary>
+        /// 取消同步的任务
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public async Task<ResponseCommon<object>> cancelOrderMXL4(CancelRequest request)
+        {
+            try
+            {
+                if (request.matSN == null || request.matSN.Count <= 0)
+                {
+                    return new ResponseCommon<object>
+                    {
+                        Code = 300,
+                        Message = $"未取消需要操作的物料条码！"
+                    };
+                }
+
+                var needCancelTasks = DbHelp.db.Queryable<CurrentTask>()
+                                               .Where(t => request.matSN.Contains(t.MatSN))
+                                               .ToList();
+                needCancelTasks.ForEach(t => t.IsCancel = true);
+                //获取当前
+                try
+                {
+                    DbHelp.db.BeginTran();
+                    DbHelp.db.Updateable(needCancelTasks).ExecuteCommand();
+                    DbHelp.db.CommitTran();
+                }
+                catch (Exception ex)
+                {
+                    DbHelp.db.RollbackTran();
+                    return new ResponseCommon<object>
+                    {
+                        Code = 300,
+                        Message = $"操作失败：{ex.Message}"
+                    };
+                }
+                //发送任务至各个标签 交给后台线程来做
+                return new ResponseCommon<object>
+                {
+                    Code = 200,
+                    Message = "success"
+                };
+            }
+            catch (Exception ex)
+            {
+                return new ResponseCommon<object>
+                {
+                    Code = 201,
+                    Message = "操作失败：" + ex.Message,
+
+                };
+            }
+        }
+
+
         public async Task<ResponseCommon> refreshInventoryRequest(RefreshInventoryRequest request)
         {
             try

WCS.Model/ApiModel/MXL4/SysOrderMXL4Request.cs

@@ -5,6 +5,11 @@ using WCS.BLL.DbModels.Task;
 
 namespace WCS.Model.ApiModel.MXL4
 {
+    public class CancelRequest : RequestBase
+    {
+        public List<string> matSN { get; set; }
+    }
+
     public class SysOrderMXL4Request : RequestBase
     {
 

WCS.WebApi/Controllers/MXL4Controller.cs

@@ -45,6 +45,24 @@ namespace WCS.WebApi.Controllers
             }
         }
 
+        [Route("cancelOrderMXL4")]
+        [HttpPost(Name = "cancelOrderMXL4")]
+        public async Task<ResponseBase> cancelOrderMXL4(CancelRequest request)
+        {
+            try
+            {
+                return await _mxl4Service.cancelOrderMXL4(request);
+            }
+            catch (Exception ex)
+            {
+                return new ResponseBase()
+                {
+                    Code = 300,
+                    Message = "操作失败：" + ex.Message,
+                };
+            }
+        }
+
         /// <summary>
         /// 刷新库存信息 当上游系统入库后可以调用此接口对硬件显示的库存信息进行刷新
         /// </summary>