|
|
@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
+import lombok.SneakyThrows;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springblade.common.enums.AppConstant;
|
|
|
import org.springblade.common.enums.OrderType;
|
|
|
@@ -33,6 +34,7 @@ import org.springblade.payment.entity.PaymentVO;
|
|
|
import org.springblade.payment.entity.SuccessParams;
|
|
|
import org.springblade.payment.event.UserPayCsEvent;
|
|
|
import org.springblade.payment.handle.handler.DataHandle;
|
|
|
+import org.springblade.payment.listener.SubAccountHandle;
|
|
|
import org.springblade.webSocket.WebSocketServer;
|
|
|
import org.springblade.wx.config.ConfigForShop;
|
|
|
import org.springblade.wx.constant.MessageTemplate;
|
|
|
@@ -75,8 +77,10 @@ public class UserPayCS {
|
|
|
private WeChatService weChatService;
|
|
|
private ConfigForShop configForShop;
|
|
|
private WebSocketServer webSocketServer;
|
|
|
+ private SubAccountHandle subAccountHandle;
|
|
|
|
|
|
|
|
|
+ @SneakyThrows
|
|
|
@EventListener
|
|
|
//@Async
|
|
|
public void PaySuccess(UserPayCsEvent userPayCsEvent) {
|
|
|
@@ -149,7 +153,8 @@ public class UserPayCS {
|
|
|
|
|
|
//通知处理代理费，申请分账
|
|
|
successParams.setBills(bills);
|
|
|
- applicationEventPublisher.publishEvent(new BillSuccessEvent(successParams));
|
|
|
+ subAccountHandle.accountHandle(new BillSuccessEvent(successParams));
|
|
|
+// applicationEventPublisher.publishEvent(new BillSuccessEvent(successParams));
|
|
|
|
|
|
String openId = shop.getOpenId();
|
|
|
String time = DateUtil.format(bills.getUpdateTime(), "yyyy年MM月dd日 HH:mm:ss");
|
