| 1234567891011121314151617181920212223242526272829303132 |
- using System;
- using System.Collections.Generic;
- using ETModel;
- namespace ETHotfix
- {
- [MessageHandler(AppType.DB)]
- public class DBQueryJsonRequestHandler : AMRpcHandler<DBQueryJsonRequest, DBQueryJsonResponse>
- {
- protected override void Run(Session session, DBQueryJsonRequest message, Action<DBQueryJsonResponse> reply)
- {
- RunAsync(session, message, reply).NoAwait();
- }
-
- protected async ETVoid RunAsync(Session session, DBQueryJsonRequest message, Action<DBQueryJsonResponse> reply)
- {
- DBQueryJsonResponse response = new DBQueryJsonResponse();
- try
- {
- DBCacheComponent dbCacheComponent = Game.Scene.GetComponent<DBCacheComponent>();
- List<ComponentWithId> components = await dbCacheComponent.GetJson(message.CollectionName, message.Json);
- response.Components = components;
- reply(response);
- }
- catch (Exception e)
- {
- ReplyError(response, e, reply);
- }
- }
- }
- }
|