11

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" />

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();
+        }
+    }
+}

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" />

Reportapi/MyCode.Project.Services/IServices/IWMSService.cs

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

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());