新增文件传输gRPC

.gitignore

@@ -259,16 +259,31 @@ paket-files/
 # Python Tools for Visual Studio (PTVS)
 __pycache__/
 *.pyc
-/ZR.Admin.WebApi/appsettings.Development.json
 /CodeGenerate
-/ZR.Admin.WebApi/appsettings.Production.json
-/ZR.Admin.WebApi/wwwroot/uploads
 /ZR.Admin.WebApi/wwwroot/Generatecode
 /ZR.Admin.WebApi/wwwroot/export
 /ZR.Vue/src/views/business/Gendemo.vue
-/ZR.Admin.WebApi/Properties/launchSettings.json
 /ZR.Admin.WebApi/ZRAdmin.xml
 /ZR.Admin.WebApi/DataProtection
 /Quartz.NET.WindowsService
-/ZRAdmin-vue
+/ZRAdmin-vue/node_modules/
+/ZRAdmin-vue/.DS_Store
+/ZRAdmin-vue/dist/
+/ZRAdmin-vue/npm-debug.log*
+/ZRAdmin-vue/yarn-debug.log*
+/ZRAdmin-vue/yarn-error.log*
+/ZRAdmin-vue/**/*.log
+/ZRAdmin-vue/tests/**/coverage/
+/ZRAdmin-vue/tests/e2e/reports
+/ZRAdmin-vue/selenium-debug.log
+/ZRAdmin-vue/.idea
+/ZRAdmin-vue/*.suo
+/ZRAdmin-vue/*.ntvs*
+/ZRAdmin-vue/*.njsproj
+/ZRAdmin-vue/*.sln
+/ZRAdmin-vue/*.local
+/ZRAdmin-vue/package-lock.json
+/ZRAdmin-vue/deploy.js
 /ZR.Admin.WebApi/ZRModel.xml
+ZRAdmin-vue/dist.zip
+**/.vshistory/

Infrastructure/ZR.Infrastructure.csproj

@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 	</PropertyGroup>
 	<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
 		<NoWarn>8632</NoWarn>

ZR.Admin.Grpc/Protos/FileTransfer.proto

@@ -0,0 +1,54 @@
+syntax = "proto3";
+
+option csharp_namespace = "ZR.Admin.Grpc";
+
+package filetransfer;
+
+service FileTransfer {
+  rpc InitUpload (InitUploadRequest) returns (InitUploadResponse);
+  rpc UploadChunk (stream UploadChunkRequest) returns (UploadChunkResponse);
+  rpc CompleteUpload (CompleteUploadRequest) returns (CompleteUploadResponse);
+  rpc CheckUploadStatus (CheckUploadStatusRequest) returns (CheckUploadStatusResponse);
+}
+
+message InitUploadRequest {
+  string file_name = 1;
+  int64 file_size = 2;
+  string file_hash = 3;
+}
+
+message InitUploadResponse {
+  string session_id = 1;
+  int64 uploaded_bytes = 2;
+}
+
+message UploadChunkRequest {
+  string session_id = 1;
+  bytes chunk_data = 2;
+  int64 offset = 3;
+}
+
+message UploadChunkResponse {
+  int64 uploaded_bytes = 1;
+}
+
+message CompleteUploadRequest {
+  string session_id = 1;
+  string file_hash = 2;
+}
+
+message CompleteUploadResponse {
+  bool success = 1;
+  string message = 2;
+}
+
+message CheckUploadStatusRequest {
+  string file_name = 1;
+  string file_hash = 2;
+}
+
+message CheckUploadStatusResponse {
+  string session_id = 1;
+  int64 uploaded_bytes = 2;
+  bool exists = 3;
+}

ZR.Admin.Grpc/Protos/my_diary.proto

@@ -0,0 +1,35 @@
+syntax = "proto3";
+
+option csharp_namespace = "ZR.Admin.Grpc";
+
+package my.diary;
+
+import "google/protobuf/timestamp.proto";
+
+// The greeting service definition.
+service MyDiary {
+  // Sends a greeting
+  rpc Edit (EditRequest) returns (EditReply);
+  rpc Query (QueryRequest) returns (QueryReply);
+}
+
+// The request message containing the user's name.
+message EditRequest {
+  string content = 1;
+  int64 user_id = 2;
+  google.protobuf.Timestamp create_time = 3; // 字段名仍然建议使用 snake_case
+}
+
+// The response message containing the greetings.
+message EditReply {
+  string result_message  = 1;
+}
+
+message QueryRequest {
+  int64 user_id = 1;
+  google.protobuf.Timestamp create_time = 2;
+}
+
+message QueryReply {
+  string content  = 1;
+}

