字段对照

ThirdPlugIns/Shentun.Peis.PlugIns.Gem/test/Shentun.Peis.PlugIns.Gem.Test/HisTest.cs

@@ -66,11 +66,11 @@ namespace Shentun.Peis.PlugIns.Gem.Test
                     },
                     Patient = new HisPatientQueryPatientInput()
                     {
-                        IdCard = "4306249901019311",
+                        IdCard = "4306249801019311",
                         IdCardCode = "01",
-                        Name = "李四",
+                        Name = "王五的",
                         Sex = "2",
-                        BirthDate = "1999-09-01",
+                        BirthDate = "1993-09-01",
                         PatientPhone = "18911254911",
                         EthnicGroupCode = "01",
                         WorkUnit = "本医院",
@@ -110,18 +110,19 @@ namespace Shentun.Peis.PlugIns.Gem.Test
                    {
                        new HisMecSaveDataItemInput()
                        {
-                           ExamRequestNo = "0001",
+                           ExamRequestNo = "0003",
                            FeeType = "1",
-                           EmpId = "TJ00000006",
+                           EmpId = "TJ00000007",
                            DeptId = "",
                            DoctId = "",
                            ExeDeptId = "",
                            Tjunit = "本院",
                            Tjfee = "1234567.89",
-                           Ztxm = "13932,13933",
+                           Ztxm = "",
                            Remark = "备注但是发射点法大师傅撒旦"
 
-                       }
+                       },
+                      
                    }
                 }
             };
@@ -155,7 +156,7 @@ namespace Shentun.Peis.PlugIns.Gem.Test
                     },
                     Item = new HisCancelQrCodeDataItemInput()
                    {
-                       Yjxh = "900",
+                       Yjxh = "899",
                        ExamRequestNo = "0001"
                     }
                 }
@@ -190,8 +191,8 @@ namespace Shentun.Peis.PlugIns.Gem.Test
                     },
                     Item = new HisPayStatusDataItemInput()
                     {
-                        Yjxh = "899",
-                        ExamRequestNo = "0001"
+                        Yjxh = "911",
+                        ExamRequestNo = "0003"
                     }
                 }
             };
@@ -225,8 +226,8 @@ namespace Shentun.Peis.PlugIns.Gem.Test
                     },
                     Item = new HisAgreeRefundDataItemInput()
                     {
-                        Yjxh = "900",
-                        ExamRequestNo = "0001"
+                        Yjxh = "911",
+                        ExamRequestNo = "0003"
                     }
                 }
             };

src/Shentun.ColumnReferencePlugIns/ColumnReferencePlugIns.cs

@@ -8,11 +8,11 @@ namespace Shentun.Peis.PlugIns
 {
     interface IColumnReferencePlugIns
     {
-        public List<string> GetColumnNames();
-        public string GetFilterColumnName();
+        public List<string> GetAppColumnNames();
+        public string GetAppFilterColumnName();
         public List<string> GetInterfaceColumnNames();
-        public Task<List<ColumnReferenceCodeValue>> GetCodeValuesAsync();
-        public Task<List<ColumnReferenceFilterCodeValue>> GetFilterCodeValuesAsync();
+        public Task<List<ColumnReferenceCodeValue>> GetAppCodeValuesAsync();
+        public Task<List<ColumnReferenceFilterCodeValue>> GetAppFilterCodeValuesAsync();
         public Task<List<ColumnReferenceCodeValue>> GetInterfaceCodeValuesAsync();
     }
 

src/Shentun.ColumnReferencePlugIns/ColumnReferencePlugInsBase.cs

@@ -45,7 +45,7 @@ namespace Shentun.Peis.PlugIns
 
 
         }
-        public virtual List<string> GetColumnNames()
+        public virtual List<string> GetAppColumnNames()
         {
             if (_columnNames == null || _columnNames.Count() == 0)
             {
@@ -71,7 +71,7 @@ namespace Shentun.Peis.PlugIns
             }
             return _interfaceColumnNames.ToList();
         }
-        public virtual async Task<List<ColumnReferenceCodeValue>> GetCodeValuesAsync()
+        public virtual async Task<List<ColumnReferenceCodeValue>> GetAppCodeValuesAsync()
         {
             using (DbConnection conn = new NpgsqlConnection(ConnctionStr))
             {
@@ -88,12 +88,12 @@ namespace Shentun.Peis.PlugIns
             };
         }
 
