DBSaveRequestHandler.cs 872 B

12345678910111213141516171819202122232425262728293031323334
  1. using System;
  2. using ETModel;
  3. namespace ETHotfix
  4. {
  5. [MessageHandler(AppType.DB)]
  6. public class DBSaveRequestHandler : AMRpcHandler<DBSaveRequest, DBSaveResponse>
  7. {
  8. protected override void Run(Session session, DBSaveRequest message, Action<DBSaveResponse> reply)
  9. {
  10. RunAsync(session, message, reply).NoAwait();
  11. }
  12. protected async ETVoid RunAsync(Session session, DBSaveRequest message, Action<DBSaveResponse> reply)
  13. {
  14. DBSaveResponse response = new DBSaveResponse();
  15. try
  16. {
  17. DBComponent dbComponent = Game.Scene.GetComponent<DBComponent>();
  18. if (string.IsNullOrEmpty(message.CollectionName))
  19. {
  20. message.CollectionName = message.Component.GetType().Name;
  21. }
  22. await dbComponent.Add(message.Component, message.CollectionName);
  23. reply(response);
  24. }
  25. catch (Exception e)
  26. {
  27. ReplyError(response, e, reply);
  28. }
  29. }
  30. }
  31. }