Browse Source

派单-- 平均派单 的登录派单增加记录

田爽 4 months ago
parent
commit
306b2900fa
2 changed files with 17 additions and 2 deletions
  1. 11 2
      src/Hotline/Orders/OrderDomainService.cs
  2. 6 0
      src/Hotline/Schedulings/Scheduling.cs

+ 11 - 2
src/Hotline/Orders/OrderDomainService.cs

@@ -584,10 +584,19 @@ public class OrderDomainService : IOrderDomainService, IScopeDependency
         {
             var sendNum = steps.Count / schedulings;
             scheduling.SendOrderNum += sendNum;
-            await _schedulingRepository.Updateable()
+            if (!scheduling.LoginSendOrderNum.HasValue)
+            {
+	            scheduling.LoginSendOrderNum = scheduling.LoginSendOrderNum.HasValue && scheduling.LoginSendOrderNum > sendNum ? scheduling.LoginSendOrderNum : sendNum;
+				await _schedulingRepository.Updateable()
+					.SetColumns(s => new Scheduling() { LoginSendOrderNum = scheduling.LoginSendOrderNum })
+					.Where(s => s.SchedulingTime == scheduling.SchedulingTime).ExecuteCommandAsync(cancellationToken);
+			}
+            sendNum = scheduling.LoginSendOrderNum.Value;
+			await _schedulingRepository.Updateable()
                 .SetColumns(s => new Scheduling() { SendOrderNum = scheduling.SendOrderNum, AtWork = scheduling.AtWork })
                 .Where(s => s.Id == scheduling.Id).ExecuteCommandAsync(cancellationToken);
-            if (sendNum <= 0) return;
+		
+			if (sendNum <= 0) return;
             var sendSteps = steps.Take(sendNum).ToList();
             await _orderRepository.Updateable().SetColumns(o => new Order()
             {

+ 6 - 0
src/Hotline/Schedulings/Scheduling.cs

@@ -66,6 +66,12 @@ namespace Hotline.Schedulings
 		/// </summary>
 		public int? SendOrderNum { get; set; }
 
+
+		/// <summary>
+		/// 登录派单次数
+		/// </summary>
+		public int? LoginSendOrderNum { get; set; }
+
 		/// <summary>
 		/// 是否上班
 		/// </summary>