DBQueryBatchRequestHandler.cs 822 B

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