This commit is contained in:
yulong 2024-02-28 09:26:47 +08:00
commit cdbc867b4b
10 changed files with 53 additions and 35 deletions

View File

@ -213,7 +213,8 @@ public class Microwaveweapon : MonoBehaviour
{
micdistance = Vector3.Distance(miceopos.position, transform.position);
var newdata = Getmicdata();
DeviceManager.Instance.send2roomStr.Enqueue(newdata);
//DeviceManager.Instance.send2roomStr.Enqueue(newdata);
MyNetMQClient.instance.Send(newdata);
//_ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", newdata));
//MQTTManager.instance.SendData(MQTTManager.instance.Micow, newdata);
microblog.MicrowaveDisplay(micdistance / 10 + 1, 0.5f);
@ -240,7 +241,8 @@ public class Microwaveweapon : MonoBehaviour
public IEnumerator Destructiondata(UnmannedAerialVehicle unmannedAerialVehicle)
{
var newdata = Aeroplane(unmannedAerialVehicle);
DeviceManager.Instance.send2roomStr.Enqueue(newdata);
MyNetMQClient.instance.Send(newdata);
//DeviceManager.Instance.send2roomStr.Enqueue(newdata);
//MQTTManager.instance.SendData(MQTTManager.instance.Planedata, newdata);
yield return new WaitForSeconds(0.5f);
GameObject game = Instantiate(Destructioneffect, unmannedAerialVehicle.transform);

View File

@ -203,7 +203,8 @@ public class Spectrumdetection : MonoBehaviour
public void SweepFrequencyBandTo()
{
string nowData = GetSyncDataThree();
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.SweepFrequencyBand, nowData);
}

View File

@ -261,7 +261,7 @@ public class View_Panel2 : XUIPanel
{
//Debug.Log("OnJoinRoom ViewPanel===" + msg);
//Debug.Log("订阅"+GlobalFlag.roomID);
//Debug.Log("订阅"+);
MyNetMQClient.instance._netMqListener.SubTopic(GlobalFlag.roomID);
SceneManager.LoadScene("AdamTraining_pilot_terminal_panl 1");
}

View File

@ -13,7 +13,7 @@ public class DeviceManager : MonoSingleton<DeviceManager>
/// <summary>
/// 发送消息
/// </summary>
public Queue<string> send2roomStr = new Queue<string>();
//public Queue<string> send2roomStr = new Queue<string>();
private bool _isStartRehearsing = false;
// 属性绑定布尔值,并在值变化时触发事件
@ -62,11 +62,12 @@ public class DeviceManager : MonoSingleton<DeviceManager>
public bool isOnlyOne = true;
private void Update()
{
if (send2roomStr.Count > 0 && isOnlyOne)
{
isOnlyOne = false;
StartCoroutine(DequeueSend2roomStr());
}
//if (send2roomStr.Count > 0 && isOnlyOne)
//{
// isOnlyOne = false;
// //StartCoroutine(DequeueSend2roomStr());
//}
#if UNITY_EDITOR
if (Input.GetKeyDown(KeyCode.Space))
{
@ -76,16 +77,16 @@ public class DeviceManager : MonoSingleton<DeviceManager>
#endif
}
IEnumerator DequeueSend2roomStr()
{
while (send2roomStr.Count > 0)
{
_ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", send2roomStr.Dequeue()));
yield return new WaitForSeconds(0.05f);
if (send2roomStr.Count == 0)
isOnlyOne = true;
}
}
//IEnumerator DequeueSend2roomStr()
//{
// while (send2roomStr.Count > 0)
// {
// _ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", send2roomStr.Dequeue()));
// yield return new WaitForSeconds(0.05f);
// if (send2roomStr.Count == 0)
// isOnlyOne = true;
// }
//}
public void AddDevice(EquipmentCommon d)
{

View File

@ -101,7 +101,8 @@ public class HighPriorityTarget : MonoBehaviour
int layerValue = LayerMask.NameToLayer(frequency);
gamepos.layer = layerValue;
string nowData = GetSyncDataTwo();
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.BandSetting, nowData);
}
}
@ -175,7 +176,8 @@ public class HighPriorityTarget : MonoBehaviour
HP -= 10;
string nowData = GetSyncDis(Pos);
Debug.Log("发送:" + nowData);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.KeyTarget, nowData);
}
else

View File

@ -282,8 +282,9 @@ public class LaserFireControlPlatformManger : MonoBehaviour
{
Debug.Log("角度合适进行打击");
var nowData = GetSyncData();
MyNetMQClient.instance.Send(nowData);
//_ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", nowData));
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.Lasing, nowData);
CastRayAndRender();
}
@ -340,7 +341,8 @@ public class LaserFireControlPlatformManger : MonoBehaviour
{
string nowData = GetSyncDis(unmannedAerialVehicle);
Debug.Log(nowData);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.DroneWasDestroyed, nowData);
string currentTime = System.DateTime.Now.ToString();
string _log = currentTime + " " + equipmentCommon.equipmentType + "(" + equipmentCommon.deviceID + ")" +

