分配

gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/dto/TaskDistCondition.java

+package com.gic.cloud.data.hook.api.dto;
+
+import java.io.Serializable;
+
+public class TaskDistCondition implements Serializable {
+    private TaskDistConditionRange fieldSize;
+    private TaskDistConditionRange resultCount;
+
+    public TaskDistConditionRange getFieldSize() {
+        return fieldSize;
+    }
+
+    public void setFieldSize(TaskDistConditionRange fieldSize) {
+        this.fieldSize = fieldSize;
+    }
+
+    public TaskDistConditionRange getResultCount() {
+        return resultCount;
+    }
+
+    public void setResultCount(TaskDistConditionRange resultCount) {
+        this.resultCount = resultCount;
+    }
+}

gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/dto/TaskDistConditionRange.java

+package com.gic.cloud.data.hook.api.dto;
+
+import java.io.Serializable;
+
+public class TaskDistConditionRange implements Serializable {
+    private int start;
+    private int end;
+
+    public int getStart() {
+        return start;
+    }
+
+    public void setStart(int start) {
+        this.start = start;
+    }
+
+    public int getEnd() {
+        return end;
+    }
+
+    public void setEnd(int end) {
+        this.end = end;
+    }
+}

gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/dto/TaskDistConfig.java

+package com.gic.cloud.data.hook.api.dto;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+public class TaskDistConfig implements Serializable {
+    //快速执行队列
+    private List<TaskDistCondition> fast;
+    //中等可动态队列
+    private List<TaskDistCondition> middle;
+    //慢队列
+    private List<TaskDistCondition> slow;
+
+    public List<TaskDistCondition> getFast() {
+        return fast;
+    }
+
+    public void setFast(List<TaskDistCondition> fast) {
+        this.fast = fast;
+    }
+
+    public List<TaskDistCondition> getMiddle() {
+        return middle;
+    }
+
+    public void setMiddle(List<TaskDistCondition> middle) {
+        this.middle = middle;
+    }
+
+    public List<TaskDistCondition> getSlow() {
+        return slow;
+    }
+
+    public void setSlow(List<TaskDistCondition> slow) {
+        this.slow = slow;
+    }
+}

gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/entity/FlatQueryTaskCondition.java

@@ -196,4 +196,14 @@ public class FlatQueryTaskCondition {
 	public void setAuthStoreIdList(List<String> authStoreIdList) {
 		this.authStoreIdList = authStoreIdList;
 	}
+
+	private int amount;
+
+	public int getAmount() {
+		return amount;
+	}
+
+	public void setAmount(int amount) {
+		this.amount = amount;
+	}
 }

gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/impl/FlatQueryResultServiceImpl.java

@@ -513,6 +513,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 		condition.setOrderField(orderField);
 		condition.setOrderDir(orderDir);
 		condition.setExecDistinct(execDistinct);
+		condition.setAmount(amount);
 		// 设置条件可否执行
 		if (curTask.getApplyPermitted().equals(Global.YES)) {
 			condition.setBuildPermitted(Global.YES);
@@ -617,6 +618,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 		}, interval*1000, interval*1000, TimeUnit.MILLISECONDS);
 	}
 
+	private
+
 
 	/** 下载任务执行计时器 */
 	//private Timer downloadTaskTimer = new Timer();