-        public virtual async Task<List<ColumnReferenceFilterCodeValue>> GetFilterCodeValuesAsync()
+        public virtual async Task<List<ColumnReferenceFilterCodeValue>> GetAppFilterCodeValuesAsync()
         {
             throw new NotImplementedException();
         }
 
-        public virtual string GetFilterColumnName()
+        public virtual string GetAppFilterColumnName()
         {
             return null;
         }

src/Shentun.ColumnReferencePlugIns/ColumnReferencePlugInsDbBase.cs

@@ -57,7 +57,7 @@ namespace Shentun.Peis.PlugIns
                 var list = (await conn.QueryAsync<ColumnReferenceCodeValue>(InterfaceSql)).ToList();
                 foreach (var item in list)
                 {
-                    item.DisplayName = LanguageConverter.GetPYSimpleCode(item.DisplayName);
+                    item.SimpleCode = LanguageConverter.GetPYSimpleCode(item.DisplayName);
                 }
                 return list;
             }

src/Shentun.ColumnReferencePlugIns/PeisPlugInsModule.cs

@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Volo.Abp;
+using Volo.Abp.Modularity;
+
+namespace Shentun.Peis.PlugIns
+{
+    public class PeisPlugInsModule : AbpModule
+    {
+        public override void OnApplicationInitialization(ApplicationInitializationContext context)
+        {
+            //var myService = context.ServiceProvider
+            //    .GetRequiredService<MyService>();
+
+            //myService.Initialize();
+        }
+    }
+}

src/Shentun.ColumnReferencePlugIns/Shentun.Peis.PlugIns.csproj

@@ -13,6 +13,7 @@
     <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="6.0.0" />
     <PackageReference Include="Npgsql" Version="6.0.2" />
     <PackageReference Include="Oracle.ManagedDataAccess.Core" Version="3.21.140" />
+    <PackageReference Include="Volo.Abp.Core" Version="6.0.0" />
   </ItemGroup>
 
   <ItemGroup>

src/Shentun.Peis.Application.Contracts/ColumnReferences/ColumnReferenceInterfaceCodeValueDto.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Shentun.Peis.ColumnReferences
+{
+    public class ColumnReferenceInterfaceCodeValueDto
+    {
+        public string CodeValue { get; set; }
+        public string DisplayName{ get; set; }
+    }
+}

src/Shentun.Peis.Application.Contracts/ColumnReferences/ColumnReferenceInterfaceCodeValuesInputDto.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Shentun.Peis.ColumnReferences
+{
+    public class ColumnReferenceInterfaceCodeValuesInputDto
+    {
+        public Guid ColumnReferenceId { get; set; }
+        public string Code { get; set;}
+    }
+}

src/Shentun.Peis.Application/ColumnReferences/ColumnReferenceAppService.cs

@@ -23,6 +23,8 @@ using Volo.Abp.ObjectMapping;
 using Microsoft.Extensions.Configuration;
 using System.IO;
 using Shentun.Peis.HelperDto;
