取数平台调整

gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/entity/CsvResultSetHelper.java

@@ -176,6 +176,9 @@ public class CsvResultSetHelper implements ResultSetHelper {
 					if (tmpResult != null && tmpResult.length() > 0) {
 						//tmpResult = DecryptUtils.getInstance().decrypt(tmpResult);
 						tmpResult = DecryptUtils.getInstance().decrypt(tmpResult);
+						if(tmpResult.startsWith("0")){
+							tmpResult = tmpResult + "\t";
+						}
 						System.out.println("tmpResult = " + tmpResult);
 					} // IF OVER
 					result.add(tmpResult);

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

@@ -627,8 +627,9 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 							log.debug("自助指标当前正在执行的任务为：", JSON.toJSONString(bigTaskConditions.get(i)));
 							if (bigTaskConditions.get(i).getBuildPermitted().equals(Global.YES)) {
 								try{
-									connection = HiveHelper.getBigDataDownloadHiveConnection();
 									condition = bigTaskConditions.remove(i); // 移除并获取第一个任务条件
+									bigTaskRunningMap.put(condition.getTaskId(), condition.getTaskId());
+									connection = HiveHelper.getBigDataDownloadHiveConnection();
 									break;
 								}catch (Exception e){
 									log.debug("获取连接异常:", e.getMessage());
@@ -637,7 +638,6 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 								}
 							} // IF OVER
 						} // FOR OVER
-						bigTaskRunningMap.put(condition.getTaskId(), condition.getTaskId());
 						takeFile(condition, connection);
 						bigTaskRunningMap.remove(condition.getTaskId());
 					} // 没有任务则忽略