From aac7f051c6d34d4f98f96c23fa9e133df04cbce1 Mon Sep 17 00:00:00 2001 From: xhxu Date: Sun, 1 Jan 2023 17:49:11 +0800 Subject: [PATCH] //refund --- .../controller/callback/TtPayController.java | 41 ++++++++++--------- .../schedule/OrderRefundAuditSchedule.java | 2 +- 2 files changed, 22 insertions(+), 21 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 5e7a1c499..ad4c3ebcf 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java @@ -211,26 +211,27 @@ public class TtPayController extends BaseController { refund_amount = (Integer) pMap.get("refund_amount"); } - Map 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 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"); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java index a2bc38e01..f00fe47bb 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java @@ -42,7 +42,7 @@ public class OrderRefundAuditSchedule { MaUtil maUtil; - @Scheduled(cron = "0 0 */1 * * ?")// + @Scheduled(cron = "0 40 */1 * * ?")// //@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 public void orderQueryRefund() {