| @@ -1,5 +1,6 @@ | |||||
| package com.iformall.controller.callback; | package com.iformall.controller.callback; | ||||
| import com.alibaba.fastjson.JSON; | |||||
| import com.alibaba.fastjson.JSONObject; | import com.alibaba.fastjson.JSONObject; | ||||
| import com.iformall.common.ErrorCode; | import com.iformall.common.ErrorCode; | ||||
| import com.iformall.common.ResultData; | 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.WxAppinfo; | ||||
| import com.iformall.domain.po.WxPayAccount; | import com.iformall.domain.po.WxPayAccount; | ||||
| import com.iformall.domain.po.WxPayOrder; | import com.iformall.domain.po.WxPayOrder; | ||||
| import com.iformall.domain.po.msg.FmInsideNotifyRefundSuccessMsg; | |||||
| import com.iformall.douyin.pay.DouYinPayHelper; | 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.interceptor.BodyReaderHttpServletRequestWrapper; | ||||
| import com.iformall.mq.MqBaseProducer; | |||||
| import com.iformall.service.WxAppinfoService; | import com.iformall.service.WxAppinfoService; | ||||
| import com.iformall.service.WxPayAccountService; | import com.iformall.service.WxPayAccountService; | ||||
| import com.iformall.service.WxPayOrderService; | import com.iformall.service.WxPayOrderService; | ||||
| @@ -54,6 +56,9 @@ public class TtPayController extends BaseController { | |||||
| @Autowired | @Autowired | ||||
| private PayServiceFactory payServiceFactory; | private PayServiceFactory payServiceFactory; | ||||
| @Autowired | |||||
| private MqBaseProducer mqBaseProducer; | |||||
| /** | /** | ||||
| * timestamp number Unix 时间戳,10 位,整型数 | * timestamp number Unix 时间戳,10 位,整型数 | ||||
| * nonce string 随机数 | * nonce string 随机数 | ||||
| @@ -130,7 +135,19 @@ public class TtPayController extends BaseController { | |||||
| map.put("cp_refundno",cp_refundno); | map.put("cp_refundno",cp_refundno); | ||||
| map.put("status",status); | map.put("status",status); | ||||
| map.put("refund_amount",refund_amount.toString()); | 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_no",0); | ||||
| resultMap.put("err_tips","success"); | resultMap.put("err_tips","success"); | ||||
| } | } | ||||