DBQueryJsonRequestHandler.cs 746 B

123456789101112131415161718192021222324252627
  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 async void Run(Session session, DBQueryJsonRequest message, Action<DBQueryJsonResponse> reply)
  10. {
  11. DBQueryJsonResponse response = new DBQueryJsonResponse();
  12. try
  13. {
  14. DBCacheComponent dbCacheComponent = Game.Scene.GetComponent<DBCacheComponent>();
  15. List<ComponentWithId> components = await dbCacheComponent.GetJson(message.CollectionName, message.Json);
  16. response.Components = components;
  17. reply(response);
  18. }
  19. catch (Exception e)
  20. {
  21. ReplyError(response, e, reply);
  22. }
  23. }
  24. }
  25. }