Start migration to asp .net core + entity framework core

2023-02-08 21:33:22 +08:00
parent aea09c2c8b
commit f7761f200f
56 changed files with 2798 additions and 0 deletions
@@ -0,0 +1,48 @@
+using System.Text;
+using Application.Interfaces;
+using MediatR;
+
+namespace Application.Game.Server;
+
+public record GetDataQuery(string Host) : IRequest<string>;
+
+public class GetDataQueryHandler : IRequestHandler<GetDataQuery, string>
+{
+    private readonly IEventManagerService eventManagerService;
+
+    public GetDataQueryHandler(IEventManagerService eventManagerService)
+    {
+        this.eventManagerService = eventManagerService;
+    }
+
+    public Task<string> Handle(GetDataQuery request, CancellationToken cancellationToken)
+    {
+        var response = "count=0\n" +
+                       "nexttime=0\n";
+        if (!eventManagerService.UseEvents())
+        {
+            return Task.FromResult(response);
+        }
+
+        var host = request.Host;
+        var urlBase = $"http://{host}/events/";
+        var dataString = new StringBuilder();
+        var events = eventManagerService.GetEvents();
+        var count = 0;
+        foreach (var pair in events.Select((@event, i) => new {Value = @event, Index = i}))
+        {
+            var value = pair.Value;
+            var index = pair.Index;
+            var fileUrl = $"{urlBase}{value.Name}";
+            var eventString = $"{index},{fileUrl},{value.NotBefore},{value.NotAfter},{value.Md5},{value.Index}";
+            dataString.Append(eventString).Append('\n');
+            count++;
+        }
+
+        response = $"count={count}\n" +
+                   "nexttime=1\n" +
+                   $"{dataString}";
+
+        return Task.FromResult(response);
+    }
+}