记得上下班打卡 | 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
32cfc71a
Commit
32cfc71a
authored
Sep 23, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'master' into dev_export_
parents
b625f2e8
2a93dc3d
Changes
8
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
101 additions
and
112 deletions
+101
-112
DamaiService.java
...m/liquidnet/service/kylin/service/other/DamaiService.java
+0
-2
KylinDamaiServiceImpl.java
...in/zhengzai/kylin/service/impl/KylinDamaiServiceImpl.java
+55
-86
IDGenerator.java
...ain/java/com/liquidnet/commons/lang/util/IDGenerator.java
+20
-10
OrderPushDamaiDto.java
...va/com/liquidnet/service/kylin/dao/OrderPushDamaiDto.java
+1
-0
KylinOrderTicketsMapper.xml
...iquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
+4
-2
KylinOrderTicketsServiceImpl.java
...vice/order/service/impl/KylinOrderTicketsServiceImpl.java
+19
-10
SweetAppletMdskController.java
...t/service/sweet/controller/SweetAppletMdskController.java
+1
-1
SweetManualMdskMapper.xml
.../liquidnet/service/sweet/mapper/SweetManualMdskMapper.xml
+1
-1
No files found.
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/other/DamaiService.java
View file @
32cfc71a
...
@@ -4,8 +4,6 @@ import com.liquidnet.service.kylin.entity.KylinTicketTimes;
...
@@ -4,8 +4,6 @@ import com.liquidnet.service.kylin.entity.KylinTicketTimes;
import
com.liquidnet.service.kylin.entity.KylinTickets
;
import
com.liquidnet.service.kylin.entity.KylinTickets
;
public
interface
DamaiService
{
public
interface
DamaiService
{
//同步场地
Boolean
sycField
(
String
fieldId
);
//同步演出
//同步演出
Boolean
sycPerformance
(
String
performanceId
);
Boolean
sycPerformance
(
String
performanceId
);
//同步场次
//同步场次
...
...
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 @
32cfc71a
This diff is collapsed.
Click to expand it.
liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/util/IDGenerator.java
View file @
32cfc71a
package
com
.
liquidnet
.
commons
.
lang
.
util
;
package
com
.
liquidnet
.
commons
.
lang
.
util
;
import
org.apache.commons.lang3.StringUtils
;
import
java.time.LocalDateTime
;
import
java.time.LocalDateTime
;
import
java.time.format.DateTimeFormatter
;
import
java.time.format.DateTimeFormatter
;
import
java.util.UUID
;
import
java.util.UUID
;
...
@@ -45,12 +47,20 @@ public class IDGenerator {
...
@@ -45,12 +47,20 @@ public class IDGenerator {
return
orderCode
;
return
orderCode
;
}
}
public
static
String
payCode
(){
public
static
Long
getDamaiCode
(
String
code
)
{
return
"PAY"
+
nextTimeId
();
if
(
code
.
length
()
<
13
)
{
return
Long
.
valueOf
(
code
);
}
else
{
return
Long
.
valueOf
(
StringUtils
.
left
(
code
,
5
).
concat
(
StringUtils
.
right
(
code
,
8
)));
}
}
public
static
String
payCode
()
{
return
"PAY"
+
nextTimeId
();
}
}
public
static
String
refundCode
(){
public
static
String
refundCode
()
{
return
"RED"
+
nextTimeId
();
return
"RED"
+
nextTimeId
();
}
}
/**
/**
...
@@ -65,11 +75,11 @@ public class IDGenerator {
...
@@ -65,11 +75,11 @@ public class IDGenerator {
}
}
public
static
void
main
(
String
[]
args
)
{
public
static
void
main
(
String
[]
args
)
{
System
.
out
.
println
(
""
+
IDGenerator
.
payCode
());
System
.
out
.
println
(
""
+
IDGenerator
.
payCode
());
System
.
out
.
println
(
""
+
IDGenerator
.
refundCode
());
System
.
out
.
println
(
""
+
IDGenerator
.
refundCode
());
System
.
out
.
println
(
"nextTimeId==="
+
IDGenerator
.
nextTimeId
());
System
.
out
.
println
(
"nextTimeId==="
+
IDGenerator
.
nextTimeId
());
System
.
out
.
println
(
"nextMilliId==="
+
IDGenerator
.
nextMilliId
());
System
.
out
.
println
(
"nextMilliId==="
+
IDGenerator
.
nextMilliId
());
System
.
out
.
println
(
"nextSnowId==="
+
IDGenerator
.
nextSnowId
());
System
.
out
.
println
(
"nextSnowId==="
+
IDGenerator
.
nextSnowId
());
System
.
out
.
println
(
"get32UUID==="
+
IDGenerator
.
get32UUID
());
System
.
out
.
println
(
"get32UUID==="
+
IDGenerator
.
get32UUID
());
}
}
}
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/dao/OrderPushDamaiDto.java
View file @
32cfc71a
...
@@ -26,4 +26,5 @@ public class OrderPushDamaiDto {
...
@@ -26,4 +26,5 @@ public class OrderPushDamaiDto {
Integer
isMember
;
Integer
isMember
;
String
orderTicketEntitiesId
;
String
orderTicketEntitiesId
;
String
getTicketType
;
String
getTicketType
;
Integer
transferStatus
;
}
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
View file @
32cfc71a
...
@@ -42,6 +42,7 @@
...
@@ -42,6 +42,7 @@
<result
column=
"is_member"
property=
"isMember"
/>
<result
column=
"is_member"
property=
"isMember"
/>
<result
column=
"order_ticket_entities_id"
property=
"orderTicketEntitiesId"
/>
<result
column=
"order_ticket_entities_id"
property=
"orderTicketEntitiesId"
/>
<result
column=
"get_ticket_type"
property=
"getTicketType"
/>
<result
column=
"get_ticket_type"
property=
"getTicketType"
/>
<result
column=
"transfer_status"
property=
"transferStatus"
/>
</resultMap>
</resultMap>
<resultMap
id=
"orderScriptDtoResult"
type=
"com.liquidnet.service.kylin.dao.OrderScriptDto"
>
<resultMap
id=
"orderScriptDtoResult"
type=
"com.liquidnet.service.kylin.dao.OrderScriptDto"
>
...
@@ -246,13 +247,14 @@
...
@@ -246,13 +247,14 @@
otr.ticket_id,
otr.ticket_id,
otr.is_member,
otr.is_member,
ote.order_ticket_entities_id,
ote.order_ticket_entities_id,
get_ticket_type
get_ticket_type,
ots.transfer_status
FROM kylin_order_tickets AS ot
FROM kylin_order_tickets AS ot
LEFT JOIN kylin_order_ticket_status AS ots ON ots.order_id = ot.order_tickets_id
LEFT JOIN kylin_order_ticket_status AS ots ON ots.order_id = ot.order_tickets_id
LEFT JOIN kylin_order_ticket_relations AS otr ON otr.order_id = ot.order_tickets_id
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_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
LEFT JOIN kylin_ticket_status AS kys ON kys.ticket_id = otr.ticket_id
WHERE
ots.pay_status = 1
WHERE
(ots.status = 1 or ots.status = 3)
AND kys.sync_damai = 1
AND kys.sync_damai = 1
AND ote.ticket_id = ${ticketsId}
AND ote.ticket_id = ${ticketsId}
</select>
</select>
...
...
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java
View file @
32cfc71a
...
@@ -118,6 +118,15 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -118,6 +118,15 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
}
}
}
}
if
(
payOrderParam
.
getIsExpress
().
equals
(
1
)
&&
ticketData
.
getIsExpress
().
equals
(
0
))
{
return
ResponseDto
.
failure
(
"票种类型错误"
);
//参数错误
}
else
if
(
payOrderParam
.
getIsElectronic
().
equals
(
1
)
&&
ticketData
.
getIsElectronic
().
equals
(
0
))
{
return
ResponseDto
.
failure
(
"票种类型错误"
);
//参数错误
}
else
if
(
payOrderParam
.
getIsExpress
().
equals
(
0
)
&&
payOrderParam
.
getIsElectronic
().
equals
(
0
)){
return
ResponseDto
.
failure
(
"票种类型错误"
);
//参数错误
}
if
(
performanceData
==
null
||
ticketTimesData
==
null
||
ticketData
==
null
)
{
if
(
performanceData
==
null
||
ticketTimesData
==
null
||
ticketData
==
null
)
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20004"
));
//参数错误
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20004"
));
//参数错误
}
}
...
@@ -489,10 +498,10 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -489,10 +498,10 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
}
}
//是否免费
//是否免费
boolean
isFree
=
false
;
boolean
isFree
=
false
;
PayResultVo
payResultVo
;
PayResultVo
payResultVo
;
if
(
orderTickets
.
getPriceActual
().
compareTo
(
BigDecimal
.
valueOf
(
0
))>
0
)
{
if
(
orderTickets
.
getPriceActual
().
compareTo
(
BigDecimal
.
valueOf
(
0
))
>
0
)
{
// 调用支付
// 调用支付
String
time1
=
DateUtil
.
format
(
DateUtil
.
Formatter
.
yyyyMMddHHmmss
.
parse
(
ticketData
.
getUseStart
()),
DateUtil
.
Formatter
.
MM_dd_zh
);
String
time1
=
DateUtil
.
format
(
DateUtil
.
Formatter
.
yyyyMMddHHmmss
.
parse
(
ticketData
.
getUseStart
()),
DateUtil
.
Formatter
.
MM_dd_zh
);
String
time2
=
DateUtil
.
format
(
DateUtil
.
Formatter
.
yyyyMMddHHmmss
.
parse
(
ticketData
.
getUseEnd
()),
DateUtil
.
Formatter
.
MM_dd_zh
);
String
time2
=
DateUtil
.
format
(
DateUtil
.
Formatter
.
yyyyMMddHHmmss
.
parse
(
ticketData
.
getUseEnd
()),
DateUtil
.
Formatter
.
MM_dd_zh
);
...
@@ -529,8 +538,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -529,8 +538,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
payResultVo
.
getData
().
setShowUrl
(
payOrderParam
.
getShowUrl
()
+
orderTicketId
);
payResultVo
.
getData
().
setShowUrl
(
payOrderParam
.
getShowUrl
()
+
orderTicketId
);
payResultVo
.
getData
().
setReturnUrl
(
payOrderParam
.
getReturnUrl
()
+
orderTicketId
);
payResultVo
.
getData
().
setReturnUrl
(
payOrderParam
.
getReturnUrl
()
+
orderTicketId
);
}
}
}
else
{
}
else
{
isFree
=
true
;
isFree
=
true
;
orderTickets
.
setPayType
(
"FREE"
);
orderTickets
.
setPayType
(
"FREE"
);
orderTickets
.
setPayCode
(
"FREE_PAY_CODE"
);
orderTickets
.
setPayCode
(
"FREE_PAY_CODE"
);
payResultVo
=
PayResultVo
.
getNew
();
payResultVo
=
PayResultVo
.
getNew
();
...
@@ -573,10 +582,10 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -573,10 +582,10 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
currentTime
=
System
.
currentTimeMillis
()
-
currentTime
;
currentTime
=
System
.
currentTimeMillis
()
-
currentTime
;
log
.
debug
(
"MQ 发送 -> time:"
+
(
currentTime
)
+
"毫秒"
);
log
.
debug
(
"MQ 发送 -> time:"
+
(
currentTime
)
+
"毫秒"
);
log
.
info
(
UserPathDto
.
setData
(
"下单(唤起支付)"
,
payOrderParam
,
payResultVo
.
getData
()));
log
.
info
(
UserPathDto
.
setData
(
"下单(唤起支付)"
,
payOrderParam
,
payResultVo
.
getData
()));
if
(
isFree
)
{
if
(
isFree
)
{
SyncOrderParam
syncOrderParam
=
SyncOrderParam
.
getNew
();
SyncOrderParam
syncOrderParam
=
SyncOrderParam
.
getNew
();
syncOrderParam
.
setOrderCode
(
orderTickets
.
getOrderCode
());
syncOrderParam
.
setOrderCode
(
orderTickets
.
getOrderCode
());
syncOrderParam
.
setPaymentAt
(
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMddHHmmss
));
syncOrderParam
.
setPaymentAt
(
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMddHHmmss
));
syncOrderParam
.
setCode
(
orderTickets
.
getPayCode
());
syncOrderParam
.
setCode
(
orderTickets
.
getPayCode
());
syncOrderParam
.
setPrice
(
orderTickets
.
getPrice
());
syncOrderParam
.
setPrice
(
orderTickets
.
getPrice
());
syncOrderParam
.
setPaymentId
(
"FREE_PAYMENT_ID"
);
syncOrderParam
.
setPaymentId
(
"FREE_PAYMENT_ID"
);
...
@@ -584,7 +593,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -584,7 +593,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
syncOrderParam
.
setStatus
(
1
);
syncOrderParam
.
setStatus
(
1
);
syncOrder
(
syncOrderParam
);
syncOrder
(
syncOrderParam
);
return
ResponseDto
.
success
(
payResultVo
.
getData
());
return
ResponseDto
.
success
(
payResultVo
.
getData
());
}
else
{
}
else
{
return
ResponseDto
.
success
(
payResultVo
.
getData
());
return
ResponseDto
.
success
(
payResultVo
.
getData
());
}
}
}
}
...
@@ -768,7 +777,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -768,7 +777,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
orderRefundsCallbackService
.
refundApply
(
orderTicketData
.
getOrderTicketsId
(),
syncOrderParam
.
getPaymentId
(),
syncOrderParam
.
getPaymentType
());
orderRefundsCallbackService
.
refundApply
(
orderTicketData
.
getOrderTicketsId
(),
syncOrderParam
.
getPaymentId
(),
syncOrderParam
.
getPaymentType
());
}
else
if
((
orderTicketData
.
getStatus
()
==
3
||
orderTicketData
.
getStatus
()
==
4
)
&&
syncOrderParam
.
getStatus
().
equals
(
1
))
{
}
else
if
((
orderTicketData
.
getStatus
()
==
3
||
orderTicketData
.
getStatus
()
==
4
)
&&
syncOrderParam
.
getStatus
().
equals
(
1
))
{
log
.
error
(
"订单号为 {} 的订单正在退款 或者已退款"
,
syncOrderParam
.
getOrderCode
());
log
.
error
(
"订单号为 {} 的订单正在退款 或者已退款"
,
syncOrderParam
.
getOrderCode
());
}
else
if
(
syncOrderParam
.
getStatus
().
equals
(
1
))
{
}
else
if
(
syncOrderParam
.
getStatus
().
equals
(
1
))
{
log
.
error
(
"订单号为 {} 的订单正常流程"
,
syncOrderParam
.
getOrderCode
());
log
.
error
(
"订单号为 {} 的订单正常流程"
,
syncOrderParam
.
getOrderCode
());
orderTickets
.
setOrderTicketsId
(
orderTicketData
.
getOrderTicketsId
());
orderTickets
.
setOrderTicketsId
(
orderTicketData
.
getOrderTicketsId
());
orderTickets
.
setPaymentType
(
syncOrderParam
.
getPaymentType
());
orderTickets
.
setPaymentType
(
syncOrderParam
.
getPaymentType
());
...
@@ -907,9 +916,9 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
...
@@ -907,9 +916,9 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
}
}
public
boolean
checkAgent
(
String
agentId
,
KylinTicketVo
ticketData
)
{
public
boolean
checkAgent
(
String
agentId
,
KylinTicketVo
ticketData
)
{
if
(
agentId
.
equals
(
0
))
{
if
(
agentId
.
equals
(
0
))
{
return
true
;
return
true
;
}
else
{
}
else
{
boolean
isAgent
=
ticketData
.
getIsAgent
()
==
1
;
boolean
isAgent
=
ticketData
.
getIsAgent
()
==
1
;
if
(
isAgent
)
{
if
(
isAgent
)
{
return
true
;
return
true
;
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetAppletMdskController.java
View file @
32cfc71a
...
@@ -39,7 +39,7 @@ public class SweetAppletMdskController {
...
@@ -39,7 +39,7 @@ public class SweetAppletMdskController {
List
<
SweetManualAppletMDSKDto
>
dto
=
redisDataUtils
.
getPushList
();
List
<
SweetManualAppletMDSKDto
>
dto
=
redisDataUtils
.
getPushList
();
List
<
SweetManualAppletMDSKDto
>
vo
=
ObjectUtil
.
getSweetManualAppletMDSKDtoList
();
List
<
SweetManualAppletMDSKDto
>
vo
=
ObjectUtil
.
getSweetManualAppletMDSKDtoList
();
for
(
SweetManualAppletMDSKDto
item
:
dto
)
{
for
(
SweetManualAppletMDSKDto
item
:
dto
)
{
if
(
item
.
getTitle
().
contains
(
name
))
{
if
(
item
.
getTitle
().
contains
(
name
)
||
item
.
getTitle
().
contains
(
"M_DSK"
)
)
{
vo
.
add
(
item
);
vo
.
add
(
item
);
}
}
}
}
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/com/liquidnet/service/sweet/mapper/SweetManualMdskMapper.xml
View file @
32cfc71a
...
@@ -75,7 +75,7 @@
...
@@ -75,7 +75,7 @@
) AS t ON p.performances_id = t.performance_id
) AS t ON p.performances_id = t.performance_id
<where>
<where>
<if
test=
"title!='' and title != null"
>
<if
test=
"title!='' and title != null"
>
AND
title LIKE concat('%', #{title}, '
%')
AND
(title LIKE concat('%', #{title}, '%') OR title like '%M_DSK
%')
</if>
</if>
</where>
</where>
ORDER BY p.created_at desc
ORDER BY p.created_at desc
...
...
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