|
|
@ -65,12 +65,16 @@ namespace BBWYB.Server.Business.JD |
|
|
|
{ |
|
|
|
List<string> orderIds = null; |
|
|
|
List<IUpdate<Order>> updateOrderList = new List<IUpdate<Order>>(); |
|
|
|
List<TimeLimitTask> insertTimeLimitTaskList = new List<TimeLimitTask>(); |
|
|
|
try |
|
|
|
{ |
|
|
|
var checkTaskList = fsql.Select<InStoreOrderCheckTask>().Where(x => x.IsChecked == false).ToList(); |
|
|
|
if (checkTaskList.Count() == 0) |
|
|
|
return; |
|
|
|
|
|
|
|
orderIds = checkTaskList.Select(x => x.OrderId).ToList(); |
|
|
|
var timelimitTaskList = fsql.Select<TimeLimitTask>().Where(t => orderIds.Contains(t.OrderId) && t.TaskType == Enums.TimeLimitTaskType.待核算任务).ToList(); |
|
|
|
|
|
|
|
var orderPurchaseInfoList = fsql.Select<OrderPurchaseInfo>().Where(opi => orderIds.Contains(opi.OrderId) && opi.IsEnabled == true).ToList(); |
|
|
|
|
|
|
|
var waitCheckInStoreOrderList = fsql.Select<InStorePurchaseOrdeRrelationInfo, Order>() |
|
|
@ -184,6 +188,22 @@ namespace BBWYB.Server.Business.JD |
|
|
|
var update = fsql.Update<Order>().Set(o => o.OrderState, Enums.OrderState.待核算) |
|
|
|
.Where(o => o.Id == checkTask.OrderId && o.OrderState == Enums.OrderState.待验收); |
|
|
|
updateOrderList.Add(update); |
|
|
|
|
|
|
|
if (!timelimitTaskList.Any(t => t.OrderId == checkTask.OrderId && t.TaskType == Enums.TimeLimitTaskType.待核算任务)) |
|
|
|
{ |
|
|
|
//创建待核算任务
|
|
|
|
var t = new TimeLimitTask() |
|
|
|
{ |
|
|
|
CreateTme = DateTime.Now, |
|
|
|
Id = idGenerator.NewLong(), |
|
|
|
OrderId = checkTask.OrderId, |
|
|
|
OrderSn = checkTask.OrderSn, |
|
|
|
ShopId = checkTask.ShopId, |
|
|
|
TaskType = Enums.TimeLimitTaskType.待核算任务, |
|
|
|
ExpirationTime = DateTime.Now.AddDays(1) |
|
|
|
}; |
|
|
|
insertTimeLimitTaskList.Add(t); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
@ -212,6 +232,9 @@ namespace BBWYB.Server.Business.JD |
|
|
|
|
|
|
|
if (orderIds != null && orderIds.Count() > 0) |
|
|
|
fsql.Update<InStoreOrderCheckTask>().Set(x => x.IsChecked, true).Where(x => orderIds.Contains(x.OrderId)).ExecuteAffrows(); |
|
|
|
|
|
|
|
if (insertTimeLimitTaskList.Count() > 0) |
|
|
|
fsql.Insert(insertTimeLimitTaskList).ExecuteAffrows(); |
|
|
|
}); |
|
|
|
} |
|
|
|
catch { } |
|
|
|