Просмотр исходного кода

[微信通知][修改]:微信退款通知化为内部消息

release_toaliyun_real
Stormeye Wu 7 лет назад
Родитель
Сommit
197433f253
2 измененных файлов: 3 добавлений и 20 удалений
  1. +2
    -19
      mallinkCallback/src/main/java/com/iformall/controller/callback/WxPayController.java
  2. +1
    -1
      mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java

+ 2
- 19
mallinkCallback/src/main/java/com/iformall/controller/callback/WxPayController.java Просмотреть файл

@@ -70,29 +70,12 @@ public class WxPayController extends BaseController {

Map<String, String> paramMap = null;



try {
paramMap = WxPayment.xmlToMap(resultxml);
logger.info("微信支付回调, notify, param: " + paramMap.toString() );


String jsonMsg = JSON.toJSONString(paramMap);
FmInsideNotifyPaySuccessMsg paySuccessMsg = new FmInsideNotifyPaySuccessMsg();
paySuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_PAY_SUCCESS.getCode());
paySuccessMsg.setDelayTimeLevel(3);
paySuccessMsg.setPayWay(EnumPayWay.PAY_WAY_WEAPP.getCode());
paySuccessMsg.setJsonMsg(jsonMsg);
// String response = wxPayOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP);
mqBaseProducer.sendMessage(paySuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode());


String response = wxPayOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP);
logger.info("微信支付回调, notify success, req : " + resultxml);

SortedMap resultMap = new TreeMap();
resultMap.put("return_code", "SUCCESS");
resultMap.put("return_msg", "OK");
return XmlUtil.getRequestXml(resultMap);
return response;
} catch (BizMessageException e) {
if (paramMap == null) {
logger.error("微信支付回调, order create error, e: " + e.getMessage());


+ 1
- 1
mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java Просмотреть файл

@@ -94,7 +94,7 @@ public class MqBaseConsumer {
fmInsideNotifyPaySuccessMsgService.send(msg);
} else if(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode().equals(baseMsg.getMsgType())) {
// 内部消息 - 微信退款通知
FmInsideNotifyRefundSuccessMsg msg = (FmInsideNotifyRefundSuccessMsg)JsonUtil.readValue(message,FmInsideNotifyPaySuccessMsg.class);
FmInsideNotifyRefundSuccessMsg msg = (FmInsideNotifyRefundSuccessMsg)JsonUtil.readValue(message,FmInsideNotifyRefundSuccessMsg.class);
fmInsideNotifyRefundSuccessMsgService.send(msg);
}
baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode());


Загрузка…
Отмена
Сохранить