package com.cdzy.payment.controller;

import com.alibaba.fastjson2.JSONObject;
import com.cdzy.payment.model.vo.EbikeWxHandleNotifyVo;
import com.cdzy.payment.service.EbikeWxPayService;
import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * 微信支付通知回调接口
 * <br>通知接口不能鉴权
 *
 * @author: yanglei
 * @since: 2025-10-21  15:00
 */
@RestController
@RequestMapping("/wxPayment/notify")
public class EbikeWxPayNotifyController {

    @Resource
    private EbikeWxPayService wxPayService;

    /**
     * 支付回调通知
     *
     * @param request  支付回调请求
     * @param response 支付回调响应
     * @return 支付回调响应
     */
    @PostMapping("/pay")
    public String payNotify(HttpServletRequest request, HttpServletResponse response) {
        EbikeWxHandleNotifyVo r = wxPayService.handlePayNotify(request);
        if (!r.isSuccess()) {
            response.setStatus(500);
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("code", "SYSTEM_ERROR");
            jsonObject.put("message", r.getMessage());
            return jsonObject.toJSONString();
        }
        response.setStatus(200);
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("code", "SUCCESS");
        jsonObject.put("message", "OK");
        return jsonObject.toJSONString();
    }

    /**
     * 退款回调通知
     *
     * @param request  退款回调请求
     * @param response 退款回调响应
     * @return 退款回调响应
     */
    @PostMapping("/refund")
    public String refundNotify(HttpServletRequest request, HttpServletResponse response) {
        EbikeWxHandleNotifyVo r = wxPayService.handleRefundNotify(request);
        if (!r.isSuccess()) {
            response.setStatus(500);
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("code", "SYSTEM_ERROR");
            jsonObject.put("message", r.getMessage());
            return jsonObject.toJSONString();
        }
        response.setStatus(200);
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("code", "SUCCESS");
        jsonObject.put("message", "OK");
        return jsonObject.toJSONString();
    }

}