import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;

import java.io.BufferedReader;

import java.io.IOException;

import java.util.stream.Collectors;

​

@RestController

public class WeixinNotifyController {

​

    @RequestMapping(value = "/weixin", method = RequestMethod.POST)

    @ResponseBody

    public String notify(HttpServletRequest request) {

        String result;

        try {

            // 读取请求体

            String requestBody = new BufferedReader(request.getReader()).lines().collect(Collectors.joining());

            // 验证请求签名（具体实现根据您的安全要求）

            // verifySignature(request, requestBody);

            // 记录接收到的数据

            LOGGER.info("微信支付通知收到: {}", requestBody);

            // 处理通知数据

            WeixinNotifyService weixinNotifyService = new WeixinNotifyService();

            weixinNotifyService.notify(requestBody);

            result = WeixinRespCheckUtil.WEIXIN_NOTIFY_SUCC;

        } catch (Exception e) {

            QMonitor.recordOne(PayMonitorConst.weixin_notify_exception);

            LOGGER.error("微信支付通知处理错误", e);

            result = WeixinRespCheckUtil.WEIXIN_NOTIFY_FAIL;

        }

        return result;

    }

}