From fab9e794961c691f776fb899c43eefa9a175edd7 Mon Sep 17 00:00:00 2001
From: liguoyang <Ligy.97@foxmail.com>
Date: Tue, 28 Jul 2026 09:51:39 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=8D=95=E5=B7=A5=E5=8F=B7=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E5=89=8D=E6=B8=85=E7=90=86=20SAP=20=E5=8E=86=E5=8F=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Organization/Repositories/IGainfoSapRepository.cs      | 2 ++
 .../Repositories/Implements/GainfoSapRepository.cs         | 7 +++++++
 .../Services/Implements/GainfoUpdateService.cs             | 3 +++
 3 files changed, 12 insertions(+)

diff --git a/Src/Dlhis.Basic/Organization/Repositories/IGainfoSapRepository.cs b/Src/Dlhis.Basic/Organization/Repositories/IGainfoSapRepository.cs
index dd9d3034..4bedf03e 100644
--- a/Src/Dlhis.Basic/Organization/Repositories/IGainfoSapRepository.cs
+++ b/Src/Dlhis.Basic/Organization/Repositories/IGainfoSapRepository.cs
@@ -5,4 +5,6 @@ namespace Dlhis.Basic.Organization.Repositories;
 public interface IGainfoSapRepository : IScopeDependency
 {
     Task<List<SapPersonItem>> GetLatestPersonsAsync(List<string> workCodes);
+
+    Task<int> DeleteByWorkCodeAsync(string workCode);
 }
diff --git a/Src/Dlhis.Basic/Organization/Repositories/Implements/GainfoSapRepository.cs b/Src/Dlhis.Basic/Organization/Repositories/Implements/GainfoSapRepository.cs
index 9ccbdb5d..ed37e5b2 100644
--- a/Src/Dlhis.Basic/Organization/Repositories/Implements/GainfoSapRepository.cs
+++ b/Src/Dlhis.Basic/Organization/Repositories/Implements/GainfoSapRepository.cs
@@ -14,6 +14,13 @@ public class GainfoSapRepository : IGainfoSapRepository
         _dbContext = dbContext;
     }
 
+    public async Task<int> DeleteByWorkCodeAsync(string workCode)
+    {
+        return await _dbContext.Deleteable<GainfoSapEntity>()
+            .Where(x => x.ename == workCode)
+            .ExecuteCommandAsync();
+    }
+
     public async Task<List<SapPersonItem>> GetLatestPersonsAsync(List<string> workCodes)
     {
         var persons = new List<SapPersonItem>();
diff --git a/Src/Dlhis.Basic/Organization/Services/Implements/GainfoUpdateService.cs b/Src/Dlhis.Basic/Organization/Services/Implements/GainfoUpdateService.cs
index 15860f92..8d2aeeed 100644
--- a/Src/Dlhis.Basic/Organization/Services/Implements/GainfoUpdateService.cs
+++ b/Src/Dlhis.Basic/Organization/Services/Implements/GainfoUpdateService.cs
@@ -99,6 +99,9 @@ public class GainfoUpdateService : IGainfoUpdateService
             _logger.LogInformation("获取SAP人员数量为:{count}", persons.Count);
             if (persons.Count > 0)
             {
+                var deleteCount = await _gainfoSapRepository.DeleteByWorkCodeAsync(code);
+                _logger.LogInformation("删除工号:{code}的GainfoSap历史数量:{count}", code, deleteCount);
+
                 var modifiedPersons = await GetModifiedPersonAsync(persons.OrderByDescending(x => x.ZSTATUS).ThenBy(x => x.ZRZRQ).ToList());
                 _logger.LogInformation("SAP人员差异数量为:{count}", modifiedPersons.Count);
                 if (modifiedPersons.Count > 0)