记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
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
董敬伟
liquidnet-bus-v1
Commits
733983cb
Commit
733983cb
authored
Jun 25, 2021
by
张国柄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
+log;
parent
6b157f8c
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
3 additions
and
0 deletions
+3
-0
KylinStationController.java
...dnet/service/kylin/controller/KylinStationController.java
+3
-0
No files found.
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinStationController.java
View file @
733983cb
...
@@ -182,6 +182,7 @@ public class KylinStationController {
...
@@ -182,6 +182,7 @@ public class KylinStationController {
voList
.
stream
().
map
(
KylinStationPerformanceVo:
:
getPerformancesId
).
toArray
()
voList
.
stream
().
map
(
KylinStationPerformanceVo:
:
getPerformancesId
).
toArray
()
).
and
(
"isPayment"
).
is
(
1
));
).
and
(
"isPayment"
).
is
(
1
));
List
<
KylinOrderTicketEntitiesVo
>
oteVoList
=
mongoTemplate
.
find
(
orderTicketEntitiesVoQuery
,
KylinOrderTicketEntitiesVo
.
class
,
KylinOrderTicketEntitiesVo
.
class
.
getSimpleName
());
List
<
KylinOrderTicketEntitiesVo
>
oteVoList
=
mongoTemplate
.
find
(
orderTicketEntitiesVoQuery
,
KylinOrderTicketEntitiesVo
.
class
,
KylinOrderTicketEntitiesVo
.
class
.
getSimpleName
());
log
.
debug
(
"oteVoList:{}"
,
JsonUtils
.
toJson
(
oteVoList
));
// 转换订单票明细结构为Map<performanceId, List<KylinOrderTicketEntitiesVo>>
// 转换订单票明细结构为Map<performanceId, List<KylinOrderTicketEntitiesVo>>
Map
<
String
,
List
<
KylinOrderTicketEntitiesVo
>>
oteVoMap
=
oteVoList
.
stream
().
collect
(
Collectors
.
groupingBy
(
KylinOrderTicketEntitiesVo:
:
getPerformanceId
));
Map
<
String
,
List
<
KylinOrderTicketEntitiesVo
>>
oteVoMap
=
oteVoList
.
stream
().
collect
(
Collectors
.
groupingBy
(
KylinOrderTicketEntitiesVo:
:
getPerformanceId
));
...
@@ -190,8 +191,10 @@ public class KylinStationController {
...
@@ -190,8 +191,10 @@ public class KylinStationController {
oteVoList
.
stream
().
filter
(
distinctByKey
(
KylinOrderTicketEntitiesVo:
:
getTicketId
)).
map
(
KylinOrderTicketEntitiesVo:
:
getTicketId
).
toArray
()
oteVoList
.
stream
().
filter
(
distinctByKey
(
KylinOrderTicketEntitiesVo:
:
getTicketId
)).
map
(
KylinOrderTicketEntitiesVo:
:
getTicketId
).
toArray
()
));
));
List
<
KylinTicketVo
>
performanceTicketVoList
=
mongoTemplate
.
find
(
performanceTicketVoQuery
,
KylinTicketVo
.
class
,
KylinTicketVo
.
class
.
getSimpleName
());
List
<
KylinTicketVo
>
performanceTicketVoList
=
mongoTemplate
.
find
(
performanceTicketVoQuery
,
KylinTicketVo
.
class
,
KylinTicketVo
.
class
.
getSimpleName
());
log
.
debug
(
"performanceTicketVoList:{}"
,
JsonUtils
.
toJson
(
performanceTicketVoList
));
// 转换票种信息结构为Map<ticketsId, ticketVo>
// 转换票种信息结构为Map<ticketsId, ticketVo>
Map
<
String
,
KylinTicketVo
>
performanceTicketMap
=
performanceTicketVoList
.
stream
().
collect
(
Collectors
.
toMap
(
KylinTicketVo:
:
getTicketsId
,
Function
.
identity
(),
(
k1
,
k2
)
->
k2
));
Map
<
String
,
KylinTicketVo
>
performanceTicketMap
=
performanceTicketVoList
.
stream
().
collect
(
Collectors
.
toMap
(
KylinTicketVo:
:
getTicketsId
,
Function
.
identity
(),
(
k1
,
k2
)
->
k2
));
log
.
debug
(
"performanceTicketMap:{}"
,
JsonUtils
.
toJson
(
performanceTicketMap
));
// 转换Map<performanceId, canDownTime>
// 转换Map<performanceId, canDownTime>
Map
<
String
,
String
>
performanceRelationMap
=
performanceRelationList
.
stream
().
collect
(
Collectors
.
toMap
(
CheckPerformanceRelationParam:
:
getPerformanceId
,
CheckPerformanceRelationParam:
:
getCanDownTime
));
Map
<
String
,
String
>
performanceRelationMap
=
performanceRelationList
.
stream
().
collect
(
Collectors
.
toMap
(
CheckPerformanceRelationParam:
:
getPerformanceId
,
CheckPerformanceRelationParam:
:
getCanDownTime
));
log
.
debug
(
"performanceRelationMap:{}"
,
JsonUtils
.
toJson
(
performanceRelationMap
));
log
.
debug
(
"performanceRelationMap:{}"
,
JsonUtils
.
toJson
(
performanceRelationMap
));
...
...
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