+using Shentun.Peis.PlugIns;
+using Volo.Abp.Threading;
 
 namespace Shentun.Peis.ColumnReferences
 {
@@ -34,6 +36,8 @@ namespace Shentun.Peis.ColumnReferences
     public class ColumnReferenceAppService : ApplicationService
     {
         private readonly IRepository<ColumnReference, Guid> _repository;
+        private readonly IRepository<ColumnReferenceCode, Guid> _columnReferenceCodeRepository;
+        private readonly IRepository<ColumnReferenceInterface, Guid> _columnReferenceInterfaceRepository;
         private readonly ColumnReferenceManager _manager;
         private readonly CacheService _cacheService;
         private readonly IRepository<IdentityUser, Guid> _userRepository;
@@ -42,13 +46,17 @@ namespace Shentun.Peis.ColumnReferences
             IRepository<ColumnReference, Guid> repository,
             ColumnReferenceManager manager,
             CacheService cacheService,
-            IRepository<IdentityUser, Guid> userRepository
+            IRepository<IdentityUser, Guid> userRepository,
+            IRepository<ColumnReferenceCode, Guid> columnReferenceCodeRepository,
+            IRepository<ColumnReferenceInterface, Guid> columnReferenceInterfaceRepository
               )
         {
             _repository = repository;
             _manager = manager;
             _cacheService = cacheService;
             _userRepository = userRepository;
+            _columnReferenceCodeRepository = columnReferenceCodeRepository;
+            _columnReferenceInterfaceRepository = columnReferenceInterfaceRepository;
 
         }
 
@@ -173,86 +181,206 @@ namespace Shentun.Peis.ColumnReferences
         {
             await _manager.UpdateSortManyAsync(input);
         }
+        /// <summary>
+        ///获取字段对照本系统所有列名
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("api/app/ColumnReference/GetAppColumnNames")]
+        public async Task<List<string>> GetAppColumnNamesAsync(ColumnReferenceIdInputDto input)
+        {
+            var entity = await _repository.GetAsync(input.Id);
+            var parmValue = entity.ParmValue;
+            var configurationBuilder = new ConfigurationBuilder()
+               .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
+            var config = configurationBuilder.Build();
+            var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
+            var className = config.GetSection("Interface").GetSection("ClassName").Value;
+            object objectValue = await InvokeAsync(assemblyName, className, parmValue, "GetAppColumnNames");
+            List<string> list = new List<string>();
+
+            if (objectValue is IEnumerable enumerableObject)
+            {
+                list = enumerableObject.Cast<string>().ToList();
+            }
+            return list;
+        }
+        public async Task<string> GetAppFilterColumnName(ColumnReferenceIdInputDto input)
+        {
+            return null;
+        }
+        /// <summary>
+        ///获取字段对照第三方系统所有列名
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("api/app/ColumnReference/GetInterfaceColumnNames")]
+        public async Task<List<string>> GetInterfaceColumnNamesAsync(ColumnReferenceIdInputDto input)
+        {
+            var entity = await _repository.GetAsync(input.Id);
+            var parmValue = entity.ParmValue;
+            var configurationBuilder = new ConfigurationBuilder()
+               .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
+            var config = configurationBuilder.Build();
+            var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
+            var className = config.GetSection("Interface").GetSection("ClassName").Value;
+            object objectValue = await InvokeAsync(assemblyName, className, parmValue, "GetInterfaceColumnNames");
+            List<string> list = new List<string>();
+
+            if (objectValue is IEnumerable enumerableObject)
+            {
+                list = enumerableObject.Cast<string>().ToList();
+            }
+            return list;
+        }
+        /// <summary>
+        ///获取字段对照本系统所有数据
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("api/app/ColumnReference/GetAppCodeValues")]
+        public async Task<List<ColumnReferenceCodeValue>> GetAppCodeValuesAsync(ColumnReferenceIdInputDto input)
+        {
+            //var columnReferenceCodes = await _columnReferenceCodeRepository.GetListAsync(o => o.CodeValue == input.Id.ToString());
 
+            var entity = await _repository.GetAsync(input.Id);
+            var parmValue = entity.ParmValue;
+            var configurationBuilder = new ConfigurationBuilder()
+               .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
+            var config = configurationBuilder.Build();
+            var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
+            var className = config.GetSection("Interface").GetSection("ClassName").Value;
+            var list = await InvokeListAsync(assemblyName, className, parmValue, "GetAppCodeValuesAsync");
+            
+            return list;
+        }
 
