package com.walker.pay.wechat.v2;

import com.walker.infrastructure.arguments.Variable;
import com.walker.infrastructure.utils.KeyValue;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.pay.Order;
import com.walker.pay.PayContext;
import com.walker.pay.ResponsePay;
import com.walker.pay.wechat.Constants;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;

import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;

public class AppOrderGenerator extends BaseOrderGenerator {

    public AppOrderGenerator(RestTemplate restTemplate){
        this.setRestTemplate(restTemplate);
    }

    @Override
    protected ResponsePay invoke(PayContext payContext, Order platformOrder) {
        WechatV2PayContext context = (WechatV2PayContext) payContext;
        String appId = context.getAppIdConfig().getStringValue();
        String mchId = context.getMchIdConfig().getStringValue();
        String apiKey = context.getApiKeyConfig().getStringValue();

        String request = this.toRequest(payContext.getProviderPayType(), platformOrder, appId, mchId, apiKey);

        ResponseEntity<String> entity = this.getRestTemplate().postForEntity(Constants.URL_ORDER_V2, request, String.class);
        if(entity == null){
            throw new RuntimeException("调用'微信APP'订单返回空数据, orderId = " + platformOrder.getId());
        }
        Map<String, String> responseMap = SignUtils.decodeXml(entity.getBody());
        if(responseMap == null){
            throw new RuntimeException("调用'微信APP'订单返回数据转换为空: SignUtils.decodeXml() == null");
        }

        AppOrderResponsePay responseValue = new AppOrderResponsePay();

        if(responseMap.get("return_code").equals("FAIL")){
//            logger.error("调用微信统一下单远程接口失败：" + responseMap.get("return_msg"));
            responseValue.setStatus(false);
            responseValue.setMessage(responseMap.get("return_msg"));
            logger.debug("微信APP支付订单返回失败:{}", responseMap);
            return responseValue;
        }

        // 需要组装手机APP需要的数据，用于调起微信APP完成App支付
        TreeMap<String, String> wxApiResult = new TreeMap<>();
        wxApiResult.put("appId", appId);
        wxApiResult.put("partnerId", mchId);
        wxApiResult.put("prepayId", responseMap.get("prepay_id"));
        wxApiResult.put("packageValue", "Sign=WXPay");
        wxApiResult.put("nonceStr", StringUtils.generateRandomNumber(6));
        wxApiResult.put("timeStamp", String.valueOf(System.currentTimeMillis() / 1000));

        List<KeyValue<String, String>> signParams = new LinkedList<>();
        signParams.add(new KeyValue("appid", appId));
        signParams.add(new KeyValue("noncestr", wxApiResult.get("nonceStr")));
        signParams.add(new KeyValue("package", wxApiResult.get("packageValue")));
        signParams.add(new KeyValue("partnerid", mchId));
        signParams.add(new KeyValue("prepayid", wxApiResult.get("prepayId")));
        signParams.add(new KeyValue("timestamp", wxApiResult.get("timeStamp")));
        wxApiResult.put("sign", SignUtils.getAppSign(signParams, apiKey));

        responseValue.setAppOrderInfo(wxApiResult);
        return responseValue;
    }

    @Deprecated
    @Override
    protected ResponsePay invoke(String providerPayType, Order platformOrder, Map<String, Variable> configuration) {
//        String appId = configuration.get(Constants.CONFIG_KEY_APP_ID).getStringValue();
//        String mchId = configuration.get(Constants.CONFIG_KEY_MCH_ID).getStringValue();
//        String apiKey = configuration.get(Constants.CONFIG_KEY_API_KEY).getStringValue();
        throw new UnsupportedOperationException("该方法已废弃!");
        /*String request = this.toRequest(providerPayType, platformOrder, appId, mchId, apiKey);

        ResponseEntity<String> entity = restTemplate.postForEntity(Constants.URL_ORDER_V2, request, String.class);
        if(entity == null){
            throw new RuntimeException("调用'微信APP'订单返回空数据, orderId = " + platformOrder.getId());
        }
        Map<String, String> responseMap = SignUtils.decodeXml(entity.getBody());
        if(responseMap == null){
            throw new RuntimeException("调用'微信APP'订单返回数据转换为空: SignUtils.decodeXml() == null");
        }

        AppOrderResponsePay responseValue = new AppOrderResponsePay();

        if(responseMap.get("return_code").equals("FAIL")){
//            logger.error("调用微信统一下单远程接口失败：" + responseMap.get("return_msg"));
            responseValue.setStatus(false);
            responseValue.setMessage(responseMap.get("return_msg"));
            logger.debug("微信APP支付订单返回失败:{}", responseMap);
            return responseValue;
        }

        // 需要组装手机APP需要的数据，用于调起微信APP完成App支付
        TreeMap<String, String> wxApiResult = new TreeMap<>();
        wxApiResult.put("appId", appId);
        wxApiResult.put("partnerId", mchId);
        wxApiResult.put("prepayId", responseMap.get("prepay_id"));
        wxApiResult.put("packageValue", "Sign=WXPay");
        wxApiResult.put("nonceStr", StringUtils.generateRandomNumber(6));
        wxApiResult.put("timeStamp", String.valueOf(System.currentTimeMillis() / 1000));

        List<KeyValue<String, String>> signParams = new LinkedList<>();
        signParams.add(new KeyValue("appid", appId));
        signParams.add(new KeyValue("noncestr", wxApiResult.get("nonceStr")));
        signParams.add(new KeyValue("package", wxApiResult.get("packageValue")));
        signParams.add(new KeyValue("partnerid", mchId));
        signParams.add(new KeyValue("prepayid", wxApiResult.get("prepayId")));
        signParams.add(new KeyValue("timestamp", wxApiResult.get("timeStamp")));
        wxApiResult.put("sign", SignUtils.getAppSign(signParams, apiKey));

        responseValue.setAppOrderInfo(wxApiResult);
        return responseValue;*/
    }

//    private RestTemplate restTemplate;

//    @Override
//    protected String acquireSign(List<KeyValue<String, String>> params, String apiKey) {
//        return SignUtils.getAppSign(params, apiKey);
//    }
}