package com.zhongshu.card.server.core.stream;

import com.github.microservice.app.stream.StreamConsumer;
import com.github.microservice.pay.client.model.weChatMiniApp.WeChatMiniAppPayRet;
import com.github.microservice.pay.client.model.weChatMiniApp.WeChatMiniAppRefundRet;
import com.zhongshu.card.server.core.service.pay.BalancePayService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Slf4j
@Component("weChatMiniAppReFundStreamConsumer")
public class WeChatMiniAppReFundStream extends StreamConsumer<WeChatMiniAppRefundRet> {

    @Autowired
    BalancePayService balancePayService;

    @Override
    public void accept(WeChatMiniAppRefundRet weChatMiniAppRefundRet) {
        log.info("---------------收到微信退款结果通知广播----------------");
    }
}
