记得上下班打卡 | 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
de59b98c
Commit
de59b98c
authored
Jun 25, 2021
by
张国柄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
验票 + log;
parent
d6d7a086
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
4 additions
and
2 deletions
+4
-2
KylinStationController.java
...dnet/service/kylin/controller/KylinStationController.java
+4
-2
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 @
de59b98c
...
@@ -33,6 +33,7 @@ import org.springframework.util.DigestUtils;
...
@@ -33,6 +33,7 @@ import org.springframework.util.DigestUtils;
import
org.springframework.util.LinkedMultiValueMap
;
import
org.springframework.util.LinkedMultiValueMap
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.bind.annotation.*
;
import
springfox.documentation.spring.web.json.Json
;
import
javax.validation.constraints.NotBlank
;
import
javax.validation.constraints.NotBlank
;
import
javax.validation.constraints.Pattern
;
import
javax.validation.constraints.Pattern
;
...
@@ -136,6 +137,7 @@ public class KylinStationController {
...
@@ -136,6 +137,7 @@ public class KylinStationController {
if
(
null
!=
checkUserRelationVo
)
{
if
(
null
!=
checkUserRelationVo
)
{
List
<
CheckPerformanceRelationParam
>
performanceRelationList
=
checkUserRelationVo
.
getRelationParams
();
List
<
CheckPerformanceRelationParam
>
performanceRelationList
=
checkUserRelationVo
.
getRelationParams
();
if
(!
CollectionUtils
.
isEmpty
(
performanceRelationList
))
{
if
(!
CollectionUtils
.
isEmpty
(
performanceRelationList
))
{
log
.
debug
(
"performanceRelationList:{}"
,
JsonUtils
.
toJson
(
performanceRelationList
));
LocalDateTime
tmpDt
=
LocalDateTime
.
of
(
LocalDate
.
now
(),
LocalTime
.
of
(
0
,
0
,
0
,
0
));
LocalDateTime
tmpDt
=
LocalDateTime
.
of
(
LocalDate
.
now
(),
LocalTime
.
of
(
0
,
0
,
0
,
0
));
String
tmpDtStr
=
DateUtil
.
format
(
tmpDt
,
DateUtil
.
Formatter
.
yyyyMMddHHmmss
);
String
tmpDtStr
=
DateUtil
.
format
(
tmpDt
,
DateUtil
.
Formatter
.
yyyyMMddHHmmss
);
Criteria
criteria
=
Criteria
.
where
(
"performancesId"
).
in
(
Criteria
criteria
=
Criteria
.
where
(
"performancesId"
).
in
(
...
@@ -174,7 +176,7 @@ public class KylinStationController {
...
@@ -174,7 +176,7 @@ public class KylinStationController {
performancesVoQuery
.
with
(
PageRequest
.
of
(
pageNo
-
1
,
pageSize
));
performancesVoQuery
.
with
(
PageRequest
.
of
(
pageNo
-
1
,
pageSize
));
performancesVoQuery
.
with
(
Sort
.
by
(
Sort
.
Order
.
asc
(
"timeEnd"
),
Sort
.
Order
.
desc
(
"sort"
)));
performancesVoQuery
.
with
(
Sort
.
by
(
Sort
.
Order
.
asc
(
"timeEnd"
),
Sort
.
Order
.
desc
(
"sort"
)));
voList
=
mongoTemplate
.
find
(
performancesVoQuery
,
KylinStationPerformanceVo
.
class
,
KylinPerformanceVo
.
class
.
getSimpleName
());
voList
=
mongoTemplate
.
find
(
performancesVoQuery
,
KylinStationPerformanceVo
.
class
,
KylinPerformanceVo
.
class
.
getSimpleName
());
log
.
debug
(
"voList:{}"
,
JsonUtils
.
toJson
(
voList
));
// 查取演出对应的订单票明细
// 查取演出对应的订单票明细
Query
orderTicketEntitiesVoQuery
=
Query
.
query
(
Criteria
.
where
(
"performanceId"
).
in
(
Query
orderTicketEntitiesVoQuery
=
Query
.
query
(
Criteria
.
where
(
"performanceId"
).
in
(
voList
.
stream
().
map
(
KylinStationPerformanceVo:
:
getPerformancesId
).
toArray
()
voList
.
stream
().
map
(
KylinStationPerformanceVo:
:
getPerformancesId
).
toArray
()
...
@@ -192,7 +194,7 @@ public class KylinStationController {
...
@@ -192,7 +194,7 @@ public class KylinStationController {
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
));
// 转换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
));
// 补充演出列表票种统计
// 补充演出列表票种统计
for
(
KylinStationPerformanceVo
r
:
voList
)
{
for
(
KylinStationPerformanceVo
r
:
voList
)
{
// 演出的所有订单票明细
// 演出的所有订单票明细
...
...
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