From d8ac6f47076e9cf242e045e059d668c19636e5a3 Mon Sep 17 00:00:00 2001 From: xhxu Date: Fri, 11 Mar 2022 18:21:17 +0800 Subject: [PATCH] //test --- .../controller/callback/TtPayController.java | 23 ++++++++++++++++--- 1 file changed, 20 insertions(+), 3 deletions(-) diff --git a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java index 281d7ca0c..015305307 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java @@ -1,5 +1,6 @@ package com.iformall.controller.callback; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.iformall.common.ErrorCode; import com.iformall.common.ResultData; @@ -7,10 +8,11 @@ import com.iformall.controller.base.BaseController; import com.iformall.domain.po.WxAppinfo; import com.iformall.domain.po.WxPayAccount; import com.iformall.domain.po.WxPayOrder; +import com.iformall.domain.po.msg.FmInsideNotifyRefundSuccessMsg; import com.iformall.douyin.pay.DouYinPayHelper; -import com.iformall.enums.EnumPayStatus; -import com.iformall.enums.EnumPayWay; +import com.iformall.enums.*; import com.iformall.interceptor.BodyReaderHttpServletRequestWrapper; +import com.iformall.mq.MqBaseProducer; import com.iformall.service.WxAppinfoService; import com.iformall.service.WxPayAccountService; import com.iformall.service.WxPayOrderService; @@ -54,6 +56,9 @@ public class TtPayController extends BaseController { @Autowired private PayServiceFactory payServiceFactory; + @Autowired + private MqBaseProducer mqBaseProducer; + /** * timestamp number Unix 时间戳,10 位,整型数 * nonce string 随机数 @@ -130,7 +135,19 @@ public class TtPayController extends BaseController { map.put("cp_refundno",cp_refundno); map.put("status",status); map.put("refund_amount",refund_amount.toString()); - wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); +// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); + + String jsonMsg = JSON.toJSONString(map); + + FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); + refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); + refundSuccessMsg.setDelayTimeLevel(3); + refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); + refundSuccessMsg.setJsonMsg(jsonMsg); + + // response = wxRefundOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP); + mqBaseProducer.sendMessage(refundSuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + resultMap.put("err_no",0); resultMap.put("err_tips","success"); }