From 1fb9f13dae38a202f853497e41e8e517c75f6eaf Mon Sep 17 00:00:00 2001
From: laoyuyu <511455842@qq.com>
Date: Fri, 26 Jul 2019 21:37:49 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=88=A0=E9=99=A4?=
 =?UTF-8?q?=E9=87=8D=E5=A4=8D=E8=AE=B0=E5=BD=95=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/arialyy/aria/orm/DBConfig.java |  2 +-
 .../main/java/com/arialyy/aria/orm/SqlHelper.java    | 12 +++++-------
 2 files changed, 6 insertions(+), 8 deletions(-)

diff --git a/Aria/src/main/java/com/arialyy/aria/orm/DBConfig.java b/Aria/src/main/java/com/arialyy/aria/orm/DBConfig.java
index e50113e7..6bdddbd4 100644
--- a/Aria/src/main/java/com/arialyy/aria/orm/DBConfig.java
+++ b/Aria/src/main/java/com/arialyy/aria/orm/DBConfig.java
@@ -38,7 +38,7 @@ class DBConfig {
   static boolean DEBUG = false;
   static Map<String, Class> mapping = new LinkedHashMap<>();
   static String DB_NAME;
-  static int VERSION = 52;
+  static int VERSION = 53;
 
   /**
    * 是否将数据库保存在Sd卡，{@code true} 是
diff --git a/Aria/src/main/java/com/arialyy/aria/orm/SqlHelper.java b/Aria/src/main/java/com/arialyy/aria/orm/SqlHelper.java
index 1795cb79..4b2683db 100644
--- a/Aria/src/main/java/com/arialyy/aria/orm/SqlHelper.java
+++ b/Aria/src/main/java/com/arialyy/aria/orm/SqlHelper.java
@@ -100,7 +100,7 @@ final class SqlHelper extends SQLiteOpenHelper {
         handle360AriaUpdate(db);
       } else if (oldVersion < 51) {
         handle365Update(db);
-      } else if (oldVersion < 52) {
+      } else if (oldVersion < 53) {
         handle366Update(db);
       } else {
         handleDbUpdate(db, null, null);
@@ -240,12 +240,9 @@ final class SqlHelper extends SQLiteOpenHelper {
    * 删除重复的repeat数据
    */
   private void delRepeatThreadRecord(SQLiteDatabase db) {
-    String repeatSql =
-        "DELETE FROM ThreadRecord WHERE (taskKey, threadId, endLocation) "
-            + "IN (SELECT taskKey, threadId, endLocation FROM ThreadRecord GROUP BY taskKey, threadId, endLocation "
-            + "HAVING COUNT(*) > 1) AND rowid "
-            + "NOT IN (SELECT MIN(rowid) FROM ThreadRecord GROUP BY taskKey, threadId, endLocation "
-            + "HAVING COUNT(*)> 1)";
+    String repeatSql = "DELETE FROM ThreadRecord WHERE (rowid) "
+        + "IN (SELECT rowid FROM ThreadRecord GROUP BY taskKey, threadId, endLocation HAVING COUNT(*) > 1) "
+        + "AND rowid NOT IN (SELECT MIN(rowid) FROM ThreadRecord GROUP BY taskKey, threadId, endLocation HAVING COUNT(*)> 1)";
     ALog.d(TAG, repeatSql);
     db.execSQL(repeatSql);
   }
@@ -262,6 +259,7 @@ final class SqlHelper extends SQLiteOpenHelper {
 
     // 执行升级操作
     handleDbUpdate(db, modifyMap, null);
+    delRepeatThreadRecord(db);
   }
 
   /**

From 558c9e1223bc5ed2b0d8d2c6fe9a6207b2c30eaa Mon Sep 17 00:00:00 2001
From: laoyuyu <511455842@qq.com>
Date: Mon, 5 Aug 2019 19:29:32 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=99=AE=E9=80=9A?=
 =?UTF-8?q?=E4=B8=8B=E8=BD=BD=E4=BB=BB=E5=8A=A1=E3=80=81=E7=BB=84=E5=90=88?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=85=B1=E4=BA=AB=E6=89=A7=E8=A1=8C=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E3=80=81=E7=BC=93=E5=AD=98=E6=B1=A0=E7=9A=84=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98=20=E4=BF=AE=E5=A4=8D=E7=BB=84=E5=90=88=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E5=90=AF=E5=8A=A8=E5=A4=B1=E8=B4=A5=E6=97=B6=EF=BC=8C?=
 =?UTF-8?q?`DownloadGroupEntity`=E7=9A=84=E7=8A=B6=E6=80=81=E5=8F=98?=
 =?UTF-8?q?=E4=B8=BA=E6=89=A7=E8=A1=8C=E4=B8=AD=E7=9A=84=E9=97=AE=E9=A2=98?=
 =?UTF-8?q?=20fix=20bug=20https://github.com/AriaLyy/Aria/issues/441?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../aria/core/common/AbsThreadTask.java       |  6 ++-
 .../aria/core/common/ThreadStateManager.java  |  6 ++-
 .../core/download/group/AbsGroupUtil.java     | 13 ++++--
 .../aria/core/download/group/DGroupUtil.java  |  6 ++-
 .../download/group/FtpDirDownloadUtil.java    |  4 +-
 .../arialyy/aria/core/queue/AbsTaskQueue.java | 10 +++--
 .../core/queue/pool/DGLoadExecutePool.java    | 31 ++++++++++++++
 ...oadSharePool.java => DGLoadSharePool.java} | 16 ++++----
 ...ExecutePool.java => DLoadExecutePool.java} |  4 +-
 .../aria/core/queue/pool/DLoadSharePool.java  | 41 +++++++++++++++++++
 .../com/arialyy/aria/orm/DelegateCommon.java  |  4 +-
 .../com/arialyy/aria/orm/DelegateFind.java    | 15 ++++---
 .../com/arialyy/aria/orm/DelegateUpdate.java  | 12 +++---
 .../java/com/arialyy/aria/util/CheckUtil.java | 21 +++++++---
 app/src/main/assets/aria_config.xml           |  4 +-
 .../multi_download/MultiDownloadActivity.java |  8 ++--
 app/src/main/res/values/strings.xml           | 21 ++++------
 build.gradle                                  |  2 +-
 18 files changed, 164 insertions(+), 60 deletions(-)
 create mode 100644 Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadExecutePool.java
 rename Aria/src/main/java/com/arialyy/aria/core/queue/pool/{DownloadSharePool.java => DGLoadSharePool.java} (72%)
 rename Aria/src/main/java/com/arialyy/aria/core/queue/pool/{DownloadExecutePool.java => DLoadExecutePool.java} (95%)
 create mode 100644 Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadSharePool.java

diff --git a/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java b/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java
index b9138926..c606be66 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/common/AbsThreadTask.java
@@ -201,10 +201,12 @@ public abstract class AbsThreadTask<ENTITY extends AbsNormalEntity, TASK_WRAPPER
    * @param state {@link IThreadState#STATE_STOP}..
    * @param bundle 而外数据
    */
-  void sendState(int state, @Nullable Bundle bundle) {
+  synchronized void sendState(int state, @Nullable Bundle bundle) {
     Message msg = mStateHandler.obtainMessage();
     msg.what = state;
-    msg.obj = this;
+    if (state != IThreadState.STATE_UPDATE_PROGRESS) {
+      msg.obj = this;
+    }
 
     if ((state == IThreadState.STATE_COMPLETE || state == IThreadState.STATE_FAIL)
         && (mTaskWrapper.getRequestType() == AbsTaskWrapper.M3U8_VOD
diff --git a/Aria/src/main/java/com/arialyy/aria/core/common/ThreadStateManager.java b/Aria/src/main/java/com/arialyy/aria/core/common/ThreadStateManager.java
index 5b4965d8..05aa0d63 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/common/ThreadStateManager.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/common/ThreadStateManager.java
@@ -96,12 +96,14 @@ public class ThreadStateManager implements IThreadState {
         }
         break;
       case STATE_RUNNING:
-        mProgress += (long) msg.obj;
+        if (msg.obj instanceof Long) {
+          mProgress += (long) msg.obj;
+        }
         break;
       case STATE_UPDATE_PROGRESS:
         if (msg.obj == null) {
           mProgress = updateBlockProgress();
-        } else {
+        } else if (msg.obj instanceof Long) {
           mProgress = (long) msg.obj;
         }
         break;
diff --git a/Aria/src/main/java/com/arialyy/aria/core/download/group/AbsGroupUtil.java b/Aria/src/main/java/com/arialyy/aria/core/download/group/AbsGroupUtil.java
index 4ae6ac2e..39d482f1 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/download/group/AbsGroupUtil.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/download/group/AbsGroupUtil.java
@@ -211,12 +211,19 @@ public abstract class AbsGroupUtil implements IUtil, Runnable {
       closeTimer();
       return;
     }
-    onStart();
-    startRunningFlow();
+    if (onStart()) {
+      startRunningFlow();
+    }
   }
 
-  protected void onStart() {
+  /**
+   * 处理启动前的检查：获取组合任务大小
+   *
+   * @return {@code false} 将不再走后续流程，任务介绍
+   */
+  protected boolean onStart() {
 
+    return false;
   }
 
   synchronized void closeTimer() {
diff --git a/Aria/src/main/java/com/arialyy/aria/core/download/group/DGroupUtil.java b/Aria/src/main/java/com/arialyy/aria/core/download/group/DGroupUtil.java
index 0c124366..6edd8efd 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/download/group/DGroupUtil.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/download/group/DGroupUtil.java
@@ -68,8 +68,7 @@ public class DGroupUtil extends AbsGroupUtil implements IUtil {
     return false;
   }
 
-  @Override protected void onStart() {
-    super.onStart();
+  @Override protected boolean onStart() {
     if (mState.getCompleteNum() == mState.getSubSize()) {
       mListener.onComplete();
     } else {
@@ -84,6 +83,7 @@ public class DGroupUtil extends AbsGroupUtil implements IUtil {
         } catch (InterruptedException e) {
           e.printStackTrace();
         }
+        return getLenComplete;
       } else {
         for (DTaskWrapper wrapper : mGTWrapper.getSubTaskWrapper()) {
           if (wrapper.getState() != IEntity.STATE_COMPLETE) {
@@ -92,6 +92,7 @@ public class DGroupUtil extends AbsGroupUtil implements IUtil {
         }
       }
     }
+    return true;
   }
 
   /**
@@ -137,6 +138,7 @@ public class DGroupUtil extends AbsGroupUtil implements IUtil {
    */
   private void checkGetSizeComplete(int count, int failCount) {
     if (failCount == mGTWrapper.getSubTaskWrapper().size()) {
+      mState.isRunning = false;
       mListener.onFail(false, new AriaIOException(TAG, "获取子任务长度失败"));
       notifyLock();
       return;
diff --git a/Aria/src/main/java/com/arialyy/aria/core/download/group/FtpDirDownloadUtil.java b/Aria/src/main/java/com/arialyy/aria/core/download/group/FtpDirDownloadUtil.java
index 7d1d54ba..f7c388e9 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/download/group/FtpDirDownloadUtil.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/download/group/FtpDirDownloadUtil.java
@@ -38,8 +38,7 @@ public class FtpDirDownloadUtil extends AbsGroupUtil {
     return FTP_DIR;
   }
 
-  @Override protected void onStart() {
-    super.onStart();
+  @Override protected boolean onStart() {
     if (mGTWrapper.getEntity().getFileSize() > 1) {
       startDownload();
     } else {
@@ -57,6 +56,7 @@ public class FtpDirDownloadUtil extends AbsGroupUtil {
       });
       new Thread(infoThread).start();
     }
+    return true;
   }
 
   private void startDownload() {
diff --git a/Aria/src/main/java/com/arialyy/aria/core/queue/AbsTaskQueue.java b/Aria/src/main/java/com/arialyy/aria/core/queue/AbsTaskQueue.java
index 98ab974f..062fa37c 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/queue/AbsTaskQueue.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/queue/AbsTaskQueue.java
@@ -26,7 +26,8 @@ import com.arialyy.aria.core.manager.TaskWrapperManager;
 import com.arialyy.aria.core.manager.ThreadTaskManager;
 import com.arialyy.aria.core.queue.pool.BaseCachePool;
 import com.arialyy.aria.core.queue.pool.BaseExecutePool;
-import com.arialyy.aria.core.queue.pool.DownloadSharePool;
+import com.arialyy.aria.core.queue.pool.DGLoadSharePool;
+import com.arialyy.aria.core.queue.pool.DLoadSharePool;
 import com.arialyy.aria.core.queue.pool.UploadSharePool;
 import com.arialyy.aria.core.upload.UploadTask;
 import com.arialyy.aria.util.ALog;
@@ -47,9 +48,12 @@ public abstract class AbsTaskQueue<TASK extends AbsTask, TASK_WRAPPER extends Ab
   AbsTaskQueue() {
     switch (getQueueType()) {
       case TYPE_D_QUEUE:
+        mCachePool = DLoadSharePool.getInstance().cachePool;
+        mExecutePool = DLoadSharePool.getInstance().executePool;
+        break;
       case TYPE_DG_QUEUE:
-        mCachePool = DownloadSharePool.getInstance().cachePool;
-        mExecutePool = DownloadSharePool.getInstance().executePool;
+        mCachePool = DGLoadSharePool.getInstance().cachePool;
+        mExecutePool = DGLoadSharePool.getInstance().executePool;
         break;
       case TYPE_U_QUEUE:
         mCachePool = UploadSharePool.getInstance().cachePool;
diff --git a/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadExecutePool.java b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadExecutePool.java
new file mode 100644
index 00000000..e9ec61e8
--- /dev/null
+++ b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadExecutePool.java
@@ -0,0 +1,31 @@
+/*
+ * Copyright (C) 2016 AriaLyy(https://github.com/AriaLyy/Aria)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.arialyy.aria.core.queue.pool;
+
+import com.arialyy.aria.core.AriaManager;
+import com.arialyy.aria.core.inf.AbsTask;
+
+/**
+ * Created by AriaL on 2017/6/29.
+ * 单个下载任务的执行池
+ */
+class DGLoadExecutePool<TASK extends AbsTask> extends DLoadExecutePool<TASK> {
+  private final String TAG = "DGLoadExecutePool";
+
+  @Override protected int getMaxSize() {
+    return AriaManager.getInstance(AriaManager.APP).getDGroupConfig().getMaxTaskNum();
+  }
+}
diff --git a/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DownloadSharePool.java b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadSharePool.java
similarity index 72%
rename from Aria/src/main/java/com/arialyy/aria/core/queue/pool/DownloadSharePool.java
rename to Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadSharePool.java
index 4c07a16e..869612dc 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DownloadSharePool.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DGLoadSharePool.java
@@ -19,21 +19,21 @@ package com.arialyy.aria.core.queue.pool;
  * Created by Aria.Lao on 2017/7/17.
  * 下载任务池，该池子为简单任务和任务组共用
  */
-public class DownloadSharePool {
-  private static volatile DownloadSharePool INSTANCE;
+public class DGLoadSharePool {
+  private static volatile DGLoadSharePool INSTANCE;
 
-  public DownloadExecutePool executePool;
+  public DGLoadExecutePool executePool;
   public BaseCachePool cachePool;
 
-  private DownloadSharePool() {
-    executePool = new DownloadExecutePool<>();
+  private DGLoadSharePool() {
+    executePool = new DGLoadExecutePool<>();
     cachePool = new BaseCachePool<>();
   }
 
-  public static DownloadSharePool getInstance() {
+  public static DGLoadSharePool getInstance() {
     if (INSTANCE == null) {
-      synchronized (DownloadSharePool.class) {
-        INSTANCE = new DownloadSharePool();
+      synchronized (DGLoadSharePool.class) {
+        INSTANCE = new DGLoadSharePool();
       }
     }
     return INSTANCE;
diff --git a/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DownloadExecutePool.java b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadExecutePool.java
similarity index 95%
rename from Aria/src/main/java/com/arialyy/aria/core/queue/pool/DownloadExecutePool.java
rename to Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadExecutePool.java
index 25fcbcb0..81e5f340 100644
--- a/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DownloadExecutePool.java
+++ b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadExecutePool.java
@@ -26,7 +26,7 @@ import java.util.concurrent.TimeUnit;
  * Created by AriaL on 2017/6/29.
  * 单个下载任务的执行池
  */
-class DownloadExecutePool<TASK extends AbsTask> extends BaseExecutePool<TASK> {
+class DLoadExecutePool<TASK extends AbsTask> extends BaseExecutePool<TASK> {
   private final String TAG = "DownloadExecutePool";
 
   @Override protected int getMaxSize() {
@@ -34,7 +34,7 @@ class DownloadExecutePool<TASK extends AbsTask> extends BaseExecutePool<TASK> {
   }
 
   @Override public boolean putTask(TASK task) {
-    synchronized (DownloadExecutePool.class) {
+    synchronized (DLoadExecutePool.class) {
       if (task == null) {
         ALog.e(TAG, "任务不能为空！！");
         return false;
diff --git a/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadSharePool.java b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadSharePool.java
new file mode 100644
index 00000000..2ab96c9d
--- /dev/null
+++ b/Aria/src/main/java/com/arialyy/aria/core/queue/pool/DLoadSharePool.java
@@ -0,0 +1,41 @@
+/*
+ * Copyright (C) 2016 AriaLyy(https://github.com/AriaLyy/Aria)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.arialyy.aria.core.queue.pool;
+
+/**
+ * Created by Aria.Lao on 2017/7/17.
+ * 下载任务池，该池子为简单任务和任务组共用
+ */
+public class DLoadSharePool {
+  private static volatile DLoadSharePool INSTANCE;
+
+  public DLoadExecutePool executePool;
+  public BaseCachePool cachePool;
+
+  private DLoadSharePool() {
+    executePool = new DLoadExecutePool<>();
+    cachePool = new BaseCachePool<>();
+  }
+
+  public static DLoadSharePool getInstance() {
+    if (INSTANCE == null) {
+      synchronized (DLoadSharePool.class) {
+        INSTANCE = new DLoadSharePool();
+      }
+    }
+    return INSTANCE;
+  }
+}
diff --git a/Aria/src/main/java/com/arialyy/aria/orm/DelegateCommon.java b/Aria/src/main/java/com/arialyy/aria/orm/DelegateCommon.java
index b1e8c319..3408a8af 100644
--- a/Aria/src/main/java/com/arialyy/aria/orm/DelegateCommon.java
+++ b/Aria/src/main/java/com/arialyy/aria/orm/DelegateCommon.java
@@ -106,7 +106,9 @@ class DelegateCommon extends AbsDelegate {
    */
   boolean checkDataExist(SQLiteDatabase db, Class clazz, String... expression) {
     db = checkDb(db);
-    CheckUtil.checkSqlExpression(expression);
+    if (!CheckUtil.checkSqlExpression(expression)) {
+      return false;
+    }
     String sql = String.format("SELECT rowid, * FROM %s WHERE %s ", CommonUtil.getClassName(clazz),
         expression[0]);
     sql = sql.replace("?", "%s");
diff --git a/Aria/src/main/java/com/arialyy/aria/orm/DelegateFind.java b/Aria/src/main/java/com/arialyy/aria/orm/DelegateFind.java
index ae8e01ad..0bb8dff0 100644
--- a/Aria/src/main/java/com/arialyy/aria/orm/DelegateFind.java
+++ b/Aria/src/main/java/com/arialyy/aria/orm/DelegateFind.java
@@ -15,7 +15,6 @@
  */
 package com.arialyy.aria.orm;
 
-import android.annotation.SuppressLint;
 import android.database.Cursor;
 import android.database.sqlite.SQLiteDatabase;
 import android.text.TextUtils;
@@ -30,10 +29,8 @@ import java.lang.reflect.Field;
 import java.net.URLDecoder;
 import java.util.ArrayList;
 import java.util.Date;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Set;
 
 /**
  * Created by laoyuyu on 2018/3/22.
@@ -201,7 +198,9 @@ class DelegateFind extends AbsDelegate {
             .append(cTableName.concat(".").concat(m.entityColumn()));
         String sql;
         if (expression != null && expression.length > 0) {
-          CheckUtil.checkSqlExpression(expression);
+          if (!CheckUtil.checkSqlExpression(expression)) {
+            return null;
+          }
           sb.append(" WHERE ").append(expression[0]).append(" ");
           sql = sb.toString();
           sql = sql.replace("?", "%s");
@@ -321,7 +320,9 @@ class DelegateFind extends AbsDelegate {
    */
   <T extends DbEntity> List<T> findData(SQLiteDatabase db, Class<T> clazz, String... expression) {
     db = checkDb(db);
-    CheckUtil.checkSqlExpression(expression);
+    if (!CheckUtil.checkSqlExpression(expression)) {
+      return null;
+    }
     String sql = String.format("SELECT rowid, * FROM %s WHERE %s", CommonUtil.getClassName(clazz),
         expression[0]);
     String[] params = new String[expression.length - 1];
@@ -339,7 +340,9 @@ class DelegateFind extends AbsDelegate {
       return null;
     }
     db = checkDb(db);
-    CheckUtil.checkSqlExpression(expression);
+    if (!CheckUtil.checkSqlExpression(expression)) {
+      return null;
+    }
     String sql = String.format("SELECT rowid, * FROM %s WHERE %s LIMIT %s,%s",
         CommonUtil.getClassName(clazz),
         expression[0], (page - 1) * num, num);
diff --git a/Aria/src/main/java/com/arialyy/aria/orm/DelegateUpdate.java b/Aria/src/main/java/com/arialyy/aria/orm/DelegateUpdate.java
index ba1085a6..669e0280 100644
--- a/Aria/src/main/java/com/arialyy/aria/orm/DelegateUpdate.java
+++ b/Aria/src/main/java/com/arialyy/aria/orm/DelegateUpdate.java
@@ -34,13 +34,15 @@ class DelegateUpdate extends AbsDelegate {
   private DelegateUpdate() {
   }
 
-    /**
+  /**
    * 删除某条数据
    */
   synchronized <T extends DbEntity> void delData(SQLiteDatabase db, Class<T> clazz,
       String... expression) {
     db = checkDb(db);
-    CheckUtil.checkSqlExpression(expression);
+    if (!CheckUtil.checkSqlExpression(expression)) {
+      return;
+    }
 
     String sql = "DELETE FROM " + CommonUtil.getClassName(clazz) + " WHERE " + expression[0] + " ";
     sql = sql.replace("?", "%s");
@@ -60,7 +62,7 @@ class DelegateUpdate extends AbsDelegate {
     ContentValues values = createValues(dbEntity);
     if (values != null) {
       db.update(CommonUtil.getClassName(dbEntity), values, "rowid=?",
-          new String[] {String.valueOf(dbEntity.rowID)});
+          new String[] { String.valueOf(dbEntity.rowID) });
     } else {
       ALog.e(TAG, "更新记录失败，记录没有属性字段");
     }
@@ -69,7 +71,7 @@ class DelegateUpdate extends AbsDelegate {
   /**
    * 更新多条记录
    */
-  synchronized <T extends  DbEntity> void updateManyData(SQLiteDatabase db, List<T> dbEntities) {
+  synchronized <T extends DbEntity> void updateManyData(SQLiteDatabase db, List<T> dbEntities) {
     db = checkDb(db);
     db.beginTransaction();
     try {
@@ -84,7 +86,7 @@ class DelegateUpdate extends AbsDelegate {
         if (value == null) {
           ALog.e(TAG, "更新记录失败，记录没有属性字段");
         } else {
-          db.update(table, value, "rowid=?", new String[] {String.valueOf(entity.rowID)});
+          db.update(table, value, "rowid=?", new String[] { String.valueOf(entity.rowID) });
         }
       }
       db.setTransactionSuccessful();
diff --git a/Aria/src/main/java/com/arialyy/aria/util/CheckUtil.java b/Aria/src/main/java/com/arialyy/aria/util/CheckUtil.java
index 8891a0a5..bc453e3a 100644
--- a/Aria/src/main/java/com/arialyy/aria/util/CheckUtil.java
+++ b/Aria/src/main/java/com/arialyy/aria/util/CheckUtil.java
@@ -24,6 +24,7 @@ import com.arialyy.aria.core.upload.UTaskWrapper;
 import com.arialyy.aria.core.upload.UploadEntity;
 import com.arialyy.aria.exception.ParamException;
 import java.io.File;
+import java.util.Arrays;
 import java.util.List;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -68,17 +69,22 @@ public class CheckUtil {
 
   /**
    * 检查sql的expression是否合法
+   *
+   * @return false 不合法
    */
-  public static void checkSqlExpression(String... expression) {
+  public static boolean checkSqlExpression(String... expression) {
     if (expression.length == 0) {
-      throw new IllegalArgumentException("sql语句表达式不能为null");
+      ALog.e(TAG, "sql语句表达式不能为null");
+      return false;
     }
     if (expression.length == 1) {
-      throw new IllegalArgumentException("表达式需要写入参数");
+      ALog.e(TAG, String.format("表达式需要写入参数，参数信息：%s", Arrays.toString(expression)));
+      return false;
     }
     String where = expression[0];
     if (!where.contains("?")) {
-      throw new IllegalArgumentException("请在where语句的'='后编写?");
+      ALog.e(TAG, String.format("请在where语句的'='后编写?，参数信息：%s", Arrays.toString(expression)));
+      return false;
     }
     Pattern pattern = Pattern.compile("\\?");
     Matcher matcher = pattern.matcher(where);
@@ -87,11 +93,14 @@ public class CheckUtil {
       count++;
     }
     if (count < expression.length - 1) {
-      throw new IllegalArgumentException("条件语句的?个数不能小于参数个数");
+      ALog.e(TAG, String.format("条件语句的?个数不能小于参数个数，参数信息：%s", Arrays.toString(expression)));
+      return false;
     }
     if (count > expression.length - 1) {
-      throw new IllegalArgumentException("条件语句的?个数不能大于参数个数");
+      ALog.e(TAG, String.format("条件语句的?个数不能大于参数个数， 参数信息：%s", Arrays.toString(expression)));
+      return false;
     }
+    return true;
   }
 
   /**
diff --git a/app/src/main/assets/aria_config.xml b/app/src/main/assets/aria_config.xml
index 1fb5c1ec..52688d22 100644
--- a/app/src/main/assets/aria_config.xml
+++ b/app/src/main/assets/aria_config.xml
@@ -113,7 +113,7 @@
   <dGroup>
 
     <!--组合任务下载队列最大任务数， 默认为2-->
-    <maxTaskNum value="1"/>
+    <maxTaskNum value="2"/>
 
     <!--设置下载失败，重试次数，默认为10-->
     <reTryNum value="1"/>
@@ -131,7 +131,7 @@
     <!-- =============================以下为子任务的配置====================================-->
 
     <!--能同时下载的子任务最大任务数，默认3-->
-    <subMaxTaskNum value="1"/>
+    <subMaxTaskNum value="5"/>
 
     <!--子任务下载失败时的重试次数，默认为5-->
     <subReTryNum value="5"/>
diff --git a/app/src/main/java/com/arialyy/simple/core/download/multi_download/MultiDownloadActivity.java b/app/src/main/java/com/arialyy/simple/core/download/multi_download/MultiDownloadActivity.java
index 65e4953c..b31d4cd4 100644
--- a/app/src/main/java/com/arialyy/simple/core/download/multi_download/MultiDownloadActivity.java
+++ b/app/src/main/java/com/arialyy/simple/core/download/multi_download/MultiDownloadActivity.java
@@ -76,7 +76,7 @@ public class MultiDownloadActivity extends BaseActivity<ActivityMultiDownloadBin
     Log.d(TAG, task.getTaskName() + ", " + task.getState());
   }
 
-  @Download.onWait void onWait(DownloadTask task){
+  @Download.onWait void onWait(DownloadTask task) {
     mAdapter.updateState(task.getEntity());
   }
 
@@ -139,8 +139,10 @@ public class MultiDownloadActivity extends BaseActivity<ActivityMultiDownloadBin
   }
 
   @DownloadGroup.onTaskFail void groupTaskFail(DownloadGroupTask task) {
-    ALog.d(TAG, String.format("group【%s】fail", task.getTaskName()));
-    mAdapter.updateState(task.getEntity());
+    if (task != null) {
+      ALog.d(TAG, String.format("group【%s】fail", task.getTaskName()));
+      mAdapter.updateState(task.getEntity());
+    }
   }
 
   @DownloadGroup.onTaskComplete void groupTaskComplete(DownloadGroupTask task) {
diff --git a/app/src/main/res/values/strings.xml b/app/src/main/res/values/strings.xml
index 2e4adb69..397f0771 100644
--- a/app/src/main/res/values/strings.xml
+++ b/app/src/main/res/values/strings.xml
@@ -106,16 +106,13 @@
   </string-array>
 
   <string-array name="group_urls">
-    <!--<item>https://res5.d.cn/5a6a3384c1b2be1a65d84b914e6a6fef697637578b6db2eb1056d50b09cf1dcf289d4045df7ef95746e498e3d6a848ab84c89b77aa60194e2c48e5a7cb748265.apk</item>-->
-    <!--<item>https://res5.d.cn/5a6a3384c1b2be1a52034c72752e8475414630ebc69318b84ef584115ebf5eaaab945ae07b7fe3596afc72a7940ff328d4a9553f6ae92d6c09ba4bfb533137f6.apk</item>-->
-    <!--<item>https://res5.d.cn/5a6a3384c1b2be1a426f06bfc69034d69c44ae1a01da180cab8e59bd1a5e1a784bac46ba0c64579d14f0e80a4ce4f068af89b0369a393456f4f449a8829cad5c.apk</item>-->
-    <item>http://static.gaoshouyou.com/d/12/0d/7f120f50c80d2e7b8c4ba24ece4f9cdd.apk</item>
-    <!--<item>http://static.ilongyuan.cn/rayark/RayarkFZ_2.0.7.apk</item>-->
+    <item>https://downs.muzhiwan.com/2019/06/19/com.and.games505.TerrariaPaid5d0a074e451c0.gpk</item>
+    <item>https://downs.muzhiwan.com/2017/03/28/com.xyzstudio_58da07426e959.apk</item>
   </string-array>
 
   <string-array name="group_urls_1">
     <item>http://hzdown.muzhiwan.com/2017/05/08/nl.noio.kingdom_59104935e56f0.apk</item>
-    <item>https://atom-installer.github.com/v1.13.0/AtomSetup.exe1</item>
+    <!--<item>https://atom-installer.github.com/v1.13.0/AtomSetup.exe1</item>-->
     <item>http://hzdown.muzhiwan.com/2017/09/05/com.mir.iphone.empire83jie.mzw_59ae6d5a3638d.apk</item>
   </string-array>
 
@@ -125,8 +122,8 @@
   </string-array>
 
   <string-array name="group_urls_3">
-    <item>http://apk500.bce.baidu-mgame.com/game/883000/883227/20170828102306_oem_5502845.apk?r=1</item>
-    <item>http://static.gaoshouyou.com/d/92/12/5592a647b8126755647abbe8074fde39.apk</item>
+    <item>https://downs.muzhiwan.com/2019/07/23/com.amazid.me_5d36bade614d9.apk</item>
+    <item>https://downs.muzhiwan.com/2019/07/30/com.counter.terrorist.attack.fps.sniper.fight_5d3fe8f0a7edf.apk</item>
   </string-array>
 
   <string-array name="group_url4">
@@ -135,8 +132,8 @@
   </string-array>
 
   <string-array name="group_names">
-    <item>王者荣耀.apk</item>
-    <item>战斗吧剑灵.apk</item>
+    <item>泰拉瑞亚.apk</item>
+    <item>疯狂屁股.apk</item>
     <!--<item>天魔幻想.apk</item>-->
   </string-array>
 
@@ -151,8 +148,8 @@
   </string-array>
 
   <string-array name="group_names_3">
-    <item>部落冲突.apk</item>
-    <item>城堡争霸.apk</item>
+    <item>神奇的绳索英雄.apk</item>
+    <item>自由火力反击.apk</item>
   </string-array>
 
 </resources>
diff --git a/build.gradle b/build.gradle
index 05b0c05b..b0fe1385 100644
--- a/build.gradle
+++ b/build.gradle
@@ -43,7 +43,7 @@ task clean(type: Delete) {
 ext {
   userOrg = 'arialyy'
   groupId = 'com.arialyy.aria'
-  publishVersion = '3.6.6_beta_1'
+  publishVersion = '3.6.6_beta_3'
 //  publishVersion = '1.0.4'  //FTP插件
   repoName='maven'
   desc = 'android 下载框架'