diff --git a/src/main/java/au/com/royalpay/payment/manage/tradelog/refund/events/listeners/NoticeRefundReviewListener.java b/src/main/java/au/com/royalpay/payment/manage/tradelog/refund/events/listeners/NoticeRefundReviewListener.java index b20bec6ed..ff771b66b 100644 --- a/src/main/java/au/com/royalpay/payment/manage/tradelog/refund/events/listeners/NoticeRefundReviewListener.java +++ b/src/main/java/au/com/royalpay/payment/manage/tradelog/refund/events/listeners/NoticeRefundReviewListener.java @@ -7,6 +7,7 @@ import au.com.royalpay.payment.tools.connections.mpsupport.MpWechatApi; import au.com.royalpay.payment.tools.connections.mpsupport.MpWechatApiProvider; import au.com.royalpay.payment.tools.connections.mpsupport.beans.TemplateMessage; import au.com.royalpay.payment.tools.env.PlatformEnvironment; +import au.com.royalpay.payment.tools.env.SysConfigManager; import com.alibaba.fastjson.JSONObject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +30,8 @@ public class NoticeRefundReviewListener implements ApplicationListener accounts = managerMapper.listRiskManagers(); - for (JSONObject account : accounts) { - String wechatOpenid = account.getString("wx_openid"); - sendRefundAuditNotify(event, client, operator, wechatOpenid); + String openidStrings = sysConfigManager.getSysConfig().getString("refund_audit_notice_people"); + String[] openids = openidStrings.split(","); + for (String openid : openids) { + sendRefundAuditNotify(event, client, operator, openid); } }