From bdae3f56afb1f36d04d8d3b3a1c07f14080c8c48 Mon Sep 17 00:00:00 2001
From: yuyubo <1870149533@qq.com>
Date: Thu, 5 Jun 2025 10:23:15 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E5=90=AF=E8=B0=83=E5=BA=A6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 MyCode.Project.ScheduleTask/JobConfig.xml     |  5 ++--
 .../Jobs/EveryFiveMinuteJob.cs                | 16 ++-----------
 .../Jobs/RetryTaskJobJob.cs                   | 24 +++++++++++++++++++
 .../MyCode.Project.ScheduleTask.csproj        |  1 +
 .../IServices/IWorkProcessService.cs          |  5 ++++
 .../InvoiceOrder/InvoiceOrderService.cs       |  6 +++++
 .../WorkProcess/WorkProcessService.cs         | 18 ++++++++++++++
 7 files changed, 59 insertions(+), 16 deletions(-)
 create mode 100644 MyCode.Project.ScheduleTask/Jobs/RetryTaskJobJob.cs

diff --git a/MyCode.Project.ScheduleTask/JobConfig.xml b/MyCode.Project.ScheduleTask/JobConfig.xml
index 9170b88..8fa8039 100644
--- a/MyCode.Project.ScheduleTask/JobConfig.xml
+++ b/MyCode.Project.ScheduleTask/JobConfig.xml
@@ -5,8 +5,9 @@
 	 
  
   <job name="EveryFiveMinuteJob"  desc="30分钟抓取一次金蝶的采购订单"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.EveryFiveMinuteJob,MyCode.Project.ScheduleTask" CronExpression="0 */30 * * * ?" />
-  
- 
+  <job name="RetryTaskJob"  desc="30分钟重新运行昨天之后失败的任务"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.RetryTaskJobJob,MyCode.Project.ScheduleTask" CronExpression="0 */30 * * * ?" />
+
+
 </Jobs>
 <!--
  <job name="EveryTimeJob"  desc="每3秒执行调度"  enabled="true"  type="MyCode.Project.ScheduleTask.Jobs.EveryJob,MyCode.Project.ScheduleTask" CronExpression="*/3 * * * * ?" />
diff --git a/MyCode.Project.ScheduleTask/Jobs/EveryFiveMinuteJob.cs b/MyCode.Project.ScheduleTask/Jobs/EveryFiveMinuteJob.cs
index ec7e972..700d22b 100644
--- a/MyCode.Project.ScheduleTask/Jobs/EveryFiveMinuteJob.cs
+++ b/MyCode.Project.ScheduleTask/Jobs/EveryFiveMinuteJob.cs
@@ -1,17 +1,5 @@
-using Quartz;
-using System;
-using System.Data;
-using System.Data.Common;
-using MyCode.Project.Services;
-using MyCode.Project.Infrastructure;
-using MyCode.Project.Infrastructure.UnityExtensions;
-using Microsoft.Practices.Unity;
-using System.Reflection;
-using MyCode.Project.Domain.Model;
-using System.Collections;
-using System.Collections.Specialized;
-using System.Collections.Generic;
-using System.Threading;
+using MyCode.Project.Services;
+using Quartz;
 
 namespace MyCode.Project.ScheduleTask.Jobs
 {
diff --git a/MyCode.Project.ScheduleTask/Jobs/RetryTaskJobJob.cs b/MyCode.Project.ScheduleTask/Jobs/RetryTaskJobJob.cs
new file mode 100644
index 0000000..00a3309
--- /dev/null
+++ b/MyCode.Project.ScheduleTask/Jobs/RetryTaskJobJob.cs
@@ -0,0 +1,24 @@
+using MyCode.Project.Services;
+using Quartz;
+
+namespace MyCode.Project.ScheduleTask.Jobs
+{
+	public class RetryTaskJobJob : IJob
+    {         
+        private IWorkProcessService _workProcessService;
+
+        public RetryTaskJobJob(IPurchaseOrderService purchaseOrderService, IWorkProcessService workProcessService)
+        {
+           
+            _workProcessService = workProcessService;
+
+        }
+
+
+        public void Execute(IJobExecutionContext context)
+        {
+            _workProcessService.RetryTask(); 
+        }
+    }
+}
+
diff --git a/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj b/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj
index 8a71c60..d91c48b 100644
--- a/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj
+++ b/MyCode.Project.ScheduleTask/MyCode.Project.ScheduleTask.csproj
@@ -92,6 +92,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="JobsHelp.cs" />
+    <Compile Include="Jobs\RetryTaskJobJob.cs" />
     <Compile Include="Jobs\EveryFiveMinuteJob.cs" />
     <Compile Include="Jobs\EveryPriority2Job.cs" />
     <Compile Include="Jobs\EveryOtherJob.cs" />
diff --git a/MyCode.Project.Services/IServices/IWorkProcessService.cs b/MyCode.Project.Services/IServices/IWorkProcessService.cs
index f1bdca6..4f486d1 100644
--- a/MyCode.Project.Services/IServices/IWorkProcessService.cs
+++ b/MyCode.Project.Services/IServices/IWorkProcessService.cs
@@ -70,5 +70,10 @@ namespace MyCode.Project.Services
         /// 调度执行优先级=6的任务
         /// </summary>
         void ExecutePriority6();
+
+        /// <summary>
+        /// 重试失败的任务
+        /// </summary>
+        void RetryTask();
     }
 }
