记得上下班打卡 | 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
08a28530
Commit
08a28530
authored
Jun 30, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'dev' into test
parents
afadb973
65b5b3a1
Changes
2
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
291 additions
and
259 deletions
+291
-259
KylinOrderTicketsServiceImpl.java
...vice/kylin/service/impl/KylinOrderTicketsServiceImpl.java
+268
-259
PerformancesExpressCallbackServiceImpl.java
...ress/shunfeng/PerformancesExpressCallbackServiceImpl.java
+23
-0
No files found.
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java
View file @
08a28530
...
@@ -314,12 +314,12 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
...
@@ -314,12 +314,12 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
return
resultData
;
return
resultData
;
}
}
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
if
(
isDownGeneral
)
{
//
if (isDownGeneral) {
currentTime
=
System
.
currentTimeMillis
();
//
currentTime = System.currentTimeMillis();
dataUtils
.
changeSurplusGeneral
(
payOrderParam
.
getTicketId
(),
payOrderParam
.
getNumber
());
//
dataUtils.changeSurplusGeneral(payOrderParam.getTicketId(), payOrderParam.getNumber());
currentTime
=
System
.
currentTimeMillis
()
-
currentTime
;
//
currentTime = System.currentTimeMillis() - currentTime;
log
.
debug
(
"redis 修改库存 异常 -> time:"
+
(
currentTime
)
+
"毫秒"
);
//
log.debug("redis 修改库存 异常 -> time:" + (currentTime) + "毫秒");
}
//
}
e
.
printStackTrace
();
e
.
printStackTrace
();
log
.
error
(
"Kylin Order Pay Error = "
+
e
.
getMessage
());
log
.
error
(
"Kylin Order Pay Error = "
+
e
.
getMessage
());
// redisLockUtil.unlock(lock);
// redisLockUtil.unlock(lock);
...
@@ -328,6 +328,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
...
@@ -328,6 +328,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
}
}
private
ResponseDto
<
PayResultVo
>
order
(
PayOrderParam
payOrderParam
,
String
uid
,
boolean
isMember
,
int
isTrueName
,
KylinPerformanceVo
performanceData
,
KylinTicketVo
ticketData
,
List
<
AdamEntersVo
>
entersVoList
,
Integer
isStudent
,
KylinTicketTimesVo
ticketTimesData
,
Long
currentTime
)
{
private
ResponseDto
<
PayResultVo
>
order
(
PayOrderParam
payOrderParam
,
String
uid
,
boolean
isMember
,
int
isTrueName
,
KylinPerformanceVo
performanceData
,
KylinTicketVo
ticketData
,
List
<
AdamEntersVo
>
entersVoList
,
Integer
isStudent
,
KylinTicketTimesVo
ticketTimesData
,
Long
currentTime
)
{
try
{
LinkedList
<
String
>
sqls
=
new
LinkedList
<>();
LinkedList
<
String
>
sqls
=
new
LinkedList
<>();
String
source
=
CurrentUtil
.
getCliSource
()
==
null
?
""
:
CurrentUtil
.
getCliSource
();
String
source
=
CurrentUtil
.
getCliSource
()
==
null
?
""
:
CurrentUtil
.
getCliSource
();
String
version
=
CurrentUtil
.
getCliVersion
()
==
null
?
""
:
CurrentUtil
.
getCliVersion
();
String
version
=
CurrentUtil
.
getCliVersion
()
==
null
?
""
:
CurrentUtil
.
getCliVersion
();
...
@@ -621,6 +622,14 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
...
@@ -621,6 +622,14 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
log
.
debug
(
"MQ 发送 -> time:"
+
(
currentTime
)
+
"毫秒"
);
log
.
debug
(
"MQ 发送 -> time:"
+
(
currentTime
)
+
"毫秒"
);
log
.
info
(
UserPathDto
.
setData
(
"下单(唤起支付)"
,
payOrderParam
,
payResultVo
));
log
.
info
(
UserPathDto
.
setData
(
"下单(唤起支付)"
,
payOrderParam
,
payResultVo
));
return
ResponseDto
.
success
(
payResultVo
);
return
ResponseDto
.
success
(
payResultVo
);
}
catch
(
Exception
e
){
currentTime
=
System
.
currentTimeMillis
();
dataUtils
.
changeSurplusGeneral
(
payOrderParam
.
getTicketId
(),
payOrderParam
.
getNumber
());
currentTime
=
System
.
currentTimeMillis
()
-
currentTime
;
log
.
debug
(
"redis 修改库存 异常 -> time:"
+
(
currentTime
)
+
"毫秒"
);
log
.
error
(
"Kylin Order Inner Pay Error = "
+
e
.
getMessage
());
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20018"
));
//乱七八糟异常
}
}
}
@Override
@Override
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/express/shunfeng/PerformancesExpressCallbackServiceImpl.java
View file @
08a28530
...
@@ -14,6 +14,8 @@ import org.springframework.data.mongodb.core.MongoTemplate;
...
@@ -14,6 +14,8 @@ import org.springframework.data.mongodb.core.MongoTemplate;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletRequest
;
import
java.util.Enumeration
;
import
java.util.List
;
/**
/**
* <p>
* <p>
...
@@ -70,6 +72,13 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -70,6 +72,13 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
System
.
out
.
println
(
performanceExpressPushStatusParam
);
System
.
out
.
println
(
performanceExpressPushStatusParam
);
System
.
out
.
println
(
res
);
System
.
out
.
println
(
res
);
Enumeration
headerNames
=
httpServletRequest
.
getHeaderNames
();
while
(
headerNames
.
hasMoreElements
())
{
String
key
=
(
String
)
headerNames
.
nextElement
();
String
value
=
httpServletRequest
.
getHeader
(
key
);
System
.
out
.
println
(
key
+
"="
+
value
);
}
return
false
;
return
false
;
}
}
...
@@ -78,6 +87,13 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -78,6 +87,13 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
JsonUtils
.
toJson
(
performanceExpressPushFreightParam
),
httpServletRequest
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
JsonUtils
.
toJson
(
performanceExpressPushFreightParam
),
httpServletRequest
);
System
.
out
.
println
(
performanceExpressPushFreightParam
);
System
.
out
.
println
(
performanceExpressPushFreightParam
);
System
.
out
.
println
(
res
);
System
.
out
.
println
(
res
);
Enumeration
headerNames
=
httpServletRequest
.
getHeaderNames
();
while
(
headerNames
.
hasMoreElements
())
{
String
key
=
(
String
)
headerNames
.
nextElement
();
String
value
=
httpServletRequest
.
getHeader
(
key
);
System
.
out
.
println
(
key
+
"="
+
value
);
}
/*KylinOrderExpressFeeInfo kylinOrderExpressFeeInfo = new KylinOrderExpressFeeInfo();
/*KylinOrderExpressFeeInfo kylinOrderExpressFeeInfo = new KylinOrderExpressFeeInfo();
String orderExpressFeeInfoId = IDGenerator.nextSnowId();
String orderExpressFeeInfoId = IDGenerator.nextSnowId();
kylinOrderExpressFeeInfo.setOrderExpressFeeInfoId(orderExpressFeeInfoId);
kylinOrderExpressFeeInfo.setOrderExpressFeeInfoId(orderExpressFeeInfoId);
...
@@ -96,6 +112,13 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -96,6 +112,13 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
JsonUtils
.
toJson
(
performanceExpressPushRouteParam
),
httpServletRequest
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
JsonUtils
.
toJson
(
performanceExpressPushRouteParam
),
httpServletRequest
);
System
.
out
.
println
(
performanceExpressPushRouteParam
);
System
.
out
.
println
(
performanceExpressPushRouteParam
);
System
.
out
.
println
(
res
);
System
.
out
.
println
(
res
);
Enumeration
headerNames
=
httpServletRequest
.
getHeaderNames
();
while
(
headerNames
.
hasMoreElements
())
{
String
key
=
(
String
)
headerNames
.
nextElement
();
String
value
=
httpServletRequest
.
getHeader
(
key
);
System
.
out
.
println
(
key
+
"="
+
value
);
}
/*KylinOrderExpressRoute kylinOrderExpressRoute = new KylinOrderExpressRoute();
/*KylinOrderExpressRoute kylinOrderExpressRoute = new KylinOrderExpressRoute();
String orderExpressRouteId = IDGenerator.nextSnowId();
String orderExpressRouteId = IDGenerator.nextSnowId();
kylinOrderExpressRoute.setOrderExpressRouteId(orderExpressRouteId);
kylinOrderExpressRoute.setOrderExpressRouteId(orderExpressRouteId);
...
...
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