|
|
@ -8,20 +8,19 @@ import com.qniao.dam.domain.service.withdrawaudit.ApplyWithdrawAuditDomainServic |
|
|
import com.qniao.dam.domian.aggregate.withdrawaudit.constant.WithdrawAuditStatus; |
|
|
import com.qniao.dam.domian.aggregate.withdrawaudit.constant.WithdrawAuditStatus; |
|
|
import com.qniao.dam.domian.aggregate.withdrawaudit.constant.WithdrawTypeEnum; |
|
|
import com.qniao.dam.domian.aggregate.withdrawaudit.constant.WithdrawTypeEnum; |
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.WithdrawAuditDao; |
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.WithdrawAuditDao; |
|
|
import com.qniao.dam.query.thirdoauthconfig.ThirdOauthConfigQueryService; |
|
|
|
|
|
import com.qniao.dam.query.walletaccount.WalletAccountQueryService; |
|
|
import com.qniao.dam.query.walletaccount.WalletAccountQueryService; |
|
|
import com.qniao.dau.application.UecServerApplicationService; |
|
|
import com.qniao.dau.application.UecServerApplicationService; |
|
|
import com.qniao.dau.application.request.GetWechatSessionDto; |
|
|
import com.qniao.dau.application.request.GetWechatSessionDto; |
|
|
import com.qniao.dau.application.response.WeChatAppletUserSessionVo; |
|
|
import com.qniao.dau.application.response.WeChatAppletUserSessionVo; |
|
|
import com.qniao.dau.domain.aggregate.thirdoauthconfig.valueobj.ThirdOauthConfig; |
|
|
|
|
|
import com.qniao.dau.domian.aggregate.authorization.constant.OAuthPlatformEnum; |
|
|
|
|
|
import com.qniao.domain.BaseApplicationService; |
|
|
import com.qniao.domain.BaseApplicationService; |
|
|
import com.qniao.domain.BaseDomainEvent; |
|
|
import com.qniao.domain.BaseDomainEvent; |
|
|
import com.qniao.framework.exception.BizException; |
|
|
import com.qniao.framework.exception.BizException; |
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
import javax.annotation.Resource; |
|
|
|
|
|
import java.util.HashMap; |
|
|
import java.util.List; |
|
|
import java.util.List; |
|
|
|
|
|
import java.util.Map; |
|
|
import java.util.Objects; |
|
|
import java.util.Objects; |
|
|
|
|
|
|
|
|
@Service |
|
|
@Service |
|
|
@ -35,8 +34,6 @@ public class WithdrawAuditApplicationService extends BaseApplicationService { |
|
|
@Resource |
|
|
@Resource |
|
|
private WithdrawAuditDao withdrawAuditDao; |
|
|
private WithdrawAuditDao withdrawAuditDao; |
|
|
@Resource |
|
|
@Resource |
|
|
private ThirdOauthConfigQueryService thirdOauthConfigQueryService; |
|
|
|
|
|
@Resource |
|
|
|
|
|
private UecServerApplicationService uecServerApplicationService; |
|
|
private UecServerApplicationService uecServerApplicationService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -51,6 +48,9 @@ public class WithdrawAuditApplicationService extends BaseApplicationService { |
|
|
String jsCode = ThirdPartyField.findFiledValueByKey(ThirdPartyField.JS_CODE, fieldList); |
|
|
String jsCode = ThirdPartyField.findFiledValueByKey(ThirdPartyField.JS_CODE, fieldList); |
|
|
GetWechatSessionDto sessionDto = new GetWechatSessionDto(jsCode, appId); |
|
|
GetWechatSessionDto sessionDto = new GetWechatSessionDto(jsCode, appId); |
|
|
WeChatAppletUserSessionVo sessionVo = uecServerApplicationService.getWechatSession(sessionDto); |
|
|
WeChatAppletUserSessionVo sessionVo = uecServerApplicationService.getWechatSession(sessionDto); |
|
|
|
|
|
Map<String, String> extDetails = new HashMap<>(); |
|
|
|
|
|
extDetails.put(ThirdPartyField.OPEN_ID, sessionVo.getOpenid()); |
|
|
|
|
|
withdrawAudit.setExtDetailsInfo(extDetails); |
|
|
} |
|
|
} |
|
|
withdrawAudit.setWalletAccountId(walletAccount.getId()); |
|
|
withdrawAudit.setWalletAccountId(walletAccount.getId()); |
|
|
walletAccount.setAvailableBalance(walletAccount.getAvailableBalance().subtract(withdrawAudit.getWithdrawAmount())); |
|
|
walletAccount.setAvailableBalance(walletAccount.getAvailableBalance().subtract(withdrawAudit.getWithdrawAmount())); |
|
|
|