package com.walker.pay.allinpaycloud;

import com.allinpay.sdk.bean.OpenConfig;
import com.walker.infrastructure.arguments.Variable;
import com.walker.pay.Order;
import com.walker.pay.OrderGenerator;
import com.walker.pay.OrderStatusQuery;
import com.walker.pay.PayChannel;
import com.walker.pay.PayContext;
import com.walker.pay.PayType;
import com.walker.pay.ServiceProvider;
import com.walker.pay.allinpaycloud.generator.BankCardOrderGenerator;
import com.walker.pay.allinpaycloud.generator.ScanWechatOrderGenerator;
import com.walker.pay.allinpaycloud.generator.WechatJsOrderGenerator;
import com.walker.pay.allinpaycloud.generator.WechatProgramOrderGenerator;
import com.walker.pay.response.OrderStatusResponsePay;
import com.walker.pay.support.SimplePayEngineProvider;
import org.springframework.web.client.RestTemplate;

import java.util.HashMap;
import java.util.Map;

/**
 * 通商云(通联)支付引擎默认实现。
 * @author 时克英
 * @date 2023-02-17
 */
public class DefaultPayEngineProvider extends SimplePayEngineProvider {

    public DefaultPayEngineProvider(){}
    public DefaultPayEngineProvider(RestTemplate restTemplate){}

    @Override
    protected String acquireProviderPayType(ServiceProvider serviceProvider, PayType payType, PayChannel payChannel) {
        if(payType == PayType.AllinPayCloud_QUICKPAY_VSP){
            return Constants.PAY_TYPE_QUICKPAY_VSP;
        } else if(payType == PayType.AllinPayCloud_WECHAT_PUBLIC){
            return Constants.PAY_TYPE_WECHAT_PUBLIC;
        } else if(payType == PayType.AllinPayCloud_ALIPAY_SERVIC){
            return Constants.PAY_TYPE_ALIPAY_SERVICE;
        } else if(payType == PayType.AllinPayCloud_WECHATPAY_MINIPROGRAM){
            return Constants.PAY_TYPE_WECHATPAY_MINIPROGRAM;
        } else if(payType == PayType.AllinPayCloud_SCAN_WEIXIN){
            return Constants.PAY_TYPE_SCAN_WEIXIN;
        } else if(payType == PayType.AllinPayCloud_SCAN_ALIPAY){
            return Constants.PAY_TYPE_SCAN_ALIPAY;
        } else if(payType == PayType.AllinPayCloud_COUPON){
            return Constants.PAY_TYPE_COUPON;
        } else {
            throw new UnsupportedOperationException("代码未实现'通商云'支付类型转换:" + payType.getName());
        }
    }

    @Override
    protected OrderGenerator acquireOrderGenerator(String providerPayType, Order platformOrder, Map<String, Variable> configuration) {
        return this.orderGeneratorMap.get(providerPayType);
    }

    @Override
    protected boolean verifySign(Object notifyData) throws Exception {
        RequestNotify requestNotify = (RequestNotify) notifyData;
        String signedValue = requestNotify.toSignSource();
        logger.debug(signedValue);
        return this.sdkClient.checkSign(signedValue, requestNotify.getSign());
    }

    @Override
    protected PayContext acquirePayContext(String providerPayType, Order platformOrder, Map<String, Variable> configuration) {
        CloudPayContext context = new CloudPayContext();
        return context;
    }

    @Override
    protected OrderStatusQuery acquireOrderStatusQuery(Order order) {
        OrderStatusQuery orderStatusQuery = new OrderStatusQuery();
        orderStatusQuery.setOrderId(order.getId());
        return orderStatusQuery;
    }

    @Override
    protected OrderStatusResponsePay invokeOrderStatus(OrderStatusQuery orderStatusQuery) {
        return this.sdkClient.searchOrderStatus(String.valueOf(orderStatusQuery.getOrderId()));
    }

    @Override
    public String generateNotifyResponse(boolean success) {
        return Constants.SUB_CODE_OK;
    }

    @Override
    public void setConfiguration(Map<String, Variable> configuration){
        super.setConfiguration(configuration);
        // 覆盖父类方法，实现初始化sdk
        OpenConfig openConfig = new OpenConfig();
        openConfig.setUrl(configuration.get(Constants.CONFIG_KEY_URL).getStringValue());
        openConfig.setAppId(configuration.get(Constants.CONFIG_KEY_APP_ID).getStringValue());
        openConfig.setSecretKey(configuration.get(Constants.CONFIG_KEY_SECRET_KEY).getStringValue());
        openConfig.setCertPath(configuration.get(Constants.CONFIG_KEY_PRIVATE_KEY_PATH).getStringValue());
        openConfig.setCertPwd(configuration.get(Constants.CONFIG_KEY_PWD).getStringValue());
        openConfig.setTlCertPath(configuration.get(Constants.CONFIG_KEY_PUBLIC_KEY).getStringValue());
        this.sdkClient = new SdkClient(openConfig);
        this.init();
        logger.info("SdkClient create...");
    }

    private void init(){
        this.setServiceProvider(ServiceProvider.AllinPayCloud);
        this.setVersion(com.walker.pay.Constants.DEFAULT_VERSION);
        this.setPayChannel(PayChannel.ProviderDirect);

        if(this.sdkClient == null){
            throw new IllegalArgumentException("SdkClient 未创建，无法构建支付引擎:" + this.getClass().getName());
        }
        BankCardOrderGenerator bankCardOrderGenerator = new BankCardOrderGenerator();
        bankCardOrderGenerator.setSdkClient(this.sdkClient);

        WechatJsOrderGenerator wechatJsOrderGenerator = new WechatJsOrderGenerator();
        wechatJsOrderGenerator.setSdkClient(this.sdkClient);

        WechatProgramOrderGenerator wechatProgramOrderGenerator = new WechatProgramOrderGenerator();
        wechatProgramOrderGenerator.setSdkClient(this.sdkClient);

        ScanWechatOrderGenerator scanWechatOrderGenerator = new ScanWechatOrderGenerator();
        scanWechatOrderGenerator.setSdkClient(this.sdkClient);

        this.orderGeneratorMap.put(Constants.PAY_TYPE_QUICKPAY_VSP, bankCardOrderGenerator);
        this.orderGeneratorMap.put(Constants.PAY_TYPE_WECHAT_PUBLIC, wechatJsOrderGenerator);
        this.orderGeneratorMap.put(Constants.PAY_TYPE_WECHATPAY_MINIPROGRAM, wechatProgramOrderGenerator);
        this.orderGeneratorMap.put(Constants.PAY_TYPE_SCAN_WEIXIN, scanWechatOrderGenerator);
    }

    private SdkClient sdkClient = null;
    private Map<String, OrderGenerator> orderGeneratorMap = new HashMap<>(8);

    /**
     * 用于测试，使用sdk对象。
     * @return
     * @date 2023-02-21
     */
    public SdkClient getSdkClient(){
        return this.sdkClient;
    }
}