黄学彪
2020-09-22 ade5917841b0fdcb1df7353ef7c56b1a1bdc9282
ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlDeviceUpdateLogic.cs
@@ -8,7 +8,7 @@
    /// <summary>
    /// HDL设备升级的逻辑
    /// </summary>
    public class HdlDeviceUpdateLogic
    public class HdlDeviceUpdateLogic : HdlDeviceUpdateCommonLogic
    {
        #region ■ 变量声明___________________________
@@ -19,6 +19,7 @@
        /// <para> 0:更新状态正常变化,后面的值为状态变更的文本翻译</para>
        /// <para> 1:升级成功</para>
        /// <para> 2:主动终止升级</para>
        /// <para> 3:从等待中取消(目前还没有用)</para>
        /// </summary>
        public Action<int, string> UpdateStatuChangedEvent = null;
        /// <summary>
@@ -26,17 +27,10 @@
        /// </summary>
        public Action<decimal> ProgressEvent = null;
        /// <summary>
        /// 当前执行的状态
        /// </summary>
        public UpdateStatuMode UpdateStatu = UpdateStatuMode.None;
        /// <summary>
        /// 设备新版本的固件信息(多个设备升级时,应该会需要公开这个对象)
        /// </summary>
        public FirmwareVersionInfo deviceFirmware = null;
        /// <summary>
        /// 升级是否完成(出现错误时,它也会变成true)
        /// </summary>
        public bool IsFinishUpdate = true;
        /// <summary>
        /// 网关
        /// </summary>
@@ -64,6 +58,7 @@
        /// <param name="i_deviceFirmware">设备的固件信息</param>
        public HdlDeviceUpdateLogic(OTADevice i_otaDevice, FirmwareVersionInfo i_deviceFirmware)
        {
            this.ClassDiv = 2;
            this.otaDevice = i_otaDevice;
            this.deviceFirmware = i_deviceFirmware;
            this.zbGateway = i_otaDevice.Gateway;
@@ -88,11 +83,13 @@
            if (this.UpdateStatu == UpdateStatuMode.Wait)
            {
                //如果是等待模式,再次点击时,移除列表
                if (FirmwareUpdateResourse.dicDeviceUpdateList.ContainsKey(otaDevice.DeviceAddr) == true)
                if (FirmwareUpdateResourse.dicUpdateList.ContainsKey(otaDevice.DeviceAddr) == true)
                {
                    FirmwareUpdateResourse.dicDeviceUpdateList.Remove(otaDevice.DeviceAddr);
                    FirmwareUpdateResourse.dicUpdateList.Remove(otaDevice.DeviceAddr);
                }
                //取消
                this.UpdateStatu = UpdateStatuMode.None;
                this.UpdateStatuChangedEvent?.Invoke(3, "");
                return;
            }
            //如果它有状态,则表示之前它被什么错误中断了
@@ -104,7 +101,7 @@
            //进入等待模式
            this.UpdateStatu = UpdateStatuMode.Wait;
            FirmwareUpdateResourse.dicDeviceUpdateList[otaDevice.DeviceAddr] = this;
            FirmwareUpdateResourse.dicUpdateList[otaDevice.DeviceAddr] = this;
            //等待中…
            this.UpdateStatuChangedEvent?.Invoke(0, Language.StringByID(R.MyInternationalizationString.uWaitting));
@@ -114,9 +111,9 @@
        }
        /// <summary>
        /// 开始执行更新操作
        /// 开始执行更新操作(FirmwareUpdateLogic调用)
        /// </summary>
        public void DoStartUpdate()
        public override void DoStartUpdate()
        {
            //状态变更
            this.IsFinishUpdate = false;
@@ -207,7 +204,7 @@
                return;
            }
            var tempZb = (ZbGateway)objValue;
            if (tempZb.CurrentGateWayId != HdlGatewayLogic.Current.GetGatewayId(this.zbGateway))
            if (tempZb.GwId != this.zbGateway.GwId)
            {
                //不是自己的网关推送,则不处理
                return;
@@ -366,7 +363,7 @@
                return;
            }
            var tempZb = (ZbGateway)objValue;
            if (tempZb.CurrentGateWayId != HdlGatewayLogic.Current.GetGatewayId(this.zbGateway))
            if (tempZb.GwId != this.zbGateway.GwId)
            {
                //不是自己的网关推送,则不处理
                return;
@@ -382,12 +379,11 @@
            {
                this.zbGateway.ReportAction -= this.UpdateDeviceProgress;
                new System.Threading.Thread(async () =>
                HdlThreadLogic.Current.RunThread(async () =>
                {
                    //终止升级
                    await this.otaDevice.KillUpdateAsync(this.zbGateway, 200);
                })
                { IsBackground = true }.Start();
                });
                this.UpdateStatu = UpdateStatuMode.DeviceUpdateFail;
                return;
@@ -416,7 +412,7 @@
        /// </summary>
        /// <param name="statusData"></param>
        /// <returns></returns>
        private bool CheckStatusCode(ZbGatewayData.OTAScheduleResponData statusData)
        private bool CheckStatusCode(CommonDevice.OTAScheduleResponData statusData)
        {
            if (statusData == null)
            {
@@ -503,7 +499,7 @@
            this.UpdateStatuChangedEvent?.Invoke(0, Language.StringByID(R.MyInternationalizationString.uDeviceUpdating));
            this.SetProgressValue(0);
            FirmwareUpdateResourse.dicDeviceUpdateList[otaDevice.DeviceAddr] = this;
            FirmwareUpdateResourse.dicUpdateList[otaDevice.DeviceAddr] = this;
            //同步进度
            this.zbGateway.ReportAction += UpdateDeviceProgress;
        }
@@ -556,7 +552,7 @@
            //升级成功
            this.UpdateStatu = UpdateStatuMode.UpdateSuccess;
            new System.Threading.Thread(() =>
            HdlThreadLogic.Current.RunThread(() =>
            {
                System.Threading.Thread.Sleep(3000);
@@ -578,22 +574,18 @@
                //移除事件
                HdlDeviceImageInfoLogic.Current.RemoveDeviceFirmwareVersionThread(otaDevice);
                Application.RunOnMainThread(() =>
                {
                    //设置进度值直接为100%
                    this.ProgressEvent?.Invoke(100);
                    //状态变更
                    this.IsFinishUpdate = true;
                    //升级完成
                    this.UpdateStatu = UpdateStatuMode.UpdateFinish;
                //设置进度值直接为100%
                this.ProgressEvent?.Invoke(100);
                //状态变更
                this.IsFinishUpdate = true;
                //升级完成
                this.UpdateStatu = UpdateStatuMode.UpdateFinish;
                    HdlFirmwareUpdateLogic.DoUpdateNextFirmware();
                HdlFirmwareUpdateLogic.DoUpdateNextFirmware();
                    //设备升级成功!
                    this.UpdateStatuChangedEvent?.Invoke(1, Language.StringByID(R.MyInternationalizationString.uDeviceUpdateSuccess));
                });
            })
            { IsBackground = true }.Start();
                //设备升级成功!
                this.UpdateStatuChangedEvent?.Invoke(1, Language.StringByID(R.MyInternationalizationString.uDeviceUpdateSuccess));
            });
        }
        #endregion
@@ -636,7 +628,7 @@
        private void StartDownLoadTimeOutThread()
        {
            this.downLoadTimeOutCount = 30;
            new System.Threading.Thread(() =>
            HdlThreadLogic.Current.RunThread(() =>
            {
                while (true)
                {
@@ -665,8 +657,7 @@
                        break;
                    }
                }
            })
            { IsBackground = true }.Start();
            });
        }
        /// <summary>
@@ -691,7 +682,7 @@
        private void StartUpdateTimeOutThread()
        {
            this.UpdateTimeOutCount = 60;
            new System.Threading.Thread(() =>
            HdlThreadLogic.Current.RunThread(() =>
            {
                while (true)
                {
@@ -719,8 +710,7 @@
                        break;
                    }
                }
            })
            { IsBackground = true }.Start();
            });
        }
        /// <summary>
@@ -738,7 +728,7 @@
        /// <summary>
        /// 释放缓存
        /// </summary>
        public void Dispose()
        public override void Dispose()
        {
            this.ProgressEvent = null;
            this.UpdateStatuChangedEvent = null;