JLChen
2020-08-12 b4bb337bdce4d09473a45610e09350056326c87a
Crabtree/SmartHome/HDL/Operation/Control.cs
@@ -394,41 +394,41 @@
                }
            }
            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>
        /// 当前数据包