From 80f2ca2df62ff1cd03046864af504245be078eb2 Mon Sep 17 00:00:00 2001
From: wjc <1243177876@qq.com>
Date: 星期四, 05 六月 2025 10:37:28 +0800
Subject: [PATCH] 2025年06月05日10:37:26

---
 app/src/main/java/com/hdl/photovoltaic/other/HdlOtaLogic.java |  362 ++++++++++++++++++++++++++++++---------------------
 1 files changed, 212 insertions(+), 150 deletions(-)

diff --git a/app/src/main/java/com/hdl/photovoltaic/other/HdlOtaLogic.java b/app/src/main/java/com/hdl/photovoltaic/other/HdlOtaLogic.java
index 77ed570..5df0ee2 100644
--- a/app/src/main/java/com/hdl/photovoltaic/other/HdlOtaLogic.java
+++ b/app/src/main/java/com/hdl/photovoltaic/other/HdlOtaLogic.java
@@ -1,14 +1,13 @@
 package com.hdl.photovoltaic.other;
 
-import android.content.ComponentName;
 import android.content.Context;
 import android.content.Intent;
 import android.content.ServiceConnection;
-import android.os.IBinder;
 import android.text.TextUtils;
 
 
 import com.google.gson.Gson;
+import com.google.gson.JsonArray;
 import com.google.gson.JsonObject;
 import com.google.gson.reflect.TypeToken;
 import com.hdl.linkpm.sdk.core.exception.HDLException;
@@ -16,9 +15,9 @@
 import com.hdl.linkpm.sdk.ota.bean.CloudDeviceFirmwaresBean;
 import com.hdl.linkpm.sdk.ota.bean.CloudGatewayDriversBean;
 import com.hdl.linkpm.sdk.ota.bean.DeviceFirmwareBean;
-import com.hdl.linkpm.sdk.ota.bean.DownloadUrlBean;
 import com.hdl.linkpm.sdk.ota.bean.GatewayDriverBean;
 import com.hdl.photovoltaic.HDLApp;
+import com.hdl.photovoltaic.R;
 import com.hdl.photovoltaic.config.UserConfigManage;
 import com.hdl.photovoltaic.internet.HttpClient;
 import com.hdl.photovoltaic.internet.HttpServer.MyNanoHttpServer;
@@ -29,22 +28,21 @@
 import com.hdl.photovoltaic.listener.CloudCallBeak;
 import com.hdl.photovoltaic.listener.LinkCallBack;
 import com.hdl.photovoltaic.utils.AesUtils;
-import com.hdl.photovoltaic.utils.AppManagerUtils;
 import com.hdl.photovoltaic.utils.Md5Utils;
+import com.hdl.photovoltaic.utils.NetworkUtils;
 import com.hdl.sdk.link.common.exception.HDLLinkException;
-import com.hdl.sdk.link.common.utils.ByteUtils;
+import com.hdl.sdk.link.core.bean.eventbus.BaseEventBus;
 import com.hdl.sdk.link.core.callback.HDLLinkCallBack;
+
+import org.apache.commons.io.FileUtils;
+import org.greenrobot.eventbus.EventBus;
 
 import java.io.File;
 import java.io.FileOutputStream;
-import java.io.IOException;
 import java.io.InputStream;
 import java.lang.reflect.Type;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.List;
-import java.util.Objects;
-import java.util.logging.FileHandler;
 
 import okhttp3.ResponseBody;
 
@@ -88,6 +86,16 @@
     private Intent intentServer = null;
 
     private ServiceConnection mServiceConnection = null;
+    /**
+     * 鏈嶅姟鏄惁寮�鍚� true=寮�鍚�
+     */
+    public boolean mServiceStart = false;
+
+    /**
+     * true琛ㄧず缁堟涓嬭浇鍗囩骇鏂囦欢(鐢ㄦ埛琛屼负)
+     */
+    private boolean stopDownload = false;
+
 
     //region -----鍥轰欢鍗囩骇---------
 
@@ -135,13 +143,19 @@
      * 鍓嶆彁鏉′欢:璁惧鑷姩涓婃姤oid淇℃伅缁欎簯绔�
      *
      * @param deviceOidId oid浜戠id
