This commit is contained in:
Antinew 2025-07-12 00:51:00 +08:00
parent a8b2c38b3b
commit 979250b912
13 changed files with 25 additions and 15 deletions

View File

@ -10,7 +10,7 @@
<ItemGroup> <ItemGroup>
<ProjectReference Include="..\InterfaceForward.Application\InterfaceForward.Application.csproj" /> <ProjectReference Include="..\InterfaceForward.Application\InterfaceForward.Application.csproj" />
<ProjectReference Include="..\InterfaceForward.ServiceDefaults\InterfaceForward.ServiceDefaults.csproj"/> <ProjectReference Include="..\InterfaceForward.ServiceDefaults\InterfaceForward.ServiceDefaults.csproj"/>
<PackageReference Include="Fake.Autofac" Version="8.0.0-preview.5" /> <PackageReference Include="Fake.Autofac" Version="8.0.0-preview10" />
<PackageReference Include="Serilog.AspNetCore" Version="9.0.0" /> <PackageReference Include="Serilog.AspNetCore" Version="9.0.0" />
<PackageReference Include="Serilog.Sinks.Elasticsearch" Version="10.0.0" /> <PackageReference Include="Serilog.Sinks.Elasticsearch" Version="10.0.0" />
<PackageReference Include="Serilog.Sinks.Console" Version="6.0.0" /> <PackageReference Include="Serilog.Sinks.Console" Version="6.0.0" />

View File

@ -48,7 +48,8 @@
"HostName": "129.204.22.146", "HostName": "129.204.22.146",
"Port": 5672, "Port": 5672,
"UserName": "rabbit", "UserName": "rabbit",
"Password": "itd!@#123" "Password": "itd!@#123",
"DispatchConsumersAsync": true
} }
} }
}, },

View File

@ -17,9 +17,9 @@
<PackageReference Include="DiffPlex" Version="1.7.2" /> <PackageReference Include="DiffPlex" Version="1.7.2" />
<PackageReference Include="Aliyun.OSS.SDK.NetCore" Version="2.14.1" /> <PackageReference Include="Aliyun.OSS.SDK.NetCore" Version="2.14.1" />
<PackageReference Include="DotNetCore.Natasha.CSharp" Version="5.2.2.1"/> <PackageReference Include="DotNetCore.Natasha.CSharp" Version="5.2.2.1"/>
<PackageReference Include="Fake.AspNetCore" Version="8.0.0-preview.5" /> <PackageReference Include="Fake.AspNetCore" Version="8.0.0-preview10" />
<PackageReference Include="Fake.EventBus.RabbitMQ" Version="8.0.0-preview.6" /> <PackageReference Include="Fake.EventBus.RabbitMQ" Version="8.0.0-preview10" />
<PackageReference Include="Fake.ObjectMapping.AutoMapper" Version="8.0.0-preview.5" /> <PackageReference Include="Fake.ObjectMapping.AutoMapper" Version="8.0.0-preview10" />
<PackageReference Include="FreeRedis" Version="1.3.6" /> <PackageReference Include="FreeRedis" Version="1.3.6" />
</ItemGroup> </ItemGroup>

View File

