Skip to content

A
aroad_aqsc
提交 546bd6ca authored 作者: 董吉利's avatar 董吉利
浏览文件
操作

queryHighWayAll(),queryHighWay()修改了highwayNames的属性名称

上级 3cb97e26
显示空白字符变更
内嵌 并排
正在显示 包含 58 行增加 和 21 行删除
src/main/java/com/elephant/framework/galaxy/aroad/bigdata/EsUtil_fanshe.java
浏览文件 @ 546bd6ca
...@@ -638,17 +638,18 @@ public class EsUtil_fanshe { ...@@ -638,17 +638,18 @@ public class EsUtil_fanshe {
.mustNot(QueryBuilders.matchPhraseQuery("dengjimingcheng", "高速")) .mustNot(QueryBuilders.matchPhraseQuery("dengjimingcheng", "高速"))
.mustNot(QueryBuilders.matchPhraseQuery("dengjimingcheng", "等外")); .mustNot(QueryBuilders.matchPhraseQuery("dengjimingcheng", "等外"));
searchRequestBuilder.setQuery(boolQueryBuilder); searchRequestBuilder.setQuery(boolQueryBuilder);
String[] highwayNames = {"id", String[] highwayNames = {
"id",
"luxianbianhao", "luxianbianhao",
"quhuadaima", "quhuadaima",
"luxianmingcheng", "luxianmingcheng",
"qidianmingcheng", "qidianmingcheng",
"zhidianmingcheng", "zhidianmingcheng",
"Qidianzhuanghao", "qidianzhuanghaoa",
"zhidianzhuanghao", "zhidianzhuanghao",
"licheng", "licheng",
"lichengjisuan", "lichengjisuan",
"sanDlicheng", "sandlicheng",
"dengjidaima", "dengjidaima",
"dengjimingcheng", "dengjimingcheng",
"chedaodaima", "chedaodaima",
...@@ -664,7 +665,7 @@ public class EsUtil_fanshe { ...@@ -664,7 +665,7 @@ public class EsUtil_fanshe {
"duantoulu", "duantoulu",
"chongfubianma", "chongfubianma",
"chongfuxuhao", "chongfuxuhao",
"qidianzhuanghao", "qidianzhuanghaob",
"zhongdianzhuanghao", "zhongdianzhuanghao",
"yanghulicheng", "yanghulicheng",
"qingyulicheng", "qingyulicheng",
...@@ -686,7 +687,7 @@ public class EsUtil_fanshe { ...@@ -686,7 +687,7 @@ public class EsUtil_fanshe {
"qidianfenjiedianleixing", "qidianfenjiedianleixing",
"zhidianfenjiedianleixing", "zhidianfenjiedianleixing",
"shengjichurukou", "shengjichurukou",
"GBMlicheng", "gbmlicheng",
"yangbanlicheng", "yangbanlicheng",
"tongcheriqi", "tongcheriqi",
"luxiandifangmingcheng", "luxiandifangmingcheng",
...@@ -696,7 +697,7 @@ public class EsUtil_fanshe { ...@@ -696,7 +697,7 @@ public class EsUtil_fanshe {
"luduanleixingdaima", "luduanleixingdaima",
"luduanleixing", "luduanleixing",
"guanyangdanweimingcheng", "guanyangdanweimingcheng",
"MQI", "mqi",
"pingdingdengji", "pingdingdengji",
"shoufeixingzhi", "shoufeixingzhi",
"biangengyuanyindaima", "biangengyuanyindaima",
...@@ -747,11 +748,44 @@ public class EsUtil_fanshe { ...@@ -747,11 +748,44 @@ public class EsUtil_fanshe {
//获取私有的属性字段 //获取私有的属性字段
Field[] beanFiled = clazz.getDeclaredFields(); Field[] beanFiled = clazz.getDeclaredFields();
basehighwayalldata.setId(hit.getId()); basehighwayalldata.setId(hit.getId());
for (int a = 1; a < highwayNames.length; a++) { for (int z = 1; z < highwayNames.length; z++) {
//暴力破解 try {
beanFiled[a].setAccessible(true); //强制反射,让private 的属性也可以访问
//给路段属性复制 beanFiled[z].setAccessible(true);
beanFiled[a].set(basehighwayalldata, sourceAsMap.get(highwayNames[a]) == null ? "" : sourceAsMap.get(highwayNames[a]).toString()); //把得到的属性进行赋值，就是把读取到的单元格中的数据赋给对应的属性
/* Row.MissingCellPolicy RETURN_NULL_AND_BLANK
Row.MissingCellPolicy RETURN_BLANK_AS_NULL
Row.MissingCellPolicy CREATE_NULL_AS_BLANK*/
if (beanFiled[z].getType().equals(String.class)) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? "" : sourceAsMap.get(highwayNames[z]).toString());
} else if (beanFiled[z].getType().equals(Integer.class)) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? 0 : Integer.valueOf(sourceAsMap.get(highwayNames[z]).toString()));
} else if (beanFiled[z].getType().equals(Long.class.getName())) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? "" : Long.valueOf(sourceAsMap.get(highwayNames[z]).toString()));
} else if (beanFiled[z].getType().equals(Float.class)) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? "" : Float.valueOf(sourceAsMap.get(highwayNames[z]).toString()));
} else if (beanFiled[z].getType().equals(Double.class)) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? 0.0 : Double.valueOf(sourceAsMap.get(highwayNames[z]).toString()));
} else if (beanFiled[z].getType().equals(Byte.class)) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? "" : Byte.valueOf(sourceAsMap.get(highwayNames[z]).toString()));
} else if (beanFiled[z].getType().equals(Boolean.class)) {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? "" : Boolean.valueOf(sourceAsMap.get(highwayNames[z]).toString()));
} else if (beanFiled[z].getType().equals(Date.class)) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Date date = null;
try {
date = sdf.parse(sourceAsMap.get(highwayNames[z]) == null ? "" : sourceAsMap.get(highwayNames[z]).toString());
} catch (Exception e) {
e.printStackTrace();
}
beanFiled[z].set(basehighwayalldata, date);
} else {
beanFiled[z].set(basehighwayalldata, sourceAsMap.get(highwayNames[z]) == null ? "" : sourceAsMap.get(highwayNames[z]).toString());
}
} catch (Exception e) {
e.printStackTrace();
}
} }
basehighwayalldataList.add(basehighwayalldata); basehighwayalldataList.add(basehighwayalldata);
} }
...@@ -782,17 +816,18 @@ public class EsUtil_fanshe { ...@@ -782,17 +816,18 @@ public class EsUtil_fanshe {
.mustNot(QueryBuilders.matchPhraseQuery("dengjimingcheng", "等外")); .mustNot(QueryBuilders.matchPhraseQuery("dengjimingcheng", "等外"));
searchRequestBuilder.setQuery(boolQueryBuilder); searchRequestBuilder.setQuery(boolQueryBuilder);
} }
String[] highwayNames = {"id", String[] highwayNames = {
"id",
"luxianbianhao", "luxianbianhao",
"quhuadaima", "quhuadaima",
"luxianmingcheng", "luxianmingcheng",
"qidianmingcheng", "qidianmingcheng",
"zhidianmingcheng", "zhidianmingcheng",
"Qidianzhuanghao", "qidianzhuanghaoa",
"zhidianzhuanghao", "zhidianzhuanghao",
"licheng", "licheng",
"lichengjisuan", "lichengjisuan",
"sanDlicheng", "sandlicheng",
"dengjidaima", "dengjidaima",
"dengjimingcheng", "dengjimingcheng",
"chedaodaima", "chedaodaima",
...@@ -808,7 +843,7 @@ public class EsUtil_fanshe { ...@@ -808,7 +843,7 @@ public class EsUtil_fanshe {
"duantoulu", "duantoulu",
"chongfubianma", "chongfubianma",
"chongfuxuhao", "chongfuxuhao",
"qidianzhuanghao", "qidianzhuanghaob",
"zhongdianzhuanghao", "zhongdianzhuanghao",
"yanghulicheng", "yanghulicheng",
"qingyulicheng", "qingyulicheng",
...@@ -830,7 +865,7 @@ public class EsUtil_fanshe { ...@@ -830,7 +865,7 @@ public class EsUtil_fanshe {
"qidianfenjiedianleixing", "qidianfenjiedianleixing",
"zhidianfenjiedianleixing", "zhidianfenjiedianleixing",
"shengjichurukou", "shengjichurukou",
"GBMlicheng", "gbmlicheng",
"yangbanlicheng", "yangbanlicheng",
"tongcheriqi", "tongcheriqi",
"luxiandifangmingcheng", "luxiandifangmingcheng",
...@@ -840,7 +875,7 @@ public class EsUtil_fanshe { ...@@ -840,7 +875,7 @@ public class EsUtil_fanshe {
"luduanleixingdaima", "luduanleixingdaima",
"luduanleixing", "luduanleixing",
"guanyangdanweimingcheng", "guanyangdanweimingcheng",
"MQI", "mqi",
"pingdingdengji", "pingdingdengji",
"shoufeixingzhi", "shoufeixingzhi",
"biangengyuanyindaima", "biangengyuanyindaima",
...@@ -962,7 +997,8 @@ public class EsUtil_fanshe { ...@@ -962,7 +997,8 @@ public class EsUtil_fanshe {
.must(QueryBuilders.rangeQuery("zhidianzhuanghao").gte(zh)); .must(QueryBuilders.rangeQuery("zhidianzhuanghao").gte(zh));
searchRequestBuilder.setQuery(boolquery); searchRequestBuilder.setQuery(boolquery);
} }
String[] highwayNames = {"id", String[] highwayNames = {
"id",
"luxianbianhao", "luxianbianhao",
"quhuadaima", "quhuadaima",
"luxianmingcheng", "luxianmingcheng",
...@@ -972,7 +1008,7 @@ public class EsUtil_fanshe { ...@@ -972,7 +1008,7 @@ public class EsUtil_fanshe {
"zhidianzhuanghao", "zhidianzhuanghao",
"licheng", "licheng",
"lichengjisuan", "lichengjisuan",
"sanDlicheng", "sandlicheng",
"dengjidaima", "dengjidaima",
"dengjimingcheng", "dengjimingcheng",
"chedaodaima", "chedaodaima",
...@@ -1136,7 +1172,8 @@ public class EsUtil_fanshe { ...@@ -1136,7 +1172,8 @@ public class EsUtil_fanshe {
searchRequestBuilder.setQuery(QueryBuilders.termQuery("luxianbianhao", keyword)); searchRequestBuilder.setQuery(QueryBuilders.termQuery("luxianbianhao", keyword));
/*searchRequestBuilder.setQuery(QueryBuilders.matchQuery("luxianbianhao",keyword));*/ /*searchRequestBuilder.setQuery(QueryBuilders.matchQuery("luxianbianhao",keyword));*/
} }
String[] highwayNames = {"id", String[] highwayNames = {
"id",
"luxianbianhao", "luxianbianhao",
"quhuadaima", "quhuadaima",
"luxianmingcheng", "luxianmingcheng",
...@@ -1146,7 +1183,7 @@ public class EsUtil_fanshe { ...@@ -1146,7 +1183,7 @@ public class EsUtil_fanshe {
"zhidianzhuanghao", "zhidianzhuanghao",
"licheng", "licheng",
"lichengjisuan", "lichengjisuan",
"sanDlicheng", "sandlicheng",
"dengjidaima", "dengjidaima",
"dengjimingcheng", "dengjimingcheng",
"chedaodaima", "chedaodaima",
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论