From e9d7d9c9aec57ab92ac11301bcbc243599b412ef Mon Sep 17 00:00:00 2001
From: yuyubo <1870149533@qq.com>
Date: Fri, 19 Sep 2025 09:52:24 +0800
Subject: [PATCH] 11

---
 .../MyCode.Project.ScheduleTask/JobConfig.xml |  1 +
 .../Jobs/AddWMSOrderJob.cs                    | 27 +++++++++++++++++++
 .../MyCode.Project.ScheduleTask.csproj        |  1 +
 .../IServices/IWMSService.cs                  |  5 ++++
 .../Implementation/WMSService.cs              | 15 +++++++++++
 5 files changed, 49 insertions(+)
 create mode 100644 Reportapi/MyCode.Project.ScheduleTask/Jobs/AddWMSOrderJob.cs

diff --git a/Reportapi/MyCode.Project.ScheduleTask/JobConfig.xml b/Reportapi/MyCode.Project.ScheduleTask/JobConfig.xml
index 4af28ae..81d3afb 100644
--- a/Reportapi/MyCode.Project.ScheduleTask/JobConfig.xml
+++ b/Reportapi/MyCode.Project.ScheduleTask/JobConfig.xml
@@ -2,6 +2,7 @@
 <Jobs>
 	<job name="EveryTimeJob"  desc="定时执行的调度"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.EveryJob,MyCode.Project.ScheduleTask" CronExpression="*/10 * * * * ?" runonce="false"/>
 	<job name="AddOrderJob"  desc="添加抓单的调度"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.AddOrderJob,MyCode.Project.ScheduleTask" CronExpression="0 0 3 * * ?" runonce="false"/>
+	<job name="AddWMSOrderJob"  desc="添加抓单的调度"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.AddWMSOrderJob,MyCode.Project.ScheduleTask" CronExpression="0 */15 * * * ?" runonce="false"/>
  </Jobs>
 <!--
   <job name="CalOrderMoreThan500Job"  desc="计算消费超过500"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.CalOrderMoreThan500Job,MyCode.Project.ScheduleTask" CronExpression="*/10 * * * * ?" runonce="false" />
diff --git a/Reportapi/MyCode.Project.ScheduleTask/Jobs/AddWMSOrderJob.cs b/Reportapi/MyCode.Project.ScheduleTask/Jobs/AddWMSOrderJob.cs
new file mode 100644
index 0000000..2a3b6c5
--- /dev/null
+++ b/Reportapi/MyCode.Project.ScheduleTask/Jobs/AddWMSOrderJob.cs
@@ -0,0 +1,27 @@
+using MyCode.Project.Services;
+using Quartz;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MyCode.Project.ScheduleTask.Jobs
+{
+    [DisallowConcurrentExecution]
+    public class AddWMSOrderJob : IJob
+    {
+
+        private IWMSService _wMSService;
+        public AddWMSOrderJob(IWMSService wMSService)
+        {
+            _wMSService = wMSService;
+        }
+
+
+        public void Execute(IJobExecutionContext context)
+        {
+            _wMSService.AddWMSTask();
+        }
+    }
+}
diff --git a/Reportapi/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj b/Reportapi/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj
index 49a78c6..f230e57 100644
--- a/Reportapi/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj
+++ b/Reportapi/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj
@@ -92,6 +92,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="JobsHelp.cs" />
+    <Compile Include="Jobs\AddWMSOrderJob.cs" />
     <Compile Include="Jobs\AddOrderJob.cs" />
     <Compile Include="Jobs\EveryJob.cs" />
     <Compile Include="Jobs\QueueJob.cs" />
diff --git a/Reportapi/MyCode.Project.Services/IServices/IWMSService.cs b/Reportapi/MyCode.Project.Services/IServices/IWMSService.cs
index dff1170..0ecc3bf 100644
--- a/Reportapi/MyCode.Project.Services/IServices/IWMSService.cs
+++ b/Reportapi/MyCode.Project.Services/IServices/IWMSService.cs
@@ -26,5 +26,10 @@ namespace MyCode.Project.Services
         /// 添加“合并吉客云订单到新表”的任务
         /// </summary>
         void AddMergeJackYunOrder();
+
+        /// <summary>
+        /// 添加WMS抓单的调度
+        /// </summary>
+        void AddWMSTask();
     }
 }
diff --git a/Reportapi/MyCode.Project.Services/Implementation/WMSService.cs b/Reportapi/MyCode.Project.Services/Implementation/WMSService.cs
index e615aac..c33e550 100644
--- a/Reportapi/MyCode.Project.Services/Implementation/WMSService.cs
+++ b/Reportapi/MyCode.Project.Services/Implementation/WMSService.cs
@@ -46,6 +46,21 @@ namespace MyCode.Project.Services.Implementation
             _workProcessService.Add<IJackYunTaskService>(this.MerchantId, "TaskGetJackYunOrder", "调度运行抓吉客云销售订单", now.ToString("yyyy-MM-dd"), 1);
         }
         #endregion
+
+
+        #region AddWMSTask(添加WMS抓单的调度)
+        /// <summary>
+        /// 添加WMS抓单的调度
+        /// </summary>
+        public void AddWMSTask()
+        {
+            DateTime now = DateTime.Now.Date;
+            _workProcessService.Add<IWMSService>(this.MerchantId, "GetList", "抓取WMS订单到本地数据库", now.Date.ToString("yyyy-MM-dd"), 1);
+        
+        }
+        #endregion
+
+
         public List<WMStoJackyunInventoryMovementView1> GetList(object now2)
         {
             DateTime now = DateTime.Parse(now2.ToString());