diff --git a/README.md b/README.md
index a6dcec8..2c1df23 100644
--- a/README.md
+++ b/README.md
@@ -17,7 +17,7 @@ allprojects {
 ```groovy
 dependencies {
          //多个物联网相关基础工具类
-         implementation 'com.github.wave-chtj:BaseIotUtils:2.4.3'
+         implementation 'com.github.wave-chtj:BaseIotUtils:2.6.0'
 }
 ```
 
diff --git a/app/src/main/java/com/ichtj/basetools/MainActivity.java b/app/src/main/java/com/ichtj/basetools/MainActivity.java
index 6454b8d..ddc5116 100644
--- a/app/src/main/java/com/ichtj/basetools/MainActivity.java
+++ b/app/src/main/java/com/ichtj/basetools/MainActivity.java
@@ -1,11 +1,20 @@
 package com.ichtj.basetools;
 
+import android.content.ComponentName;
+import android.content.Context;
 import android.content.Intent;
 import android.net.Uri;
+import android.net.wifi.ScanResult;
+import android.net.wifi.WifiManager;
 import android.os.Bundle;
 import android.os.Environment;
 import android.os.Handler;
+import android.util.Log;
+import android.widget.Button;
+import android.widget.Toast;
+
 import androidx.annotation.Nullable;
+import androidx.core.content.ContextCompat;
 
 import com.alibaba.android.arouter.facade.annotation.Route;
 import com.chtj.base_framework.FScreentTools;
@@ -29,6 +38,9 @@
 import com.face_chtj.base_iotutils.ToastUtils;
 import com.face_chtj.base_iotutils.UriPathUtils;
 import com.face_chtj.base_iotutils.callback.INotifyStateCallback;
+import com.face_chtj.base_iotutils.download.DownloadCallback;
+import com.face_chtj.base_iotutils.download.DownloadManager;
+import com.face_chtj.base_iotutils.download.DownloadStatus;
 import com.ichtj.basetools.allapp.AllAppAty;
 import com.ichtj.basetools.audio.AudioAty;
 import com.ichtj.basetools.base.BaseActivity;
@@ -66,9 +78,12 @@
 import com.ichtj.basetools.video.VideoPlayAty;
 
 import java.io.InputStream;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.Executor;
+import java.util.concurrent.Executors;
 
 @Route(path = PACKAGES.BASE + "basetools")
 public class MainActivity extends BaseActivity implements CustomButtonGridView.OnButtonClickListener {
@@ -79,21 +94,40 @@ public class MainActivity extends BaseActivity implements CustomButtonGridView.O
     protected void onCreate(@Nullable Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_main_aty);
+        Button button = findViewById(R.id.btnNext);
+        button.setTextColor(ContextCompat.getColor(this, R.color.red));
         customButtonGridView = findViewById(R.id.customButtonGridView);
         customButtonGridView.setButtonMap(getDisplayBtn());
         customButtonGridView.setNumColumns(2); // 设置每列显示2个按钮
         customButtonGridView.setOnButtonClickListener(this);
+//        DownloadManager downloadManager =new DownloadManager(this, new DownloadCallback() {
+//            @Override
+//            public void onDownloadStatusChanged(DownloadStatus status) {
+//                Log.d(TAG, "onDownloadStatusChanged: "+status.toString());
+//            }
+//
+//            @Override
+//            public void onDownloadProgress(String url, int progress) {
+//                Log.d(TAG, "onDownloadProgress: url>>"+url+",progress>>"+progress);
+//            }
+//        });
+//        downloadManager.downloadFile("https://fireware-1257276602.cos.ap-guangzhou.myqcloud.com/test_file/ichtj_test/update.zip","/sdcard/testdownload/update.zip");
+//        downloadManager.downloadFile("https://fireware-1257276602.cos.ap-guangzhou.myqcloud.com/test_file/ichtj_test/sabresd_6dq-ota-20211029155349.zip","/sdcard/testdownload/20211029155349.zip");
+        Intent intent = new Intent();
+        intent.setComponent(new ComponentName("com.zto.ztoexpresscabinet", "com.zto.ztoexpresscabinet.business.view.MainActivity"));
+        intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
+        startActivity(intent);
     }
 
     public Map<Integer, String> getDisplayBtn() {
         Map<Integer, String> btnList = new HashMap<>();
-        Space ramSpace = new Space(0, 0, 0);
+        Space ramSpace = null;
         try {
             ramSpace = FStorageTools.getRamSpace(FStorageTools.TYPE_MB);
         } catch (Throwable throwable) {
             throwable.printStackTrace();
         }
-        Space sdSpace = new Space(0, 0, 0);
+        Space sdSpace = null;
         try {
             sdSpace = FStorageTools.getSdcardSpace(FStorageTools.TYPE_MB);
         } catch (Throwable throwable) {
@@ -107,8 +141,8 @@ public Map<Integer, String> getDisplayBtn() {
         btnList.put(FKey.KEY_IS_ROOT, "是否ROOT：" + AppsUtils.isRoot());
         btnList.put(FKey.KEY_LOCAL_IP, "本地IP：" + NetUtils.getLocalIp());
         btnList.put(FKey.KEY_FW_VERSION, "固件版本：" + DeviceUtils.getFwVersion());
-        btnList.put(FKey.KEY_RAM, "运存：" + ramSpace.getTotalSize() + "M/" + ramSpace.getUseSize() + "M/" + ramSpace.getAvailableSize() + "M");
-        btnList.put(FKey.KEY_SD_SPACE, "SD：" + sdSpace.getTotalSize() + "M/" + sdSpace.getUseSize() + "M/" + sdSpace.getAvailableSize() + "M");
+        btnList.put(FKey.KEY_RAM, "运存：" + ramSpace.getTotalSize() + "MB/" + ramSpace.getUseSize() + "MB/" + ramSpace.getAvailableSize() + "MB");
+        btnList.put(FKey.KEY_SD_SPACE, "SD：" + sdSpace.getTotalSize() + "MB/" + sdSpace.getUseSize() + "MB/" + sdSpace.getAvailableSize() + "MB");
         btnList.put(FKey.KEY_ETH_MODE, "ETH模式：" + FEthTools.getIpMode(BaseIotUtils.getContext()));
         try {
             btnList.put(FKey.KEY_DBM, "4G信号值：" + FLteTools.getDbm());
diff --git a/app/src/main/java/com/ichtj/basetools/StartPageAty.java b/app/src/main/java/com/ichtj/basetools/StartPageAty.java
index 1e64284..ace726d 100644
--- a/app/src/main/java/com/ichtj/basetools/StartPageAty.java
+++ b/app/src/main/java/com/ichtj/basetools/StartPageAty.java
@@ -7,11 +7,6 @@
 import com.ichtj.basetools.base.BaseActivity;
 import com.ichtj.basetools.util.PACKAGES;
 
-/**
- * Create on 2019/10/16
- * author chtj
- * desc $ 启动页
- */
 public class StartPageAty extends BaseActivity {
 
     @Override
diff --git a/app/src/main/java/com/ichtj/basetools/socket/SocketAty.java b/app/src/main/java/com/ichtj/basetools/socket/SocketAty.java
index 3d4b126..b1f2761 100644
--- a/app/src/main/java/com/ichtj/basetools/socket/SocketAty.java
+++ b/app/src/main/java/com/ichtj/basetools/socket/SocketAty.java
@@ -111,97 +111,9 @@ public void onViewClicked(View view) {
         switch (view.getId()) {
             case R.id.btnConnect://开启连接
                 if(selectOpiton==TCP_OPTION){
-                    //设置参数 地址+端口
-                    baseTcpSocket = new BaseTcpSocket(etIp.getText().toString(), Integer.parseInt(etPort.getText().toString()), 5000);
-                    //设置监听回调
-                    baseTcpSocket.setSocketListener(new ISocketListener() {
-                        @Override
-                        public void recv(byte[] data, int offset, int size) {
-                            KLog.d(TAG,"recv:>="+Arrays.toString(data));
-                            Message message = handler.obtainMessage();
-                            try {
-                                message.obj = "\n\r读到数据:" + /*Arrays.toString(data);*/new String(data, "UTF-8");
-                            } catch (UnsupportedEncodingException e) {
-                                e.printStackTrace();
-                            }
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void writeSuccess(byte[] data) {
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r写入数据:" + Arrays.toString(data);
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void connSuccess() {
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r连接成功";
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void connFaild(Throwable t) {
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r连接异常";
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void connClose() {
-                            KLog.d(TAG, "The connection is disconnect");
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r关闭连接";
-                            handler.sendMessage(message);
-                        }
-                    });
-                    //开启连接
-                    baseTcpSocket.connect(this);
+                    startTcpConnect();
                 }else if(selectOpiton==UDP_OPTION){
-                    //设置参数 地址+端口
-                    baseUdpSocket=new BaseUdpSocket(etIp.getText().toString(), Integer.parseInt(etPort.getText().toString()),0);
-                    //设置监听回调
-                    baseUdpSocket.setSocketListener(new ISocketListener() {
-                        @Override
-                        public void recv(byte[] data, int offset, int size) {
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r读到数据:" + Arrays.toString(data);
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void writeSuccess(byte[] data) {
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r写入数据:" + Arrays.toString(data);
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void connSuccess() {
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r连接成功";
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void connFaild(Throwable t) {
-                            KLog.d(TAG, "errMeg: "+t.getMessage());
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r连接异常";
-                            handler.sendMessage(message);
-                        }
-
-                        @Override
-                        public void connClose() {
-                            KLog.d(TAG, "The connection is disconnect");
-                            Message message = handler.obtainMessage();
-                            message.obj = "\n\r关闭连接";
-                            handler.sendMessage(message);
-                        }
-                    });
-                    //开启连接
-                    baseUdpSocket.connect(this);
+                    startUdpConnect();
                 }
                 break;
             case R.id.btnDisConnect://关闭连接
@@ -232,4 +144,100 @@ public void connClose() {
                 break;
         }
     }
+
+    private void startUdpConnect() {
+        //设置参数 地址+端口
+        baseUdpSocket=new BaseUdpSocket(etIp.getText().toString(), Integer.parseInt(etPort.getText().toString()),0);
+        //设置监听回调
+        baseUdpSocket.setSocketListener(new ISocketListener() {
+            @Override
+            public void recv(byte[] data, int offset, int size) {
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r读到数据:" + Arrays.toString(data);
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void writeSuccess(byte[] data) {
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r写入数据:" + Arrays.toString(data);
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void connSuccess() {
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r连接成功";
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void connFaild(Throwable t) {
+                KLog.d(TAG, "errMeg: "+t.getMessage());
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r连接异常";
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void connClose() {
+                KLog.d(TAG, "The connection is disconnect");
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r关闭连接";
+                handler.sendMessage(message);
+            }
+        });
+        //开启连接
+        baseUdpSocket.connect(this);
+    }
+
+    private void startTcpConnect() {
+        //设置参数 地址+端口
+        baseTcpSocket = new BaseTcpSocket(etIp.getText().toString(), Integer.parseInt(etPort.getText().toString()), 5000);
+        //设置监听回调
+        baseTcpSocket.setSocketListener(new ISocketListener() {
+            @Override
+            public void recv(byte[] data, int offset, int size) {
+                KLog.d(TAG,"recv:>="+Arrays.toString(data));
+                Message message = handler.obtainMessage();
+                try {
+                    message.obj = "\n\r读到数据:" + /*Arrays.toString(data);*/new String(data, "UTF-8");
+                } catch (UnsupportedEncodingException e) {
+                    e.printStackTrace();
+                }
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void writeSuccess(byte[] data) {
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r写入数据:" + Arrays.toString(data);
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void connSuccess() {
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r连接成功";
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void connFaild(Throwable t) {
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r连接异常";
+                handler.sendMessage(message);
+            }
+
+            @Override
+            public void connClose() {
+                KLog.d(TAG, "The connection is disconnect");
+                Message message = handler.obtainMessage();
+                message.obj = "\n\r关闭连接";
+                handler.sendMessage(message);
+            }
+        });
+        //开启连接
+        baseTcpSocket.connect(this);
+    }
 }
diff --git a/app/src/main/res/layout/activity_main_aty.xml b/app/src/main/res/layout/activity_main_aty.xml
index 9bb2108..f18dda9 100644
--- a/app/src/main/res/layout/activity_main_aty.xml
+++ b/app/src/main/res/layout/activity_main_aty.xml
@@ -3,6 +3,12 @@
     android:orientation="vertical"
     android:layout_width="match_parent"
     android:layout_height="match_parent">
+    <Button
+        android:id="@+id/btnNext"
+        android:layout_width="wrap_content"
+        android:text="dsldlsfs"
+        android:visibility="gone"
+        android:layout_height="wrap_content"/>
     <com.ichtj.basetools.util.CustomButtonGridView
         android:id="@+id/customButtonGridView"
         android:layout_width="match_parent"
diff --git a/app/src/main/res/values/colors.xml b/app/src/main/res/values/colors.xml
index 2d5463f..56ba399 100644
--- a/app/src/main/res/values/colors.xml
+++ b/app/src/main/res/values/colors.xml
@@ -19,4 +19,7 @@
     <color name="green">#00FF37</color>
     <color name="red">#FF0000</color>
 
+    <color name="gray_1">#CACDD2</color>
+    <color name="blue_1">#0144C6</color>
+
 </resources>
diff --git a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/NotifyUtils.java b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/NotifyUtils.java
index 1c59b94..b4b051e 100644
--- a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/NotifyUtils.java
+++ b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/NotifyUtils.java
@@ -52,6 +52,7 @@ public class NotifyUtils {
     private Notification.Builder builder = null;
     //自定义的系统通知视图
     private RemoteViews contentView = null;
+    private boolean isRefreshUi=true;
     private int notifyId = -1; //notification标识
     private boolean mSlideOff = true;//滑动时是否可以删除
     private boolean mAutoCancel = false;//点击的时候是否消失
@@ -63,6 +64,13 @@ public class NotifyUtils {
     //跳转设置
     public static final String SETTINGS_ACTION = "android.settings.APPLICATION_DETAILS_SETTINGS";
 
+    /**
+     * 是否允许刷新UI
+     */
+    public void setRefreshUi(boolean refreshUi) {
+        isRefreshUi = refreshUi;
+    }
+
     /**
      * 获取系统中是否已经通过 允许通知的权限
      *
@@ -407,22 +415,24 @@ public static NotifyUtils setmAutoCancel(boolean mAutoCancel) {
      * 更改参数时执行
      */
     public void exeuNotify() {
-        if (getInstance().manager != null) {
-            if (getInstance().notifyId != -1) {
-                if (getInstance().builder != null) {
-                    getInstance().builder.setOngoing(!getInstance().mSlideOff);//滑动不能清除
-                    getInstance().builder.setAutoCancel(getInstance().mAutoCancel);//点击的时候消失
-                    getInstance().manager.notify(getInstance().notifyId, getInstance().builder.build());  //参数一为ID，用来区分不同APP的Notification
-                }
-                SPUtils.putBoolean("needClose", getInstance().mAutoCancel);
-                if (getInstance().mINotifyStateCallback != null) {
-                    getInstance().mINotifyStateCallback.enableStatus(true);
+        if (isRefreshUi){
+            if (getInstance().manager != null) {
+                if (getInstance().notifyId != -1) {
+                    if (getInstance().builder != null) {
+                        getInstance().builder.setOngoing(!getInstance().mSlideOff);//滑动不能清除
+                        getInstance().builder.setAutoCancel(getInstance().mAutoCancel);//点击的时候消失
+                        getInstance().manager.notify(getInstance().notifyId, getInstance().builder.build());  //参数一为ID，用来区分不同APP的Notification
+                    }
+                    SPUtils.putBoolean("needClose", getInstance().mAutoCancel);
+                    if (getInstance().mINotifyStateCallback != null) {
+                        getInstance().mINotifyStateCallback.enableStatus(true);
+                    }
+                } else {
+                    throw new NullPointerException("notifyId ==null:method > setNotifyId(int notifyId)");
                 }
             } else {
-                throw new NullPointerException("notifyId ==null:method > setNotifyId(int notifyId)");
+                throw new NullPointerException("manager or builder ==null");
             }
-        } else {
-            throw new NullPointerException("manager or builder ==null");
         }
     }
 
diff --git a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadCallback.java b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadCallback.java
new file mode 100644
index 0000000..1708973
--- /dev/null
+++ b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadCallback.java
@@ -0,0 +1,6 @@
+package com.face_chtj.base_iotutils.download;
+
+public interface DownloadCallback {
+    void onDownloadStatusChanged(DownloadStatus status);
+    void onDownloadProgress(String url, int progress);
+}
diff --git a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadDatabaseHelper.java b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadDatabaseHelper.java
new file mode 100644
index 0000000..44750ba
--- /dev/null
+++ b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadDatabaseHelper.java
@@ -0,0 +1,78 @@
+package com.face_chtj.base_iotutils.download;
+
+import android.content.ContentValues;
+import android.content.Context;
+import android.database.Cursor;
+import android.database.sqlite.SQLiteDatabase;
+import android.database.sqlite.SQLiteOpenHelper;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class DownloadDatabaseHelper extends SQLiteOpenHelper {
+
+    private static final String DATABASE_NAME = "downloads.db";
+    private static final int DATABASE_VERSION = 1;
+
+    public static final String TABLE_DOWNLOADS = "downloads";
+    public static final String COLUMN_URL = "url";
+    public static final String COLUMN_FILE_PATH = "file_path";
+    public static final String COLUMN_PROGRESS = "progress";
+    public static final String COLUMN_IS_PAUSED = "is_paused";
+
+    public DownloadDatabaseHelper(Context context) {
+        super(context, DATABASE_NAME, null, DATABASE_VERSION);
+    }
+
+    @Override
+    public void onCreate(SQLiteDatabase db) {
+        String createTable = "CREATE TABLE " + TABLE_DOWNLOADS + " (" +
+                COLUMN_URL + " TEXT PRIMARY KEY, " +
+                COLUMN_FILE_PATH + " TEXT, " +
+                COLUMN_PROGRESS + " INTEGER, " +
+                COLUMN_IS_PAUSED + " INTEGER)";
+        db.execSQL(createTable);
+    }
+
+    @Override
+    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
+        db.execSQL("DROP TABLE IF EXISTS " + TABLE_DOWNLOADS);
+        onCreate(db);
+    }
+
+    public void addDownloadTask(DownloadTask task) {
+        SQLiteDatabase db = this.getWritableDatabase();
+        ContentValues values = new ContentValues();
+        values.put(COLUMN_URL, task.getUrl());
+        values.put(COLUMN_FILE_PATH, task.getFilePath());
+        values.put(COLUMN_PROGRESS, task.getProgress());
+        values.put(COLUMN_IS_PAUSED, task.isPaused() ? 1 : 0);
+        db.insertWithOnConflict(TABLE_DOWNLOADS, null, values, SQLiteDatabase.CONFLICT_REPLACE);
+        db.close();
+    }
+
+    public List<DownloadTask> getAllDownloadTasks() {
+        List<DownloadTask> tasks = new ArrayList<>();
+        SQLiteDatabase db = this.getReadableDatabase();
+        Cursor cursor = db.rawQuery("SELECT * FROM " + TABLE_DOWNLOADS, null);
+        if (cursor.moveToFirst()) {
+            do {
+                String url = cursor.getString(cursor.getColumnIndex(COLUMN_URL));
+                String filePath = cursor.getString(cursor.getColumnIndex(COLUMN_FILE_PATH));
+                int progress = cursor.getInt(cursor.getColumnIndex(COLUMN_PROGRESS));
+                boolean isPaused = cursor.getInt(cursor.getColumnIndex(COLUMN_IS_PAUSED)) == 1;
+                tasks.add(new DownloadTask(url, filePath, progress, isPaused));
+            } while (cursor.moveToNext());
+        }
+        cursor.close();
+        db.close();
+        return tasks;
+    }
+
+    public void deleteDownloadTask(String url) {
+        SQLiteDatabase db = this.getWritableDatabase();
+        db.delete(TABLE_DOWNLOADS, COLUMN_URL + " = ?", new String[]{url});
+        db.close();
+    }
+}
+
diff --git a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadManager.java b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadManager.java
new file mode 100644
index 0000000..8f7adcb
--- /dev/null
+++ b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadManager.java
@@ -0,0 +1,164 @@
+package com.face_chtj.base_iotutils.download;
+
+import android.content.Context;
+import android.util.Log;
+
+import okhttp3.Call;
+import okhttp3.Callback;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+public class DownloadManager {
+    private static final String TAG=DownloadManager.class.getSimpleName();
+    private final OkHttpClient client;
+    private final DownloadDatabaseHelper dbHelper;
+    private final Map<String, Call> currentDownloads;
+    private final DownloadCallback callback;
+    private final ScheduledExecutorService progressExecutor;
+
+    public DownloadManager(Context context, DownloadCallback callback) {
+        this.client = new OkHttpClient();
+        this.dbHelper = new DownloadDatabaseHelper(context);
+        this.currentDownloads = new HashMap<>();
+        this.callback = callback;
+        this.progressExecutor = Executors.newScheduledThreadPool(1);
+        restoreDownloads();
+    }
+
+    public void downloadFile(String url, String filePath) {
+        File file = new File(filePath);
+        File parent=new File(file.getParent());
+        Log.d(TAG, "downloadFile: parent>>"+parent.getAbsolutePath());
+        if (!parent.exists()){
+            parent.mkdirs();
+        }
+        DownloadTask task = new DownloadTask(url, filePath, 0, false);
+        dbHelper.addDownloadTask(task);
+        startDownload(task);
+    }
+
+    private void startDownload(final DownloadTask task) {
+        if (currentDownloads.containsKey(task.getUrl())) {
+            Log.d(TAG,"Already in download queue: " + task.getUrl());
+            return;
+        }
+
+        Request request = new Request.Builder().url(task.getUrl()).build();
+        Call call = client.newCall(request);
+        currentDownloads.put(task.getUrl(), call);
+        callback.onDownloadStatusChanged(new DownloadStatus(task.getUrl(), DownloadStatus.Status.STARTED));
+
+        call.enqueue(new Callback() {
+            @Override
+            public void onFailure(Call call, IOException e) {
+                Log.d(TAG,"Download failed: " + task.getUrl());
+                currentDownloads.remove(task.getUrl());
+                callback.onDownloadStatusChanged(new DownloadStatus(task.getUrl(), DownloadStatus.Status.ERROR, e.getMessage()));
+            }
+
+            @Override
+            public void onResponse(Call call, Response response) throws IOException {
+                if (!response.isSuccessful()) {
+                    onFailure(call, new IOException("Unexpected code " + response));
+                    return;
+                }
+
+                File file = new File(task.getFilePath());
+                try (InputStream is = response.body().byteStream();
+                     FileOutputStream fos = new FileOutputStream(file)) {
+
+                    byte[] buffer = new byte[1024];
+                    int bytesRead;
+                    int totalBytesRead = 0;
+                    final int contentLength = (int) response.body().contentLength();
+
+                    // Schedule progress updates
+                    final int finalTotalBytesRead = totalBytesRead;
+                    progressExecutor.scheduleAtFixedRate(new Runnable() {
+                        @Override
+                        public void run() {
+                        int progress = (int) (((double) finalTotalBytesRead / contentLength) * 100);
+                        callback.onDownloadProgress(task.getUrl(), progress);
+                        }
+                    }, 0, 1, TimeUnit.SECONDS);
+
+                    while ((bytesRead = is.read(buffer)) != -1) {
+                        fos.write(buffer, 0, bytesRead);
+                        totalBytesRead += bytesRead;
+                    }
+
+                    progressExecutor.shutdown();
+                    callback.onDownloadStatusChanged(new DownloadStatus(task.getUrl(), DownloadStatus.Status.COMPLETED));
+                } finally {
+                    currentDownloads.remove(task.getUrl());
+                    dbHelper.deleteDownloadTask(task.getUrl());
+                }
+            }
+        });
+    }
+
+    private DownloadTask getDownloadTaskByUrl(String url) {
+        List<DownloadTask> tasks = dbHelper.getAllDownloadTasks();
+        for (DownloadTask task : tasks) {
+            if (task.getUrl().equals(url)) {
+                return task;
+            }
+        }
+        return null;
+    }
+
+    public void pauseDownload(String url) {
+        Call call = currentDownloads.get(url);
+        if (call != null) {
+            call.cancel();
+            DownloadTask task = getDownloadTaskByUrl(url);
+            if (task != null) {
+                task.setPaused(true);
+                dbHelper.addDownloadTask(task);
+                callback.onDownloadStatusChanged(new DownloadStatus(url, DownloadStatus.Status.PAUSED));
+            }
+        }
+    }
+
+    public void resumeDownload(String url) {
+        DownloadTask task = getDownloadTaskByUrl(url);
+        if (task != null && task.isPaused()) {
+            task.setPaused(false);
+            dbHelper.addDownloadTask(task);
+            startDownload(task);
+            callback.onDownloadStatusChanged(new DownloadStatus(url, DownloadStatus.Status.RESUMED));
+        }
+    }
+
+    public void deleteDownload(String url) {
+        pauseDownload(url);
+        dbHelper.deleteDownloadTask(url);
+        currentDownloads.remove(url);
+        DownloadTask task = getDownloadTaskByUrl(url);
+        if (task != null) {
+            new File(task.getFilePath()).delete();
+        }
+    }
+
+    private void restoreDownloads() {
+        List<DownloadTask> tasks = dbHelper.getAllDownloadTasks();
+        for (DownloadTask task : tasks) {
+            if (!task.isPaused()) {
+                startDownload(task);
+            }
+        }
+    }
+}
diff --git a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadStatus.java b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadStatus.java
new file mode 100644
index 0000000..c34cf6c
--- /dev/null
+++ b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadStatus.java
@@ -0,0 +1,47 @@
+package com.face_chtj.base_iotutils.download;
+
+public class DownloadStatus {
+    public enum Status {
+        STARTED,
+        PAUSED,
+        RESUMED,
+        COMPLETED,
+        ERROR
+    }
+
+    private String url;
+    private Status status;
+    private String errorMessage;
+
+    public DownloadStatus(String url, Status status) {
+        this.url = url;
+        this.status = status;
+    }
+
+    public DownloadStatus(String url, Status status, String errorMessage) {
+        this.url = url;
+        this.status = status;
+        this.errorMessage = errorMessage;
+    }
+
+    public String getUrl() {
+        return url;
+    }
+
+    public Status getStatus() {
+        return status;
+    }
+
+    public String getErrorMessage() {
+        return errorMessage;
+    }
+
+    @Override
+    public String toString() {
+        return "DownloadStatus{" +
+                "url='" + url + '\'' +
+                ", status=" + status +
+                ", errorMessage='" + errorMessage + '\'' +
+                '}';
+    }
+}
diff --git a/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadTask.java b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadTask.java
new file mode 100644
index 0000000..29da6b5
--- /dev/null
+++ b/base_iotutils/src/main/java/com/face_chtj/base_iotutils/download/DownloadTask.java
@@ -0,0 +1,29 @@
+package com.face_chtj.base_iotutils.download;
+
+public class DownloadTask {
+    private String url;
+    private String filePath;
+    private int progress;
+    private boolean isPaused;
+
+    // Constructors, getters, and setters
+    public DownloadTask(String url, String filePath, int progress, boolean isPaused) {
+        this.url = url;
+        this.filePath = filePath;
+        this.progress = progress;
+        this.isPaused = isPaused;
+    }
+
+    public String getUrl() { return url; }
+    public void setUrl(String url) { this.url = url; }
+
+    public String getFilePath() { return filePath; }
+    public void setFilePath(String filePath) { this.filePath = filePath; }
+
+    public int getProgress() { return progress; }
+    public void setProgress(int progress) { this.progress = progress; }
+
+    public boolean isPaused() { return isPaused; }
+    public void setPaused(boolean paused) { isPaused = paused; }
+}
+
diff --git a/other/command.txt b/other/command.txt
index ae6f777..518fbd6 100644
--- a/other/command.txt
+++ b/other/command.txt
@@ -42,7 +42,7 @@ cmd:adb shell dumpsys window | findstr mCurrentFocus // 
 -------------------------------------------------
 cd sdcard;busybox find ./ -size +51200k > /sdcard/report.txt;cd / //��׿��19,���Ҵ���50M���ļ���ָ���ļ���
 find sdcard/ -size +50M > /sdcard/report.txt //��׿��25,���Ҵ���50M���ļ���ָ���ļ���
-du -m -d 1 /sdcard/* //�г�sdcar�ļ����²㼶Ϊ1 ���ļ���Ϣ
+du -m -d 1 /sdcard/* //�г�sdcard�ļ����²㼶Ϊ1 ���ļ���Ϣ
 -------------------------------------------------
 data MMddHHmmyyyy.ss set //����ʱ���ʽ
 date 010411482023.58 set //����ʱ��