ZR.Admin.Grpc/Services/FileTransferService.cs

@@ -0,0 +1,109 @@
+using Grpc.Core;
+using ZR.Admin.Grpc;
+
+namespace GrpcService.Services
+{
+    public class FileTransferService : FileTransfer.FileTransferBase
+    {
+        private readonly string _storagePath = "Îļþ";
+        private readonly IUploadSessionManager _sessionManager;
+
+        public FileTransferService(IUploadSessionManager sessionManager)
+        {
+            Directory.CreateDirectory(_storagePath);
+            _sessionManager = sessionManager;
+        }
+
+        public override Task<InitUploadResponse> InitUpload(InitUploadRequest request, ServerCallContext context)
+        {
+            var sessionId = _sessionManager.CreateSession(request.FileName, request.FileSize, request.FileHash);
+            var uploadedBytes = _sessionManager.GetUploadedBytes(sessionId);
+
+            return Task.FromResult(new InitUploadResponse
+            {
+                SessionId = sessionId,
+                UploadedBytes = uploadedBytes
+            });
+        }
+
+        public override async Task<UploadChunkResponse> UploadChunk(IAsyncStreamReader<UploadChunkRequest> requestStream, ServerCallContext context)
+        {
+            UploadChunkRequest currentRequest = null;
+            var response = new UploadChunkResponse();
+
+            while (await requestStream.MoveNext())
+            {
+                currentRequest = requestStream.Current;
+                var session = _sessionManager.GetSession(currentRequest.SessionId);
+
+                if (session == null)
+                {
+                    throw new RpcException(new Status(StatusCode.NotFound, "Session not found"));
+                }
+
+                using (var fileStream = new FileStream(session.TempFilePath, FileMode.OpenOrCreate, FileAccess.Write))
+                {
+                    fileStream.Seek(currentRequest.Offset, SeekOrigin.Begin);
+                    await fileStream.WriteAsync(currentRequest.ChunkData.ToByteArray(), 0, currentRequest.ChunkData.Length);
+                }
+
+                _sessionManager.UpdateSessionProgress(currentRequest.SessionId, currentRequest.Offset + currentRequest.ChunkData.Length);
+                response.UploadedBytes = currentRequest.Offset + currentRequest.ChunkData.Length;
+            }
+
+            return response;
+        }
+
+        public override async Task<CompleteUploadResponse> CompleteUpload(CompleteUploadRequest request, ServerCallContext context)
+        {
+            var session = _sessionManager.GetSession(request.SessionId);
+            if (session == null)
+            {
+                return await Task.FromResult(new CompleteUploadResponse
+                {
+                    Success = false,
+                    Message = "Session not found"
+                });
+            }
+
+            // Verify file hash if needed
+            if (!string.IsNullOrEmpty(request.FileHash))
+            {
+                var actualHash = await FileHelper.GetQuickFileIdentity(session.TempFilePath);
+                if (actualHash != request.FileHash)
+                {
+                    return await Task.FromResult(new CompleteUploadResponse
+                    {
+                        Success = false,
+                        Message = "File hash mismatch"
+                    });
+                }
+            }
+
+            // Move temp file to final location
+            var finalPath = Path.Combine(_storagePath, session.FileName);
+            //var finalPath = FileHelper.GetUniqueFilePath(_storagePath, session.FileName);
+            File.Move(session.TempFilePath, finalPath, true);
+
+            _sessionManager.CompleteSession(request.SessionId);
+
+            return await Task.FromResult(new CompleteUploadResponse
+            {
+                Success = true,
+                Message = "File uploaded successfully"
+            });
+        }
+
+        public override Task<CheckUploadStatusResponse> CheckUploadStatus(CheckUploadStatusRequest request, ServerCallContext context)
+        {
+            var session = _sessionManager.FindSession(request.FileName, request.FileHash);
+
+            return Task.FromResult(new CheckUploadStatusResponse
+            {
+                SessionId = session?.SessionId ?? "",
+                UploadedBytes = session?.UploadedBytes ?? 0,
+                Exists = session != null
+            });
+        }
+    }
+}