-        //public async Task<List<string>> GetColumns(ColumnReferenceIdInputDto input)
-        //{
-        //    var entity = await _repository.GetAsync(input.Id);
-        //    var parmValue = entity.ParmValue;
-        //    var configurationBuilder = new ConfigurationBuilder()
-        //       .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
-        //    var config = configurationBuilder.Build();
-        //    var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
-        //    var className = config.GetSection("Interface").GetSection("ClassName").Value;
-        //    object objectValue = Invoke(assemblyName, className, "GetColumns");
-        //    List<string> list = new List<string>();
+        public async Task<List<ColumnReferenceFilterCodeValue>> GetAppFilterCodeValues(ColumnReferenceIdInputDto input)
+        {
+            return null;
+        }
+        /// <summary>
+        ///获取字段对照第三方系统所有数据
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("api/app/ColumnReference/GetInterfaceCodeValues")]
+        public async Task<List<ColumnReferenceCodeValue>> GetInterfaceCodeValuesAsync(ColumnReferenceIdInputDto input)
+        {
+            var entity = await _repository.GetAsync(input.Id);
+            var parmValue = entity.ParmValue;
+            var configurationBuilder = new ConfigurationBuilder()
+               .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
+            var config = configurationBuilder.Build();
+            var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
+            var className = config.GetSection("Interface").GetSection("ClassName").Value;
+            var list = await InvokeListAsync(assemblyName, className, parmValue, "GetInterfaceCodeValuesAsync");
+           
 
-        //    if (objectValue is IEnumerable enumerableObject)
-        //    {
-        //        list = enumerableObject.Cast<string>().ToList();
-        //    }
-        //    return list;
-        //}
-        //public async Task<string> GetFilterColumnName(ColumnReferenceIdInputDto input)
-        //{
-        //    return null;
-        //}
 
-        //public async Task<List<string>> GetInterfaceColumns(ColumnReferenceIdInputDto input)
-        //{
-        //    var entity = await _repository.GetAsync(input.Id);
-        //    var parmValue = entity.ParmValue;
-        //    var configurationBuilder = new ConfigurationBuilder()
-        //       .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
-        //    var config = configurationBuilder.Build();
-        //    var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
-        //    var className = config.GetSection("Interface").GetSection("ClassName").Value;
-        //    object objectValue = Invoke(assemblyName, className, "GetInterfaceColumns");
-        //    List<string> list = new List<string>();
+            return list;
+        }
+        /// <summary>
+        /// 通过本系统编码获取第三方系统编码
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("api/app/ColumnReference/GetInterfaceCodeValuesByAppCode")]
+        public async Task<List<ColumnReferenceInterfaceCodeValueDto>> GetInterfaceCodeValuesByAppCode(ColumnReferenceInterfaceCodeValuesInputDto input)
+        {
+            var columnReferenceCode = await _columnReferenceCodeRepository.FirstOrDefaultAsync(o => o.CodeValue == input.Code);
+            if(columnReferenceCode == null)
+            {
+                return null;
+            }
+            var items = await _columnReferenceInterfaceRepository.GetListAsync(o => o.ColumnReferenceCodeId == columnReferenceCode.Id);
+           
+            var entity = await _repository.GetAsync(input.ColumnReferenceId);
+            var parmValue = entity.ParmValue;
+            var configurationBuilder = new ConfigurationBuilder()
+               .AddJsonStream(new MemoryStream(System.Text.Encoding.UTF8.GetBytes(parmValue)));
+            var config = configurationBuilder.Build();
+            var assemblyName = config.GetSection("Interface").GetSection("AssemblyName").Value;
+            var className = config.GetSection("Interface").GetSection("ClassName").Value;
+            var list = await InvokeListAsync(assemblyName, className, parmValue, "GetInterfaceCodeValuesAsync");
+            var result = new List<ColumnReferenceInterfaceCodeValueDto>();
+            foreach ( var item in items)
+            {
+                var columnReferenceInterfaceCodeValueDto = new ColumnReferenceInterfaceCodeValueDto()
+                {
+                    CodeValue = item.InterfaceCodeValue,
+                };
+                var interfaceItem = list.Where(o => o.Code == item.InterfaceCodeValue).FirstOrDefault();
+                if(interfaceItem != null)
+                {
+                    columnReferenceInterfaceCodeValueDto.DisplayName = interfaceItem.DisplayName;
+                }
+                result.Add(columnReferenceInterfaceCodeValueDto);
+            }
+            return result;
+        }
+        public async Task<List<ColumnReferenceCodeValue>> GetColumnReferenceInterfaceCodeValues(ColumnReferenceIdInputDto input)
+        {
+            return null;
+        }
 
-        //    if (objectValue is IEnumerable enumerableObject)
-        //    {
-        //        list = enumerableObject.Cast<string>().ToList();
-        //    }
-        //    return list;
-        //}
+        public async Task CreateColumnReferenceValue(CreateColumnReferenceValue input)
+        {
 
-        //public async Task<List<ColumnReferenceCodeValue>> GetCodeValues(ColumnReferenceIdInputDto input)
-        //{
-        //    return null;
-        //}
+        }
 
