Skip to content

X
xzxt-api-report
Commit 0ed4dde0 by liulianglang
Options

通话记录接口

parent c2f4ab8a
Showing with 601 additions and 133 deletions
pom.xml
......@@ -157,7 +157,7 @@
</configuration>
</plugin>
</plugins>
<finalName>xzxt-api-report-quanguotongyongjcxx</finalName>
<finalName>xzxt-api-report-hunanrygj</finalName>
<resources>
<!-- 打包包含xml文件-->
<resource>
......
src/main/java/com/founder/controller/SjController.java
......@@ -23,12 +23,12 @@ public class SjController {
private SjService sjService;
/**
* 手机信息
* 手机信息,通过手机号码查询机主信息
* @param xyrParam
* @return
*/
@PostMapping("/getSjxx")
public Result getSjxx(@RequestBody XyrParam xyrParam){
@PostMapping("/getSjxxBySjhm")
public Result getSjxxBySjhm(@RequestBody XyrParam xyrParam){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
......@@ -38,29 +38,29 @@ public class SjController {
reslt.setStatus("fail");
return reslt;
}
if(StringUtils.isEmpty(xyrParam.getZjhm()) ){
if(StringUtils.isEmpty(xyrParam.getSjhm()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入人员证件号码，不能查询！");
reslt.setMsg("没有传入手机号码，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
try {
mapResult = sjService.getSjxx(request, xyrParam);
mapResult = sjService.getSjxx1(request, xyrParam);
reslt.setData(mapResult);
reslt.setMsg("网吧信息查询成功");
reslt.setMsg("机主信息查询成功");
reslt.setStatus("success");
}catch (Exception e){
e.printStackTrace();
reslt.setData(new ArrayList<>());
reslt.setMsg("网吧信息查询失败");
reslt.setMsg("机主信息查询失败");
reslt.setStatus("fail");
}
return reslt;
}
@PostMapping("/getSjxx1")
public Result getSjxx1(@RequestBody XyrParam xyrParam){
@PostMapping("/getSjxx2")
public Result getSjxx2(@RequestBody XyrParam xyrParam){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
......@@ -79,7 +79,7 @@ public class SjController {
}
Map mapResult = new HashMap();
try {
mapResult = sjService.getSjxx1(request, xyrParam);
mapResult = sjService.getSjxx2(request, xyrParam);
reslt.setData(mapResult);
reslt.setMsg("网吧信息查询成功");
reslt.setStatus("success");
......@@ -91,8 +91,36 @@ public class SjController {
}
return reslt;
}
@PostMapping("/getSjxx2")
public Result getSjxx2(@RequestBody XyrParam xyrParam){
@PostMapping("/getTest")
public Result getTest(@RequestParam("SenderID") String SenderID,@RequestParam("InfoSet") String InfoSet, @RequestBody XyrParam xyrParam){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
Map mapResult = new HashMap();
try {
System.out.println("SenderID--"+SenderID);
System.out.println("InfoSet--"+InfoSet);
reslt.setData(mapResult);
reslt.setMsg("网吧信息查询成功");
reslt.setStatus("success");
}catch (Exception e){
e.printStackTrace();
reslt.setData(new ArrayList<>());
reslt.setMsg("网吧信息查询失败");
reslt.setStatus("fail");
}
return reslt;
}
/**
* 手机信息,通过证件号码查询机主信息
* @param xyrParam
* @return
*/
@PostMapping("/getSjxxByZjhm")
public Result getSjxxByZjhm(@RequestBody XyrParam xyrParam){
Result reslt = new Result();
HttpServletRequest request = IpADdress.getRequest();
String header = request.getHeader("founder.authorization");
......@@ -105,44 +133,99 @@ public class SjController {
if(StringUtils.isEmpty(xyrParam.getZjhm()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入人员证件号码，不能查询！");
reslt.setMsg("没有传入证件号码，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
try {
mapResult = sjService.getSjxx2(request, xyrParam);
mapResult = sjService.getSjxxByZjhm(request, xyrParam);
reslt.setData(mapResult);
reslt.setMsg("网吧信息查询成功");
reslt.setMsg("机主信息查询成功");
reslt.setStatus("success");
}catch (Exception e){
e.printStackTrace();
reslt.setData(new ArrayList<>());
reslt.setMsg("网吧信息查询失败");
reslt.setMsg("机主信息查询失败");
reslt.setStatus("fail");
}
return reslt;
}
@PostMapping("/getTest")
public Result getTest(@RequestParam("SenderID") String SenderID,@RequestParam("InfoSet") String InfoSet, @RequestBody XyrParam xyrParam){
/**
* 快递查询，手机号码
* @param xyrParam
* @return
*/
@PostMapping("/getKdxxBySjhm")
public Result getKdxxBySjhm(@RequestBody XyrParam xyrParam){
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(xyrParam.getSjhm()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入手机号码，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
try {
System.out.println("SenderID--"+SenderID);
System.out.println("InfoSet--"+InfoSet);
mapResult = sjService.getKdxxBySjhm(request, xyrParam);
reslt.setData(mapResult);
reslt.setMsg("网吧信息查询成功");
reslt.setMsg("快递信息查询成功");
reslt.setStatus("success");
}catch (Exception e){
e.printStackTrace();
reslt.setData(new ArrayList<>());
reslt.setMsg("网吧信息查询失败");
reslt.setMsg("快递信息查询失败");
reslt.setStatus("fail");
}
return reslt;
}
/**
* 话单查询，手机号码
* @param xyrParam
* @return
*/
@PostMapping("/getTxxxBySjhm")
public Result getTxxxBySjhm(@RequestBody XyrParam xyrParam){
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(xyrParam.getSjhm()) ){
reslt.setData(new ArrayList<>());
reslt.setMsg("没有传入手机号码，不能查询！");
reslt.setStatus("fail");
return reslt;
}
Map mapResult = new HashMap();
try {
mapResult = sjService.getTxxxBySjhm(request, xyrParam);
reslt.setData(mapResult);
reslt.setMsg("话单信息查询成功");
reslt.setStatus("success");
}catch (Exception e){
e.printStackTrace();
reslt.setData(new ArrayList<>());
reslt.setMsg("话单信息查询失败");
reslt.setStatus("fail");
}
return reslt;
}
}
src/main/java/com/founder/service/SjService.java
......@@ -7,11 +7,17 @@ import java.util.Map;
public interface SjService {
Map<String, Object> getSjxx(HttpServletRequest request, XyrParam xyrParam) throws Exception;
Map<String, Object> getSjxx1(HttpServletRequest request, XyrParam xyrParam) throws Exception;
Map<String, Object> getSjxx2(HttpServletRequest request, XyrParam xyrParam) throws Exception;
Map<String, Object> getSjxxByZjhm(HttpServletRequest request, XyrParam xyrParam) throws Exception;
Map<String, Object> getKdxxBySjhm(HttpServletRequest request, XyrParam xyrParam) throws Exception;
Map<String, Object> getTxxxBySjhm(HttpServletRequest request, XyrParam xyrParam) throws Exception;
}
src/main/java/com/founder/service/impl/SjServiceImpl.java
......@@ -27,8 +27,9 @@ import java.util.Map;
@Service
public class SjServiceImpl implements SjService {
@Override
public Map<String, Object> getSjxx(HttpServletRequest request, XyrParam xyrParam) throws Exception {
public Map<String, Object> getSjxx1(HttpServletRequest request, XyrParam xyrParam) throws Exception {
Map<String, Object> returnMap = new HashMap<>();
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(xyrParam.getPage());
......@@ -41,87 +42,101 @@ public class SjServiceImpl implements SjService {
String bodyJson="{\n" +
" \"app_header\": {},\n" +
" \"app_body\": {}}";
String param="SenderID=C43-00000005&ServiceID=S43-00000548&EndUser=李德书,432326197503264512,430000290000&InfoType=KHCX&InfoSet=<Content><Header>\n" +
"<RequestID>KHCX_65.28.39.173_20200825172913_1234</RequestID>\n" +
"<CommonInfo>\n" +
"<approveID>430102195309191513</approveID>\n" +
"<approveName>测试吴俊明</approveName>\n" +
"<DeptName>局领导</DeptName>\n" +
"</CommonInfo>\n" +
"<CaseInfo>\n" +
"<CaseID>A4301000000002020070001</CaseID>\n" +
"<CaseName>监管平台对接测试</CaseName>\n" +
"<CaseProperty>刑事</CaseProperty>\n" +
"<CaseCause>查询案件:监管平台对接测试</CaseCause>\n" +
"<CaseResume>查询机主，详单，寄递</CaseResume>\n" +
"</CaseInfo></Header><Body>\n" +
"<DbSource name=\"KHCX\" carrier=\"YD\">YDKHCX</DbSource><Fields Count=\"1\">\n" +
"<FieldCondition>\n" +
"<LogicCaculation>and</LogicCaculation>\n" +
"<LeftBracket></LeftBracket>\n" +
"<LeftValue>PHONE_NUM</LeftValue>\n" +
"<ConditionCalculation>=</ConditionCalculation>\n" +
"<RightValue>15830000000</RightValue>\n" +
"<RightBracket></RightBracket>\n" +
"</FieldCondition></Fields></Body></Content>";
String resultToken = "";
String urlstr=""+param;
System.out.println(URLEncoder.encode(urlstr,"UTF-8"));
String resultToken = "";
// resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/"+param, headers, bodyJson);
resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/?"+URLEncoder.encode(urlstr,"UTF-8"), headers, bodyJson);
resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/?SenderID=C43-00000005&ServiceID=S43-00000548&EndUser=李德书,432326197503264512,430000290000&InfoType=KHCX&InfoSet="+URLEncoder.encode(initCondition(xyrParam.getSjhm()),"UTF-8"), headers, bodyJson);
// resultToken = HttpClient.doPostJson("http://127.0.0.1:9051/sjcx/getTest?SenderID=11&InfoSet="+initCondition(), headers, bodyJson);
System.out.println(resultToken);
JSONObject jsonObject = xmltoJson(resultToken);
System.out.println(jsonObject.toJSONString());
JSONObject results=jsonObject.getJSONObject("Result");
JSONObject datas=results.getJSONObject("Datas");
JSONObject ottoMsg=datas.getJSONObject("OTTOMsg");
JSONObject uqs=ottoMsg.getJSONObject("uqs");
JSONObject rs=uqs.getJSONObject("response");
int total=rs.getIntValue("totalResults");
JSONObject userInfos=uqs.getJSONObject("userInfos");
JSONArray list=userInfos.getJSONArray("userInfo");
List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
if(list.size()>0){
for(int i=0;i<list.size();i++){
Map<String, Object> mapnr = new HashMap();
JSONObject job = list.getJSONObject(i); // 遍历 jsonarray 数组，把每一个对象转成 json 对象
// 得到 每个对象中的属性值
String phoneNo=job.getString("phoneNo"); //电话号码
String provLatnId=job.getString("provLatnId"); //用户地域标识
String userName=job.getString("userName"); //用户姓名
String status=job.getString("status"); //用户状态
String setuPaddr=job.getString("SETUPaddr"); //安装地址
String certTypeId=job.getString("certTypeId"); //证件类型
String idCard=job.getString("idCard"); //证件号码
String openDate=job.getString("openDate"); //业务受理时间
String address=job.getString("address");//客户地址
mapnr.put("phoneNo",phoneNo);
mapnr.put("provLatnId",provLatnId);
mapnr.put("userName",userName);
mapnr.put("setuPaddr",setuPaddr);
mapnr.put("certTypeId",certTypeId);
mapnr.put("status",status);
mapnr.put("openDate",openDate);
mapnr.put("idCard",idCard);
mapnr.put("address",address);
result.add(mapnr);
JSONObject jsonObject = xmltoJson(resultToken);
System.out.println(jsonObject.toJSONString());
JSONObject results=jsonObject.getJSONObject("Result");
JSONObject datas=results.getJSONObject("Datas");
JSONObject ottoMsg=datas.getJSONObject("OTTOMsg");
JSONObject uqs=ottoMsg.getJSONObject("uqs");
JSONObject rs=uqs.getJSONObject("response");
int total=rs.getIntValue("totalResults");
JSONObject userInfos=uqs.getJSONObject("userInfos");
List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
if(total>0){
if(total==1){
Map<String, Object> mapnr = new HashMap();
JSONObject job=userInfos.getJSONObject("userInfo");
// 得到 每个对象中的属性值
String phoneNo=job.getString("phoneNo"); //电话号码
String provLatnId=job.getString("provLatnId"); //用户地域标识
String userName=job.getString("userName"); //用户姓名
String status=job.getString("status"); //用户状态
String setuPaddr=job.getString("SETUPaddr"); //安装地址
String certTypeId=job.getString("certTypeId"); //证件类型
String idCard=job.getString("idCard"); //证件号码
String openDate=job.getString("openDate"); //业务受理时间
String address=job.getString("address");//客户地址
mapnr.put("phoneNo",phoneNo);
mapnr.put("provLatnId",provLatnId);
mapnr.put("userName",userName);
mapnr.put("setuPaddr",setuPaddr);
mapnr.put("certTypeId",certTypeId);
mapnr.put("status",status);
mapnr.put("openDate",openDate);
mapnr.put("idCard",idCard);
mapnr.put("address",address);
result.add(mapnr);
returnMap.put("total",total);
returnMap.put("rows", result);
}else{
JSONArray list=userInfos.getJSONArray("userInfo");
if(list.size()>0){
for(int i=0;i<list.size();i++){
Map<String, Object> mapnr = new HashMap();
JSONObject job = list.getJSONObject(i); // 遍历 jsonarray 数组，把每一个对象转成 json 对象
// 得到 每个对象中的属性值
String phoneNo=job.getString("phoneNo"); //电话号码
String provLatnId=job.getString("provLatnId"); //用户地域标识
String userName=job.getString("userName"); //用户姓名
String status=job.getString("status"); //用户状态
String setuPaddr=job.getString("SETUPaddr"); //安装地址
String certTypeId=job.getString("certTypeId"); //证件类型
String idCard=job.getString("idCard"); //证件号码
String openDate=job.getString("openDate"); //业务受理时间
String address=job.getString("address");//客户地址
mapnr.put("phoneNo",phoneNo);
mapnr.put("provLatnId",provLatnId);
mapnr.put("userName",userName);
mapnr.put("setuPaddr",setuPaddr);
mapnr.put("certTypeId",certTypeId);
mapnr.put("status",status);
mapnr.put("openDate",openDate);
mapnr.put("idCard",idCard);
mapnr.put("address",address);
result.add(mapnr);
}
}
returnMap.put("total",total);
returnMap.put("rows", result);
}
returnMap.put("total",total);
returnMap.put("rows", result);
}else {
returnMap.put("total",total);
returnMap.put("rows", new ArrayList<Map<String, Object>>());
}
return returnMap;
}
@Override
public Map<String, Object> getSjxx1(HttpServletRequest request, XyrParam xyrParam) throws Exception {
public Map<String, Object> getSjxxByZjhm(HttpServletRequest request, XyrParam xyrParam) throws Exception {
Map<String, Object> returnMap = new HashMap<>();
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(xyrParam.getPage());
......@@ -134,36 +149,11 @@ public class SjServiceImpl implements SjService {
String bodyJson="{\n" +
" \"app_header\": {},\n" +
" \"app_body\": {}}";
String param="<Content><Header>\n" +
"<RequestID>KHCX_65.28.39.173_20200825172913_1234</RequestID>\n" +
"<CommonInfo>\n" +
"<approveID>430102195309191513</approveID>\n" +
"<approveName>测试吴俊明</approveName>\n" +
"<DeptName>局领导</DeptName>\n" +
"</CommonInfo>\n" +
"<CaseInfo>\n" +
"<CaseID>A4301000000002020070001</CaseID>\n" +
"<CaseName>监管平台对接测试</CaseName>\n" +
"<CaseProperty>刑事</CaseProperty>\n" +
"<CaseCause>查询案件:监管平台对接测试</CaseCause>\n" +
"<CaseResume>查询机主，详单，寄递</CaseResume>\n" +
"</CaseInfo></Header><Body>\n" +
"<DbSource name=\"KHCX\" carrier=\"YD\">YDKHCX</DbSource><Fields Count=\"1\">\n" +
"<FieldCondition>\n" +
"<LogicCaculation>and</LogicCaculation>\n" +
"<LeftBracket></LeftBracket>\n" +
"<LeftValue>PHONE_NUM</LeftValue>\n" +
"<ConditionCalculation>=</ConditionCalculation>\n" +
"<RightValue>15830000000</RightValue>\n" +
"<RightBracket></RightBracket>\n" +
"</FieldCondition></Fields></Body></Content>";
String resultToken = "";
String urlstr=""+param;
System.out.println(URLEncoder.encode(urlstr,"UTF-8"));
String resultToken = "";
// resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/"+param, headers, bodyJson);
resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/?SenderID=C43-00000005&ServiceID=S43-00000548&EndUser=李德书,432326197503264512,430000290000&InfoType=KHCX&InfoSet="+URLEncoder.encode(initCondition(),"UTF-8"), headers, bodyJson);
resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/?SenderID=C43-00000005&ServiceID=S43-00000548&EndUser=李德书,432326197503264512,430000290000&InfoType=KHCX&InfoSet="+URLEncoder.encode(initConditionByZjhm(xyrParam.getZjhm()),"UTF-8"), headers, bodyJson);
// resultToken = HttpClient.doPostJson("http://127.0.0.1:9051/sjcx/getTest?SenderID=11&InfoSet="+initCondition(), headers, bodyJson);
System.out.println(resultToken);
......@@ -171,24 +161,24 @@ public class SjServiceImpl implements SjService {
System.out.println(jsonObject.toJSONString());
JSONObject results=jsonObject.getJSONObject("Result");
JSONObject datas=results.getJSONObject("Datas");
int total=0;
JSONObject ottoMsg=datas.getJSONObject("OTTOMsg");
JSONObject uqs=ottoMsg.getJSONObject("uqs");
JSONObject rs=uqs.getJSONObject("response");
int total=rs.getIntValue("totalResults");
total=rs.getIntValue("totalResults");
JSONObject userInfos=uqs.getJSONObject("userInfos");
JSONArray list=userInfos.getJSONArray("userInfo");
List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
if(list.size()>0){
for(int i=0;i<list.size();i++){
if(total>0){
if(total==1){
Map<String, Object> mapnr = new HashMap();
JSONObject job = list.getJSONObject(i); // 遍历 jsonarray 数组，把每一个对象转成 json 对象
JSONObject job=userInfos.getJSONObject("userInfo");
// 得到 每个对象中的属性值
String phoneNo=job.getString("phoneNo"); //电话号码
String provLatnId=job.getString("provLatnId"); //用户地域标识
String userName=job.getString("userName"); //用户姓名
String status=job.getString("status"); //用户状态
String status=job.getString("status"); //用户状态 1：在用，0：欠费停机，2：停机，3：注销，9其它
String setuPaddr=job.getString("SETUPaddr"); //安装地址
String certTypeId=job.getString("certTypeId"); //证件类型
String idCard=job.getString("idCard"); //证件号码
......@@ -205,13 +195,282 @@ public class SjServiceImpl implements SjService {
mapnr.put("idCard",idCard);
mapnr.put("address",address);
result.add(mapnr);
returnMap.put("total",total);
returnMap.put("rows", result);
}else{
JSONArray list=userInfos.getJSONArray("userInfo");
if(list.size()>0){
for(int i=0;i<list.size();i++){
Map<String, Object> mapnr = new HashMap();
JSONObject job = list.getJSONObject(i); // 遍历 jsonarray 数组，把每一个对象转成 json 对象
// 得到 每个对象中的属性值
String phoneNo=job.getString("phoneNo"); //电话号码
String provLatnId=job.getString("provLatnId"); //用户地域标识
String userName=job.getString("userName"); //用户姓名
String status=job.getString("status"); //用户状态
String setuPaddr=job.getString("SETUPaddr"); //安装地址
String certTypeId=job.getString("certTypeId"); //证件类型
String idCard=job.getString("idCard"); //证件号码
String openDate=job.getString("openDate"); //业务受理时间
String address=job.getString("address");//客户地址
mapnr.put("phoneNo",phoneNo);
mapnr.put("provLatnId",provLatnId);
mapnr.put("userName",userName);
mapnr.put("setuPaddr",setuPaddr);
mapnr.put("certTypeId",certTypeId);
mapnr.put("status",status);
mapnr.put("openDate",openDate);
mapnr.put("idCard",idCard);
mapnr.put("address",address);
result.add(mapnr);
}
}
returnMap.put("total",total);
returnMap.put("rows", result);
}
}else {
returnMap.put("total",total);
returnMap.put("rows", new ArrayList<Map<String, Object>>());
}
returnMap.put("total",total);
returnMap.put("rows", result);
return returnMap;
}
@Override
public Map<String, Object> getKdxxBySjhm(HttpServletRequest request, XyrParam xyrParam) throws Exception {
Map<String, Object> returnMap = new HashMap<>();
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(xyrParam.getPage());
easyUIPage.setPagePara(xyrParam.getLimit());
int begin = easyUIPage.getBegin();
int end = easyUIPage.getEnd();
xyrParam.setPage(begin);
xyrParam.setLimit(end);
Map<String, String> headers =initHttpXmlHeads();
String bodyJson="{\n" +
" \"app_header\": {},\n" +
" \"app_body\": {}}";
String resultToken = "";
// resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/"+param, headers, bodyJson);
resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/?SenderID=C43-00000005&ServiceID=S43-00000548&EndUser=李德书,432326197503264512,430000290000&InfoType=KHCX&InfoSet="+URLEncoder.encode(initKdConditionByZjhm(xyrParam.getSjhm()),"UTF-8"), headers, bodyJson);
// resultToken = HttpClient.doPostJson("http://127.0.0.1:9051/sjcx/getTest?SenderID=11&InfoSet="+initCondition(), headers, bodyJson);
int total=0;
System.out.println(resultToken);
JSONObject jsonObject = xmltoJson(resultToken);
System.out.println(jsonObject.toJSONString());
JSONObject results=jsonObject.getJSONObject("Result");
JSONObject datas=results.getJSONObject("Datas");
JSONObject ottoMsg=datas.getJSONObject("OTTOMsg");
JSONObject jdcx=ottoMsg.getJSONObject("JDCX");
JSONObject datalist=jdcx.getJSONObject("datalist");
total=jdcx.getIntValue("recordCount");
List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
if(total>0){
if(total==1){
Map<String, Object> mapnr = new HashMap();
JSONObject job=datalist.getJSONObject("data");
String senderAddress=job.getString("senderAddress"); //发货地址
String receiverName=job.getString("receiverName"); //收货方姓名
String companyName=job.getString("companyName"); //寄递公司地址
String receiverMobile=job.getString("receiverMobile"); //收货方移动电话
String senderCounty=job.getString("senderCounty"); //发货方所在区县
String senderNation=job.getString("senderNation"); //发货方所在国家
String senderProvince=job.getString("senderProvince"); //发货方所在省份
String senderCity=job.getString("senderCity"); //发货方所在市
String receiverAddress=job.getString("receiverAddress");//收货人详细地址
String senderName=job.getString("senderName");//发货方姓名
String ecOrderID=job.getString("ecOrderID");//订单号
String goodsName=job.getString("goodsName");//物品名称
mapnr.put("senderAddress",senderAddress);
mapnr.put("receiverName",receiverName);
mapnr.put("companyName",companyName);
mapnr.put("receiverMobile",receiverMobile);
mapnr.put("senderCounty",senderCounty);
mapnr.put("senderNation",senderNation);
mapnr.put("senderProvince",senderProvince);
mapnr.put("senderCity",senderCity);
mapnr.put("receiverAddress",receiverAddress);
mapnr.put("senderName",senderName);
mapnr.put("ecOrderID",ecOrderID);
mapnr.put("goodsName",goodsName);
result.add(mapnr);
returnMap.put("total",total);
returnMap.put("rows", result);
}else {
JSONArray list=datalist.getJSONArray("data");
if(list.size()>0){
for(int i=0;i<list.size();i++){
Map<String, Object> mapnr = new HashMap();
JSONObject job = list.getJSONObject(i); // 遍历 jsonarray 数组，把每一个对象转成 json 对象
// 得到 每个对象中的属性值
String senderAddress=job.getString("senderAddress"); //发货地址
String receiverName=job.getString("receiverName"); //收货方姓名
String companyName=job.getString("companyName"); //寄递公司地址
String receiverMobile=job.getString("receiverMobile"); //收货方移动电话
String senderCounty=job.getString("senderCounty"); //发货方所在区县
String senderNation=job.getString("senderNation"); //发货方所在国家
String senderProvince=job.getString("senderProvince"); //发货方所在省份
String senderCity=job.getString("senderCity"); //发货方所在市
String receiverAddress=job.getString("receiverAddress");//收货人详细地址
String senderName=job.getString("senderName");//发货方姓名
String ecOrderID=job.getString("ecOrderID");//订单号
String goodsName=job.getString("goodsName");//物品名称
mapnr.put("senderAddress",senderAddress);
mapnr.put("receiverName",receiverName);
mapnr.put("companyName",companyName);
mapnr.put("receiverMobile",receiverMobile);
mapnr.put("senderCounty",senderCounty);
mapnr.put("senderNation",senderNation);
mapnr.put("senderProvince",senderProvince);
mapnr.put("senderCity",senderCity);
mapnr.put("receiverAddress",receiverAddress);
mapnr.put("senderName",senderName);
mapnr.put("ecOrderID",ecOrderID);
mapnr.put("goodsName",goodsName);
result.add(mapnr);
}
}
returnMap.put("total",total);
returnMap.put("rows", result);
}
}else {
returnMap.put("total",total);
returnMap.put("rows", new ArrayList<Map<String, Object>>());
}
return returnMap;
}
@Override
public Map<String, Object> getTxxxBySjhm(HttpServletRequest request, XyrParam xyrParam) throws Exception {
Map<String, Object> returnMap = new HashMap<>();
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(xyrParam.getPage());
easyUIPage.setPagePara(xyrParam.getLimit());
int begin = easyUIPage.getBegin();
int end = easyUIPage.getEnd();
xyrParam.setPage(begin);
xyrParam.setLimit(end);
Map<String, String> headers =initHttpXmlHeads();
String bodyJson="{\n" +
" \"app_header\": {},\n" +
" \"app_body\": {}}";
String resultToken = "";
// resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/"+param, headers, bodyJson);
resultToken = HttpClient.doPostJson("http://65.26.10.200:8581/GatewayMsg/proxy/invoke/?SenderID=C43-00000005&ServiceID=S43-00000548&EndUser=李德书,432326197503264512,430000290000&InfoType=KHCX&InfoSet="+URLEncoder.encode(initHdConditionByZjhm(xyrParam),"UTF-8"), headers, bodyJson);
// resultToken = HttpClient.doPostJson("http://127.0.0.1:9051/sjcx/getTest?SenderID=11&InfoSet="+initCondition(), headers, bodyJson);
System.out.println(resultToken);
JSONObject jsonObject = xmltoJson(resultToken);
System.out.println(jsonObject.toJSONString());
JSONObject results=jsonObject.getJSONObject("Result");
JSONObject datas=results.getJSONObject("Datas");
int total=0;
JSONObject ottoMsg=datas.getJSONObject("OTTOMsg");
JSONObject dccx=ottoMsg.getJSONObject("DCCX");
JSONObject msgContent=dccx.getJSONObject("MsgContent");
JSONObject commonlyQuery=msgContent.getJSONObject("CommonlyQuery");
JSONObject commonlyQueryResponse=commonlyQuery.getJSONObject("CommonlyQueryResponse");
total=commonlyQueryResponse.getIntValue("ResultCount");
JSONObject datalist=commonlyQueryResponse.getJSONObject("CommonQueryResultList");
List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
if(total>0){
if(total==1){
Map<String, Object> mapnr = new HashMap();
JSONObject job=datalist.getJSONObject("CommonQueryResultInfo");
String oppositeNumber=job.getString("OppositeNumber"); //对方号码
String toAttAreaCode=job.getString("ToAttAreaCode"); // 对方号码所在地
String customerNumber=job.getString("CustomerNumber"); //服务号码
String userAttAreaCode=job.getString("UserAttAreaCode"); //服务方所在地
String callType=job.getString("CallType"); //呼号类型
String beginTime=job.getString("BeginTime"); //开始时间
String timeLen=job.getString("TimeLen"); //通话时长 （单位秒）
mapnr.put("oppositeNumber",oppositeNumber);
mapnr.put("toAttAreaCode",toAttAreaCode);
mapnr.put("customerNumber",customerNumber);
mapnr.put("userAttAreaCode",userAttAreaCode);
mapnr.put("callType",callType);
mapnr.put("beginTime",beginTime);
mapnr.put("timeLen",timeLen);
result.add(mapnr);
returnMap.put("total",total);
returnMap.put("rows", result);
}else {
JSONArray list=datalist.getJSONArray("CommonQueryResultInfo");
if(list.size()>0){
for(int i=0;i<list.size();i++){
Map<String, Object> mapnr = new HashMap();
JSONObject job = list.getJSONObject(i); // 遍历 jsonarray 数组，把每一个对象转成 json 对象
// 得到 每个对象中的属性值
String oppositeNumber=job.getString("OppositeNumber"); //对方号码
String toAttAreaCode=job.getString("ToAttAreaCode"); // 对方号码所在地
String customerNumber=job.getString("CustomerNumber"); //服务号码
String userAttAreaCode=job.getString("UserAttAreaCode"); //服务方所在地
String callType=job.getString("CallType"); //呼号类型
String beginTime=job.getString("BeginTime"); //开始时间
String timeLen=job.getString("TimeLen"); //通话时长 （单位秒）
mapnr.put("oppositeNumber",oppositeNumber);
mapnr.put("toAttAreaCode",toAttAreaCode);
mapnr.put("customerNumber",customerNumber);
mapnr.put("userAttAreaCode",userAttAreaCode);
mapnr.put("callType",callType);
mapnr.put("beginTime",beginTime);
mapnr.put("timeLen",timeLen);
result.add(mapnr);
}
}
returnMap.put("total",total);
returnMap.put("rows", result);
}
}else {
returnMap.put("total",total);
returnMap.put("rows", new ArrayList<Map<String, Object>>());
}
return returnMap;
}
@Override
public Map<String, Object> getSjxx2(HttpServletRequest request, XyrParam xyrParam) throws Exception {
Map<String, Object> returnMap = new HashMap<>();
......@@ -323,7 +582,13 @@ public class SjServiceImpl implements SjService {
return headParams;
}
private String initCondition() {
/**
* 手机号码机主查询参数
* @param sjhm
* @return
*/
private String initCondition(String sjhm) {
StringBuffer sb = new StringBuffer();
sb.append("<Content><Header>");
sb.append("<RequestID>KHCX_65.28.39.173_20200825172913_1234</RequestID>");
......@@ -346,7 +611,121 @@ public class SjServiceImpl implements SjService {
sb.append("<LeftBracket></LeftBracket>");
sb.append("<LeftValue>PHONE_NUM</LeftValue>");
sb.append("<ConditionCalculation>=</ConditionCalculation>");
sb.append("<RightValue>15830000000</RightValue>");
sb.append("<RightValue>"+sjhm+"</RightValue>");
sb.append("<RightBracket></RightBracket>");
sb.append("</FieldCondition></Fields></Body></Content>");
return sb.toString();
}
/**
* 手机号码机主查询参数,证件号码查询
* @param zjhm
* @return
*/
private String initConditionByZjhm(String zjhm) {
StringBuffer sb = new StringBuffer();
sb.append("<Content><Header>");
sb.append("<RequestID>KHCX_65.28.39.173_20200825172913_1111</RequestID>");
sb.append("<CommonInfo>");
sb.append("<approveID>430102195309191513</approveID>");
sb.append("<approveName>测试吴俊明</approveName>");
sb.append("<DeptName>局领导</DeptName>");
sb.append("</CommonInfo>");
sb.append("<CaseInfo>");
sb.append("<CaseID>A4301000000002020070001</CaseID>");
sb.append("<CaseName>监管平台对接测试</CaseName>");
sb.append("<CaseProperty>刑事</CaseProperty>");
sb.append("<CaseCause>查询案件:监管平台对接测试</CaseCause>");
sb.append("<CaseResume>查询机主，详单，寄递</CaseResume>");
sb.append("</CaseInfo></Header><Body>");
sb.append("<DbSource name=\"KHCX\" carrier=\"YD\">YDKHCX</DbSource><Fields Count=\"1\">");
sb.append("<FieldCondition>");
sb.append("<LogicCaculation>and</LogicCaculation>");
sb.append("<LeftBracket></LeftBracket>");
sb.append("<LeftValue>idCard</LeftValue>");
sb.append("<ConditionCalculation>=</ConditionCalculation>");
sb.append("<RightValue>"+zjhm+"</RightValue>");
sb.append("<RightBracket></RightBracket>");
sb.append("</FieldCondition></Fields></Body></Content>");
return sb.toString();
}
/**
* 手机号码快递查询初始化参数
* @param sjhm
* @return
*/
private String initKdConditionByZjhm(String sjhm) {
StringBuffer sb = new StringBuffer();
sb.append("<Content><Header>");
sb.append("<RequestID>JDCX_65.28.39.173_20200825172913_1234</RequestID>");
sb.append("<CommonInfo>");
sb.append("<approveID>430102195309191513</approveID>");
sb.append("<approveName>测试吴俊明</approveName>");
sb.append("<DeptName>局领导</DeptName>");
sb.append("</CommonInfo>");
sb.append("<CaseInfo>");
sb.append("<CaseID>A4301000000002020070001</CaseID>");
sb.append("<CaseName>监管平台对接测试</CaseName>");
sb.append("<CaseProperty>刑事</CaseProperty>");
sb.append("<CaseCause>查询案件:监管平台对接测试</CaseCause>");
sb.append("<CaseResume>查询机主，详单，寄递</CaseResume>");
sb.append("</CaseInfo></Header><Body>");
sb.append("<DbSource name=\"JDCX\" carrier=\"JDCX\">JDCX</DbSource><Fields Count=\"1\">");
sb.append("<FieldCondition>");
sb.append("<LogicCaculation>and</LogicCaculation>");
sb.append("<LeftBracket></LeftBracket>");
sb.append("<LeftValue>PHONE_NUM</LeftValue>");
sb.append("<ConditionCalculation>=</ConditionCalculation>");
sb.append("<RightValue>"+sjhm+"</RightValue>");
sb.append("<RightBracket></RightBracket>");
sb.append("</FieldCondition></Fields></Body></Content>");
return sb.toString();
}
/**
* 手机号码话单查询初始化参数
* @param
* @return
*/
private String initHdConditionByZjhm(XyrParam xyrParam) {
StringBuffer sb = new StringBuffer();
sb.append("<Content><Header>");
sb.append("<RequestID>DCCX_65.28.39.173_20200825172913_1234</RequestID>");
sb.append("<CommonInfo>");
sb.append("<approveID>430102195309191513</approveID>");
sb.append("<approveName>测试吴俊明</approveName>");
sb.append("<DeptName>局领导</DeptName>");
sb.append("</CommonInfo>");
sb.append("<CaseInfo>");
sb.append("<CaseID>A4301000000002020070001</CaseID>");
sb.append("<CaseName>监管平台对接测试</CaseName>");
sb.append("<CaseProperty>刑事</CaseProperty>");
sb.append("<CaseCause>查询案件:监管平台对接测试</CaseCause>");
sb.append("<CaseResume>查询机主，详单，寄递</CaseResume>");
sb.append("</CaseInfo></Header><Body>");
sb.append("<DbSource name=\"DCCX\" carrier=\"YD\">GSM,SMS,ROAM,GPRS,local</DbSource><Fields Count=\"2\">");
sb.append("<FieldCondition>");
sb.append("<LogicCaculation>and</LogicCaculation>");
sb.append("<LeftBracket></LeftBracket>");
sb.append("<LeftValue>START_TIME</LeftValue>");
sb.append("<ConditionCalculation>=</ConditionCalculation>");
sb.append("<RightValue>"+xyrParam.getKssj()+","+xyrParam.getJssj()+"</RightValue>");
sb.append("<RightBracket></RightBracket>");
sb.append("</FieldCondition>");
sb.append("<FieldCondition>");
sb.append("<LogicCaculation>and</LogicCaculation>");
sb.append("<LeftBracket></LeftBracket>");
sb.append("<LeftValue>CHARGE_NUM</LeftValue>");
sb.append("<ConditionCalculation>=</ConditionCalculation>");
sb.append("<RightValue>"+xyrParam.getSjhm()+"</RightValue>");
sb.append("<RightBracket></RightBracket>");
sb.append("</FieldCondition></Fields></Body></Content>");
......
src/main/resources/application.yml
......@@ -27,7 +27,7 @@ jslocation: E:/sysDictJs/common/dict/
ssdw: 140000000000
server:
port: 9061
port: 9051
xxcx:
author: Basic 9b6c45cfcf3a4a629e3ed90fa3e5d058
orc: http://39.99.224.27:8866/predict/chinese_ocr_db_crnn_mobile
......
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