Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
A
asset-distribution
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
data-spider
asset-distribution
Commits
66476524
Commit
66476524
authored
Sep 03, 2019
by
liwenbin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
对于订单hangup状态 不处理,等待最终结果
parent
e8cfb407
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
4 additions
and
1 deletion
+4
-1
ConsumerConfig.java
...up/asset/distribution/config/rabbitmq/ConsumerConfig.java
+1
-1
NotifyServiceImpl.java
...t/distribution/service/notify/impl/NotifyServiceImpl.java
+3
-0
No files found.
src/main/java/com/quantgroup/asset/distribution/config/rabbitmq/ConsumerConfig.java
View file @
66476524
...
@@ -71,7 +71,7 @@ public class ConsumerConfig implements RabbitListenerConfigurer {
...
@@ -71,7 +71,7 @@ public class ConsumerConfig implements RabbitListenerConfigurer {
JSONObject
jo
=
JSONObject
.
parseObject
(
ms
);
JSONObject
jo
=
JSONObject
.
parseObject
(
ms
);
String
noticeType
=
jo
.
getString
(
"noticeType"
);
String
noticeType
=
jo
.
getString
(
"noticeType"
);
if
(
FundingResult
.
REJECT
.
getCode
().
equals
(
noticeType
)
if
(
FundingResult
.
REJECT
.
getCode
().
equals
(
noticeType
)
||
FundingResult
.
HANG_UP
.
getCode
().
equals
(
noticeType
)
//
|| FundingResult.HANG_UP.getCode().equals(noticeType)
||
FundingResult
.
CANCEL_LOAN
.
getCode
().
equals
(
noticeType
)
||
FundingResult
.
CANCEL_LOAN
.
getCode
().
equals
(
noticeType
)
||
FundingResult
.
FUAD_ASSIGN_SUCC
.
getCode
().
equals
(
noticeType
)){
||
FundingResult
.
FUAD_ASSIGN_SUCC
.
getCode
().
equals
(
noticeType
)){
log
.
info
(
"助贷资金路由有效MQ消息接收, 消息内容 : {} "
,
ms
);
log
.
info
(
"助贷资金路由有效MQ消息接收, 消息内容 : {} "
,
ms
);
...
...
src/main/java/com/quantgroup/asset/distribution/service/notify/impl/NotifyServiceImpl.java
View file @
66476524
...
@@ -63,6 +63,9 @@ public class NotifyServiceImpl implements INotifyService{
...
@@ -63,6 +63,9 @@ public class NotifyServiceImpl implements INotifyService{
if
(
StringUtils
.
isEmpty
(
response
)
||
(
data
=
JSON
.
parseObject
(
response
)).
getInteger
(
"code"
)
!=
0
)
{
if
(
StringUtils
.
isEmpty
(
response
)
||
(
data
=
JSON
.
parseObject
(
response
)).
getInteger
(
"code"
)
!=
0
)
{
throw
new
QGException
(
QGExceptionType
.
NOTIFY_BUSINESS_FLOW_ERROR
,
bizNo
,
status
);
throw
new
QGException
(
QGExceptionType
.
NOTIFY_BUSINESS_FLOW_ERROR
,
bizNo
,
status
);
}
}
}
catch
(
QGException
qe
)
{
log
.
error
(
"资产分发订单终态通知业务流系统出现错误, 错误信息 : {}, bizNo : {}, status : {}"
,
qe
.
qgExceptionType
.
code
+
"->"
+
qe
.
detail
,
bizNo
,
status
);
alarmService
.
dingtalkAlarm
(
"Warn"
,
"通知业务流系统订单终态出现错误"
,
"错误信息 : "
+
qe
.
qgExceptionType
.
code
+
"->"
+
qe
.
detail
+
" , bizNo : "
+
bizNo
+
" , "
+
"status : "
+
status
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
error
(
"资产分发订单终态通知业务流系统异常, bizNo : {}, status : {}"
,
bizNo
,
status
);
log
.
error
(
"资产分发订单终态通知业务流系统异常, bizNo : {}, status : {}"
,
bizNo
,
status
);
alarmService
.
dingtalkAlarm
(
"Warn"
,
"通知业务流系统订单终态异常"
,
"bizNo : "
+
bizNo
+
" , "
+
"status : "
+
status
);
alarmService
.
dingtalkAlarm
(
"Warn"
,
"通知业务流系统订单终态异常"
,
"bizNo : "
+
bizNo
+
" , "
+
"status : "
+
status
);
...
...
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