G2M_CreateUnitHandler.cs 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  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. Unit unit = EntityFactory.CreateWithId<Unit, int>(scene, IdGenerater.Instance.GenerateId(), 1001);
  11. unit.AddComponent<MoveComponent>();
  12. unit.Position = new Vector3(-10, 0, -10);
  13. NumericComponent numericComponent = unit.AddComponent<NumericComponent>();
  14. numericComponent.Set(NumericType.Speed, 6f); // 速度是6米每秒
  15. unit.AddComponent<MailBoxComponent>();
  16. await unit.AddLocation();
  17. unit.AddComponent<UnitGateComponent, long>(request.GateSessionId);
  18. scene.GetComponent<UnitComponent>().Add(unit);
  19. response.UnitId = unit.Id;
  20. // 把自己广播给周围的人
  21. M2C_CreateUnits createUnits = new M2C_CreateUnits();
  22. createUnits.Units.Add(UnitHelper.CreateUnitInfo(unit));
  23. MessageHelper.Broadcast(unit, createUnits);
  24. // 把周围的人通知给自己
  25. createUnits.Units.Clear();
  26. Unit[] units = scene.GetComponent<UnitComponent>().GetAll();
  27. foreach (Unit u in units)
  28. {
  29. createUnits.Units.Add(UnitHelper.CreateUnitInfo(u));
  30. }
  31. MessageHelper.SendActor(unit.GetComponent<UnitGateComponent>().GateSessionActorId, createUnits);
  32. reply();
  33. }
  34. }
  35. }