|
@ -40,7 +40,7 @@ public class ElasticsearchUtil {
|
|
|
|
|
|
private Logger logger = LoggerFactory.getLogger(ElasticsearchUtil.class);
|
|
|
|
|
|
private final String commonParams="xmijk_quota";
|
|
|
private final String commonParams = "xmijk_quota";
|
|
|
|
|
|
@Autowired
|
|
|
private ElasticFactory elasticFactory;
|
|
@ -54,6 +54,8 @@ public class ElasticsearchUtil {
|
|
|
public List excute(String sql, Class clazz, String esType, String esIndex) {
|
|
|
List saveModels = new ArrayList<>();
|
|
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssXX");
|
|
|
SimpleDateFormat dateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
|
try {
|
|
|
//解决 group by之后默认是200的问题
|
|
|
if (sql.toLowerCase().contains("group by")) {
|
|
@ -109,7 +111,13 @@ public class ElasticsearchUtil {
|
|
|
if (heads.get(i).contains("date_histogram")) {
|
|
|
key = "setQuotaDate";
|
|
|
}
|
|
|
value = dateFormat.parse(String.valueOf(value));
|
|
|
try {
|
|
|
//yyyy-MM-dd'T'HH:mm:ssXX
|
|
|
value = dateFormat.parse(String.valueOf(one.get(i)));
|
|
|
} catch (Exception e) {
|
|
|
//yyyy-MM-dd HH:mm:ss
|
|
|
value = dateFormat1.parse(String.valueOf(one.get(i)));
|
|
|
}
|
|
|
// value = DateUtil.strToDate(String.valueOf(value).replace("T00:00:00+0800", " 00:00:00"), "yyyy-MM-dd HH:mm:ss");
|
|
|
}
|
|
|
|
|
@ -121,7 +129,7 @@ public class ElasticsearchUtil {
|
|
|
clazz.getMethod(key, Double.class).invoke(saveModel, value);
|
|
|
} else if (value instanceof java.util.Date) {
|
|
|
clazz.getMethod(key, java.util.Date.class).invoke(saveModel, value);
|
|
|
}else if (value instanceof java.util.List) {
|
|
|
} else if (value instanceof java.util.List) {
|
|
|
clazz.getMethod(key, java.util.List.class).invoke(saveModel, value);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
@ -334,19 +342,19 @@ public class ElasticsearchUtil {
|
|
|
* 获取一级指标的增量、到达量
|
|
|
* 备注:原接口的二级指标对应现在的一级指标
|
|
|
*
|
|
|
* @param startDate 开始时间
|
|
|
* @param endDate 结束时间
|
|
|
* @param area 区域code
|
|
|
* @param level 等级
|
|
|
* @param index 指标
|
|
|
* @param timeLevel 1增量 2到达量
|
|
|
* @param startDate 开始时间
|
|
|
* @param endDate 结束时间
|
|
|
* @param area 区域code
|
|
|
* @param level 等级
|
|
|
* @param index 指标
|
|
|
* @param timeLevel 1增量 2到达量
|
|
|
* @param slaveKey1 一级维度
|
|
|
* @param interval 1日 2周 3月
|
|
|
* @param lowLevel 下个等级
|
|
|
* @param interval 1日 2周 3月
|
|
|
* @param lowLevel 下个等级
|
|
|
* @return
|
|
|
* @throws Exception
|
|
|
*/
|
|
|
public List findDateQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timeLevel, String slaveKey1, String interval, String lowLevel) throws Exception {
|
|
|
public List findDateQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timeLevel, String slaveKey1, String interval, String lowLevel) throws Exception {
|
|
|
|
|
|
//时间格式转换 yyyy-MM-dd转成 2017-07-17T00:00:00+0800
|
|
|
if (StringUtils.isNotEmpty(startDate)) {
|
|
@ -370,33 +378,32 @@ public class ElasticsearchUtil {
|
|
|
low_level = lowLevel;
|
|
|
}
|
|
|
if (SaveModel.teamLevel.equals(low_level)) {
|
|
|
sql.append("select team,teamName,slaveKey1,slaveKey1Name,sum(result1) result1, sum(result2) result2 from " + esIndex + " where ");
|
|
|
sql.append("select team,teamName,slaveKey1,slaveKey1Name,sum(result1) result1, sum(result2) result2,quotaDate from " + esIndex + " where ");
|
|
|
groupBy.append(" group by team,teamName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
} else if (SaveModel.OrgLevel.equals(low_level)) {
|
|
|
sql.append("select hospital,hospitalName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
sql.append("select hospital,hospitalName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2),quotaDate result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by hospital,hospitalName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
} else if (SaveModel.townLevel.equals(low_level)) {
|
|
|
sql.append("select town,townName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by town,townName" );
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
sql.append("select town,townName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2,quotaDate from " + esIndex + " where ");
|
|
|
groupBy.append(" group by town,townName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
} else if (SaveModel.cityLevel.equals(low_level)) {
|
|
|
sql.append("select city,cityName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
sql.append("select city,cityName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2,quotaDate from " + esIndex + " where ");
|
|
|
groupBy.append(" group by city,cityName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (StringUtils.isNotEmpty(area)) {
|
|
|
|
|
|
if (SaveModel.teamLevel.equals(level + "")) {
|
|
|
sql.append(" team='" + area + "'");
|
|
|
} else if (SaveModel.OrgLevel.equals(level + "")) {
|
|
@ -417,7 +424,7 @@ public class ElasticsearchUtil {
|
|
|
if (StringUtils.isNotEmpty(endDate)) {
|
|
|
sql.append(" and quotaDate<='" + endDate + "'");
|
|
|
}
|
|
|
if (StringUtils.isNotEmpty(slaveKey1)&&!commonParams.equals(slaveKey1)) {
|
|
|
if (StringUtils.isNotEmpty(slaveKey1) && !commonParams.equals(slaveKey1)) {
|
|
|
sql.append(" and slaveKey1='" + slaveKey1 + "' ");
|
|
|
}
|
|
|
|
|
@ -479,37 +486,37 @@ public class ElasticsearchUtil {
|
|
|
if (SaveModel.teamLevel.equals(low_level)) {
|
|
|
sql.append("select team,teamName,slaveKey1,slaveKey1Name,slaveKey2,slaveKey2Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by team,teamName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2)||commonParams.equals(slaveKey2)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2) || commonParams.equals(slaveKey2)) {
|
|
|
groupBy.append(",slaveKey2,slaveKey2Name");
|
|
|
}
|
|
|
} else if (SaveModel.OrgLevel.equals(low_level)) {
|
|
|
sql.append("select hospital,hospitalName,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by hospital,hospitalName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2)||commonParams.equals(slaveKey2)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2) || commonParams.equals(slaveKey2)) {
|
|
|
groupBy.append(",slaveKey2,slaveKey2Name");
|
|
|
}
|
|
|
} else if (SaveModel.townLevel.equals(low_level)) {
|
|
|
sql.append("select town,townName,slaveKey1,slaveKey1Name,slaveKey2,slaveKey2Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by town,townName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2)||commonParams.equals(slaveKey2)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2) || commonParams.equals(slaveKey2)) {
|
|
|
groupBy.append(",slaveKey2,slaveKey2Name");
|
|
|
}
|
|
|
} else if (SaveModel.cityLevel.equals(low_level)) {
|
|
|
sql.append("select city,cityName,slaveKey1,slaveKey1Name,slaveKey2,slaveKey2Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by city,cityName");
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1)||commonParams.equals(slaveKey1)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey1) || commonParams.equals(slaveKey1)) {
|
|
|
groupBy.append(",slaveKey1,slaveKey1Name");
|
|
|
}
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2)||commonParams.equals(slaveKey2)) {
|
|
|
if (!org.springframework.util.StringUtils.isEmpty(slaveKey2) || commonParams.equals(slaveKey2)) {
|
|
|
groupBy.append(",slaveKey2,slaveKey2Name");
|
|
|
}
|
|
|
}
|
|
@ -535,10 +542,10 @@ public class ElasticsearchUtil {
|
|
|
if (StringUtils.isNotEmpty(endDate)) {
|
|
|
sql.append(" and quotaDate<='" + endDate + "'");
|
|
|
}
|
|
|
if (StringUtils.isNotBlank(slaveKey1)&&(!commonParams.equals(slaveKey1))) {
|
|
|
if (StringUtils.isNotBlank(slaveKey1) && (!commonParams.equals(slaveKey1))) {
|
|
|
sql.append(" and slaveKey1='" + slaveKey1 + "'");
|
|
|
}
|
|
|
if (StringUtils.isNotBlank(slaveKey2)&&(!commonParams.equals(slaveKey2))) {
|
|
|
if (StringUtils.isNotBlank(slaveKey2) && (!commonParams.equals(slaveKey2))) {
|
|
|
sql.append(" and slaveKey2='" + slaveKey2 + "'");
|
|
|
}
|
|
|
|
|
@ -598,6 +605,7 @@ public class ElasticsearchUtil {
|
|
|
|
|
|
/**
|
|
|
* 获取一个指标下所有一级维度按维度分组的数据
|
|
|
*
|
|
|
* @param startDate
|
|
|
* @param endDate
|
|
|
* @param area
|
|
@ -609,7 +617,7 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
* @throws Exception
|
|
|
*/
|
|
|
public List findDateAllQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timeLevel,String interval, String lowLevel) throws Exception {
|
|
|
public List findDateAllQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timeLevel, String interval, String lowLevel) throws Exception {
|
|
|
|
|
|
//时间格式转换 yyyy-MM-dd转成 2017-07-17T00:00:00+0800
|
|
|
if (StringUtils.isNotEmpty(startDate)) {
|
|
@ -640,7 +648,7 @@ public class ElasticsearchUtil {
|
|
|
groupBy.append(" group by hospital,hospitalName,slaveKey1,slaveKey1Name");
|
|
|
} else if (SaveModel.townLevel.equals(low_level)) {
|
|
|
sql.append("select town,townName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by town,townName,slaveKey1,slaveKey1Name" );
|
|
|
groupBy.append(" group by town,townName,slaveKey1,slaveKey1Name");
|
|
|
} else if (SaveModel.cityLevel.equals(low_level)) {
|
|
|
sql.append("select city,cityName,slaveKey1,slaveKey1Name,sum(result1) result1,sum(result2) result2 from " + esIndex + " where ");
|
|
|
groupBy.append(" group by city,cityName,slaveKey1,slaveKey1Name");
|
|
@ -730,12 +738,17 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel1(String quotaDate, String area, int level, String index, String timelevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel1(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, null, null);
|
|
|
if (list.size() > 0) {
|
|
|
return (SaveModel) list.get(0);
|
|
|
} else {
|
|
|
return null;
|
|
|
}
|
|
|
List list = findDateQuotaLevel1(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 1级维度
|
|
|
* 查询某一天某一个1级维度的某个1级维度下的指标 例如查询65岁以上患者
|
|
@ -748,13 +761,14 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel1NoSlaveKey1(String quotaDate, String area, int level, String index, String timelevel) throws Exception {
|
|
|
List list = findDateQuotaLevel1(quotaDate, quotaDate, area, level, index, timelevel, null, null, null);
|
|
|
List list = findDateQuotaLevel1(quotaDate, quotaDate, area, level, index, timelevel, null, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 1级维度
|
|
|
* 查询某一个时间区间某一个1级维度的某个1级维度下的指标 例如查询65岁以上患者
|
|
|
*
|
|
|
* @param startDate
|
|
|
* @param endDate
|
|
|
* @param area
|
|
@ -764,8 +778,8 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
* @throws Exception
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel1NoSlaveKey1(String startDate, String endDate,String area, int level, String index, String timelevel) throws Exception {
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, null, null, null);
|
|
|
public SaveModel findOneDateQuotaLevel1NoSlaveKey1(String startDate, String endDate, String area, int level, String index, String timelevel) throws Exception {
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, null, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
|
}
|
|
|
|
|
@ -783,10 +797,10 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timelevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, slaveKey1, null, null);
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, slaveKey1, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
|
}
|
|
|
|
|
@ -817,7 +831,7 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findOneDateQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timelevel) throws Exception {
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, commonParams, null, null);
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, commonParams, null, null);
|
|
|
return list;
|
|
|
}
|
|
|
|
|
@ -834,12 +848,12 @@ public class ElasticsearchUtil {
|
|
|
* @param slaveKey2 二级维度的key
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findOneDateQuotaLevel2(String quotaDate, String area, int level, String index, String timelevel, String slaveKey1, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
public List<SaveModel> findOneDateQuotaLevel2(String quotaDate, String area, int level, String index, String timelevel, String slaveKey1, String slaveKey2) throws Exception {
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, slaveKey2, null, null);
|
|
|
return list;
|
|
@ -858,8 +872,8 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel2NoSlaveKey1(String quotaDate, String area, int level, String index, String timelevel, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, null, slaveKey2, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
@ -878,8 +892,8 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel2NoSlaveKey2(String quotaDate, String area, int level, String index, String timelevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, null, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
@ -900,11 +914,11 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public SaveModel findOneDateQuotaLevel2(String startDate, String endDate, String area, int level, String index, String timelevel, String slaveKey1, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(startDate, endDate, area, level, index, timelevel, slaveKey1, slaveKey2, null, null);
|
|
|
return (SaveModel) list.get(0);
|
|
@ -923,8 +937,8 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findOneDateQuotaLevel2(String quotaDate, String area, int level, String index, String timelevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, commonParams, null, null);
|
|
|
return list;
|
|
@ -966,12 +980,13 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findLineChartDateQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timelevel, String interval, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, slaveKey1, interval, null);
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, slaveKey1, interval, null);
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 折线图
|
|
|
* 1级维度
|
|
@ -987,9 +1002,10 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findLineChartDateQuotaLevel1NoSlaveKey1(String startDate, String endDate, String area, int level, String index, String timelevel, String interval) throws Exception {
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, null, interval, null);
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, null, interval, null);
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 折线图
|
|
|
* 2级维度
|
|
@ -1007,11 +1023,11 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findLineChartDateQuotaLevel2(String startDate, String endDate, String area, int level, String index, String timelevel, String interval, String slaveKey1, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(startDate, endDate, area, level, index, timelevel, slaveKey1, slaveKey2, interval, null);
|
|
|
return list;
|
|
@ -1130,12 +1146,13 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findListDateQuotaLevel1(String quotaDate, String area, int level, String index, String timelevel, String lowLevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel1(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, null, lowLevel);
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 列表
|
|
|
* 1级维度
|
|
@ -1170,8 +1187,8 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findListDateQuotaLevel1(String startDate, String endDate, String area, int level, String index, String timelevel, String lowLevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel1(startDate, endDate, area, level, index, timelevel, slaveKey1, null, lowLevel);
|
|
|
return list;
|
|
@ -1193,27 +1210,27 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findListDateQuotaLevel2(String quotaDate, String area, int level, String index, String timelevel, String lowLevel, String slaveKey1, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, slaveKey2, null, lowLevel);
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
public List<SaveModel> findListDateQuotaLevel2NoSlaveKey1(String quotaDate, String area, int level, String index, String timelevel, String lowLevel, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, null, slaveKey2, null, lowLevel);
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
public List<SaveModel> findListDateQuotaLevel2NoSlaveKey2(String quotaDate, String area, int level, String index, String timelevel, String lowLevel, String slaveKey1) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(quotaDate, quotaDate, area, level, index, timelevel, slaveKey1, null, null, lowLevel);
|
|
|
return list;
|
|
@ -1241,11 +1258,11 @@ public class ElasticsearchUtil {
|
|
|
* @return
|
|
|
*/
|
|
|
public List<SaveModel> findListDateQuotaLevel2(String startDate, String endDate, String area, int level, String index, String timelevel, String lowLevel, String slaveKey1, String slaveKey2) throws Exception {
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey1)){
|
|
|
slaveKey1=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey1)) {
|
|
|
slaveKey1 = commonParams;
|
|
|
}
|
|
|
if(org.springframework.util.StringUtils.isEmpty(slaveKey2)){
|
|
|
slaveKey2=commonParams;
|
|
|
if (org.springframework.util.StringUtils.isEmpty(slaveKey2)) {
|
|
|
slaveKey2 = commonParams;
|
|
|
}
|
|
|
List list = findDateQuotaLevel2(startDate, endDate, area, level, index, timelevel, slaveKey1, slaveKey2, null, lowLevel);
|
|
|
return list;
|