档案表crud

Src/Dlhis.Basic/MealUser/Services/IGainfoService.cs

@@ -0,0 +1,15 @@
+using Dlhis.Basic.MealUser.Request;
+using Dlhis.Entity.Basic.Entity;
+using Kurisu.Core.DataAccess.Dto;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Dlhis.Basic.MealUser.Services
+{
+    public interface IGainfoService : IScopeDependency
+    {
+        Task SaveAsync(GainfoAddSaveRequest request);
+        Task<Pagination<GainfoEntity>> GetPageAsync(GainfoPageRequest request);
+        Task UpdateAsync(GainfoAddSaveRequest request);
+        
+    }
+}

Src/Dlhis.Basic/MealUser/Services/Implements/GainfoService.cs

@@ -0,0 +1,77 @@
+using Dlhis.Basic.BusinessPlace.Response;
+using Dlhis.Basic.MealUser.Request;
+using Dlhis.Basic.Organization.Services;
+using Dlhis.Entity.Basic.Entity;
+using Kurisu.AspNetCore.Utils.Extensions;
+using Kurisu.Core.DataAccess.Dto;
+using Kurisu.SqlSugar.Extensions;
+using Kurisu.SqlSugar.Services;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Dlhis.Basic.MealUser.Services.Implements
+{
+    public class GainfoService : IGainfoService
+    {
+        
+        private readonly IGainfoStore _gainfoStore;
+
+        public GainfoService(IDbContext dbContext, IGainfoStore gainfoStore)
+        {
+           
+            _gainfoStore = gainfoStore;
+        }
+        /// <summary>
+        ///保存档案号
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public async Task SaveAsync(GainfoAddSaveRequest request)
+        {
+            await CheckGainfoGuestnoAsync(request);//档案号是否重复
+
+            var gainfos = new List<GainfoEntity>();
+            gainfos.Add(request.gainfoEntity);
+            await _gainfoStore.InsertAsync(request.gainfoStatus,gainfos);
+        }
+        /// <summary>
+        /// 档案分页
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public Task<Pagination<GainfoEntity>> GetPageAsync( GainfoPageRequest request)
+        {
+            var page = _gainfoStore.Queryable(request.gainfoStatus)
+                .Select<GainfoEntity>()
+               .ToPageListAsync(request);
+            return page;
+        }
+        /// <summary>
+        ///修改档案号
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public async Task UpdateAsync(GainfoAddSaveRequest request)
+        {
+            var gainfos = new List<GainfoEntity>();
+            gainfos.Add(request.gainfoEntity);
+            await _gainfoStore.UpdateAsync(request.gainfoStatus,gainfos);
+        }
+
+
+
+        //-------------------------------------------help methods-----------------------------------------------
+        /// <summary>
+        /// 检查档案号是否重复
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        private async Task CheckGainfoGuestnoAsync(GainfoAddSaveRequest request)
+        {
+
+            var checkGainfoGuestno = await _gainfoStore.Queryable(request.gainfoStatus)
+                .Where(x => x.Guestno == request.gainfoEntity.Guestno)
+                .AnyAsync();
+            checkGainfoGuestno.ThrowIfTrue($"档案号[{request.gainfoEntity.Guestno}]已存在");
+        }
+    }
+}

Src/Dlhis.Basic/MealUser/Services/Implements/MealUserService.cs

@@ -1,6 +1,9 @@
 using Dlhis.Basic.MealUser.Request;
 using Dlhis.Basic.MealUser.Response;
+using Dlhis.Basic.Organization.Services;
 using Dlhis.Entity.Basic.Entity;
+using Dlhis.Entity.Basic.Enums;
+using Kurisu.AspNetCore.Utils.Extensions;
 using Kurisu.Core.DataAccess.Dto;
 using Kurisu.SqlSugar.Extensions;
 using Kurisu.SqlSugar.Services;
@@ -10,10 +13,12 @@ namespace Dlhis.Basic.MealUser.Services.Implements;
 public class MealUserService : IMealUserService
 {
     private readonly IDbContext _dbContext;
+    private readonly IGainfoStore _gainfoStore;
 
-    public MealUserService(IDbContext dbContext)
+    public MealUserService(IDbContext dbContext, IGainfoStore gainfoStore)
     {
         _dbContext = dbContext;
+        _gainfoStore = gainfoStore;
     }
 
     public async Task<Pagination<MealUserResponse>> GetPageAsync(MealUserPageRequest request)
@@ -28,13 +33,19 @@ public class MealUserService : IMealUserService
     public async Task AddAsync(MealUserAddRequest request)
     {
         //todo 获取档案信息
+        
+        var gainfoEntity = await _gainfoStore.Queryable(GainfoStatusEnumType.Working)
+               .Where(x => x.Guestno == request.UserId)
+               .FirstAsync();
+        var b = gainfoEntity == null ? true : false;
+        b.ThrowIfTrue($"档案[{request.UserId}]不存在");
 
         var entity = new CanteenUserEntity
         {
             UserId = request.UserId,
             UserType = request.UserType,
-            UserCode = "",
-            CarNo = "",
+            UserCode = gainfoEntity.Ename,
+            CarNo = gainfoEntity.CarNo,
             Balance = 0,
             BalanceOfRecharge = 0,
             BalanceOfSubsidies = 0,