Skip to content

X
xzxt-api-report
Commit 8566db70 by liulianglang
Options

删除多余文件

parent 16e63da4
Showing with 0 additions and 1996 deletions
src/main/java/com/founder/controller/XxcxController.java deleted 100644 → 0
package com.founder.controller;
import cn.hutool.crypto.SecureUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.founder.common.IpADdress;
import com.founder.common.IpADressLock;
import com.founder.common.LogsUtil;
import com.founder.model.*;
import com.founder.service.SysGnsyrzOpenApiService;
import com.founder.service.XxcxService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.http.HttpHeaders;
import org.springframework.web.client.RestTemplate;
import javax.servlet.http.HttpServletRequest;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
@RestController
@RequestMapping(value="/xxcx",produces = "application/json; charset=utf-8")
public class XxcxController {
@Value("${xxcx.author}")
private String author;
@Value("${app_keyes}")
private String app_key;
@Value("${app_secretes}")
private String app_secret;
@Value("${moduleId}")
private String moduleId;
@Value("${moduleName}")
private String moduleName;
@Value("${gabesUrl}")
private String gabesUrl;
@Value("${gabUrl}")
private String gabUrl;
@Autowired
private SysGnsyrzOpenApiService sysGnsyrzOpenApiService;
@Autowired
private XxcxService xxcxService;
@Autowired
private IpADressLock ipADressLock;
@Autowired
private RestTemplate restTemplate;
@ResponseBody
@RequestMapping("/ajxxcx")
public Result queryAsjxx(HttpServletRequest requestIp,@RequestBody TbStAsjView tbStAsjView ){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
TbStAsjView tbStAsjView1=new TbStAsjView();
try {
String asjbh = tbStAsjView.getAsjbh();
String jjdbh = tbStAsjView.getJjdbh();
if(StringUtils.isEmpty(asjbh) && StringUtils.isEmpty(jjdbh)){
reslt.setData(null);
reslt.setMsg("查询参数为空，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(!StringUtils.isEmpty(asjbh)){
tbStAsjView1 = xxcxService.queryTbStAsjByAsjbh(asjbh);
}else if(!StringUtils.isEmpty(jjdbh)){
tbStAsjView1 = xxcxService.queryTbStAsjByJjdbh(jjdbh);
}
reslt.setData(tbStAsjView1 );
sysGnsyrzOpenApiService.insertGNSYRZOPENAPI("01","基础信息-案件表基本信息",LogsUtil.getNotEmptyFiled(tbStAsjView1).toString(),"","","460000000000","海南电诈平台","", ipADressLock.getAddressIp(requestIp),"1");
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
} catch (Exception e) {
reslt.setData(tbStAsjView1);
reslt.setMsg("案件信息查询失败\n"+e.getMessage());
reslt.setStatus("error");
e.printStackTrace();
}
return reslt;
}
@RequestMapping("/bhrxxcx")
public Result queryBhrxx(@RequestBody TbXwRybhView param){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
List<TbXwRybhView> tbXwRybhViews = new ArrayList<>();
try {
if(StringUtils.isEmpty(param.getAsjbh()) && StringUtils.isEmpty(param.getBhrCyzjZjhm())){
reslt.setData(new ArrayList<>());
reslt.setMsg("查询参数为空，不能查询！");
reslt.setStatus("fail");
return reslt;
}
tbXwRybhViews = xxcxService.queryTbXwRybh(param);
reslt.setData(tbXwRybhViews);
reslt.setMsg("被害人信息查询成功");
reslt.setStatus("success");
} catch (Exception e) {
reslt.setData(tbXwRybhViews);
reslt.setMsg("被害人信息查询失败\n"+e.getMessage());
reslt.setStatus("error");
e.printStackTrace();
}
return reslt;
}
// @RequestMapping("/test")
// public Result test( testParam xyr){
// Result reslt = new Result();
// HttpServletRequest request = IpADdress.getRequest();
//
//
// Map mapResult = new HashMap();
//System.out.println("page:"+xyr.getPage()+",,,pageSize:"+xyr.getPageSize()+",,,likeValue:"+xyr.getLikeValue());
// String resultToken="{\"status\":200,\"msg\":\"成功获取地址信息\",\"data\":[{\"bh\":\"5147017330106起支行\",\"time\":null,\"name\":\"招商银行杭州凤起支行\",\"address\":null,\"x\":\"120.14481\",\"y\":\"30.28322\",\"xy\":\"30.28322,120.144810000000007\",\"distance\":null},{\"bh\":\"390204440404行附近\",\"time\":null,\"name\":\"珠海市金湾区招商银行高栏港支行附近\",\"address\":null,\"x\":\"113.19977\",\"y\":\"21.98177\",\"xy\":\"21.9817700000000009,113.199770000000001\",\"distance\":null},{\"bh\":\"4AE1ECC3EB40466F86862255A4FF74FE\",\"time\":null,\"name\":\"安徽省芜湖市镜湖区滨江公共服务中心新芜路社区中山路步行街18号商之都北楼招商银行芜湖分行\",\"address\":null,\"x\":\"118.365608686899\",\"y\":\"31.3328402774493\",\"xy\":\"31.3328402774493,118.365608686898995\",\"distance\":null},{\"bh\":\"22360351440605厦附近\",\"time\":null,\"name\":\"佛山市南海区招商银行佛山分行大厦附近\",\"address\":null,\"x\":\"113.144\",\"y\":\"23.05404\",\"xy\":\"23.0540400000000005,113.144000000000005\",\"distance\":null},{\"bh\":\"22447855440605厦附近\",\"time\":null,\"name\":\"佛山市南海区招商银行佛山分行大厦附近\",\"address\":null,\"x\":\"113.144\",\"y\":\"23.05404\",\"xy\":\"23.0540400000000005,113.144000000000005\",\"distance\":null},{\"bh\":\"520296253420103行大厦\",\"time\":null,\"name\":\"武汉市江汉区淮海路招商银行武汉分行大厦\",\"address\":null,\"x\":\"114.24519\",\"y\":\"30.60033\",\"xy\":\"30.6003299999999996,114.245189999999994\",\"distance\":null},{\"bh\":\"64382472610303行隔壁\",\"time\":null,\"name\":\"宝鸡市金台区陈仓园市民广场招商银行分行隔壁\",\"address\":null,\"x\":\"107.16592\",\"y\":\"34.36125\",\"xy\":\"34.3612499999999983,107.16592\",\"distance\":null},{\"bh\":\"1d0fb3a1410002c8e0530a58091502c8\",\"time\":null,\"name\":\"天津市南开区黄河道招商银行黄河道广得大楼黄河道招商银行黄河道广得大楼自助\",\"address\":null,\"x\":\"117.1565170285591\",\"y\":\"39.1371212005952\",\"xy\":\"39.1371212005952032,117.156517028559094\",\"distance\":null},{\"bh\":\"1d0fb3a2904302c8e0530a58091502c8\",\"time\":null,\"name\":\"天津市塘沽区上海道招商银行\",\"address\":null,\"x\":\"117.659599304752\",\"y\":\"39.0142707815322\",\"xy\":\"39.014270781532197,117.659599304752007\",\"distance\":null},{\"bh\":\"520269739320602\",\"time\":null,\"name\":\"江苏省南通市崇川区跃龙路80号招商银行3层\",\"address\":null,\"x\":\"120.85813\",\"y\":\"32.00884\",\"xy\":\"32.0088399999999993,120.858130000000003\",\"distance\":null}],\"count\":10}";
// JSONObject resultJson =JSONObject.parseObject(resultToken);
// JSONArray array= resultJson.getJSONArray("data");
//
// reslt.setData(array);
// reslt.setMsg("案件信息查询成功");
// reslt.setStatus("success");
// return reslt;
//
//
//
// }
@RequestMapping("/AsjApiQuery")
public Result AsjApiQuery(@RequestBody AsjRyRelateVoBzpt asj){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
List<Map<String,Object>> listResult = new ArrayList<>();
JSONObject jsonParams = new JSONObject();
jsonParams.put("index","tb_st_asj");// 索引名称
jsonParams.put("request",JSONObject.parse(queryJson(asj)));// 请求json
System.out.println("----"+jsonParams.toJSONString());
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabesUrl+"search",params,JSONObject.class).getBody();
LinkedHashMap json = (LinkedHashMap) resultJson.get("result");
LinkedHashMap jsonResponse = (LinkedHashMap) json.get("response");
LinkedHashMap jsonHit = (LinkedHashMap) jsonResponse.get("hits");
int total = (int) jsonHit.get("total");
if(total > 0 ){
List<LinkedHashMap> jsonHitArray = (List<LinkedHashMap>) jsonHit.get("hits");
SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddhhmmss");
for(int i=0;i<jsonHitArray.size();i++){
Map map = new HashMap();
LinkedHashMap obj = (LinkedHashMap) jsonHitArray.get(i).get("_source");
String asjbh = (String) obj.get("v_solr6_tb_st_asj_AS_ASJBH");
String ajmc = (String) obj.get("v_solr6_tb_st_asj_AT_AJMC");
String ajlbdmMc = (String) obj.get("v_solr6_tb_st_asj_AS_AJLBDM_value");// 案件类别
String ajlbdm = (String) obj.get("v_solr6_tb_st_asj_AS_AJLBDM");// 案件类别代码
String ajzlbMc = (String) obj.get("v_solr6_tb_st_asj_AS_ZATZ_JYQK_value");// 小案类别
String ajxzlbMc = (String) obj.get("tb_st_asj_asjbz_AJXLB_VALUE");// 细类案类别
String bzrXm = (String) obj.get("tb_st_asj_asjbz_XXCZRY_XM");// 标注人姓名
String bzrDwdmMc = (String) obj.get("tb_st_asj_asjbz_XXCZDW_GAJGJGDM_VALUE");// 标注人单位
String asjfsddDzmc = (String) obj.get("v_solr6_tb_st_asj_AT_ASJFSDD_DZMC");// 案发地详细地址
String ssjzrmby = (String) obj.get("v_solr6_tb_st_asj_AN_SSJZRMBY");// 损失总价值
String larq = (String) obj.get("v_solr6_tb_st_asj_AS_LARQ");// 立案日期
String ladwPcs = (String) obj.get("v_solr6_tb_st_asj_AS_LADW_GAJGJGDM");// 立案单位
String asjfssjAsjfskssj = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ");// 案发时间
String jyaq = (String) obj.get("v_solr6_tb_st_asj_AT_JYAQ");// 简要案情
String bzztMs = (String) obj.get("tb_st_asj_asjbz_BZZT_VALUE");// 标注状态描述
String bzzt = (String) obj.get("tb_st_asj_asjbz_BZZT");// 标注状态
map.put("asjbh",asjbh);
map.put("ajmc",ajmc);
map.put("ajlbdmMc",ajlbdmMc);
map.put("ajlbdm",ajlbdm);
map.put("ajzlbMc",ajzlbMc);
map.put("ajxzlbMc",ajxzlbMc);
map.put("bzrDwdmMc",bzrDwdmMc);
map.put("bzrXm",bzrXm);
map.put("asjfsddDzmc",asjfsddDzmc);
map.put("ssjzrmby",ssjzrmby);
String ladwMc = "";
// if(null!=ladwPcs){
// ladwMc = detailervice.getDwMcBydm(ladwPcs);
// }
map.put("ladwPcs",ladwMc);
// 立案日期和案发日期 过滤
if(null != larq){
try {
map.put("larq",sf.parse(larq));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("larq","无");
}
if(null != asjfssjAsjfskssj){
try {
map.put("asjfssjAsjfskssj",sf.parse(asjfssjAsjfskssj));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("asjfssjAsjfskssj","无");
}
if(StringUtils.isEmpty(bzztMs)){
map.put("bzztMs","未标注");
}else{
map.put("bzztMs",bzztMs);
}
map.put("bzzt",bzzt);
map.put("jyaq",jyaq);
listResult.add(map);
}
}
mapResult.put("total",total);
mapResult.put("rows",listResult);
reslt.setData(mapResult);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
@RequestMapping("/AsjApiByAsjbh")
public Result AsjApiByAsjbh(@RequestBody AsjRyRelateVoBzpt asjbl){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(asjbl.getAsjbh()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入案件编号，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
List<Map<String,Object>> listResult = new ArrayList<>();
AsjRyRelateVoBzpt asj=new AsjRyRelateVoBzpt();
asj.setAsjbh(asjbl.getAsjbh());
JSONObject jsonParams = new JSONObject();
jsonParams.put("index","tb_st_asj");// 索引名称
jsonParams.put("request",JSONObject.parse(queryJson(asj)));// 请求json
System.out.println("----"+jsonParams.toJSONString());
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabesUrl+"search",params,JSONObject.class).getBody();
LinkedHashMap json = (LinkedHashMap) resultJson.get("result");
LinkedHashMap jsonResponse = (LinkedHashMap) json.get("response");
LinkedHashMap jsonHit = (LinkedHashMap) jsonResponse.get("hits");
int total = (int) jsonHit.get("total");
if(total > 0 ){
List<LinkedHashMap> jsonHitArray = (List<LinkedHashMap>) jsonHit.get("hits");
SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddhhmmss");
for(int i=0;i<jsonHitArray.size();i++){
Map map = new HashMap();
LinkedHashMap obj = (LinkedHashMap) jsonHitArray.get(i).get("_source");
String asjbh = (String) obj.get("v_solr6_tb_st_asj_AS_ASJBH");
String ajmc = (String) obj.get("v_solr6_tb_st_asj_AT_AJMC");
String ajlbdmMc = (String) obj.get("v_solr6_tb_st_asj_AS_AJLBDM_value");// 案件类别
String ajlbdm = (String) obj.get("v_solr6_tb_st_asj_AS_AJLBDM");// 案件类别代码
String ajzlbMc = (String) obj.get("v_solr6_tb_st_asj_AS_ZATZ_JYQK_value");// 小案类别
String ajxzlbMc = (String) obj.get("tb_st_asj_asjbz_AJXLB_VALUE");// 细类案类别
String bzrXm = (String) obj.get("tb_st_asj_asjbz_XXCZRY_XM");// 标注人姓名
String bzrDwdmMc = (String) obj.get("tb_st_asj_asjbz_XXCZDW_GAJGJGDM_VALUE");// 标注人单位
String asjfsddDzmc = (String) obj.get("v_solr6_tb_st_asj_AT_ASJFSDD_DZMC");// 案发地详细地址
String asjfsddXzqh = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSDD_XZQHDM");// 案发地详细地址
String ssjzrmby = (String) obj.get("v_solr6_tb_st_asj_AN_SSJZRMBY");// 损失总价值
String larq = (String) obj.get("v_solr6_tb_st_asj_AS_LARQ");// 立案日期
String ladwdm = (String) obj.get("v_solr6_tb_st_asj_AS_LADW_GAJGJGDM");// 立案单位代码
String ladwMc = (String) obj.get("v_solr6_tb_st_asj_AT_LADW_GAJGMC");// 立案单位名称
String asjfssjAsjfskssj = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ");// 案发开始时间
String asjfssjAsjfsjssj = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSJSSJ");// 案发结束时间
String jyaq = (String) obj.get("v_solr6_tb_st_asj_AT_JYAQ");// 简要案情
String bzztMs = (String) obj.get("tb_st_asj_asjbz_BZZT_VALUE");// 标注状态描述
String bzzt = (String) obj.get("tb_st_asj_asjbz_BZZT");// 标注状态
map.put("asjbh",asjbh);
map.put("ajmc",ajmc);
map.put("ajlbdmMc",ajlbdmMc);
map.put("ajlbdm",ajlbdm);
map.put("ajzlbMc",ajzlbMc);
map.put("ajxzlbMc",ajxzlbMc);
map.put("bzrDwdmMc",bzrDwdmMc);
map.put("bzrXm",bzrXm);
map.put("asjfsddDzmc",asjfsddDzmc);
map.put("ssjzrmby",ssjzrmby);
map.put("asjfsddXzqh",asjfsddXzqh);
// if(null!=ladwPcs){
// ladwMc = detailervice.getDwMcBydm(ladwPcs);
// }
map.put("ladwdm",ladwdm);
map.put("ladwMc",ladwMc);
// 立案日期和案发日期 过滤
if(null != larq){
try {
map.put("larq",sf.parse(larq));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("larq","无");
}
if(null != asjfssjAsjfskssj){
try {
map.put("asjfssjAsjfskssj",sf.parse(asjfssjAsjfskssj));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("asjfssjAsjfskssj","无");
}
if(null != asjfssjAsjfsjssj){
try {
map.put("asjfssjAsjfsjssj",sf.parse(asjfssjAsjfsjssj));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("asjfssjAsjfsjssj","无");
}
if(StringUtils.isEmpty(bzztMs)){
map.put("bzztMs","未标注");
}else{
map.put("bzztMs",bzztMs);
}
map.put("bzzt",bzzt);
map.put("jyaq",jyaq);
listResult.add(map);
}
}
mapResult.put("total",total);
mapResult.put("rows",listResult);
reslt.setData(mapResult);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
private JSONObject getAsjResultJson() {
String resutStr = "{\n" +
" \"status_code\": \"1000\",\n" +
" \"elapsed_time\": \"669\",\n" +
" \"message\": \"请求成功\",\n" +
" \"version\": \"1.0\",\n" +
" \"request_id\": \"1a577df9a7624fa7ab95169bf614470b\",\n" +
" \"result\": {\n" +
" \"response\": {\n" +
" \"_shards\": {\n" +
" \"total\": 30,\n" +
" \"failed\": 0,\n" +
" \"successful\": 30,\n" +
" \"skipped\": 0\n" +
" },\n" +
" \"hits\": {\n" +
" \"hits\": [\n" +
" {\n" +
" \"_routing\": \"A46001\",\n" +
" \"_index\": \"ngw_v_solr6_tb_st_asj_new2\",\n" +
" \"_type\": \"doc\",\n" +
" \"_source\": {\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSJSSJ_2\": \"201703\",\n" +
" \"v_solr6_tb_st_asj_AS_SLSJ\": \"20170321192006\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSJSSJ_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_AT_AJMC\": \"手机被盗案\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSJSSJ_3\": \"20170321\",\n" +
" \"v_solr6_tb_st_asj_AS_XXCZDW_GAJGJGDM\": \"460203520000\",\n" +
" \"v_solr6_tb_st_asj_AS_LARQ\": \"20170406000000\",\n" +
" \"v_solr6_tb_st_asj_AS_ZUZDW_GAJGJGDM\": \"460203520000\",\n" +
" \"v_solr6_tb_st_asj_XXDJDW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_AS_SJ\": \"20170321190545\",\n" +
" \"v_solr6_tb_st_asj_XXDJDW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_XXDJDW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_AS_DJSJ\": \"20170325012755\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJBH\": \"A46001\",\n" +
" \"v_solr6_tb_st_asj_AS_ZUZDW_ZBR_XM\": \"zhang\",\n" +
" \"v_solr6_tb_st_asj_AS_ZCJDDM\": \"0600\",\n" +
" \"v_solr6_tb_st_asj_AT_ZAZBSD_DMBCMS\": \"其他手段\",\n" +
" \"v_solr6_tb_st_asj_AS_SFXSAJ\": \"1\",\n" +
" \"v_solr6_tb_st_asj_SLDW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_SLDW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSJSSJ\": \"20170321194045\",\n" +
" \"v_solr6_tb_st_asj_SLDW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_AS_XXCZRY_XM\": \"zhang\",\n" +
" \"v_solr6_tb_st_asj_QH_2\": \"460200\",\n" +
" \"v_solr6_tb_st_asj_QH_3\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_QH_1\": \"460000\",\n" +
" \"v_solr6_tb_st_asj_AS_XXDJRY_XM\": \"zhang\",\n" +
" \"v_solr6_tb_st_asj_LADW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_AN_PART\": \"1\",\n" +
" \"v_solr6_tb_st_asj_AT_JYAQ\": \"有人手机被盗。\",\n" +
" \"JOIN_FIELD\": \"v_solr6_tb_st_asj\",\n" +
" \"v_solr6_tb_st_asj_LARQ_2\": \"201704\",\n" +
" \"v_solr6_tb_st_asj_LARQ_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_LARQ_3\": \"20170406\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSDD_XZQHDM\": \"460204\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSH_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_ZBR_LXDH\": \"00000000000\",\n" +
" \"v_solr6_tb_st_asj_AN_ASJFSDD_DQJD\": \"109.50083\",\n" +
" \"v_solr6_tb_st_asj_AS_XBR_GMSFHM\": \"000000000000000001\",\n" +
" \"v_solr6_tb_st_asj_AS_XXSC_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_XCKYBH\": \"K4606\",\n" +
" \"v_solr6_tb_st_asj_AS_GXSJ\": \"20201101005936\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSJDQPCL_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AJLBDM_2\": \"05000200\",\n" +
" \"v_solr6_tb_st_asj_ASJLYDM_2\": \"0900\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSB_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AJLBDM_1\": \"05000000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSKSSJ_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_ASJLYDM_1\": \"0900\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSKSSJ_2\": \"201703\",\n" +
" \"v_solr6_tb_st_asj_AJLBDM_3\": \"05000200\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSKSSJ_3\": \"20170321\",\n" +
" \"v_solr6_tb_st_asj_AS_XXDJDW_GAJGJGDM\": \"460203520000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSDD_XZQHDM_2\": \"460200\",\n" +
" \"v_solr6_tb_st_asj_FXASJDD_XZQHDM_1\": \"460000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSDD_XZQHDM_1\": \"460000\",\n" +
" \"v_solr6_tb_st_asj_AS_XSJQLBDM\": \"100\",\n" +
" \"v_solr6_tb_st_asj_FXASJDD_XZQHDM_3\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_FXASJDD_XZQHDM_2\": \"460200\",\n" +
" \"v_solr6_tb_st_asj_AS_ZBR_XM\": \"zhang\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ZASJ_ZASJLBDM_1\": \"99\",\n" +
" \"v_solr6_tb_st_asj_AT_ASJFSDD_DZMC\": \"三亚市\",\n" +
" \"v_solr6_tb_st_asj_AS_LADW_GAJGJGDM\": \"460203520000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSDD_XZQHDM_3\": \"460204\",\n" +
" \"v_solr6_tb_st_asj_AS_FXASJDD_XZQHDM\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_AS_XBR_XM\": \"li\",\n" +
" \"v_solr6_tb_st_asj_AS_SLDW_GAJGJGDM\": \"460203520000\",\n" +
" \"v_solr6_tb_st_asj_XSJQLBDM_3\": \"100\",\n" +
" \"v_solr6_tb_st_asj_XSJQLBDM_2\": \"100\",\n" +
" \"v_solr6_tb_st_asj_XSJQLBDM_1\": \"100\",\n" +
" \"v_solr6_tb_st_asj_ZCJDDM_2\": \"0600\",\n" +
" \"v_solr6_tb_st_asj_AT_LADW_GAJGMC\": \"三亚市公安局天涯分局新风派出所\",\n" +
" \"v_solr6_tb_st_asj_ZCJDDM_1\": \"0600\",\n" +
" \"v_solr6_tb_st_asj_AS_ZBR_GMSFHM\": \"000000000000000000\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSQ_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AT_ZUZDW_GAJGMC\": \"三亚市公安局天涯分局新风派出所\",\n" +
" \"v_solr6_tb_st_asj_DJSJ_3\": \"20170325\",\n" +
" \"v_solr6_tb_st_asj_DJSJ_2\": \"201703\",\n" +
" \"v_solr6_tb_st_asj_AS_SFGM_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_ZAZBSD_ZAZBSDDM\": \"99\",\n" +
" \"v_solr6_tb_st_asj_AT_SLDW_GAJGMC\": \"三亚市公安局天涯分局新风派出所\",\n" +
" \"v_solr6_tb_st_asj_DJSJ_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_AJ_GEO_POSITION\": \"18.2525,109.50083\",\n" +
" \"v_solr6_tb_st_asj_AS_AJLBDM\": \"05000200\",\n" +
" \"v_solr6_tb_st_asj_XXCZDW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_XXCZDW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_XXCZDW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_SLSJ_3\": \"20170321\",\n" +
" \"v_solr6_tb_st_asj_AN_ASJFSDD_DQWD\": \"18.2525\",\n" +
" \"v_solr6_tb_st_asj_SLSJ_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_SLSJ_2\": \"201703\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ\": \"20170321190545\",\n" +
" \"v_solr6_tb_st_asj_AN_SSJZRMBY\": \"5300\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJLYDM\": \"0900\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSSJ_ZASJ_ZASJLBDM\": \"99\",\n" +
" \"v_solr6_tb_st_asj_LADW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_AS_QH\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_AS_SFMA_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_LADW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_AT_FXASJDD_DZMC\": \"三亚市新风路创新小吃城二楼\",\n" +
" \"v_solr6_tb_st_asj_ZCZJ_ZXSJ01_2\": \"201704\",\n" +
" \"v_solr6_tb_st_asj_ZCZJ_ZXSJ01_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_AT_XXLYMS\": \"fmq_kafka\",\n" +
" \"v_solr6_tb_st_asj_AS_XBR_LXDH\": \"00000000000\",\n" +
" \"v_solr6_tb_st_asj_AT_XXCZDW_GAJGMC\": \"三亚市公安局天涯分局新风派出所\",\n" +
" \"v_solr6_tb_st_asj_ZCZJ_ZXSJ01_3\": \"20170414\",\n" +
" \"v_solr6_tb_st_asj_ZY_PK\": \"A4602035200002017040116\",\n" +
" \"v_solr6_tb_st_asj_RESTYPE\": \"AJ\",\n" +
" \"v_solr6_tb_st_asj_AS_XXCZDW_GAJGJGDM_value\": \"三亚市公安局天涯分局新风派出所\",\n" +
" \"v_solr6_tb_st_asj_SJ_3\": \"20170321\",\n" +
" \"v_solr6_tb_st_asj_SJ_2\": \"201703\",\n" +
" \"v_solr6_tb_st_asj_SJ_1\": \"2017\",\n" +
" \"v_solr6_tb_st_asj_AS_AJLBDM_value\": \"盗窃案\",\n" +
" \"v_solr6_tb_st_asj_AS_ZUZDW_XBR_XM1\": \"liu\",\n" +
" \"v_solr6_tb_st_asj_ZAZBSD_ZAZBSDDM_1\": \"99\",\n" +
" \"v_solr6_tb_st_asj_AS_ZCZJ_ZXSJ01\": \"20170414000000\",\n" +
" \"v_solr6_tb_st_asj_AS_JJBH\": \"001\",\n" +
" \"v_solr6_tb_st_asj_AT_XXDJDW_GAJGMC\": \"三亚市公安局天涯分局新风派出所\"\n" +
" },\n" +
" \"_id\": \"1_A4602035200002017040116\",\n" +
" \"_score\": 2.0\n" +
" },\n" +
" {\n" +
" \"_routing\": \"A460201\",\n" +
" \"_index\": \"ngw_v_solr6_tb_st_asj_new2\",\n" +
" \"_type\": \"doc\",\n" +
" \"_source\": {\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSJSSJ_2\": \"201601\",\n" +
" \"v_solr6_tb_st_asj_AS_SLSJ\": \"20160107071017\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSJSSJ_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_AT_AJMC\": \"抢劫案\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSJSSJ_3\": \"20160107\",\n" +
" \"v_solr6_tb_st_asj_AS_XXCZDW_GAJGJGDM\": \"460203530000\",\n" +
" \"v_solr6_tb_st_asj_AS_LARQ\": \"20160108000000\",\n" +
" \"v_solr6_tb_st_asj_AS_ZUZDW_GAJGJGDM\": \"460203530000\",\n" +
" \"v_solr6_tb_st_asj_XXDJDW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_AS_SJ\": \"20160107070557\",\n" +
" \"v_solr6_tb_st_asj_XXDJDW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_XXDJDW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_AS_DJSJ\": \"20160108150714\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJBH\": \"A4602035300002016010101\",\n" +
" \"v_solr6_tb_st_asj_AS_ZUZDW_ZBR_XM\": \"zhag\",\n" +
" \"v_solr6_tb_st_asj_AS_ZCJDDM\": \"0600\",\n" +
" \"v_solr6_tb_st_asj_AT_ZAZBSD_DMBCMS\": \"结伙\",\n" +
" \"v_solr6_tb_st_asj_AS_SFXSAJ\": \"1\",\n" +
" \"v_solr6_tb_st_asj_SLDW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_SLDW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSJSSJ\": \"20160107071004\",\n" +
" \"v_solr6_tb_st_asj_SLDW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_AS_XXCZRY_XM\": \"zsf\",\n" +
" \"v_solr6_tb_st_asj_QH_2\": \"460200\",\n" +
" \"v_solr6_tb_st_asj_QH_3\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_QH_1\": \"460000\",\n" +
" \"v_solr6_tb_st_asj_AS_XXDJRY_XM\": \"zsf\",\n" +
" \"v_solr6_tb_st_asj_LADW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_AN_PART\": \"1\",\n" +
" \"v_solr6_tb_st_asj_AT_JYAQ\":\"sss\",\n" +
" \"JOIN_FIELD\": \"v_solr6_tb_st_asj\",\n" +
" \"v_solr6_tb_st_asj_LARQ_2\": \"201601\",\n" +
" \"v_solr6_tb_st_asj_LARQ_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_LARQ_3\": \"20160108\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSDD_XZQHDM\": \"460204\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSH_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_ZBR_LXDH\": \"00000000000\",\n" +
" \"v_solr6_tb_st_asj_AN_ASJFSDD_DQJD\": \"109.49514\",\n" +
" \"v_solr6_tb_st_asj_AS_XBR_GMSFHM\": \"000000000000000001\",\n" +
" \"v_solr6_tb_st_asj_AS_XXSC_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_XCKYBH\": \"K46020409\",\n" +
" \"v_solr6_tb_st_asj_AS_GXSJ\": \"20201101020923\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSJDQPCL_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AJLBDM_2\": \"05000100\",\n" +
" \"v_solr6_tb_st_asj_ASJLYDM_2\": \"0100\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSB_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AJLBDM_1\": \"05000000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSKSSJ_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_ASJLYDM_1\": \"0100\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSKSSJ_2\": \"201601\",\n" +
" \"v_solr6_tb_st_asj_AJLBDM_3\": \"05000100\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ASJFSKSSJ_3\": \"20160107\",\n" +
" \"v_solr6_tb_st_asj_AS_XXDJDW_GAJGJGDM\": \"460203530000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSDD_XZQHDM_2\": \"460200\",\n" +
" \"v_solr6_tb_st_asj_FXASJDD_XZQHDM_1\": \"460000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSDD_XZQHDM_1\": \"460000\",\n" +
" \"v_solr6_tb_st_asj_AS_XSJQLBDM\": \"100\",\n" +
" \"v_solr6_tb_st_asj_FXASJDD_XZQHDM_3\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_FXASJDD_XZQHDM_2\": \"460200\",\n" +
" \"v_solr6_tb_st_asj_AS_ZBR_XM\": \"zhj\",\n" +
" \"v_solr6_tb_st_asj_ASJFSSJ_ZASJ_ZASJLBDM_1\": \"99\",\n" +
" \"v_solr6_tb_st_asj_AT_ASJFSDD_DZMC\": \"三亚市\",\n" +
" \"v_solr6_tb_st_asj_AS_LADW_GAJGJGDM\": \"460203530000\",\n" +
" \"v_solr6_tb_st_asj_ASJFSDD_XZQHDM_3\": \"460204\",\n" +
" \"v_solr6_tb_st_asj_AS_FXASJDD_XZQHDM\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_AS_XBR_XM\": \"zsds\",\n" +
" \"v_solr6_tb_st_asj_AS_SLDW_GAJGJGDM\": \"460203530000\",\n" +
" \"v_solr6_tb_st_asj_XSJQLBDM_3\": \"100\",\n" +
" \"v_solr6_tb_st_asj_XSJQLBDM_2\": \"100\",\n" +
" \"v_solr6_tb_st_asj_XSJQLBDM_1\": \"100\",\n" +
" \"v_solr6_tb_st_asj_ZCJDDM_2\": \"0600\",\n" +
" \"v_solr6_tb_st_asj_AT_LADW_GAJGMC\": \"三亚市公安局天涯分局新居派出所\",\n" +
" \"v_solr6_tb_st_asj_ZCJDDM_1\": \"0600\",\n" +
" \"v_solr6_tb_st_asj_AS_ZBR_GMSFHM\": \"000000000000000000\",\n" +
" \"v_solr6_tb_st_asj_AS_SFSQ_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AT_ZUZDW_GAJGMC\": \"三亚市公安局天涯分局新居派出所\",\n" +
" \"v_solr6_tb_st_asj_DJSJ_3\": \"20160108\",\n" +
" \"v_solr6_tb_st_asj_DJSJ_2\": \"201601\",\n" +
" \"v_solr6_tb_st_asj_AS_SFGM_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_ZAZBSD_ZAZBSDDM\": \"99\",\n" +
" \"v_solr6_tb_st_asj_AT_SLDW_GAJGMC\": \"三亚市公安局天涯分局新居派出所\",\n" +
" \"v_solr6_tb_st_asj_DJSJ_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_AJ_GEO_POSITION\": \"18.25708,109.49514\",\n" +
" \"v_solr6_tb_st_asj_AS_AJLBDM\": \"05000100\",\n" +
" \"v_solr6_tb_st_asj_XXCZDW_GAJGJGDM_3\": \"460204000000\",\n" +
" \"v_solr6_tb_st_asj_XXCZDW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_XXCZDW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_SLSJ_3\": \"20160107\",\n" +
" \"v_solr6_tb_st_asj_AN_ASJFSDD_DQWD\": \"18.25708\",\n" +
" \"v_solr6_tb_st_asj_SLSJ_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_SLSJ_2\": \"201601\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ\": \"20160107070557\",\n" +
" \"v_solr6_tb_st_asj_AN_SSJZRMBY\": \"0\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJLYDM\": \"0100\",\n" +
" \"v_solr6_tb_st_asj_AS_ASJFSSJ_ZASJ_ZASJLBDM\": \"99\",\n" +
" \"v_solr6_tb_st_asj_LADW_GAJGJGDM_1\": \"460000000000\",\n" +
" \"v_solr6_tb_st_asj_AS_QH\": \"460203\",\n" +
" \"v_solr6_tb_st_asj_AS_SFMA_PDBZ\": \"0\",\n" +
" \"v_solr6_tb_st_asj_LADW_GAJGJGDM_2\": \"460200000000\",\n" +
" \"v_solr6_tb_st_asj_AT_FXASJDD_DZMC\": \"三亚市儋州社区铁路北巷4号\",\n" +
" \"v_solr6_tb_st_asj_ZCZJ_ZXSJ01_2\": \"201602\",\n" +
" \"v_solr6_tb_st_asj_ZCZJ_ZXSJ01_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_AT_XXLYMS\": \"fmq_kafka\",\n" +
" \"v_solr6_tb_st_asj_AS_XBR_LXDH\": \"00000000000\",\n" +
" \"v_solr6_tb_st_asj_AT_XXCZDW_GAJGMC\": \"三亚市公安局天涯分局新居派出所\",\n" +
" \"v_solr6_tb_st_asj_ZCZJ_ZXSJ01_3\": \"20160215\",\n" +
" \"v_solr6_tb_st_asj_ZY_PK\": \"A4602035300002016010101\",\n" +
" \"v_solr6_tb_st_asj_RESTYPE\": \"AJ\",\n" +
" \"v_solr6_tb_st_asj_AS_XXCZDW_GAJGJGDM_value\": \"三亚市公安局天涯分局新居派出所\",\n" +
" \"v_solr6_tb_st_asj_SJ_3\": \"20160107\",\n" +
" \"v_solr6_tb_st_asj_SJ_2\": \"201601\",\n" +
" \"v_solr6_tb_st_asj_SJ_1\": \"2016\",\n" +
" \"v_solr6_tb_st_asj_AS_AJLBDM_value\": \"抢劫案\",\n" +
" \"v_solr6_tb_st_asj_AS_ZUZDW_XBR_XM1\": \"zsds\",\n" +
" \"v_solr6_tb_st_asj_ZAZBSD_ZAZBSDDM_1\": \"99\",\n" +
" \"v_solr6_tb_st_asj_AS_ZCZJ_ZXSJ01\": \"20160215000000\",\n" +
" \"v_solr6_tb_st_asj_AS_JJBH\": \"M000720994\",\n" +
" \"v_solr6_tb_st_asj_AT_XXDJDW_GAJGMC\": \"三亚市公安局天涯分局新居派出所\"\n" +
" },\n" +
" \"_id\": \"1_A4602101\",\n" +
" \"_score\": 2.0\n" +
" }\n" +
" ],\n" +
" \"total\": 2,\n" +
" \"max_score\": 2.0\n" +
" },\n" +
" \"took\": 527,\n" +
" \"timed_out\": false,\n" +
" \"aggregations\": {\n" +
" \"xbfl1\": {\n" +
" \"doc_count_error_upper_bound\": 0,\n" +
" \"sum_other_doc_count\": 0,\n" +
" \"buckets\": [\n" +
" {\n" +
" \"doc_count\": 33259,\n" +
" \"key\": \"05000300\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 20987,\n" +
" \"key\": \"05000200\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 1727,\n" +
" \"key\": \"05000100\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 1287,\n" +
" \"key\": \"05000400\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 1055,\n" +
" \"key\": \"05000000\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 790,\n" +
" \"key\": \"05001000\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 372,\n" +
" \"key\": \"05000700\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 174,\n" +
" \"key\": \"05001100\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 36,\n" +
" \"key\": \"05000800\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 34,\n" +
" \"key\": \"05001300\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 27,\n" +
" \"key\": \"05000900\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 10,\n" +
" \"key\": \"05000600\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 4,\n" +
" \"key\": \"05001200\"\n" +
" },\n" +
" {\n" +
" \"doc_count\": 1,\n" +
" \"key\": \"05000200_12\"\n" +
" }\n" +
" ]\n" +
" }\n" +
" }\n" +
" }\n" +
" }\n" +
"}";
return JSONObject.parseObject(resutStr);
}
@RequestMapping("/AsjApiByZjhm")
public Result AsjApiByZjhm(@RequestBody XyrParam xyr){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(xyr.getZjhm()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入证件号码，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
List<Map<String,Object>> listResult = new ArrayList<>();
AsjRyRelateVoBzpt asj=new AsjRyRelateVoBzpt();
JSONObject jsonParams = new JSONObject();
jsonParams.put("index","tb_st_asj");// 索引名称
jsonParams.put("request",JSONObject.parse(xxcxService.getEsAsjQryStr(xyr)));// 请求json
System.out.println("----"+jsonParams.toJSONString());
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabesUrl+"search",params,JSONObject.class).getBody();
// JSONObject resultJson =getAsjResultJson();
LinkedHashMap json = (LinkedHashMap) resultJson.get("result");
LinkedHashMap jsonResponse = (LinkedHashMap) json.get("response");
LinkedHashMap jsonHit = (LinkedHashMap) jsonResponse.get("hits");
int total = (int) jsonHit.get("total");
if(total > 0 ){
List<LinkedHashMap> jsonHitArray = (List<LinkedHashMap>) jsonHit.get("hits");
SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddhhmmss");
for(int i=0;i<jsonHitArray.size();i++){
Map map = new HashMap();
LinkedHashMap obj = (LinkedHashMap) jsonHitArray.get(i).get("_source");
String asjbh = (String) obj.get("v_solr6_tb_st_asj_AS_ASJBH");
String ajmc = (String) obj.get("v_solr6_tb_st_asj_AT_AJMC");
String ajlbdmMc = (String) obj.get("v_solr6_tb_st_asj_AS_AJLBDM_value");// 案件类别名称
String ajlbdm = (String) obj.get("v_solr6_tb_st_asj_AS_AJLBDM");// 案件类别代码
String ajzlbMc = (String) obj.get("v_solr6_tb_st_asj_AS_ZATZ_JYQK_value");// 小案类别
String ajxzlbMc = (String) obj.get("tb_st_asj_asjbz_AJXLB_VALUE");// 细类案类别
String bzrXm = (String) obj.get("tb_st_asj_asjbz_XXCZRY_XM");// 标注人姓名
String bzrDwdmMc = (String) obj.get("tb_st_asj_asjbz_XXCZDW_GAJGJGDM_VALUE");// 标注人单位
String asjfsddDzmc = (String) obj.get("v_solr6_tb_st_asj_AT_ASJFSDD_DZMC");// 案发地详细地址
String asjfsddXzqh = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSDD_XZQHDM");// 案发地详细地址
String ssjzrmby = (String) obj.get("v_solr6_tb_st_asj_AN_SSJZRMBY");// 损失总价值
String larq = (String) obj.get("v_solr6_tb_st_asj_AS_LARQ");// 立案日期
String ladwdm = (String) obj.get("v_solr6_tb_st_asj_AS_LADW_GAJGJGDM");// 立案单位代码
String ladwMc = (String) obj.get("v_solr6_tb_st_asj_AT_LADW_GAJGMC");// 立案单位名称
String asjfssjAsjfskssj = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ");// 案发开始时间
String asjfssjAsjfsjssj = (String) obj.get("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSJSSJ");// 案发结束时间
String jyaq = (String) obj.get("v_solr6_tb_st_asj_AT_JYAQ");// 简要案情
String bzztMs = (String) obj.get("tb_st_asj_asjbz_BZZT_VALUE");// 标注状态描述
String bzzt = (String) obj.get("tb_st_asj_asjbz_BZZT");// 标注状态
String zcjddm=(String) obj.get("v_solr6_tb_st_asj_AS_ZCJDDM");//侦查阶段代码
String zbrxm=(String) obj.get("v_solr6_tb_st_asj_AS_ZUZDW_ZBR_XM");//主办人姓名
String zbrdwmc=(String) obj.get("v_solr6_tb_st_asj_AT_ZUZDW_GAJGMC");//主办人单位名称
map.put("asjbh",asjbh);
map.put("ajmc",ajmc);
map.put("ajlbdmMc",ajlbdmMc);
map.put("zcjddm",zcjddm);
map.put("ajlbdm",ajlbdm);
map.put("ajzlbMc",ajzlbMc);
map.put("ajxzlbMc",ajxzlbMc);
map.put("bzrDwdmMc",bzrDwdmMc);
map.put("bzrXm",bzrXm);
map.put("asjfsddDzmc",asjfsddDzmc);
map.put("ssjzrmby",ssjzrmby);
map.put("zbrxm",zbrxm);
map.put("zbrdwmc",zbrdwmc);
map.put("asjfsddXzqh",asjfsddXzqh);
// if(null!=ladwPcs){
// ladwMc = detailervice.getDwMcBydm(ladwPcs);
// }
map.put("ladwdm",ladwdm);
map.put("ladwMc",ladwMc);
// 立案日期和案发日期 过滤
if(null != larq){
try {
map.put("larq",sf.parse(larq));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("larq","无");
}
if(null != asjfssjAsjfskssj){
try {
map.put("asjfssjAsjfskssj",sf.parse(asjfssjAsjfskssj));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("asjfssjAsjfskssj","无");
}
if(null != asjfssjAsjfsjssj){
try {
map.put("asjfssjAsjfsjssj",sf.parse(asjfssjAsjfsjssj));
} catch (ParseException e) {
e.printStackTrace();
}
}else{
map.put("asjfssjAsjfsjssj","无");
}
if(StringUtils.isEmpty(bzztMs)){
map.put("bzztMs","未标注");
}else{
map.put("bzztMs",bzztMs);
}
map.put("bzzt",bzzt);
map.put("jyaq",jyaq);
listResult.add(map);
}
}
mapResult.put("total",total);
mapResult.put("rows",listResult);
reslt.setData(mapResult);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
@RequestMapping("/AsjApiGroupByZjhm")
public Result AsjApiGroupByZjhm(@RequestBody AsjRyRelateVoBzpt asjbl){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(asjbl.getAsjbh()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入案件编号，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
mapResult.put("isExist","flase");
List<Map<String,Object>> listResult = new ArrayList<>();
AsjRyRelateVoBzpt asj=new AsjRyRelateVoBzpt();
asj.setAsjbh(asjbl.getAsjbh());
JSONObject jsonParams = new JSONObject();
jsonParams.put("index","tb_xw_zbfzxyr");// 索引名称
jsonParams.put("request",JSONObject.parse(xxcxService.getCountByAsjbhNum1()));// 请求json
System.out.println("----"+jsonParams.toJSONString());
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabesUrl+"search",params,JSONObject.class).getBody();
System.out.println("result---"+resultJson.toJSONString());
// LinkedHashMap json = (LinkedHashMap) resultJson.get("result");
// LinkedHashMap jsonResponse = (LinkedHashMap) json.get("response");
// LinkedHashMap jsonHit = (LinkedHashMap) jsonResponse.get("hits");
// int total = (int) jsonHit.get("total");
// if(total > 0 ){
// mapResult.put("isExist","true");
// }
reslt.setData(mapResult);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
@RequestMapping("/AsjApiGroupByZjhm3")
public Result AsjApiGroupByZjhm3(@RequestBody AsjRyRelateVoBzpt asjbl){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(asjbl.getAsjbh()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入案件编号，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
mapResult.put("isExist","flase");
List<Map<String,Object>> listResult = new ArrayList<>();
AsjRyRelateVoBzpt asj=new AsjRyRelateVoBzpt();
asj.setAsjbh(asjbl.getAsjbh());
JSONObject jsonParams = new JSONObject();
jsonParams.put("index","tb_xw_zbfzxyr");// 索引名称
jsonParams.put("request",JSONObject.parse(xxcxService.getCountByAsjbhNum3()));// 请求json
System.out.println("----"+jsonParams.toJSONString());
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabesUrl+"search",params,JSONObject.class).getBody();
System.out.println("result---"+resultJson.toJSONString());
// LinkedHashMap json = (LinkedHashMap) resultJson.get("result");
// LinkedHashMap jsonResponse = (LinkedHashMap) json.get("response");
// LinkedHashMap jsonHit = (LinkedHashMap) jsonResponse.get("hits");
// int total = (int) jsonHit.get("total");
// if(total > 0 ){
// mapResult.put("isExist","true");
// }
reslt.setData(mapResult);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
@RequestMapping("/AsjApiIsExist")
public Result AsjApiIsExist(@RequestBody AsjRyRelateVoBzpt asjbl){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(asjbl.getAsjbh()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入案件编号，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
mapResult.put("isExist","false");
List<Map<String,Object>> listResult = new ArrayList<>();
AsjRyRelateVoBzpt asj=new AsjRyRelateVoBzpt();
asj.setAsjbh(asjbl.getAsjbh());
JSONObject jsonParams = new JSONObject();
jsonParams.put("index","tb_st_asj");// 索引名称
jsonParams.put("request",JSONObject.parse(queryJson(asj)));// 请求json
System.out.println("----"+jsonParams.toJSONString());
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabesUrl+"search",params,JSONObject.class).getBody();
LinkedHashMap json = (LinkedHashMap) resultJson.get("result");
LinkedHashMap jsonResponse = (LinkedHashMap) json.get("response");
LinkedHashMap jsonHit = (LinkedHashMap) jsonResponse.get("hits");
int total = (int) jsonHit.get("total");
if(total > 0 ){
mapResult.put("isExist","true");
}
reslt.setData(mapResult);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
@RequestMapping("/zbfzxyrxxByAsjbh")
public Result zbfzxyrxxByAsjbh(@RequestBody AsjRyRelateVoBzpt asjbl){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(asjbl.getAsjbh()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入案件编号，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
Map<String, Object> resultMap = new HashMap<String, Object>();
//通过案件编号拿到受害人信息
//如没有案件编号表示没有相关联的受害人信息
//拿到身份证号码调用人员常口---数据库落地数据基本只有身份证号码
Qgckzp getzp = new Qgckzp(); //全国人员常口
List<TbStRy> listTbStRy = new ArrayList<>();
AsjRyRelateVoBzpt asj=new AsjRyRelateVoBzpt();
asj.setAsjbh(asjbl.getAsjbh());
JSONObject jsonParams = new JSONObject();
jsonParams.put("asjbh",asj.getAsjbh());
jsonParams.put("from","0");
jsonParams.put("size","1000");
HttpEntity<Map<String,Object>> params = new HttpEntity<>(jsonParams,getHeaders(asj));// 请求头
JSONObject resultJson = restTemplate.postForEntity(gabUrl+"xyr",params,JSONObject.class).getBody();
List<LinkedHashMap> jsonHitArray = (List<LinkedHashMap>) resultJson.get("result");
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
if(jsonHitArray.size()>0){
for(int i=0;i<jsonHitArray.size();i++){
TbStRy tbStRy = new TbStRy();
LinkedHashMap obj = (LinkedHashMap) jsonHitArray.get(i);
String xm = (String) obj.get("ZHFZXYR_XM");// 姓名
String xzzDzmc = (String) obj.get("ZHFZXYR_XZZ_DZMC");// 现住址
String lxdh = (String) obj.get("ZHFZXYR_LXDH");// 联系电话
String csrq = (String) obj.get("ZHFZXYR_CSRQ_RQGZXX");// 出生日期
String cyzjZjhm = (String) obj.get("ZHFZXYR_CYZJ_ZJHM");// 证件号码
String xbdm = (String) obj.get("ZHFZXYR_XBDM");// 性别
String mzdm = (String) obj.get("ZHFZXYR_MZDM");// 民族
String gjdm = (String) obj.get("ZHFZXYR_GJDM");// 国际
tbStRy.setXm(xm);
tbStRy.setXzzDzmc(xzzDzmc);
tbStRy.setLxdh(lxdh);
if(StringUtils.isNotEmpty(csrq)){
try {
tbStRy.setCsrq(sf.format(sf.parse(csrq)));
} catch (ParseException e) {
e.printStackTrace();
}
}
HashMap<String,String> codeMap = new HashMap<String,String>();
// 性别
if(StringUtils.isNotEmpty(xbdm)){
// 翻译行政区划
codeMap.put("groupid","CODE_XB");
codeMap.put("code",xbdm);
tbStRy.setXbdm(xbdm);
// String name = sysDictitemMapper.getNameByCode(codeMap);
// tbStRy.setXbdmStr(name);
}
// 民族
if(StringUtils.isNotEmpty(mzdm)){
// 翻译行政区划
codeMap.put("groupid","CODE_MZ");
codeMap.put("code",mzdm);
tbStRy.setMzdm(mzdm);
// String name = sysDictitemMapper.getNameByCode(codeMap);
// tbStRy.setMzdmStr(name);
}
// 国籍
if(StringUtils.isNotEmpty(gjdm)){
// 翻译行政区划
codeMap.put("groupid","CODE_GJ");
codeMap.put("code",gjdm);
tbStRy.setGjdm(gjdm);
// String name = sysDictitemMapper.getNameByCode(codeMap);
// tbStRy.setGjdm(name);
}
tbStRy.setCyzjZjhm(cyzjZjhm);
// if (cyzjZjhm != null && !"".equals(cyzjZjhm.trim())) {
// String ryzp = getzp.getQgckZpXml(cyzjZjhm);// 获取人员照片
// tbStRy.setZp(ryzp);
// }
listTbStRy.add(tbStRy);
}
}
String zbfzxyrCount = "0";
if(listTbStRy!=null){
zbfzxyrCount = ""+listTbStRy.size();
}
resultMap.put("total",zbfzxyrCount);
resultMap.put("rows",listTbStRy);
reslt.setData(resultMap);
reslt.setMsg("案件信息查询成功");
reslt.setStatus("success");
return reslt;
}
public HttpHeaders getHeaders(AsjRyRelateVoBzpt asj) {
HttpHeaders hearders = new HttpHeaders();
// 设置请求头的格式类型
hearders.setContentType(MediaType.APPLICATION_JSON);
hearders.set("app_key",app_key);
hearders.set("app_secret",app_secret);
hearders.set("moduleId",moduleId);
hearders.set("moduleName",moduleName);
hearders.set("userCardId","460000");
hearders.set("userName","admin");
hearders.set("userDept","460000");
hearders.set("userDeptName","海南省公安厅");
hearders.set("zdsbip","74.25.21.65");
return hearders;
}
public String queryJson(AsjRyRelateVoBzpt asj) {
String sortStr1 = "," + "\"sort\": {";//排序
String sortStr2 = "}";
String ascOrdesc = "desc";
if(asj.getPage()==null||"".equals(asj.getPage())){
asj.setPage("1");
}
if(asj.getLimit()==null||"".equals(asj.getLimit())){
asj.setLimit("10");
}
String fenye = ",\"from\":" + (((Integer.parseInt(asj.getPage()) - 1) * Integer.parseInt(asj.getLimit()))) + ",\"size\":" + asj.getLimit();
String unitCode = asj.getUnitcode();
String grade = asj.getGrade();
//编辑查询条件
String qbStr1 = "{\"query\": {\"bool\": {";
String qbStr2 = "}}, \"track_total_hits\": true";
String sortQ = "\"" + "v_solr6_tb_st_asj_AS_LARQ" + "\"" + ": { \"order\": \"" + ascOrdesc + "\"}";
String sortjson = sortStr1 + sortQ + sortStr2 + fenye;
qbStr2 += sortjson + "}";
String shouldStr1 = ",\"should\": [";
String shouldStr2 = "]";
String matchstr1 = "{\"match\": {";
String matchstr2 = "}}";
String must1 = "\"must\": [";
String must2 = "]";
String must_not1 = "\"must_not\": [";
String must_not2 = "]";
String mmsStr1 = "\"must_not\": [{\"match\": {";
String mmsStr2 = "}}]";
String wildcardStr1 = "{\"wildcard\": {";//模糊查询
String wildcardStr2 = "}}";
String rangStr1 = "{\"range\": {";//日期范围
String rangStr2 = "}}}";
String existStr1 = "{\"exists\": {";//非空
String existStr2 = "}}";
String filterStr1 = "\"filter\": [";
String filterStr2 = "]";
// // 根据用户grade判断 B公安部 S省级 D地市 X县级 K派出所
if("B".equals(grade)){
asj.setLadw_gajgjgdm("B");
}else if("S".equals(grade)){
asj.setLadw_gajgjgdm(asj.getUnitcode().substring(0,2));
}else if("D".equals(grade)){
asj.setLadw_gajgjgdm(asj.getUnitcode().substring(0,4));
}else if("X".equals(grade)){
asj.setLadw_gajgjgdm(asj.getUnitcode().substring(0,6));
}else if("K".equals(grade)){
asj.setLadw_gajgjgdm(asj.getUnitcode().substring(0,6));
}
String q = matchstr1 + "\"v_solr6_tb_st_asj_AS_XXSC_PDBZ\" : \"0\"" + matchstr2;// 默认删除标志为0
String q1 = "";//must_not
String q2 = "";//should
// q += ",{\"bool\" : { \"should\" : [{\"terms\" : {\"v_solr6_tb_st_asj_AS_AJLBDM\" : [\"05000200\",\"05000300\",\"05000100\",\"05000400\",\"06010300\",\"05001000\",\"04000900\",\"06012400\",\"05001100\",\"06012300\",\"03080700\",\"04000300\",\"06015400\"]}}]}}";
if (StringUtils.isNotEmpty(asj.getAsjbh())) {// 案件编号
q += "," + matchstr1 + "\"v_solr6_tb_st_asj_AS_ASJBH\" : \"" + asj.getAsjbh() + "\"" + matchstr2;
}
if (StringUtils.isNotEmpty(asj.getAjlbdm())) {// 案件类别
q += "," + matchstr1 + "\"v_solr6_tb_st_asj_AS_AJLBDM\" : \"" + asj.getAjlbdm() + "\"" + matchstr2;
}
if (StringUtils.isNotEmpty(asj.getXszalxdm())) {// 小案类别
q += "," + matchstr1 + "\"v_solr6_tb_st_asj_AS_ZATZ_JYQK\" : \"" + asj.getXszalxdm() + "\"" + matchstr2;
}
if (StringUtils.isNotEmpty(asj.getXslalxdm())) {// 案件细类别
q += "," + matchstr1 + "\"tb_st_asj_asjbz_AJXLB\" : \"" + asj.getXslalxdm() + "\"" + matchstr2;
}
if (StringUtils.isNotEmpty(asj.getLadw_gajgjgdm())&&!"B".equals(asj.getLadw_gajgjgdm())
&&StringUtils.isEmpty(asj.getLadw_gajgjgdms())&& StringUtils.isEmpty(asj.getBzrDwdm())) {// 默认登陆者立案单位代码 当不选择立案单位查询条件时 公安部用户查所有
String unitcode = asj.getLadw_gajgjgdm();
if(unitCode.endsWith("0000000000")){
unitCode=unitcode.substring(0,2) + "*";
}else if(unitCode.endsWith("00000000")){
unitCode=unitcode.substring(0,4)+ "*";
}else if(unitCode.endsWith("000000")){
unitCode=unitcode.substring(0,6)+ "*";
}else if(unitCode.endsWith("0000")){
unitCode=unitcode.substring(0,8)+ "*";
}
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AS_LADW_GAJGJGDM\" : \"" + unitCode + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getLadw_gajgjgdm())
&&StringUtils.isNotEmpty(asj.getLadw_gajgjgdms())) {// 查询条件立案单位代码当选择立案单位查询条件时情况 立案单位根据规则截取模糊查询
String unitcode = asj.getLadw_gajgjgdms();
if(unitcode.endsWith("0000000000")){
unitcode=unitcode.substring(0,2) + "*";
}else if(unitcode.endsWith("00000000")){
unitcode=unitcode.substring(0,4)+ "*";
}else if(unitcode.endsWith("000000")){
unitcode=unitcode.substring(0,6)+ "*";
}else if(unitcode.endsWith("0000")){
unitcode=unitcode.substring(0,8)+ "*";
}
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AS_LADW_GAJGJGDM\" : \"" + unitcode + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getLasjRqsjKssj()) && StringUtils.isNotEmpty(asj.getLasjRqsjKssj())
&&!asj.getLasjRqsjKssj().equals(asj.getLasjRqsjJssj())) {// 立案时间
if(null != asj.getLasjRqsjJssj() && !"".equals(asj.getLasjRqsjJssj())){
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AS_LARQ\" : {\"lte\": \"" + simpleTime(asj.getLasjRqsjJssj()) + "\"" + ",\"gte\": \"" + simpleTime(asj.getLasjRqsjKssj()) + "\"" + rangStr2;
}else{
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AS_LARQ\" : {\"gte\": \"" + simpleTime(asj.getLasjRqsjKssj()) + "\"" + rangStr2;
}
} else if (StringUtils.isNotEmpty(asj.getLasjRqsjJssj()) && StringUtils.isEmpty(asj.getLasjRqsjKssj())) {
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AS_LARQ\" : {\"lte\": \"" + simpleTime(asj.getLasjRqsjJssj()) + "\"" + rangStr2;
} else if (StringUtils.isNotEmpty(asj.getLasjRqsjKssj()) && StringUtils.isNotEmpty(asj.getLasjRqsjJssj())
&&asj.getLasjRqsjKssj().equals(asj.getLasjRqsjJssj())) {
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AS_LARQ\" : \"" + simpleTime(asj.getLasjRqsjKssj()) + "*\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getAsjfssjKssj()) && StringUtils.isNotEmpty(asj.getAsjfssjKssj())
&&!asj.getAsjfssjKssj().equals(asj.getAsjfssjJssj())) {// 案发时间
if(null != asj.getAsjfssjJssj() && !"".equals(asj.getAsjfssjJssj())){
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ\" : {\"lte\": \"" + simpleTime(asj.getAsjfssjJssj()) + "\"" + ",\"gte\": \"" + simpleTime(asj.getAsjfssjKssj()) + "\"" + rangStr2;
}else{
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ\" : {\"gte\": \"" + simpleTime(asj.getAsjfssjKssj()) + "\"" + rangStr2;
}
} else if (StringUtils.isNotEmpty(asj.getAsjfssjJssj()) && StringUtils.isEmpty(asj.getAsjfssjKssj())) {
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ\" : {\"lte\": \"" + simpleTime(asj.getAsjfssjJssj()) + "\"" + rangStr2;
} else if (StringUtils.isNotEmpty(asj.getAsjfssjKssj()) && StringUtils.isNotEmpty(asj.getAsjfssjJssj())
&&asj.getAsjfssjKssj().equals(asj.getAsjfssjJssj())) {
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ\" : \"" +simpleTime(asj.getAsjfssjJssj()) + "*\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getBzzt())) {// 标注状态
// 已标注
if("1".equals(asj.getBzzt())){
q += "," + matchstr1 + "\"tb_st_asj_asjbz_BZZT\" : \"" + asj.getBzzt() + "\"" + matchstr2;
}else{// 未标注
q1 += matchstr1 + "\"tb_st_asj_asjbz_BZZT\" : \"1\"" + matchstr2;
}
}
if (StringUtils.isNotEmpty(asj.getSsjzMin()) && StringUtils.isNotEmpty(asj.getSsjzMin())) {// 损失总值
if(null != asj.getSsjzMax() && !"".equals(asj.getSsjzMax())){
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AN_SSJZRMBY\" : {\"lte\": \"" + asj.getSsjzMax() + "\"" + ",\"gte\": \"" + asj.getSsjzMin() + "\"" + rangStr2;
}else{
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AN_SSJZRMBY\" : {\"gte\": \"" + asj.getSsjzMax() + "\"" + rangStr2;
}
} else if (StringUtils.isNotEmpty(asj.getSsjzMax()) && StringUtils.isEmpty(asj.getSsjzMin())) {
q += "," + rangStr1 + "\"v_solr6_tb_st_asj_AN_SSJZRMBY\" : {\"lte\": \"" + asj.getSsjzMax() + "\"" + rangStr2;
}
if (StringUtils.isNotEmpty(asj.getAsjfsdd_xzqhdm())) {// 案发地行政区划模糊查询
String asjfsddXzqh = asj.getAsjfsdd_xzqhdm();
if(asjfsddXzqh.endsWith("0000")){
asjfsddXzqh=asjfsddXzqh.substring(0,2) + "*";
}else if(asjfsddXzqh.endsWith("00")){
asjfsddXzqh=asjfsddXzqh.substring(0,4)+ "*";
}else{
asjfsddXzqh = asjfsddXzqh;
}
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AS_ASJFSDD_XZQHDM\" : \"" + asjfsddXzqh + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getAsjfsddDzmc())) {// 案发地详细地址模糊查询
String asjfsddMc = "*" + asj.getAsjfsddDzmc() + "*";
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AT_ASJFSDD_DZMC\" : \"" + asjfsddMc + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getJyaq())) {// 简要案情
String jyaq = "*" + asj.getJyaq() + "*";
q += "," + wildcardStr1 + "\"v_solr6_tb_st_asj_AT_JYAQ\" : \"" + jyaq + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getBzrXm())) {// 标注人姓名
q += "," + matchstr1 + "\"tb_st_asj_asjbz_XXCZRY_XM\" : \"" + asj.getBzrXm() + "\"" + matchstr2;
}
if (StringUtils.isNotEmpty(asj.getBzrDwdm())) {// 标注人单位模糊查询
String unitcode = asj.getBzrDwdm();
if(unitCode.endsWith("0000000000")){
unitCode=unitcode.substring(0,2) + "*";
}else if(unitCode.endsWith("00000000")){
unitCode=unitcode.substring(0,4)+ "*";
}else if(unitCode.endsWith("000000")){
unitCode=unitcode.substring(0,6)+ "*";
}else if(unitCode.endsWith("0000")){
unitCode=unitcode.substring(0,4)+ "*";
}
q += "," + wildcardStr1 + "\"tb_st_asj_asjbz_XXCZDW_GAJGJGDM\" : \"" + unitCode + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getBzrSfzh())) {// 标注人身份证号码
q += "," + wildcardStr1 + "\"tb_st_asj_asjbz_XXCZRY_GMSFHM\" : \"" + asj.getBzrSfzh() + "\"" + wildcardStr2;
}
if (StringUtils.isNotEmpty(asj.getCyclzt())) {// 查询退回
q += existStr1 + "\"field\":\"tb_st_asj_asjbz_HTMS\"" + existStr2;
}
q1 = "," + must_not1 + q1 + must_not2;
q2 = shouldStr1 + q2 + shouldStr2;
q = qbStr1 + must1 + q + must2 + q2 + q1 + qbStr2;
System.out.println("调用部查询接口es条件为:"+q);
return q;
}
public static String simpleTime(String time) {
SimpleDateFormat sf = new SimpleDateFormat("yyyyMMdd");
String date = "";
date = sf.format(java.sql.Date.valueOf(time));
return date;
}
@RequestMapping("/barxxcx")
public Result queryBarxx(@RequestBody TbXwBaView param){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
List<TbXwBaView> tbXwBaViews = new ArrayList<>();
try {
if(StringUtils.isEmpty(param.getAsjbh()) && StringUtils.isEmpty(param.getBarCyzjCyzjhm())){
reslt.setData(new ArrayList<>());
reslt.setMsg("查询参数为空，不能查询！");
reslt.setStatus("fail");
return reslt;
}
tbXwBaViews = xxcxService.queryTbXwBa(param);
reslt.setData(tbXwBaViews);
reslt.setMsg("报案人信息查询成功");
reslt.setStatus("success");
} catch (Exception e) {
reslt.setData(tbXwBaViews);
reslt.setMsg("报案人信息查询失败\n"+e.getMessage());
reslt.setStatus("error");
e.printStackTrace();
}
return reslt;
}
@RequestMapping("/jjxxcx")
public Result queryJjxx(@RequestBody TbZhzxJjxxView param){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
List<TbZhzxJjxxView> tbZhzxJjxxViews = new ArrayList<>();
try {
if(StringUtils.isEmpty(param.getJjdbh()) && StringUtils.isEmpty(param.getBjrxm()) && StringUtils.isEmpty(param.getJjyxm()) && StringUtils.isEmpty(param.getAsjbh())){
reslt.setData(new ArrayList<>());
reslt.setMsg("查询参数为空，不能查询！");
reslt.setStatus("fail");
return reslt;
}
tbZhzxJjxxViews = xxcxService.queryJjxx(param);
reslt.setData(tbZhzxJjxxViews);
reslt.setMsg("接警信息查询成功");
reslt.setStatus("success");
} catch (Exception e) {
reslt.setData(tbZhzxJjxxViews);
reslt.setMsg("接警信息查询失败\n"+e.getMessage());
reslt.setStatus("error");
e.printStackTrace();
}
return reslt;
}
@RequestMapping("/cjxxcx")
public Result queryCjxx(@RequestBody TbZhzxCjxxView param){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
if(StringUtils.isEmpty(header) || !author.equals(header)){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有授权码或者授权码验证未通过，不能查询！");
reslt.setStatus("fail");
return reslt;
}
List<TbZhzxCjxxView> tbZhzxCjxxViews = new ArrayList<>();
try {
if(StringUtils.isEmpty(param.getJjdbh()) && StringUtils.isEmpty(param.getPjdbh()) && StringUtils.isEmpty(param.getPjyxm()) && StringUtils.isEmpty(param.getAsjbh())){
reslt.setData(new ArrayList<>());
reslt.setMsg("查询参数为空，不能查询！");
reslt.setStatus("fail");
return reslt;
}
tbZhzxCjxxViews = xxcxService.queryCjxx(param);
reslt.setData(tbZhzxCjxxViews);
reslt.setMsg("处警信息查询成功");
reslt.setStatus("success");
} catch (Exception e) {
reslt.setData(tbZhzxCjxxViews);
reslt.setMsg("处警信息查询失败\n"+e.getMessage());
reslt.setStatus("error");
e.printStackTrace();
}
return reslt;
}
}
src/main/java/com/founder/service/XxcxService.java deleted 100644 → 0
package com.founder.service;
import com.founder.model.*;
import java.util.List;
public interface XxcxService {
public List<TbStAsjView> queryTbStAsj(String asjbh,String sfzh);
public TbStAsjView queryTbStAsjByAsjbh(String asjbh);
TbStAsjView queryTbStAsjByJjdbh(String jjdbh);
List<TbXwRybhView> queryTbXwRybh(TbXwRybhView param);
String getEsAsjQryStr(XyrParam xyr);
String getCountByAsjbhNum1();
String getCountByAsjbhNum3();
List<TbXwBaView> queryTbXwBa(TbXwBaView param);
List<TbZhzxJjxxView> queryJjxx(TbZhzxJjxxView param);
List<TbZhzxCjxxView> queryCjxx(TbZhzxCjxxView param);
}
src/main/java/com/founder/service/impl/XxcxServiceImpl.java deleted 100644 → 0
package com.founder.service.impl;
import com.founder.dao.XxcxDao;
import com.founder.model.*;
import com.founder.service.XxcxService;
import org.apache.commons.lang3.StringUtils;
import org.apache.lucene.search.join.ScoreMode;
import org.elasticsearch.index.query.*;
import org.elasticsearch.join.query.JoinQueryBuilders;
import org.elasticsearch.script.Script;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.elasticsearch.join.query.HasChildQueryBuilder;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import static org.elasticsearch.search.sort.SortOrder.DESC;
@Service
public class XxcxServiceImpl implements XxcxService {
@Autowired
private XxcxDao xxcxDao;
@Override
public List<TbStAsjView> queryTbStAsj(String asjbh, String sfzh) {
List<TbStAsjView> tbStAsjViews = new ArrayList<>();
if(!StringUtils.isEmpty(asjbh)){
}else if(!StringUtils.isEmpty(sfzh)){
String ajbh = "";
}
return tbStAsjViews;
}
@Override
public TbStAsjView queryTbStAsjByAsjbh(String asjbh){
TbStAsjView tbStAsjView = null;
TbStAsj param = new TbStAsj();
param.setAsjbh(asjbh);
TbStAsj tbStAsj = xxcxDao.queryTbStAsj(param);
if(tbStAsj!=null){
tbStAsjView = new TbStAsjView();
tbStAsjView.setAjlbdm(tbStAsj.getAjlbdm());
tbStAsjView.setAjmc(tbStAsj.getAjmc());
tbStAsjView.setZcjddm(tbStAsj.getZcjddm());
tbStAsjView.setAsjbh(tbStAsj.getAsjbh());
tbStAsjView.setAsjfsddDzmc(tbStAsj.getAsjfsddDzmc());
tbStAsjView.setAsjfsddXzqhdm(tbStAsj.getAsjfsddXzqhdm());
tbStAsjView.setAsjfssjAsjfsjssj(tbStAsj.getAsjfssjAsjfsjssj());
tbStAsjView.setAsjfssjAsjfskssj(tbStAsj.getAsjfssjAsjfskssj());
tbStAsjView.setGxsj(tbStAsj.getGxsj());
tbStAsjView.setJyaq(tbStAsj.getJyaq());
tbStAsjView.setLadwGajgjgdm(tbStAsj.getLadwGajgjgdm());
tbStAsjView.setLadwGajgmc(tbStAsj.getLadwGajgmc());
tbStAsjView.setLarq(tbStAsj.getLarq());
tbStAsjView.setSlsj(tbStAsj.getSlsj());
tbStAsjView.setXxlyms(tbStAsj.getXxlyms());
tbStAsjView.setZczjZxsj(tbStAsj.getZczjZxsj01());
tbStAsjView.setAsjlydm(tbStAsj.getAsjlydm());
tbStAsjView.setSsjzrmby(tbStAsj.getSsjzrmby());
tbStAsjView.setJjdbh(tbStAsj.getJjbh());
}
return tbStAsjView;
}
private BoolQueryBuilder getBoolXyr(XyrParam xyr) {
BoolQueryBuilder bqXyr = QueryBuilders.boolQuery();
// 信息删除判断标志
TermsQueryBuilder termQueryBuilderXxsc = QueryBuilders.termsQuery("v_solr6_tb_xw_zbfzxyr_PS_XXSC_PDBZ", "0");
bqXyr.must(termQueryBuilderXxsc);
//姓名
if (StringUtils.isNotEmpty(xyr.getXm())) {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_XM", "*" + xyr.getXm() + "*");
bqXyr.must(wildcardQueryBuilder);
}
if (StringUtils.isNotEmpty(xyr.getZjhm())) {
String [] zjhms=xyr.getZjhm().split(",");
BoolQueryBuilder zjBuilder=new BoolQueryBuilder();
for(int i=0;i<zjhms.length;i++){
zjBuilder.should(QueryBuilders.termsQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_CYZJ_ZJHM", zjhms[i]));
}
// TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_CYZJ_ZJHM", xyr.getZjhm());
// bqXyr.must(termQueryBuilder);
bqXyr.must(zjBuilder);
}
//性别
if (StringUtils.isNotEmpty(xyr.getXbdm())) {
TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_XBDM", xyr.getXbdm());
bqXyr.must(termQueryBuilder);
}
//抓获日期
// if (StringUtils.isNotEmpty(xyr.getZhrqKssj()) && StringUtils.isNotEmpty(xyr.getZhrqJssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHRQ").gte(xyr.getZhrqKssj()).lte(DateUtil.EndDateAdd(xyr.getZhrqJssj()));
// bqXyr.must(rangeQueryBuilder);
// } else {
// if (StringUtils.isNotEmpty(xyr.getZhrqKssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHRQ").gte(xyr.getZhrqKssj());
// bqXyr.must(rangeQueryBuilder);
// }
// if (StringUtils.isNotEmpty(xyr.getZhrqJssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHRQ").lte(DateUtil.EndDateAdd(xyr.getZhrqJssj()));
// bqXyr.must(rangeQueryBuilder);
// }
// }
//抓获单位
if (StringUtils.isNotEmpty(xyr.getZhdwdm())) {
String unitcode = xyr.getZhdwdm();
if (unitcode.endsWith("0000000000")) {
unitcode = unitcode.substring(0, 2);
}
// 市局
else if (unitcode.endsWith("00000000")) {
unitcode = unitcode.substring(0, 4);
}
// 分局
else if (unitcode.endsWith("000000")) {
unitcode = unitcode.substring(0, 6);
}
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHDW_GAJGJGDM", unitcode + "*");
bqXyr.must(wildcardQueryBuilder);
}
// 现住址名称
if (StringUtils.isNotEmpty(xyr.getXzzmc())) {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_xw_zbfzxyr_PT_ZHFZXYR_XZZ_DZMC", "*" + xyr.getXzzmc() + "*");
bqXyr.must(wildcardQueryBuilder);
}
//出生日期
// if (StringUtils.isNotEmpty(xyr.getCsrqKssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_CSRQ_RQGZXX").gte(xyr.getCsrqKssj());
// bqXyr.must(rangeQueryBuilder);
// }
// if (StringUtils.isNotEmpty(xyr.getCsrqJssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_CSRQ_RQGZXX").lte(DateUtil.EndDateAdd(xyr.getCsrqJssj()));
// bqXyr.must(rangeQueryBuilder);
// }
// 国籍
if (StringUtils.isNotEmpty(xyr.getGjdm())) {
TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_GJDM", xyr.getGjdm());
bqXyr.must(termQueryBuilder);
}
// 民族
if (StringUtils.isNotEmpty(xyr.getMzdm())) {
TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_MZDM", xyr.getMzdm());
bqXyr.must(termQueryBuilder);
}
// 户籍地行政区划
if (StringUtils.isNotEmpty(xyr.getHjdqhdm())) {
String zhfzxyrHjdzXzqhdm = xyr.getHjdqhdm();
if (zhfzxyrHjdzXzqhdm.endsWith("0000")) {
zhfzxyrHjdzXzqhdm = zhfzxyrHjdzXzqhdm.substring(0, 2);
} else if (zhfzxyrHjdzXzqhdm.endsWith("00")) {
zhfzxyrHjdzXzqhdm = zhfzxyrHjdzXzqhdm.substring(0, 4);
}
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_HJDZ_XZQHDM", zhfzxyrHjdzXzqhdm + "*");
bqXyr.must(wildcardQueryBuilder);
}
// 户籍地名称
if (StringUtils.isNotEmpty(xyr.getHjdmc())) {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_xw_zbfzxyr_PT_ZHFZXYR_HJDZ_DZMC", "*" + xyr.getHjdmc() + "*");
bqXyr.must(wildcardQueryBuilder);
}
return bqXyr;
}
private BoolQueryBuilder getBoolAsj(AsjParam asj) {
BoolQueryBuilder bqAj = QueryBuilders.boolQuery();
// 信息删除判断标志
TermsQueryBuilder termQueryBuilderXxsc = QueryBuilders.termsQuery("v_solr6_tb_st_asj_AS_XXSC_PDBZ", "0");
bqAj.must(termQueryBuilderXxsc);
if (null != asj) {
// 案事件编号模糊查询
if (StringUtils.isNotEmpty(asj.getAsjbh())) {
TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("v_solr6_tb_st_asj_AS_ASJBH", asj.getAsjbh());
bqAj.must(termsQueryBuilder);
}
// 案件类别代码模糊查询
if (StringUtils.isNotEmpty(asj.getAjlbdm())) {
// 根据规则截取前三位
String ajlbdm = "";
if (asj.getAjlbdm().endsWith("000")) {
ajlbdm = asj.getAjlbdm().substring(0, 3) + "*";
} else {
ajlbdm = asj.getAjlbdm();
}
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AS_AJLBDM", ajlbdm);
bqAj.must(wildcardQueryBuilder);
}
//标注状态
if (StringUtils.isNotEmpty(asj.getBzzt())) {
if ("1".equals(asj.getBzzt())) {
TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("tb_st_asj_asjbz_BZZT", asj.getBzzt());
bqAj.must(termQueryBuilder);
} else {
TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("tb_st_asj_asjbz_BZZT", "1");
bqAj.mustNot(termQueryBuilder);
}
}
// 小案类别
if (StringUtils.isNotEmpty(asj.getZatzJyqk())) {
// 根据规则截取前三位
String zatz = "";
if (asj.getZatzJyqk().endsWith("000000")) {
zatz = asj.getZatzJyqk().substring(0, 6) + "*";
} else if (asj.getZatzJyqk().endsWith("00")) {
zatz = asj.getZatzJyqk().substring(0, 10) + "*";
} else {
zatz = asj.getZatzJyqk();
}
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AS_ZATZ_JYQK", zatz);
bqAj.must(wildcardQueryBuilder);
}
// 细案类别
if (StringUtils.isNotEmpty(asj.getAjxlb())) {
TermsQueryBuilder termQueryBuilder = QueryBuilders.termsQuery("tb_st_asj_asjbz_AJXLB", asj.getAjxlb());
bqAj.must(termQueryBuilder);
}
// 案件名称
if (StringUtils.isNotEmpty(asj.getAjmc())) {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AT_AJMC", "*" + asj.getAjmc() + "*");
bqAj.must(wildcardQueryBuilder);
}
// 案发时间(年月日)范围
// if (StringUtils.isNotEmpty(asj.getAfsjKssj()) && StringUtils.isNotEmpty(asj.getAfsjJssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ").gte(asj.getAfsjKssj()).lte(DateUtil.EndDateAdd(asj.getAfsjJssj()));
// bqAj.must(rangeQueryBuilder);
// } else {
// if (StringUtils.isNotEmpty(asj.getAfsjKssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ").gte(asj.getAfsjKssj());
// bqAj.must(rangeQueryBuilder);
// }
// if (StringUtils.isNotEmpty(asj.getAfsjJssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_st_asj_AS_ASJFSSJ_ASJFSKSSJ").lte(DateUtil.EndDateAdd(asj.getAfsjJssj()));
// bqAj.must(rangeQueryBuilder);
// }
// }
//立案单位
if (StringUtils.isNotEmpty(asj.getLadwdm())) {
String unitcode = asj.getLadwdm();
if (unitcode.endsWith("0000000000")) {
unitcode = unitcode.substring(0, 2);
}
// 市局
else if (unitcode.endsWith("00000000")) {
unitcode = unitcode.substring(0, 4);
}
// 分局
else if (unitcode.endsWith("000000")) {
unitcode = unitcode.substring(0, 6);
}
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AS_LADW_GAJGJGDM", unitcode + "*");
bqAj.must(wildcardQueryBuilder);
}
// //立案日期
// if (StringUtils.isNotEmpty(asj.getLarqKssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_st_asj_AS_LARQ").gte(asj.getLarqKssj());
// bqAj.must(rangeQueryBuilder);
//
// }
// if (StringUtils.isNotEmpty(asj.getLarqJssj())) {
// RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("v_solr6_tb_st_asj_AS_LARQ").lte(DateUtil.EndDateAdd(asj.getLarqJssj()));
// bqAj.must(rangeQueryBuilder);
// }
// 简要案情模糊查询
if (asj.getJyaq() != null && !asj.getJyaq().isEmpty()) {
String jyaq = asj.getJyaq();
String[] jyaqs = jyaq.split(",|，");
String jyaqType = asj.getJyaqType();
if ("and".equals(jyaqType)) {
for (String aq : jyaqs) {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AT_JYAQ", "*" + aq + "*");
bqAj.must(wildcardQueryBuilder);
}
} else if ("or".equals(jyaqType)) {
BoolQueryBuilder bqShould = QueryBuilders.boolQuery();
for (String aq : jyaqs) {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AT_JYAQ", "*" + aq + "*");
bqShould.should(wildcardQueryBuilder);
}
bqAj.must(bqShould);
} else {
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("v_solr6_tb_st_asj_AT_JYAQ", "*" + jyaq + "*");
bqAj.must(wildcardQueryBuilder);
}
}
}
return bqAj;
}
@Override
public String getEsAsjQryStr(XyrParam xyr) {
BoolQueryBuilder bqAj = QueryBuilders.boolQuery();
// 信息删除判断标志
TermsQueryBuilder termQueryBuilderXxsc = QueryBuilders.termsQuery("v_solr6_tb_st_asj_AS_XXSC_PDBZ", "0");
bqAj.must(termQueryBuilderXxsc);
BoolQueryBuilder bqXyr = getBoolXyr(xyr);
HasChildQueryBuilder childQueryBuilder = JoinQueryBuilders.hasChildQuery("v_solr6_tb_xw_zbfzxyr", bqXyr, ScoreMode.None);
bqAj.must(childQueryBuilder);
int page = xyr.getPage();
int limit = xyr.getLimit();
int begin = (page - 1) * limit;
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(bqAj).from(begin).size(limit);
searchSourceBuilder.sort("v_solr6_tb_st_asj_AS_LARQ", DESC);
return searchSourceBuilder.toString();
}
@Override
public String getCountByAsjbhNum1(){
//函数扩展聚合
// Script script = new Script("doc['v_solr6_tb_xw_zbfzxyr_PS_ASJBH'].values +'####'+ doc['v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_CYZJ_ZJHM'].values");
// TermsAggregationBuilder app = AggregationBuilders.terms("app").script(script).size(10000);
TermsAggregationBuilder termsAgg = AggregationBuilders.terms("asjbhGroup").field("v_solr6_tb_xw_zbfzxyr_PS_ASJBH").size(10);
//聚合，count为自带的
// termsAgg.subAggregation(AggregationBuilders.avg("avgAmount").field("amount"));
//声明BucketPath，用于后面的bucket筛选
Map<String, String> bucketsPathsMap = new HashMap<>(8);
bucketsPathsMap.put("orderCount", "_count");
// bucketsPathsMap.put("avgAmount", "avgAmount");
//设置脚本
Script script = new Script("params.orderCount >=2");
//构建bucket选择器
// BucketSelectorPipelineAggregationBuilder bs =
// PipelineAggregatorBuilders.bucketSelector("having", bucketsPathsMap, script);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
// termsAgg.subAggregation(bs);
searchSourceBuilder.aggregation(termsAgg);
return searchSourceBuilder.toString();
}
@Override
public String getCountByAsjbhNum3(){
//函数扩展聚合
Script script1 = new Script("doc['v_solr6_tb_xw_zbfzxyr_PS_ASJBH'].values +'####'+ doc['v_solr6_tb_xw_zbfzxyr_PS_ZHFZXYR_CYZJ_ZJHM'].values");
TermsAggregationBuilder termsAgg = AggregationBuilders.terms("asjbhGroup").script(script1).size(10);
// TermsAggregationBuilder termsAgg = AggregationBuilders.terms("asjbhGroup").field("v_solr6_tb_xw_zbfzxyr_PS_ASJBH").size(10);
//聚合，count为自带的
// termsAgg.subAggregation(AggregationBuilders.avg("avgAmount").field("amount"));
//声明BucketPath，用于后面的bucket筛选
Map<String, String> bucketsPathsMap = new HashMap<>(8);
bucketsPathsMap.put("orderCount", "_count");
// bucketsPathsMap.put("avgAmount", "avgAmount");
//设置脚本
Script script = new Script("params.orderCount >=2");
//构建bucket选择器
// BucketSelectorPipelineAggregationBuilder bs =
// PipelineAggregatorBuilders.bucketSelector("having", bucketsPathsMap, script);
//
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
// termsAgg.subAggregation(bs);
searchSourceBuilder.aggregation(termsAgg);
return searchSourceBuilder.toString();
}
@Override
public TbStAsjView queryTbStAsjByJjdbh(String jjdbh) {
TbStAsjView tbStAsjView = null;
TbStAsj param = new TbStAsj();
param.setJjbh(jjdbh);
TbStAsj tbStAsj = xxcxDao.queryTbStAsj(param);
if(tbStAsj!=null){
tbStAsjView = new TbStAsjView();
tbStAsjView.setAjlbdm(tbStAsj.getAjlbdm());
tbStAsjView.setAjmc(tbStAsj.getAjmc());
tbStAsjView.setZcjddm(tbStAsj.getZcjddm());
tbStAsjView.setAsjbh(tbStAsj.getAsjbh());
tbStAsjView.setAsjfsddDzmc(tbStAsj.getAsjfsddDzmc());
tbStAsjView.setAsjfsddXzqhdm(tbStAsj.getAsjfsddXzqhdm());
tbStAsjView.setAsjfssjAsjfsjssj(tbStAsj.getAsjfssjAsjfsjssj());
tbStAsjView.setAsjfssjAsjfskssj(tbStAsj.getAsjfssjAsjfskssj());
tbStAsjView.setGxsj(tbStAsj.getGxsj());
tbStAsjView.setJyaq(tbStAsj.getJyaq());
tbStAsjView.setLadwGajgjgdm(tbStAsj.getLadwGajgjgdm());
tbStAsjView.setLadwGajgmc(tbStAsj.getLadwGajgmc());
tbStAsjView.setLarq(tbStAsj.getLarq());
tbStAsjView.setSlsj(tbStAsj.getSlsj());
tbStAsjView.setXxlyms(tbStAsj.getXxlyms());
tbStAsjView.setZczjZxsj(tbStAsj.getZczjZxsj01());
tbStAsjView.setAsjlydm(tbStAsj.getAsjlydm());
tbStAsjView.setSsjzrmby(tbStAsj.getSsjzrmby());
tbStAsjView.setJjdbh(tbStAsj.getJjbh());
}
return tbStAsjView;
}
@Override
public List<TbXwRybhView> queryTbXwRybh(TbXwRybhView param) {
List<TbXwRybhView> result = new ArrayList<>();
try {
List<TbXwRybh> rybhList = xxcxDao.queryTbXwRybh(param);
if(rybhList!=null && !rybhList.isEmpty()){
for(TbXwRybh entity : rybhList){
TbXwRybhView view = new TbXwRybhView();
view.setAsjbh(entity.getAsjbh());
view.setBhrCsrqRqgzsx(entity.getBhrCsrqRqgzsx());
view.setBhrCsrqRqgzxx(entity.getBhrCsrqRqgzxx());
view.setBhrCyzjCyzjdm(entity.getBhrCyzjCyzjdm());
view.setBhrCyzjZjhm(entity.getBhrCyzjZjhm());
view.setBhrGzdw(entity.getBhrGzdw());
view.setBhrLxdh(entity.getBhrLxdh());
view.setBhrXbdm(entity.getBhrXbdm());
view.setBhrXm(entity.getBhrXm());
view.setBhrXzzDzmc(entity.getBhrXzzDzmc());
view.setBhrXzzXzqhdm(entity.getBhrXzzXzqhdm());
result.add(view);
}
}
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
@Override
public List<TbXwBaView> queryTbXwBa(TbXwBaView param) {
List<TbXwBaView> result = new ArrayList<>();
try {
List<TbXwBa> tbXwBaList = xxcxDao.queryTbXwBa(param);
if(tbXwBaList!=null && !tbXwBaList.isEmpty()){
for(TbXwBa entity : tbXwBaList){
TbXwBaView view = new TbXwBaView();
view.setAsjbh(entity.getAsjbh());
view.setBarCsrq(entity.getBarCsrq());
view.setBarCyzjCyzjdm(entity.getBarCyzjCyzjdm());
view.setBarCyzjCyzjhm(entity.getBarCyzjZjhm());
view.setBarGzdw(entity.getBarGzdw());
view.setBarLxdh(entity.getBarLxdh());
view.setBarXbdm(entity.getBarXbdm());
view.setBarXm(entity.getBarXm());
view.setBarXzzDzmc(entity.getBarXzzDzmc());
view.setBarXzzXzqhdm(entity.getBarXzzXzqhdm());
result.add(view);
}
}
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
@Override
public List<TbZhzxJjxxView> queryJjxx(TbZhzxJjxxView param) {
List<TbZhzxJjxxView> result = new ArrayList<>();
try {
List<TbZhzxJjxx> tbZhzxJjxxList = xxcxDao.queryJjxx(param);
if(tbZhzxJjxxList!=null && !tbZhzxJjxxList.isEmpty()){
for(TbZhzxJjxx entity : tbZhzxJjxxList){
TbZhzxJjxxView view = new TbZhzxJjxxView();
view.setBjdh(entity.getBjdh());
view.setBjfsdm(entity.getBjfsdm());
view.setBjlbdm(entity.getBjlbdm());
view.setBjlxdm(entity.getBjlxdm());
view.setBjnr(entity.getBjnr());
view.setBjrxb(entity.getBjrxb());
view.setBjrxm(entity.getBjrxm());
view.setBjsj(entity.getBjsj());
view.setBjxldm(entity.getBjxldm());
view.setDicBjfsdm(entity.getDicBjfsdm());
view.setDicJjdw(entity.getDicJjdw());
view.setJjdbh(entity.getJjdbh());
view.setJjdw(entity.getJjdw());
view.setJjyxm(entity.getJjyxm());
view.setLxdh(entity.getLxdh());
view.setSfdd(entity.getSfdd());
view.setYhdz(entity.getYhdz());
view.setAsjbh(entity.getAsjbh());
result.add(view);
}
}
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
@Override
public List<TbZhzxCjxxView> queryCjxx(TbZhzxCjxxView param) {
List<TbZhzxCjxxView> result = new ArrayList<>();
try {
List<TbZhzxCjxx> tbZhzxCjxxList = xxcxDao.queryCjxx(param);
if(tbZhzxCjxxList!=null && !tbZhzxCjxxList.isEmpty()){
for(TbZhzxCjxx entity : tbZhzxCjxxList){
TbZhzxCjxxView view = new TbZhzxCjxxView();
view.setJjdbh(entity.getJjdbh());
view.setDdsj(entity.getDdsj());
view.setPjdbh(entity.getPjdbh());
view.setPjsj(entity.getPjsj());
view.setPjyj(entity.getPjyj());
view.setPjyxm(entity.getPjyxm());
view.setZbqk(entity.getZbqk());
view.setAsjbh(entity.getAsjbh());
result.add(view);
}
}
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}
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