From b0eb954b4374c8de1a925557ba3689aab295c428 Mon Sep 17 00:00:00 2001 From: liguoyang Date: Tue, 26 Nov 2024 16:42:39 +0800 Subject: [PATCH] =?UTF-8?q?remove=20=E6=97=A0=E7=94=A8=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Common/Services/IHangfireService.cs | 25 ---------- .../Services/Implements/HangfireService.cs | 50 ------------------- 2 files changed, 75 deletions(-) delete mode 100644 Src/Dlhis.ScheduledTask/Common/Services/IHangfireService.cs delete mode 100644 Src/Dlhis.ScheduledTask/Common/Services/Implements/HangfireService.cs diff --git a/Src/Dlhis.ScheduledTask/Common/Services/IHangfireService.cs b/Src/Dlhis.ScheduledTask/Common/Services/IHangfireService.cs deleted file mode 100644 index 0999a1ca..00000000 --- a/Src/Dlhis.ScheduledTask/Common/Services/IHangfireService.cs +++ /dev/null @@ -1,25 +0,0 @@ -// using Dlhis.Basic.Api.Request; -// using Dlhis.ScheduledTask.Common.Request; -// using Dlhis.ScheduledTask.TaskAssignment.Request; -// -// namespace Dlhis.ScheduledTask.Common.Services; -// -// /// -// /// hangfire调度服务 -// /// -// public interface IHangfireService : IScopeDependency -// { -// /// -// /// 创建sap人员同步后台任务 -// /// -// /// -// /// -// Task CreateSapPersonSyncBackgroundJobAsync(SapNoRequest request); -// -// /// -// /// 创建sap人事范围同步后台任务 -// /// -// /// -// /// -// Task CreateSapWerkSyncBackgroundJobAsync(SapNoRequest request); -// } \ No newline at end of file diff --git a/Src/Dlhis.ScheduledTask/Common/Services/Implements/HangfireService.cs b/Src/Dlhis.ScheduledTask/Common/Services/Implements/HangfireService.cs deleted file mode 100644 index ae4c195d..00000000 --- a/Src/Dlhis.ScheduledTask/Common/Services/Implements/HangfireService.cs +++ /dev/null @@ -1,50 +0,0 @@ -// using Dlhis.Entity.Basic.Entity; -// using Dlhis.ScheduledTask.Common.Request; -// using Dlhis.ScheduledTask.TaskAssignment.Request; -// using Hangfire; -// using Kurisu.AspNetCore.DataAccess.SqlSugar.Services; -// using Kurisu.AspNetCore.Utils; -// using Kurisu.AspNetCore.Utils.Extensions; -// -// namespace Dlhis.ScheduledTask.Common.Services.Implements; -// -// public class HangfireService : IHangfireService -// { -// private readonly RedisCache _redisCache; -// private readonly IDbContext _dbContext; -// private readonly IJinkoJipService _jinkoJipService; -// -// public HangfireService(RedisCache redisCache, IDbContext dbContext, IJinkoJipService jinkoJipService) -// { -// _redisCache = redisCache; -// _dbContext = dbContext; -// _jinkoJipService = jinkoJipService; -// } -// -// public async Task CreateSapPersonSyncBackgroundJobAsync(SapNoRequest request) -// { -// // var jobKey = $"hangfire:background:person:{request.Code}"; -// // -// // using var handler = await _redisCache.LockAsync(jobKey); -// // if (handler.Acquired) -// // { -// // BackgroundJob.Enqueue(x => x.TodoByCodeAsync(request.Code)); -// // } -// } -// -// public async Task CreateSapWerkSyncBackgroundJobAsync(SapNoRequest request) -// { -// // var jobKey = $"hangfire:background:werk:{request.Code}"; -// // -// // await using var handler = await _redisCache.LockAsync(jobKey); -// // if (handler.Acquired) -// // { -// // var werkInfo = await _dbContext.Queryable().Where(x => x.Werk == request.Code).SingleAsync(); -// // werkInfo.ThrowIfNull("人事范围不存在"); -// // -// // werkInfo.BackgroundJobKey.IsPresent().ThrowIfTrue("任务进行中,无法再次发起同步"); -// // -// // BackgroundJob.Enqueue(x => x.TodoByWerkAsync(request.Code)); -// // } -// } -// } \ No newline at end of file