批量删除接口

BBWY.Server.API/Controllers/OrderSyncController.cs

@@ -47,6 +47,16 @@ namespace BBWY.Server.API.Controllers
             orderSyncBusiness.ManualSyncOrder(shopId, orderIds, null, null);
         }
 
+        /// <summary>
+        /// 订单批量删除
+        /// </summary>
+        /// <param name="shopId"></param>
+        /// <param name="orderIds"></param>
+        [HttpPost("{shopId}")]
+        public void OrderDelete([FromRoute]long shopId, [FromBody]IList<string> orderIds)
+        {
+            orderSyncBusiness.OrderDelete(shopId, orderIds);
+        }
 
         /// <summary>
         /// 根据日期同步
@@ -94,5 +104,6 @@ namespace BBWY.Server.API.Controllers
         {
             orderSyncBusiness.DeleteTimeOutWaitPayOrder();
         }
+
     }
 }

BBWY.Server.Business/Sync/OrderSyncBusiness.cs

@@ -16,6 +16,7 @@ using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Linq;
 using System.Net.Http;
+using System.Security.Cryptography;
 using System.Threading;
 using System.Threading.Tasks;
 using Yitter.IdGenerator;
@@ -752,6 +753,20 @@ namespace BBWY.Server.Business
             return orderState;
         }
 
+        public void OrderDelete(long ShopId, IList<string> orderIds)
+        {
+            fsql.Transaction(() =>
+            {
+                fsql.Delete<Order>().Where(o => o.ShopId == ShopId && orderIds.Contains(o.Id)).ExecuteAffrows();
+                fsql.Delete<OrderSku>().Where(osku => orderIds.Contains(osku.OrderId)).ExecuteAffrows();
+                fsql.Delete<OrderCostDetail>().Where(ocd => orderIds.Contains(ocd.OrderId)).ExecuteAffrows();
+                fsql.Delete<OrderCost>().Where(oc => orderIds.Contains(oc.OrderId)).ExecuteAffrows();
+                fsql.Delete<OrderDropShipping>().Where(ods => orderIds.Contains(ods.OrderId)).ExecuteAffrows();
+                fsql.Delete<OrderConsignee>().Where(ocs => orderIds.Contains(ocs.OrderId)).ExecuteAffrows();
+                fsql.Delete<OrderCoupon>().Where(oc => orderIds.Contains(oc.OrderId)).ExecuteAffrows();
+            });
+        }
+
         /// <summary>
         /// 接收订单推送
         /// </summary>