wxr
2024-06-07 56da43f1e25a191cd83fb91c5756f19ef7431bb0
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
using System;
using Shared.SimpleControl.Phone;
 
namespace Shared.SimpleControl
{
    public class EquipmentPublicClass
    {
 
        static bool BSaveGateWay = true;
 
        public void AlertNotOnline ()
        {
            new Alert (Language.StringByID (R.MyInternationalizationString.Tip), Language.StringByID (R.MyInternationalizationString.TipEquipmentNotOnline), Language.StringByID (R.MyInternationalizationString.Close)).Show ();
        }
 
        static bool isConnectiong = false;
        static DateTime mFlagDateTime;
        //public static bool upLoadLink = true;
        /// <summary>
        /// 检测/连接远程
        /// </summary>
        public static void CheckLinkRemote (int status, bool IsReconnectRemote = true)
        {
 
            //20S后强制重置isConnectiong状态,防止isConnectiong一直为true状态
            if (mFlagDateTime.AddSeconds (20).Ticks <= System.DateTime.Now.Ticks) {
                mFlagDateTime = DateTime.Now;
                if (isConnectiong) {
                    Shared.Utlis.WriteLine ("20s》isConnectiong true ");
                    isConnectiong = false;
                }
            }
 
            if (isConnectiong) {
                return;
            }
            isConnectiong = true;
            UserConfig.Instance.internetStatus = status;
 
            if (MainPage.LoginUser == null || !MainPage.LoginUser.IsLogin) {
                isConnectiong = false;
                return;
            }
 
#if DEBUG
            Shared.Utlis.WriteLine ($"CheckLinkRemote: 开始");
#endif
 
            new System.Threading.Thread (async () => {
                bool IsRemoteLoadingShow = false;
                //Control.IsCanLocal = false;
                try {
                    if (status == 0) {
                        Utlis.ShowAppLinkStatus (AppLinkStatus.WiFiUnlink);
                        Application.RunOnMainThread (() => {
                            MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.InternetStatusTip));
                        });
                        if (CommonPage.IsRemote) {
                            SmartHome.MqttCommon.DisConnectRemote ("NO net", false);
                        }
                    } else {
 
                        #region 新方案
                        var mHomeGateway = UserConfig.Instance.HomeGateway;
                        //1.当前住宅云端还没绑定网关
                        if (mHomeGateway == null) {
                            Utlis.ShowAppLinkStatus (AppLinkStatus.WiFiOffline);
                            DisConnectRemoteAsync ();
                        }
 
                        //2.远程连接情况下,是否需要断开连接重连
                        if (IsReconnectRemote) {
                            if (CommonPage.IsRemote) {
                                CommonPage.IsRemote = false;
                                Utlis.ShowAppLinkStatus (AppLinkStatus.WiFiOffline);
                                SmartHome.MqttCommon.DisConnectRemote ("IsReconnectRemote");
                            }
                        }
 
                        bool canRemote = false;
                        if (CommonPage.IsRemote) {
                            SmartHome.MqttCommon.MqttRemoteSend (new byte [] { }, 3);
                        }
                        //当前住宅云端是否绑定网关,默认没有
                        bool HomeGatewaysExists = false;
                        SmartHome.MqttCommon.GatewayCommon = null;
                        if (mHomeGateway != null) {
                            //(1).当前住宅云端已经绑定网关
                            HomeGatewaysExists = true;
                            //(2).模拟生成一个网关对象
                            SmartHome.MqttCommon.GatewayCommon = new OnePortBus () {
                                SubnetID = (byte)mHomeGateway.subnetId,
                                DeviceID = (byte)mHomeGateway.deviceId,
                                MAC = mHomeGateway.mac,
                                Remote_IP1 = "115.29.251.24",
                                Remote_IP1_Prot = "9999",
                                Name = "OnePortBus",
                                obj1 = 1,
                            };
                            canRemote = true;
                            //(3).当前Wi-Fi连接,参试本地搜索网关
                            if (status == 2) {
                                //var result = Control.ControlBytesSendHasReturn (Command.ReadGateway, common.SubnetID, common.DeviceID, new byte [] { (byte)new Random ().Next (255), (byte)new Random ().Next (255) });
                                #region
                                //开始本地搜索网关...
                                //MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.SearchingGatewayLocally));
                                MainPage.LoadingStart (Language.StringByID (R.MyInternationalizationString.SearchingGatewayLocally));
 
                                UserConfig.Instance.IsLocalEncrypt = false;
                                var control = new Control ();
                                control.Send (new Target () {
                                    IPEndPoint = new System.Net.IPEndPoint (System.Net.IPAddress.Parse (new Net.NetWiFi ().BroadcastIpAddress.ToString ()), 6000),
                                    Command = Command.ReadGateway,
                                    SubnetID = SmartHome.MqttCommon.GatewayCommon.SubnetID,
                                    DeviceID = SmartHome.MqttCommon.GatewayCommon.DeviceID,
                                    AddData = new byte [] { (byte)new Random ().Next (255), (byte)new Random ().Next (255) },
                                }, SendCount.Three, true, true);
                                var result = control.UsefulBytes;
 
                                //优化一下,防止逻辑异常
                                if(result == null) {
                                    UserConfig.Instance.IsLocalEncrypt = true;
                                    control.Send (new Target () {
                                        IPEndPoint = new System.Net.IPEndPoint (System.Net.IPAddress.Parse (new Net.NetWiFi ().BroadcastIpAddress.ToString ()), 6000),
                                        Command = Command.ReadGateway,
                                        SubnetID = SmartHome.MqttCommon.GatewayCommon.SubnetID,
                                        DeviceID = SmartHome.MqttCommon.GatewayCommon.DeviceID,
                                        AddData = new byte [] { (byte)new Random ().Next (255), (byte)new Random ().Next (255) },
                                    }, SendCount.Three, true, true);
                                    result = control.UsefulBytes;
                                }
 
                                #endregion
                                if (result != null) {
                                    //没有配置通讯秘钥时,写入秘钥
                                    if (!string.IsNullOrEmpty (UserConfig.Instance.LocalEncryptKey) && !UserConfig.Instance.IsLocalEncrypt) {
                                        byte [] AseKeyBytes = UserConfig.Instance.GenerateLocalEncryptionKey ();
                                        byte [] sendBytes = new byte [17];
                                        sendBytes [0] =(byte)1 ; //0:不加密 1:加密
                                        Array.Copy (AseKeyBytes, 0, sendBytes, 1, 16);
                                        byte [] backBytes = Control.ControlBytesSendHasReturn (Command.SetGateWayLocalEncryption, SmartHome.MqttCommon.GatewayCommon.SubnetID, SmartHome.MqttCommon.GatewayCommon.DeviceID, sendBytes);
                                    }
 
 
                                    var mac0 = CommonPage.byteToHex16 (result [5]) + "." + CommonPage.byteToHex16 (result [6]) + "." + CommonPage.byteToHex16 (result [7]) + "." + CommonPage.byteToHex16 (result [8]) + "." + CommonPage.byteToHex16 (result [9]) + "." + CommonPage.byteToHex16 (result [10]) + "." + CommonPage.byteToHex16 (result [11]) + "." + CommonPage.byteToHex16 (result [12]);
                                    if (SmartHome.MqttCommon.GatewayCommon.MAC.Replace (".", "").Replace (":", "").ToUpper () == mac0.Replace (".", "").Replace (":", "").ToUpper ()) {
                                        //搜索成功,启用本地连接
                                        //Control.IsCanLocal = true;//本地搜索成功,允许本地通信
                                        canRemote = false;
                                        Shared.SimpleControl.CommonPage.IsRemote = false;
                                        Application.RunOnMainThread (() => {
                                            Utlis.ShowAppLinkStatus (AppLinkStatus.WiFi);
                                            MainPage.Loading.Hide ();
                                        });
                                        UserMiddle.ReadAllDeviceStatus ();
                                        await SmartHome.MqttCommon.DisConnectRemote ("WIFI", false);
                                        MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.SearchGatewaySuccess));
                                    }
                                } else {
                                    //搜索失败,启用远程连接
                                    MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.SearchGatewayFail));
                                }
                            }
                            //(3).本地搜索不到网关或者没连接Wi-Fi情况下,检测是否拥有当前住宅的远程权限
                            if (canRemote) {
                                if (!UserConfig.Instance.AllowRemoteControl) {
                                    //没有当前住宅的远程权限
                                    canRemote = false;
                                    MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.NoRemoteControlPermission));
                                }
                            }
                        }
 
                        //5.能远程
                        if (canRemote) {
                            if (!CommonPage.IsRemote) {
                                if (UserConfig.Instance.CheckHomeGatewaysNotEmpty ()) {
                                    if (!string.IsNullOrEmpty (UserConfig.Instance.GatewayMAC)) {
                                        // 5.1能远程,显示CloudUnlink状态,IsRemote设为true开始远程
                                        //MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.StartEnablingRmote));
                                        MainPage.LoadingTipShow (Language.StringByID (R.MyInternationalizationString.StartEnablingRmote));
                                        Utlis.ShowAppLinkStatus (AppLinkStatus.CloudUnlink);
                                        IsRemoteLoadingShow = true;
                                        CommonPage.IsRemote = true;
                                        SmartHome.MqttCommon.InitState ();
                                    }
                                }
                            }
 
                        } else {
                            //6.不能远程,如果之前远程模式则断开MQTT连接,显示为未连接
                            if (CommonPage.IsRemote) {
                                Utlis.ShowAppLinkStatus (AppLinkStatus.WiFiOffline);
                                CommonPage.IsRemote = false;
                                await SmartHome.MqttCommon.DisConnectRemote ("", false);
                            }
                            //本地不存在与当前住宅绑定网关的数据
                            if (!HomeGatewaysExists) {
                                Utlis.ShowAppLinkStatus (AppLinkStatus.WiFiOffline);
                            }
                        }
                    }
                    #endregion
                } catch (Exception ex) {
                    Shared.Utlis.WriteLine ("CheckLinkRemote : " + ex.ToString ());
                } finally {
                    isConnectiong = false;
                    //if (!IsRemoteLoadingShow) {
                    //    Application.RunOnMainThread (() => {
                    //        MainPage.Loading.Hide ();
                    //    });
                    //}
 
                    Application.RunOnMainThread (() => {
                        MainPage.Loading.Hide ();
#if DEBUG
                        //upLoadLink = true;
#endif
 
                        //平台迁移数据处理 wxr 2022-06-14 13:37:49
                        if ( !UserConfig.Instance.CurrentRegion.indiaIsAsyncDeviceMark) {
                            //upLoadLink = false;
                            MigrateBean bean = new MigrateBean ();
                            System.Threading.Tasks.Task.Run (() => {
                                try {
                                    //var dd = bean.GetTimerBackupBean ();
                                    //bean.TimerBakeupFileDetailedInformation (dd.id);
 
                                    Application.RunOnMainThread (() => {
                                        MainPage.Loading.Start (Language.StringByID (R.MyInternationalizationString.load));
                                    });
                                    //1.获取迁移备份
                                    var migrateBackup = bean.GetMigrateBackupBean ();
                                    if (migrateBackup != null) {
                                        //2.下载备份
                                        bean.UserBakeupFileDetailedInformation (migrateBackup.id);
                                    }
 
                                } catch {
                                } finally {
                                    Application.RunOnMainThread (() => {
                                        MainPage.Loading.Hide ();
                                    });
                                }
                            });
 
                        }
 
 
                    });
 
                    ////不是远程 并且本地搜索不到匹配的网关就提示禁止本地发送
                    //if (!CommonPage.IsRemote && !Control.IsCanLocal && status != 0) {
                    //    Application.RunOnMainThread (() => {
                    //        Utlis.ShowAppLinkStatus (AppLinkStatus.WiFiUnlink);
                    //        //无法本地通信。当前住宅云端没有绑定网关、或者当前住宅本地没有网关数据!
                    //        //MainPage.AddTip (Language.StringByID (R.MyInternationalizationString.DisableLocalCommunication));
                    //        //new Alert (Language.StringByID (R.MyInternationalizationString.Tip),
                    //        //    Language.StringByID (R.MyInternationalizationString.DisableLocalCommunication),
                    //        //    Language.StringByID (R.MyInternationalizationString.Close)).Show ();
                    //    });
                    //}
 
                    //在确定用户及住宅信息后,初始化基本信息,如:
                    var logBean = HDL_ON_Android.Aliyu.AliyuLogUtil.getLogBean;
 
                    logBean.setHomeId (UserConfig.Instance.CurrentRegion.Id);
                    logBean.setUserId (MainPage.LoginUser.ID);
                    logBean.setAppVersion (MainPage.RequestVersion);
#if DEBUG
                    Shared.Utlis.WriteLine ($"CheckLinkRemote: 结束");
#endif
                }
            }) { IsBackground = true }.Start ();
        }
 
        /// <summary>
        /// 关闭远程连接模式,并断开MQTT
        /// </summary>
        /// <returns></returns>
        static async System.Threading.Tasks.Task DisConnectRemoteAsync ()
        {
 
            if (CommonPage.IsRemote) {
                CommonPage.IsRemote = false;
                await SmartHome.MqttCommon.DisConnectRemote ();
            }
        }
    }
}