hrp人员科室修复

performance/Performance.EntityModels/Entity/per_employee.cs

@@ -127,23 +127,28 @@ public class per_employee
         public string Remark { get; set; }
 
         /// <summary>
-        /// 
+        /// 0 未通过验证 1 通过验证
         /// </summary>
-        public Nullable<DateTime> CreateTime { get; set; }
-    
+        public int? IsVerify { get; set; }
+
         /// <summary>
-        /// 
+        /// 验证失败描述
         /// </summary>
-        public Nullable<int> CreateUser { get; set; }
+        public string VerifyMessage { get; set; }
 
         /// <summary>
-        /// 0 未通过验证 1 通过验证
+        /// 是否是hrp人员 0 不是 1 是
         /// </summary>
-        public int? IsVerify { get; set; }
+        public Nullable<int> IsHrpEmployee { get; set; }
 
         /// <summary>
-        /// 验证失败描述
+        /// 
         /// </summary>
-        public string VerifyMessage { get; set; }
+        public Nullable<DateTime> CreateTime { get; set; }
+    
+        /// <summary>
+        /// 
+        /// </summary>
+        public Nullable<int> CreateUser { get; set; }
     }
 }

performance/Performance.Services/ExtractExcelService/DictionaryService.cs

@@ -16,6 +16,7 @@ public class DictionaryService : IAutoInjection
         private readonly ILogger<DictionaryService> logger;
         private readonly QueryService queryService;
         private readonly LogManageService logService;
+        private readonly PerforCofhrpdepartmentRepository cofhrpdepartmentRepository;
         private readonly PerforPeremployeeRepository peremployeeRepository;
         private readonly PerforHospitalconfigRepository hospitalconfigRepository;
         private readonly PerforExtypeRepository extypeRepository;
@@ -27,6 +28,7 @@ public class DictionaryService : IAutoInjection
             ILogger<DictionaryService> logger,
             QueryService queryService,
             LogManageService logService,
+            PerforCofhrpdepartmentRepository cofhrpdepartmentRepository,
             PerforPeremployeeRepository peremployeeRepository,
             PerforHospitalconfigRepository hospitalconfigRepository,
             PerforExtypeRepository extypeRepository,
@@ -38,6 +40,7 @@ PerforHisscriptRepository hisscriptRepository
             this.logger = logger;
             this.queryService = queryService;
             this.logService = logService;
+            this.cofhrpdepartmentRepository = cofhrpdepartmentRepository;
             this.peremployeeRepository = peremployeeRepository;
             this.hospitalconfigRepository = hospitalconfigRepository;
             this.extypeRepository = extypeRepository;
@@ -93,17 +96,29 @@ private void Employee(per_allot allot, sys_hospitalconfig config, string sql)
                 var data = queryService.QueryData<per_employee>(config, allot, sql);
                 if (data == null || !data.Any()) return;
 
-                var employees = peremployeeRepository.GetEntities(t => t.AllotId == allot.ID);
-                if (employees != null && employees.Any())
-                {
-                    peremployeeRepository.RemoveRange(employees.ToArray());
-                }
+                //var employees = peremployeeRepository.GetEntities(t => t.AllotId == allot.ID);
+                //if (employees != null && employees.Any())
+                //{
+                //    peremployeeRepository.RemoveRange(employees.ToArray());
+                //}
 
                 data.ToList().ForEach(t =>
                 {
                     t.AllotId = allot.ID;
                     t.HospitalId = allot.HospitalId;
+                    t.IsHrpEmployee = 1;
                 });
+
+                var hrpDepartments = cofhrpdepartmentRepository.GetEntities(t => t.AllotId == allot.ID);
+                if (hrpDepartments != null && hrpDepartments.Any())
+                {
+                    data = data.GroupJoin(hrpDepartments, outer => new { department = outer.Department }, inner => new { department = inner.HRPDepartment }, (outer, inner) => new { outer, inner }).Select(t =>
+                    {
+                        t.outer.AccountingUnit = t.inner?.FirstOrDefault()?.AccountingUnit;
+                        return t.outer;
+                    });
+                }
+
                 peremployeeRepository.AddRange(data.ToArray());
             }
             catch (Exception ex)
@@ -161,5 +176,34 @@ private string GetSaveValue(params string[] arr)
                 return value;
             return arr.FirstOrDefault(w => !string.IsNullOrEmpty(w));
         }
+
+        /// <summary>
+        /// 校正HRP人员的科室信息
+        /// </summary>
+        /// <param name="allotId"></param>
+        public void CorrectionHRPDepartment(int allotId)
+        {
+            try
+            {
+                var employees = peremployeeRepository.GetEntities(t => t.AllotId == allotId && (t.IsHrpEmployee ?? 0) == 1);
+                if (employees == null || !employees.Any()) return;
+
+                var hrpDepartments = cofhrpdepartmentRepository.GetEntities(t => t.AllotId == allotId);
+                if (hrpDepartments != null && hrpDepartments.Any())
+                {
+                    employees = employees.GroupJoin(hrpDepartments, outer => new { department = outer.Department }, inner => new { department = inner.HRPDepartment }, (outer, inner) => new { outer, inner }).Select(t =>
+                    {
+                        t.outer.AccountingUnit = t.inner?.FirstOrDefault()?.AccountingUnit;
+                        return t.outer;
+                    }).ToList();
+
+                    peremployeeRepository.UpdateRange(employees.ToArray());
+                }
+            }
+            catch (Exception ex)
+            {
+                logger.LogError($"修改HRP人员科室时发生异常：{ex}");
+            }
+        }
     }
 }