This commit is contained in:
余宇波 2025-07-18 17:09:55 +08:00
parent 38bf2c2913
commit a7fd4de781
3 changed files with 25 additions and 3 deletions

View File

@ -21,5 +21,10 @@ namespace MyCode.Project.Services
/// 添加抓单的调度 /// 添加抓单的调度
/// </summary> /// </summary>
void AddTask(); void AddTask();
/// <summary>
/// 添加“合并吉客云订单到新表”的任务
/// </summary>
void AddMergeJackYunOrder();
} }
} }

View File

@ -22,13 +22,15 @@ namespace MyCode.Project.Services.Implementation
private IPushKingDeeOrderRepository _pushKingDeeOrderRepository; private IPushKingDeeOrderRepository _pushKingDeeOrderRepository;
private IPushKingDeeOrderItemRepository _pushKingDeeOrderItemRepository; private IPushKingDeeOrderItemRepository _pushKingDeeOrderItemRepository;
private IYTKJTShopParameterRepository _yTKJTShopParameterRepository; private IYTKJTShopParameterRepository _yTKJTShopParameterRepository;
private IWorkProcessService _workProcessService;
public JackYunTaskService(IJackOrdersRepository jackOrdersRepository public JackYunTaskService(IJackOrdersRepository jackOrdersRepository
, IJackOrdersItemRepository jackOrdersItemRepository , IJackOrdersItemRepository jackOrdersItemRepository
, IPushKingDeeOrderRepository pushKingDeeOrderRepository , IPushKingDeeOrderRepository pushKingDeeOrderRepository
, IPushKingDeeOrderItemRepository pushKingDeeOrderItemRepository , IPushKingDeeOrderItemRepository pushKingDeeOrderItemRepository
, IYTKJTShopParameterRepository yTKJTShopParameterRepository , IYTKJTShopParameterRepository yTKJTShopParameterRepository
, IJackYunService jackYunService) , IJackYunService jackYunService,
IWorkProcessService workProcessService )
{ {
_yTKJTShopParameterRepository = yTKJTShopParameterRepository; _yTKJTShopParameterRepository = yTKJTShopParameterRepository;
_pushKingDeeOrderRepository = pushKingDeeOrderRepository; _pushKingDeeOrderRepository = pushKingDeeOrderRepository;
@ -36,6 +38,7 @@ namespace MyCode.Project.Services.Implementation
_jackOrdersRepository = jackOrdersRepository; _jackOrdersRepository = jackOrdersRepository;
_jackOrdersItemRepository = jackOrdersItemRepository; _jackOrdersItemRepository = jackOrdersItemRepository;
_jackYunService = jackYunService; _jackYunService = jackYunService;
_workProcessService = workProcessService;
} }
#region TaskGetJackYunOrder() #region TaskGetJackYunOrder()
@ -47,7 +50,8 @@ namespace MyCode.Project.Services.Implementation
{ {
DateTime runTime = DateTime.Parse(now); DateTime runTime = DateTime.Parse(now);
var list = _jackYunService.testTradeFullInfoGet(runTime); var list = _jackYunService.testTradeFullInfoGet(runTime);
SetOrder(list); SetOrder(list);
_workProcessService.Add<IJackYunTaskService>(this.MerchantId, "GetAndMergeJackYunOrder", "合并吉客云订单到新表", now, 1);
} }
#endregion #endregion
@ -156,6 +160,7 @@ namespace MyCode.Project.Services.Implementation
return JsonHelper.ToJson(list); return JsonHelper.ToJson(list);
} }
#endregion #endregion
} }
} }

View File

@ -106,6 +106,18 @@ namespace MyCode.Project.Services.Implementation
} }
#endregion #endregion
#region AddMergeJackYunOrder()
/// <summary>
/// 添加“合并吉客云订单到新表”的任务
/// </summary>
public void AddMergeJackYunOrder()
{
string now = DateTime.Now.ToString();
_workProcessService.Add<IJackYunTaskService>(this.MerchantId, "GetAndMergeJackYunOrder", "合并吉客云订单到新表", now, 1);
}
#endregion
} }