| | |
| | | } |
| | | } |
| | | return; |
| | | if (Shared.SimpleControl.CommonPage.IsRemote && !isLocal) { |
| | | System.Console.WriteLine ("远程发送数据:" + SendFlag); |
| | | SmartHome.MqttCommon.MqttRemoteSend (Packet.Bytes); |
| | | Packet.FlagDateTime = DateTime.Now; |
| | | Packet.HaveSendCount--; |
| | | //这里是重发两次 |
| | | while (Packet.HaveSendCount < 3) { |
| | | if (Packet.FlagDateTime.AddMilliseconds (1000).Ticks <= System.DateTime.Now.Ticks) { |
| | | SmartHome.MqttCommon.MqttRemoteSend (Packet.Bytes); |
| | | System.Console.WriteLine ("重发远程发送数据:" + SendFlag); |
| | | Packet.FlagDateTime = DateTime.Now; |
| | | Packet.HaveSendCount++; |
| | | } |
| | | System.Threading.Thread.Sleep (100); |
| | | }
allDone.Set ();
} else { |
| | | try { |
| | | System.Console.WriteLine ("发送数据:" + SendFlag); |
| | | BusSocket.AsyncBeginSend (Packet); |
| | | Packet.HaveSendCount--; |
| | | //if (Shared.SimpleControl.CommonPage.IsRemote && !isLocal) { |
| | | // System.Console.WriteLine ("远程发送数据:" + SendFlag); |
| | | // SmartHome.MqttCommon.MqttRemoteSend (Packet.Bytes); |
| | | // Packet.FlagDateTime = DateTime.Now; |
| | | // Packet.HaveSendCount--; |
| | | // //这里是重发两次 |
| | | // while (Packet.HaveSendCount < 3) { |
| | | // if (Packet.FlagDateTime.AddMilliseconds (1000).Ticks <= System.DateTime.Now.Ticks) { |
| | | // SmartHome.MqttCommon.MqttRemoteSend (Packet.Bytes); |
| | | // System.Console.WriteLine ("重发远程发送数据:" + SendFlag); |
| | | // Packet.FlagDateTime = DateTime.Now; |
| | | // Packet.HaveSendCount++; |
| | | // } |
| | | // System.Threading.Thread.Sleep (100); |
| | | // }
// allDone.Set ();
//} else { |
| | | // try { |
| | | // System.Console.WriteLine ("发送数据:" + SendFlag); |
| | | // BusSocket.AsyncBeginSend (Packet); |
| | | // Packet.HaveSendCount--; |
| | | |
| | | //这里是重发两次 |
| | | while (Packet.HaveSendCount < 3) { |
| | | if (Packet.FlagDateTime.AddMilliseconds (1000).Ticks <= System.DateTime.Now.Ticks) { |
| | | System.Console.WriteLine ("重发数据:" + SendFlag); |
| | | BusSocket.AsyncBeginSend (Packet); |
| | | } |
| | | System.Threading.Thread.Sleep (100); |
| | | } |
| | | // //这里是重发两次 |
| | | // while (Packet.HaveSendCount < 3) { |
| | | // if (Packet.FlagDateTime.AddMilliseconds (1000).Ticks <= System.DateTime.Now.Ticks) { |
| | | // System.Console.WriteLine ("重发数据:" + SendFlag); |
| | | // BusSocket.AsyncBeginSend (Packet); |
| | | // } |
| | | // System.Threading.Thread.Sleep (100); |
| | | // } |
| | | |
| | | } catch (Exception ex) { |
| | | Console.WriteLine ("managerSendCount:" + ex.ToString ()); |
| | | } finally { |
| | | allDone.Set (); |
| | | } |
| | | } |
| | | // } catch (Exception ex) { |
| | | // Console.WriteLine ("managerSendCount:" + ex.ToString ()); |
| | | // } finally { |
| | | // allDone.Set (); |
| | | // } |
| | | //} |
| | | } |
| | | /// <summary> |
| | | /// 当前数据包 |