[Y] 指定退款审核人

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<NewRefund
     private ManagerMapper managerMapper;
     @Resource
     private MpWechatApiProvider mpWechatApiProvider;
+    @Resource
+    private SysConfigManager sysConfigManager;
 
     @Override
     public void onApplicationEvent(NewRefundReviewEvent event) {
@@ -42,10 +45,10 @@ public class NoticeRefundReviewListener implements ApplicationListener<NewRefund
         }
 
         //风控团队接收
-        List<JSONObject> 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);
         }
     }