|
@@ -141,7 +141,7 @@ public class UserWithdrawalServiceImpl extends ServiceImpl<UserWithdrawalDao, Us
|
|
|
if (null == detail) {
|
|
|
throw new BizException("参数异常,未找到交易记录,param is {}", jsonStr);
|
|
|
}
|
|
|
- if(!TradeStatusEnum.pending.equals(detail.getStatus())){
|
|
|
+ if (!TradeStatusEnum.pending.equals(detail.getStatus())) {
|
|
|
return;
|
|
|
}
|
|
|
if ("1".equals(callback.getStatus())) {
|
|
@@ -160,8 +160,9 @@ public class UserWithdrawalServiceImpl extends ServiceImpl<UserWithdrawalDao, Us
|
|
|
accountRecordDto.setFrozenType(FrozenTypeEnum.FROZEN_DEDUCT);
|
|
|
accountRecordDto.setSaveRecord(true);
|
|
|
userAccountService.accountChange(accountRecordDto);
|
|
|
-
|
|
|
- }else if("2".equals(callback.getStatus())){
|
|
|
+ //发生提现成功通知
|
|
|
+ successSend(detail.getUserId(), detail.getPhone());
|
|
|
+ } else if ("2".equals(callback.getStatus())) {
|
|
|
//交易失败
|
|
|
detail.setStatus(TradeStatusEnum.failed);
|
|
|
detail.setErrorCode(callback.getErrorCode());
|
|
@@ -175,7 +176,7 @@ public class UserWithdrawalServiceImpl extends ServiceImpl<UserWithdrawalDao, Us
|
|
|
accountRecordDto.setFrozenType(FrozenTypeEnum.FROZEN_BACK);
|
|
|
accountRecordDto.setSaveRecord(false);
|
|
|
userAccountService.accountChange(accountRecordDto);
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
return;
|
|
|
}
|
|
|
detail.setCallbackJson(jsonStr);
|
|
@@ -186,11 +187,10 @@ public class UserWithdrawalServiceImpl extends ServiceImpl<UserWithdrawalDao, Us
|
|
|
Map<Long, String> receivers = new HashMap<>();
|
|
|
receivers.put(userId, phone);
|
|
|
try {
|
|
|
- String url = sysMessageService.selectConfigUrl(MessageTypeEnum.TEACHER_WITHDRAW_SUCCESS.getCode());
|
|
|
- sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.VIP_EXPIRE,
|
|
|
- receivers, null, 0, url, ClientEnum.STUDENT.getCode());
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.TEACHER_WITHDRAW_SUCCESS,
|
|
|
+ receivers, null, 0, null, ClientEnum.TEACHER.getCode());
|
|
|
} catch (Exception e) {
|
|
|
- log.error("会员到期3天极光消息推送异常,userId={}", userId);
|
|
|
+ log.error("老师提现极光消息推送异常,userId={}", userId);
|
|
|
}
|
|
|
}
|
|
|
|