G2M_CreateUnitHandler.cs 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. using System;
  2. using UnityEngine;
  3. namespace ET
  4. {
  5. [ActorMessageHandler]
  6. public class G2M_CreateUnitHandler : AMActorRpcHandler<Scene, G2M_CreateUnit, M2G_CreateUnit>
  7. {
  8. protected override async ETTask Run(Scene scene, G2M_CreateUnit request, M2G_CreateUnit response, Action reply)
  9. {
  10. UnitComponent unitComponent = scene.GetComponent<UnitComponent>();
  11. Unit unit = unitComponent.AddChildWithId<Unit, int>(IdGenerater.Instance.GenerateId(), 1001);
  12. unit.AddComponent<MoveComponent>();
  13. unit.AddComponent<PathfindingComponent, string>("solo");
  14. unit.Position = new Vector3(-10, 0, -10);
  15. NumericComponent numericComponent = unit.AddComponent<NumericComponent>();
  16. numericComponent.Set(NumericType.Speed, 6f); // 速度是6米每秒
  17. unit.AddComponent<MailBoxComponent>();
  18. await unit.AddLocation();
  19. unit.AddComponent<UnitGateComponent, long>(request.GateSessionId);
  20. unitComponent.Add(unit);
  21. response.UnitId = unit.Id;
  22. // 把自己广播给周围的人
  23. M2C_CreateUnits createUnits = new M2C_CreateUnits();
  24. createUnits.Units.Add(UnitHelper.CreateUnitInfo(unit));
  25. MessageHelper.Broadcast(unit, createUnits);
  26. // 把周围的人通知给自己
  27. createUnits.Units.Clear();
  28. Unit[] units = scene.GetComponent<UnitComponent>().GetAll();
  29. foreach (Unit u in units)
  30. {
  31. createUnits.Units.Add(UnitHelper.CreateUnitInfo(u));
  32. }
  33. MessageHelper.SendActor(unit.GetComponent<UnitGateComponent>().GateSessionActorId, createUnits);
  34. reply();
  35. }
  36. }
  37. }