DBQueryJsonRequestHandler.cs 852 B

12345678910111213141516171819202122232425262728293031
  1. using System;
  2. using System.Collections.Generic;
  3. using ETModel;
  4. namespace ETHotfix
  5. {
  6. [MessageHandler(AppType.DB)]
  7. public class DBQueryJsonRequestHandler : AMRpcHandler<DBQueryJsonRequest, DBQueryJsonResponse>
  8. {
  9. protected override void Run(Session session, DBQueryJsonRequest message, Action<DBQueryJsonResponse> reply)
  10. {
  11. RunAsync(session, message, reply).Coroutine();
  12. }
  13. protected async ETVoid RunAsync(Session session, DBQueryJsonRequest message, Action<DBQueryJsonResponse> reply)
  14. {
  15. DBQueryJsonResponse response = new DBQueryJsonResponse();
  16. try
  17. {
  18. List<ComponentWithId> components = await Game.Scene.GetComponent<DBComponent>().GetJson(message.CollectionName, message.Json);
  19. response.Components = components;
  20. reply(response);
  21. }
  22. catch (Exception e)
  23. {
  24. ReplyError(response, e, reply);
  25. }
  26. }
  27. }
  28. }