package com.dgtis.data.api; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.dgtis.common.core.utils.DateUtils; import com.dgtis.common.core.utils.StringUtils; import com.dgtis.common.core.utils.poi.CsvUtil; import com.dgtis.common.core.utils.poi.ExcelUtil; import com.dgtis.common.core.web.domain.AjaxResult; import com.dgtis.common.security.utils.SecurityUtils; import com.dgtis.data.domain.Customer; import com.dgtis.data.service.ISysUserService; import com.dgtis.data.util.AddressResolutionUtil; import com.dgtis.system.api.domain.SysUser; import com.mysql.cj.x.protobuf.MysqlxDatatypes; import org.apache.http.HttpEntity; import org.apache.http.entity.ContentType; import org.apache.http.nio.entity.NStringEntity; import org.apache.http.util.EntityUtils; import org.elasticsearch.client.Request; import org.elasticsearch.client.Response; import org.elasticsearch.client.RestClient; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.text.DecimalFormat; import java.util.*; /** * @description:客户信息列表api * @author:qxm * @date:2021/1/22 10:24 */ @Controller @RequestMapping("/customer") public class CustomerApiController { private static Logger logger = LoggerFactory.getLogger(CustomerApiController.class); @Autowired private RestClient restClient; @Autowired private ISysUserService userService; @GetMapping("/getCustomerList") @ResponseBody public AjaxResult getCustomerList(@RequestParam(defaultValue = "1") int pageNum,@RequestParam(defaultValue = "10") int pageSize, String education,//学历 String policybelong,//业绩归属 String payS,String payE, //年缴费区间 String fadate,//投保年份 String productname,//险种类别 String insuredAmountS,String insuredAmountE,//保额区间 String ageS,String ageE,//年龄区间 String gender,//性别 String sobirth,//省份 String NOVPolicy,//保单件数 String custtype,//客户类型 投保人 String SCustID,// 核心客户号 String custclass,//客户等级 String participantsDateS,String participantsDateE,//参与方时间 String PIncomeS,String PIncomeE,//年收入区间 String Insured,//投保对象 String lp,//理赔 String yx,//有效 String gzgw,//关注官微 String zcgw,//注册官微 String name,//客户姓名 String idcard,//客户证件号码 String mobile//客户手机号 ) { try { //模糊查询渠道 Long userId = SecurityUtils.getUserId(); SysUser sysUser = userService.selectUserById(userId); String deptCode = null; // “上海人寿”部门编号开发环境是null，生产环境是0。不是上海人寿部门的才分渠道 if (StringUtils.isNotEmpty(sysUser.getDept().getDeptCode()) && ! "0".equals(sysUser.getDept().getDeptCode())) { deptCode = sysUser.getDept().getDeptCode(); } logger.info("进客户列表时间："+DateUtils.getTime()); /*Long userId = SecurityUtils.getUserId(); SysUser sysUser = userService.selectUserById(userId); String deptCode = sysUser.getDept().getDeptCode();*/ //2.如果没有客户信息以外的查询条件，只需要查询客户信息 // 获取索引的别名，字段，创建时间 String beginBirthDay = ""; String endBirthDay = ""; if(StringUtils.isNotEmpty(ageS)){ String year = DateUtils.getYYYY(); int bYear = Integer.parseInt(year)-Integer.parseInt(ageS); endBirthDay = bYear+"-"+DateUtils.getMMDD(); } if(StringUtils.isNotEmpty(ageE)){ String year = DateUtils.getYYYY(); int bYear = Integer.parseInt(year)-Integer.parseInt(ageE); beginBirthDay = bYear+"-"+DateUtils.getMMDD(); } //拼装查询条件 StringBuilder builder =new StringBuilder(); builder.append("{"); builder.append("\"query\":{");//query开始 builder.append("\"bool\":{");//boot开始 builder.append("\"must\":[");//must开始 //业绩归属字段 /*if(StringUtils.isNotEmpty(deptCode)){ builder.append("{\"prefix\":{\"policybelong\":\""+deptCode+"\"}},"); }*/ if(StringUtils.isNotEmpty(policybelong)){ builder.append("{\"prefix\":{\"policybelong\":\""+policybelong+"\"}},"); } //客户姓名 if(StringUtils.isNotEmpty(name)){ builder.append("{\"wildcard\":{\"name\":\"*"+name+"*\"}},"); } //客户手机 if(StringUtils.isNotEmpty(mobile)){ builder.append("{\"wildcard\":{\"pmphone\":\"*"+mobile+"*\"}},"); } //投保年份 if(StringUtils.isNotEmpty(fadate)){ builder.append("{\"wildcard\":{\"fadate\":\"*"+fadate+"*\"}},"); } if(StringUtils.isNotEmpty(gender)){ builder.append("{\"prefix\":{\"gender\":"+gender+"}},"); } if(StringUtils.isNotEmpty(NOVPolicy)){ builder.append("{\"prefix\":{\"label25\":\""+NOVPolicy+"\"}},"); } if(StringUtils.isNotEmpty(custclass)){ builder.append("{\"term\":{\"custclass\":\""+custclass+"\"}},"); } if(StringUtils.isNotEmpty(sobirth)){ builder.append("{\"wildcard\":{\"sobirth\":\"*"+sobirth+"*\"}},");//模糊匹配 } if(StringUtils.isNotEmpty(SCustID)){ builder.append("{\"wildcard\":{\"scustid\":\"*"+SCustID+"*\"}},");//模糊匹配 } if(StringUtils.isNotEmpty(custtype)){ builder.append("{\"wildcard\":{\"custtype\":\"*"+custtype+"*\"}},"); } if(StringUtils.isNotEmpty(beginBirthDay) && StringUtils.isNotEmpty(endBirthDay)){ builder.append("{\"range\":{\"birthday\":{\"gte\":\""+beginBirthDay+"\",\"lte\":\""+endBirthDay+"\"}}},"); }else{ if(StringUtils.isNotEmpty(beginBirthDay)){ builder.append("{\"range\":{\"birthday\":{\"gte\":\""+beginBirthDay+"\"}}},"); } if(StringUtils.isNotEmpty(endBirthDay)){ builder.append("{\"range\":{\"birthday\":{\"lte\":\""+endBirthDay+"\"}}},"); } } if(StringUtils.isNotEmpty(participantsDateS) && StringUtils.isNotEmpty(participantsDateE)){ builder.append("{\"range\":{\"fadate\":{\"gte\":\""+participantsDateS+"\",\"lte\":\""+participantsDateE+"\"}}},"); }else{ if(StringUtils.isNotEmpty(participantsDateS)){ builder.append("{\"range\":{\"fadate\":{\"gte\":\""+participantsDateS+"\"}}},"); } if(StringUtils.isNotEmpty(participantsDateE)){ builder.append("{\"range\":{\"fadate\":{\"lte\":\""+participantsDateE+"\"}}},"); } } if(StringUtils.isNotEmpty(PIncomeS) && StringUtils.isNotEmpty(PIncomeE)){ builder.append("{\"range\":{\"pincome\":{\"gte\":\""+PIncomeS+"\",\"lte\":\""+PIncomeE+"\"}}},"); }else{ if(StringUtils.isNotEmpty(PIncomeS)){ builder.append("{\"range\":{\"pincome\":{\"gte\":\""+PIncomeS+"\"}}},"); } if(StringUtils.isNotEmpty(PIncomeE)){ builder.append("{\"range\":{\"pincome\":{\"lte\":\""+PIncomeE+"\"}}},"); } } if(StringUtils.isNotEmpty(yx)){ if (yx.equals("0")){ builder.append("{\"range\":{\"novpolicy\":{\"gt\":\""+yx+"\"}}},"); }else { builder.append("{\"prefix\":{\"label91\":\"失效客户\"}},"); } } if(StringUtils.isNotEmpty(education)){ String[] edus = education.split("&"); builder.append("{\"terms\":{\"education\":["); for (String edu:edus) { builder.append("\""+edu+"\","); } builder.delete(builder.length()-1,builder.length()); builder.append ("]}},"); } if(StringUtils.isNotEmpty(gzgw) && "0".equals(gzgw)){ builder.append("{\"prefix\":{\"label73\":\"关注官微\"}},"); } if(StringUtils.isNotEmpty(zcgw) && "0".equals(zcgw)){ builder.append("{\"prefix\":{\"label74\":\"注册官微\"}},"); } if(StringUtils.isNotEmpty(lp) && "0".equals(lp)){ builder.append("{\"prefix\":{\"label57\":\"最近一次理赔类型\"}},"); } if(StringUtils.isNotEmpty(gender) || StringUtils.isNotEmpty(NOVPolicy) || StringUtils.isNotEmpty(custtype) || StringUtils.isNotEmpty(custclass) || StringUtils.isNotEmpty(sobirth) || StringUtils.isNotEmpty(SCustID) || StringUtils.isNotEmpty(beginBirthDay) || StringUtils.isNotEmpty(endBirthDay) || StringUtils.isNotEmpty(education) || StringUtils.isNotEmpty(PIncomeS) || StringUtils.isNotEmpty(PIncomeE) || (StringUtils.isNotEmpty(gzgw) && "0".equals(gzgw)) || (StringUtils.isNotEmpty(zcgw) && "0".equals(zcgw)) || StringUtils.isNotEmpty(yx) || (StringUtils.isNotEmpty(lp) && "0".equals(lp)) || /*StringUtils.isNotEmpty(deptCode) ||*/ StringUtils.isNotEmpty(participantsDateS) || StringUtils.isNotEmpty(participantsDateE) || StringUtils.isNotEmpty(policybelong) || StringUtils.isNotEmpty(name) || StringUtils.isNotEmpty(mobile) || StringUtils.isNotEmpty(fadate)){ builder.delete(builder.length()-1,builder.length()); } builder.append("],");//must结束 builder.append("\"must_not\":[");//must_not if(StringUtils.isNotEmpty(gzgw) && "1".equals(gzgw)){ builder.append("{\"prefix\":{\"label73\":\"关注官微\"}},"); } if(StringUtils.isNotEmpty(zcgw) && "1".equals(zcgw)){ builder.append("{\"prefix\":{\"label74\":\"注册官微\"}},"); } if(StringUtils.isNotEmpty(lp) && "1".equals(lp)){ builder.append("{\"prefix\":{\"label57\":\"最近一次理赔类型\"}},"); } if( (StringUtils.isNotEmpty(gzgw) && "1".equals(gzgw)) || (StringUtils.isNotEmpty(zcgw) && "1".equals(zcgw)) || (StringUtils.isNotEmpty(lp) && "1".equals(lp)) ){ builder.delete(builder.length()-1,builder.length()); } builder.append("],"); builder.append("\"should\":["); if(StringUtils.isNotEmpty(deptCode)){ // builder.append("{\"wildcard\":{\"salecom\":\"*"+deptCode+"*\"}}"); } //客户证件号码 if(StringUtils.isNotEmpty(idcard)){ builder.append("{\"wildcard\":{\"idcard\":\"*"+idcard+"*\"}},"); builder.append("{\"wildcard\":{\"passport\":\"*"+idcard+"*\"}},"); builder.append("{\"wildcard\":{\"dlicense\":\"*"+idcard+"*\"}},"); builder.append("{\"wildcard\":{\"otheridnumber\":\"*"+idcard+"*\"}},"); builder.delete(builder.length()-1,builder.length()); } builder.append("]");//should builder.append("}");//boot结束 builder.append("},");//query结束 builder.append("\"from\":"+((pageNum-1)*10)+",");//第几页 builder.append("\"size\":"+pageSize+",");//查询几个 builder.append("\"sort\":[{\"scustid\":{\"order\":\"asc\"}}],");//排序 builder.append("\"aggs\":{}");// builder.append("}"); logger.info(builder.toString()); HttpEntity entity = new NStringEntity(builder.toString(), ContentType.APPLICATION_JSON); String url = "/shanglifeecif.individual/_search?pretty=true"; Request scriptRequest = new Request("GET", url); scriptRequest.setEntity(entity); Response response = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(response.getEntity()); JSONObject jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List listMap = new ArrayList<>(); Map map = new HashMap(); for (int i = 0; i paramMap = new HashMap(); paramMap.put("pretty", "true"); Request scriptRequest = new Request("GET", "/shanglifeecif.individual/default_type_/"+id+"?pretty=true"); Response response = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(response.getEntity()); Map map = new HashMap(); JSONObject jsonObject = JSON.parseObject(result); JSONObject source = JSON.parseObject(jsonObject.getString("_source")); String indid = jsonObject.getString("_id"); String custtype = source.getString("custtype"); String scustid = source.getString("scustid"); Map mpInfo = getLables(jsonObject, deptCode); map.put("custInfo",mpInfo); Map query =new HashMap(); query.put("indid1",indid); scriptRequest = new Request("GET", "/shanglifeecif.indrelationship/_search?pretty=true&q=indid1:"+scustid); response = restClient.performRequest(scriptRequest); result = EntityUtils.toString(response.getEntity()); jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List relationship = new ArrayList<>(); for (int i = 0; i (); for (int i = 0; i (); for (int i = 0; i (); for (int i = 0; i majorCategorie = new HashMap(); Map mpremMap = new HashMap(); int firstDate = 1;//定义第一次长期险获取 Date date = new Date(); Calendar cal = Calendar.getInstance(); cal.setTime(date); cal.add(Calendar.YEAR, 1); Date nextYearTime = cal.getTime(); String currentDateTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD,date); String currentYear = DateUtils.parseDateToStr(DateUtils.YYYY,date); Set noivpolicyset= new HashSet<>();//失效保单 Set novpolicyset= new HashSet<>();//有效保单 //获取最近年份 logger.info("getCustomerOverViewById",array.toJSONString()); for (int i = 0; i npdate.getTime() && Integer.parseInt(npDateStrYear)>Integer.parseInt(currentYear)){ handedinprem+=_source.getDouble("prem"); } } if(!norenewal.equals(payendyear) && npDateStr.compareTo(currentDateTime)>0 && !npDateStrYear.equals(currentYear)){ handedinprem+=_source.getDouble("prem"); } } String m = DateUtils.parseDateToStr("M", padate); if(mpremMap.containsKey(m)){ double tprem = Double.parseDouble(mpremMap.get(m).toString()); tprem+=_source.getDouble("prem"); mpremMap.put(m,df.format(tprem)); edata[Integer.parseInt(m)-1] = df.format(tprem); adata[Integer.parseInt(m)-1] = df.format(tprem); }else{ mpremMap.put(m,df.format(_source.getDouble("prem"))); edata[Integer.parseInt(m)-1] = df.format(_source.getDouble("prem")); adata[Integer.parseInt(m)-1] = df.format(_source.getDouble("prem")); } }else{ if("趸缴".equals(_source.getString("payment")) && currentYear.equals(DateUtils.parseDateToStr("yyyy",padate))){ prem+=_source.getDouble("prem"); handedinprem+=_source.getDouble("prem"); } } } String risk_categories_name = _source.getString("risk_categories_name"); if(majorCategorie.containsKey(risk_categories_name)){ double risk = Double.parseDouble(majorCategorie.get(risk_categories_name).toString()); if(_source.containsKey("risk")){ risk += _source.getDouble("risk"); } majorCategorie.put(risk_categories_name,risk); }else{ if(_source.containsKey("risk") && StringUtils.isNotEmpty(risk_categories_name)){ majorCategorie.put(risk_categories_name,_source.getDouble("risk")); } } }else{ //客户的所有保单缴费期满且承保期限已满正常终止的客户,需要加上累计保费 if("终止".equals(_source.getString("policystate"))){ String norenewal = _source.getString("norenewal")==null?"":_source.getString("norenewal").trim();//续保次数 String payendyear = _source.getString("payendyear")==null?"":_source.getString("payendyear").trim();//缴费年期 Date pmdate = _source.getDate("pmdate");//终保日期 if(norenewal.equals(payendyear) && currentDateTime.compareTo(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD,pmdate))>0){ if(_source.containsKey("sumprem")){ sumprem+=_source.getDouble("sumprem"); } } Integer agrmntage = _source.getInteger("agrmntage"); //短期险 if(agrmntage<180){ Date pindate = _source.getDate("pindate");//起保日期 guaranteeDay+=DateUtils.getDateDifDay(pmdate,pindate); } } if (_source.getString("policystate") != null) { noivpolicyset.add(_source.getString("policyno")); } } } mpInfo.put("noivpolicy",noivpolicyset.size()); mpInfo.put("novpolicy",novpolicyset.size()); expectedData.put("data",edata); actaulData.put("data",adata); Map lineBarChartData = new HashMap(); lineBarChartData.put("expectedData",expectedData); lineBarChartData.put("actaulData",actaulData); lineBarChartData.put("xaxisData",xaxisData); map.put("lineBarChartData",lineBarChartData); //查询理赔信息 String lpqSearch = "lpscutid:"+scustid; if( StringUtils.isNotEmpty(deptCode)){ lpqSearch = "(lpscutid:"+scustid+"%20AND%20salecom:"+deptCode+")"; } scriptRequest = new Request("GET", "/shanglifeecif.insuranceclaimthread/_search?size=100&pretty=true&q="+lpqSearch); response = restClient.performRequest(scriptRequest); result = EntityUtils.toString(response.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); Map insuranceclaimthread = new HashMap(); List insuranceclaimthreads = new ArrayList<>(); double claimAmount = 0;//理赔总金额 Set claimTypeSet = new HashSet<>();//理赔类型 for (int i = 0; i 0?"是":"否"); insuranceclaimthread.put("claimAmount",df.format(claimAmount)); insuranceclaimthread.put("claimType",String.join(",",claimTypeSet)); map.put("insuranceclaimthread",insuranceclaimthread); mpInfo.put("prem",df.format(prem));//年缴保费/应交保费 mpInfo.put("sumprem",df.format(sumprem));//累计保费 mpInfo.put("handedinprem",df.format(handedinprem));//已交保费 mpInfo.put("insureDay",(insureDay/365) +"年"+(insureDay%365)+"天"); //保障天数需要加上退保之前的天数 String tbcustomerinfoSearch = "scustid:"+scustid; if( StringUtils.isNotEmpty(deptCode)){ tbcustomerinfoSearch = "(scustid:"+scustid+"%20AND%20salecom:"+deptCode+")"; } scriptRequest = new Request("GET", "/shanglifeecif.tbcustomerinfo/_search?pretty=true&sort=sdate:asc&size=100&q="+tbcustomerinfoSearch); response = restClient.performRequest(scriptRequest); result = EntityUtils.toString(response.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); Date fSdate = null;//最终起始日期，分段的 Date fEdate = null;//最终结束日期，分段的 for (int i = 0; i 0){ if(sdate.getTime()<=fEdate.getTime()){ //保单结束日期在最终结束日期之后，需要把保单结束日期赋值给最终结束日期 if(edate.getTime()>fEdate.getTime()){ fEdate = edate; } }else{ //保单的开始日期在结束日期之后，需要先计算前一段的日期差值加到保障天数 if(i!=array.size()){ guaranteeDay+=DateUtils.getDateDifDay(fEdate,fSdate); fSdate = sdate; fEdate = edate; } } if(i==(array.size()-1)){ guaranteeDay+=DateUtils.getDateDifDay(fEdate,fSdate); } } } } mpInfo.put("guaranteeDay",guaranteeDay>insureDay?insureDay+"天":guaranteeDay+"天"); map.put("custInfo",mpInfo); //险种数据准备 Map riskMap = new HashMap(); riskMap.put("人寿保险","0"); riskMap.put("新型寿险","0"); riskMap.put("意外伤害保险","0"); riskMap.put("医疗险","0"); riskMap.put("重疾保险","0"); riskMap.put("年金保险","0"); for(String key : majorCategorie.keySet()){ if(riskMap.containsKey(key)){ riskMap.put(key,majorCategorie.get(key)); } } map.put("majorCategorie",riskMap); logger.info("出客户概览时间："+DateUtils.getTime()); return AjaxResult.success(map); } catch (Exception e) { logger.info("客户概览报错时间："+DateUtils.getTime()); e.printStackTrace(); return AjaxResult.error(); } } @GetMapping("/export") public void export(HttpServletResponse response, HttpServletRequest request, String education,//学历 String policybelong,//业绩归属 String payS,String payE, //年缴费区间 String fadate,//投保年份 String productname,//险种类别 String insuredAmountS,String insuredAmountE,//保额区间 String ageS,String ageE,//年龄区间 String gender,//性别 String sobirth,//省份 String NOVPolicy,//保单件数 String custtype,//客户类型 投保人 String SCustID,// 核心客户号 String custclass,//客户等级 String participantsDateS,String participantsDateE,//参与方时间 String PIncomeS,String PIncomeE,//年收入区间 String Insured,//投保对象 String lp,//理赔 String yx,//有效 String gzgw,//关注官微 String zcgw,//注册官微 String name,//客户姓名 String idcard,//客户证件号码 String mobile//客户手机号 ) { logger.info("导出进时间："+DateUtils.getTime()); try{ Long userId = SecurityUtils.getUserId(); SysUser sysUser = userService.selectUserById(userId); String deptCode = null; // “上海人寿”部门编号开发环境是null，生产环境是0。不是上海人寿部门的才分渠道 if (StringUtils.isNotEmpty(sysUser.getDept().getDeptCode()) && ! "0".equals(sysUser.getDept().getDeptCode())) { deptCode = sysUser.getDept().getDeptCode(); } //1.如果存在保单信息的查询条件，需要先查询保单信息然后通过保单关联出客户信息 //处理保单查询条件 /*List customerIds = new ArrayList(); if(StringUtils.isNotEmpty(payS) || StringUtils.isNotEmpty(payE) || StringUtils.isNotEmpty(insuredAmountS) || StringUtils.isNotEmpty(insuredAmountE) || StringUtils.isNotEmpty(productname) || StringUtils.isNotEmpty(fadate)){ customerIds = queryInsurancearrangement(policybelong,payS,payE,fadate,productname,insuredAmountS,insuredAmountE); }*/ //2.如果没有客户信息以外的查询条件，只需要查询客户信息 // 获取索引的别名，字段，创建时间 String beginBirthDay = ""; String endBirthDay = ""; if(StringUtils.isNotEmpty(ageS)){ String year = DateUtils.getYYYY(); int bYear = Integer.parseInt(year)-Integer.parseInt(ageS); endBirthDay = bYear+"-"+DateUtils.getMMDD(); } if(StringUtils.isNotEmpty(ageE)){ String year = DateUtils.getYYYY(); int bYear = Integer.parseInt(year)-Integer.parseInt(ageE); beginBirthDay = bYear+"-"+DateUtils.getMMDD(); } //拼装查询条件 StringBuilder builder =new StringBuilder(); builder.append("{"); builder.append("\"query\":{");//query开始 builder.append("\"bool\":{");//boot开始 builder.append("\"must\":[");//must开始 //业绩归属字段 /*if(StringUtils.isNotEmpty(deptCode)){ builder.append("{\"prefix\":{\"policybelong\":\""+deptCode+"\"}},"); }*/ if(StringUtils.isNotEmpty(policybelong)){ builder.append("{\"prefix\":{\"policybelong\":\""+policybelong+"\"}},"); } //客户姓名 if(StringUtils.isNotEmpty(name)){ builder.append("{\"wildcard\":{\"name\":\"*"+name+"*\"}},"); } //客户手机 if(StringUtils.isNotEmpty(mobile)){ builder.append("{\"wildcard\":{\"pmphone\":\"*"+mobile+"*\"}},"); } //投保年份 if(StringUtils.isNotEmpty(fadate)){ builder.append("{\"wildcard\":{\"fadate\":\"*"+fadate+"*\"}},"); } if(StringUtils.isNotEmpty(gender)){ builder.append("{\"prefix\":{\"gender\":"+gender+"}},"); } if(StringUtils.isNotEmpty(NOVPolicy)){ builder.append("{\"prefix\":{\"label25\":\""+NOVPolicy+"\"}},"); } if(StringUtils.isNotEmpty(custclass)){ builder.append("{\"term\":{\"custclass\":\""+custclass+"\"}},"); } if(StringUtils.isNotEmpty(sobirth)){ builder.append("{\"wildcard\":{\"sobirth\":\"*"+sobirth+"*\"}},");//模糊匹配 } if(StringUtils.isNotEmpty(SCustID)){ builder.append("{\"wildcard\":{\"scustid\":\"*"+SCustID+"*\"}},");//模糊匹配 } if(StringUtils.isNotEmpty(custtype)){ builder.append("{\"wildcard\":{\"custtype\":\"*"+custtype+"*\"}},"); } if(StringUtils.isNotEmpty(beginBirthDay) && StringUtils.isNotEmpty(endBirthDay)){ builder.append("{\"range\":{\"birthday\":{\"gte\":\""+beginBirthDay+"\",\"lte\":\""+endBirthDay+"\"}}},"); }else{ if(StringUtils.isNotEmpty(beginBirthDay)){ builder.append("{\"range\":{\"birthday\":{\"gte\":\""+beginBirthDay+"\"}}},"); } if(StringUtils.isNotEmpty(endBirthDay)){ builder.append("{\"range\":{\"birthday\":{\"lte\":\""+endBirthDay+"\"}}},"); } } if(StringUtils.isNotEmpty(participantsDateS) && StringUtils.isNotEmpty(participantsDateE)){ builder.append("{\"range\":{\"fadate\":{\"gte\":\""+participantsDateS+"\",\"lte\":\""+participantsDateE+"\"}}},"); }else{ if(StringUtils.isNotEmpty(participantsDateS)){ builder.append("{\"range\":{\"fadate\":{\"gte\":\""+participantsDateS+"\"}}},"); } if(StringUtils.isNotEmpty(participantsDateE)){ builder.append("{\"range\":{\"fadate\":{\"lte\":\""+participantsDateE+"\"}}},"); } } if(StringUtils.isNotEmpty(PIncomeS) && StringUtils.isNotEmpty(PIncomeE)){ builder.append("{\"range\":{\"pincome\":{\"gte\":\""+PIncomeS+"\",\"lte\":\""+PIncomeE+"\"}}},"); }else{ if(StringUtils.isNotEmpty(PIncomeS)){ builder.append("{\"range\":{\"pincome\":{\"gte\":\""+PIncomeS+"\"}}},"); } if(StringUtils.isNotEmpty(PIncomeE)){ builder.append("{\"range\":{\"pincome\":{\"lte\":\""+PIncomeE+"\"}}},"); } } if(StringUtils.isNotEmpty(yx)){ if (yx.equals("0")){ builder.append("{\"range\":{\"novpolicy\":{\"gt\":\""+yx+"\"}}},"); }else { builder.append("{\"prefix\":{\"label91\":\"失效客户\"}},"); } } if(StringUtils.isNotEmpty(education)){ String[] edus = education.split("&"); builder.append("{\"terms\":{\"education\":["); for (String edu:edus) { builder.append("\""+edu+"\","); } builder.delete(builder.length()-1,builder.length()); builder.append ("]}},"); } if(StringUtils.isNotEmpty(gzgw) && "0".equals(gzgw)){ builder.append("{\"prefix\":{\"label73\":\"关注官微\"}},"); } if(StringUtils.isNotEmpty(zcgw) && "0".equals(zcgw)){ builder.append("{\"prefix\":{\"label74\":\"注册官微\"}},"); } if(StringUtils.isNotEmpty(lp) && "0".equals(lp)){ builder.append("{\"prefix\":{\"label57\":\"最近一次理赔类型\"}},"); } if(StringUtils.isNotEmpty(gender) || StringUtils.isNotEmpty(NOVPolicy) || StringUtils.isNotEmpty(custtype) || StringUtils.isNotEmpty(custclass) || StringUtils.isNotEmpty(sobirth) || StringUtils.isNotEmpty(SCustID) || StringUtils.isNotEmpty(beginBirthDay) || StringUtils.isNotEmpty(endBirthDay) || StringUtils.isNotEmpty(education) || StringUtils.isNotEmpty(PIncomeS) || StringUtils.isNotEmpty(PIncomeE) || (StringUtils.isNotEmpty(gzgw) && "0".equals(gzgw)) || (StringUtils.isNotEmpty(zcgw) && "0".equals(zcgw)) || StringUtils.isNotEmpty(yx) || (StringUtils.isNotEmpty(lp) && "0".equals(lp)) || /*StringUtils.isNotEmpty(deptCode) ||*/ StringUtils.isNotEmpty(participantsDateS) || StringUtils.isNotEmpty(participantsDateE) || StringUtils.isNotEmpty(policybelong) || StringUtils.isNotEmpty(name) || StringUtils.isNotEmpty(mobile) || StringUtils.isNotEmpty(fadate)){ builder.delete(builder.length()-1,builder.length()); } builder.append("],");//must结束 builder.append("\"must_not\":[");//must_not if(StringUtils.isNotEmpty(gzgw) && "1".equals(gzgw)){ builder.append("{\"prefix\":{\"label73\":\"关注官微\"}},"); } if(StringUtils.isNotEmpty(zcgw) && "1".equals(zcgw)){ builder.append("{\"prefix\":{\"label74\":\"注册官微\"}},"); } if(StringUtils.isNotEmpty(lp) && "1".equals(lp)){ builder.append("{\"prefix\":{\"label57\":\"最近一次理赔类型\"}},"); } if( (StringUtils.isNotEmpty(gzgw) && "1".equals(gzgw)) || (StringUtils.isNotEmpty(zcgw) && "1".equals(zcgw)) || (StringUtils.isNotEmpty(lp) && "1".equals(lp)) ){ builder.delete(builder.length()-1,builder.length()); } builder.append("],"); builder.append("\"should\":["); if(StringUtils.isNotEmpty(deptCode)){ // builder.append("{\"wildcard\":{\"salecom\":\"*"+deptCode+"*\"}}"); } //客户证件号码 if(StringUtils.isNotEmpty(idcard)){ builder.append("{\"wildcard\":{\"idcard\":\"*"+idcard+"*\"}},"); builder.append("{\"wildcard\":{\"passport\":\"*"+idcard+"*\"}},"); builder.append("{\"wildcard\":{\"dlicense\":\"*"+idcard+"*\"}},"); builder.append("{\"wildcard\":{\"otheridnumber\":\"*"+idcard+"*\"}},"); builder.delete(builder.length()-1,builder.length()); } builder.append("]");//should builder.append("}");//boot结束 builder.append("},");//query结束 builder.append("\"from\":\"0\",");//第几页 builder.append("\"size\":\"10000\",");//查询几个 builder.append("\"sort\":[{\"scustid\":{\"order\":\"asc\"}}],");//排序 builder.append("\"aggs\":{}");// builder.append("}"); HttpEntity entity = new NStringEntity(builder.toString(), ContentType.APPLICATION_JSON); String url = "/shanglifeecif.individual/_search?&scroll=5m"; Request scriptRequest = new Request("GET", url); scriptRequest.setEntity(entity); Response responseData = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(responseData.getEntity()); JSONObject jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List customers = new ArrayList(); String scroll_id = jsonObject.getString("_scroll_id"); entity = new NStringEntity("{\n" + " \"scroll_id\": \""+scroll_id+"\",\n" + " \"scroll\": \"5m\"\n" + "}", ContentType.APPLICATION_JSON); while (array.size() != 0) { // 这里填写你的业务逻辑，即对每一条数据的处理 for (int i = 0; i list = AddressResolutionUtil.addressResolution(ral); if(list!=null && list.size()>0){ customer.setProvince(list.get(0).get("province").toString()); } } if(mp.containsKey("birthday")){ String birthday = jsonOb.getString("birthday"); mp.put("birthday", birthday); mp.put("age",DateUtils.getAge(DateUtils.dateTime(DateUtils.YYYY_MM_DD,birthday))); customer.setBirthDay("\t"+birthday); customer.setAge(DateUtils.getAge(DateUtils.dateTime(DateUtils.YYYY_MM_DD,birthday))); } //String regex = "(\\w{4})(\\w+)(\\w{0})"; if(mp.containsKey("idcard")){ customer.setIdType("身份证"); String idCard = jsonOb.getString("idcard"); //customer.setIdCard("\t"+jsonOb.getString("idcard").replaceAll(regex, "$1****$3")); if(idCard.length()>6){ customer.setIdCard("\t"+idCard.replaceAll(idCard.substring(idCard.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("passport")){ customer.setIdType("护照"); String passport = jsonOb.getString("passport"); //customer.setIdCard("\t"+jsonOb.getString("passport").replaceAll(regex, "$1****$3")); if(passport.length()>6){ customer.setIdCard("\t"+passport.replaceAll(passport.substring(passport.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("dlicense")){ customer.setIdType("驾驶证"); String dlicense = jsonOb.getString("dlicense"); //customer.setIdCard("\t"+jsonOb.getString("dlicense").replaceAll(regex, "$1****$3")); if(dlicense.length()>6){ customer.setIdCard("\t"+dlicense.replaceAll(dlicense.substring(dlicense.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("otheridnumber")){ customer.setIdType("其它证件类型"); String otheridnumber = jsonOb.getString("otheridnumber"); //customer.setIdCard("\t"+jsonOb.getString("otheridnumber").replaceAll(regex, "$1****$3")); if(otheridnumber.length()>6){ customer.setIdCard("\t"+otheridnumber.replaceAll(otheridnumber.substring(otheridnumber.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } } if(mp.containsKey("custclass")){ String custclazz = jsonOb.getString("custclass"); switch (custclazz){ case "1": customer.setCustClass("钻石"); break; case "2": customer.setCustClass("白金"); break; case "3": customer.setCustClass("黄金"); break; case "4": customer.setCustClass("普通"); break; default: customer.setCustClass("无"); } }else{ customer.setCustClass("无"); } customers.add(customer); } // 继续向后查询 scriptRequest = new Request("GET", "/_search/scroll"); scriptRequest.setEntity(entity); responseData = restClient.performRequest(scriptRequest); result = EntityUtils.toString(responseData.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); } Map header = new LinkedHashMap<>(); header.put("scustId", "核心客户号"); header.put("custId", "客户号"); header.put("name", "姓名"); header.put("idType", "证件类型"); header.put("idCard", "证件号码"); header.put("sex", "性别"); header.put("age", "年龄"); header.put("birthDay", "出生日期"); header.put("custClass", "客户等级"); header.put("custType", "客户类型"); header.put("province", "省份"); header.put("education", "学历"); header.put("vaild", "是否有效客户"); /*header.put("policyBelong", "业绩归属");*/ header.put("pIncome", "年收入(万)"); header.put("num", "保单件数"); CsvUtil.export(request, response, "customer", header, customers); logger.info("导出出时间："+DateUtils.getTime()); }catch (Exception e){ logger.info("导出出错："+DateUtils.getTime()); e.printStackTrace(); } } /** * 导出四要素疑似相同指姓名、性别、证件类型、手机号一致 * @param response * @param request */ @GetMapping("/exportSameZero") public void exportSameZero(HttpServletResponse response, HttpServletRequest request) { logger.info("导出四要素进时间："+DateUtils.getTime()); try{ Request scriptRequest = new Request("GET", "/shanglifeecif.samecustomer/_search?sort=name:asc&q=sametype:0&size=10000&scroll=5m"); Response responseData = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(responseData.getEntity()); JSONObject jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List customers = new ArrayList(); String scroll_id = jsonObject.getString("_scroll_id"); HttpEntity entity = new NStringEntity("{\n" + " \"scroll_id\": \""+scroll_id+"\",\n" + " \"scroll\": \"5m\"\n" + "}", ContentType.APPLICATION_JSON); while (array.size() != 0) { // 这里填写你的业务逻辑，即对每一条数据的处理 for (int i = 0; i 6){ customer.setIdCard("\t"+idcard.replaceAll(idcard.substring(idcard.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("passport")){ customer.setIdType("护照"); // customer.setIdCard("\t"+jsonOb.getString("passport")); String passport = jsonOb.getString("passport"); if(passport.length()>6){ customer.setIdCard("\t"+passport.replaceAll(passport.substring(passport.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("dlicense")){ customer.setIdType("驾驶证"); // customer.setIdCard("\t"+jsonOb.getString("dlicense")); String dlicense = jsonOb.getString("dlicense"); if(dlicense.length()>6){ customer.setIdCard("\t"+dlicense.replaceAll(dlicense.substring(dlicense.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("otheridnumber")){ customer.setIdType("其它证件类型"); // customer.setIdCard("\t"+jsonOb.getString("otheridnumber")); String otheridnumber = jsonOb.getString("otheridnumber"); if(otheridnumber.length()>6){ customer.setIdCard("\t"+otheridnumber.replaceAll(otheridnumber.substring(otheridnumber.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } } customers.add(customer); } // 继续向后查询 scriptRequest = new Request("GET", "/_search/scroll"); scriptRequest.setEntity(entity); responseData = restClient.performRequest(scriptRequest); result = EntityUtils.toString(responseData.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); } Map header = new LinkedHashMap<>(); header.put("scustId", "核心客户号"); header.put("name", "姓名"); header.put("idType", "证件类型"); header.put("idCard", "证件号码"); header.put("sex", "性别"); header.put("birthDay", "出生日期"); CsvUtil.export(request, response, "customer", header, customers); logger.info("导出四要素出时间："+DateUtils.getTime()); }catch (Exception e){ logger.info("导出四要素出错："+DateUtils.getTime()); e.printStackTrace(); } } /** * 导出三要素疑似相同指姓名、性别、出生日期一致 * @param response * @param request */ @GetMapping("/exportSameOne") public void exportSameOne(HttpServletResponse response, HttpServletRequest request) { logger.info("导出三要素进时间："+DateUtils.getTime()); try{ Request scriptRequest = new Request("GET", "/shanglifeecif.samecustomer/_search?sort=name:asc,gender:asc,birthday:asc&q=sametype:1&size=10000&scroll=5m"); Response responseData = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(responseData.getEntity()); JSONObject jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List customers = new ArrayList(); String scroll_id = jsonObject.getString("_scroll_id"); HttpEntity entity = new NStringEntity("{\n" + " \"scroll_id\": \""+scroll_id+"\",\n" + " \"scroll\": \"5m\"\n" + "}", ContentType.APPLICATION_JSON); while (array.size() != 0) { // 这里填写你的业务逻辑，即对每一条数据的处理 for (int i = 0; i 6){ customer.setIdCard("\t"+idcard.replaceAll(idcard.substring(idcard.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("passport")){ customer.setIdType("护照"); // customer.setIdCard("\t"+jsonOb.getString("passport")); String passport = jsonOb.getString("passport"); if(passport.length()>6){ customer.setIdCard("\t"+passport.replaceAll(passport.substring(passport.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("dlicense")){ customer.setIdType("驾驶证"); // customer.setIdCard("\t"+jsonOb.getString("dlicense")); String dlicense = jsonOb.getString("dlicense"); if(dlicense.length()>6){ customer.setIdCard("\t"+dlicense.replaceAll(dlicense.substring(dlicense.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("otheridnumber")){ customer.setIdType("其它证件类型"); // customer.setIdCard("\t"+jsonOb.getString("otheridnumber")); String otheridnumber = jsonOb.getString("otheridnumber"); if(otheridnumber.length()>6){ customer.setIdCard("\t"+otheridnumber.replaceAll(otheridnumber.substring(otheridnumber.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } } customers.add(customer); } // 继续向后查询 scriptRequest = new Request("GET", "/_search/scroll"); scriptRequest.setEntity(entity); responseData = restClient.performRequest(scriptRequest); result = EntityUtils.toString(responseData.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); } Map header = new LinkedHashMap<>(); header.put("scustId", "核心客户号"); header.put("name", "姓名"); header.put("idType", "证件类型"); header.put("idCard", "证件号码"); header.put("sex", "性别"); header.put("birthDay", "出生日期"); CsvUtil.export(request, response, "customer", header, customers); logger.info("导出三要素出时间："+DateUtils.getTime()); }catch (Exception e){ logger.info("导出三要素出错："+DateUtils.getTime()); e.printStackTrace(); } } /** * 导出两要素疑似相同指姓名、证件号码一致 * @param response * @param request */ @GetMapping("/exportSameTwo") public void exportSameTwo(HttpServletResponse response, HttpServletRequest request) { logger.info("导出两要素进时间："+DateUtils.getTime()); try{ Request scriptRequest = new Request("GET", "/shanglifeecif.samecustomer/_search?sort=name:asc&q=sametype:2&size=10000&scroll=5m"); Response responseData = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(responseData.getEntity()); JSONObject jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List customers = new ArrayList(); String scroll_id = jsonObject.getString("_scroll_id"); HttpEntity entity = new NStringEntity("{\n" + " \"scroll_id\": \""+scroll_id+"\",\n" + " \"scroll\": \"5m\"\n" + "}", ContentType.APPLICATION_JSON); while (array.size() != 0) { // 这里填写你的业务逻辑，即对每一条数据的处理 for (int i = 0; i 6){ customer.setIdCard("\t"+idcard.replaceAll(idcard.substring(idcard.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("passport")){ customer.setIdType("护照"); // customer.setIdCard("\t"+jsonOb.getString("passport")); String passport = jsonOb.getString("passport"); if(passport.length()>6){ customer.setIdCard("\t"+passport.replaceAll(passport.substring(passport.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("dlicense")){ customer.setIdType("驾驶证"); // customer.setIdCard("\t"+jsonOb.getString("dlicense")); String dlicense = jsonOb.getString("dlicense"); if(dlicense.length()>6){ customer.setIdCard("\t"+dlicense.replaceAll(dlicense.substring(dlicense.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("otheridnumber")){ customer.setIdType("其它证件类型"); // customer.setIdCard("\t"+jsonOb.getString("otheridnumber")); String otheridnumber = jsonOb.getString("otheridnumber"); if(otheridnumber.length()>6){ customer.setIdCard("\t"+otheridnumber.replaceAll(otheridnumber.substring(otheridnumber.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } } customers.add(customer); } // 继续向后查询 scriptRequest = new Request("GET", "/_search/scroll"); scriptRequest.setEntity(entity); responseData = restClient.performRequest(scriptRequest); result = EntityUtils.toString(responseData.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); } Map header = new LinkedHashMap<>(); header.put("scustId", "核心客户号"); header.put("name", "姓名"); header.put("idType", "证件类型"); header.put("idCard", "证件号码"); header.put("sex", "性别"); header.put("birthDay", "出生日期"); CsvUtil.export(request, response, "customer", header, customers); logger.info("导出两要素出时间："+DateUtils.getTime()); }catch (Exception e){ logger.info("导出两要素出错："+DateUtils.getTime()); e.printStackTrace(); } } /** * 导出数据清洗数据 * @param response * @param request */ @GetMapping("/dataCleaning") public void dataCleaning(HttpServletResponse response, HttpServletRequest request,String sameType) { logger.info("导出数据清洗进时间："+DateUtils.getTime()); try{ Request scriptRequest = new Request("GET", "/shanglifeecif.samecustomer/_search?sort=name:asc&q=sametype:"+sameType+"&size=10000&scroll=5m"); Response responseData = restClient.performRequest(scriptRequest); String result = EntityUtils.toString(responseData.getEntity()); JSONObject jsonObject = JSON.parseObject(result); JSONObject hitsobject = (JSONObject) jsonObject.get("hits"); JSONArray array = JSON.parseArray(hitsobject.get("hits").toString()); List customers = new ArrayList(); String scroll_id = jsonObject.getString("_scroll_id"); HttpEntity entity = new NStringEntity("{\n" + " \"scroll_id\": \""+scroll_id+"\",\n" + " \"scroll\": \"5m\"\n" + "}", ContentType.APPLICATION_JSON); while (array.size() != 0) { // 这里填写你的业务逻辑，即对每一条数据的处理 for (int i = 0; i 6){ customer.setIdCard("\t"+idcard.replaceAll(idcard.substring(idcard.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("passport")){ customer.setIdType("护照"); // customer.setIdCard("\t"+jsonOb.getString("passport")); String passport = jsonOb.getString("passport"); if(passport.length()>6){ customer.setIdCard("\t"+passport.replaceAll(passport.substring(passport.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("dlicense")){ customer.setIdType("驾驶证"); // customer.setIdCard("\t"+jsonOb.getString("dlicense")); String dlicense = jsonOb.getString("dlicense"); if(dlicense.length()>6){ customer.setIdCard("\t"+dlicense.replaceAll(dlicense.substring(dlicense.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } }else if(mp.containsKey("otheridnumber")){ customer.setIdType("其它证件类型"); // customer.setIdCard("\t"+jsonOb.getString("otheridnumber")); String otheridnumber = jsonOb.getString("otheridnumber"); if(otheridnumber.length()>6){ customer.setIdCard("\t"+otheridnumber.replaceAll(otheridnumber.substring(otheridnumber.length()-6), "******")); }else{ customer.setIdCard("\t"+"******"); } } customer.setZipCode("\t"+jsonOb.getString("zipcode")); customer.setMobile("\t"+jsonOb.getString("mobile")); customer.setEmail("\t"+jsonOb.getString("email")); customer.setPinDate(jsonOb.getString("pindate")); customer.setAgentName(jsonOb.getString("agentname")); customer.setSalecomName(jsonOb.getString("salecomname")); customers.add(customer); } // 继续向后查询 scriptRequest = new Request("GET", "/_search/scroll"); scriptRequest.setEntity(entity); responseData = restClient.performRequest(scriptRequest); result = EntityUtils.toString(responseData.getEntity()); jsonObject = JSON.parseObject(result); hitsobject = (JSONObject) jsonObject.get("hits"); array = JSON.parseArray(hitsobject.get("hits").toString()); } Map header = new LinkedHashMap<>(); header.put("scustId", "核心客户号"); header.put("name", "姓名"); header.put("idType", "证件类型"); header.put("idCard", "证件号码"); header.put("sex", "性别"); header.put("birthDay", "出生日期"); if("8".equals(sameType) || "16".equals(sameType)){ header.put("mobile", "手机号码"); }else if("9".equals(sameType)){ header.put("zipCode", "邮政编码"); }else if("12".equals(sameType)){ header.put("degree", "学历"); }else if("14".equals(sameType)){ header.put("email", "邮箱"); }else if("15".equals(sameType)){ header.put("pinDate", "起保日期"); }else if("18".equals(sameType)){ header.put("agentName", "业务员名称"); }else if("19".equals(sameType)){ header.put("salecomName", "业绩归属"); } CsvUtil.export(request, response, "customer", header, customers); logger.info("导出数据清洗出时间："+DateUtils.getTime()); }catch (Exception e){ logger.info("导出数据清洗出错："+DateUtils.getTime()); e.printStackTrace(); } } public Map getLables(JSONObject jsonObject,String deptCode ) throws Exception { Map mpInfo = new HashMap(); JSONObject source = JSON.parseObject(jsonObject.getString("_source")); String indid = jsonObject.getString("_id"); mpInfo.put("id",indid); String salecom = source.getString("salecom"); //多渠道不显示标签 最高级全部显示 ， 渠道不一样 不显示 if(StringUtils.isEmpty(deptCode)||deptCode.equals(salecom)){ //单渠道显示所有标签 mpInfo.putAll(JSON.parseObject(jsonObject.getString("_source"),Map.class)); } else{ logger.info(jsonObject.toJSONString()); Map maps = JSON.parseObject(jsonObject.getString("_source"),Map.class); List publicLabels = new ArrayList<>(); publicLabels.add("label1"); publicLabels.add("label2"); publicLabels.add("label3"); publicLabels.add("label4"); publicLabels.add("label9"); publicLabels.add("label10"); publicLabels.add("label21"); publicLabels.add("Label67"); publicLabels.add("Label69"); publicLabels.add("Label70"); publicLabels.add("Label71"); publicLabels.add("Label74"); publicLabels.add("label77"); publicLabels.add("Label80"); publicLabels.add("Label96"); publicLabels.add("Label97"); publicLabels.add("Label100"); publicLabels.add("Label101"); publicLabels.add("Label103"); publicLabels.add("Label104"); publicLabels.add("Label105"); publicLabels.add("Label106"); for (Map.Entry entry : maps.entrySet()){ String key = entry.getKey(); if(key.startsWith("label")){ if(publicLabels.contains(key)){ //公用标签显示 mpInfo.put(key,entry.getValue()); } }else{ mpInfo.put(key,entry.getValue()); } } } if(mpInfo.containsKey("birthday")){ mpInfo.put("birthday", source.getString("birthday")); mpInfo.put("age",DateUtils.getAge(DateUtils.dateTime(DateUtils.YYYY_MM_DD,source.getString("birthday")))); }else{ mpInfo.put("birthday",""); mpInfo.put("age",""); } return mpInfo; } }