记得上下班打卡 | 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
fc83fe72
Commit
fc83fe72
authored
Jul 19, 2021
by
anjiabin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改查询逻辑
parent
12f38f38
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
6 additions
and
36 deletions
+6
-36
DragonConstant.java
...com/liquidnet/service/dragon/constant/DragonConstant.java
+0
-1
IDragonOrdersService.java
...iquidnet/service/dragon/service/IDragonOrdersService.java
+0
-2
DragonPayBiz.java
...net/service/dragon/channel/strategy/biz/DragonPayBiz.java
+1
-1
DragonOrdersServiceImpl.java
.../service/dragon/service/impl/DragonOrdersServiceImpl.java
+0
-6
DataUtils.java
...in/java/com/liquidnet/service/dragon/utils/DataUtils.java
+5
-26
No files found.
liquidnet-bus-api/liquidnet-service-dragon-api/src/main/java/com/liquidnet/service/dragon/constant/DragonConstant.java
View file @
fc83fe72
...
...
@@ -17,7 +17,6 @@ public class DragonConstant {
public
static
final
String
REFUND_REDIS_KET
=
"dragon:refund:refundCode:"
;
// 订单号对应回调地址
public
static
final
String
REDIS_KET_PAY_ORDERCODE
=
"dragon:pay:orderCode:"
;
// 订单编号
public
static
final
String
REDIS_KET_PAY_CODE
=
"dragon:pay:code:"
;
// 支付流水号
public
enum
PayChannelEnum
{
...
...
liquidnet-bus-api/liquidnet-service-dragon-api/src/main/java/com/liquidnet/service/dragon/service/IDragonOrdersService.java
View file @
fc83fe72
...
...
@@ -13,6 +13,4 @@ public interface IDragonOrdersService {
String
dragonNotify
(
HttpServletRequest
request
,
String
payType
,
String
deviceFrom
);
DragonPayOrderQueryRespDto
checkOrderStatusByCode
(
String
code
);
DragonPayOrderQueryRespDto
checkOrderStatusByOrderCode
(
String
orderCode
);
}
liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/strategy/biz/DragonPayBiz.java
View file @
fc83fe72
...
...
@@ -74,7 +74,7 @@ public class DragonPayBiz {
DragonOrdersDto
ordersDto
=
new
DragonOrdersDto
();
BeanUtil
.
copy
(
orders
,
ordersDto
);
//放到redis缓存中
dataUtils
.
createPayOrder
(
orders
.
get
OrderCode
(),
orders
.
get
Code
(),
ordersDto
);
dataUtils
.
createPayOrder
(
orders
.
getCode
(),
ordersDto
);
// 持久化到数据库
boolean
insertResult
=
mqHandleUtil
.
sendMySqlRedis
(
SqlMapping
.
get
(
"dragon_orders.insert"
),
...
...
liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/service/impl/DragonOrdersServiceImpl.java
View file @
fc83fe72
...
...
@@ -67,10 +67,4 @@ public class DragonOrdersServiceImpl implements IDragonOrdersService {
String
payType
=
DragonConstant
.
PayTypeEnum
.
getEnumByCode
(
ordersDto
.
getPaymentType
()).
getPayType
();
return
payChannelStrategyContext
.
getStrategy
(
payType
).
checkOrderStatus
(
code
);
}
@Override
public
DragonPayOrderQueryRespDto
checkOrderStatusByOrderCode
(
String
orderCode
)
{
String
code
=
dataUtils
.
getCodeByOrderCode
(
orderCode
);
return
this
.
checkOrderStatusByCode
(
code
);
}
}
liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/utils/DataUtils.java
View file @
fc83fe72
...
...
@@ -11,38 +11,17 @@ public class DataUtils {
@Autowired
private
RedisUtil
redisUtil
;
/**
* 根据订单编号获取支付code
* @param orderCode
* @return
*/
public
String
getCodeByOrderCode
(
String
orderCode
)
{
//获取支付订单号
return
(
String
)
redisUtil
.
get
(
DragonConstant
.
REDIS_KET_PAY_ORDERCODE
+
orderCode
);
}
public
void
createPayOrder
(
String
orderCode
,
String
code
,
DragonOrdersDto
ordersDto
)
{
if
(!
redisUtil
.
hasKey
(
DragonConstant
.
REDIS_KET_PAY_ORDERCODE
+
orderCode
))
{
redisUtil
.
set
(
DragonConstant
.
REDIS_KET_PAY_ORDERCODE
+
orderCode
,
code
);
public
void
createPayOrder
(
String
code
,
DragonOrdersDto
ordersDto
)
{
if
(!
redisUtil
.
hasKey
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
))
{
redisUtil
.
set
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
,
ordersDto
);
}
}
public
DragonOrdersDto
getPayOrderByCode
(
String
code
)
{
if
(
!
redisUtil
.
hasKey
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
))
{
//TODO 是否降级处理
if
(
redisUtil
.
hasKey
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
))
{
return
(
DragonOrdersDto
)
redisUtil
.
get
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
);
}
return
(
DragonOrdersDto
)
redisUtil
.
get
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
);
}
public
DragonOrdersDto
getPayOrderByOrderCode
(
String
orderCode
)
{
if
(!
redisUtil
.
hasKey
(
DragonConstant
.
REDIS_KET_PAY_ORDERCODE
+
orderCode
))
{
//TODO 是否降级处理
}
//获取支付订单号
String
code
=
(
String
)
redisUtil
.
get
(
DragonConstant
.
REDIS_KET_PAY_ORDERCODE
+
orderCode
);
return
(
DragonOrdersDto
)
redisUtil
.
get
(
DragonConstant
.
REDIS_KET_PAY_CODE
+
code
);
return
null
;
}
public
void
updateOrderStatus
(
String
code
,
DragonOrdersDto
dragonOrdersDto
)
{
...
...
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