-        //public async Task<List<ColumnReferenceFilterCodeValue>> GetFilterCodeValues(ColumnReferenceIdInputDto input)
-        //{
-        //    return null;
-        //}
+        private async Task<object> InvokeAsync(string assemblyName, string className,string classConstructorArg, string methodName, object[] args = null)
+        {
+            Assembly assembly = Assembly.Load(assemblyName);
+            Type type = assembly.GetType(className);
+            // 创建类的实例
+            object instance = Activator.CreateInstance(type, classConstructorArg);
+            // 获取方法信息
+            MethodInfo method = type.GetMethod(methodName);
+            // 调用方法,如果方法需要参数，可以传入对应的参数数组，例如: new object[] { arg1, arg2 }
+            object returnValue;
+            var isAsync = (method.ReturnType == typeof(Task) ||
+                (method.ReturnType.IsGenericType && method.ReturnType.GetGenericTypeDefinition() == typeof(Task<>)));
+            if (isAsync)
+            {
+                // 使用反射调用方法
 
-        //public async Task<List<ColumnReferenceCodeValue>> GetInterfaceCodeValues(ColumnReferenceIdInputDto input)
-        //{
-        //    return null;
-        //}
+                //object returnValue = method.Invoke(instance, args);
+                returnValue = await(Task<object>)method.Invoke(instance, args);
+            }
+            else
+            {
+                returnValue = method.Invoke(instance, args);
 
-        //public async Task<List<ColumnReferenceCodeValue>> GetColumnReferenceInterfaceCodeValues(ColumnReferenceIdInputDto input)
-        //{
-        //    return null;
-        //}
+            }
+            return returnValue;
+        }
+        private async Task<List<ColumnReferenceCodeValue>> InvokeListAsync(string assemblyName, string className, string classConstructorArg, string methodName, object[] args = null)
+        {
+            Assembly assembly = Assembly.Load(assemblyName);
+            Type type = assembly.GetType(className);
+            // 创建类的实例
+            object instance = Activator.CreateInstance(type, classConstructorArg);
+            // 获取方法信息
+            MethodInfo method = type.GetMethod(methodName);
+            // 调用方法,如果方法需要参数，可以传入对应的参数数组，例如: new object[] { arg1, arg2 }
+            List<ColumnReferenceCodeValue> returnValue;
+            var isAsync = (method.ReturnType == typeof(Task) ||
+                (method.ReturnType.IsGenericType && method.ReturnType.GetGenericTypeDefinition() == typeof(Task<>)));
+            if (isAsync)
+            {
+                // 使用反射调用方法
 
-        //public async Task CreateColumnReferenceValue(CreateColumnReferenceValue input)
-        //{
+                //object returnValue = method.Invoke(instance, args);
+                returnValue = await (Task<List<ColumnReferenceCodeValue>>)method.Invoke(instance, args);
+            }
+            else
+            {
+                returnValue = (List<ColumnReferenceCodeValue>)method.Invoke(instance, args);
 
-        //}
+            }
+            return returnValue;
+        }
 
-        //private object Invoke(string assemblyName, string className, string methodName, object[] args = null)
-        //{
-        //    Assembly assembly = Assembly.Load(assemblyName);
-        //    Type type = assembly.GetType(className);
-        //    // 创建类的实例
-        //    object instance = Activator.CreateInstance(type);
-        //    // 获取方法信息
-        //    MethodInfo method = type.GetMethod(methodName);
-        //    // 调用方法,如果方法需要参数，可以传入对应的参数数组，例如: new object[] { arg1, arg2 }
-        //    object returnValue = method.Invoke(instance, args);
-        //    return returnValue;
-        //}
     }
 }

src/Shentun.Peis.Application/PeisApplicationModule.cs

@@ -13,6 +13,8 @@ using Shentun.Peis.MyUser;
 using Shentun.Peis.PermissionManagements;
 using Shentun.Peis.OrganizationUnits;
 using Volo.Abp.Http.Client.IdentityModel;
+using Shentun.Peis.PlugIns;
+using Volo.Abp.Modularity.PlugIns;
 
 namespace Shentun.Peis;
 
@@ -46,7 +48,10 @@ public class PeisApplicationModule : AbpModule
 
         context.Services.AddHttpClient("Peis");
 
-       
+        //context.Services.AddApplication<PeisPlugInsModule>(options =>
+        //{
+        //    options.PlugInSources.AddFolder(@"E:\Whitedolphins\NextPeis\src\Shentun.ColumnReferencePlugIns\bin\Debug\net6.0");
+        //});
     }
 
 

test/Shentun.Peis.Application.Tests/ColumnReferenceAppServiceTest.cs

