Commit 5edf965a by fudahua

队列处理逻辑变更

parent ad563ba5
...@@ -576,8 +576,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -576,8 +576,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
providerLocalTag.traceId = UUID.randomUUID().toString(); providerLocalTag.traceId = UUID.randomUUID().toString();
try{ try{
if (taskConditions != null && taskConditions.size() > 0) { if (taskConditions != null && taskConditions.size() > 0) {
FlatQueryTaskCondition condition = null;
//FlatQueryTaskCondition condition = taskConditions.remove(0); // 移除并获取第一个任务条件 //FlatQueryTaskCondition condition = taskConditions.remove(0); // 移除并获取第一个任务条件
logger.info("总数:{}",taskConditions.size());
for (int i=0; i<taskConditions.size(); i++ ) { for (int i=0; i<taskConditions.size(); i++ ) {
logger.info("[ 自助指标当前正在执行的任务为:]:{}", JSON.toJSONString(taskConditions.get(i))); logger.info("[ 自助指标当前正在执行的任务为:]:{}", JSON.toJSONString(taskConditions.get(i)));
if (taskConditions.get(i).getBuildPermitted().equals(Global.YES) if (taskConditions.get(i).getBuildPermitted().equals(Global.YES)
...@@ -600,6 +600,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -600,6 +600,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
logger.info("加入相应队列-小数据队列:{}", JSONObject.toJSONString(taskConditions.get(i))); logger.info("加入相应队列-小数据队列:{}", JSONObject.toJSONString(taskConditions.get(i)));
smallConditions.add(taskConditions.get(i)); smallConditions.add(taskConditions.get(i));
taskConditions.remove(i); taskConditions.remove(i);
}else{
logger.info("没有相应add");
} }
} // IF OVER } // IF OVER
} // FOR OVER } // FOR OVER
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment