记得上下班打卡 | 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
dcfbefb2
Commit
dcfbefb2
authored
Jun 25, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/dev' into dev
parents
65fd947c
893d83ee
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
23 additions
and
20 deletions
+23
-20
liquidnet-service-adam.yml
...et-bus-config/liquidnet-config/liquidnet-service-adam.yml
+1
-1
liquidnet-service-kylin.yml
...t-bus-config/liquidnet-config/liquidnet-service-kylin.yml
+1
-1
KylinPerformancesMapper.xml
...iquidnet.service.kylin.mapper/KylinPerformancesMapper.xml
+20
-17
KylinStationController.java
...dnet/service/kylin/controller/KylinStationController.java
+1
-1
No files found.
liquidnet-bus-config/liquidnet-config/liquidnet-service-adam.yml
View file @
dcfbefb2
...
@@ -28,7 +28,7 @@ logging:
...
@@ -28,7 +28,7 @@ logging:
console
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
console
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
rolling-file-name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
rolling-file-name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
level
:
level
:
root
:
${liquidnet.logfile.level}
root
:
info
#以下是为指定包设置日志级别
#以下是为指定包设置日志级别
com.liquidnet
:
${liquidnet.logfile.level}
com.liquidnet
:
${liquidnet.logfile.level}
# -----------------------------------------------------------
# -----------------------------------------------------------
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-kylin.yml
View file @
dcfbefb2
...
@@ -28,7 +28,7 @@ logging:
...
@@ -28,7 +28,7 @@ logging:
console
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
console
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
rolling-file-name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
rolling-file-name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
level
:
level
:
root
:
${liquidnet.logfile.level}
root
:
info
#以下是为指定包设置日志级别
#以下是为指定包设置日志级别
com
:
com
:
liquidnet
:
${liquidnet.logfile.level}
liquidnet
:
${liquidnet.logfile.level}
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinPerformancesMapper.xml
View file @
dcfbefb2
...
@@ -394,7 +394,7 @@
...
@@ -394,7 +394,7 @@
kt.use_start,
kt.use_start,
IFNULL(kts.total_general , 0) AS 'total_general' ,
IFNULL(kts.total_general , 0) AS 'total_general' ,
IFNULL(ot.total_sale_general , 0) AS 'sale_general' ,
IFNULL(ot.total_sale_general , 0) AS 'sale_general' ,
IFNULL((kts.total_general -
ot.total_sale_general
),0) AS 'surplus_general',
IFNULL((kts.total_general -
IFNULL(ot.total_sale_general,0)
),0) AS 'surplus_general',
IFNULL(ot.total_sale_price , 0) AS 'total_sale_price' ,
IFNULL(ot.total_sale_price , 0) AS 'total_sale_price' ,
IFNULL(kts.total_exchange , 0) AS 'total_exchange',
IFNULL(kts.total_exchange , 0) AS 'total_exchange',
IFNULL(ot.total_refund_general , 0) AS 'total_refund_general',
IFNULL(ot.total_refund_general , 0) AS 'total_refund_general',
...
@@ -403,8 +403,11 @@
...
@@ -403,8 +403,11 @@
IFNULL(otp.total_paying_number , 1) AS 'total_paying_number',
IFNULL(otp.total_paying_number , 1) AS 'total_paying_number',
IFNULL(ut.total_buy_users , 0) AS 'total_buy_users'
IFNULL(ut.total_buy_users , 0) AS 'total_buy_users'
FROM
FROM
(select t.performances_id from kylin_performances t where t.performances_id = ${performancesId}) AS kp
(select t.performances_id,ktr.ticket_id from kylin_performances t inner join kylin_ticket_time_relation kttr
inner JOIN(
on t.performances_id = kttr.performance_id
inner join kylin_ticket_relations ktr on kttr.times_id = ktr.times_id
where t.performances_id = ${performancesId}) AS kp
left JOIN(
SELECT
SELECT
kotr.performance_id AS 'performance_id',
kotr.performance_id AS 'performance_id',
kotr.ticket_id,
kotr.ticket_id,
...
@@ -420,7 +423,7 @@
...
@@ -420,7 +423,7 @@
WHERE 1>0 and kotr.performance_id = ${performancesId}
WHERE 1>0 and kotr.performance_id = ${performancesId}
and kots.`status` in(1,3,4) and kot.coupon_type ='no'
and kots.`status` in(1,3,4) and kot.coupon_type ='no'
group by kotr.performance_id,kotr.ticket_id
group by kotr.performance_id,kotr.ticket_id
) AS ot ON
ot.performance_id = kp.performances_id
) AS ot ON
(ot.performance_id = kp.performances_id and ot.ticket_id = kp.ticket_id)
left JOIN(
left JOIN(
SELECT
SELECT
kotr.performance_id,kotr.ticket_id,
kotr.performance_id,kotr.ticket_id,
...
@@ -432,21 +435,21 @@
...
@@ -432,21 +435,21 @@
WHERE 1>0 and kotr.performance_id = ${performancesId}
WHERE 1>0 and kotr.performance_id = ${performancesId}
and kots.`status` = 0 and kot.coupon_type ='no'
and kots.`status` = 0 and kot.coupon_type ='no'
group by kotr.performance_id,kotr.ticket_id
group by kotr.performance_id,kotr.ticket_id
) AS otp ON
otp.performance_id = kp.performances_id
) AS otp ON
(otp.performance_id = kp.performances_id and otp.ticket_id = kp.ticket_id)
inner join kylin_tickets kt on kt.tickets_id = ot
.ticket_id
left join kylin_tickets kt on kt.tickets_id = kp
.ticket_id
inner join kylin_ticket_status kts on kts.ticket_id = kt.tickets
_id
left join kylin_ticket_status kts on kts.ticket_id = kp.ticket
_id
inner JOIN(
inner JOIN(
select t.performance_id,count(t.user_id) as 'total_buy_users' from(
select t.performance_id,count(t.user_id) as 'total_buy_users' from(
SELECT
SELECT
kotr.performance_id,
kotr.performance_id,
kot.user_id
kot.user_id
FROM
FROM
kylin_order_ticket_relations kotr
kylin_order_ticket_relations kotr
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
WHERE kotr.performance_id = ${performancesId} and (kots.`status` = 0 OR kots.`status` = 1)
WHERE kotr.performance_id = ${performancesId} and (kots.`status` = 0 OR kots.`status` = 1)
group by kotr.performance_id,kot.user_id
group by kotr.performance_id,kot.user_id
) t
) t
) AS ut ON ut.performance_id = kp.performances_id
) AS ut ON ut.performance_id = kp.performances_id
</select>
</select>
<select
id=
"getPerformanceSponsorList"
resultMap=
"performanceSponsorDaoResult"
>
<select
id=
"getPerformanceSponsorList"
resultMap=
"performanceSponsorDaoResult"
>
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinStationController.java
View file @
dcfbefb2
...
@@ -190,7 +190,7 @@ public class KylinStationController {
...
@@ -190,7 +190,7 @@ public class KylinStationController {
Query
performanceTicketVoQuery
=
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
in
(
Query
performanceTicketVoQuery
=
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
in
(
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
,
Kylin
Ticket
Vo
.
class
.
getSimpleName
());
List
<
KylinTicketVo
>
performanceTicketVoList
=
mongoTemplate
.
find
(
performanceTicketVoQuery
,
KylinTicketVo
.
class
,
Kylin
Performance
Vo
.
class
.
getSimpleName
());
log
.
debug
(
"performanceTicketVoList:{}"
,
JsonUtils
.
toJson
(
performanceTicketVoList
));
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
));
...
...
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