@ -51,7 +51,7 @@ public class ServiceProviderService : ApplicationService
/// <returns></returns> /// <returns></returns>
[HttpGet("ServiceProvider/GetServiceProviderInterfaceCascadedList")] [HttpGet("ServiceProvider/GetServiceProviderInterfaceCascadedList")]
public async Task<List<ServiceProviderInterfaceCascadedObjectValue>> public async Task<List<ServiceProviderInterfaceCascadedObjectValue>>
GetServiceProviderInterfaceCascadedListAsync([Required] int interfaceId, string serviceProviderName) GetServiceProviderInterfaceCascadedListAsync([Required] int interfaceId, string? serviceProviderName)
{ {
return await _serviceProviderRepository.GetServiceProviderInterfaceCascadedListAsync(interfaceId, return await _serviceProviderRepository.GetServiceProviderInterfaceCascadedListAsync(interfaceId,
serviceProviderName); serviceProviderName);

View File

@ -11,6 +11,6 @@
<ItemGroup> <ItemGroup>
<PackageReference Include="Fake.DomainDrivenDesign" Version="8.0.0-preview.5" /> <PackageReference Include="Fake.DomainDrivenDesign" Version="8.0.0-preview10" />
</ItemGroup> </ItemGroup>
</Project> </Project>

View File

@ -1,4 +1,5 @@
using Fake.Modularity; using Fake.DomainDrivenDesign;
using Fake.Modularity;
using InterfaceForward.Domain.Shared.Helpers; using InterfaceForward.Domain.Shared.Helpers;
using InterfaceForward.Domain.Shared.Options; using InterfaceForward.Domain.Shared.Options;
using Microsoft.Extensions.Configuration; using Microsoft.Extensions.Configuration;
@ -6,6 +7,7 @@ using Microsoft.Extensions.DependencyInjection;
namespace InterfaceForward.Domain.Shared namespace InterfaceForward.Domain.Shared
{ {
[DependsOn(typeof(FakeDomainDrivenDesignModule))]
public class InterfaceForwardDomainSharedModule : FakeModule public class InterfaceForwardDomainSharedModule : FakeModule
{ {
public override void ConfigureServices(ServiceConfigurationContext context) public override void ConfigureServices(ServiceConfigurationContext context)

View File

@ -10,7 +10,7 @@ namespace InterfaceForward.Repositories;
/// <typeparam name="T"></typeparam> /// <typeparam name="T"></typeparam>
public class BasicRepository<T> : SqlSugarRepository<InterfaceForwardDbContext, T>, IBasicRepository<T>where T : class, IAggregateRoot, new() public class BasicRepository<T> : SqlSugarRepository<InterfaceForwardDbContext, T>, IBasicRepository<T>where T : class, IAggregateRoot, new()
{ {
protected ISqlSugarClient Context => GetDbContextAsync().Result.SqlSugarClient; protected ISqlSugarClient Context => GetDbContextAsync().Result;
public ISugarQueryable<T> AsQueryable() public ISugarQueryable<T> AsQueryable()
{ {
@ -37,7 +37,7 @@ public class BasicRepository<T> : SqlSugarRepository<InterfaceForwardDbContext,
Expression<Func<T, TResult>> resultExpression) Expression<Func<T, TResult>> resultExpression)
{ {
var ctx = await GetDbContextAsync(); var ctx = await GetDbContextAsync();
return await ctx.SqlSugarClient.Queryable<T>().Where(whereExpression).Select(resultExpression).ToListAsync(); return await ctx.Queryable<T>().Where(whereExpression).Select(resultExpression).ToListAsync();
} }
public async Task<int> CountAsync(Expression<Func<T, bool>> exp) public async Task<int> CountAsync(Expression<Func<T, bool>> exp)

View File

@ -8,5 +8,5 @@ public class GetMapListInputVO : PagedQueryInput
[Required] [Required]
public int InterfaceId { get; set; } public int InterfaceId { get; set; }
public string NameOrCode { get; set; } public string? NameOrCode { get; set; }
} }

View File

@ -15,6 +15,6 @@ namespace InterfaceForward.Repositories.Interface.ValueObjects
///<summary> ///<summary>
/// 接口名 /// 接口名
///</summary> ///</summary>
public string NameOrCode { get; set; } public string? NameOrCode { get; set; }
} }
} }

View File

@ -7,7 +7,7 @@
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="Fake.SqlSugarCore" Version="8.0.0-preview.5" /> <PackageReference Include="Fake.SqlSugarCore" Version="8.0.0-preview10" />
<PackageReference Include="NEST" Version="7.17.5" /> <PackageReference Include="NEST" Version="7.17.5" />
</ItemGroup> </ItemGroup>

View File

@ -24,4 +24,11 @@ public class InterfaceForwardDbContext:SugarDbContext<InterfaceForwardDbContext>
base.ConfigureEntityService(property, column); base.ConfigureEntityService(property, column);
} }
protected override void ConfigureGlobalFilters()
{
//需自定义扩展
SqlSugarClient.QueryFilter.AddTableFilter<ISoftDelete>(u =>
DataFilter.IsEnabled<ISoftDelete>() == false || !u.IsDeleted);
}
} }

View File

@ -22,7 +22,7 @@ namespace InterfaceForward.Repositories.ServiceProvider.Services
/// </summary> /// </summary>
/// <returns></returns> /// <returns></returns>
Task<List<ServiceProviderInterfaceCascadedObjectValue>> GetServiceProviderInterfaceCascadedListAsync( Task<List<ServiceProviderInterfaceCascadedObjectValue>> GetServiceProviderInterfaceCascadedListAsync(
int interfaceId, string serviceProviderName); int interfaceId, string? serviceProviderName);
/// <summary> /// <summary>
/// 更新服务商 /// 更新服务商

View File

@ -46,7 +46,7 @@ public class ServiceProviderRepository : BasicRepository<ServiceProviderEntity>,
/// <inheritdoc /> /// <inheritdoc />
public async Task<List<ServiceProviderInterfaceCascadedObjectValue>> public async Task<List<ServiceProviderInterfaceCascadedObjectValue>>
GetServiceProviderInterfaceCascadedListAsync(int interfaceId, string serviceProviderName) GetServiceProviderInterfaceCascadedListAsync(int interfaceId, string? serviceProviderName)
{ {
var mappedIds = await Context.Queryable<InterfaceMapEntity>() var mappedIds = await Context.Queryable<InterfaceMapEntity>()
.LeftJoin<InterfaceEntity>((x, y) => x.DownStreamId == y.Id) .LeftJoin<InterfaceEntity>((x, y) => x.DownStreamId == y.Id)