package com.foxinmy.weixin4j.pay.api;
   
   import com.foxinmy.weixin4j.api.BaseApi;
   import com.foxinmy.weixin4j.exception.WeixinException;
   import com.foxinmy.weixin4j.http.weixin.WeixinRequestExecutor;
   import com.foxinmy.weixin4j.pay.model.WeixinPayAccount;
   import com.foxinmy.weixin4j.pay.payment.mch.MerchantResult;
   import com.foxinmy.weixin4j.pay.sign.WeixinPaymentSignature;
   import com.foxinmy.weixin4j.pay.type.IdQuery;
  import com.foxinmy.weixin4j.pay.sign.WeixinSignature;
  import com.foxinmy.weixin4j.util.RandomUtil;
  import com.foxinmy.weixin4j.util.StringUtil;
  import com.foxinmy.weixin4j.util.Weixin4jConfigUtil;
  
  import java.io.File;
  import java.io.FileInputStream;
  import java.io.IOException;
  import java.io.InputStream;
  import java.util.HashMap;
  import java.util.Map;
  import java.util.ResourceBundle;
  
  /**
   * 商户支付
   *
   * @className MchApi
   * @author jinyu(foxinmy@gmail.com)
   * @date 2016年3月26日
   * @since JDK 1.6
   * @see <a href="https://pay.weixin.qq.com/wiki/doc/api/index.html">商户支付平台</a>
   */
  public class MchApi extends BaseApi {
      private final static ResourceBundle WEIXIN_BUNDLE;
  
      private final static String PEM_CERT_PREFIX = "-----BEGIN CERTIFICATE-----";
  
      static {
          WEIXIN_BUNDLE = ResourceBundle.getBundle("com/foxinmy/weixin4j/pay/weixin");
      }
  
      protected final WeixinPayAccount weixinAccount;
      protected final WeixinSignature weixinSignature;
      private volatile WeixinRequestExecutor weixinSSLExecutor;
  
      public MchApi(WeixinPayAccount weixinAccount) {
          this.weixinAccount = weixinAccount;
          this.weixinSignature = new WeixinPaymentSignature(weixinAccount.getPaySignKey());
      }
  
      @Override
      protected ResourceBundle weixinBundle() {
          return WEIXIN_BUNDLE;
      }
  
      /**
       * 支付接口请求基本数据
       *
       * @param idQuery
       *            ID信息 可为空
       * @return 基础map
       */
      protected Map<String, String> createBaseRequestMap(IdQuery idQuery) {
          Map<String, String> map = new HashMap<String, String>();
          map.put("appid", weixinAccount.getId());
          map.put("mch_id", weixinAccount.getMchId());
          map.put("nonce_str", RandomUtil.generateString(16));
          if (StringUtil.isNotBlank(weixinAccount.getDeviceInfo())) {
              map.put("device_info", weixinAccount.getDeviceInfo());
          }
          if (StringUtil.isNotBlank(weixinAccount.getSubId())) {
              map.put("sub_appid", weixinAccount.getSubId());
          }
          if (StringUtil.isNotBlank(weixinAccount.getSubMchId())) {
              map.put("sub_mch_id", weixinAccount.getSubMchId());
          }
          if (idQuery != null) {
              map.put(idQuery.getType().getName(), idQuery.getId());
          }
          return map;
      }
  
      /**
       * 微信签名类
       *
       * @return
       */
      public WeixinSignature getWeixinSignature() {
          return this.weixinSignature;
      }
  
      /**
       * 微信SSL
       *
       * @return
       */
      protected WeixinRequestExecutor getWeixinSSLExecutor() throws WeixinException {
          if (weixinSSLExecutor == null) {
              if(weixinAccount.getCertificateFile().startsWith(PEM_CERT_PREFIX)){
                  // 证书是PEM格式，直接使用PEM内容生成请求执行类
                 this.weixinSSLExecutor = weixinExecutor.createSSLRequestExecutor(weixinAccount.getMchId(),
                         weixinAccount.getCertificateFile(), weixinAccount.getCertificateKey());
             }else {
                 // 证书是p12格式，读取证书文件并生成请求执行类
                 try {
                     InputStream is = null;
                     File certificate = new File(
                             Weixin4jConfigUtil.replaceClassPathValue(weixinAccount.getCertificateFile()));
                     if (!certificate.exists() || !certificate.isFile()) {
                         is = Weixin4jConfigUtil.CLASSLOADER.getResourceAsStream(certificate.getName());
                     } else {
                         is = new FileInputStream(certificate);
                     }
                     if (is == null) {
                         throw new WeixinException("Invalid certificate file : " + certificate.toString());
                     }
                     this.weixinSSLExecutor = weixinExecutor.createSSLRequestExecutor(weixinAccount.getCertificateKey(), is);
                 } catch (IOException e) {
                     throw new WeixinException("IO Error on createSSLRequestExecutor", e);
                 }
             }
         }
         return this.weixinSSLExecutor;
     }
 
     /**
      * 设置商户信息
      *
      * @param merchant
      */
     protected <T extends MerchantResult> void declareMerchant(T merchant) {
         merchant.setAppId(weixinAccount.getId());
         merchant.setMchId(weixinAccount.getMchId());
         merchant.setDeviceInfo(weixinAccount.getDeviceInfo());
         merchant.setSubAppId(weixinAccount.getSubId());
         merchant.setSubMchId(weixinAccount.getSubMchId());
         merchant.setNonceStr(RandomUtil.generateString(16));
     }
 }