| | |
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | else
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
|
|---|
| | | } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.teamRewardPreRecieved.name())) {
|
|---|
| | | if (hongBaoV2SettleTempService.countByKey(msg.getKey()) > 0)
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | else
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | }else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
|
|---|
| | | OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(msg.getBody()),
|
|---|
| | | OrderMoneyRecievedMQMsg.class);
|
|---|
| | | if (dto != null) {
|
|---|
