Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
M
map-parent
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
常超
map-parent
Commits
617bebeb
Commit
617bebeb
authored
Mar 20, 2023
by
yangyang
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/skyp_Api_NeiMeng' into skyp_Api_NeiMeng
parents
2b9e05f8
a46e14dd
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
272 additions
and
198 deletions
+272
-198
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/AjdaEntity.java
+26
-0
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/WpdaEntity.java
+25
-0
service/publicapi/src/main/java/com/founder/publicapi/controller/KshService/KshSlServiceController.java
+221
-198
No files found.
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/AjdaEntity.java
0 → 100644
View file @
617bebeb
package
com
.
founder
.
commonutils
.
model
.
nmDataEntity
.
NeiMengEntity
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
java.io.Serializable
;
@Data
public
class
AjdaEntity
implements
Serializable
{
@ApiModelProperty
(
value
=
"身份证号"
)
private
String
value
;
@ApiModelProperty
(
value
=
"号码类型(01 身份证号 02 车牌号 03 案件编号)"
)
private
String
type
;
@ApiModelProperty
(
value
=
"请求用户名"
)
private
String
qqyhm
;
@ApiModelProperty
(
value
=
"请求人身份证号"
)
private
String
qqrsfzh
;
@ApiModelProperty
(
value
=
"请求设备ip"
)
private
String
qqip
;
}
\ No newline at end of file
common/common_utils/src/main/java/com/founder/commonutils/model/nmDataEntity/NeiMengEntity/WpdaEntity.java
0 → 100644
View file @
617bebeb
package
com
.
founder
.
commonutils
.
model
.
nmDataEntity
.
NeiMengEntity
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
java.io.Serializable
;
@Data
public
class
WpdaEntity
implements
Serializable
{
@ApiModelProperty
(
value
=
"物品号码(手机号码或imei号码或身份证号)"
)
private
String
number
;
@ApiModelProperty
(
value
=
"号码类型 (\"01\" 手机号,\"02\" imsi,\"03\" 身份证号)"
)
private
String
type
;
@ApiModelProperty
(
value
=
"请求用户名"
)
private
String
qqyhm
;
@ApiModelProperty
(
value
=
"请求人身份证号"
)
private
String
qqrsfzh
;
@ApiModelProperty
(
value
=
"请求设备ip"
)
private
String
qqip
;
}
service/publicapi/src/main/java/com/founder/publicapi/controller/KshService/KshSlServiceController.java
View file @
617bebeb
...
...
@@ -713,6 +713,24 @@ public class KshSlServiceController {
kshlink
.
setProperties
(
linkspropertice
);
return
kshlink
;
}
//没有信息返回的空对象
public
Hnkshresult
result
(
String
name
){
Hnkshresult
result
=
new
Hnkshresult
();
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
name
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
result
;
}
//hander参数
public
static
Map
<
String
,
String
>
getToken
(
HttpServletRequest
request
)
{
// 当前登录者信息
...
...
@@ -747,6 +765,8 @@ public class KshSlServiceController {
public
String
CRJFX
=
"http://26.13.101.72:8999/center_new/006/004"
;
public
String
CXFX
=
"http://26.13.101.72:8999/center_new/006/005"
;
public
String
TXFX
=
"http://26.13.101.72:8999/center_new/006/007"
;
public
String
AJDA
=
"http://26.13.101.72:8999/center_new/001/006"
;
//案件档案
public
String
WPDA
=
"http://26.13.101.72:8999/center_new/001/003"
;
//物品档案
//通过身份证号查询人员亲属关系信息
...
...
@@ -793,42 +813,13 @@ public class KshSlServiceController {
for
(
int
i
=
0
;
i
<
data
.
size
();
i
++)
{
JSONObject
arr
=
data
.
getJSONObject
(
i
);
String
zjhm
=
arr
.
getString
(
"GXDXZJHM"
);
//关系对象zjhm
//nodes
HnTbStRygxDTO
mergeDTOgjd
=
new
HnTbStRygxDTO
();
mergeDTOgjd
.
setId
(
zjhm
);
mergeDTOgjd
.
setLabel
(
zjhm
);
Kshpropertice
kshpropertice
=
new
Kshpropertice
();
kshpropertice
.
setId
(
zjhm
);
kshpropertice
.
setLabel
(
zjhm
);
kshpropertice
.
setImgType
(
"idcard"
);
kshpropertice
.
setBoderColor
(
null
);
mergeDTOgjd
.
setProperties
(
kshpropertice
);
nodes
.
add
(
mergeDTOgjd
);
HnTbStRygxDTO
node
=
node
(
zjhm
,
zjhm
,
"idcard"
,
null
);
nodes
.
add
(
node
);
sumup
.
add
(
zjhm
);
// links
String
gxlx
=
arr
.
getString
(
"GXLX"
);
//关系类型
kshlinks
kshlink
=
new
kshlinks
();
kshlink
.
setSource
(
jpgxEntity
.
getSfzh
());
kshlink
.
setTarget
(
zjhm
);
kshlink
.
setLabel
(
gxlx
);
Linkspropertice
linkspropertice
=
new
Linkspropertice
();
linkspropertice
.
setTime
(
null
);
linkspropertice
.
setSource
(
jpgxEntity
.
getSfzh
());
linkspropertice
.
setTarget
(
zjhm
);
linkspropertice
.
setLabel
(
gxlx
);
GlgxData
glgxData
=
new
GlgxData
();
List
<
GlgxData
>
list
=
new
ArrayList
<>();
glgxData
.
setBsh
(
jpgxEntity
.
getSfzh
());
glgxData
.
setBshlx
(
"idcard"
);
glgxData
.
setGlbsh
(
zjhm
);
glgxData
.
setGlbshlx
(
"idcard"
);
glgxData
.
setSjly
(
"科信"
);
glgxData
.
setGlgx
(
gxlx
);
glgxData
.
setGlsj
(
null
);
list
.
add
(
glgxData
);
linkspropertice
.
setGlgxData
(
list
);
kshlink
.
setProperties
(
linkspropertice
);
re
.
add
(
kshlink
);
kshlinks
link
=
link
(
jpgxEntity
.
getSfzh
(),
zjhm
,
gxlx
,
null
,
jpgxEntity
.
getSfzh
(),
"idcard"
,
zjhm
,
"idcard"
,
"科兴"
,
"家谱关系"
,
null
);
re
.
add
(
link
);
}
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
re
);
...
...
@@ -838,18 +829,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"家谱关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"家谱关系"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -858,8 +839,6 @@ public class KshSlServiceController {
}
}
// 通过身份证和时间段查询旅店同住宿人员频次等信息
@OperLog
(
message
=
"同住关系"
,
operation
=
OperationType
.
QUERY
)
@PostMapping
(
"/tzgx"
)
...
...
@@ -924,18 +903,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"同住关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"同住关系"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -979,34 +948,25 @@ 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
);
nodes
.
add
(
idcard
);
sumup
.
add
(
zjhm
);
kshlinks
link
=
link
(
tagxEntity
.
getIdCard
(),
zjhm
,
"同案"
,
xxdjsj
,
tagxEntity
.
getIdCard
(),
"idcard"
,
zjhm
,
"idcard"
,
"科兴"
,
"同案关系"
,
xxdjsj
);
kshlinks
link
=
link
(
tagxEntity
.
getIdCard
(),
zjhm
,
ajbh
,
xxdjsj
,
tagxEntity
.
getIdCard
(),
"idcard"
,
zjhm
,
"idcard"
,
"科兴"
,
"同案关系"
,
xxdjsj
);
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
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
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
);
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
...
...
@@ -1063,7 +1023,7 @@ public class KshSlServiceController {
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
re
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"
同事
关系"
);
dataSumup
.
setName
(
"
社会
关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
...
...
@@ -1084,7 +1044,7 @@ public class KshSlServiceController {
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
re
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"
校友
关系"
);
dataSumup
.
setName
(
"
社会
关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
...
...
@@ -1092,18 +1052,8 @@ public class KshSlServiceController {
return
new
MapRestResult
(
"(01 同事关系 02校友关系)没有此type"
);
}
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"社会关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"社会关系"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
...
...
@@ -1167,18 +1117,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"通联关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"通联关系"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1293,7 +1233,7 @@ public class KshSlServiceController {
String
zjhm
=
jsonObject
.
getString
(
"acid"
);
//帐号ID
String
acty
=
jsonObject
.
getString
(
"acty"
);
//账号类型
// nodes
HnTbStRygxDTO
mergeDTOgjd
=
node
(
zjhm
,
zjhm
,
acty
,
null
);
HnTbStRygxDTO
mergeDTOgjd
=
node
(
zjhm
,
zjhm
,
"idcard"
,
null
);
nodes
.
add
(
mergeDTOgjd
);
sumup
.
add
(
zjhm
);
// links
...
...
@@ -1311,18 +1251,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"社会关系"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"虚实关联"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
...
...
@@ -1331,7 +1261,6 @@ public class KshSlServiceController {
}
// (msis)手机号、imsi、imei三个号码相互查询,例如一机多号和一号多机
//
@OperLog
(
message
=
"四码关联"
,
operation
=
OperationType
.
QUERY
)
@PostMapping
(
"/smglTwo"
)
@ApiOperation
(
value
=
"四码关联"
)
...
...
@@ -1377,7 +1306,6 @@ public class KshSlServiceController {
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
);
...
...
@@ -1393,10 +1321,10 @@ 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
,
"
idcard
"
,
null
);
HnTbStRygxDTO
imei1
=
node
(
"imei:"
+
imei
+
"\n"
+
"msis:"
+
msis
,
"imei:"
+
imei
+
"\n"
+
"msis:"
+
msis
,
"
sjk
"
,
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
,
"
idcard
"
,
"科兴"
,
"四码关联"
,
latm
);
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
);
...
...
@@ -1413,10 +1341,10 @@ 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
,
"
idacrd
"
,
null
);
HnTbStRygxDTO
imsi1
=
node
(
"imsi:"
+
imsi
+
"\n"
+
"msis:"
+
msis
,
"imsi:"
+
imsi
+
"\n"
+
"msis:"
+
msis
,
"
sjk
"
,
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
,
"
idcard
"
,
"科兴"
,
"四码关联"
,
latm
);
kshlinks
link
=
link
(
smglTwoEntity
.
getValue
(),
"imsi:"
+
imsi
+
"\n"
+
"msis:"
+
msis
,
"一机多号"
,
latm
,
smglTwoEntity
.
getValue
(),
"imei"
,
"imsi:"
+
imsi
+
"\n"
+
"msis:"
+
msis
,
"
sjk
"
,
"科兴"
,
"四码关联"
,
latm
);
re
.
add
(
link
);
}
...
...
@@ -1433,18 +1361,8 @@ public class KshSlServiceController {
}
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"四码关联"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"四码关联"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1453,7 +1371,6 @@ public class KshSlServiceController {
}
}
// 与其通联的手机号码信息
@OperLog
(
message
=
"通联分析"
,
operation
=
OperationType
.
QUERY
)
@PostMapping
(
"/tlfx"
)
...
...
@@ -1500,7 +1417,7 @@ public class KshSlServiceController {
HnTbStRygxDTO
node
=
node
(
anotherPhone
,
anotherPhone
,
"sjk"
,
null
);
nodes
.
add
(
node
);
sumup
.
add
(
anotherPhone
);
kshlinks
link
=
link
(
tlfxEntity
.
getPhoneNumber
(),
anotherPhone
,
countNum
,
null
,
tlfxEntity
.
getPhoneNumber
(),
"sjk"
,
anotherPhone
,
"sjk"
,
"科兴"
,
"通联分析"
,
null
);
kshlinks
link
=
link
(
tlfxEntity
.
getPhoneNumber
(),
anotherPhone
,
"通话频次"
+
countNum
,
null
,
tlfxEntity
.
getPhoneNumber
(),
"sjk"
,
anotherPhone
,
"sjk"
,
"科兴"
,
"通联分析"
,
null
);
re
.
add
(
link
);
}
}
...
...
@@ -1512,18 +1429,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"通联分析"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"通联分析"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1590,18 +1497,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"寄递分析"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"寄递分析"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1716,18 +1613,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"入住分析"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"入住分析"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1780,7 +1667,7 @@ public class KshSlServiceController {
String
xxdjsj
=
arr
.
getString
(
"XXDJSJ"
);
//信息登记时间
String
crjrylb
=
arr
.
getString
(
"CRJRYLB"
);
//出入境人员类别
//nodes
HnTbStRygxDTO
node
=
node
(
crjzjhm
,
crjzjhm
,
"
other
"
,
null
);
HnTbStRygxDTO
node
=
node
(
crjzjhm
,
crjzjhm
,
"
idcard
"
,
null
);
nodes
.
add
(
node
);
sumup
.
add
(
crjzjhm
);
kshlinks
link
=
link
(
crjfxEntity
.
getSfzh
(),
crjzjhm
,
crjrylb
,
cjsj
,
crjfxEntity
.
getSfzh
(),
"idcard"
,
crjzjhm
,
"idcard"
,
"科兴"
,
"出入境分析"
,
cjsj
);
...
...
@@ -1794,18 +1681,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"出入境分析"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"出入境分析"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1864,10 +1741,10 @@ public class KshSlServiceController {
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
);
nodes
.
add
(
node
);
sumup
.
add
(
ph
);
kshlinks
link
=
link
(
cxfxEntity
.
getSfzh
(),
ph
,
bc
,
ddsj
,
cxfxEntity
.
getSfzh
(),
"idcard"
,
ph
,
"
idcard
"
,
"科兴"
,
"出行分析"
,
ddsj
);
kshlinks
link
=
link
(
cxfxEntity
.
getSfzh
(),
ph
,
bc
,
ddsj
,
cxfxEntity
.
getSfzh
(),
"idcard"
,
ph
,
"
other
"
,
"科兴"
,
"出行分析"
,
ddsj
);
re
.
add
(
link
);
}
kshdata
.
setNodes
(
nodes
);
...
...
@@ -1878,18 +1755,8 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
kshdata
kshdata
=
new
kshdata
();
dataSumup
dataSumup
=
new
dataSumup
();
List
<
String
>
sumup
=
new
ArrayList
<>();
List
<
HnTbStRygxDTO
>
nodes
=
new
ArrayList
<>();
List
<
kshlinks
>
links
=
new
ArrayList
<>();
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"出行分析"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
Hnkshresult
result1
=
result
(
"出行分析"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
@@ -1961,18 +1828,174 @@ public class KshSlServiceController {
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
Hnkshresult
result1
=
result
(
"同行分析"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
new
MapRestResult
(
e
);
}
}
//通过案件编号或身份证号查询案件信息; 通过驾驶证号或车牌号查询相应的违章信息;
@OperLog
(
message
=
"案件档案"
,
operation
=
OperationType
.
QUERY
)
@PostMapping
(
"/ajda"
)
@ApiOperation
(
value
=
"案件档案"
)
public
MapRestResult
ajda
(
@RequestBody
AjdaEntity
ajdaEntity
,
HttpServletRequest
request
)
{
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
));
//先把String对象转换成json对象
JSONObject
object
=
JSONObject
.
parseObject
(
s
);
if
(!
object
.
getString
(
"code"
).
equals
(
"1"
)){
return
new
MapRestResult
(
"接口调用失败,返回的错误信息为:"
+
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 车牌号 03 案件编号)
if
(
ajdaEntity
.
getType
().
equals
(
"01"
)){
String
ajbh
=
arr
.
getString
(
"AJBH"
);
//案件编号
String
xxdjsj
=
arr
.
getString
(
"XXDJSJ"
);
//信息登记时间
HnTbStRygxDTO
node
=
node
(
ajbh
,
ajbh
,
"aj"
,
null
);
nodes
.
add
(
node
);
sumup
.
add
(
ajbh
);
kshlinks
link
=
link
(
ajdaEntity
.
getValue
(),
ajbh
,
"案件编号"
,
xxdjsj
,
ajdaEntity
.
getValue
(),
"idcard"
,
ajbh
,
"aj"
,
"科兴"
,
"案件档案"
,
xxdjsj
);
re
.
add
(
link
);
}
else
if
(
ajdaEntity
.
getType
().
equals
(
"02"
)){
String
buco
=
arr
.
getString
(
"buco"
);
//违法编号
String
rlad
=
arr
.
getString
(
"rlad"
);
//联系方式
HnTbStRygxDTO
node
=
node
(
buco
,
buco
,
"aj"
,
null
);
nodes
.
add
(
node
);
sumup
.
add
(
buco
);
kshlinks
link
=
link
(
ajdaEntity
.
getValue
(),
buco
,
"违法编号"
,
null
,
ajdaEntity
.
getValue
(),
"cph"
,
buco
,
"aj"
,
"科兴"
,
"案件档案"
,
null
);
re
.
add
(
link
);
}
else
if
(
ajdaEntity
.
getType
().
equals
(
"03"
)){
String
sfzh
=
arr
.
getString
(
"barzjhm"
);
//报案人证件号码
String
xm
=
arr
.
getString
(
"barxm"
);
//报案人姓名
String
basj
=
arr
.
getString
(
"basj"
);
//报案时间
String
ajmc
=
arr
.
getString
(
"ajmc"
);
//案件名称
HnTbStRygxDTO
node
=
node
(
sfzh
,
xm
+
sfzh
,
"idcard"
,
null
);
nodes
.
add
(
node
);
sumup
.
add
(
sfzh
);
kshlinks
link
=
link
(
ajdaEntity
.
getValue
(),
sfzh
,
ajmc
,
basj
,
ajdaEntity
.
getValue
(),
"aj"
,
sfzh
,
"idcard"
,
"科兴"
,
"案件档案"
,
basj
);
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
{
Hnkshresult
result1
=
result
(
"案件档案"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
new
MapRestResult
(
e
);
}
}
//通过案件编号或身份证号查询案件信息; 通过驾驶证号或车牌号查询相应的违章信息;
@OperLog
(
message
=
"物品档案"
,
operation
=
OperationType
.
QUERY
)
@PostMapping
(
"/wpda"
)
@ApiOperation
(
value
=
"物品档案"
)
public
MapRestResult
wpda
(
@RequestBody
WpdaEntity
wpdaEntity
,
HttpServletRequest
request
)
{
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
(
wpdaEntity
.
getQqip
())&&
StringUtils
.
isNotEmpty
(
wpdaEntity
.
getQqrsfzh
())&&
StringUtils
.
isNotEmpty
(
wpdaEntity
.
getQqyhm
())){
wpdaEntity
.
setQqip
(
ipAddr
);
wpdaEntity
.
setQqrsfzh
(
identitycard
);
wpdaEntity
.
setQqyhm
(
trueName
);
}
try
{
Map
<
String
,
String
>
map
=
objectToMap
(
wpdaEntity
);
String
s
=
HttpUtil
.
doPost
(
WPDA
,
map
,
getToken
(
request
));
//先把String对象转换成json对象
JSONObject
object
=
JSONObject
.
parseObject
(
s
);
if
(!
object
.
getString
(
"code"
).
equals
(
"1"
)){
return
new
MapRestResult
(
"接口调用失败,返回的错误信息为:"
+
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
>
links
=
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
);
}
}
kshdata
.
setNodes
(
nodes
);
kshdata
.
setLinks
(
links
);
kshdata
.
setLinks
(
re
);
dataSumup
.
setList
(
sumup
);
dataSumup
.
setName
(
"
同行分析
"
);
dataSumup
.
setName
(
"
物品档案
"
);
result
.
setKshdata
(
kshdata
);
result
.
setDataSumup
(
dataSumup
);
return
new
MapRestResult
(
200
,
"ok"
,
result
);
}
else
{
Hnkshresult
result1
=
result
(
"物品档案"
);
return
new
MapRestResult
(
200
,
"ok"
,
result1
);
}
}
catch
(
Exception
e
)
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment