Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
B
bigdatainterservice
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
曹鹏
bigdatainterservice
Commits
6d5610f0
Commit
6d5610f0
authored
May 18, 2019
by
吴善钰
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/master'
parents
22ee818f
50b10b58
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
116 additions
and
32 deletions
+116
-32
src/main/java/com/founder/interservice/bkxx/model/Bkxx.java
+3
-0
src/main/java/com/founder/interservice/bkxx/service/impl/BkServiceImpl.java
+51
-30
src/main/java/com/founder/interservice/ryhx/controller/RyhxController.java
+32
-0
src/main/resources/static/js/bkxxInsert.js
+6
-1
src/main/webapp/WEB-INF/jsp/bkxx/bkxxInsert.jsp
+2
-1
src/main/webapp/WEB-INF/jsp/ryhx/gxqxx.jsp
+22
-0
No files found.
src/main/java/com/founder/interservice/bkxx/model/Bkxx.java
View file @
6d5610f0
...
@@ -50,4 +50,7 @@ public class Bkxx {
...
@@ -50,4 +50,7 @@ public class Bkxx {
private
String
xxly
;
//信息来源,如果是民警手动录入的,则默认给录入人姓名,如果是系统自动加入布控,则给布控任务的布控对象号码
private
String
xxly
;
//信息来源,如果是民警手动录入的,则默认给录入人姓名,如果是系统自动加入布控,则给布控任务的布控对象号码
private
String
xxlytype
;
//信息来源type,01,表示民警录入,02,表示系统关联自动加入
private
String
xxlytype
;
//信息来源type,01,表示民警录入,02,表示系统关联自动加入
private
String
sqr_gajgjgdm
;
private
String
sqr_gajgjgmc
;
}
}
src/main/java/com/founder/interservice/bkxx/service/impl/BkServiceImpl.java
View file @
6d5610f0
...
@@ -15,6 +15,7 @@ import com.founder.interservice.model.Track;
...
@@ -15,6 +15,7 @@ import com.founder.interservice.model.Track;
import
com.founder.interservice.util.DateUtil
;
import
com.founder.interservice.util.DateUtil
;
import
com.founder.interservice.util.KeyUtil
;
import
com.founder.interservice.util.KeyUtil
;
import
com.founder.interservice.util.ResultVOUtil
;
import
com.founder.interservice.util.ResultVOUtil
;
import
com.founder.interservice.util.StringUtil
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
...
@@ -72,7 +73,20 @@ public class BkServiceImpl implements BkService{
...
@@ -72,7 +73,20 @@ public class BkServiceImpl implements BkService{
}
else
{
}
else
{
//新增
//新增
int
bkxxs
=
bkxxMapper
.
selectBkxxCount
(
bkxx
);
int
bkxxs
=
bkxxMapper
.
selectBkxxCount
(
bkxx
);
if
(
bkxxs
<
1
){
if
(
bkxxs
<
1
)
{
//获取机构总布控数,布控不能超过50,追踪不能超过10
String
dwdm
=
""
;
if
(!
StringUtil
.
ckeckEmpty
(
bkxx
.
getSqr_gajgjgdm
()))
{
dwdm
=
bkxx
.
getSqr_gajgjgdm
().
substring
(
0
,
6
);
}
int
count
=
this
.
getBkxxCount
(
dwdm
,
bkxx
.
getType
());
int
maxCount
=
0
;
if
(
"01"
.
equals
(
bkxx
.
getType
())){
//布控
maxCount
=
50
;
}
else
if
(
"02"
.
equals
(
bkxx
.
getType
())){
//追踪
maxCount
=
10
;
}
if
(
count
<
maxCount
)
{
//可以新增
String
id
=
KeyUtil
.
getUniqueKey
(
"BK"
);
String
id
=
KeyUtil
.
getUniqueKey
(
"BK"
);
bkxx
.
setXxzjbh
(
id
);
bkxx
.
setXxzjbh
(
id
);
bkxx
.
setDjsj
(
new
Date
());
bkxx
.
setDjsj
(
new
Date
());
...
@@ -95,84 +109,91 @@ public class BkServiceImpl implements BkService{
...
@@ -95,84 +109,91 @@ public class BkServiceImpl implements BkService{
* 001:手机号布控,002:QQ号码布控,003:微信id,004:身份证号,005:车牌号,006:IMSI,007:IMEI,008:护照,009:微信号码
* 001:手机号布控,002:QQ号码布控,003:微信id,004:身份证号,005:车牌号,006:IMSI,007:IMEI,008:护照,009:微信号码
*/
*/
if
(
"002"
.
equals
(
bkxx
.
getBkdxlx
())
||
"003"
.
equals
(
bkxx
.
getBkdxlx
())||
"007"
.
equals
(
bkxx
.
getBkdxlx
()))
{
if
(
"002"
.
equals
(
bkxx
.
getBkdxlx
())
||
"003"
.
equals
(
bkxx
.
getBkdxlx
())
||
"007"
.
equals
(
bkxx
.
getBkdxlx
()))
{
//QQ号码/微信id/IMEI
//QQ号码/微信id/IMEI
List
<
String
>
imsis
=
bkServiceCommon
.
queryTargetBshByBsh
(
bkxx
.
getBkdxhm
(),
"IMSI"
);
List
<
String
>
imsis
=
bkServiceCommon
.
queryTargetBshByBsh
(
bkxx
.
getBkdxhm
(),
"IMSI"
);
List
<
String
>
oldImsis
=
new
ArrayList
<>();
List
<
String
>
oldImsis
=
new
ArrayList
<>();
if
(
imsis
!=
null
&&
!
imsis
.
isEmpty
())
{
if
(
imsis
!=
null
&&
!
imsis
.
isEmpty
())
{
for
(
String
imsi
:
imsis
)
{
for
(
String
imsi
:
imsis
)
{
List
<
BkTaskResult
>
bkTaskResults
=
bkTaskResultRepository
.
findBkResultsByBkXxzjbh
(
bkxx
.
getXxzjbh
());
List
<
BkTaskResult
>
bkTaskResults
=
bkTaskResultRepository
.
findBkResultsByBkXxzjbh
(
bkxx
.
getXxzjbh
());
if
(
bkTaskResults
!=
null
&&
bkTaskResults
.
size
()>
0
)
{
if
(
bkTaskResults
!=
null
&&
bkTaskResults
.
size
()
>
0
)
{
for
(
BkTaskResult
oldResult
:
bkTaskResults
)
{
for
(
BkTaskResult
oldResult
:
bkTaskResults
)
{
oldImsis
.
add
(
oldResult
.
getImsi
());
oldImsis
.
add
(
oldResult
.
getImsi
());
}
}
if
(!
oldImsis
.
contains
(
imsi
)){
if
(!
oldImsis
.
contains
(
imsi
))
{
//在库中不存在
//在库中不存在
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
imsi
,
""
);
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
imsi
,
""
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
}
}
}
else
{
}
else
{
//关于此数据,库中没有结果
//关于此数据,库中没有结果
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
imsi
,
""
);
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
imsi
,
""
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
}
}
}
}
}
}
}
else
if
(
"006"
.
equals
(
bkxx
.
getBkdxlx
()))
{
}
else
if
(
"006"
.
equals
(
bkxx
.
getBkdxlx
()))
{
//通过IMSI查询IMEI
//通过IMSI查询IMEI
List
<
String
>
imeis
=
bkServiceCommon
.
queryTargetBshByBsh
(
bkxx
.
getBkdxhm
(),
"IMSI"
);
List
<
String
>
imeis
=
bkServiceCommon
.
queryTargetBshByBsh
(
bkxx
.
getBkdxhm
(),
"IMSI"
);
List
<
String
>
oldImeis
=
new
ArrayList
<>();
List
<
String
>
oldImeis
=
new
ArrayList
<>();
if
(
imeis
!=
null
&&
!
imeis
.
isEmpty
())
{
if
(
imeis
!=
null
&&
!
imeis
.
isEmpty
())
{
for
(
String
imei
:
imeis
)
{
for
(
String
imei
:
imeis
)
{
List
<
BkTaskResult
>
bkTaskResults
=
bkTaskResultRepository
.
findBkResultsByBkXxzjbh
(
bkxx
.
getXxzjbh
());
List
<
BkTaskResult
>
bkTaskResults
=
bkTaskResultRepository
.
findBkResultsByBkXxzjbh
(
bkxx
.
getXxzjbh
());
if
(
bkTaskResults
!=
null
&&
bkTaskResults
.
size
()>
0
)
{
if
(
bkTaskResults
!=
null
&&
bkTaskResults
.
size
()
>
0
)
{
for
(
BkTaskResult
oldResult
:
bkTaskResults
)
{
for
(
BkTaskResult
oldResult
:
bkTaskResults
)
{
oldImeis
.
add
(
oldResult
.
getImei
());
oldImeis
.
add
(
oldResult
.
getImei
());
}
}
if
(
oldImeis
.
contains
(
imei
)){
if
(
oldImeis
.
contains
(
imei
))
{
//在库中不存在
//在库中不存在
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
""
,
imei
);
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
""
,
imei
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
}
}
}
else
{
}
else
{
//关于此数据,库中没有结果
//关于此数据,库中没有结果
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
""
,
imei
);
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
null
,
bkxx
,
""
,
imei
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
}
}
}
}
}
}
}
else
if
(
"005"
.
equals
(
bkxx
.
getBkdxlx
()))
{
}
else
if
(
"005"
.
equals
(
bkxx
.
getBkdxlx
()))
{
//005:车牌号
//005:车牌号
List
<
String
>
oldCphm
=
new
ArrayList
<>();
List
<
String
>
oldCphm
=
new
ArrayList
<>();
String
kssj
=
DateUtil
.
getDate
().
getTime
()
+
""
;
String
kssj
=
DateUtil
.
getDate
().
getTime
()
+
""
;
String
jssj
=
DateUtil
.
convertStringToDate
(
DateUtil
.
beforeDate
(-
1
).
substring
(
0
,
10
)).
getTime
()+
""
;
String
jssj
=
DateUtil
.
convertStringToDate
(
DateUtil
.
beforeDate
(-
1
).
substring
(
0
,
10
)).
getTime
()
+
""
;
/* System.out.println("=============================进来了=========================");
/* System.out.println("=============================进来了=========================");
System.out.println("=============================进来了=============信息主键============"+bkxx.getXxzjbh());*/
System.out.println("=============================进来了=============信息主键============"+bkxx.getXxzjbh());*/
List
<
BkTaskResult
>
bkTaskResults
=
bkTaskResultRepository
.
findBkResultsByBkXxzjbh
(
bkxx
.
getXxzjbh
());
List
<
BkTaskResult
>
bkTaskResults
=
bkTaskResultRepository
.
findBkResultsByBkXxzjbh
(
bkxx
.
getXxzjbh
());
/* System.out.println("=============================进来了=============判重成功了============"+bkTaskResults.size());*/
/* System.out.println("=============================进来了=============判重成功了============"+bkTaskResults.size());*/
if
(
bkTaskResults
!=
null
&&
bkTaskResults
.
size
()>
0
)
{
if
(
bkTaskResults
!=
null
&&
bkTaskResults
.
size
()
>
0
)
{
for
(
BkTaskResult
oldResult
:
bkTaskResults
)
{
for
(
BkTaskResult
oldResult
:
bkTaskResults
)
{
oldCphm
.
add
(
oldResult
.
getBkbsh
());
oldCphm
.
add
(
oldResult
.
getBkbsh
());
}
}
if
(!
oldCphm
.
contains
(
bkxx
.
getBkdxhm
())){
if
(!
oldCphm
.
contains
(
bkxx
.
getBkdxhm
()))
{
//在库中不存在
//在库中不存在
//直接获取轨迹信息
//直接获取轨迹信息
Track
newLocation
=
bkServiceCommon
.
getNewLocation
(
bkxx
.
getBkdxhm
(),
kssj
,
jssj
);
Track
newLocation
=
bkServiceCommon
.
getNewLocation
(
bkxx
.
getBkdxhm
(),
kssj
,
jssj
);
/* System.out.print("获取的轨迹信息:"+newLocation.getAddress()+";==经纬度="+newLocation.getJ()+"===纬度"+newLocation.getW());*/
/* System.out.print("获取的轨迹信息:"+newLocation.getAddress()+";==经纬度="+newLocation.getJ()+"===纬度"+newLocation.getW());*/
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
newLocation
,
bkxx
,
""
,
""
);
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
newLocation
,
bkxx
,
""
,
""
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
}
}
}
else
{
}
else
{
//关于此数据,库中没有结果
//关于此数据,库中没有结果
//直接获取轨迹信息
//直接获取轨迹信息
Track
newLocation
=
bkServiceCommon
.
getNewLocation
(
bkxx
.
getBkdxhm
(),
kssj
,
jssj
);
Track
newLocation
=
bkServiceCommon
.
getNewLocation
(
bkxx
.
getBkdxhm
(),
kssj
,
jssj
);
/* System.out.println("=============================进来了==查询了轨迹============"+newLocation.getAddress());*/
/* System.out.println("=============================进来了==查询了轨迹============"+newLocation.getAddress());*/
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
newLocation
,
bkxx
,
""
,
""
);
BkTaskResult
bkTaskResult
=
bkServiceCommon
.
setBkResult
(
newLocation
,
bkxx
,
""
,
""
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
bkTaskResultRepository
.
save
(
bkTaskResult
);
}
}
}
}
}
else
{
}
else
{
//提示,超过布控或追踪总数
result
.
put
(
"id"
,
null
);
result
.
put
(
"maxCount"
,
maxCount
);
result
.
put
(
"status"
,
ResultEnum
.
PARAM_ERROR
.
getCode
());
result
.
put
(
"message"
,
"超过最大布控/追踪数"
);
}
}
else
{
result
.
put
(
"id"
,
null
);
result
.
put
(
"id"
,
null
);
result
.
put
(
"status"
,
ResultEnum
.
PARAM_ERROR
.
getCode
());
result
.
put
(
"status"
,
ResultEnum
.
PARAM_ERROR
.
getCode
());
result
.
put
(
"message"
,
"数据已存在,不可重复!"
);
result
.
put
(
"message"
,
"数据已存在,不可重复!"
);
...
...
src/main/java/com/founder/interservice/ryhx/controller/RyhxController.java
View file @
6d5610f0
...
@@ -363,9 +363,41 @@ public class RyhxController {
...
@@ -363,9 +363,41 @@ public class RyhxController {
relationList
=
removeJSonObject
(
relationList
);
relationList
=
removeJSonObject
(
relationList
);
}
}
}
}
TbStCqhotel
tbStCqhotel
=
null
;
List
<
TbStCqhotel
>
listHotel
=
new
ArrayList
<>();
List
<
TbStCqhotelData
>
listHotelData
=
null
;
//本人住店信息
List
<
TbStCqhotelData
>
listOtherHotelData
=
new
ArrayList
<>();
//本人所有同住人信息
try
{
if
(
zjhm
!=
null
&&
!
""
.
equals
(
zjhm
))
{
//旅店住宿信息
listHotelData
=
ryhxService
.
queryHotelRzxx
(
zjhm
);
if
(
listHotelData
!=
null
&&
listHotelData
.
size
()
>
0
)
{
for
(
TbStCqhotelData
tbStCqhotelData
:
listHotelData
)
{
String
hotelno
=
tbStCqhotelData
.
getHotelno
();
String
rzsj
=
tbStCqhotelData
.
getRzsj
();
String
roomno
=
tbStCqhotelData
.
getRoomno
();
//疑似落脚点(旅店信息)
if
(
null
!=
hotelno
&&
!
""
.
equals
(
hotelno
))
{
tbStCqhotel
=
ryhxService
.
queryHotelAddr
(
hotelno
);
listHotel
.
add
(
tbStCqhotel
);
}
//根据旅店信息,查询同住人员信息
if
(
null
!=
tbStCqhotel
)
{
//当前酒店同住人员信息
List
<
TbStCqhotelData
>
listOneHotelData
=
ryhxService
.
queryHotelxx
(
zjhm
,
hotelno
,
rzsj
,
roomno
);
listOtherHotelData
.
addAll
(
listOneHotelData
);
}
}
}
}
}
catch
(
Exception
e
){
e
.
printStackTrace
();
}
ModelAndView
modelAndView
=
new
ModelAndView
(
"ryhx/gxqxx"
);
ModelAndView
modelAndView
=
new
ModelAndView
(
"ryhx/gxqxx"
);
modelAndView
.
addObject
(
"relationList"
,
relationList
);
modelAndView
.
addObject
(
"relationList"
,
relationList
);
modelAndView
.
addObject
(
"relationnum"
,
relationList
.
size
());
modelAndView
.
addObject
(
"relationnum"
,
relationList
.
size
());
modelAndView
.
addObject
(
"listOtherHotelData"
,
listOtherHotelData
);
//同住人员住宿信息
modelAndView
.
addObject
(
"listOtherHotelDatacount"
,
listOtherHotelData
.
size
());
//同住人员住宿信息
modelAndView
.
addObject
(
"zjhm"
,
zjhm
);
modelAndView
.
addObject
(
"zjhm"
,
zjhm
);
return
modelAndView
;
return
modelAndView
;
}
}
...
...
src/main/resources/static/js/bkxxInsert.js
View file @
6d5610f0
...
@@ -123,7 +123,12 @@
...
@@ -123,7 +123,12 @@
if
(
data
.
data
.
id
==
"0"
){
if
(
data
.
data
.
id
==
"0"
){
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'保存失败'
});
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'保存失败'
});
}
else
if
(
data
.
data
.
id
==
null
){
}
else
if
(
data
.
data
.
id
==
null
){
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'数据已存在,不可重复提交'
});
if
(
data
.
data
.
maxCount
!=
null
){
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'已超过最大布控/追踪数'
});
}
else
{
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'数据已存在,不可重复提交'
});
}
}
else
{
}
else
{
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'保存成功'
});
$
.
messager
.
alert
({
title
:
'提示'
,
msg
:
'保存成功'
});
}
}
...
...
src/main/webapp/WEB-INF/jsp/bkxx/bkxxInsert.jsp
View file @
6d5610f0
...
@@ -202,7 +202,8 @@
...
@@ -202,7 +202,8 @@
<input type="hidden" id="xxly" name="xxly" value="${bkxx.xxly}"/>
<input type="hidden" id="xxly" name="xxly" value="${bkxx.xxly}"/>
<input type="hidden" id="xxlytype" name="xxlytype" value="${bkxx.xxlytype}"/>
<input type="hidden" id="xxlytype" name="xxlytype" value="${bkxx.xxlytype}"/>
<input type="hidden" id="djsj" name="djsj" value="${djsjStr}"/>
<input type="hidden" id="djsj" name="djsj" value="${djsjStr}"/>
<input type="hidden" id="sqr_gajgjgdm" name="sqr_gajgjgdm" value="${bkxx.sqr_gajgjgdm}"/>
<input type="hidden" id="sqr_gajgjgmc" name="sqr_gajgjgmc" value="${bkxx.sqr_gajgjgmc}"/>
</td>
</td>
</tr>
</tr>
</tbody>
</tbody>
...
...
src/main/webapp/WEB-INF/jsp/ryhx/gxqxx.jsp
View file @
6d5610f0
...
@@ -35,6 +35,28 @@
...
@@ -35,6 +35,28 @@
</div>
</div>
</div>
</div>
</c:if>
</c:if>
<c:forEach
var=
"tzxx"
items=
"${listOtherHotelData}"
>
<c:if
test=
"${not empty listOtherHotelData}"
>
<div
class=
"new1 tabs-o animated pulse"
>
<span
class=
"tbs-title"
>
同住人
</span>
<div
class=
"tbs-cont"
>
<div
class=
"fl count"
onclick=
"tips(this)"
>
${tzxx.xm}
</div>
<div
class=
"fl ajbh"
>
${tzxx.idcode}
</div>
</div>
</div>
</c:if>
</c:forEach>
<c:if
test=
"${empty listOtherHotelData}"
>
<div
class=
"new1 tabs-o animated pulse"
style=
"margin-top: -298px;"
>
<span
class=
"tbs-title"
style=
"font-size:14px; margin-left: 13px;"
>
提示
</span>
<div
class=
"tbs-cont"
>
<div
class=
"fl count"
onclick=
"tips(this)"
>
${listOtherHotelDatacount}
</div>
<div
class=
"fl ajbh"
>
<span
style=
"font-size:16px; margin-left: 22px;"
>
暂无查询结果
</span>
</div>
</div>
</div>
</c:if>
</div>
</div>
<script
type=
"text/javascript"
src=
"/js/jquery-1.11.3.js"
></script>
<script
type=
"text/javascript"
src=
"/js/jquery-1.11.3.js"
></script>
<script
type=
"text/javascript"
src=
"/common/layer/layer.js"
></script>
<script
type=
"text/javascript"
src=
"/common/layer/layer.js"
></script>
...
...
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