diff --git a/MyCode.Project.Services/Implementation/InvoiceOrder/InvoiceOrderService.cs b/MyCode.Project.Services/Implementation/InvoiceOrder/InvoiceOrderService.cs
index 71bbe22..d6f8e09 100644
--- a/MyCode.Project.Services/Implementation/InvoiceOrder/InvoiceOrderService.cs
+++ b/MyCode.Project.Services/Implementation/InvoiceOrder/InvoiceOrderService.cs
@@ -10,6 +10,7 @@ using MyCode.Project.Domain.Message.Response.User;
 using MyCode.Project.Domain.Model;
 using MyCode.Project.Domain.Repositories;
 using MyCode.Project.Infrastructure.Common;
+using MyCode.Project.Infrastructure.Enumeration;
 using MyCode.Project.Infrastructure.Exceptions;
 using MyCode.Project.Infrastructure.Extensions;
 using MyCode.Project.OutSideService;
@@ -35,11 +36,13 @@ namespace MyCode.Project.Services.Implementation
         private IInvoiceOrderItemRepository _invoiceOrderItemRepository;
         private IInvoiceOrderRepository _invoiceOrderRepository;
         private ITiaoMaRepository _tiaoMaRepository;
+        private ISysWorkProcessV2Repository _sysWorkProcessV2Repository;
 
         public InvoiceOrderService(IPurchaseOrderRepository purchaseOrderRepository
             , IPurchaseOrderItemRepository purchaseOrderItemRepository
             , IInvoiceOrderItemRepository invoiceOrderItemRepository
             , IInvoiceOrderRepository invoiceOrderRepository
+            , ISysWorkProcessV2Repository sysWorkProcessV2Repository
             , ITiaoMaRepository tiaoMaRepository
             , IWorkProcessService workProcessService
             , IKingDeeService kingDeeService)
@@ -48,6 +51,7 @@ namespace MyCode.Project.Services.Implementation
             _purchaseOrderRepository = purchaseOrderRepository;
             _invoiceOrderItemRepository = invoiceOrderItemRepository;
             _invoiceOrderRepository = invoiceOrderRepository;
+            _sysWorkProcessV2Repository = sysWorkProcessV2Repository;
             _tiaoMaRepository = tiaoMaRepository;
             _workProcessService = workProcessService;
             _kingDeeService = kingDeeService;
@@ -354,5 +358,7 @@ namespace MyCode.Project.Services.Implementation
 
         }
         #endregion
+
+ 
     }
 }
diff --git a/MyCode.Project.Services/Implementation/WorkProcess/WorkProcessService.cs b/MyCode.Project.Services/Implementation/WorkProcess/WorkProcessService.cs
index c95bbfa..92c9815 100644
--- a/MyCode.Project.Services/Implementation/WorkProcess/WorkProcessService.cs
+++ b/MyCode.Project.Services/Implementation/WorkProcess/WorkProcessService.cs
@@ -469,5 +469,23 @@ namespace MyCode.Project.Services.Implementation
             }
         }
         #endregion
+
+        #region RetryTask(重试失败的任务)
+        /// <summary>
+        /// 重试失败的任务
+        /// </summary>
+        public void RetryTask()
+        {
+            DateTime today = DateTime.Now.Date.AddDays(-1);
+            var list = _sysWorkProcessV2Repository.Queryable().Where(t =>  t.FuncStatus == 4 && t.RetryCount <= 10
+             && t.CreateTime >= today).OrderBy(t => t.EditTime).Take(20).ToList();
+            list.ForEach(t =>
+            {
+                t.RetryCount = t.RetryCount + 1;
+                t.FuncStatus = 0;
+            });
+            _sysWorkProcessV2Repository.Update(list);
+        }
+        #endregion
     }
 }