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
eac80a6e
Commit
eac80a6e
authored
May 10, 2021
by
刘亚鑫
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
标识号区域碰撞
parent
632d0f5d
Show whitespace changes
Inline
Side-by-side
Showing
12 changed files
with
166 additions
and
120 deletions
+166
-120
common/common_utils/src/main/java/com/founder/commonutils/peopleEntity/JzXxResult.java
+60
-0
common/common_utils/src/main/java/com/founder/commonutils/peopleEntity/RegionalsTask.java
+1
-1
common/common_utils/src/main/java/com/founder/commonutils/peopleEntity/SjGjInfo.java
+18
-0
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/controller/PhoneController.java
+19
-3
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/PhoneInfoMapper.java
+2
-2
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/RegInfoMapper.java
+0
-3
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/xml/PhoneInfoMapper.xml
+16
-2
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/xml/RegInfoMapper.xml
+5
-58
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/PhoneService.java
+1
-1
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/RegTaskService.java
+0
-3
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/impl/PhoneServiceImpl.java
+44
-39
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/impl/RegTaskServiceImpl.java
+0
-8
No files found.
common/common_utils/src/main/java/com/founder/commonutils/peopleEntity/JzXxResult.java
0 → 100644
View file @
eac80a6e
package
com
.
founder
.
commonutils
.
peopleEntity
;
public
class
JzXxResult
{
private
String
deviceAddress
;
// 地址
private
String
deviceCode
;
// 设备编号
private
String
deviceMc
;
// 设备名称
private
String
type
;
// 类型
private
String
x
;
private
String
y
;
public
String
getDeviceAddress
()
{
return
deviceAddress
;
}
public
void
setDeviceAddress
(
String
deviceAddress
)
{
this
.
deviceAddress
=
deviceAddress
;
}
public
String
getDeviceCode
()
{
return
deviceCode
;
}
public
void
setDeviceCode
(
String
deviceCode
)
{
this
.
deviceCode
=
deviceCode
;
}
public
String
getDeviceMc
()
{
return
deviceMc
;
}
public
void
setDeviceMc
(
String
deviceMc
)
{
this
.
deviceMc
=
deviceMc
;
}
public
String
getType
()
{
return
type
;
}
public
void
setType
(
String
type
)
{
this
.
type
=
type
;
}
public
String
getX
()
{
return
x
;
}
public
void
setX
(
String
x
)
{
this
.
x
=
x
;
}
public
String
getY
()
{
return
y
;
}
public
void
setY
(
String
y
)
{
this
.
y
=
y
;
}
}
common/common_utils/src/main/java/com/founder/commonutils/peopleEntity/RegionalsTask.java
View file @
eac80a6e
...
...
@@ -28,7 +28,7 @@ public class RegionalsTask implements Serializable {
@ApiModelProperty
(
"任务类型"
)
private
String
taskType
;
//任务类型 skhs 时空回溯 qypz 区域碰撞 ccbs车车伴随
@ApiModelProperty
(
"任务来源"
)
private
String
taskObject
;
//任务对象 01 车 02 人 03 人像
private
String
taskObject
;
//任务对象 01 车 02 人 03 人像
07手机号
@ApiModelProperty
(
"第三方任务id"
)
private
String
taskIdThirdParty
;
//第三方任务id,例如东莞人像区域碰撞云天返回的任务id
...
...
common/common_utils/src/main/java/com/founder/commonutils/peopleEntity/SjGjInfo.java
View file @
eac80a6e
...
...
@@ -7,6 +7,7 @@ public class SjGjInfo {
private
String
objectValue
;
//值为手机号
private
String
objectType
;
//类型为手机
private
String
objectTypeName
;
//类型为手机
//地址
private
String
address
;
//基站编号
...
...
@@ -19,6 +20,7 @@ public class SjGjInfo {
private
String
stationName
;
//时间戳
private
String
timestamp
;
private
String
time
;
//经度
private
String
x
;
//纬度
...
...
@@ -31,6 +33,22 @@ public class SjGjInfo {
private
String
taskId
;
private
String
region
;
public
String
getObjectTypeName
()
{
return
objectTypeName
;
}
public
void
setObjectTypeName
(
String
objectTypeName
)
{
this
.
objectTypeName
=
objectTypeName
;
}
public
String
getTime
()
{
return
time
;
}
public
void
setTime
(
String
time
)
{
this
.
time
=
time
;
}
public
String
getCount
()
{
return
count
;
}
...
...
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/controller/PhoneController.java
View file @
eac80a6e
...
...
@@ -30,10 +30,10 @@ public class PhoneController {
@ApiOperation
(
value
=
"手机轨迹"
)
@OperLog
(
message
=
"手机轨迹"
,
operation
=
OperationType
.
QUERY
)
@PostMapping
(
"/getSjGjInfo"
)
public
MapRestResult
getSjGjInfo
(
@ApiParam
(
name
=
"objectValue"
,
value
=
"标识号值"
,
required
=
fals
e
)
public
MapRestResult
getSjGjInfo
(
@ApiParam
(
name
=
"objectValue"
,
value
=
"标识号值"
,
required
=
tru
e
)
@RequestParam
String
objectValue
,
@ApiParam
(
name
=
"objectType"
,
value
=
"标识号类型"
,
required
=
tru
e
)
@RequestParam
(
required
=
false
)
String
objectType
,
@ApiParam
(
name
=
"objectType"
,
value
=
"标识号类型"
,
required
=
fals
e
)
@RequestParam
String
objectType
,
@ApiParam
(
name
=
"kssj"
,
value
=
"开始时间"
,
required
=
true
)
@RequestParam
String
kssj
,
@ApiParam
(
name
=
"jssj"
,
value
=
"结束时间"
,
required
=
true
)
...
...
@@ -48,4 +48,19 @@ public class PhoneController {
tbStRegionalstaskresult
.
setPagePara
(
Integer
.
valueOf
(
tbStRegionalstaskresult
.
getLimit
()));
return
phoneService
.
getRegionalsResult
(
tbStRegionalstaskresult
);
}
@OperLog
(
message
=
"范围内基站点位数据接口"
,
operation
=
OperationType
.
QUERY
)
@ApiOperation
(
value
=
"范围内基站点位数据接口"
)
@PostMapping
(
"/selectJzXx"
)
public
MapRestResult
selectJzXx
(
@ApiParam
(
name
=
"qsjd"
,
value
=
"起始经度"
)
@RequestParam
String
qsjd
,
@ApiParam
(
name
=
"qswd"
,
value
=
"起始纬度"
)
@RequestParam
String
qswd
,
@ApiParam
(
name
=
"jsjd"
,
value
=
"结束经度"
)
@RequestParam
String
jsjd
,
@ApiParam
(
name
=
"jswd"
,
value
=
"结束纬度"
)
@RequestParam
String
jswd
)
{
return
phoneService
.
selectJzXx
(
qsjd
,
qswd
,
jsjd
,
jswd
);
}
}
\ No newline at end of file
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/PhoneInfoMapper.java
View file @
eac80a6e
package
com
.
founder
.
peopleapi
.
mapper
;
import
com.founder.commonutils.peopleEntity.JzXxResult
;
import
com.founder.commonutils.peopleEntity.RegionalsDetail
;
import
com.founder.commonutils.peopleEntity.RegionalsPerson
;
import
com.founder.commonutils.peopleEntity.TbStRegionalstaskresult
;
import
com.founder.commonutils.peopleEntity.reslutFl
;
import
org.apache.ibatis.annotations.Mapper
;
import
org.apache.ibatis.annotations.Param
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.stereotype.Component
;
import
java.util.List
;
...
...
@@ -19,4 +18,5 @@ public interface PhoneInfoMapper {
Integer
getAllResultcount
(
TbStRegionalstaskresult
tbStRegionalstaskresult
);
List
<
RegionalsDetail
>
getAllRegionalsDetail
(
@Param
(
"reultId"
)
String
reultId
);
RegionalsPerson
getAllRegionalsPerson
(
@Param
(
"sfzhm"
)
String
sfzhm
);
List
<
JzXxResult
>
getJzInfoByQsJwd
(
@Param
(
"qsjd"
)
String
qsjd
,
@Param
(
"qswd"
)
String
qswd
,
@Param
(
"jsjd"
)
String
jsjd
,
@Param
(
"jswd"
)
String
jswd
);
}
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/RegInfoMapper.java
View file @
eac80a6e
...
...
@@ -26,7 +26,4 @@ public interface RegInfoMapper {
void
updateRegionalsTask
(
RegionalsTask
regionalsTask
);
List
<
RegionalsTask
>
selecteRegionalsTasks
(
@Param
(
"startTime"
)
String
startTime
,
@Param
(
"endTime"
)
String
endTime
,
@Param
(
"taskObject"
)
String
taskObject
,
@Param
(
"carNum"
)
String
carNum
,
@Param
(
"fsrIdentity"
)
String
fsrIdentity
);
List
<
RegionalsCarCarResult
>
selecteRegionalsTasksResults
(
@Param
(
"taskId"
)
String
taskId
);
}
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/xml/PhoneInfoMapper.xml
View file @
eac80a6e
...
...
@@ -2,7 +2,7 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper
namespace=
"com.founder.peopleapi.mapper.PhoneInfoMapper"
>
<resultMap
id=
"RegionalsDetail"
type=
"com.founder.commonutils.
car
Entity.RegionalsDetail"
>
<resultMap
id=
"RegionalsDetail"
type=
"com.founder.commonutils.
people
Entity.RegionalsDetail"
>
<result
column=
"xxzjbh"
property=
"xxzjbh"
jdbcType=
"VARCHAR"
/>
<result
column=
"sfzhm"
property=
"sfzhm"
jdbcType=
"VARCHAR"
/>
<result
column=
"sf_Check"
property=
"sfCheck"
jdbcType=
"VARCHAR"
/>
...
...
@@ -108,5 +108,18 @@
</if>
</select>
</mapper>
<!--根据起始经纬度获取人像点位数据-->
<select
id=
"getJzInfoByQsJwd"
parameterType=
"java.lang.String"
resultType=
"com.founder.commonutils.peopleEntity.JzXxResult"
>
select
BSID as deviceCode,
XZQH_DZ as deviceAddress,
XCOORD as x,
YCOORD as y
from tb_my_jzxx t where 1=1
<if
test=
"qsjd!=null and qsjd!='' and qsjd!=null and qsjd!='' and qswd!=null and qswd!='' and jswd!=null and jswd!=''"
>
AND XCOORD
<![CDATA[>=]]>
#{qsjd,jdbcType=VARCHAR} AND XCOORD
<![CDATA[<=]]>
#{jsjd,jdbcType=VARCHAR}
AND YCOORD
<![CDATA[>=]]>
#{qswd,jdbcType=VARCHAR} AND YCOORD
<![CDATA[<=]]>
#{jswd,jdbcType=VARCHAR}
</if>
</select>
</mapper>
\ No newline at end of file
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/mapper/xml/RegInfoMapper.xml
View file @
eac80a6e
...
...
@@ -141,69 +141,14 @@
where 1=1
<if
test=
"taskId != null and taskId != ''"
>
and TASK_ID = #{ taskId , jdbcType=VARCHAR }
</if>
</update>
<!--获取所有任务-->
<select
id=
"selecteRegionalsTasks"
parameterType=
"String"
resultType=
"com.founder.commonutils.peopleEntity.RegionalsTask"
>
SELECT task_Id AS taskId,
task_Name AS taskName,
(CASE WHEN progress = 'BEGIN' THEN '任务开始'
WHEN progress = 'RUN' THEN '任务执行'
WHEN progress = 'END' THEN '任务完成'
else '任务失败' end)
as progress,
state as state,
fsr_Jh as fsrJh,
fsr_Identity as fsrIdentity,
task_Type as taskType,
task_Object as taskObject,
to_char(djsj,'yyyy-mm-dd hh24:mi:ss') as djsj,
fsr_Xm as fsrXm,
carNum as carNum
FROM tb_st_regionals_task
where 1=1
<if
test=
"startTime != null and startTime != ''"
>
and DJSJ
<![CDATA[>=]]>
TO_DATE(#{ startTime , jdbcType=VARCHAR },'yyyy-MM-dd')
</if>
<if
test=
"endTime != null and endTime != ''"
>
and DJSJ
<![CDATA[<]]>
(TO_DATE(#{ endTime , jdbcType=VARCHAR },'yyyy-MM-dd')+1)
</if>
<if
test=
"taskObject != null and taskObject != ''"
>
and task_Object = #{ taskObject , jdbcType=VARCHAR }
</if>
<if
test=
"fsrIdentity != null and fsrIdentity != ''"
>
and fsr_Identity = #{ fsrIdentity , jdbcType=VARCHAR }
</if>
<if
test=
"carNum != null and carNum != ''"
>
and carNum = #{ carNum , jdbcType=VARCHAR }
</if>
</select>
<!--获取任务结果-->
<select
id=
"selecteRegionalsTasksResults"
parameterType=
"String"
resultType=
"com.founder.commonutils.peopleEntity.RegionalsCarCarResult"
>
SELECT
r.xxzjbh as xxzjbh,
r.task_id as taskId,
r.object_value as object_value,
to_char(r.djsj,'yyyy-mm-dd hh24:mi:ss') as djsj,
r.X AS X,
r.Y AS Y,
r.KKURLPIC as kkUrlPic,
to_char(r.time,'yyyy-mm-dd hh24:mi:ss') as time,
r.deviceid as deviceId,
r.devicename as deviceName,
p.XM as xm,
p.MZ as mz,
p.img as img,
p.xb as xb,
p.sfzhm as sfzhm,
p.xzzdzmc as xzzdzmc,
p.phone as phone,
p.HJDQHDZ as hjdqhdz,
p.csrq as csrq
FROM TB_ST_REGIONALS_RESULT r,TB_ST_REGIONALS_detail d,TB_ST_REGIONALS_PERSON p
where r.XXZJBH = d.RESULT_ID
and d.SFZHM = P.SFZHM(+)
<if
test=
"taskId != null and taskId != ''"
>
and r.task_Id = #{ taskId , jdbcType=VARCHAR }
</if>
</select>
<!--标识号碰撞结果数据保存-->
<insert
id=
"saveResultPz"
parameterType=
"com.founder.commonutils.peopleEntity.SjGjInfo"
>
INSERT INTO TB_ST_REGIONALS_RESULT (
XXZJBH,
TASK_ID,
OBJECT_TYPE,
OBJECT_TYPE_NAME,
OBJECT_VALUE,
REGION,
count,
...
...
@@ -215,6 +160,8 @@
VALUES(
#{ xxzjbh , jdbcType=VARCHAR }
,#{ taskId , jdbcType=VARCHAR }
,#{ objectType , jdbcType=VARCHAR }
,#{ objectTypeName , jdbcType=VARCHAR }
,#{ objectValue , jdbcType=VARCHAR }
,#{ region , jdbcType=VARCHAR }
,#{ count , jdbcType=VARCHAR }
...
...
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/PhoneService.java
View file @
eac80a6e
package
com
.
founder
.
peopleapi
.
service
;
import
com.founder.commonutils.peopleEntity.AreaInfo
;
import
com.founder.commonutils.peopleEntity.TbStRegionalstaskresult
;
import
com.founder.commonutils.publicEntity.MapRestResult
;
import
java.util.List
;
...
...
@@ -14,5 +13,6 @@ public interface PhoneService {
MapRestResult
getRegionalsResult
(
com
.
founder
.
commonutils
.
peopleEntity
.
TbStRegionalstaskresult
tbStRegionalstaskresult
)
throws
Exception
;
MapRestResult
selectJzXx
(
String
qsjd
,
String
qswd
,
String
jsjd
,
String
jswd
);
}
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/RegTaskService.java
View file @
eac80a6e
...
...
@@ -22,7 +22,4 @@ public interface RegTaskService {
MapRestResult
saveRegional
(
Regionals
regionals
);
List
<
RegionalsTask
>
selecteRegionalsTasks
(
String
startTime
,
String
endTime
,
String
taskObject
,
String
carNum
,
String
fsrIdentity
);
List
<
RegionalsCarCarResult
>
selecteRegionalsTasksResults
(
@Param
(
"taskId"
)
String
taskId
);
}
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/impl/PhoneServiceImpl.java
View file @
eac80a6e
...
...
@@ -57,7 +57,7 @@ public class PhoneServiceImpl implements PhoneService {
Map
resultMap
=
new
HashMap
();
List
childrenList
=
new
ArrayList
();
String
cxsj
=
kssj
+
" - "
+
jssj
;
String
url
=
"http://26.3.13.120:8501/nmsj/getMySjGjXx?sjhm="
+
objectValue
+
"&cxSj="
+
cxsj
+
"&page=1&limit=9999"
;
String
url
=
"http://26.3.13.120:8501/nmsj/getMySjGjXx?sjhm="
+
objectValue
+
"&cxSj="
+
cxsj
+
"&page=1&limit=9999
99
"
;
HttpEntity
<
JSONObject
>
jsonObject
=
restTemplate
.
getForEntity
(
url
,
JSONObject
.
class
);
if
(
StringUtils
.
isNotEmpty
(
String
.
valueOf
(
jsonObject
.
getBody
())))
{
...
...
@@ -133,7 +133,7 @@ public class PhoneServiceImpl implements PhoneService {
//todo:gai成基站标号
phoneReceiving
.
setObjectValue
(
t
);
//基站编号
phoneReceiving
.
setObjectType
(
"
"
);
//02 代表卡口编号
基站
phoneReceiving
.
setObjectType
(
"
03"
);
//02 代表卡口编号 03
基站
phoneReceiving
.
setTaskId
(
p
.
getTaskId
());
phoneReceiving
.
setRegion
(
p
.
getRegion
());
phoneReceivinglist
.
add
(
phoneReceiving
);
...
...
@@ -285,19 +285,19 @@ public class PhoneServiceImpl implements PhoneService {
//2.2 通过单个卡口编号获取结果---------时空和回溯直接批量调用的--------------
public
List
<
SjGjInfo
>
phoneInfoResults
(
List
<
PhoneReceiving
>
phoneReceivings
)
{
List
<
SjGjInfo
>
carKk
Infolist
=
new
ArrayList
<>();
List
<
SjGjInfo
>
carKk
Infolists
=
new
ArrayList
<>();
List
<
SjGjInfo
>
sjjZ
Infolist
=
new
ArrayList
<>();
List
<
SjGjInfo
>
sjjZ
Infolists
=
new
ArrayList
<>();
for
(
PhoneReceiving
phoneReceiving
:
phoneReceivings
)
{
try
{
Thread
.
sleep
(
100
);
carKkInfolist
=
car
all
(
phoneReceiving
);
System
.
out
.
println
(
phoneReceiving
.
getObjectValue
()
+
"单个卡口编号获取结果==============="
+
carKk
Infolist
.
size
());
carKkInfolists
.
addAll
(
carKk
Infolist
);
sjjZInfolist
=
phone
all
(
phoneReceiving
);
System
.
out
.
println
(
phoneReceiving
.
getObjectValue
()
+
"单个卡口编号获取结果==============="
+
sjjZ
Infolist
.
size
());
sjjZInfolists
.
addAll
(
sjjZ
Infolist
);
}
catch
(
InterruptedException
e
)
{
e
.
printStackTrace
();
}
}
return
carKk
Infolists
;
return
sjjZ
Infolists
;
}
...
...
@@ -306,11 +306,11 @@ public class PhoneServiceImpl implements PhoneService {
*
* @return
*/
public
List
<
SjGjInfo
>
car
all
(
PhoneReceiving
phoneReceiving
)
{
public
List
<
SjGjInfo
>
phone
all
(
PhoneReceiving
phoneReceiving
)
{
List
<
SjGjInfo
>
listResult
=
new
ArrayList
<>();
Map
resultMap
=
new
HashMap
();
String
cxsj
=
phoneReceiving
.
getKssj
()
+
" - "
+
phoneReceiving
.
getJssj
();
String
url
=
"http://26.3.13.120:8501/nmsj/getMyJzFwXx?jzbh="
+
phoneReceiving
.
getObjectValue
()
+
"&cxSj="
+
cxsj
+
"&page=1&limit=9999"
;
String
url
=
"http://26.3.13.120:8501/nmsj/getMyJzFwXx?jzbh="
+
phoneReceiving
.
getObjectValue
()
+
"&cxSj="
+
cxsj
+
"&page=1&limit=9999
99
"
;
HttpEntity
<
JSONObject
>
jsonObject
=
restTemplate
.
getForEntity
(
url
,
JSONObject
.
class
);
if
(
StringUtils
.
isNotEmpty
(
String
.
valueOf
(
jsonObject
.
getBody
())))
{
...
...
@@ -335,7 +335,8 @@ public class PhoneServiceImpl implements PhoneService {
sjGjInfo
.
setObjectValue
(
sjhm
);
//todo:修改objecttype
sjGjInfo
.
setObjectType
(
""
);
sjGjInfo
.
setObjectType
(
"phone"
);
sjGjInfo
.
setObjectTypeName
(
"手机号码"
);
sjGjInfo
.
setAddress
(
jzmc
);
sjGjInfo
.
setStationName
(
jzmc
);
sjGjInfo
.
setBase
(
jzbh
);
...
...
@@ -344,6 +345,7 @@ public class PhoneServiceImpl implements PhoneService {
sjGjInfo
.
setOldX
(
jd
);
sjGjInfo
.
setOldY
(
wd
);
sjGjInfo
.
setTimestamp
(
String
.
valueOf
(
l
));
sjGjInfo
.
setTime
(
fxsj
);
sjGjInfo
.
setTaskId
(
phoneReceiving
.
getTaskId
());
listResult
.
add
(
sjGjInfo
);
...
...
@@ -377,7 +379,7 @@ public class PhoneServiceImpl implements PhoneService {
CompletableFuture
[]
cfs1
=
pllist
.
stream
()
.
map
(
phonejzInfos
->
CompletableFuture
.
supplyAsync
(()
->
//1.进行保存
car
InfoSaveResultPz
(
phonejzInfos
),
executorService
)
phone
InfoSaveResultPz
(
phonejzInfos
),
executorService
)
//----------1、结果----------------------
.
handle
((
m
,
throwable
)
->
{
if
(
throwable
!=
null
)
{
//保存处理
...
...
@@ -403,9 +405,9 @@ public class PhoneServiceImpl implements PhoneService {
//4、数据批量分流 END-----------------------对有身份证号的详情数据进行批量-----------------------------------------------------------------------------------------------------
CompletableFuture
[]
cfs2
=
pllist
.
stream
()
.
map
(
carKk
Infos
->
CompletableFuture
.
supplyAsync
(()
->
.
map
(
sjGj
Infos
->
CompletableFuture
.
supplyAsync
(()
->
//2 获取号主信息入人员表
getCarRelationInfoPz
(
carKk
Infos
),
executorService
)
getCarRelationInfoPz
(
sjGj
Infos
),
executorService
)
//----------2、结果----------------------
//计数器
.
handle
((
n
,
throwable
)
->
{
...
...
@@ -433,14 +435,14 @@ public class PhoneServiceImpl implements PhoneService {
}
//4.1 保存结果表(通过单个卡口编号获取结果)(当前时间段被卡口抓拍到的号牌号)-----------------------
public
Map
<
String
,
List
<
SjGjInfo
>>
carInfoSaveResultPz
(
List
<
SjGjInfo
>
carKk
Infos
)
{
public
Map
<
String
,
List
<
SjGjInfo
>>
phoneInfoSaveResultPz
(
List
<
SjGjInfo
>
sjgj
Infos
)
{
Map
<
String
,
List
<
SjGjInfo
>>
map
=
new
HashMap
<>();
//保存数据
//保存成功list
List
<
SjGjInfo
>
sucesslist
=
new
ArrayList
<>();
//保存失败list
List
<
SjGjInfo
>
errorlist
=
new
ArrayList
<>();
carKk
Infos
.
forEach
(
p
->
{
sjgj
Infos
.
forEach
(
p
->
{
try
{
//保存结果表
p
.
setXxzjbh
(
KeyUtil
.
getUniqueKey
(
"C"
));
// 信息主键编号
...
...
@@ -468,11 +470,10 @@ public class PhoneServiceImpl implements PhoneService {
public
Map
<
List
<
SjGjInfo
>,
List
<
PhoneRy
>>
getCarRelationInfoPz
(
List
<
SjGjInfo
>
sjgjInfos
)
{
// 返回实体 采用LinkedHashMap 顺序插入,顺序输出
Map
<
List
<
SjGjInfo
>,
List
<
PhoneRy
>>
maplist
=
new
LinkedHashMap
<>();
List
<
PhoneRy
>
car
RyInfosucess
=
new
ArrayList
<>();
List
<
SjGjInfo
>
car
RyInfonull
=
new
ArrayList
<>();
List
<
SjGjInfo
>
car
RyInfoerro
=
new
ArrayList
<>();
List
<
PhoneRy
>
phone
RyInfosucess
=
new
ArrayList
<>();
List
<
SjGjInfo
>
phone
RyInfonull
=
new
ArrayList
<>();
List
<
SjGjInfo
>
phone
RyInfoerro
=
new
ArrayList
<>();
for
(
SjGjInfo
p
:
sjgjInfos
)
{
try
{
// 机主信息
PhoneRy
phoneRy
=
new
PhoneRy
();
...
...
@@ -482,17 +483,18 @@ public class PhoneServiceImpl implements PhoneService {
LinkedHashMap
resultJson
=
(
LinkedHashMap
)
jsonObject
.
getBody
().
get
(
"data"
);
//获取返回的数据结果
List
<
LinkedHashMap
>
array
=
(
List
<
LinkedHashMap
>)
resultJson
.
get
(
"rows"
);
System
.
out
.
println
(
array
.
toString
());
for
(
int
i
=
0
;
i
<
array
.
size
();
i
++)
{
LinkedHashMap
object
=
array
.
get
(
i
);
if
(
array
!=
null
&&
array
.
size
()!=
0
)
{
LinkedHashMap
object
=
array
.
get
(
0
);
String
bshxx
=
p
.
getObjectValue
();
String
xm
=
(
String
)
object
.
get
(
"xm"
);
String
zjhm
=
(
String
)
object
.
get
(
"zjhm"
);
phoneRy
.
setXm
(
xm
);
phoneRy
.
setSfzhm
(
zjhm
);
phoneRy
.
setPhone
(
bshxx
);
}
}
}
try
{
if
(
null
!=
phoneRy
)
{
// 人员表去重
String
sfzhm
=
phoneRy
.
getSfzhm
();
...
...
@@ -500,10 +502,10 @@ public class PhoneServiceImpl implements PhoneService {
Integer
e
=
regInfoMapper
.
selecteRegionalsPerson
(
sfzhm
);
if
(
e
==
0
)
{
//号主入库
car
RyInfosucess
.
add
(
phoneRy
);
phone
RyInfosucess
.
add
(
phoneRy
);
//循环保存关联list数据
//TODO:为什么循环
car
RyInfosucess
.
stream
().
forEach
(
t
->
{
phone
RyInfosucess
.
stream
().
forEach
(
t
->
{
RegionalsPerson
regionalsPerson
=
new
RegionalsPerson
();
regionalsPerson
.
setXxzjbh
(
KeyUtil
.
getUniqueKey
(
"RY"
));
// 信息主键编号
regionalsPerson
.
setPhone
(
t
.
getPhone
());
...
...
@@ -515,9 +517,6 @@ public class PhoneServiceImpl implements PhoneService {
regionalsPerson
.
setXm
(
t
.
getXm
());
regionalsPerson
.
setHjdqhdz
(
t
.
getHjdqhdz
());
regionalsPerson
.
setCsrq
(
t
.
getCsrq
());
// 照片数据处理
byte
[]
img
=
(
t
.
getImg
()).
getBytes
();
regionalsPerson
.
setImg
(
img
);
// 保存详情(作为关联号主信息)
RegionalsDetail
regionalsDetail
=
new
RegionalsDetail
();
...
...
@@ -526,7 +525,7 @@ public class PhoneServiceImpl implements PhoneService {
regionalsDetail
.
setResultId
(
p
.
getXxzjbh
());
regionalsDetail
.
setObjectTypeName
(
"新录入号主信息"
);
regionalsDetail
.
setObjectValue
(
t
.
getObjValue
());
regionalsDetail
.
setObjectType
(
"
c
zxx"
);
regionalsDetail
.
setObjectType
(
"
h
zxx"
);
regionalsDetail
.
setSfzhm
(
t
.
getSfzhm
());
// 保存详情表
regInfoMapper
.
saveRegionalsDetail
(
regionalsDetail
);
...
...
@@ -537,7 +536,7 @@ public class PhoneServiceImpl implements PhoneService {
regionalsResult
.
setXxzjbh
(
p
.
getId
());
regionalsResult
.
setSfCheck
(
"1"
);
//翻译成功
regInfoMapper
.
updateRegionalsResult
(
regionalsResult
);
System
.
out
.
println
(
"有号主信息翻译===================="
+
car
RyInfosucess
.
toString
());
System
.
out
.
println
(
"有号主信息翻译===================="
+
phone
RyInfosucess
.
toString
());
});
}
else
{
// 号主入库
...
...
@@ -557,18 +556,18 @@ public class PhoneServiceImpl implements PhoneService {
regionalsResult
.
setXxzjbh
(
p
.
getXxzjbh
());
regionalsResult
.
setSfCheck
(
"1"
);
//翻译成功
regInfoMapper
.
updateRegionalsResult
(
regionalsResult
);
car
RyInfosucess
.
add
(
phoneRy
);
phone
RyInfosucess
.
add
(
phoneRy
);
System
.
out
.
println
(
"之前有号主信息翻译信息===================="
+
p
.
getObjectValue
());
}
}
else
{
// 未关联到数据
car
RyInfonull
.
add
(
p
);
phone
RyInfonull
.
add
(
p
);
// 保存详情(作为关联号主信息)
RegionalsDetail
regionalsDetail
=
new
RegionalsDetail
();
regionalsDetail
.
setXxzjbh
(
KeyUtil
.
getUniqueKey
(
"DE"
));
// 信息主键编号
// 结果数据id保存
regionalsDetail
.
setResultId
(
p
.
getXxzjbh
());
regionalsDetail
.
setObjectTypeName
(
"无号主信息"
);
regionalsDetail
.
setObjectType
(
"
c
zxx"
);
regionalsDetail
.
setObjectType
(
"
h
zxx"
);
// 保存详情表
regInfoMapper
.
saveRegionalsDetail
(
regionalsDetail
);
// 保存验证信息
...
...
@@ -582,16 +581,16 @@ public class PhoneServiceImpl implements PhoneService {
// 保存验证信息
RegionalsResult
regionalsResult
=
new
RegionalsResult
();
regionalsResult
.
setXxzjbh
(
p
.
getXxzjbh
());
regionalsResult
.
setSfCheck
(
"
c
z"
);
//翻译失败
regionalsResult
.
setSfCheck
(
"
h
z"
);
//翻译失败
regInfoMapper
.
updateRegionalsResult
(
regionalsResult
);
System
.
out
.
println
(
"号主信息翻译失败原因======="
+
e
+
"翻译失败的号
牌号
========="
+
p
.
getObjectValue
());
car
RyInfoerro
.
add
(
p
);
System
.
out
.
println
(
"号主信息翻译失败原因======="
+
e
+
"翻译失败的号
码
========="
+
p
.
getObjectValue
());
phone
RyInfoerro
.
add
(
p
);
}
}
// 返回没有翻译出号主信息和翻译出号主信息
maplist
.
put
(
carRyInfonull
,
car
RyInfosucess
);
maplist
.
put
(
phoneRyInfonull
,
phone
RyInfosucess
);
// 返回号主信息请求失败的数据
maplist
.
put
(
carRyInfoerro
,
car
RyInfosucess
);
maplist
.
put
(
phoneRyInfoerro
,
phone
RyInfosucess
);
return
maplist
;
}
...
...
@@ -706,4 +705,10 @@ public class PhoneServiceImpl implements PhoneService {
}
}
}
@Override
public
MapRestResult
selectJzXx
(
String
qsjd
,
String
qswd
,
String
jsjd
,
String
jswd
){
List
<
JzXxResult
>
kkList
=
phoneInfoMapper
.
getJzInfoByQsJwd
(
qsjd
,
qswd
,
jsjd
,
jswd
);
return
MapRestResult
.
build
(
200
,
"获取基站信息"
,
kkList
.
size
(),
kkList
);
}
}
serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/impl/RegTaskServiceImpl.java
View file @
eac80a6e
...
...
@@ -40,13 +40,5 @@ public class RegTaskServiceImpl implements RegTaskService {
return
MapRestResult
.
build
(
200
,
"区域保存成功"
,
""
);
}
@Override
public
List
<
RegionalsTask
>
selecteRegionalsTasks
(
String
startTime
,
String
endTime
,
String
taskObject
,
String
carNum
,
String
fsrIdentity
)
{
return
regInfoMapper
.
selecteRegionalsTasks
(
startTime
,
endTime
,
taskObject
,
carNum
,
fsrIdentity
);
}
@Override
public
List
<
RegionalsCarCarResult
>
selecteRegionalsTasksResults
(
String
taskId
)
{
return
regInfoMapper
.
selecteRegionalsTasksResults
(
taskId
);
}
}
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