Skip to content

M
map-parent
Commit c630082e by 宋珺琪
Options

0.0.0(内蒙）

parent 89049078
Showing with 270 additions and 195 deletions
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/hnkshEntity/Kshpropertice.java
......@@ -12,6 +12,7 @@ public class Kshpropertice implements Serializable {
private String label;
private String imgType;
private String imagePhoto;
private String boderColor;
/* @ApiModelProperty(value = "标签")
......
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/KshServicePojo.java
......@@ -73,7 +73,13 @@ public class KshServicePojo extends Model<KshServicePojo> {
@TableField(exist = false)
private int page;
@ApiModelProperty(value = "路由名称")
@ApiModelProperty(value = "每页多少")
@TableField(exist = false)
private int pageSize;
//双击节点查询 前端把类型传过来 后台做校验
@ApiModelProperty(value = "类型")
@TableField(exist = false)
private String objectType;
}
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/JdfxEntity.java
......@@ -19,10 +19,10 @@ public class JdfxEntity implements Serializable {
private String timeEnd;
@ApiModelProperty(value = "页码（默认1）")
private String pageNumber ="1";
private String pageNumber;
@ApiModelProperty(value = "每页数量（默认10）")
private String pageSize ="10";
private String pageSize;
@ApiModelProperty(value = "请求用户名")
private String qqyhm;
......
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/JpgxEntity.java
......@@ -11,9 +11,9 @@ public class JpgxEntity implements Serializable {
@ApiModelProperty(value = "身份证号")
private String sfzh;
@ApiModelProperty(value = "页码（默认1）")
private String pageNumber ="1";
private String pageNumber ;
@ApiModelProperty(value = "每页数量（默认10）")
private String pageSize ="10";
private String pageSize ;
@ApiModelProperty(value = "请求用户名")
private String qqyhm;
@ApiModelProperty(value = "请求人身份证号")
......
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/ShgxEntity.java
......@@ -15,10 +15,10 @@ public class ShgxEntity implements Serializable {
private String type;
@ApiModelProperty(value = "页码（默认1）")
private String pageNum ="1";
private String pageNum ;
@ApiModelProperty(value = "每页数量（默认10）")
private String pageSize="10";
private String pageSize;
@ApiModelProperty(value = "请求用户名")
private String qqyhm;
......
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/TlfxEntity.java
......@@ -20,10 +20,10 @@ public class TlfxEntity implements Serializable {
private String timeEnd;
@ApiModelProperty(value = "页码（默认1）")
private String pageNumber ="1";
private String pageNumber ;
@ApiModelProperty(value = "每页数量（默认10）")
private String pageSize="10";
private String pageSize;
@ApiModelProperty(value = "请求用户名")
private String qqyhm;
......
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/TlgxEntity.java
......@@ -18,10 +18,10 @@ public class TlgxEntity implements Serializable {
private String timeEnd;
@ApiModelProperty(value = "页码（默认1）")
private String pageNumber ="1";
private String pageNumber;
@ApiModelProperty(value = "每页数量（默认10）")
private String pageSize ="10";
private String pageSize;
@ApiModelProperty(value = "请求用户名")
private String qqyhm;
......
common/common_utils/src/main/java/com/founder/commonutils/util/JsonValidator.java
......@@ -185,10 +185,14 @@ public class JsonValidator {
}
public static void main(String[] args){
String s ="{\n" +
"\t\"param\":[\n" +
"\t\t{\"name\":\"身份证号\",\"id\":\"sfzh\",\"type\": \"text\"},{\"name\":\"类型\",\"id\":\"type\",\"type\":\"optional\",\"value\":[{\"lable\":\"配偶\",\"value\":\"01\"},{\"lable\":\"子女\",\"value\":\"02\"}]},{\"name\":\"开始时间\",\"id\":\"timeStart\",\"type\":\"time\",\"format\":\"yyyy-MM-dd\"},{\"name\":\"结束时间\",\"id\":\"timeEnd\",\"type\":\"time\",\"format\":\"yyyy-MM-dd\"}\n" +
"\t\"param\": [\n" +
"\t\t{\n" +
"\t\t\t\"name\": \"身份证号\",\n" +
"\t\t\t\"id\": \"sfzh\",\n" +
"\t\t\t\"type\": \"text\",\n" +
"\t\t\t\"flag\":[\"idcard\",\"aaaa\"]\n" +
"\t\t}\n" +
"\t]\n" +
"\t\n" +
"}";
System.out.println(s+":"+new JsonValidator().validate(s));
}
......
service/publicapi/src/main/java/com/founder/publicapi/controller/KshService/KshSlServiceController.java
......@@ -26,6 +26,10 @@ import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.lang.reflect.Field;
import java.util.*;
import java.util.stream.Collectors;
import static java.util.stream.Collectors.collectingAndThen;
import static java.util.stream.Collectors.toCollection;
/**
* 可视化算例6个接口
......@@ -676,7 +680,7 @@ public class KshSlServiceController {
return map;
}
public HnTbStRygxDTO node(String id ,String lable ,String imgType, String boderColor){
public HnTbStRygxDTO node(String id ,String lable ,String imgType,String imagePhoto, String boderColor){
HnTbStRygxDTO mergeDTOgjd = new HnTbStRygxDTO();
mergeDTOgjd.setId(id);
mergeDTOgjd.setLabel(lable);
......@@ -684,6 +688,7 @@ public class KshSlServiceController {
kshpropertice.setId(id);
kshpropertice.setLabel(lable);
kshpropertice.setImgType(imgType);
kshpropertice.setImagePhoto(imagePhoto);
kshpropertice.setBoderColor(boderColor);
mergeDTOgjd.setProperties(kshpropertice);
return mergeDTOgjd;
......@@ -773,17 +778,19 @@ public class KshSlServiceController {
@OperLog(message = "家谱关系", operation = OperationType.QUERY)
@PostMapping("/jpgx")
@ApiOperation(value = "家谱关系")
public MapRestResult jpgx(@RequestBody JpgxEntity jpgxEntity, HttpServletRequest request) {
public MapRestResult jpgx(String sfzh, HttpServletRequest request) {
JpgxEntity jpgxEntity = new JpgxEntity();
jpgxEntity.setSfzh(sfzh);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(jpgxEntity.getQqip())&&StringUtils.isNotEmpty(jpgxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(jpgxEntity.getQqyhm())){
jpgxEntity.setQqip(ipAddr);
jpgxEntity.setQqrsfzh(identitycard);
jpgxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(jpgxEntity);
System.out.println("入参实体转化为map===="+map);
......@@ -813,7 +820,7 @@ public class KshSlServiceController {
for (int i = 0; i < data.size(); i++) {
JSONObject arr = data.getJSONObject(i);
String zjhm = arr.getString("GXDXZJHM"); //关系对象zjhm
HnTbStRygxDTO node = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO node = node(zjhm, zjhm, "idcard", getPhoto(zjhm,request),null);
nodes.add(node);
sumup.add(zjhm);
// links
......@@ -843,17 +850,23 @@ public class KshSlServiceController {
@OperLog(message = "同住关系", operation = OperationType.QUERY)
@PostMapping("/tzgx")
@ApiOperation(value = "同住关系")
public MapRestResult tzgx(@RequestBody TzgxEntity tzgxEntity,HttpServletRequest request) {
public MapRestResult tzgx(String objNum ,String resourceType,String timeDiff,String startTime,String endTime, String frequency,HttpServletRequest request) {
TzgxEntity tzgxEntity = new TzgxEntity();
tzgxEntity.setObjNum(objNum);
tzgxEntity.setResourceType(resourceType);
tzgxEntity.setTimeDiff(timeDiff);
tzgxEntity.setStartTime(startTime);
tzgxEntity.setEndTime(endTime);
tzgxEntity.setFrequency(frequency);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(tzgxEntity.getQqip())&&StringUtils.isNotEmpty(tzgxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(tzgxEntity.getQqyhm())){
tzgxEntity.setQqip(ipAddr);
tzgxEntity.setQqrsfzh(identitycard);
tzgxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(tzgxEntity);
String s = HttpUtil.doPost(TZGX, map, getToken(request));
......@@ -878,12 +891,12 @@ public class KshSlServiceController {
String xm = arr.getString("tzr_xm"); //关系对象的xm
String count = arr.getString("count"); //次数
//nodes
HnTbStRygxDTO mergeDTOgjd = node(zjhm, xm + zjhm, "idcard", null);
HnTbStRygxDTO mergeDTOgjd = node(zjhm, xm + zjhm,"idcard",getPhoto(zjhm,request), null);
nodes.add(mergeDTOgjd);
sumup.add(zjhm);
// links
//获取jdInfo 酒店信息
JSONArray jdInfo = object.getJSONArray("jdInfo");
JSONArray jdInfo = arr.getJSONArray("jdInfo");
// String[] strarray1 = String.valueOf(jdInfo.getJSONObject(0)).split(","); //遇到逗号就分割
String zzsj = arr.getString("zzsj");//最早关系构造时间
String zjsj = arr.getString("zjsj"); //最近关系构建时间
......@@ -917,17 +930,17 @@ public class KshSlServiceController {
@OperLog(message = "同案关系", operation = OperationType.QUERY)
@PostMapping("/tagx")
@ApiOperation(value = "同案关系")
public MapRestResult tagx(@RequestBody TagxEntity tagxEntity,HttpServletRequest request) {
public MapRestResult tagx(String idCard,HttpServletRequest request) {
TagxEntity tagxEntity = new TagxEntity();
tagxEntity.setIdCard(idCard);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(tagxEntity.getQqip())&&StringUtils.isNotEmpty(tagxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(tagxEntity.getQqyhm())){
tagxEntity.setQqip(ipAddr);
tagxEntity.setQqrsfzh(identitycard);
tagxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(tagxEntity);
String s = HttpUtil.doPost(TAGX, map, getToken(request));
......@@ -948,12 +961,11 @@ public class KshSlServiceController {
for (int i1 = 0; i1 < resultList.size(); i1++) {
JSONObject jsonObject = resultList.getJSONObject(i1);
String zjhm = jsonObject.getString("ZJHM");//同案人的身份证
String ajbh = jsonObject.getString("AJBH");//案件编号
String xxdjsj = jsonObject.getString("XXDJSJ");//信息登记时间
HnTbStRygxDTO idcard = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO idcard = node(zjhm, zjhm, "idcard", getPhoto(zjhm,request),null);
nodes.add(idcard);
sumup.add(zjhm);
kshlinks link = link(tagxEntity.getIdCard(), zjhm, ajbh, xxdjsj, tagxEntity.getIdCard(), "idcard", zjhm, "idcard", "科兴", "同案关系", xxdjsj);
kshlinks link = link(tagxEntity.getIdCard(), zjhm, "信息登记时间:"+xxdjsj, xxdjsj, tagxEntity.getIdCard(), "idcard", zjhm, "idcard", "科兴", "同案关系", xxdjsj);
re.add(link);
}
}
......@@ -978,17 +990,18 @@ public class KshSlServiceController {
@OperLog(message = "社会关系", operation = OperationType.QUERY)
@PostMapping("/shgx")
@ApiOperation(value = "社会关系")
public MapRestResult shgx(@RequestBody ShgxEntity shgxEntity,HttpServletRequest request) {
public MapRestResult shgx(String zjhm,String type,String pageNum,String pageSize,HttpServletRequest request) {
ShgxEntity shgxEntity = new ShgxEntity();
shgxEntity.setZjhm(zjhm);shgxEntity.setType(type);shgxEntity.setPageNum(pageNum);shgxEntity.setPageSize(pageSize);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(shgxEntity.getQqip())&&StringUtils.isNotEmpty(shgxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(shgxEntity.getQqyhm())){
shgxEntity.setQqip(ipAddr);
shgxEntity.setQqrsfzh(identitycard);
shgxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(shgxEntity);
String s = HttpUtil.doPost(SHGX, map, getToken(request));
......@@ -1011,13 +1024,13 @@ public class KshSlServiceController {
//遍历每一条关系
for (int i = 0; i < data.size(); i++) {
JSONObject arr = data.getJSONObject(i);
String zjhm = arr.getString("ZJHM"); //关系对象zjhm
String zjhm1 = arr.getString("ZJHM"); //关系对象zjhm
String rzsj = arr.getString("RZSJ"); //同事的入职时间
HnTbStRygxDTO idcard = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO idcard = node(zjhm1, zjhm1, "idcard", getPhoto(zjhm1,request),null);
nodes.add(idcard);
sumup.add(zjhm);
sumup.add(zjhm1);
// links
kshlinks link = link(shgxEntity.getZjhm(), zjhm, "同事", rzsj, shgxEntity.getZjhm(), "idcard", zjhm, "idcard", "科兴", "同事", rzsj);
kshlinks link = link(zjhm, zjhm1, "同事", rzsj, zjhm, "idcard", zjhm1, "idcard", "科兴", "同事", rzsj);
re.add(link);
}
kshdata.setNodes(nodes);
......@@ -1031,14 +1044,14 @@ public class KshSlServiceController {
//遍历每一条关系
for (int i = 0; i < data.size(); i++) {
JSONObject arr = data.getJSONObject(i);
String zjhm = arr.getString("ZJHM"); //关系对象zjhm
String zjhm1 = arr.getString("ZJHM"); //关系对象zjhm
String bysj = arr.getString("BYSJ"); //毕业时间
//nodes
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO mergeDTOgjd = node(zjhm1, zjhm1, "idcard", getPhoto(zjhm1,request),null);
nodes.add(mergeDTOgjd);
sumup.add(zjhm);
sumup.add(zjhm1);
// links
kshlinks link = link(shgxEntity.getZjhm(), zjhm, "校友", bysj, shgxEntity.getZjhm(), "idcard", zjhm, "idcard", "科兴", "校友", bysj);
kshlinks link = link(zjhm, zjhm1, "校友", bysj, zjhm, "idcard", zjhm1, "idcard", "科兴", "校友", bysj);
re.add(link);
}
kshdata.setNodes(nodes);
......@@ -1065,17 +1078,18 @@ public class KshSlServiceController {
@OperLog(message = "通联关系", operation = OperationType.QUERY)
@PostMapping("/tlgx")
@ApiOperation(value = "通联关系")
public MapRestResult tlgx(@RequestBody TlgxEntity tlgxEntity,HttpServletRequest request) {
public MapRestResult tlgx( String sjh, String timeStart,String timeEnd, String pageNumber, String pageSize,HttpServletRequest request) {
TlgxEntity tlgxEntity = new TlgxEntity();
tlgxEntity.setSjh(sjh);tlgxEntity.setTimeStart(timeStart);tlgxEntity.setTimeEnd(timeEnd);
tlgxEntity.setPageNumber(pageNumber);tlgxEntity.setPageSize(pageSize);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(tlgxEntity.getQqip())&&StringUtils.isNotEmpty(tlgxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(tlgxEntity.getQqyhm())){
tlgxEntity.setQqip(ipAddr);
tlgxEntity.setQqrsfzh(identitycard);
tlgxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(tlgxEntity);
String s = HttpUtil.doPost(TLGX, map, getToken(request));
......@@ -1102,7 +1116,7 @@ public class KshSlServiceController {
String thsk = arr.getString("thsk"); //通话时刻
String bist = arr.getString("bist"); //关系人对端号码
//nodes
HnTbStRygxDTO mergeDTOgjd = node(bist, xm + bist, "sjk", null);
HnTbStRygxDTO mergeDTOgjd = node(bist, xm + bist, "sjk", null,null);
nodes.add(mergeDTOgjd);
sumup.add(bist);
// links
......@@ -1128,21 +1142,22 @@ public class KshSlServiceController {
}
//（01:身份证号;02:驾照;03:护照;04:手机号;05:虚拟账号信息）
//身份证、驾驶证、护照、手机号（imei、imsi）、虚拟账号（虚拟账号）号码之间互查
@OperLog(message = "虚实关联", operation = OperationType.QUERY)
@PostMapping("/xsgx")
@ApiOperation(value = "虚实关联")
public MapRestResult xsgx(@RequestBody XsgxEntity xsgxEntity,HttpServletRequest request) {
public MapRestResult xsgx(String value,String type,HttpServletRequest request) {
XsgxEntity xsgxEntity = new XsgxEntity();
xsgxEntity.setValue(value); xsgxEntity.setType(type);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(xsgxEntity.getQqip())&&StringUtils.isNotEmpty(xsgxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(xsgxEntity.getQqyhm())){
xsgxEntity.setQqip(ipAddr);
xsgxEntity.setQqrsfzh(identitycard);
xsgxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(xsgxEntity);
String s = HttpUtil.doPost(XSGX, map, getToken(request));
......@@ -1172,10 +1187,11 @@ public class KshSlServiceController {
String sfzh1 = jsonObject.getString("sfzh");//身份证
String xm = jsonObject.getString("xm");//身份证
HnTbStRygxDTO node = node(sfzh1, xm + sfzh1, "idcard", null);
HnTbStRygxDTO node = node(sfzh1, sfzh1, "idcard", getPhoto(sfzh1,request),null);
nodes.add(node);
sumup.add(sfzh1);
link(xsgxEntity.getValue(),sfzh1,"身份证",null,xsgxEntity.getValue(),"idcard",sfzh1,"idcard","科兴","身份证",null);
kshlinks link = link(xsgxEntity.getValue(), sfzh1, "身份证", null, xsgxEntity.getValue(), "idcard", sfzh1, "idcard", "科兴", "身份证", null);
re.add(link);
}
}
......@@ -1183,14 +1199,14 @@ public class KshSlServiceController {
JSONArray jzhm = arr.getJSONArray("jzhm");//data中 的驾照 为数组02
for (int i1 = 0; i1 < jzhm.size(); i1++) {
JSONObject jsonObject = jzhm.getJSONObject(i1);
String zjhm = jsonObject.getString("ZJHM");//驾照证件号码
String zjhm = jsonObject.getString("BZHMZ");//办证号码值
String qfrq = jsonObject.getString("QFRQ");//驾照_签发日期
// nodes
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "jz", null,null);
nodes.add(mergeDTOgjd);
sumup.add(zjhm);
// links
kshlinks link = link(xsgxEntity.getValue(), zjhm, "驾照", qfrq, xsgxEntity.getValue(), "idcard", zjhm, "idcard", "科兴", "驾照", qfrq);
kshlinks link = link(xsgxEntity.getValue(), zjhm, "驾照", qfrq, xsgxEntity.getValue(), "idcard", zjhm, "jz", "科兴", "驾照", qfrq);
re.add(link);
}
}
......@@ -1198,14 +1214,14 @@ public class KshSlServiceController {
JSONArray hzhm = arr.getJSONArray("hzhm");//data中 的护照 为数组03
for (int i1 = 0; i1 < hzhm.size(); i1++) {
JSONObject jsonObject = hzhm.getJSONObject(i1);
String zjhm = jsonObject.getString("ZJHM");//护照证件号码
String zjhm = jsonObject.getString("BZHMZ");//办证号码值
String qfrq = jsonObject.getString("QFRQ");//护照_签发日期
// nodes
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "hz", null,null);
nodes.add(mergeDTOgjd);
sumup.add(zjhm);
// links
kshlinks link = link(xsgxEntity.getValue(), zjhm, "护照", qfrq, xsgxEntity.getValue(), "idcard", zjhm, "idcard", "科兴", "护照", qfrq);
kshlinks link = link(xsgxEntity.getValue(), zjhm, "护照", qfrq, xsgxEntity.getValue(), "idcard", zjhm, "hz", "科兴", "护照", qfrq);
re.add(link);
}
}
......@@ -1216,7 +1232,7 @@ public class KshSlServiceController {
String zjhm = jsonObject.getString("SJH");//手机号码
String qfrq = jsonObject.getString("XXRKSJ");//信息入库时间
// nodes
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "sjk", null);
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "sjk", null,null);
nodes.add(mergeDTOgjd);
sumup.add(zjhm);
// links
......@@ -1225,7 +1241,7 @@ public class KshSlServiceController {
}
}
if (xsgxEntity.getType().equals("01")||xsgxEntity.getType().equals("02")||xsgxEntity.getType().equals("03")||xsgxEntity.getType().equals("05")) {
if (xsgxEntity.getType().equals("01")||xsgxEntity.getType().equals("02")||xsgxEntity.getType().equals("03")||xsgxEntity.getType().equals("04")) {
JSONObject xnxx = arr.getJSONObject("xnxx");//data中 的虚拟账号信息 为对象05
JSONArray acid = xnxx.getJSONArray("acid");//xnxx中acid为数组
for (int i1 = 0; i1 < acid.size(); i1++) {
......@@ -1233,11 +1249,11 @@ public class KshSlServiceController {
String zjhm = jsonObject.getString("acid");//帐号ID
String acty = jsonObject.getString("acty");//账号类型
// nodes
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "idcard", null);
HnTbStRygxDTO mergeDTOgjd = node(zjhm, zjhm, "other", null,null);
nodes.add(mergeDTOgjd);
sumup.add(zjhm);
// links
kshlinks link = link(xsgxEntity.getValue(), zjhm, acty, null, xsgxEntity.getValue(), "idcard", zjhm, "idcard", "科兴", acty, null);
kshlinks link = link(xsgxEntity.getValue(), zjhm, acty, null, xsgxEntity.getValue(), "idcard", zjhm, "other", "科兴", acty, null);
re.add(link);
}
}
......@@ -1264,17 +1280,19 @@ public class KshSlServiceController {
@OperLog(message = "四码关联", operation = OperationType.QUERY)
@PostMapping("/smglTwo")
@ApiOperation(value = "四码关联")
public MapRestResult smglTwo(@RequestBody SmglTwoEntity smglTwoEntity,HttpServletRequest request ) {
public MapRestResult smglTwo(String value, String type,HttpServletRequest request ) {
SmglTwoEntity smglTwoEntity = new SmglTwoEntity();
smglTwoEntity.setValue(value);smglTwoEntity.setType(type);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(smglTwoEntity.getQqip())&&StringUtils.isNotEmpty(smglTwoEntity.getQqrsfzh())&& StringUtils.isNotEmpty(smglTwoEntity.getQqyhm())){
smglTwoEntity.setQqip(ipAddr);
smglTwoEntity.setQqrsfzh(identitycard);
smglTwoEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(smglTwoEntity);
String s = HttpUtil.doPost(SMGL, map, getToken(request));
......@@ -1301,19 +1319,12 @@ public class KshSlServiceController {
String imei = arr.getString("imei"); //imei
String imsi = arr.getString("imsi"); //imsi
String latm = arr.getString("latm"); //最近采集时间
HnTbStRygxDTO imei1 = node("imei:"+imei+"\n"+"imsi:"+imsi, "imei:"+imei+"\n"+"imsi:"+imsi, "sjk", null);
HnTbStRygxDTO imei1 = node("imei:"+imei+"\n"+"imsi:"+imsi, "imei:"+imei+"\n"+"imsi:"+imsi, "sjk", null,null);
nodes.add(imei1);
sumup.add("imei:"+imei+"\n"+"imsi:"+imsi);
kshlinks link = link(smglTwoEntity.getValue(), "imei:"+imei+"\n"+"imsi:"+imsi, "一号多机",latm, smglTwoEntity.getValue(), "sjk", "imei:"+imei+"\n"+"imsi:"+imsi, "idcard", "科兴", "四码关联", latm);
re.add(link);
}
kshdata.setNodes(nodes);
kshdata.setLinks(re);
dataSumup.setList(sumup);
dataSumup.setName("四码关联");
result.setKshdata(kshdata);
result.setDataSumup(dataSumup);
return new MapRestResult(200, "ok", result);
}else if (smglTwoEntity.getType().equals("02")){
//遍历每一条关系
for (int i = 0; i < data.size(); i++) {
......@@ -1321,19 +1332,12 @@ public class KshSlServiceController {
String imei = arr.getString("imei"); //imei
String msis = arr.getString("msis"); //msis
String latm = arr.getString("latm"); //最近采集时间
HnTbStRygxDTO imei1 = node("imei:"+imei+"\n"+"msis:"+msis, "imei:"+imei+"\n"+"msis:"+msis, "sjk", null);
HnTbStRygxDTO imei1 = node("imei:"+imei+"\n"+"msis:"+msis, "imei:"+imei+"\n"+"msis:"+msis, "sjk", null,null);
nodes.add(imei1);
sumup.add("imei:"+imei+"\n"+"msis:"+msis);
kshlinks link = link(smglTwoEntity.getValue(), "imei:"+imei+"\n"+"msis:"+msis, "一机多号",latm, smglTwoEntity.getValue(), "imsi", "imei:"+imei+"\n"+"msis:"+msis, "sjk", "科兴", "四码关联", latm);
re.add(link);
}
kshdata.setNodes(nodes);
kshdata.setLinks(re);
dataSumup.setList(sumup);
dataSumup.setName("四码关联");
result.setKshdata(kshdata);
result.setDataSumup(dataSumup);
return new MapRestResult(200, "ok", result);
}else if (smglTwoEntity.getType().equals("03")){
//遍历每一条关系
for (int i = 0; i <data.size(); i++) {
......@@ -1341,25 +1345,33 @@ public class KshSlServiceController {
String imsi = arr.getString("imsi"); //imsi
String msis = arr.getString("msis"); //msis
String latm = arr.getString("latm"); //最近采集时间
HnTbStRygxDTO imsi1 = node("imsi:"+imsi+"\n"+"msis:"+msis, "imsi:"+imsi+"\n"+"msis:"+msis, "sjk", null);
HnTbStRygxDTO imsi1 = node("imsi:"+imsi+"\n"+"msis:"+msis, "imsi:"+imsi+"\n"+"msis:"+msis, "sjk", null,null);
nodes.add(imsi1);
sumup.add("imsi:"+imsi+"\n"+"msis:"+msis);
kshlinks link = link(smglTwoEntity.getValue(), "imsi:"+imsi+"\n"+"msis:"+msis, "一机多号", latm,smglTwoEntity.getValue(), "imei", "imsi:"+imsi+"\n"+"msis:"+msis, "sjk", "科兴", "四码关联", latm);
re.add(link);
}
kshdata.setNodes(nodes);
kshdata.setLinks(re);
dataSumup.setList(sumup);
dataSumup.setName("四码关联");
result.setKshdata(kshdata);
result.setDataSumup(dataSumup);
return new MapRestResult(200, "ok", result);
}
else {
return new MapRestResult("（01 手机号；02 imsi；03 imei）没有此类型");
}
//对nodes去重
ArrayList<HnTbStRygxDTO> collect1 = nodes.stream().
collect(collectingAndThen(toCollection(() -> new TreeSet<>(Comparator.comparing(HnTbStRygxDTO::getId))), ArrayList::new));
kshdata.setNodes(collect1);
//对links去重
ArrayList<kshlinks> collect2 = re.stream()
.collect(collectingAndThen(toCollection(() -> new TreeSet<>(Comparator.comparing(o -> o.getSource() + ";" + o.getTarget()))), ArrayList::new));
kshdata.setLinks(collect2);
//对sumup去重
List<String> collect = sumup.stream().distinct().collect(Collectors.toList());
dataSumup.setList(collect);
dataSumup.setName("四码关联");
result.setKshdata(kshdata);
result.setDataSumup(dataSumup);
return new MapRestResult(200, "ok", result);
} else {
Hnkshresult result1 = result("四码关联");
return new MapRestResult(200, "ok", result1);
......@@ -1375,17 +1387,19 @@ public class KshSlServiceController {
@OperLog(message = "通联分析", operation = OperationType.QUERY)
@PostMapping("/tlfx")
@ApiOperation(value = "通联分析")
public MapRestResult tlfx(@RequestBody TlfxEntity tlfxEntity,HttpServletRequest request) {
public MapRestResult tlfx(String timeType, String phoneNumber, String timeStart,String timeEnd, String pageNumber,String pageSize,HttpServletRequest request) {
TlfxEntity tlfxEntity = new TlfxEntity();
tlfxEntity.setTimeType(timeType);tlfxEntity.setPhoneNumber(phoneNumber);tlfxEntity.setTimeStart(timeStart);tlfxEntity.setTimeEnd(timeEnd);
tlfxEntity.setPageNumber(pageNumber);tlfxEntity.setPageSize(pageSize);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(tlfxEntity.getQqip())&&StringUtils.isNotEmpty(tlfxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(tlfxEntity.getQqyhm())){
tlfxEntity.setQqip(ipAddr);
tlfxEntity.setQqrsfzh(identitycard);
tlfxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(tlfxEntity);
String s = HttpUtil.doPost(TLFX, map, getToken(request));
......@@ -1414,7 +1428,7 @@ public class KshSlServiceController {
JSONObject jsonObject = countCall.getJSONObject(i1);
String anotherPhone = jsonObject.getString("anotherPhone");//手机号码
String countNum = jsonObject.getString("countNum");//通话频次统计
HnTbStRygxDTO node = node(anotherPhone, anotherPhone, "sjk", null);
HnTbStRygxDTO node = node(anotherPhone, anotherPhone, "sjk", null,null);
nodes.add(node);
sumup.add(anotherPhone);
kshlinks link = link(tlfxEntity.getPhoneNumber(), anotherPhone, "通话频次"+countNum, null, tlfxEntity.getPhoneNumber(), "sjk", anotherPhone, "sjk", "科兴", "通联分析", null);
......@@ -1429,7 +1443,7 @@ public class KshSlServiceController {
result.setDataSumup(dataSumup);
return new MapRestResult(200, "ok", result);
} else {
Hnkshresult result1 = result("通联分析");
Hnkshresult result1 = result("通联分析2");
return new MapRestResult(200, "ok", result1);
}
......@@ -1443,17 +1457,17 @@ public class KshSlServiceController {
@OperLog(message = "寄递分析", operation = OperationType.QUERY)
@PostMapping("/jdfx")
@ApiOperation(value = "寄递分析")
public MapRestResult jdfx(@RequestBody JdfxEntity jdfxEntity,HttpServletRequest request) {
public MapRestResult jdfx(String sjh,String timeStart,String timeEnd,String pageNumber,String pageSize,HttpServletRequest request) {
JdfxEntity jdfxEntity = new JdfxEntity();
jdfxEntity.setSjh(sjh);jdfxEntity.setTimeStart(timeStart);jdfxEntity.setTimeEnd(timeEnd);jdfxEntity.setPageNumber(pageNumber);jdfxEntity.setPageSize(pageSize);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(jdfxEntity.getQqip())&&StringUtils.isNotEmpty(jdfxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(jdfxEntity.getQqyhm())){
jdfxEntity.setQqip(ipAddr);
jdfxEntity.setQqrsfzh(identitycard);
jdfxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(jdfxEntity);
String s = HttpUtil.doPost(JDFX, map, getToken(request));
......@@ -1482,16 +1496,24 @@ public class KshSlServiceController {
String fitm = jsonObject.getString("read");//首次发现时间
String dvnm = jsonObject.getString("dvnm");//快递单号
String reph = jsonObject.getString("reph");//收件者手机号
HnTbStRygxDTO node = node(dvnm, "收件者名称"+rece+"收件者手机号"+reph+"收件者地址"+read, "other", null);
HnTbStRygxDTO node = node(reph, reph, "sjk", null,null);
nodes.add(node);
sumup.add(dvnm);
kshlinks link = link(jdfxEntity.getSjh(), dvnm, dvnm, fitm, jdfxEntity.getSjh(), "sjk", dvnm, "other", "科兴", "寄递分析", fitm);
sumup.add(reph);
kshlinks link = link(jdfxEntity.getSjh(), reph, dvnm, fitm, jdfxEntity.getSjh(), "sjk", reph, "sjk", "科兴", "寄递分析", fitm);
re.add(link);
}
}
kshdata.setNodes(nodes);
kshdata.setLinks(re);
dataSumup.setList(sumup);
//对nodes去重
ArrayList<HnTbStRygxDTO> collect1 = nodes.stream().
collect(collectingAndThen(toCollection(() -> new TreeSet<>(Comparator.comparing(HnTbStRygxDTO::getId))), ArrayList::new));
kshdata.setNodes(collect1);
//对links去重
ArrayList<kshlinks> collect2 = re.stream()
.collect(collectingAndThen(toCollection(() -> new TreeSet<>(Comparator.comparing(o -> o.getSource() + ";" + o.getTarget()))), ArrayList::new));
kshdata.setLinks(collect2);
//对sumup去重
List<String> collect = sumup.stream().distinct().collect(Collectors.toList());
dataSumup.setList(collect);
dataSumup.setName("寄递分析");
result.setKshdata(kshdata);
result.setDataSumup(dataSumup);
......@@ -1511,17 +1533,18 @@ public class KshSlServiceController {
@OperLog(message = "入住分析", operation = OperationType.QUERY)
@PostMapping("/rzfx")
@ApiOperation(value = "入住分析")
public MapRestResult rzfx(@RequestBody RzfxEntity rzfxEntity,HttpServletRequest request) {
public MapRestResult rzfx( String jdmc, String jdbm, String sfzh, String resourceType, String frequency, String point, String startTime, String endTime,HttpServletRequest request) {
RzfxEntity rzfxEntity = new RzfxEntity();
rzfxEntity.setJdmc(jdmc);rzfxEntity.setJdbm(jdbm);rzfxEntity.setSfzh(sfzh);rzfxEntity.setResourceType(resourceType);
rzfxEntity.setFrequency(frequency);rzfxEntity.setPoint(point);rzfxEntity.setStartTime(startTime);rzfxEntity.setEndTime(endTime);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(rzfxEntity.getQqip())&&StringUtils.isNotEmpty(rzfxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(rzfxEntity.getQqyhm())){
rzfxEntity.setQqip(ipAddr);
rzfxEntity.setQqrsfzh(identitycard);
rzfxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(rzfxEntity);
String s = HttpUtil.doPost(RZFX, map, getToken(request));
......@@ -1560,7 +1583,7 @@ public class KshSlServiceController {
String ldmc = jsonObject.getString("DWMC");//旅店名称
String ldbm = jsonObject.getString("DWBM");//旅店编码
String rzsj = jsonObject.getString("RZSJ");//入住时间
HnTbStRygxDTO node = node(ldbm, ldmc + ldbm, "other", null);
HnTbStRygxDTO node = node(ldbm, ldmc + ldbm, "other", null,null);
nodes.add(node);
sumup.add(ldbm);
kshlinks link = link(value, ldbm, xm+zjhm, rzsj, value, "other", ldbm, "other", "科兴", "入住分析", rzsj);
......@@ -1579,7 +1602,7 @@ public class KshSlServiceController {
String ldmc = jsonObject1.getString("DWMC");//旅店名称
String rzsj = jsonObject.getString("RZSJ");//入住时间
String zjhm = jsonObject.getString("ZJHM");//证件号码
HnTbStRygxDTO node = node(ldbm, ldmc + ldbm, "other",null);
HnTbStRygxDTO node = node(ldbm, ldmc + ldbm, "other",null,null);
nodes.add(node);
sumup.add(ldbm);
kshlinks link = link(value, ldbm, xm+zjhm, rzsj, value, "other", ldbm, "other", "科兴", "入住分析", rzsj);
......@@ -1595,7 +1618,7 @@ public class KshSlServiceController {
String ldmc = jsonObject.getString("DWMC");//旅店名称
String ldbm = jsonObject.getString("DWBM");//旅店编码
String rzsj = jsonObject.getString("RZSJ");//入住时间
HnTbStRygxDTO node = node(ldbm, ldmc + ldbm, "other", null);
HnTbStRygxDTO node = node(ldbm, ldmc + ldbm, "other", null,null);
nodes.add(node);
sumup.add(ldbm);
kshlinks link = link(value, ldbm, xm+zjhm, rzsj, value, "other", ldbm, "other", "科兴", "入住分析", rzsj);
......@@ -1627,17 +1650,18 @@ public class KshSlServiceController {
@OperLog(message = "出入境分析", operation = OperationType.QUERY)
@PostMapping("/crjfx")
@ApiOperation(value = "出入境分析")
public MapRestResult crjfx(@RequestBody CrjfxEntity crjfxEntity, HttpServletRequest request) {
public MapRestResult crjfx( String frequency, String sfzh, String timeStart, String timeEnd, HttpServletRequest request) {
CrjfxEntity crjfxEntity = new CrjfxEntity();
crjfxEntity.setFrequency(frequency);crjfxEntity.setSfzh(sfzh);crjfxEntity.setTimeStart(timeStart);crjfxEntity.setTimeEnd(timeEnd);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(crjfxEntity.getQqip())&&StringUtils.isNotEmpty(crjfxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(crjfxEntity.getQqyhm())){
crjfxEntity.setQqip(ipAddr);
crjfxEntity.setQqrsfzh(identitycard);
crjfxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(crjfxEntity);
System.out.println("入参实体转化为map===="+map);
......@@ -1667,7 +1691,7 @@ public class KshSlServiceController {
String xxdjsj = arr.getString("XXDJSJ"); //信息登记时间
String crjrylb = arr.getString("CRJRYLB"); //出入境人员类别
//nodes
HnTbStRygxDTO node = node(crjzjhm, crjzjhm, "idcard", null);
HnTbStRygxDTO node = node(crjzjhm, crjzjhm, "idcard", null,null);
nodes.add(node);
sumup.add(crjzjhm);
kshlinks link = link(crjfxEntity.getSfzh(), crjzjhm, crjrylb, cjsj, crjfxEntity.getSfzh(), "idcard", crjzjhm, "idcard", "科兴", "出入境分析", cjsj);
......@@ -1696,17 +1720,18 @@ public class KshSlServiceController {
@OperLog(message = "出行分析", operation = OperationType.QUERY)
@PostMapping("/cxfx")
@ApiOperation(value = "出行分析")
public MapRestResult cxfx(@RequestBody CxfxEntity cxfxEntity, HttpServletRequest request) {
public MapRestResult cxfx( String sfzh, String qsd, String shift, String trafficType, String mdd, HttpServletRequest request) {
CxfxEntity cxfxEntity = new CxfxEntity();
cxfxEntity.setSfzh(sfzh);cxfxEntity.setQsd(qsd);cxfxEntity.setShift(shift);cxfxEntity.setTrafficType(trafficType);cxfxEntity.setMdd(mdd);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(cxfxEntity.getQqip())&&StringUtils.isNotEmpty(cxfxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(cxfxEntity.getQqyhm())){
cxfxEntity.setQqip(ipAddr);
cxfxEntity.setQqrsfzh(identitycard);
cxfxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(cxfxEntity);
System.out.println("入参实体转化为map===="+map);
......@@ -1735,13 +1760,12 @@ public class KshSlServiceController {
//遍历每一条关系
for (int i = 0; i < data.size(); i++) {
JSONObject arr = data.getJSONObject(i);
String qsd = arr.getString("QSD"); //起始地
String qssj = arr.getString("QSSJ"); //起始时间
String ddsj = arr.getString("DDSJ"); //到达时间
String xm = arr.getString("XM"); //姓名
String bc = arr.getString("KYBC"); //班次
String ph = arr.getString("PH"); //票号
HnTbStRygxDTO node = node(ph, "票号"+ph, "other", null);
HnTbStRygxDTO node = node(ph, "票号"+ph, "other", null,null);
nodes.add(node);
sumup.add(ph);
kshlinks link = link(cxfxEntity.getSfzh(), ph, bc, ddsj, cxfxEntity.getSfzh(), "idcard", ph, "other", "科兴", "出行分析", ddsj);
......@@ -1770,17 +1794,18 @@ public class KshSlServiceController {
@OperLog(message = "同行分析", operation = OperationType.QUERY)
@PostMapping("/txfx")
@ApiOperation(value = "同行分析")
public MapRestResult txfx(@RequestBody TxfxEntity txfxEntity, HttpServletRequest request) {
public MapRestResult txfx(String value, String type, HttpServletRequest request) {
TxfxEntity txfxEntity = new TxfxEntity();
txfxEntity.setValue(value);txfxEntity.setType(type);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(txfxEntity.getQqip())&&StringUtils.isNotEmpty(txfxEntity.getQqrsfzh())&& StringUtils.isNotEmpty(txfxEntity.getQqyhm())){
txfxEntity.setQqip(ipAddr);
txfxEntity.setQqrsfzh(identitycard);
txfxEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(txfxEntity);
System.out.println("入参实体转化为map===="+map);
......@@ -1814,7 +1839,7 @@ public class KshSlServiceController {
String count = arr.getString("count"); //次数
String zjsj = arr.getString("zjsj"); //最近关系构建时间
JSONArray detail = arr.getJSONArray("detail");//时空聚合内容
HnTbStRygxDTO node = node(sfzh, xm+sfzh, "idcard", null);
HnTbStRygxDTO node = node(sfzh, xm+sfzh, "idcard", getPhoto(sfzh,request),null);
nodes.add(node);
sumup.add(sfzh);
kshlinks link = link(txfxEntity.getValue(), sfzh,count+"次",zjsj,txfxEntity.getValue(),"idcard",sfzh,"idcard","科兴","同行分析",zjsj);
......@@ -1839,20 +1864,21 @@ public class KshSlServiceController {
}
//通过案件编号或身份证号查询案件信息； 通过驾驶证号或车牌号查询相应的违章信息；
@OperLog(message = "案件档案", operation = OperationType.QUERY)
@OperLog(message = "涉案信息", operation = OperationType.QUERY)
@PostMapping("/ajda")
@ApiOperation(value = "案件档案")
public MapRestResult ajda(@RequestBody AjdaEntity ajdaEntity, HttpServletRequest request) {
@ApiOperation(value = "涉案信息")
public MapRestResult ajda(String value, String type, HttpServletRequest request) {
AjdaEntity ajdaEntity = new AjdaEntity();
ajdaEntity.setValue(value);ajdaEntity.setType(type);
Hnkshresult result = new Hnkshresult();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(ajdaEntity.getQqip())&&StringUtils.isNotEmpty(ajdaEntity.getQqrsfzh())&& StringUtils.isNotEmpty(ajdaEntity.getQqyhm())){
ajdaEntity.setQqip(ipAddr);
ajdaEntity.setQqrsfzh(identitycard);
ajdaEntity.setQqyhm(trueName);
}
try {
Map<String, String> map = objectToMap(ajdaEntity);
String s = HttpUtil.doPost(AJDA, map, getToken(request));
......@@ -1878,7 +1904,7 @@ public class KshSlServiceController {
if (ajdaEntity.getType().equals("01")){
String ajbh = arr.getString("AJBH");//案件编号
String xxdjsj = arr.getString("XXDJSJ");//信息登记时间
HnTbStRygxDTO node = node(ajbh, ajbh, "aj", null);
HnTbStRygxDTO node = node(ajbh, ajbh, "aj", null,null);
nodes.add(node);
sumup.add(ajbh);
kshlinks link = link(ajdaEntity.getValue(), ajbh, "案件编号", xxdjsj, ajdaEntity.getValue(), "idcard", ajbh, "aj", "科兴", "案件档案", xxdjsj);
......@@ -1887,7 +1913,7 @@ public class KshSlServiceController {
String buco = arr.getString("buco");//违法编号
String rlad = arr.getString("rlad");//联系方式
HnTbStRygxDTO node = node(buco, buco, "aj", null);
HnTbStRygxDTO node = node(buco, buco, "aj", null,null);
nodes.add(node);
sumup.add(buco);
kshlinks link = link(ajdaEntity.getValue(), buco, "违法编号", null, ajdaEntity.getValue(), "cph", buco, "aj", "科兴", "案件档案", null);
......@@ -1898,10 +1924,10 @@ public class KshSlServiceController {
String basj = arr.getString("basj"); //报案时间
String ajmc = arr.getString("ajmc"); //案件名称
HnTbStRygxDTO node = node(sfzh, xm+sfzh, "idcard", null);
HnTbStRygxDTO node = node(sfzh, xm+sfzh, "idcard", getPhoto(sfzh,request),null);
nodes.add(node);
sumup.add(sfzh);
kshlinks link = link(ajdaEntity.getValue(), sfzh,ajmc,basj,ajdaEntity.getValue(),"aj",sfzh,"idcard","科兴","案件档案",basj);
kshlinks link = link(ajdaEntity.getValue(), sfzh,"报案人",basj,ajdaEntity.getValue(),"aj",sfzh,"idcard","科兴","案件档案",basj);
re.add(link);
}
......@@ -1925,82 +1951,61 @@ public class KshSlServiceController {
}
//通过案件编号或身份证号查询案件信息； 通过驾驶证号或车牌号查询相应的违章信息；
@OperLog(message = "物品档案", operation = OperationType.QUERY)
@PostMapping("/wpda")
@ApiOperation(value = "物品档案")
public MapRestResult wpda(@RequestBody WpdaEntity wpdaEntity, HttpServletRequest request) {
Hnkshresult result = new Hnkshresult();
public String RYDA = "http://26.13.101.72:8999/center_new/001/001";
//获取照片
public String getPhoto(String zjhm ,HttpServletRequest request){
Map<String, String> map = new HashMap<>();
SysUser sysUser = (SysUser)request.getAttribute("user");
String trueName = sysUser.getTrueName();// 请求人姓名
String identitycard = sysUser.getIdentitycard();// 请求人证件
String ipAddr = NetworkUtil.getIpAddr(request);// 请求人ip
if (StringUtils.isNotEmpty(wpdaEntity.getQqip())&&StringUtils.isNotEmpty(wpdaEntity.getQqrsfzh())&& StringUtils.isNotEmpty(wpdaEntity.getQqyhm())){
wpdaEntity.setQqip(ipAddr);
wpdaEntity.setQqrsfzh(identitycard);
wpdaEntity.setQqyhm(trueName);
}
map.put("zjhm",zjhm);//证件号码（身份证号或护照号）
map.put("qqyhm",sysUser.getTrueName());
map.put("qqrsfzh",sysUser.getIdentitycard());
map.put("qqip",NetworkUtil.getIpAddr(request));
try {
Map<String, String> map = objectToMap(wpdaEntity);
String s = HttpUtil.doPost(WPDA, map, getToken(request));
//先把String对象转换成json对象
String s = HttpUtil.doPost(RYDA, map, getToken(request));
JSONObject object = JSONObject.parseObject(s);
if (!object.getString("code").equals("1")){
return new MapRestResult("接口调用失败，返回的错误信息为："+object.getString("msg"));
return"获取照片，返回的错误信息为："+object.getString("msg");
}
if (object.getJSONArray("data").size()>0) {
kshdata kshdata = new kshdata();
dataSumup dataSumup = new dataSumup();
List<String> sumup = new ArrayList<>();
List<HnTbStRygxDTO> nodes = new ArrayList<>();
List<kshlinks> re = new ArrayList<>();
//获取data数组
JSONArray data = object.getJSONArray("data");
//遍历每一条关系
for (int i = 0; i < data.size(); i++) {
JSONObject arr = data.getJSONObject(i);
// 号码类型 （"01" 手机号，"02" imsi，"03" 身份证号）
if (wpdaEntity.getType().equals("01")){
String zjhm = arr.getString("ZJHM");//
HnTbStRygxDTO node = node(zjhm, zjhm, "idcard", null);
nodes.add(node);
sumup.add(zjhm);
kshlinks link = link(wpdaEntity.getNumber(), zjhm, "身份证", null, wpdaEntity.getNumber(), "sjk", zjhm, "idcard", "科兴", "物品档案", null);
re.add(link);
}else if (wpdaEntity.getType().equals("02")){
String sjh = arr.getString("SJH");//手机号
HnTbStRygxDTO node = node(sjh, sjh, "sjk", null);
nodes.add(node);
sumup.add(sjh);
kshlinks link = link(wpdaEntity.getNumber(), sjh, "手机号", null, wpdaEntity.getNumber(), "imsi", sjh, "sjk", "科兴", "物品档案", null);
re.add(link);
}else if (wpdaEntity.getType().equals("03")){
String sjh = arr.getString("SJH");//手机号
HnTbStRygxDTO node = node(sjh, sjh, "sjk", null);
nodes.add(node);
sumup.add(sjh);
kshlinks link = link(wpdaEntity.getNumber(), sjh, "手机号", null, wpdaEntity.getNumber(), "idcard", sjh, "sjk", "科兴", "物品档案", null);
re.add(link);
}
JSONObject arr = data.getJSONObject(0);
JSONArray photoImgs = arr.getJSONArray("photoImgs");
String o = photoImgs.get(0).toString();
return o;
} catch (Exception e) {
e.printStackTrace();
return e.toString();
}
kshdata.setNodes(nodes);
kshdata.setLinks(re);
dataSumup.setList(sumup);
dataSumup.setName("物品档案");
result.setKshdata(kshdata);
result.setDataSumup(dataSumup);
return new MapRestResult(200, "ok", result);
} else {
Hnkshresult result1 = result("物品档案");
return new MapRestResult(200, "ok", result1);
}
@OperLog(message = "获取照片", operation = OperationType.QUERY)
@PostMapping("/getphotoImgs")
@ApiOperation(value = "获取照片")
public MapRestResult getphotoImgs(String zjhm ,HttpServletRequest request){
Map<String, String> map = new HashMap<>();
SysUser sysUser = (SysUser)request.getAttribute("user");
map.put("zjhm",zjhm);//证件号码（身份证号或护照号）
map.put("qqyhm",sysUser.getTrueName());
map.put("qqrsfzh",sysUser.getIdentitycard());
map.put("qqip",NetworkUtil.getIpAddr(request));
try {
String s = HttpUtil.doPost(RYDA, map, getToken(request));
JSONObject object = JSONObject.parseObject(s);
if (!object.getString("code").equals("1")){
return new MapRestResult("获取照片，返回的错误信息为："+object.getString("msg"));
}
//获取data数组
JSONArray data = object.getJSONArray("data");
JSONObject arr = data.getJSONObject(0);
JSONArray photoImgs = arr.getJSONArray("photoImgs");
String o = "data:image/png;base64,"+photoImgs.get(0).toString();
return new MapRestResult(200,"ok",o);
} catch (Exception e) {
e.printStackTrace();
return new MapRestResult(e);
}
}
}
service/publicapi/src/main/java/com/founder/publicapi/controller/publicService/KshServiceController.java
......@@ -168,7 +168,66 @@ public class KshServiceController extends ApiController {
queryWrapper.eq("isDeleted", "0");
queryWrapper.orderByDesc("cjsj");
IPage page1 = kshService.page(page, queryWrapper);
IPage<KshServicePojo> page1 = kshService.page(page, queryWrapper);
//接收前端传过来的传参类型 类型去跟每条算例的json入参做判断
String objectType = kshServicePojo.getObjectType();
for (KshServicePojo record : page1.getRecords()) {
JSONObject object = JSONObject.parseObject(record.getParam());
JSONArray param = object.getJSONArray("param");
for (int i = 0; i < param.size(); i++) {
// 虚实关联 四码关联 涉案信息 加上下拉框选项 赋值给checked字段是什么类型返回回去
if (record.getSlname().equals("虚实关联")){
if (param.getJSONObject(i).containsKey("checked")){
if (objectType.equals("idcard")){
param.getJSONObject(i).put("checked","01");
}else if (objectType.equals("jz")){
param.getJSONObject(i).put("checked","02");
}else if (objectType.equals("hz")){
param.getJSONObject(i).put("checked","03");
}else if (objectType.equals("sjk")){
param.getJSONObject(i).put("checked","04");
}else if (objectType.equals("wlzh")||objectType.equals("wxid")||objectType.equals("qq")||objectType.equals("other")){
param.getJSONObject(i).put("checked","05");
}
}
}
if (record.getSlname().equals("四码关联")) {
if (param.getJSONObject(i).containsKey("checked")) {
if (objectType.equals("sjk")){
param.getJSONObject(i).put("checked","01");
}else if (objectType.equals("imsi")){
param.getJSONObject(i).put("checked","02");
}else if (objectType.equals("imei")){
param.getJSONObject(i).put("checked","03");
}
}
}
if (record.getSlname().equals("涉案信息")) {
if (param.getJSONObject(i).containsKey("checked")) {
if (objectType.equals("idcard")){
param.getJSONObject(i).put("checked","01");
}else if (objectType.equals("cph")){
param.getJSONObject(i).put("checked","02");
}else if (objectType.equals("aj")){
param.getJSONObject(i).put("checked","03");
}
}
}
//判断是param数组是否存在mold节点
if (param.getJSONObject(i).containsKey("mold")){
//如果存在 获取mold数组判断是否存在前端传来的值类型
JSONArray mold = param.getJSONObject(i).getJSONArray("mold");
if (mold.contains(objectType)){
System.out.println("存在");
param.getJSONObject(i).put("flag","true");
}
}
}
object.put("param",param);
record.setParam(object.toString());
}
return new MapRestResult(200, "OK", page1.getTotal(), page1.getRecords());
}
......
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