ZR.Admin.Grpc/Services/GreeterService.cs

@@ -0,0 +1,37 @@
+using Grpc.Core;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ZR.Admin.Grpc.Services
+{
+    public class GreeterService : Greeter.GreeterBase
+    {
+        private readonly ILogger<GreeterService> _logger;
+
+        public GreeterService(ILogger<GreeterService> logger)
+        {
+            _logger = logger;
+        }
+
+        // 实现 SayHello 方法
+        // 第一个参数是请求消息 (HelloRequest)
+        // 第二个参数是服务器上下文 (ServerCallContext)，提供关于当前调用的信息
+        public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
+        {
+            _logger.LogInformation($"接收到来自 {request.Name} 的请求");
+
+            // 构建并返回回复消息
+            var reply = new HelloReply
+            {
+                Message = $"你好，{request.Name} 来自 gRPC 服务器！"
+            };
+
+            // 返回一个 Task<HelloReply>
+            return Task.FromResult(reply);
+        }
+    }
+}

ZR.Admin.Grpc/Services/MyDiaryService.cs

@@ -0,0 +1,76 @@
+using Grpc.Core;
+using Microsoft.Extensions.Logging;
+using ZR.Service.IService;
+
+namespace ZR.Admin.Grpc.Services
+{
+    public class MyDiaryService(ILogger<MyDiaryService> logger, IMyDiaryService myDiaryService) : MyDiary.MyDiaryBase
+    {
+        public override async Task<EditReply> Edit(EditRequest request, ServerCallContext context)
+        {
+            logger.LogInformation($"接收到来自 {request.UserId} 的请求");
+
+            var myDiary = new Model.MyDiary()
+            {
+                Content = request.Content,
+                CreateTime = request.CreateTime.ToDateTime().ToLocalTime(),
+                UserId = request.UserId
+            };
+
+            var myDiaryToday = await myDiaryService.Queryable()
+                .Where(it => it.CreateTime.Date == myDiary.CreateTime.Date && it.UserId == myDiary.UserId)
+                .FirstAsync();
+            if (myDiaryToday != null)
+            {
+                myDiaryToday.Content = myDiary.Content;
+                await myDiaryService.Updateable(myDiaryToday)
+                    .ExecuteCommandAsync();
+            }
+            else
+            {
+                await myDiaryService.Insertable(myDiary).ExecuteReturnSnowflakeIdAsync();
+            }
+
+                
+
+            // 构建并返回回复消息
+            var reply = new EditReply()
+            {
+                ResultMessage = $"日记已记录 来自 gRPC 服务器！"
+            };
+
+            logger.LogInformation($"日记已记录");
+
+            // 返回一个 Task<HelloReply>
+            return reply;
+        }
+
+        public override async Task<QueryReply> Query(QueryRequest request, ServerCallContext context)
+        {
+            logger.LogInformation($"接收到来自 {request.UserId} 的请求");
+
+            var myDiary = new Model.MyDiary()
+            {
+                CreateTime = request.CreateTime.ToDateTime().ToLocalTime(),
+                UserId = request.UserId
+            };
+
+            var myDiaryToday = await myDiaryService.Queryable()
+                .Where(it => it.CreateTime.Date == myDiary.CreateTime.Date && it.UserId == myDiary.UserId)
+                .FirstAsync();
+
+            if (myDiaryToday != null)
+            {
+                myDiary.Content = myDiaryToday.Content;
+            }
+
+            // 构建并返回回复消息
+            var reply = new QueryReply()
+            {
+                Content = myDiary.Content ?? ""
+            };
+
+            return reply;
+        }
+    }
+}

ZR.Admin.Grpc/ZR.Admin.Grpc.csproj

@@ -1,14 +1,20 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
-        <TargetFramework>net7.0</TargetFramework>
+        <TargetFramework>net9.0</TargetFramework>
         <Nullable>enable</Nullable>
         <ImplicitUsings>enable</ImplicitUsings>
     </PropertyGroup>
 