+     * @param oid         璁惧oid
+     * @param homeId      鐢电珯id
      * @param callBack    -
      */
-    public void getCurrentDeviceFirmwares(String deviceOidId, CloudCallBeak<List<DeviceFirmwareBean>> callBack) {
+    public void getCurrentDeviceFirmwares(String deviceOidId, String oid, String homeId, CloudCallBeak<List<DeviceFirmwareBean>> callBack) {
         String requestUrl = HttpApi.POST_OTA_GET_DeviceFirmwares;
         JsonObject json = new JsonObject();
-        json.addProperty("deviceOidId", deviceOidId);
-        json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
+        if (!TextUtils.isEmpty(deviceOidId)) {
+            json.addProperty("deviceOidId", deviceOidId);
+        } else {
+            json.addProperty("oid", oid);
+        }
+        json.addProperty("homeId", homeId);
         HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
             @Override
             public void onSuccess(String json) {
@@ -184,7 +198,7 @@
         JsonObject json = new JsonObject();
         json.addProperty("hardwareModel", hardwareModel);
         json.addProperty("osImageId", osImageId);
-        json.addProperty("protocolType", "ZIGBEE");//鍗忚绫诲瀷,鍙敤鍊�:BUSPRO,KNX,ZIGBEE,OTHER
+//        json.addProperty("protocolType", "ZIGBEE");//鍗忚绫诲瀷,鍙敤鍊�:BUSPRO,KNX,ZIGBEE,OTHER
         HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
             @Override
             public void onSuccess(String json) {
@@ -245,59 +259,6 @@
 
     }
 
-    /**
-     * 鍚戜簯绔幏鍙栥�愯澶囧浐浠躲�戝崌绾у寘涓嬭浇鍦板潃
-     *
-     * @param firmwareVersionId 鍥轰欢鐗堟湰Id
-     */
-    public void getDeviceFirmwareDownloadUrl(String firmwareVersionId, CloudCallBeak<DownloadUrlBean> callBack) {
-//        "protocolType":"bus",
-//                "deviceModel":"029B9988",
-//                "firmwareNameEn":"鏍稿績灞�",
-//                "firmwareNameCn":"鏍稿績灞�",
-//                "imageId":"12345678",
-//                "version":"V01.02.20"
-        String requestUrl = HttpApi.POST_OTA_GET_LinkDeviceFirmwareDownloadUrl;
-        JsonObject json = new JsonObject();
-        json.addProperty("firmwareVersionId", firmwareVersionId);
-        HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
-            @Override
-            public void onSuccess(String json) {
-
-                if (TextUtils.isEmpty(json)) {
-                    if (callBack != null) {
-                        callBack.onSuccess(new DownloadUrlBean());
-                    }
-                    return;
-                }
-                Gson gson = new Gson();
-                Type typeOfT = new TypeToken<DownloadUrlBean>() {
-                }.getType();
-                DownloadUrlBean downloadUrlBean = gson.fromJson(json, typeOfT);
-                if (callBack != null) {
-                    callBack.onSuccess(downloadUrlBean);
-                }
-            }
-
-            @Override
-            public void onFailure(HDLException e) {
-                if (callBack != null) {
-                    callBack.onFailure(e);
-                }
-            }
-        });
-    }
-
-    /**
-     * 鍚戜簯绔幏鍙栥�愯澶囧浐浠躲�戜笅杞藉崌绾ф枃浠�
-     *
-     * @param downloadUrl 浜戠鍥轰欢鍦板潃
-     */
-    public void getDeviceFirmwareDownloadFile(String downloadUrl, CloudCallBeak<DownloadUrlBean> callBack) {
-        String requestUrl = HttpApi.POST_OTA_GET_LinkDeviceFirmwareDownloadUrl;
-        JsonObject json = new JsonObject();
-
-    }
 
     //endregion
 
@@ -308,12 +269,13 @@
      * 鍓嶆彁鏉′欢:璁惧鑷姩涓婃姤oid淇℃伅缁欎簯绔�
      *
      * @param oid      缃戝叧璁惧oid
+     * @param homeId   鐢电珯id
      * @param callBack -
      */
-    public void getCurrentGatewayDrivers(String oid, CloudCallBeak<List<GatewayDriverBean>> callBack) {
+    public void getCurrentGatewayDrivers(String oid, String homeId, CloudCallBeak<List<GatewayDriverBean>> callBack) {
         String requestUrl = HttpApi.POST_OTA_GET_GatewayDrivers;
         JsonObject json = new JsonObject();
-        json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
+        json.addProperty("homeId", homeId);
         json.addProperty("oid", oid);
 
         HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
@@ -389,8 +351,9 @@
 
     }
 
+
     /**
-     * 浜戠鍙戣捣銆愯澶囬┍鍔ㄣ�戝崌绾TA鎸囦护
+     * 浜戠鍙戣捣銆愯澶囬┍鍔ㄥ崌绾с�慜TA鎸囦护
      *
      * @param oid             缃戝叧璁惧oid
      * @param driverVersionId 椹卞姩鐗堟湰id
@@ -419,49 +382,23 @@
         });
     }
 
+
+    //endregion
+
+
     /**
-     * 鍚戜簯绔幏鍙栥�愯澶囬┍鍔ㄣ�戝崌绾у寘涓嬭浇鍦板潃
-     *
-     * @param driverVersionId 椹卞姩鐗堟湰Id
+     * 鍙栨秷缁堟涓嬭浇鏂囦欢鎸囦护
      */
-    public void getDeviceDriverDownloadUrl(String driverVersionId, CloudCallBeak<DownloadUrlBean> callBack) {
-
-        String requestUrl = HttpApi.POST_OTA_GET_LinkDeviceDriverDownloadUrl;
-        JsonObject json = new JsonObject();
-        json.addProperty("driverVersionId", driverVersionId);
-        HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
-            @Override
-            public void onSuccess(String s) {
-                if (TextUtils.isEmpty(s)) {
-                    if (callBack != null) {
-                        callBack.onSuccess(new DownloadUrlBean());
-                    }
-                    return;
-                }
-                Gson gson = new Gson();
-                Type typeOfT = new TypeToken<DownloadUrlBean>() {
-                }.getType();
-                DownloadUrlBean downloadUrlBean = gson.fromJson(s, typeOfT);
-                if (callBack != null) {
-                    callBack.onSuccess(downloadUrlBean);
-                }
-            }
-
-            @Override
-            public void onFailure(HDLException e) {
-                if (callBack != null) {
-                    callBack.onFailure(e);
-                }
-            }
-        });
+    public void stopDownloadUpgradeFile() {
+        this.stopDownload = true;
     }
 
     /**
-     * 鍚戜簯绔幏鍙栥�愯澶囬┍鍔ㄣ�戜笅杞藉崌绾ф枃浠�
+     * 鍚戜簯绔幏鍙栥�愯澶囧崌绾ф枃浠�(椹卞姩,鍥轰欢)涓嬭浇銆戝崌绾ф枃浠�
      *
-     * @param downloadUrl 浜戠鍥轰欢鍦板潃
+     * @param downloadUrl 浜戠椹卞姩鍦板潃
      */
-    public void getDeviceDriverDownloadFile(String downloadUrl, CloudCallBeak<ResponseBody> callBack) {
+    public void getDeviceUpgradeDownloadFile(String downloadUrl, CloudCallBeak<ResponseBody> callBack) {
         HttpClient.getInstance().downLoadFile(downloadUrl, new CloudCallBeak<ResponseBody>() {
             @Override
             public void onSuccess(ResponseBody s) {
@@ -482,9 +419,6 @@
 
     }
 
-
-    //endregion
-
     /**
      * 鏈湴鍗囩骇鍖呮帹閫�(鍛婅瘔缃戝叧涓嬭浇鍗囩骇鍖呭湴鍧�绛変俊鎭�)
      *
@@ -499,6 +433,7 @@
      */
     public void pushUpgradePacketInfo(String mac, String oid, String module, String version, String size, String url, String sign_method, LinkCallBack<String> linkCallBack) {
         String requestUrl = TopicApi.SET_GATEWAY_UPGRADE_INFO;
+        JsonArray jsonArray = new JsonArray();
         JsonObject json = new JsonObject();
         json.addProperty("oid", oid);// 鐗╃悊璁惧oid
         json.addProperty("module", module);//妯″潡淇℃伅
@@ -506,8 +441,10 @@
 //        json.addProperty("is_diff", is_diff);//true=澧為噺鍖咃紝false=鍏ㄩ噺鍖�
         json.addProperty("size", size);//鍗囩骇鍖呭ぇ灏�
         json.addProperty("url", url);//鍗囩骇鍖呬笅杞藉湴鍧�
-        json.addProperty("sign_method", sign_method);//鍗囩骇鍖呯鍚嶇被鍨�:md5
-        TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, json, "", new HDLLinkCallBack() {
+        json.addProperty("sign", sign_method);//鍗囩骇鍖呯鍚嶇被鍨�:md5
+        json.addProperty("sign_method", "md5");//鍗囩骇鍖呯鍚嶇被鍨�:md5
+        jsonArray.add(json);
+        TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, jsonArray, "", new HDLLinkCallBack() {
             @Override
             public void onSuccess(String msg) {
                 if (linkCallBack != null) {
@@ -525,6 +462,43 @@
         });
     }
 
+    /**
+     * 鍙栨秷鍗囩骇椹卞姩,鍥轰欢鏂囦欢鎸囦护
+     *
+     * @param mac          璁惧mac
+     * @param linkCallBack 鍥炶皟update
+     */
+    public void cancelUpgrade(String mac, LinkCallBack<Boolean> linkCallBack) {
+        String requestUrl = TopicApi.SET_GATEWAY_REMOTE_EDIT;
+//        JsonObject json = new JsonObject();
+//        json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
+//        json.addProperty("server_addr", AppConfigManage.getUserRegionUrl());
+//        json.addProperty("local_secret", UserConfigManage.getInstance().getLocalSecret());
+//        //瑙e瘑璐熻浇鏁版嵁(鍐欏瘑閽ョ粰缃戝叧涓�瀹氭槸鏄庢枃锛屽洜涓洪偅鏃剁綉鍏宠繕娌℃湁瀵嗛挜)
+//        TcpClient.getInstance().sendDataToLinkGateway(mac, false, requestUrl, json, "", new HDLLinkCallBack() {
+//            @Override
+//            public void onSuccess(String msg) {
+//                GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(mac);
+//                if (gatewayBean != null) {
+//                    if (!TextUtils.isEmpty(UserConfigManage.getInstance().getLocalSecret())) {
+//                        gatewayBean.setLocalEncrypt(true);
+//                    }
+//                }
+//                if (linkCallBack != null) {
+//                    linkCallBack.onSuccess(true);
+//                }
+//
+//            }
+//
+//            @Override
+//            public void onError(HDLLinkException e) {
+//                if (linkCallBack != null) {
+//                    linkCallBack.onError(e);
+//                }
+//            }
+//        });
+    }
+
 
     /**
      * 鍚姩鏈湴鏈嶅姟
@@ -534,11 +508,12 @@
         //1,寤虹珛鏈湴鏈嶅姟锛�
         //2锛屽憡璇夌綉鍏虫墜鏈篿p鍜岀鍙o紱
         //瀹炰緥鍖� 鑾峰彇ip 鍦板潃
-        MyNanoHttpServer.getInstance(AppManagerUtils.getAppManager().getIPAddress(HDLApp.getInstance()));
+        MyNanoHttpServer.getInstance(NetworkUtils.getIPAddress(HDLApp.getInstance()));
         //MyNanoHttpServer.getInstance("127.0.0.1");
         intentServer = new Intent();
         intentServer.setClass(HDLApp.getInstance(), MyNanoHttpService.class);
         this.mServiceConnection = serviceConnection;
+        this.mServiceStart = true;
         //鍚姩鏈嶅姟鐩戝惉
         HDLApp.getInstance().bindService(intentServer, serviceConnection, Context.BIND_AUTO_CREATE);
     }
@@ -549,66 +524,153 @@
     public void unLocalService() {
         if (intentServer != null && this.mServiceConnection != null) {
             HDLApp.getInstance().unbindService(this.mServiceConnection);
+            this.mServiceStart = false;
         }
     }
+
 
     /**
      * 澶勭悊涓嬭浇鏂囦欢鏁版嵁
      *
-     * @param zipData 鏂囦欢鏁版嵁娴佸璞�
-     * @param md5     妫�楠屾枃浠禡D5鍊�
-     * @return 杩斿洖瑙e瘑鐨刡yte[]
+     * @param fileFullPath 鏂囦欢鍏ㄨ矾寰�
+     * @param zipData      鏂囦欢鏁版嵁娴佸璞�
+     * @param md5          妫�楠屾枃浠禡D5鍊�
+     * @param driver       椹卞姩鎴栬�呭浐浠�
+     * @return 鎴愬姛true
      */
-    public byte[] disposeDownLoadFile(ResponseBody zipData, String md5) {
+    public boolean disposeDownLoadFile(String fileFullPath, ResponseBody zipData, String md5, String driver) {
+        this.stopDownload = false;
+        //-100:娌℃湁鏁版嵁;-101:娌℃湁md5绉橀挜;-102:md5绉橀挜涓嶅;-103:鏈夊紓甯�;
         if (zipData == null) {
-            return null;
+            this.eventBusPost(fileFullPath, driver, -100, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_unable_to_pull_up_the_cloud_upgrade_file_data));
+            return false;
         }
         if (TextUtils.isEmpty(md5)) {
-            return null;
+            this.eventBusPost(fileFullPath, driver, -101, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_failed_to_obtain_the_md5_key_of_the_upgrade_file_on_the_cloud));
+            return false;
         }
         InputStream is = null;
-        List<Byte> byteList = new ArrayList<>();
-        byte[] decrypt = null;
+        byte[] buf = new byte[1204 * 4];
+        int len = 0;
+        FileOutputStream fos = null;
+        File file = null;
         try {
+            file = new File(fileFullPath);
             is = zipData.byteStream();
-            int total = (int) zipData.contentLength();
-            byte[] buf = new byte[1024*4];
+            long total = zipData.contentLength();
+            if (total == 0) {
+                this.eventBusPost(fileFullPath, driver, -102, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_unable_to_pull_up_the_cloud_upgrade_file_data));
+                return false;
+            }
+            fos = new FileOutputStream(file);
             long sum = 0;
-            int len = 0;
             while ((len = is.read(buf)) != -1) {
-                sum += len;
-                //todo 涓嬭浇涓紝鍙互鑷鍔犲叆杩涘害鏉�(鍙互骞挎挱鍑哄幓)
-                int progress = (int) (sum * 1.0f / total * 100);
-                for (int i = 0; i < len; i++) {
-                    byteList.add(buf[i]);
-                }
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        } finally {
-            try {
-                if (is != null) {
+                if (this.stopDownload) {
+                    this.eventBusPost(fileFullPath, driver, -108, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_the_user_cancels_downloading_the_upgrade_file));
+                    fos.flush();
+                    fos.close();
                     is.close();
+                    //todo 鐢ㄦ埛缁堟缁х画璇诲彇鏁版嵁;
+                    return false;
                 }
-                Byte[] sourceByte = byteList.toArray(new Byte[0]);
-                byte[] bytes = new byte[sourceByte.length];
-                for (int i = 0; i < sourceByte.length; i++) {
-                    bytes[i] = sourceByte[i];
+                fos.write(buf, 0, len);
+                sum += len;
+                //todo 涓嬭浇涓紝鍙互鑷繁璁$畻鐨勮繘搴︽潯(鍙互骞挎挱鍑哄幓)
+                int progress = (int) (100 * sum * 1.0f / total);
+                if (sum != total) {
+                    //涓嶇瓑浜�100閮借鎶�,绛変簬100澶勭悊鏁村潡閫昏緫瀹屼箣鍚庡啀鎶�100;
+                    this.eventBusPost(fileFullPath, driver, progress, "姝e父涓婃姤杩涘害鍊�---" + progress);
                 }
-                //涓嬭浇鏂囦欢闇�瑕佽В瀵嗕箣鍚庡啀杩涜md5鍘诲仛姣斿
-                decrypt = AesUtils.decrypt(bytes);
-                if (decrypt != null) {
-                    String fileMD5 = Md5Utils.encodeMD5(decrypt);
-                    if (TextUtils.isEmpty(fileMD5) || !Objects.equals(fileMD5, md5)) {
-                        //鏍¢獙澶辫触,缃┖
-                        decrypt = null;
-                    }
-                }
-            } catch (IOException ignored) {
-
             }
+            fos.flush();
+            fos.close();
+            is.close();
+            byte[] bytes = HdlFileLogic.getInstance().readFileByte(fileFullPath);
+//            byte[] bytes = FileUtils.readFileToByteArray(file);//杩欎釜鏂规硶涓嶅吋鐢╝ndroid 6.0
+            //todo 涓嬭浇鏂囦欢闇�瑕佽В瀵嗕箣鍚庡啀杩涜md5鍘诲仛姣斿
+            byte[] decrypt = AesUtils.decrypt(bytes);
+            if (decrypt == null) {
+                this.eventBusPost(fileFullPath, driver, -105, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_failed_to_decrypt_the_upgrade_aes_file));
+                return false;
+            }
+            String fileMD5 = Md5Utils.encodeMD5(decrypt);
+            if (TextUtils.isEmpty(fileMD5)) {
+                this.eventBusPost(fileFullPath, driver, -106, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_failed_to_generate_md5_for_the_upgrade_file));
+                return false;
+            }
+            if (!md5.equals(fileMD5)) {
+                this.eventBusPost(fileFullPath, driver, -107, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_description_failed_to_compare_the_md5_of_the_upgrade_file));
+                return false;
+            }
+            //todo 娉ㄦ剰:瑙e瘑涔嬪悗锛岃閲嶆柊鍐欐暟鎹�;
+            HdlFileLogic.getInstance().writeFile(fileFullPath, decrypt);
+//            FileUtils.writeByteArrayToFile(file, decrypt, false);//杩欎釜鏂规硶涓嶅吋鐢╝ndroid 6.0
+            this.eventBusPost(fileFullPath, driver, 100, HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_the_upgrade_file_is_downloaded));
+            return true;
+        } catch (Exception e) {
+            this.eventBusPost(fileFullPath, driver, -103, e.getMessage());
+            e.printStackTrace();
         }
-        return decrypt;
+        return false;
+    }
+
+
+    /**
+     * 鍙戝竷杩涘害涓婚
+     *
+     * @param type          椹卞姩:driver,鍥轰欢:firmware
+     * @param progressValue 杩涘害鍊�
+     * @param describe      鎻忚堪鏂囨湰
+     */
+    public void eventBusPost(String fileFullPath, String type, int progressValue, String describe) {
+
+
+        if (this.stopDownload) {
+//            HdlFileLogic.getInstance().deleteFile(fileFullPath);//鍒犻櫎涓嬭浇涓嶅畬鏁存暟鎹�;
+            //鍙栨秷涓嬭浇骞挎挱涓�娆�
+            BaseEventBus baseEventBus = new BaseEventBus();
+            baseEventBus.setTopic(localDownloadProgress);
+            Progress progress = new Progress();
+            progress.step = -108;
+            progress.describe = describe;
+            baseEventBus.setType(type);
+            baseEventBus.setData(progress);
+            EventBus.getDefault().post(baseEventBus);
+            return;
+        }
+//        HdlThreadLogic.runMainThread(new Runnable() {
+//            @Override
+//            public void run() {
+        BaseEventBus baseEventBus = new BaseEventBus();
+        baseEventBus.setTopic(localDownloadProgress);
+        Progress progress = new Progress();
+        progress.step = progressValue;
+        progress.describe = describe;
+        progress.type = type;
+        baseEventBus.setType(type);
+        baseEventBus.setData(progress);
+        EventBus.getDefault().post(baseEventBus);
+//            }
+//        });
+
+
+    }
+
+
+    //鑷畾涔変笂鎶ヤ笅杞介┍鍔ㄦ垨鍥轰欢杩涘害涓婚
+    public static final String localDownloadProgress = "cloud/download/progress/up";
+
+
+    public static final String driver_type = "driver";
+    public static final String firmware_type = "firmware";
+
+    public static class Progress {
+        //杩涘害鍊�
+        public int step;
+        //杩涘害鎻忚堪淇℃伅
+        public String describe;
+        //琛ㄧず鏄┍鍔紝鍥轰欢;
+        public String type;
     }
 
 

--
Gitblit v1.8.0