新增组合任务url重复检查 https://github.com/AriaLyy/Aria/issues/395

初始化任务时，如果url、path有错误将会回调`@Download.onTaskFail`、`@Upload.onTaskFail`、`@DownGroup.onTaskFail`

Aria/src/main/java/com/arialyy/aria/core/common/BaseListener.java

@@ -110,7 +110,7 @@ public abstract class BaseListener<ENTITY extends AbsEntity, TASK_WRAPPER extend
     mEntity.setFailNum(mEntity.getFailNum() + 1);
     saveData(IEntity.STATE_FAIL, mEntity.getCurrentProgress());
     handleSpeed(0);
-    mTask.needRetry = needRetry;
+    mTask.setNeedRetry(needRetry);
     mTask.putExpand(AbsTask.ERROR_INFO_KEY, e);
     sendInState2Target(ISchedulers.FAIL);
     e.printStackTrace();

Aria/src/main/java/com/arialyy/aria/core/common/ftp/AbsFtpInfoThread.java

@@ -257,7 +257,7 @@ public abstract class AbsFtpInfoThread<ENTITY extends AbsEntity, TASK_WRAPPER ex
       charSet = "UTF-8";
       reply = client.sendCommand("OPTS UTF8", "ON");
       if (reply != FTPReply.COMMAND_IS_SUPERFLUOUS) {
-        ALog.i(TAG, "FTP 服务器不支持开启UTF8编码，尝试使用Aria手动设置的编码");
+        ALog.i(TAG, "D_FTP 服务器不支持开启UTF8编码，尝试使用Aria手动设置的编码");
         if (!TextUtils.isEmpty(mTaskWrapper.asFtp().getCharSet())) {
           charSet = mTaskWrapper.asFtp().getCharSet();
         }

Aria/src/main/java/com/arialyy/aria/core/common/ftp/FTPSDelegate.java

@@ -22,7 +22,7 @@ import com.arialyy.aria.core.inf.AbsTarget;
 import com.arialyy.aria.core.inf.ITargetHandler;
 
 /**
- * FTP SSL/TSL 参数委托
+ * D_FTP SSL/TSL 参数委托
  */
 public class FTPSDelegate<TARGET extends AbsTarget> implements ITargetHandler {
   private final String TAG = "FTPSDelegate";

Aria/src/main/java/com/arialyy/aria/core/common/http/HttpHeaderDelegate.java

@@ -29,7 +29,7 @@ import java.util.Set;
 
 /**
  * Created by laoyuyu on 2018/3/9.
- * HTTP header参数设置委托类
+ * D_HTTP header参数设置委托类
  */
 public class HttpHeaderDelegate<TARGET extends AbsTarget>
     implements IHttpHeaderDelegate<TARGET> {

Aria/src/main/java/com/arialyy/aria/core/download/AbsDTarget.java

@@ -42,7 +42,7 @@ abstract class AbsDTarget<TARGET extends AbsDTarget> extends AbsTarget<TARGET> {
    * 6、把任务设置为最高优先级任务后，将自动执行任务，不需要重新调用start()启动任务
    */
   public void setHighestPriority() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       AriaManager.getInstance(AriaManager.APP)
           .setCmd(
               CommonUtil.createNormalCmd(getTaskWrapper(), NormalCmdFactory.TASK_HIGHEST_PRIORITY,

Aria/src/main/java/com/arialyy/aria/core/download/DNormalDelegate.java

@@ -22,6 +22,7 @@ import com.arialyy.aria.core.manager.TaskWrapperManager;
 import com.arialyy.aria.core.queue.DownloadTaskQueue;
 import com.arialyy.aria.orm.DbEntity;
 import com.arialyy.aria.util.ALog;
+import com.arialyy.aria.util.CheckUtil;
 import com.arialyy.aria.util.CommonUtil;
 import java.io.File;
 
@@ -113,10 +114,10 @@ class DNormalDelegate<TARGET extends AbsDTarget> implements INormalTarget {
     }
     File file = new File(filePath);
     if (file.isDirectory()) {
-      if (mTarget.getTargetType() == ITargetHandler.HTTP) {
+      if (mTarget.getTargetType() == ITargetHandler.D_HTTP) {
         ALog.e(TAG, "下载失败，保存路径【" + filePath + "】不能为文件夹，路径需要是完整的文件路径，如：/mnt/sdcard/game.zip");
         return false;
-      } else if (mTarget.getTargetType() == ITargetHandler.FTP) {
+      } else if (mTarget.getTargetType() == ITargetHandler.D_FTP) {
         filePath += mEntity.getFileName();
       }
     } else {
@@ -167,7 +168,7 @@ class DNormalDelegate<TARGET extends AbsDTarget> implements INormalTarget {
     if (TextUtils.isEmpty(url)) {
       ALog.e(TAG, "下载失败，url为null");
       return false;
-    } else if (!url.startsWith("http") && !url.startsWith("ftp")) {
+    } else if (!CheckUtil.checkUrlNotThrow(url)) {
       ALog.e(TAG, "下载失败，url【" + url + "】错误");
       return false;
     }

Aria/src/main/java/com/arialyy/aria/core/download/DownloadTarget.java

@@ -118,7 +118,7 @@ public class DownloadTarget extends AbsDTarget<DownloadTarget>
   }
 
   @Override public int getTargetType() {
-    return HTTP;
+    return D_HTTP;
   }
 
   /**

Aria/src/main/java/com/arialyy/aria/core/download/FtpDownloadTarget.java

@@ -126,7 +126,7 @@ public class FtpDownloadTarget extends AbsDTarget<FtpDownloadTarget>
   }
 
   @Override public int getTargetType() {
-    return FTP;
+    return D_FTP;
   }
 
   @CheckResult

Aria/src/main/java/com/arialyy/aria/core/download/HttpGroupDelegate.java

@@ -22,6 +22,7 @@ import com.arialyy.aria.orm.DbEntity;
 import com.arialyy.aria.util.ALog;
 import com.arialyy.aria.util.CommonUtil;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
@@ -61,11 +62,11 @@ class HttpGroupDelegate extends AbsGroupDelegate<DownloadGroupTarget> {
   @CheckResult
   DownloadGroupTarget setSubFileName(List<String> subTaskFileName) {
     if (subTaskFileName == null || subTaskFileName.isEmpty()) {
-      ALog.e(TAG, "修改子任务的文件名失败：列表为null");
+      ALog.w(TAG, "修改子任务的文件名失败：列表为null");
       return getTarget();
     }
     if (subTaskFileName.size() != getTaskWrapper().getSubTaskWrapper().size()) {
-      ALog.e(TAG, "修改子任务的文件名失败：子任务文件名列表数量和子任务的数量不匹配");
+      ALog.w(TAG, "修改子任务的文件名失败：子任务文件名列表数量和子任务的数量不匹配");
       return getTarget();
     }
     mSubNameTemp.clear();
@@ -179,6 +180,19 @@ class HttpGroupDelegate extends AbsGroupDelegate<DownloadGroupTarget> {
       ALog.e(TAG, "下载失败，子任务下载列表为null");
       return false;
     }
+
+    Set<String> repeated = new HashSet<>();
+    List<String> results = new ArrayList<>();
+    for (String url : mUrls) {
+      if (!repeated.add(url)) {
+        results.add(url);
+      }
+    }
+    if (!results.isEmpty()) {
+      ALog.e(TAG, String.format("组合任务中有url重复，重复的url：%s", Arrays.toString(results.toArray())));
+      return false;
+    }
+
     Set<Integer> delItem = new HashSet<>();
 
     int i = 0;
@@ -188,7 +202,6 @@ class HttpGroupDelegate extends AbsGroupDelegate<DownloadGroupTarget> {
         delItem.add(i);
         continue;
       } else if (!url.startsWith("http")) {
-        //} else if (!url.startsWith("http") && !url.startsWith("ftp")) {
         ALog.e(TAG, "子任务url【" + url + "】错误，即将删除该子任务。");
         delItem.add(i);
         continue;

Aria/src/main/java/com/arialyy/aria/core/download/group/AbsGroupUtil.java

@@ -41,7 +41,7 @@ public abstract class AbsGroupUtil implements IUtil, Runnable {
    */
   int FTP_DIR = 0xa1;
   /**
-   * HTTP 任务组
+   * D_HTTP 任务组
    */
   int HTTP_GROUP = 0xa2;
 

Aria/src/main/java/com/arialyy/aria/core/download/group/DownloadGroupUtil.java

@@ -148,7 +148,7 @@ public class DownloadGroupUtil extends AbsGroupUtil implements IUtil {
 
     mGTWrapper.asHttp().setFileLenAdapter(null);
     synchronized (LOCK) {
-      LOCK.notify();
+      LOCK.notifyAll();
     }
   }
 

Aria/src/main/java/com/arialyy/aria/core/inf/AbsTarget.java

@@ -15,6 +15,8 @@
  */
 package com.arialyy.aria.core.inf;
 
+import android.os.Handler;
+import android.os.Looper;
 import android.support.annotation.CheckResult;
 import android.text.TextUtils;
 import com.arialyy.aria.core.AriaManager;
@@ -25,6 +27,10 @@ import com.arialyy.aria.core.download.DGTaskWrapper;
 import com.arialyy.aria.core.download.DownloadGroupEntity;
 import com.arialyy.aria.core.download.DTaskWrapper;
 import com.arialyy.aria.core.manager.TaskWrapperManager;
+import com.arialyy.aria.core.scheduler.DownloadGroupSchedulers;
+import com.arialyy.aria.core.scheduler.DownloadSchedulers;
+import com.arialyy.aria.core.scheduler.ISchedulers;
+import com.arialyy.aria.core.scheduler.UploadSchedulers;
 import com.arialyy.aria.core.upload.UTaskWrapper;
 import com.arialyy.aria.util.ALog;
 import com.arialyy.aria.util.CommonUtil;
@@ -196,11 +202,41 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
     return taskType;
   }
 
+  /**
+   * 如果检查实体失败，将错误回调
+   */
+  protected boolean checkConfig() {
+    boolean b = checkEntity();
+    ISchedulers schedulers = getScheduler();
+    if (!b && schedulers != null) {
+      new Handler(Looper.getMainLooper(), schedulers).obtainMessage(ISchedulers.FAIL,
+          new TempTask(mTaskWrapper, mEntity)).sendToTarget();
+    }
+
+    return b;
+  }
+
+  private ISchedulers getScheduler() {
+    int type = getTargetType();
+    switch (type) {
+      case D_FTP:
+      case D_HTTP:
+        return DownloadSchedulers.getInstance();
+      case U_FTP:
+      case U_HTTP:
+        return UploadSchedulers.getInstance();
+      case GROUP_HTTP:
+      case GROUP_FTP_DIR:
+        return DownloadGroupSchedulers.getInstance();
+    }
+    return null;
+  }
+
   /**
    * 保存修改
    */
   @Override public void save() {
-    if (!checkEntity()) {
+    if (!checkConfig()) {
       ALog.e(TAG, "保存修改失败");
     } else {
       ALog.i(TAG, "保存成功");
@@ -224,7 +260,8 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
   /**
    * 设置target类型
    *
-   * @return {@link #HTTP}、{@link #FTP}、{@link #GROUP_HTTP}、{@link #GROUP_FTP_DIR}
+   * @return {@link #D_HTTP}、{@link #U_HTTP}、{@link #D_FTP}、{@link #U_FTP}、{@link
+   * #GROUP_HTTP}、{@link #GROUP_FTP_DIR}
    */
   public abstract int getTargetType();
 
@@ -232,7 +269,7 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * 添加任务
    */
   @Override public void add() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       AriaManager.getInstance(AriaManager.APP)
           .setCmd(CommonUtil.createNormalCmd(getTaskWrapper(), NormalCmdFactory.TASK_CREATE,
               checkTaskType()))
@@ -244,7 +281,7 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * 开始任务
    */
   @Override public void start() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       AriaManager.getInstance(AriaManager.APP)
           .setCmd(
               CommonUtil.createNormalCmd(mTaskWrapper, NormalCmdFactory.TASK_START,
@@ -259,13 +296,13 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * @see #stop()
    */
   @Deprecated public void pause() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       stop();
     }
   }
 
   @Override public void stop() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       AriaManager.getInstance(AriaManager.APP)
           .setCmd(
               CommonUtil.createNormalCmd(mTaskWrapper, NormalCmdFactory.TASK_STOP, checkTaskType()))
@@ -277,7 +314,7 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * 恢复任务
    */
   @Override public void resume() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       AriaManager.getInstance(AriaManager.APP)
           .setCmd(
               CommonUtil.createNormalCmd(mTaskWrapper, NormalCmdFactory.TASK_START,
@@ -290,7 +327,7 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * 删除任务
    */
   @Override public void cancel() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       AriaManager.getInstance(AriaManager.APP)
           .setCmd(CommonUtil.createNormalCmd(mTaskWrapper, NormalCmdFactory.TASK_CANCEL,
               checkTaskType()))
@@ -302,7 +339,7 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * 任务重试
    */
   @Override public void reTry() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       List<ICmd> cmds = new ArrayList<>();
       int taskType = checkTaskType();
       cmds.add(
@@ -319,7 +356,7 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * {@code false}如果任务已经完成，只删除任务数据库记录，
    */
   @Override public void cancel(boolean removeFile) {
-    if (checkEntity()) {
+    if (checkConfig()) {
       CancelCmd cancelCmd =
           (CancelCmd) CommonUtil.createNormalCmd(mTaskWrapper, NormalCmdFactory.TASK_CANCEL,
               checkTaskType());
@@ -332,9 +369,80 @@ public abstract class AbsTarget<TARGET extends AbsTarget> implements ITargetHand
    * 重新下载
    */
   @Override public void reStart() {
-    if (checkEntity()) {
+    if (checkConfig()) {
       cancel();
       start();
     }
   }
+
+  private static class TempTask implements ITask {
+
+    private AbsTaskWrapper wrapper;
+    private AbsEntity entity;
+
+    private TempTask(AbsTaskWrapper wrapper, AbsEntity entity) {
+      this.wrapper = wrapper;
+      this.entity = entity;
+    }
+
+    @Override public int getTaskType() {
+      return TEMP;
+    }
+
+    @Override public int getState() {
+      return entity.getState();
+    }
+
+    @Override public String getKey() {
+      return entity.getKey();
+    }
+
+    @Override public boolean isRunning() {
+      return false;
+    }
+
+    @Override public AbsTaskWrapper getTaskWrapper() {
+      return wrapper;
+    }
+
+    @Override public void start() {
+
+    }
+
+    @Override public void stop() {
+
+    }
+
+    @Override public void stop(int type) {
+
+    }
+
+    @Override public void cancel() {
+
+    }
+
+    @Override public Object getExpand(String key) {
+      return null;
+    }
+
+    @Override public boolean isStop() {
+      return false;
+    }
+
+    @Override public boolean isCancel() {
+      return false;
+    }
+
+    @Override public boolean isNeedRetry() {
+      return false;
+    }
+
+    @Override public String getTaskName() {
+      return "TempTask";
+    }
+
+    @Override public int getSchedulerType() {
+      return TaskSchedulerType.TYPE_DEFAULT;
+    }
+  }
 }

Aria/src/main/java/com/arialyy/aria/core/inf/AbsTask.java

@@ -32,9 +32,9 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
   public static final String ERROR_INFO_KEY = "ERROR_INFO_KEY";
 
   /**
-   * 是否需要重试，默认为true
+   * 是否需要重试，默认为false
    */
-  public boolean needRetry = true;
+  private boolean needRetry = true;
   protected TASK_WRAPPER mTaskWrapper;
   protected Handler mOutHandler;
   protected Context mContext;
@@ -76,9 +76,18 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
     mExpand.put(key, obj);
   }
 
+  @Override public boolean isNeedRetry() {
+    return needRetry;
+  }
+
+  public void setNeedRetry(boolean needRetry) {
+    this.needRetry = needRetry;
+  }
+
   /**
    * 读取扩展数据
    */
+  @Override
   public Object getExpand(String key) {
     return mExpand.get(key);
   }
@@ -106,7 +115,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
   /**
    * 获取当前下载进度
    */
-  @Override public long getCurrentProgress() {
+  public long getCurrentProgress() {
     return mTaskWrapper.getEntity().getCurrentProgress();
   }
 
@@ -115,7 +124,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    *
    * @return 如：已经下载3mb的大小，则返回{@code 3mb}
    */
-  @Override public String getConvertCurrentProgress() {
+  public String getConvertCurrentProgress() {
     if (mTaskWrapper.getEntity().getCurrentProgress() == 0) {
       return "0b";
     }
@@ -127,7 +136,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    *
    * @return 如果文件长度为0，则返回0m，否则返回转换后的长度1b、1kb、1mb、1gb、1tb
    */
-  @Override public String getConvertFileSize() {
+  public String getConvertFileSize() {
     if (mTaskWrapper.getEntity().getFileSize() == 0) {
       return "0mb";
     }
@@ -137,7 +146,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
   /**
    * 获取文件大小
    */
-  @Override public long getFileSize() {
+  public long getFileSize() {
     return mTaskWrapper.getEntity().getFileSize();
   }
 
@@ -146,7 +155,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    *
    * @return 返回百分比进度，如果文件长度为0，返回0
    */
-  @Override public int getPercent() {
+  public int getPercent() {
     if (mTaskWrapper.getEntity().getFileSize() == 0) {
       return 0;
     }
@@ -217,6 +226,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
   /**
    * 任务的调度类型
    */
+  @Override
   public int getSchedulerType() {
     return mSchedulerType;
   }
@@ -226,6 +236,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    *
    * @return {@code true}任务已经取消
    */
+  @Override
   public boolean isCancel() {
     return isCancel;
   }
@@ -235,6 +246,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    *
    * @return {@code true}任务已经停止
    */
+  @Override
   public boolean isStop() {
     return isStop;
   }
@@ -256,7 +268,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    * </pre>
    * 才能生效
    */
-  @Override public long getSpeed() {
+  public long getSpeed() {
     return mTaskWrapper.getEntity().getSpeed();
   }
 
@@ -277,7 +289,7 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
    * </pre>
    * 才能生效
    */
-  @Override public String getConvertSpeed() {
+  public String getConvertSpeed() {
     return mTaskWrapper.getEntity().getConvertSpeed();
   }
 
@@ -285,11 +297,6 @@ public abstract class AbsTask<ENTITY extends AbsEntity, TASK_WRAPPER extends Abs
     return mTaskWrapper;
   }
 
-  /**
-   * 获取任务名，也就是文件名
-   */
-  public abstract String getTaskName();
-
   public boolean isHighestPriorityTask() {
     return isHeighestTask;
   }

Aria/src/main/java/com/arialyy/aria/core/inf/AbsTaskWrapper.java

@@ -39,11 +39,6 @@ public abstract class AbsTaskWrapper<ENTITY extends AbsEntity>
    */
   private boolean refreshInfo = false;
 
-  /**
-   * 任务状态，和Entity的state同步
-   */
-  private int state = IEntity.STATE_WAIT;
-
   /**
    * 是否是新任务，{@code true} 新任务
    */
@@ -142,7 +137,6 @@ public abstract class AbsTaskWrapper<ENTITY extends AbsEntity>
   }
 
   public void setState(int state) {
-    this.state = state;
     entity.setState(state);
   }
 

Aria/src/main/java/com/arialyy/aria/core/inf/IHttpHeaderDelegate.java

@@ -22,7 +22,7 @@ import java.util.Map;
 
 /**
  * Created by laoyuyu on 2018/3/9.
- * HTTP Header功能接口
+ * D_HTTP Header功能接口
  */
 public interface IHttpHeaderDelegate<TARGET extends ITargetHandler> {
 

Aria/src/main/java/com/arialyy/aria/core/inf/ITargetHandler.java

@@ -20,12 +20,14 @@ package com.arialyy.aria.core.inf;
  * 任务接收器的控制接口，处理添加任务、开始任务、停止任务、删除任务等功能
  */
 public interface ITargetHandler {
-  int HTTP = 1;
+  int D_HTTP = 1;
-  int FTP = 2;
+  int U_HTTP = 2;
+  int U_FTP = 3;
+  int D_FTP = 4;
   //HTTP任务组
-  int GROUP_HTTP = 3;
+  int GROUP_HTTP = 5;
   //FTP文件夹
-  int GROUP_FTP_DIR = 4;
+  int GROUP_FTP_DIR = 6;
 
   /**
    * 添加任务

Aria/src/main/java/com/arialyy/aria/core/inf/ITask.java

@@ -41,6 +41,10 @@ public interface ITask<TASK_WRAPPER extends AbsTaskWrapper> {
    * 组合任务的子任务
    */
   int DOWNLOAD_GROUP_SUB = 4;
+  /**
+   * 填充的
+   */
+  int TEMP = 5;
   /**
    * 未知
    */
@@ -95,39 +99,41 @@ public interface ITask<TASK_WRAPPER extends AbsTaskWrapper> {
   void cancel();
 
   /**
-   * 原始byte速度
+   * 读取扩展数据
    */
-  long getSpeed();
+  Object getExpand(String key);
 
   /**
-   * 转换单位后的速度
+   * 任务是否停止了
+   *
+   * @return {@code true}任务已经停止
    */
-  String getConvertSpeed();
+  boolean isStop();
 
   /**
-   * 获取百分比进度
+   * 任务是否取消了
+   *
+   * @return {@code true}任务已经取消
    */
-  int getPercent();
+  boolean isCancel();
 
   /**
-   * 原始文件byte长度
+   * 任务是否需要重试
+   *
+   * @return {@code true}任务已经取消
    */
-  long getFileSize();
+  boolean isNeedRetry();
 
   /**
-   * 转换单位后的文件长度
+   * 获取任务名，也就是文件名
    */
-  String getConvertFileSize();
+  String getTaskName();
 
   /**
-   * 获取当前进度
+   * 任务的调度类型
+   * {@link TaskSchedulerType}
    */
-  long getCurrentProgress();
+  int getSchedulerType();
+
 
-  /**
-   * 获取单位转换后的进度
-   *
-   * @return 返回 3mb
-   */
-  String getConvertCurrentProgress();
 }

Aria/src/main/java/com/arialyy/aria/core/queue/ITaskQueue.java

@@ -22,13 +22,14 @@ import com.arialyy.aria.core.download.DownloadTask;
 import com.arialyy.aria.core.download.DTaskWrapper;
 import com.arialyy.aria.core.inf.AbsTask;
 import com.arialyy.aria.core.inf.AbsTaskWrapper;
+import com.arialyy.aria.core.inf.ITask;
 import com.arialyy.aria.core.upload.UploadTask;
 import com.arialyy.aria.core.upload.UTaskWrapper;
 
 /**
  * Created by lyy on 2016/8/16. 任务功能接口
  */
-public interface ITaskQueue<TASK extends AbsTask, TASK_WRAPPER extends AbsTaskWrapper> {
+public interface ITaskQueue<TASK extends ITask, TASK_WRAPPER extends AbsTaskWrapper> {
 
   /**
    * 通过key跑断任务是在存在

Aria/src/main/java/com/arialyy/aria/core/scheduler/AbsSchedulers.java

@@ -45,7 +45,7 @@ import java.util.concurrent.TimeUnit;
 /**
  * Created by lyy on 2017/6/4. 事件调度器，用于处理任务状态的调度
  */
-abstract class AbsSchedulers<TASK_ENTITY extends AbsTaskWrapper, TASK extends AbsTask,
+abstract class AbsSchedulers<TASK_ENTITY extends AbsTaskWrapper, TASK extends ITask,
     QUEUE extends ITaskQueue<TASK, TASK_ENTITY>> implements ISchedulers {
   private final String TAG = "AbsSchedulers";
 
@@ -273,7 +273,8 @@ abstract class AbsSchedulers<TASK_ENTITY extends AbsTaskWrapper, TASK extends Ab
           listener.onTaskComplete(task);
           break;
         case FAIL:
-          listener.onTaskFail(task, (Exception) task.getExpand(AbsTask.ERROR_INFO_KEY));
+          listener.onTaskFail(task.getTaskType() == ITask.TEMP ? null : task,
+              (Exception) task.getExpand(AbsTask.ERROR_INFO_KEY));
           break;
         case NO_SUPPORT_BREAK_POINT:
           listener.onNoSupportBreakPoint(task);
@@ -290,12 +291,13 @@ abstract class AbsSchedulers<TASK_ENTITY extends AbsTaskWrapper, TASK extends Ab
     if (!canSend) {
       return;
     }
-    if (task.getTaskType() == ITask.DOWNLOAD || task.getTaskType() == ITask.DOWNLOAD_GROUP) {
+    int type = task.getTaskType();
+    if (type == ITask.DOWNLOAD || type == ITask.DOWNLOAD_GROUP) {
       AriaManager.APP.sendBroadcast(
-          createData(state, task.getTaskType(), task.getTaskWrapper().getEntity()));
+          createData(state, type, task.getTaskWrapper().getEntity()));
-    } else if (task.getTaskType() == ITask.UPLOAD) {
+    } else if (type == ITask.UPLOAD) {
       AriaManager.APP.sendBroadcast(
-          createData(state, task.getTaskType(), task.getTaskWrapper().getEntity()));
+          createData(state, type, task.getTaskWrapper().getEntity()));
     } else {
       ALog.w(TAG, "发送广播失败，没有对应的任务");
     }
@@ -326,7 +328,7 @@ abstract class AbsSchedulers<TASK_ENTITY extends AbsTaskWrapper, TASK extends Ab
    * @param task 下载任务
    */
   private void handleFailTask(final TASK task) {
-    if (!task.needRetry || task.isStop() || task.isCancel()) {
+    if (!task.isNeedRetry() || task.isStop() || task.isCancel()) {
       mQueue.removeTaskFormQueue(task.getKey());
       startNextTask(task);
       callback(FAIL, task);

Aria/src/main/java/com/arialyy/aria/core/upload/FtpUploadTarget.java

@@ -99,6 +99,6 @@ public class FtpUploadTarget extends AbsUploadTarget<FtpUploadTarget>
   }
 
   @Override public int getTargetType() {
-    return FTP;
+    return U_FTP;
   }
 }

Aria/src/main/java/com/arialyy/aria/core/upload/UNormalDelegate.java

@@ -22,6 +22,7 @@ import com.arialyy.aria.core.manager.TaskWrapperManager;
 import com.arialyy.aria.core.queue.UploadTaskQueue;
 import com.arialyy.aria.orm.DbEntity;
 import com.arialyy.aria.util.ALog;
+import com.arialyy.aria.util.CheckUtil;
 import com.arialyy.aria.util.CommonUtil;
 import java.io.File;
 
@@ -121,7 +122,7 @@ class UNormalDelegate<TARGET extends AbsUploadTarget> implements INormalTarget {
     if (TextUtils.isEmpty(url)) {
       ALog.e(TAG, "上传失败，url为null");
       return false;
-    } else if (!url.startsWith("http") && !url.startsWith("ftp")) {
+    } else if (!CheckUtil.checkUrlNotThrow(url)) {
       ALog.e(TAG, "上传失败，url【" + url + "】错误");
       return false;
     }

Aria/src/main/java/com/arialyy/aria/core/upload/UploadTarget.java

@@ -120,6 +120,6 @@ public class UploadTarget extends AbsUploadTarget<UploadTarget>
   }
 
   @Override public int getTargetType() {
-    return HTTP;
+    return U_HTTP;
   }
 }

Aria/src/main/java/com/arialyy/aria/core/upload/uploader/FtpThreadTask.java

@@ -35,7 +35,7 @@ import java.io.IOException;
 import java.io.UnsupportedEncodingException;
 
 /**
- * Created by Aria.Lao on 2017/7/28. FTP 单线程上传任务，需要FTP 服务器给用户打开append和write的权限
+ * Created by Aria.Lao on 2017/7/28. D_FTP 单线程上传任务，需要FTP 服务器给用户打开append和write的权限
  */
 class FtpThreadTask extends AbsFtpThreadTask<UploadEntity, UTaskWrapper> {
   private final String TAG = "FtpThreadTask";

Aria/src/main/java/com/arialyy/aria/util/CheckUtil.java

@@ -118,7 +118,7 @@ public class CheckUtil {
   public static void checkUrlInvalidThrow(String url) {
     if (TextUtils.isEmpty(url)) {
       throw new IllegalArgumentException("url不能为null");
-    } else if (!url.startsWith("http") && !url.startsWith("ftp")) {
+    } else if (!url.startsWith("http") && !url.startsWith("ftp") && !url.startsWith("sftp")) {
       throw new IllegalArgumentException("url错误");
     }
     int index = url.indexOf("://");
@@ -133,7 +133,7 @@ public class CheckUtil {
   public static void checkUrl(String url) {
     if (TextUtils.isEmpty(url)) {
       throw new NullPointerException("url为空");
-    } else if (!url.startsWith("http") && !url.startsWith("ftp")) {
+    } else if (!url.startsWith("http") && !url.startsWith("ftp") && !url.startsWith("sftp")) {
       throw new IllegalArgumentException(String.format("url【%s】错误", url));
     }
     int index = url.indexOf("://");
@@ -151,7 +151,7 @@ public class CheckUtil {
     if (TextUtils.isEmpty(url)) {
       ALog.e(TAG, "url不能为null");
       return false;
-    } else if (!url.startsWith("http") && !url.startsWith("ftp")) {
+    } else if (!url.startsWith("http") && !url.startsWith("ftp") && !url.startsWith("sftp")) {
       ALog.e(TAG, "url【" + url + "】错误");
       return false;
     }

DEV_LOG.md

@@ -1,5 +1,5 @@
 ## 开发日志
-  + v_3.6.4
+  + v_3.6.4 (2019/5/16)
     - 优化任务接收器的代码结构
     - 修复`DbEntity.saveAll()`失败的问题
     - 修复分块任务重命名失败的问题
@@ -10,7 +10,7 @@
     - fix bug https://github.com/AriaLyy/Aria/issues/388
     - 修复使用`Content-Disposition`的文件名时，第一次下载无法重命名文件的问题
     - 修复使用`Content-Disposition`的文件名时，多次重命名文件的问题
-    - 组合任务新增`unknownSize()`，用于处理组合任务大小未知的情况，https://github.com/AriaLyy/Aria/issues/380
+    - 组合任务新增`unknownSize()`，用于处理组合任务大小ø未知的情况，https://github.com/AriaLyy/Aria/issues/380
     - 优化`AbsThreadTask`代码
     - 新增文件长度处理功能 https://github.com/AriaLyy/Aria/issues/393
       ```java
@@ -27,6 +27,8 @@
     - 优化`isRunning()`的逻辑，任务是否在执行的判断将更加准确
     - 修复多次重复快速点击`暂停、开始`时，任务有可能重复下载的问题
     - 修复组合任务中没有等待中的只任务实体保存失败的问题
+    - 新增组合任务url重复检查 https://github.com/AriaLyy/Aria/issues/395
+    - 初始化任务时，如果url、path有错误将会回调`@Download.onTaskFail`、`@Upload.onTaskFail`、`@DownGroup.onTaskFail`
   + v_3.6.3 (2019/4/2)
     - fix bug https://github.com/AriaLyy/Aria/issues/377
   + v_3.6.2 (2019/4/1)

README.md

@@ -42,8 +42,8 @@ Aria有以下特点：
 [![Compiler](https://api.bintray.com/packages/arialyy/maven/AriaCompiler/images/download.svg)](https://bintray.com/arialyy/maven/AriaCompiler/_latestVersion)
 
 ```java
-compile 'com.arialyy.aria:aria-core:3.6.3'
+compile 'com.arialyy.aria:aria-core:3.6.4'
-annotationProcessor 'com.arialyy.aria:aria-compiler:3.6.3'
+annotationProcessor 'com.arialyy.aria:aria-compiler:3.6.4'
 ```
 如果出现android support依赖错误，请将 `compile 'com.arialyy.aria:aria-core:<last-version>'`替换为
 ```
@@ -113,12 +113,36 @@ protected void onCreate(Bundle savedInstanceState) {
 
 
 ### 版本日志
-* v3.6.3 (2019/4/2)
+ + v_3.6.4 (2019/5/16)
-  - fix bug https://github.com/AriaLyy/Aria/issues/368
+    - 优化任务接收器的代码结构
-  - 增加gradle 5.0支持
+    - 修复`DbEntity.saveAll()`失败的问题
-  - fix bug https://github.com/AriaLyy/Aria/issues/374
+    - 修复分块任务重命名失败的问题
-  - fix bug https://github.com/AriaLyy/Aria/issues/377
+    - fix bug https://github.com/AriaLyy/Aria/issues/379
-  - 增加分页获取任务列表api, 详情见：https://aria.laoyuyu.me/aria_doc/api/task_list.html#%E4%BB%BB%E5%8A%A1%E5%88%97%E8%A1%A8%E5%88%86%E9%A1%B5%EF%BC%88362%E4%BB%A5%E4%B8%8A%E7%89%88%E6%9C%AC%E6%94%AF%E6%8C%81%EF%BC%89
+    - 移除`getDownloadTask(String url)`、`getGroupTask(List<String> urls)`、`getFtpDirTask(String path)`
+      等获取任务的api，如果你希望获取对应状态，请使用实体的状态判断，如：`getDownloadEntity()`、`getDownloadGroupEntity()`
+      `getFtpDirEntity()`
+    - fix bug https://github.com/AriaLyy/Aria/issues/388
+    - 修复使用`Content-Disposition`的文件名时，第一次下载无法重命名文件的问题
+    - 修复使用`Content-Disposition`的文件名时，多次重命名文件的问题
+    - 组合任务新增`unknownSize()`，用于处理组合任务大小ø未知的情况，https://github.com/AriaLyy/Aria/issues/380
+    - 优化`AbsThreadTask`代码
+    - 新增文件长度处理功能 https://github.com/AriaLyy/Aria/issues/393
+      ```java
+      .setFileLenAdapter(new IHttpFileLenAdapter() {
+        @Override public long handleFileLen(Map<String, List<String>> headers) {
+          ...
+          // 处理header中的文件长度
+
+          return fileLen;
+        }
+       })
+      ```
+    - 修复组合任务多次回调`onStop`注解的问题
+    - 优化`isRunning()`的逻辑，任务是否在执行的判断将更加准确
+    - 修复多次重复快速点击`暂停、开始`时，任务有可能重复下载的问题
+    - 修复组合任务中没有等待中的只任务实体保存失败的问题
+    - 新增组合任务url重复检查 https://github.com/AriaLyy/Aria/issues/395
+    - 初始化任务时，如果url、path有错误将会回调`@Download.onTaskFail`、`@Upload.onTaskFail`、`@DownGroup.onTaskFail`
 
 [更多版本记录](https://github.com/AriaLyy/Aria/blob/master/DEV_LOG.md)
 

app/src/main/java/com/arialyy/simple/base/BaseApplication.java

@@ -24,7 +24,7 @@ import com.arialyy.aria.core.Aria;
 import com.arialyy.frame.core.AbsFrame;
 import com.arialyy.simple.BuildConfig;
 import com.arialyy.simple.common.ConnectionChangeReceiver;
-import com.squareup.leakcanary.LeakCanary;
+//import com.squareup.leakcanary.LeakCanary;
 
 /**
  * Created by Lyy on 2016/9/27.
@@ -45,18 +45,15 @@ public class BaseApplication extends Application {
           .build());
       StrictMode.setThreadPolicy(
           new StrictMode.ThreadPolicy.Builder().detectAll().penaltyLog().build());
-      if (LeakCanary.isInAnalyzerProcess(this)) {//1
+      //if (LeakCanary.isInAnalyzerProcess(this)) {//1
         // This process is dedicated to LeakCanary for heap analysis.
         // You should not init your app in this process.
-        return;
+        //return;
+      //}
+      //LeakCanary.install(this);
   }
-      LeakCanary.install(this);
-  }
-
-  registerReceiver(new ConnectionChangeReceiver(),
-        new
 
-  IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
+  //registerReceiver(new ConnectionChangeReceiver(), new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
 }
 
   public static BaseApplication getApp() {

app/src/main/java/com/arialyy/simple/core/download/FtpDownloadActivity.java

@@ -35,7 +35,7 @@ import java.io.File;
  * Ftp下载测试
  */
 public class FtpDownloadActivity extends BaseActivity<ActivityFtpDownloadBinding> {
-  private final String URL = "ftp://9.9.9.205:2121/Cyberduck-6.9.4.30164.zip";
+  private final String URL = "sftp://9.9.9.205:2222/Cyberduck-6.9.4.30164.zip";
   //private final String URL = "ftp://182.92.180.213:21/video/572fed5c2ad48_1024.jpg";
   //private final String URL = "ftp://182.92.180.213:21/DATA/20180205/rar/1111.rar";
   //private final String URL = "ftp://d:d@dygodj8.com:12311/咖啡风暴HD大陆公映意语中字[飘花www.piaohua.com].mp4";
@@ -60,8 +60,9 @@ public class FtpDownloadActivity extends BaseActivity<ActivityFtpDownloadBinding
     switch (view.getId()) {
       case R.id.start:
         Aria.download(this).loadFtp(URL)
-            .login("lao", "123456")
+            .login("N0rI", "0qcK")
-            .setFilePath("/mnt/sdcard/").start();
+            .setFilePath("/mnt/sdcard/", true)
+            .start();
         break;
       case R.id.stop:
         Aria.download(this).loadFtp(URL).stop();

app/src/main/java/com/arialyy/simple/core/download/SingleTaskActivity.java

@@ -22,6 +22,7 @@ import android.content.Intent;
 import android.graphics.Bitmap;
 import android.os.Bundle;
 import android.os.Environment;
+import android.os.Handler;
 import android.text.TextUtils;
 import android.util.Log;
 import android.view.Menu;
@@ -37,7 +38,6 @@ import com.arialyy.aria.core.download.DTaskWrapper;
 import com.arialyy.aria.core.download.DownloadEntity;
 import com.arialyy.aria.core.download.DownloadTarget;
 import com.arialyy.aria.core.download.DownloadTask;
-import com.arialyy.aria.core.inf.AbsHttpFileLenAdapter;
 import com.arialyy.aria.core.inf.IEntity;
 import com.arialyy.aria.core.inf.IHttpFileLenAdapter;
 import com.arialyy.aria.core.scheduler.ISchedulers;
@@ -317,7 +317,7 @@ public class SingleTaskActivity extends BaseActivity<ActivitySingleBinding> {
         //.addHeader("Cookie", "BAIDUID=648E5FF020CC69E8DD6F492D1068AAA9:FG=1; BIDUPSID=648E5FF020CC69E8DD6F492D1068AAA9; PSTM=1519099573; BD_UPN=12314753; locale=zh; BDSVRTM=0")
         .useServerFileName(true)
         .setFilePath(path, true)
-        .setFileLenAdapter(new AbsHttpFileLenAdapter() {
+        .setFileLenAdapter(new IHttpFileLenAdapter() {
           @Override public long handleFileLen(Map<String, List<String>> headers) {
 
             List<String> sLength = headers.get("Content-Length");

build.gradle

@@ -43,7 +43,7 @@ task clean(type: Delete) {
 ext {
   userOrg = 'arialyy'
   groupId = 'com.arialyy.aria'
-  publishVersion = '3.6.4_dev_2'
+  publishVersion = '3.6.4'
 //  publishVersion = '1.0.4'  //FTP插件
   repoName='maven'
   desc = 'android 下载框架'