+    <ItemGroup>
+      <Compile Remove="Services\FileTransferService.cs" />
+    </ItemGroup>
+
     <ItemGroup>
         <Protobuf Include="Protos\greet.proto" GrpcServices="Both" />
         <Protobuf Include="Protos\block.proto" GrpcServices="Client" />
+        <Protobuf Include="Protos\my_diary.proto" GrpcServices="Server" />
+        <Protobuf Include="Protos\FileTransfer.proto" GrpcServices="Server" />
     </ItemGroup>
 
     <ItemGroup>
@@ -16,7 +22,7 @@
     </ItemGroup>
 
     <ItemGroup>
-      <Folder Include="Services\" />
+      <ProjectReference Include="..\ZR.Service\ZR.Service.csproj" />
     </ItemGroup>
 
 </Project>

ZR.Admin.WebApi/Controllers/System/SysFileController.cs

@@ -1,3 +1,4 @@
+using NLog;
 using SqlSugar;
 using ZR.Admin.WebApi.Filters;
 using ZR.ServiceCore.Model;
@@ -24,6 +25,8 @@ namespace ZR.Admin.WebApi.Controllers
             _sysFileService = sysFileService;
         }
         
+        private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
+
         /// <summary>
         /// 查询文件存储列表
         /// </summary>
@@ -129,5 +132,44 @@ namespace ZR.Admin.WebApi.Controllers
                 return NoContent();
             }
         }
+        
+        /// <summary>
+        /// 通过文件ID下载文件
+        /// </summary>
+        /// <param name="fileId"></param>
+        /// <returns></returns>
+        [HttpGet("download/{fileId}")]
+        public IActionResult Download([FromRoute] long fileId)
+        {
+            var sysFile = _sysFileService.Queryable().Where(it => it.Id == fileId).First();
+            if (sysFile == null)
+            {
+                throw new CustomException("服务器上不存在此文件");
+            }
+
+            Stream? stream;
+            switch ((StoreType)Enum.Parse(typeof(StoreType), sysFile.StoreType.ToString() ?? string.Empty))
+            {
+                case StoreType.LOCAL:
+                    Logger.Info("本地存储");
+                    stream = sysFile.IsEncrypted == "1" ? _sysFileService.DecryptSysFileStream(sysFile.FileUrl) 
+                        : new FileStream(sysFile.FileUrl, FileMode.Open);
+                    break;
+                case StoreType.ALIYUN:
+                    stream = AliyunOssHelper.DownloadFile(sysFile.FileUrl, "", sysFile.IsEncrypted == "1");
+                    break;
+                default:
+                    throw new CustomException("不支持的存储类型");
+            }
+            if (stream != null)
+            {
+                return new FileStreamResult(stream, "application/octet-stream")
+                {
+                    FileDownloadName = sysFile.RealName
+                };
+            }
+
+            return NoContent();
+        }
     }
 }

ZR.Admin.WebApi/Program.cs

@@ -1,13 +1,15 @@
 using AspNetCoreRateLimit;
 using Infrastructure.Converter;
 using Microsoft.AspNetCore.DataProtection;
-using NLog.Web;
-using System.Text.Json;
+using Microsoft.AspNetCore.RateLimiting;
+using Microsoft.AspNetCore.Server.Kestrel.Core;
 using Microsoft.Extensions.Caching.Distributed;
 using Microsoft.Extensions.Caching.Redis;
 using Microsoft.Extensions.Options;
+using NLog.Web;
+using System.Text.Json;
 using ZR.Admin.Grpc;
-using ZR.Admin.Grpc.Extensions;
+using ZR.Admin.Grpc.Services;
 using ZR.Admin.WebApi.Extensions;
 using ZR.Infrastructure.Cache;
 using ZR.Infrastructure.WebExtensions;
@@ -70,7 +72,11 @@ if (openRedis == "1")
     builder.Services.AddSingleton<IDistributedCache>(new CSRedisCache(RedisHelper.Instance));
 }
 
