From 691dbe24f5724f153e07947c7b75bdfea5f0b6d5 Mon Sep 17 00:00:00 2001
From: wxr <wxr@hdlchina.com.cn>
Date: 星期二, 24 九月 2024 16:15:15 +0800
Subject: [PATCH] 离线控制模式

---
 HDL_ON/DAL/Mqtt/MqttClient.cs |   54 ++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 38 insertions(+), 16 deletions(-)

diff --git a/HDL_ON/DAL/Mqtt/MqttClient.cs b/HDL_ON/DAL/Mqtt/MqttClient.cs
index 4353a7f..36272cc 100644
--- a/HDL_ON/DAL/Mqtt/MqttClient.cs
+++ b/HDL_ON/DAL/Mqtt/MqttClient.cs
@@ -13,6 +13,8 @@
 using HDL_ON.UI;
 using HDL_ON.DAL.Server;
 using HDL_ON;
+using Newtonsoft.Json;
+using System.Collections.Generic;
 
 namespace HDL_ON.DAL.Mqtt
 {
@@ -159,6 +161,7 @@
         public static void InitState()
         {
             IfNeedReadAllDeviceStatus = true;
+            Common.ApiUtlis.Ins.hadInternet = true;
             StartCloudMqtt();
         }
 
@@ -338,16 +341,22 @@
         public static async Task StartCloudMqtt()
         {
             //娌℃湁缃戠粶鐨勭姸鎬佷笅灏濊瘯涓�涓嬭繛鎺qtt 锛屽畨鍗撶殑缃戠粶鐘舵�佸彉鍖栫洃鍚湁寮傚父锛屼慨鏀瑰簳灞傞夯鐑�
-            if (MainPage.InternetStatus == 0 && MainPage.LinkHdlMqttCount > 1)
+            if (MainPage.InternetStatus == 0 && MainPage.LinkHdlMqttCount > 1 )
+            {
+                return;
+            }
+
+
+            if (!Common.ApiUtlis.Ins.hadInternet)
             {
                 return;
             }
             MainPage.LinkHdlMqttCount++;
 
-            if (!UserInfo.Current.IsLogin)
-            {
-                return;
-            }
+            //if (!UserInfo.Current.IsLogin)
+            //{
+            //    return;
+            //}
             if (DB_ResidenceData.Instance.CurrentRegion == null || DB_ResidenceData.Instance.CurrentRegion.id == null)
             {
                 return;
@@ -364,6 +373,26 @@
             await Task.Factory.StartNew((Func<Task>)(async () => {
                 try
                 {
+                    try
+                    {
+                        //澧炲姞3绉掍簯鏈嶅姟鍣ㄨ繛鎺ユ娴嬶紝杩炰笉涓婃湇鍔″櫒鐨勬椂鍊欎笉鍒锋柊鏁版嵁
+                        var dataList = new List<GlobalRegionListRes>();
+                        var requestJson = HttpUtil.GetSignRequestJson(new GetRegionListObj() { regionMark = HttpUtil.RegionMark });
+                        var revertObj = HttpUtil.RequestHttpsPost(NewAPI.API_POST_GlobalRegionList, requestJson, HttpUtil.GlobalRequestHttpsHost, "", 3);
+                        if (revertObj == null || revertObj.Code != StateCode.SUCCESS)
+                        {
+                            Common.ApiUtlis.Ins.hadInternet = false;
+                            return;
+                        }
+                        else
+                        {
+                            Common.ApiUtlis.Ins.hadInternet = true;
+                        }
+                    }
+                    catch
+                    {
+                    }
+
                     #region 鍒濆鍖栬繙绋婱qtt
                     RemoteMqttIsConnecting = true;
                     RemoteMqttClient = new MqttFactory().CreateMqttClient();
@@ -831,23 +860,18 @@
         /// </summary>
         static void ReceiveNotifySqueezeAsync(string mMes)
         {
-#if DEBUG
-            //return;
-#endif
             if (mMes == PushSignStr) return;//鏄嚜宸辩殑鐧诲綍鎺ㄩ�佷笉澶勭悊//鎴栬�呭綋鍓嶄笉鏄繙绋嬮摼鎺ョ姸鎬�
             //娴嬭瘯璐﹀彿锛屼笉鎸や笅绾�
             switch (UserInfo.Current.userMobileInfo)
             {
-                case "18316672920":
                 case "15626203746":
-                case "464027401@qq.com":
                     return;
             }
 
-            if (!UserInfo.Current.IsLogin)
-            {
-                return;
-            }
+            //if (!UserInfo.Current.IsLogin)
+            //{
+            //    return;
+            //}
 
             DisConnectRemoteMqttClient("鎸や笅绾�");
 
@@ -891,9 +915,7 @@
         static void SendPushSignOut()
         {
             byte[] message = Encoding.UTF8.GetBytes(PushSignStr);
-#if DEBUG
             MqttRemoteSend(message, 4);
-#endif
         }
 
         /// <summary>

--
Gitblit v1.8.0