1.增加齐库sku检查推送日志

2.定期修复待核算缺失任务

BBWYB.Server.API/Controllers/TimeLimitTaskController.cs

@@ -28,6 +28,16 @@ namespace BBWYB.Server.API.Controllers
             timeLimitTaskBusiness.CheckTask();
         }
 
+        /// <summary>
+        ///  修复订单缺失的待核算任务
+        /// </summary>
+        [HttpPost]
+        [AllowAnonymous]
+        public void RepairOrderComputationTask()
+        {
+            timeLimitTaskBusiness.RepairOrderComputationTask();
+        }
+
         /// <summary>
         /// 查询限时任务列表
         /// </summary>

BBWYB.Server.Business/Order/OrderBusiness.cs

@@ -717,6 +717,7 @@ namespace BBWYB.Server.Business
 
         public void CheckSku(CheckSkuRequest request)
         {
+            nLogManager.Default().Info($"CheckSku {JsonConvert.SerializeObject(request)}");
             var dbOrder = fsql.Select<Order>(request.OrderId).ToOne();
             if (dbOrder == null)
                 throw new BusinessException($"订单{request.OrderId}不存在");

BBWYB.Server.Business/TimeLimitTask/TimeLimitTaskBusiness.cs

@@ -28,6 +28,40 @@ namespace BBWYB.Server.Business
                                         .ExecuteAffrows();
         }
 
+        /// <summary>
+        /// 修复订单待核算任务
+        /// </summary>
+        public void RepairOrderComputationTask()
+        {
+            var childSelect = fsql.Select<TimeLimitTask>().As("t").Where(t => t.TaskType == Enums.TimeLimitTaskType.待核算任务);
+            var noComputationTaskOrderList = fsql.Select<Order>().Where(o => o.OrderState == Enums.OrderState.待核算 &&
+                                                            !childSelect.Where(t => t.OrderId == o.Id).Any())
+                                                            .ToList(o => new
+                                                            {
+                                                                o.Id,
+                                                                o.OrderSn,
+                                                                o.ShopId,
+                                                            });
+            var insertComputationTaskList = noComputationTaskOrderList.Select(o => new TimeLimitTask()
+            {
+                Id = idGenerator.NewLong(),
+                CreateTme = DateTime.Now,
+                OrderId = o.Id,
+                OrderSn = o.OrderSn,
+                ShopId = o.ShopId,
+                TaskType = Enums.TimeLimitTaskType.待核算任务,
+                ExpirationTime = DateTime.Now.AddDays(1),
+                Remark = "RepairOrderComputationTask"
+            }).ToList();
+
+            if (insertComputationTaskList.Count() > 0)
+            {
+                fsql.Transaction(() =>
+                {
+                    fsql.Insert(insertComputationTaskList).ExecuteAffrows();
+                });
+            }
+        }
 
         public TimeLimitTaskListResponse QueryTimeLimitTask(QueryTimeLimitTaskRequest request)
         {