记得上下班打卡 | 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
85069ab4
Commit
85069ab4
authored
Aug 20, 2021
by
Administrator
🎨
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'pre' into 'master'
Pre See merge request
!20
parents
c58e0b46
9d0068eb
Changes
5
Show whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
31 additions
and
23 deletions
+31
-23
KylinPerformancesAdminServiceImpl.java
...kylin/service/impl/KylinPerformancesAdminServiceImpl.java
+24
-20
KylinOrderTicketsMapper.java
...quidnet/service/kylin/mapper/KylinOrderTicketsMapper.java
+1
-1
KylinOrderTicketsMapper.xml
...iquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
+1
-1
KylinTicketTimesPartnerServiceImpl.java
...vice/impl/partner/KylinTicketTimesPartnerServiceImpl.java
+2
-1
PerformanceVoTask.java
...m/liquidnet/service/platform/utils/PerformanceVoTask.java
+3
-0
No files found.
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinPerformancesAdminServiceImpl.java
View file @
85069ab4
...
...
@@ -654,17 +654,20 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
//找到所有ticketId
List
<
TicketTimesTicketCreatePartnerVo
>
timesVoList
=
vo
.
getTicketTimes
();
for
(
TicketTimesTicketCreatePartnerVo
timesVo
:
timesVoList
)
{
for
(
KylinTicketPartnerVo
ticketVo
:
timesVo
.
getTicket
()){
List
<
String
>
orderTicketRedisIdList
=
new
ArrayList
<>();
List
<
String
>
userRedisIdList
=
new
ArrayList
<>();
List
<
String
>
orderTicketIdList
=
new
ArrayList
<>();
List
<
OrderIdsDao
>
orderIdsDaoList
=
kylinOrderTicketsMapper
.
getOrderUserIdByTimesId
(
timesVo
.
getTicketTimesId
());
log
.
info
(
"修改场次相关 mysql ticketId -> "
+
ticketVo
.
getTicketsId
());
List
<
OrderIdsDao
>
orderIdsDaoList
=
kylinOrderTicketsMapper
.
getOrderUserIdByTimesId
(
ticketVo
.
getTicketsId
());
log
.
info
(
"修改场次相关 mysql data -> "
+
orderIdsDaoList
.
size
());
for
(
OrderIdsDao
item
:
orderIdsDaoList
)
{
orderTicketRedisIdList
.
add
(
KylinRedisConst
.
ORDER
+
item
.
getOrderTicketsId
());
userRedisIdList
.
add
(
KylinRedisConst
.
ORDER_LIST
+
item
.
getUserId
());
orderTicketIdList
.
add
(
item
.
getOrderTicketsId
());
}
HashMap
<
String
,
Object
>
mapMongo
=
new
HashMap
<>();
mapMongo
.
put
(
"useStart"
,
times
Vo
.
getUseStart
());
mapMongo
.
put
(
"useStart"
,
ticket
Vo
.
getUseStart
());
long
time1
=
System
.
currentTimeMillis
();
mongoTemplate
.
getCollection
(
KylinOrderTicketVo
.
class
.
getSimpleName
()).
updateMany
(
Query
.
query
(
Criteria
.
where
(
"orderTicketsId"
).
in
(
orderTicketIdList
)).
getQueryObject
(),
...
...
@@ -677,4 +680,5 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
log
.
debug
(
"修改场次相关 redis time -> "
+
(
System
.
currentTimeMillis
()
-
time1
)
+
" ms "
);
}
}
}
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderTicketsMapper.java
View file @
85069ab4
...
...
@@ -35,6 +35,6 @@ public interface KylinOrderTicketsMapper extends BaseMapper<KylinOrderTickets> {
List
<
KylinOrderTickets
>
getCanPlaceOrderList
(
@Param
(
"performanceId"
)
String
performanceId
,
@Param
(
"mid"
)
int
mid
,
@Param
(
"limitNum"
)
int
limitNum
);
List
<
OrderIdsDao
>
getOrderUserIdByTimesId
(
@Param
(
"ti
meId"
)
String
time
Id
);
List
<
OrderIdsDao
>
getOrderUserIdByTimesId
(
@Param
(
"ti
cketId"
)
String
ticket
Id
);
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
View file @
85069ab4
...
...
@@ -344,6 +344,6 @@
<select
id=
"getOrderUserIdByTimesId"
resultType=
"com.liquidnet.service.kylin.dao.OrderIdsDao"
>
select order_tickets_id,user_id from kylin_order_tickets as kot left join kylin_order_ticket_relations as kotr on kotr.order_id = kot.order_tickets_id
where ti
me_id =#{time
Id}
where ti
cket_id =#{ticket
Id}
</select>
</mapper>
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketTimesPartnerServiceImpl.java
View file @
85069ab4
...
...
@@ -240,7 +240,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
ticketMap
.
put
(
"useEnd"
,
kylinTicketTimesPartnerVo
.
getUseEnd
());
ticketMap
.
put
(
"useStart"
,
kylinTicketTimesPartnerVo
.
getUseStart
());
BasicDBObject
ticketObject
=
ObjectUtil
.
cloneBasicDBObject
().
append
(
"$set"
,
ticketMap
);
mongoTemplate
.
getCollection
(
KylinTicketPartnerVo
.
class
.
getSimpleName
()).
update
One
(
mongoTemplate
.
getCollection
(
KylinTicketPartnerVo
.
class
.
getSimpleName
()).
update
Many
(
Query
.
query
(
Criteria
.
where
(
"timesId"
).
is
(
createTicketTimesParam
.
getTicketTimesId
())).
getQueryObject
(),
ticketObject
);
...
...
@@ -248,6 +248,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"changeTimes"
,
createTicketTimesParam
,
JsonUtils
.
fromJson
(
doc
.
toJson
(),
KylinTicketTimesPartnerVo
.
class
)));
return
ResponseDto
.
success
(
JsonUtils
.
fromJson
(
doc
.
toJson
(),
KylinTicketTimesPartnerVo
.
class
));
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
20103
));
}
}
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/PerformanceVoTask.java
View file @
85069ab4
...
...
@@ -387,6 +387,9 @@ public class PerformanceVoTask {
if
(!
misVo
.
getTitle
().
equals
(
mongoVo
.
getTitle
()))
{
log
.
debug
(
"NEED CHANGE TITLE"
);
return
true
;
}
if
(!
misVo
.
getImgPoster
().
equals
(
mongoVo
.
getImgPoster
()))
{
log
.
debug
(
"NEED CHANGE IMGPOSTER"
);
return
true
;
}
else
if
(!
misVo
.
getType
().
equals
(
mongoVo
.
getType
()))
{
log
.
debug
(
"NEED CHANGE TYPE"
);
return
true
;
...
...
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