View File

@ -417,7 +417,8 @@ public class TerrestrialRadioInterferenceManger : MonoBehaviour
unmannedAerialVehicleManage.CheckSatellitePositioningFrequency(
InterferenceMode);
var nowData = GetSyncData(unmannedAerialVehicleManage);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.WRJExpel, nowData);
}
UnmannedAerialVehicle unmannedAerialVehicle = wrj.GetComponent<UnmannedAerialVehicle>();
@ -427,7 +428,8 @@ public class TerrestrialRadioInterferenceManger : MonoBehaviour
unmannedAerialVehicle.CheckSatellitePositioningFrequency(
InterferenceMode);
var nowData = GetSyncData(unmannedAerialVehicle);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.WRJDitch, nowData);
}
isDo = true;

View File

@ -115,9 +115,10 @@ public class UnmannedAerialVehicle : MonoBehaviour
if (isPassMessage)
{
string nowData = GetSyncDis();
MyNetMQClient.instance.Send(nowData);
//Debug.Log(nowData);
//_ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", nowData));
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.DroneWasDestroyed, nowData);
string currentTime = System.DateTime.Now.ToString();
string _log = currentTime + " " + unmannedAerialVehicleManage.equipmentCommon.equipmentType + "(" + unmannedAerialVehicleManage.equipmentCommon.deviceID + ")"
@ -144,9 +145,10 @@ public class UnmannedAerialVehicle : MonoBehaviour
if (_equipmentCommon)
{
string nowData = string.Format("{0},{1}", "SetToBeDestroyed", _equipmentCommon.deviceID);
MyNetMQClient.instance.Send(nowData);
//Debug.Log(nowData);
//_ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", nowData));
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.SetToBeDestroyed, nowData);
string currentTime = System.DateTime.Now.ToString();
string _log = currentTime + " " + unmannedAerialVehicleManage.equipmentCommon.equipmentType + "(" + unmannedAerialVehicleManage.equipmentCommon.deviceID + ")"
@ -263,8 +265,9 @@ public class UnmannedAerialVehicle : MonoBehaviour
{
string nowData = GetSyncData(attackTarget);
Debug.Log(nowData);
MyNetMQClient.instance.Send(nowData);
//_ = SyncCreateRoom.SendMessageAsync(string.Format("send2room {0}", nowData));
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.SingleDronePosition, nowData);
float distance = Vector3.Distance(transform.position, attackTarget.position);
transform.DOMove(attackTarget.position, distance / FireSpeed).SetEase(Ease.Linear).OnComplete(() =>

View File

@ -238,7 +238,8 @@ public class UnmannedAerialVehicleManage : MonoBehaviour
int layerValue = LayerMask.NameToLayer(dataLinkCommunicationFrequency);
gamePos.layer = layerValue;
string nowData = GetSyncDataTwo();
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.BandSetting, nowData);
}
}
@ -266,7 +267,8 @@ public class UnmannedAerialVehicleManage : MonoBehaviour
int layerValue = LayerMask.NameToLayer(electronicReconnaissanceCapability);
dzWRJCamera.cullingMask = 1 << layerValue;
string nowData = GetSyncDataThree();
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.SweepFrequencyBand, nowData);
}
}
@ -316,7 +318,8 @@ public class UnmannedAerialVehicleManage : MonoBehaviour
if (_unmannedAerialVehicle.Count == 0)
{
string nowData = string.Format("{0},{1}", "SetToBeDestroyed", equipmentCommon.deviceID);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.SetToBeDestroyed, nowData);
UploadLog(equipmentCommon.deviceID);
WWWForm headers = new WWWForm();
@ -500,7 +503,8 @@ public class UnmannedAerialVehicleManage : MonoBehaviour
{
string nowData = GetSyncData(attackTarget);
//MQTTManager.instance.SendData(MQTTManager.instance.SingleDronePosition, nowData);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
}
/// <summary>
/// 无人机攻击目标传递
@ -1089,7 +1093,8 @@ public class UnmannedAerialVehicleManage : MonoBehaviour
isMove = false;
Vector3 _positions = positions.Dequeue();
var nowData = GetSyncData(_positions);
DeviceManager.Instance.send2roomStr.Enqueue(nowData);
MyNetMQClient.instance.Send(nowData);
//DeviceManager.Instance.send2roomStr.Enqueue(nowData);
//MQTTManager.instance.SendData(MQTTManager.instance.DronePosition, nowData);
StartCoroutine(MoveObjectAlongPath(_positions)); // 启动协程,按规划的路线移动物体
}

View File

@ -60,7 +60,7 @@ public class MyNetMQClient : MonoBehaviour
/// <param name="msg"></param>
public void Send(string msg)
{
_netMqPublisher.AddMessageToSendQue("Room", 0, Encoding.UTF8.GetBytes(msg));
_netMqPublisher.AddMessageToSendQue(GlobalFlag.roomID, 0, Encoding.UTF8.GetBytes(msg));
}
private void Update()