-
+builder.Services.AddRateLimiter(o => o
+    .AddFixedWindowLimiter(policyName: "fixed", options =>
+    {
+        // configuration
+    }));
 
 builder.Services.AddMvc(options =>
 {
@@ -102,7 +108,19 @@ builder.Services.AddSwaggerConfig();
 // var blockClient = new Block.BlockClient(channel);
 // var blockReply = await blockClient.GetBlockAsync(new BlockRequest { In = "asads" });
 // Console.WriteLine("BlockReply: " + blockReply.Out);
-builder.Services.AddGrpcServiceConfiguration(builder.Configuration);
+//builder.Services.AddGrpcServiceConfiguration(builder.Configuration);
+
+// 配置 Kestrel 监听 HTTP/2 的非加密流量
+//builder.WebHost.ConfigureKestrel(options =>
+//{
+//    // 如果你只想监听一个端口，只保留其中一个 Listen
+//    options.ListenLocalhost(8888, o =>
+//    {
+//        o.Protocols = HttpProtocols.Http2; // 明确设置为 Http2
+//    });
+
+//});
+
 var app = builder.Build();
 InternalApp.ServiceProvider = app.Services;
 InternalApp.Configuration = builder.Configuration;
@@ -135,7 +153,7 @@ app.UseStaticFiles();
 //开启路由访问
 app.UseRouting();
 app.UseCors("Policy");//要放在app.UseEndpoints前。
-//app.UseHttpsRedirection();
+app.UseHttpsRedirection();
 
 app.UseAuthentication();
 app.UseAuthorization();
@@ -190,4 +208,7 @@ using (var serviceScope = app.Services.CreateScope())
     //Console.WriteLine(helloReply);
 }
 
+app.MapGrpcService<GreeterService>();
+app.MapGrpcService<MyDiaryService>();
+
 app.Run();

ZR.Admin.WebApi/Properties/launchSettings.json

@@ -13,7 +13,7 @@
         "commandName": "Project",
         "dotnetRunMessages": true,
         "launchUrl": "",
-      "applicationUrl": "http://localhost:8888",
+        "applicationUrl": "https://localhost:8888",
         "environmentVariables": {
             "ASPNETCORE_ENVIRONMENT": "Development"
         }

ZR.Admin.WebApi/ZR.Admin.WebApi.csproj

@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 		<Nullable>enable</Nullable>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<GenerateDocumentationFile>true</GenerateDocumentationFile>

ZR.Admin.WebApi/appsettings.Production.json

@@ -0,0 +1,20 @@
+{
+    "urls": "http://[*]:8888", //项目启动url，如果改动端口前端对应devServer也需要进行修改
+    "dbConfigs": [
+        {
+            "Conn": "server=8.140.174.251;user=admin;pwd=admin123;database=ZrAdmin",
+            "DbType": 0, //数据库类型 MySql = 0, SqlServer = 1, Oracle = 3，PgSql = 4
+            "ConfigId": "0", //多租户唯一标识
+            "IsAutoCloseConnection": true
+        }
+        //...下面添加更多的数据库源
+    ],
+    //redis服务配置
+    "RedisServer": {
+        "open": 1, //是否启用redis
+        "Cache": "8.140.174.251:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=cache:",
+        //    "Cache": "127.0.0.1:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=cache:",
+        "Session": "8.140.174.251:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=session:"
+        //    "Session": "127.0.0.1:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=session:"
+    },
+}

ZR.Admin.WebApi/appsettings.json

@@ -8,7 +8,7 @@
     },
     "dbConfigs": [
         {
-      "Conn": "server=8.140.174.251;user=admin;pwd=admin123;database=ZrAdmin;port=33060",
+            "Conn": "server=127.0.0.1;user=admin;pwd=admin123;database=ZrAdmin;port=3306",
             "DbType": 0, //数据库类型 MySql = 0, SqlServer = 1, Oracle = 3，PgSql = 4
             "ConfigId": "0", //多租户唯一标识
             "IsAutoCloseConnection": true
@@ -18,12 +18,12 @@
     //代码生成数据库配置
     "CodeGenDbConfig": {
         //代码生成连接字符串，注意{dbName}为固定格式，不要填写数据库名
-    "Conn": "Data Source=LAPTOP-STKF2M8H\\SQLEXPRESS;User ID=admin;Password=admin123;Initial Catalog={dbName};",
-    "DbType": 1,
+        "Conn": "Data Source=127.0.0.1;user=admin;pwd=admin123;database=ZrAdmin;port=3306",
+        "DbType": 0,
         "IsAutoCloseConnection": true,
         "DbName": "ZrAdmin" //代码生成默认连接数据库,Oracle库是实例的名称
     },
-  "urls": "http://localhost:8888", //项目启动url，如果改动端口前端对应devServer也需要进行修改
+    "urls": "https://localhost:8888", //项目启动url，如果改动端口前端对应devServer也需要进行修改
     "corsUrls": [ "http://localhost:8887", "http://localhost:8886" ], //跨域地址（前端启动项目，前后端分离单独部署需要设置），多个用","隔开
     "JwtSettings": {
         "Issuer": "ZRAdmin.NET", //即token的签发者。
@@ -102,10 +102,8 @@
     //redis服务配置
     "RedisServer": {
         "open": 1, //是否启用redis
-    "Cache": "8.140.174.251:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=cache:",
-//    "Cache": "127.0.0.1:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=cache:",
-    "Session": "8.140.174.251:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=session:"
-//    "Session": "127.0.0.1:6379,password=Wyd210213,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=session:"
+        "Cache": "127.0.0.1:6379,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=cache:",
+        "Session": "127.0.0.1:6379,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=session:"
     },
     //验证码配置
     "CaptchaOptions": {

ZR.CodeGenerator/ZR.CodeGenerator.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 	</PropertyGroup>
 
 	<ItemGroup>

ZR.Common/ZR.Common.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 	</PropertyGroup>
 
 	<ItemGroup>

ZR.Model/MyDiary.cs

@@ -0,0 +1,23 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ZR.Model
+{
+    [SugarTable("my_diary")]
+    public class MyDiary
+    {
+        [SugarColumn(IsPrimaryKey = true)]
+        [JsonConverter(typeof(ValueToStringConverter))]
+        public long Id { get; set; }
+
+        public string Content { get; set; }
+
+        [JsonConverter(typeof(ValueToStringConverter))]
+        public long UserId { get; set; }
+
+        public DateTime CreateTime { get; set; }
+    }
+}

ZR.Model/ZR.Model.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 		<GenerateDocumentationFile>true</GenerateDocumentationFile>
 		<NoWarn>1701;1702;1591;1570</NoWarn>
 	</PropertyGroup>

ZR.Repository/ZR.Repository.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 	</PropertyGroup>
 
 	<ItemGroup>

ZR.Service/IService/IMyDiaryService.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using ZR.Model;
+
+namespace ZR.Service.IService
+{
+    public interface IMyDiaryService : IBaseService<MyDiary>
+    {
+
+    }
+}

ZR.Service/MyDiaryService.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using ZR.Model;
+using ZR.Service.IService;
+
+namespace ZR.Service
+{
+    [AppService(ServiceType = typeof(IMyDiaryService), ServiceLifetime = LifeTime.Transient)]
+    public class MyDiaryService : BaseService<MyDiary>, IMyDiaryService
+    {
+    }
+}

ZR.Service/ZR.Service.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<GenerateDocumentationFile>true</GenerateDocumentationFile>
 	</PropertyGroup>

ZR.ServiceCore/Services/SysUserService.cs

@@ -76,7 +76,7 @@ namespace ZR.Service
         /// <returns></returns>
         public SysUser SelectUserById(long userId)
         {
-            var user = Queryable().Filter(null, true).WithCache(60 * 5)
+            var user = Queryable().Filter(null, true)
                 .Where(f => f.UserId == userId).First();
             if (user != null && user.UserId > 0)
             {

ZR.ServiceCore/ZR.ServiceCore.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFramework>net7.0</TargetFramework>
+		<TargetFramework>net9.0</TargetFramework>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<GenerateDocumentationFile>true</GenerateDocumentationFile>
 		<NoWarn>1701;1702;1591;1570</NoWarn>

ZR.Tasks/ZR.Tasks.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net7.0</TargetFramework>
+    <TargetFramework>net9.0</TargetFramework>
   </PropertyGroup>
 
   <ItemGroup>