|
|
|
@@ -211,26 +211,27 @@ public class TtPayController extends BaseController { |
|
|
|
refund_amount = (Integer) pMap.get("refund_amount"); |
|
|
|
} |
|
|
|
|
|
|
|
Map<String,String> map = new HashMap<>(); |
|
|
|
map.put("tenantId",tenantId); |
|
|
|
map.put("appid",appid); |
|
|
|
map.put("cp_refundno",cp_refundno); |
|
|
|
map.put("status",status); |
|
|
|
map.put("refund_amount",refund_amount.toString()); |
|
|
|
// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); |
|
|
|
|
|
|
|
String jsonMsg = JSON.toJSONString(map); |
|
|
|
|
|
|
|
FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); |
|
|
|
refundSuccessMsg.setTenantId(tenantId); |
|
|
|
refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); |
|
|
|
refundSuccessMsg.setDelayTimeLevel(3); |
|
|
|
refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); |
|
|
|
refundSuccessMsg.setPayVersion(EnumPayVersion.DY_PAY_V2.getCode()); |
|
|
|
refundSuccessMsg.setJsonMsg(jsonMsg); |
|
|
|
|
|
|
|
// response = wxRefundOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP); |
|
|
|
mqBaseProducer.sendMessage(refundSuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
//todo 抖音退款不通过回调处理,通过定时处理 |
|
|
|
// Map<String,String> map = new HashMap<>(); |
|
|
|
// map.put("tenantId",tenantId); |
|
|
|
// map.put("appid",appid); |
|
|
|
// map.put("cp_refundno",cp_refundno); |
|
|
|
// map.put("status",status); |
|
|
|
// map.put("refund_amount",refund_amount.toString()); |
|
|
|
//// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); |
|
|
|
// |
|
|
|
// String jsonMsg = JSON.toJSONString(map); |
|
|
|
// |
|
|
|
// FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); |
|
|
|
// refundSuccessMsg.setTenantId(tenantId); |
|
|
|
// refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); |
|
|
|
// refundSuccessMsg.setDelayTimeLevel(3); |
|
|
|
// refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); |
|
|
|
// refundSuccessMsg.setPayVersion(EnumPayVersion.DY_PAY_V2.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"); |
|
|
|
|