记得上下班打卡 | 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
6859aa68
Commit
6859aa68
authored
Sep 24, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
增加 大麦同步日志
修改 大麦数据查询
parent
1a4c322a
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
6 additions
and
7 deletions
+6
-7
KylinDamaiServiceImpl.java
...in/zhengzai/kylin/service/impl/KylinDamaiServiceImpl.java
+4
-5
KylinOrderTicketsMapper.xml
...iquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
+2
-2
No files found.
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinDamaiServiceImpl.java
View file @
6859aa68
...
...
@@ -80,8 +80,8 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
obj1
.
setSystemId
(
taobaoTicketUtils
.
getSystemId
());
req
.
setPushProjectParam
(
obj1
);
log
.
info
(
"[同步演出] 演出名称 = "
+
performanceData
.
getTitle
()
+
" 大麦演出id ="
+
performanceKey
);
AlibabaDamaiMevOpenPushprojectResponse
rsp
=
client
.
execute
(
req
);
log
.
info
(
"performance="
+
rsp
.
getBody
());
if
(
rsp
.
getResult
().
getSuccess
())
{
List
<
KylinTicketTimeRelation
>
timeRelation
=
ticketTimeRelationMapper
.
selectList
(
new
UpdateWrapper
<
KylinTicketTimeRelation
>().
eq
(
"performance_id"
,
performanceId
));
for
(
int
i
=
0
;
i
<
timeRelation
.
size
();
i
++)
{
...
...
@@ -117,8 +117,8 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
obj1
.
setSupplierSecret
(
taobaoTicketUtils
.
getSupplierSecret
());
obj1
.
setSystemId
(
taobaoTicketUtils
.
getSystemId
());
req
.
setPushPerformParam
(
obj1
);
log
.
info
(
"[同步场次] 场次名称 = "
+
timesData
.
getTitle
()
+
" 大麦场次id ="
+
ticketTimesKey
);
AlibabaDamaiMevOpenPushperformResponse
rsp
=
client
.
execute
(
req
);
log
.
info
(
"times = "
+
rsp
.
getBody
());
if
(
rsp
.
getResult
().
getSuccess
())
{
List
<
KylinTicketRelations
>
ticketRelation
=
ticketRelationsMapper
.
selectList
(
new
UpdateWrapper
<
KylinTicketRelations
>().
eq
(
"times_id"
,
timesData
.
getTicketTimesId
()));
for
(
int
i
=
0
;
i
<
ticketRelation
.
size
();
i
++)
{
...
...
@@ -155,8 +155,8 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
obj1
.
setSystemId
(
taobaoTicketUtils
.
getSystemId
());
// obj1.setRemark("0");
req
.
setPushItemParam
(
obj1
);
log
.
info
(
"[同步票种] 票种名称 = "
+
ticketsData
.
getTitle
()
+
" 大麦票种id ="
+
ticketIdKey
);
AlibabaDamaiMevOpenPushitemResponse
rsp
=
client
.
execute
(
req
);
log
.
info
(
"ticket = "
+
rsp
.
getBody
());
if
(
rsp
.
getResult
().
getSuccess
())
{
return
sycOrder
(
timemId
,
ticketsData
.
getTicketsId
(),
ticketIdKey
);
// return true;
...
...
@@ -175,7 +175,7 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
TaobaoClient
client
=
taobaoTicketUtils
.
initTaobaoClient
();
AlibabaDamaiMevOpenBatchpushticketRequest
req
=
new
AlibabaDamaiMevOpenBatchpushticketRequest
();
List
<
OrderPushDamaiDto
>
data
=
orderTicketsMapper
.
pushDamaiDetailsList
(
ticketsId
);
log
.
info
(
"
data = "
+
data
.
size
()
+
" ticketsId
="
+
ticketsId
);
log
.
info
(
"
[同步订单] 票种张数 = "
+
data
.
size
()
+
" 票种id
="
+
ticketsId
);
int
forSize
=
100
;
int
forCount
=
data
.
size
()
%
forSize
==
0
?
data
.
size
()
/
forSize
:
(
data
.
size
()
/
forSize
)
+
1
;
for
(
int
i
=
0
;
i
<
forCount
;
i
++)
{
...
...
@@ -217,7 +217,6 @@ public class KylinDamaiServiceImpl extends ServiceImpl<KylinRoadShowsMapper, Kyl
}
}
req
.
setThirdTicketSetOpenParamList
(
list2
);
log
.
info
(
"list2 = "
+
list2
.
size
());
if
(
list2
.
size
()
==
0
)
{
return
true
;
}
else
{
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
View file @
6859aa68
...
...
@@ -254,8 +254,8 @@
LEFT JOIN kylin_order_ticket_relations AS otr ON otr.order_id = ot.order_tickets_id
LEFT JOIN kylin_order_ticket_entities AS ote ON ote.order_id = ot.order_tickets_id
LEFT JOIN kylin_ticket_status AS kys ON kys.ticket_id = otr.ticket_id
WHERE (ots.status = 1 or ots.status = 3)
AND
kys.sync_damai
= 1
WHERE (ots.status = 1 or ots.status = 3
or ots.status = 6
)
AND
is_payment
= 1
AND ote.ticket_id = ${ticketsId}
</select>
...
...
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