Skip to content

A
aroad_aqsc
提交 1bc4d684 authored 作者: xuyanqi's avatar xuyanqi
浏览文件
操作

搜索

上级 04b05e90
显示空白字符变更
内嵌 并排
正在显示 包含 145 行增加 和 323 行删除
src/main/java/com/elephant/framework/galaxy/aroad/bigdata/EsUtil_fanshe.java
浏览文件 @ 1bc4d684
......@@ -47,13 +47,20 @@ public class EsUtil_fanshe {
public static TransportClient getClient() throws Exception {
Settings settings = Settings.builder().put("cluster.name", "myes").build();
if (transportClient == null) {
synchronized (EsUtil_fanshe.class) {
/*synchronized (EsUtil_fanshe.class) {
// 创建Client连接对象
transportClient = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.6.100"), 9300))
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.6.110"), 9300))
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.6.120"), 9300));
}
}*/
// 创建Client连接对象
transportClient = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.6.100"), 9300))
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.6.110"), 9300))
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.6.120"), 9300));
}
......@@ -324,7 +331,7 @@ public class EsUtil_fanshe {
* @Author: dongjili
* @Date:
*/
public static String queryBridgeOne(String keyword, String index, String type, int start, int row) throws Exception {
public static Boolean queryBridgeOne(String keyword, String index, String type, int start, int row) throws Exception {
// 搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
......@@ -332,133 +339,16 @@ public class EsUtil_fanshe {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"qiaoliangmingcheng",
"qiaoliangdaima"
"qiaoliangmingcheng"
));
}
String[] bridgeNames = {
"id",
"quhuadaima",
"quhuamingcheng",
"qiaoliangmingcheng",
"qiaoliangdaima",
"zhongxinzhuanghao",
"luxianbianma",
"luxianmingcheng",
"jishudengji",
"quanchang",
"kuajingzongchang",
"dankongzuidakuajing",
"qiaokuazuhe",
"qiaoliangquankuan",
"qiaomianjingkuan",
"kuajingfenleidaima",
"kuajingfenleileixing",
"nianxianfenleidaima",
"nianxianfenleileixing",
"yuanshangbujiegou1daima",
"yuanshangbujiegou1xingshi",
"yuanshangbujiegou2daima",
"yuanshangbujiegou2xingshi",
"shangbujiegoudaima",
"shangbujiegouxingshi",
"shangbujiegoucailiaodaima",
"shangbujiegoucailiaomingcheng",
"qiaodunleixingdaima",
"qiaodunleixingmingcheng",
"shejihezaidaima",
"shejihezaidengji",
"kangzhendengjidaima",
"kangzhendengji",
"kuayuediwudaima",
"kuayuediwuleixing",
"kuayuemingcheng",
"tonghangdengji",
"fangzhuangleixing",
"lijiaoleibie",
"jianshedanwei",
"shejidanwei",
"shigongdanwei",
"jianlidanwei",
"xiujianniandu",
"tongcheriqi",
"guanyangdaima",
"guanyangmingcheng",
"jianguandanweimingcheng",
"shoufeixingzhidaima",
"shoufeixingzhi",
"pingdingdengjidaima",
"pingdingdengji",
"pingdingdanwei",
"pingdingriqi",
"gaizaoniandu",
"wangongriqi",
"gaizaobuwei",
"gaizaoshigongdanwei",
"gongchengxingzhi",
"bubuxiangmu",
"binghaidaima",
"binghaibuwei",
"binghaimiaoshu",
"guanzhicuoshidaima",
"guanzhicuoshi",
"beizhu",
"zhuqiaokongshu",
"zhuqiaozhukua",
"zhuqiaobiankua",
"qianyinqiaochang",
"houyinqiaochang",
"qiaoxiajingkong",
"xiabujiegoudaima",
"xiabujiegoumingcheng",
"qiaotaidaima",
"qiaotaimingcheng",
"zhizuodaima",
"zhizuomingcheng",
"qiaomianpuzhuangdaima",
"qiaomianpuzhuangmingcheng",
"shensuofengdaima",
"shensuofengmingcheng",
"wanpoxiedaima",
"wanpoxiemingcheng",
"yuyingliqiao",
"zaixiuzaijian",
"zhadaomianji",
"shejihongshuipinlv",
"zongzaojia",
"maishezhuanghao",
"shifouzhadaoqiao",
"shifoushangkuaqiao",
"guanlidanweimingcheng",
"guanlidanweidaima",
"biangengyuanyindaima",
"biangengyuanyin",
"biangengshijian",
"xiangmuxingzhi",
"xiangmumingcheng",
"jihuaxiangmubianma",
"xiangmuleibie",
"xiangmudaima",
"xiangmuluxianbianma",
"xiangmuluxianmingcheng",
"xiangmuqiaoliangzhuanghao",
"xiangmubiangengyuanyin",
"xiangmubiangengshijian",
"touzilaiyuan",
"qiaoliangsuozaiweizhi",
"shifoukuanluzhaiqiao",
"shifouzaizhangdaqiaolaingmuluzhong",
"tianbaodanweimingcheng"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
String bridgeName="桥梁明细表";
SearchHits hits = response.getHits();
if (hits.getHits().length>0){
return bridgeName;
return true;
}else {
return null;
return false;
}
}
/**
......@@ -608,7 +498,7 @@ public class EsUtil_fanshe {
* @Author: dongjili
* @Date:
*/
public static String queryHighWayOne(String keyword, String index, String type, int start, int row) throws Exception {
public static Boolean queryHighWayOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
......@@ -616,111 +506,17 @@ public class EsUtil_fanshe {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"luxianbianhao",
"luxianmingcheng",
"qidianmingcheng",
"zhidianmingcheng"
"luxianmingcheng"
));
}
String[] highwayNames = {"id",
"luxianbianhao",
"quhuadaima",
"luxianmingcheng",
"qidianmingcheng",
"zhidianmingcheng",
"Qidianzhuanghao",
"zhidianzhuanghao",
"licheng",
"lichengjisuan",
"sanDlicheng",
"dengjidaima",
"dengjimingcheng",
"chedaodaima",
"chedaofenlei",
"mianchengdaima",
"mianchengfenlei",
"lujikuandu",
"lumiankuandu",
"shejishisu",
"xiujianniandu",
"gaijianniandu",
"chengguanlu",
"duantoulu",
"chongfubianma",
"chongfuxuhao",
"qidianzhuanghao",
"zhongdianzhuanghao",
"yanghulicheng",
"qingyulicheng",
"kelvhaolicheng",
"yilvhualicheng",
"dimaodaima",
"dimaohanzi",
"handongshuliang",
"maisheqidianzhuanghao",
"maishezhidianzhuanghao",
"quhuamingchengshi",
"quhuamingchengxian",
"quhuamingchengxiang",
"luduanxuhao",
"guanyangdanweileibie",
"beizhu",
"kaigongriqi",
"jungongriqi",
"qidianfenjiedianleixing",
"zhidianfenjiedianleixing",
"shengjichurukou",
"GBMlicheng",
"yangbanlicheng",
"tongcheriqi",
"luxiandifangmingcheng",
"jianshexingzhidaima",
"jianshexingzhihanzi",
"duanlianleixing",
"luduanleixingdaima",
"luduanleixing",
"guanyangdanweimingcheng",
"MQI",
"pingdingdengji",
"shoufeixingzhi",
"biangengyuanyindaima",
"biangengyuanyin",
"biangengshijian",
"xiangmuxingzhi",
"xiangmumingcheng",
"xiangmudaima",
"xiangmuqidianmingcheng",
"xiangmuzhidianmingcheng",
"xiangmuleibie",
"jihuaxiangmubianma",
"xiangmuluxianbianma",
"xiangmuluxianmingcheng",
"xiangmubiangengyuanyin",
"xiangmubiangengshijian",
"touzilaiyuan",
"miancenghoudu",
"zuijinyicidaxiuniandu",
"zuijinyicizhongxiuniandu",
"guodaotiaozhengqianluxianbianma",
"guodaozhuanghaochuandiyuliulicheng",
"nianpingjunrijiaotongliang",
"shifouanganxiangongluguanlijieyang",
"luxiantiaozhengleixing",
"shangnianluxianbianma",
"shangnianluxianmingcheng",
"shangnianluxianqidianzhuanghao",
"shangnianluxianzhidianzhuanghao",
"tianbaodanweimingcheng"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
String highwayName="路段明细表";
if (hits.getHits().length>0){
return highwayName;
return true;
}else {
return null;
return false;
}
}
......@@ -823,7 +619,7 @@ public class EsUtil_fanshe {
* @Author: dongjili
* @Date: 2019/4/28 0028
*/
public static String queryTunnelOne(String keyword, String index, String type, int start, int row) throws Exception {
public static Boolean queryTunnelOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
......@@ -831,63 +627,18 @@ public class EsUtil_fanshe {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"suidaomingcheng"
));
}
String[] basicTunnelNames = {"id",
"suidaomingcheng",
"suidaodaima",
"zhongxinzhuanghao",
"luxianbianma",
"luxianmingcheng",
"jishudengji",
"changdu",
"jingkuan",
"jinggao",
"changdufenleidaima",
"fenleimingcheng",
"shuixiasuidao",
"xiujianniandu",
"jianshedanwei",
"shejidanwei",
"shigongdanwei",
"jianlidanwei",
"tongcheshijian",
"shuidaoyanghudengji",
"guanyangdanweixingzhi",
"guanyangdanweimingcheng",
"jianguandanwei",
"pingdingdengji",
"pingdingriqi",
"pingdingdanwei",
"pingdingdengjitujian",
"pingdingriqitujian",
"pingdingdanweitujian",
"pingdingdengjijidian",
"pingdingriqijidian",
"pingdingdanweijidian",
"pingdingdengjiqita",
"pingdingriqiqita",
"pingdingdanweiqita",
"gaijianniandu",
"wangongriqi",
"gaizaibuwei",
"gongchengxingzhi",
"binghaibuwei",
"binghaimiaoshu",
"xianjizhengqudaima",
"shifouzaizhangdasuidaomuluzhong",
"beizhu"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
String tunnelName="隧道明细表";
if (hits.getHits().length>0){
return tunnelName;
return true;
}else {
return null;
return false;
}
}
......@@ -905,10 +656,11 @@ public class EsUtil_fanshe {
if (org.apache.commons.lang.StringUtils.isNotBlank(keyword)) {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"name"
));
// searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
// "id",
// "name"
// ));
searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
}
String[] baseRoadTollNames = {"id",
"roadCode",
......@@ -968,7 +720,7 @@ public class EsUtil_fanshe {
* @Author: dongjili
* @Date: 2019/4/28 0028
*/
public static String queryBaseRoadTollOne(String keyword, String index, String type, int start, int row) throws Exception {
public static Boolean queryBaseRoadTollOne(String keyword, String index, String type, int start, int row) throws Exception {
//搜索数据
SearchRequestBuilder searchRequestBuilder = getClient().prepareSearch(index).setTypes(type).setFrom(start).setSize(row);
//isNotBlank(str) 等价于 str != null && str.length > 0 && str.trim().length> 0(去掉字符串两端的多余的空格的长度）
......@@ -976,40 +728,17 @@ public class EsUtil_fanshe {
//multiMatchQuery多个字段匹配某一个值
//multiMatchQuery(text,fields)其中的fields是字段的名字，可以写好几个，每一个中间用逗号分隔
searchRequestBuilder.setQuery(QueryBuilders.multiMatchQuery(keyword,
"id",
"name"
));
}
String[] baseRoadTollNames = {"id",
"roadCode",
"roadName",
"number",
"code",
"name",
"shortName",
"tecLevel",
"locationType",
"tollDirection",
"entNum",
"entEtcNum",
"entMtcNum",
"entMixNum",
"expNum",
"expEtcNum",
"expMtcNum",
"expMixNum",
"managementUnit",
"longitude",
"latitude"
};
SearchResponse response = searchRequestBuilder.get();
//获取命中次数，查询结果有多少对象
SearchHits hits = response.getHits();
String baseRoadTollName="收费站明细表";
if (hits.getHits().length>0){
return baseRoadTollName;
return true;
} else {
return null;
return false;
}
}
......
src/main/java/com/elephant/framework/galaxy/aroad/bigdata/ReadElasticsearch.java
浏览文件 @ 1bc4d684
......@@ -15,10 +15,10 @@ public class ReadElasticsearch {
public static void createIndexAnd2Hbase() throws Exception {
//分词查询桥梁数据返回list集合
//ArrayList<LuKeBridge> luKeBridges = EsUtil_fanshe.queryBridge("广州桥", "basicbridgedata", "2018", 0, 2000000000);
/* for (LuKeBridge luKeBridge : luKeBridges) {
ArrayList<LuKeBridge> luKeBridges = EsUtil_fanshe.queryBridge("桥", "basicbridgedata", "2018", 0, 2000000000);
for (LuKeBridge luKeBridge : luKeBridges) {
System.out.println(luKeBridge.toString());
}*/
}
//分词查询路段数据返回list集合
//ArrayList<LuKeHighWay> lukehighways = EsUtil_fanshe.queryHighWay("广州桥", "basichighwaydata", "2018", 0, 2000000000);
/*for (LuKeHighWay lukehighway : lukehighways) {
......@@ -30,25 +30,25 @@ public class ReadElasticsearch {
System.out.println(basicTunnel.toString());
}*/
//分词查询收费站数据返回list集合
//ArrayList<BaseRoadToll_String> baseRoadTollStrings = EsUtil_fanshe.queryBaseRoadTollString("广州桥", "baseroadtolldata", "2018", 0, 2000000000);
/*for (BaseRoadToll_String baseRoadTollString : baseRoadTollStrings) {
System.out.println(baseRoadTollString.toString());
}*/
// ArrayList<BaseRoadToll_String> baseRoadTollStrings = EsUtil_fanshe.queryBaseRoadTollString("桥", "baseroadtolldata", "2018", 0, 2000000000);
// System.out.println(baseRoadTollString.toString());
// }
//封装查询匹配所有的名称
ArrayList<String> names = new ArrayList<>();
//查询匹配桥梁名称
String bridgeOne = EsUtil_fanshe.queryBridgeOne("桥", "basicbridgedata", "2018", 0, 2000000000);
names.add(bridgeOne);
//查询匹配路段名称
String highWayOne = EsUtil_fanshe.queryHighWayOne("桥", "basichighwaydata", "2018", 0, 2000000000);
names.add(highWayOne);
//查询匹配隧道名称
String tunnelOne = EsUtil_fanshe.queryTunnelOne("桥", "basictunneldata", "2018", 0, 2000000000);
names.add(tunnelOne);
//查询匹配收费站名称
String baseRoadTollOne = EsUtil_fanshe.queryBaseRoadTollOne("桥", "baseroadtolldata", "2018", 0, 2000000000);
names.add(baseRoadTollOne);
System.out.println(names.toString());
// ArrayList<String> names = new ArrayList<>();
// //查询匹配桥梁名称
// String bridgeOne = EsUtil_fanshe.queryBridgeOne("桥", "basicbridgedata", "2018", 0, 2000000000);
// names.add(bridgeOne);
// //查询匹配路段名称
// String highWayOne = EsUtil_fanshe.queryHighWayOne("桥", "basichighwaydata", "2018", 0, 2000000000);
// names.add(highWayOne);
// //查询匹配隧道名称
// String tunnelOne = EsUtil_fanshe.queryTunnelOne("桥", "basictunneldata", "2018", 0, 2000000000);
// names.add(tunnelOne);
// //查询匹配收费站名称
// String baseRoadTollOne = EsUtil_fanshe.queryBaseRoadTollOne("桥", "baseroadtolldata", "2018", 0, 2000000000);
// names.add(baseRoadTollOne);
// System.out.println(names.toString());
}
}
src/main/java/com/elephant/framework/galaxy/aroad/module/szgl/controller/SzglController.java 0 → 100644
浏览文件 @ 1bc4d684
package com.elephant.framework.galaxy.aroad.module.szgl.controller;
import com.elephant.framework.galaxy.aroad.bigdata.*;
import com.elephant.framework.galaxy.aroad.module.codegen.response.R;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/szgl")
public class SzglController {
/**
* 全局搜索路段、收费站、桥梁、隧道
* @Param keyword 搜索条件
*/
@GetMapping("/bigdata")
public R getBigData(@RequestParam("keyword") String keyword) throws Exception {
List<Map<String,Object>> responseList = new ArrayList<>();
//查询匹配桥梁名称
Boolean bridgeOne = EsUtil_fanshe.queryBridgeOne(keyword, "basicbridgedata", "2018", 0, 2000000000);
if(bridgeOne){
responseList.add(new HashMap<String,Object>(){{
put("label","桥梁");
put("name","qiaoliang");
}});
}
//查询匹配路段名称
Boolean highWayOne = EsUtil_fanshe.queryHighWayOne(keyword ,"basichighwaydata", "2018", 0, 2000000000);
if(highWayOne){
responseList.add(new HashMap<String,Object>(){{
put("label","路段");
put("name","luduan");
}});
}
//查询匹配隧道名称
Boolean tunnelOne = EsUtil_fanshe.queryTunnelOne(keyword, "basictunneldata", "2018", 0, 2000000000);
if(tunnelOne){
responseList.add(new HashMap<String,Object>(){{
put("label","隧道");
put("name","suidao");
}});
}
//查询匹配收费站名称
Boolean baseRoadTollOne = EsUtil_fanshe.queryBaseRoadTollOne(keyword, "baseroadtolldata", "2018", 0, 2000000000);
if(baseRoadTollOne){
responseList.add(new HashMap<String,Object>(){{
put("label","收费站");
put("name","shoufeizhan");
}});
}
return new R<>(responseList);
}
/**
* 查询桥梁
* @Param keyword 搜索条件
*/
@GetMapping("/bridge")
public R getBridge(@RequestParam("keyword") String keyword) throws Exception {
ArrayList<LuKeBridge> luKeBridges = EsUtil_fanshe.queryBridge(keyword, "basicbridgedata", "2018", 0, 2000000000);
return new R<>(luKeBridges);
}
/**
* 查询路段
* @Param keyword 搜索条件
*/
@GetMapping("/highWay")
public R getHighWay(@RequestParam("keyword") String keyword) throws Exception {
ArrayList<LuKeHighWay> lukehighways = EsUtil_fanshe.queryHighWay(keyword, "basichighwaydata", "2018", 0, 2000000000);
return new R<>(lukehighways);
}
/**
* 查询隧道
* @Param keyword 搜索条件
*/
@GetMapping("/tunnel")
public R getTunnel(@RequestParam("keyword") String keyword) throws Exception {
ArrayList<BasicTunnel> basicTunnels = EsUtil_fanshe.queryTunnel("广州桥", "basictunneldata", "2018", 0, 2000000000);
return new R<>(basicTunnels);
}
/**
* 查询收费站
* @Param keyword 搜索条件
*/
@GetMapping("/baseRoadToll")
public R getBaseRoadToll(@RequestParam("keyword") String keyword) throws Exception {
ArrayList<BaseRoadToll_String> baseRoadTollStrings = EsUtil_fanshe.queryBaseRoadTollString(keyword, "baseroadtolldata", "2018", 0, 2000000000);
return new R<>(baseRoadTollStrings);
}
}
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论