package com.iplatform.pay.notify;

import com.iplatform.pay.BasePayApi;
import com.iplatform.pay.Constants;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.pay.exception.NotifyException;
import com.walker.pay.wechat.WechatV2PayEngineProvider;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.IOException;

/**
 * 微信支付v2版本的通知接口。
 * @author 时克英
 * @date 2023-03-01
 */
@RestController
@RequestMapping("/pay/notify/wx_v2")
@ConditionalOnClass({WechatV2PayEngineProvider.class})
public class WechatPayV2Api extends BasePayApi {

    @PostMapping("/orderNotify")
    public void orderPayNotify(@RequestBody String raw) throws IOException {
        if(StringUtils.isEmpty(raw)){
            throw new IllegalArgumentException("'微信v2支付'通知，未接收到原始数据:" + raw, null);
        }

        try {
            String error = this.getPayEngineManager().notifyOrder(Constants.PAY_DEFINITION_ID_WECHAT_V2, raw);
            if(StringUtils.isNotEmpty(error)){
                throw new RuntimeException("'微信v2支付'引擎返回错误:" + error, null);
            }
        } catch (NotifyException e) {
            throw new RuntimeException("'微信v2支付'结果通知异常:" + e.getMessage() + ", raw = " + raw , e);
        }

        // 微信v2版本，必须返回成功响应，还是xml格式。
        String response = this.getPayEngineManager().generateNotifyResponse(Constants.PAY_DEFINITION_ID_WECHAT_V2, true);
        this.ajaxOutPutXml(response);
//        return ResponseValue.success();
    }
}