@@ -0,0 +1,124 @@
+using Shentun.Peis.ChargeRequests;
+using Shentun.Peis.ColumnReferences;
+using Shentun.Peis.Models;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Uow;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Shentun.Peis
+{
+    public class ColumnReferenceAppServiceTest : PeisApplicationTestBase
+    {
+        private readonly IRepository<ColumnReference, Guid> _repository;
+        private readonly ColumnReferenceAppService _appService;
+        private readonly ITestOutputHelper _output;
+        private readonly IUnitOfWorkManager _unitOfWorkManager;
+        public ColumnReferenceAppServiceTest(ITestOutputHelper testOutputHelper)
+        {
+            _output = testOutputHelper;
+            _unitOfWorkManager = GetRequiredService<IUnitOfWorkManager>();
+            _repository = GetRequiredService<IRepository<ColumnReference, Guid>>();
+            _appService = GetRequiredService<ColumnReferenceAppService>();
+        }
+
+        [Fact]
+        public async Task GetAppColumnNames()
+        {
+            using (var unitOfWork = _unitOfWorkManager.Begin(isTransactional: true))
+            {
+
+                var entity = new ColumnReferenceIdInputDto()
+                {
+                    Id = new Guid("3a1222e4-3249-34a2-85f0-f72e974de543"),
+
+                };
+
+                var newEntity = await _appService.GetAppColumnNamesAsync(entity);
+                if(newEntity != null)
+                {
+                    foreach(var column in newEntity)
+                    {
+                        _output.WriteLine(column);
+                    }
+                }
+                await unitOfWork.CompleteAsync();
+            }
+        }
+
+        [Fact]
+        public async Task GetInterfaceColumnNames()
+        {
+            using (var unitOfWork = _unitOfWorkManager.Begin(isTransactional: true))
+            {
+
+                var entity = new ColumnReferenceIdInputDto()
+                {
+                    Id = new Guid("3a1222e4-3249-34a2-85f0-f72e974de543"),
+
+                };
+
+                var newEntity = await _appService.GetInterfaceColumnNamesAsync(entity);
+                if (newEntity != null)
+                {
+                    foreach (var column in newEntity)
+                    {
+                        _output.WriteLine(column);
+                    }
+                }
+                await unitOfWork.CompleteAsync();
+            }
+        }
+
+        [Fact]
+        public async Task GetAppCodeValues()
+        {
+            using (var unitOfWork = _unitOfWorkManager.Begin(isTransactional: true))
+            {
+
+                var entity = new ColumnReferenceIdInputDto()
+                {
+                    Id = new Guid("3a1222e4-3249-34a2-85f0-f72e974de543"),
+
+                };
+
+                var newEntity = await _appService.GetAppCodeValuesAsync(entity);
+                foreach (var column in newEntity)
+                {
+                    _output.WriteLine(column.DisplayName);
+                }
+                await unitOfWork.CompleteAsync();
+            }
+        }
+
+        [Fact]
+        public async Task GetInterfaceCodeValues()
+        {
+            using (var unitOfWork = _unitOfWorkManager.Begin(isTransactional: true))
+            {
+
+                var entity = new ColumnReferenceIdInputDto()
+                {
+                    Id = new Guid("3a1222e4-3249-34a2-85f0-f72e974de543"),
+
+                };
+
+                var newEntity = await _appService.GetInterfaceCodeValuesAsync(entity);
+                if(newEntity != null)
+                {
+                    foreach (var column in newEntity)
+                    {
+                        _output.WriteLine(column.DisplayName);
+                    }
+                }
+              
+                await unitOfWork.CompleteAsync();
+            }
+        }
+    }
+}

test/Shentun.Peis.ColumnReference.Tests/ColumnReferencePlugInsAsbitemBaseTest.cs → test/Shentun.Peis.ColumnReference.Tests/ColumnReferencePlugInsTest.cs

@@ -11,10 +11,10 @@ using Xunit.Abstractions;
 
 namespace Shentun.Peis.PlugIns.Tests
 {
-    public class ColumnReferencePlugInsAsbitemBaseTest
+    public class ColumnReferencePlugInsTest
     {
         private readonly ITestOutputHelper _output;
-        public ColumnReferencePlugInsAsbitemBaseTest(ITestOutputHelper testOutputHelper)
+        public ColumnReferencePlugInsTest(ITestOutputHelper testOutputHelper)
         {
             _output = testOutputHelper;