mirror of
https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git
synced 2026-06-14 12:20:04 +08:00
update 退余额
This commit is contained in:
@@ -11,7 +11,6 @@ import com.google.common.collect.Lists;
|
|||||||
import com.google.common.collect.Sets;
|
import com.google.common.collect.Sets;
|
||||||
import com.huifu.adapay.core.AdapayCore;
|
import com.huifu.adapay.core.AdapayCore;
|
||||||
import com.huifu.adapay.core.util.AdapaySign;
|
import com.huifu.adapay.core.util.AdapaySign;
|
||||||
import com.jsowell.adapay.response.PaymentReverseResponse;
|
|
||||||
import com.jsowell.common.constant.Constants;
|
import com.jsowell.common.constant.Constants;
|
||||||
import com.jsowell.common.core.domain.vo.AuthorizedDeptVO;
|
import com.jsowell.common.core.domain.vo.AuthorizedDeptVO;
|
||||||
import com.jsowell.common.core.domain.ykc.RealTimeMonitorData;
|
import com.jsowell.common.core.domain.ykc.RealTimeMonitorData;
|
||||||
@@ -1106,13 +1105,19 @@ public class OrderService {
|
|||||||
/**
|
/**
|
||||||
* 支付撤销成功
|
* 支付撤销成功
|
||||||
*/
|
*/
|
||||||
private void paymentReverseSucceeded(String data) throws JsonProcessingException {
|
private void paymentReverseSucceeded(String data) {
|
||||||
log.info("支付撤销成功 data:{}", JSON.toJSONString(data));
|
log.info("支付撤销成功 data:{}", JSON.toJSONString(data));
|
||||||
JSONObject jsonObject = JSON.parseObject(data);
|
JSONObject jsonObject = JSON.parseObject(data);
|
||||||
ObjectMapper mapper = new ObjectMapper();
|
JSONObject reason = jsonObject.getJSONObject("reason");
|
||||||
mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);
|
if (ScenarioEnum.BALANCE.getValue().equals(reason.getString("scenarioType"))) {
|
||||||
PaymentReverseResponse paymentReverseResponse = mapper.readValue(jsonObject.toJSONString(), PaymentReverseResponse.class);
|
// 这笔支付订单原来是充值余额的,退款成功了,需要扣掉会员的本金金额
|
||||||
log.info("支付撤销成功 paymentReverseResponse:{}", JSON.toJSONString(paymentReverseResponse));
|
UpdateMemberBalanceDTO dto = new UpdateMemberBalanceDTO();
|
||||||
|
dto.setMemberId(reason.getString("memberId"));
|
||||||
|
dto.setUpdatePrincipalBalance(new BigDecimal(jsonObject.getString("reverse_amt"))); // 更新会员本金金额,单位元
|
||||||
|
dto.setType(MemberWalletEnum.TYPE_OUT.getValue());
|
||||||
|
dto.setSubType(MemberWalletEnum.SUBTYPE_USER_REFUND.getValue());
|
||||||
|
memberBasicInfoService.updateMemberBalance(dto);
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -684,7 +684,7 @@ public class AdapayMemberService {
|
|||||||
expendMap.put("orderCode", orderCode);
|
expendMap.put("orderCode", orderCode);
|
||||||
}
|
}
|
||||||
reverseParams.put("expand", expendMap);
|
reverseParams.put("expand", expendMap);
|
||||||
// reverseParams.put("reason", "reason");
|
reverseParams.put("reason", expendMap);
|
||||||
Map<String, Object> paymentReverse = null;
|
Map<String, Object> paymentReverse = null;
|
||||||
try {
|
try {
|
||||||
paymentReverse = PaymentReverse.create(reverseParams, config.getWechatAppId());
|
paymentReverse = PaymentReverse.create(reverseParams, config.getWechatAppId());
|
||||||
|
|||||||
Reference in New Issue
Block a user