云数据模块修改

Models/CloudProduct/CloudProductModule.cs

@@ -9,7 +9,6 @@ using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using MySql.Data.MySqlClient;
 using Store.Modules.CloudProduct.Services;
-using Microsoft.Extensions.Configuration;
 
 namespace Store.Modules.CloudProduct
 {

Models/CloudProduct/Controllers/GoodsController.cs

@@ -19,12 +19,14 @@ namespace Store.Modules.CloudProduct.Controllers
 		private readonly IGoodsService _goodsService;
 		private readonly IOpenSearchService _searchService;
 		private readonly IRawDataStorage _rawDataStorage;
+		private readonly GoodsIndexJob _goodsIndexJob;
 
-		public GoodsController(IGoodsService goodsService, IOpenSearchService searchService, IRawDataStorage rawDataStorage)
+		public GoodsController(IGoodsService goodsService, IOpenSearchService searchService, IRawDataStorage rawDataStorage, GoodsIndexJob goodsIndexJob)
 		{
 			_goodsService = goodsService;
 			_searchService = searchService;
 			_rawDataStorage = rawDataStorage;
+			_goodsIndexJob = goodsIndexJob;
 		}
 
 		[HttpGet]
@@ -32,7 +34,11 @@ namespace Store.Modules.CloudProduct.Controllers
 		{
 			return DateTime.Now.ToLongDateString();
 		}
-
+		[HttpGet]
+		public async Task Job()
+		{
+			await _goodsIndexJob.ProcessPendingAsync();
+		}
 		/// <summary>
 		/// 搜索
 		/// </summary>

Models/CloudProduct/Repositorys/GoodsRepository.cs

@@ -1,5 +1,6 @@
 using FreeSql;
 using MAX.Core.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
 using Store.Modules.CloudProduct.Entities;
 
 namespace Store.Modules.CloudProduct.Repositorys
@@ -9,7 +10,7 @@ namespace Store.Modules.CloudProduct.Repositorys
 	/// </summary>
 	public class GoodsRepository : BaseRepository<GoodsEntity>, IScopedDependency
 	{
-		public GoodsRepository(IFreeSql fsql) : base(fsql)
+		public GoodsRepository([FromKeyedServices("CloudProductConnection")] IFreeSql fsql) : base(fsql)
 		{
 		}
 	}

Models/CloudProduct/Startup.cs

@@ -19,6 +19,23 @@ namespace Store.Modules.CloudProduct
 
 		public void Register(IServiceRegistrar registrar)
 		{
+
+
+
+			Func<IServiceProvider, IFreeSql> KJDFsqlFactory = r =>
+			{
+				var config = r.GetRequiredService<IConfiguration>();
+				var connection = config.GetValue<string>("CloudProductConnection");
+				IFreeSql fsql = new FreeSql.FreeSqlBuilder()
+					.UseConnectionString(FreeSql.DataType.MySql, connection)
+					.UseAdoConnectionPool(true)
+					.Build();
+				return fsql;
+			};
+			registrar.RegisterSingleton<IFreeSql>("CloudProductConnection", (s, k) =>
+			{
+				return KJDFsqlFactory(s);
+			});
 		}
 
 		public async void Start(IServiceProvider serviceProvider)

Models/CloudProduct/Store.Modules.CloudProduct.csproj

@@ -1,7 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>

Models/CloudProduct/appsettings.json

@@ -1,4 +1,5 @@
 {
+  "CloudProductConnection": "Server=192.168.0.200;Port=3306;Database=goods_center;Uid=root;Pwd=123456;Allow User Variables=true",
   "Search": {
     "Url": "http://192.168.0.200:9200",
     "IndexName": "goods_search"