mirror of
https://github.com/oshima-studios/OshimaGameModule.git
synced 2026-03-05 22:20:28 +00:00
342 lines
15 KiB
C#
342 lines
15 KiB
C#
using Microsoft.AspNetCore.Builder;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using Milimoe.FunGame.Core.Api.Transmittal;
|
||
using Milimoe.FunGame.Core.Api.Utility;
|
||
using Milimoe.FunGame.Core.Entity;
|
||
using Milimoe.FunGame.Core.Interface;
|
||
using Milimoe.FunGame.Core.Interface.Base.Addons;
|
||
using Milimoe.FunGame.Core.Library.Common.Addon;
|
||
using Milimoe.FunGame.Core.Library.Common.Event;
|
||
using Milimoe.FunGame.Core.Library.Constant;
|
||
using Oshima.Core.Configs;
|
||
using Oshima.Core.Constant;
|
||
using Oshima.FunGame.OshimaModules.Characters;
|
||
using Oshima.FunGame.OshimaModules.Items;
|
||
using Oshima.FunGame.OshimaModules.Models;
|
||
using Oshima.FunGame.OshimaServers.Service;
|
||
using Oshima.FunGame.WebAPI.Constant;
|
||
using Oshima.FunGame.WebAPI.Controllers;
|
||
using Oshima.FunGame.WebAPI.Models;
|
||
using Oshima.FunGame.WebAPI.Services;
|
||
using ProjectRedbud.FunGame.SQLQueryExtension;
|
||
using TaskScheduler = Milimoe.FunGame.Core.Api.Utility.TaskScheduler;
|
||
|
||
namespace Oshima.FunGame.WebAPI
|
||
{
|
||
public class OshimaWebAPI : WebAPIPlugin, IHotReloadAware, ILoginEvent
|
||
{
|
||
public override string Name => OshimaGameModuleConstant.WebAPI;
|
||
|
||
public override string Description => OshimaGameModuleConstant.Description;
|
||
|
||
public override string Version => OshimaGameModuleConstant.Version;
|
||
|
||
public override string Author => OshimaGameModuleConstant.Author;
|
||
|
||
private IServiceScopeFactory? _serviceScopeFactory = null;
|
||
|
||
public override void ProcessInput(string input)
|
||
{
|
||
// RainBOT 测试
|
||
using (IServiceScope? scope = _serviceScopeFactory?.CreateScope())
|
||
{
|
||
if (scope != null)
|
||
{
|
||
// 从作用域中获取 IServiceProvider
|
||
IServiceProvider serviceProvider = scope.ServiceProvider;
|
||
|
||
try
|
||
{
|
||
if (input.Trim() != "")
|
||
{
|
||
// 获取 RainBOTService 实例
|
||
RainBOTService bot = serviceProvider.GetRequiredService<RainBOTService>();
|
||
ThirdPartyMessage message = new()
|
||
{
|
||
IsGroup = true,
|
||
GroupOpenId = "1",
|
||
AuthorOpenId = "1",
|
||
OpenId = "1",
|
||
Detail = input,
|
||
Id = "1",
|
||
Timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
||
};
|
||
OtherData data = new();
|
||
|
||
bool result = bot.HandlerByConsole(message, data).GetAwaiter().GetResult();
|
||
|
||
if (!result || message.IsCompleted)
|
||
{
|
||
Controller.WriteLine(message.Result);
|
||
}
|
||
}
|
||
|
||
if (input == "test")
|
||
{
|
||
//FunGameController funGameController = serviceProvider.GetRequiredService<FunGameController>();
|
||
//Controller.WriteLine(Controller.JSON.GetObject<string>(funGameController.ShowDailyStore(1)) ?? "test");
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
Controller.Error(e);
|
||
}
|
||
}
|
||
}
|
||
|
||
if (input == "testuser")
|
||
{
|
||
using SQLHelper? sql = Controller.GetSQLHelper();
|
||
if (sql != null)
|
||
{
|
||
try
|
||
{
|
||
sql.NewTransaction();
|
||
|
||
// 注册用户
|
||
sql.RegisterUser("un", "pw", "1@2.3", "");
|
||
User? user = sql.GetUserByUsernameAndPassword("un", "pw");
|
||
|
||
if (user != null)
|
||
{
|
||
Controller.WriteLine($"User found: ID = {user.Id}, Username = {user.Username}, Email = {user.Email}");
|
||
|
||
// 测试更新密码
|
||
string newPassword = "new_pw";
|
||
sql.UpdatePassword("un", newPassword);
|
||
User? updatedUser = sql.GetUserByUsernameAndPassword("un", newPassword);
|
||
|
||
if (updatedUser != null)
|
||
{
|
||
Controller.WriteLine($"Password updated successfully for user: {updatedUser.Username}");
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("Failed to update password.");
|
||
}
|
||
|
||
// 测试更新游戏时间
|
||
int gameTimeToAdd = 60; // 分钟
|
||
sql.UpdateGameTime("un", gameTimeToAdd);
|
||
User? gameTimeUser = sql.GetUserByUsernameAndPassword("un", newPassword); // 注意：密码已更新
|
||
|
||
if (gameTimeUser != null)
|
||
{
|
||
Controller.WriteLine($"Game time updated successfully. New game time: {gameTimeUser.GameTime} minutes");
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("Failed to update game time.");
|
||
}
|
||
|
||
// 测试加载库存
|
||
if (sql.LoadInventory(user))
|
||
{
|
||
Controller.WriteLine($"Inventory loaded successfully for user: {user.Username}");
|
||
Controller.WriteLine($"Inventory Name: {user.Inventory.Name}, Credits: {user.Inventory.Credits}, Materials: {user.Inventory.Materials}");
|
||
|
||
// 测试更新库存 Credits
|
||
double newCredits = 100.50;
|
||
sql.UpdateInventoryCredits(user.Id, newCredits);
|
||
sql.LoadInventory(user); // 重新加载库存
|
||
|
||
if (user.Inventory.Credits == (double)newCredits)
|
||
{
|
||
Controller.WriteLine($"Credits updated successfully. New credits: {user.Inventory.Credits}");
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("Failed to update credits.");
|
||
}
|
||
|
||
// 测试更新库存 Materials
|
||
double newMaterials = 50.75;
|
||
sql.UpdateInventoryMaterials(user.Id, newMaterials);
|
||
sql.LoadInventory(user); // 重新加载库存
|
||
|
||
if (user.Inventory.Materials == (double)newMaterials)
|
||
{
|
||
Controller.WriteLine($"Materials updated successfully. New materials: {user.Inventory.Materials}");
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("Failed to update materials.");
|
||
}
|
||
|
||
// 测试角色
|
||
Character character = new OshimaShiya();
|
||
user.Inventory.Characters.Add(character);
|
||
|
||
// 测试物品
|
||
Item item = new 攻击之爪25();
|
||
user.Inventory.Items.Add(item);
|
||
|
||
sql.UpdateInventory(user.Inventory); // 更新库存
|
||
|
||
sql.LoadInventory(user); // 重新加载库存
|
||
if (user.Inventory.Characters.Count > 0 && user.Inventory.Items.Count > 0)
|
||
{
|
||
Controller.WriteLine($"Characters and Items updated successfully.");
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("Failed to update characters and items.");
|
||
}
|
||
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("Failed to load inventory.");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("User not found");
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
Controller.Error(e);
|
||
}
|
||
finally
|
||
{
|
||
sql.Rollback();
|
||
Controller.WriteLine("Transaction rolled back in finally block.");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
Controller.WriteLine("SQLHelper is null.");
|
||
}
|
||
}
|
||
}
|
||
|
||
public override void AfterLoad(WebAPIPluginLoader loader, params object[] objs)
|
||
{
|
||
Statics.RunningPlugin = this;
|
||
FunGameService.WebAPIPluginLoader ??= loader;
|
||
Controller.NewSQLHelper();
|
||
Controller.NewMailSender();
|
||
if (objs.Length > 0 && objs[0] is WebApplicationBuilder builder)
|
||
{
|
||
builder.Services.AddScoped<QQBotService>();
|
||
builder.Services.AddScoped<RainBOTService>();
|
||
builder.Services.AddScoped<FunGameController>();
|
||
builder.Services.AddScoped<QQController>();
|
||
builder.Services.AddScoped<TestController>();
|
||
// 使用 Configure<BotConfig> 从配置源绑定
|
||
builder.Services.Configure<BotConfig>(builder.Configuration.GetSection("Bot"));
|
||
}
|
||
WebAPIAuthenticator.WebAPICustomBearerTokenAuthenticator += CustomBearerTokenAuthenticator;
|
||
FunGameConstant.InitFunGame();
|
||
FunGameSimulation.InitFunGameSimulation();
|
||
FunGameService.RefreshNotice();
|
||
TaskScheduler.Shared.AddTask("重置每日运势", new TimeSpan(0, 0, 0), () =>
|
||
{
|
||
Controller.WriteLine("已重置所有人的今日运势");
|
||
Daily.ClearDaily();
|
||
// 刷新活动缓存
|
||
FunGameService.GetEventCenter(null);
|
||
FunGameService.RefreshNotice();
|
||
FunGameService.PreRefreshStore();
|
||
});
|
||
TaskScheduler.Shared.AddTask("上九", new TimeSpan(9, 0, 0), () =>
|
||
{
|
||
Controller.WriteLine("重置物品交易冷却时间/刷新地区天气");
|
||
_ = FunGameService.AllowSellAndTrade();
|
||
_ = FunGameService.UpdateRegionWeather();
|
||
});
|
||
TaskScheduler.Shared.AddTask("下三", new TimeSpan(15, 0, 0), () =>
|
||
{
|
||
Controller.WriteLine("重置物品交易冷却时间/刷新地区天气");
|
||
_ = FunGameService.AllowSellAndTrade();
|
||
_ = FunGameService.UpdateRegionWeather();
|
||
});
|
||
TaskScheduler.Shared.AddRecurringTask("刷新存档缓存", TimeSpan.FromMinutes(1), () =>
|
||
{
|
||
FunGameService.RefreshSavedCache();
|
||
FunGameService.RefreshClubData();
|
||
Controller.WriteLine("读取 FunGame 存档缓存", LogLevel.Debug);
|
||
OnlineService.RoomsAutoDisband();
|
||
Controller.WriteLine("清除空闲房间", LogLevel.Debug);
|
||
}, true);
|
||
TaskScheduler.Shared.AddTask("刷新每日任务", new TimeSpan(4, 0, 0), () =>
|
||
{
|
||
// 刷新每日任务
|
||
Task.Run(() =>
|
||
{
|
||
FunGameService.RefreshDailyQuest();
|
||
Controller.WriteLine("刷新每日任务");
|
||
});
|
||
Task.Run(() =>
|
||
{
|
||
FunGameService.RefreshDailySignIn();
|
||
Controller.WriteLine("刷新签到");
|
||
});
|
||
Task.Run(() =>
|
||
{
|
||
FunGameService.RefreshStoreData();
|
||
Controller.WriteLine("刷新商店");
|
||
});
|
||
Task.Run(() =>
|
||
{
|
||
FunGameService.RefreshMarketData();
|
||
Controller.WriteLine("刷新市场");
|
||
});
|
||
// 刷新活动缓存
|
||
FunGameService.GetEventCenter(null);
|
||
FunGameService.RefreshNotice();
|
||
});
|
||
TaskScheduler.Shared.AddRecurringTask("刷新boss", TimeSpan.FromHours(1), () =>
|
||
{
|
||
FunGameService.GenerateBoss();
|
||
Controller.WriteLine("刷新boss");
|
||
}, true);
|
||
TaskScheduler.Shared.AddRecurringTask("刷新活动缓存", TimeSpan.FromHours(4), () =>
|
||
{
|
||
FunGameService.GetEventCenter(null);
|
||
Controller.WriteLine("刷新活动缓存");
|
||
}, true);
|
||
}
|
||
|
||
public void OnBeforeUnload()
|
||
{
|
||
TaskScheduler.Shared.RemoveTask("重置每日运势");
|
||
TaskScheduler.Shared.RemoveTask("上九");
|
||
TaskScheduler.Shared.RemoveTask("下三");
|
||
TaskScheduler.Shared.RemoveTask("刷新存档缓存");
|
||
TaskScheduler.Shared.RemoveTask("刷新每日任务");
|
||
TaskScheduler.Shared.RemoveTask("刷新boss");
|
||
TaskScheduler.Shared.RemoveTask("刷新活动缓存");
|
||
}
|
||
|
||
public override void OnWebAPIStarted(params object[] objs)
|
||
{
|
||
if (objs.Length > 0 && objs[0] is WebApplication app)
|
||
{
|
||
_serviceScopeFactory = app.Services.GetRequiredService<IServiceScopeFactory>();
|
||
if (_serviceScopeFactory != null) Controller.WriteLine("获取到：IServiceScopeFactory");
|
||
}
|
||
}
|
||
|
||
private string CustomBearerTokenAuthenticator(string token)
|
||
{
|
||
if (GeneralSettings.TokenList.Contains(token))
|
||
{
|
||
return "APIUser";
|
||
}
|
||
return "";
|
||
}
|
||
|
||
public void BeforeLoginEvent(object sender, LoginEventArgs e)
|
||
{
|
||
Controller.WriteLine(e.Password);
|
||
}
|
||
|
||
public void AfterLoginEvent(object sender, LoginEventArgs e)
|
||
{
|
||
|
||
}
|
||
}
|
||
}
|