Contents

# 微信是同一个批次号未退款成功可重复申请
module Trade
  module Model::Refund::WxpayRefund

    def transaction_id
      refunded_payment&.payment_uuid
    end

    def out_trade_no
      self.origin&.payment_entity_no
    end

    def do_refund(**params)
      app = Wechat::WechatApp.find_by(mch_id: payment.seller_identifier)
      _params = {
        out_refund_no: self.refund_uuid,
        amount: {
          total: (payment.total_amount * 100).to_i,
          refund: (total_amount * 100).to_i,
          currency: 'CNY'
        },
        transaction_id: self.payment.payment_uuid
      }
      options = {
        mchid: app.mch_id,
        serial_no: app.serial_no
        #apiclient_cert: OpenSSL::X509::Certificate.new(app.apiclient_cert),
        #apiclient_key: OpenSSL::PKey::RSA.new(app.apiclient_key)
      }

      begin
        result = WxPay::Api.invoke_refund(_params, options)
      rescue StandardError => e
        result = {}
        result['return_code'] = e.message.truncate(225)
      ensure
        store_refund_result(result)
      end

      self
    end

    def store_refund_result(result = {})
      if ['PROCESSING', 'SUCCESS'].include? result['status']
        self.state = 'completed'
        self.refunded_at = result['success_time']
      else
        self.state = 'failed'
        self.comment = result['return_code']
      end
    end

    def refund_query
      return if state == 'completed'
      app = Wechat::WechatApp.find_by(mch_id: payment.seller_identifier)
      params = {
        out_refund_no: self.refund_uuid
      }
      options = {
        mchid: app.mch_id,
        serial_no: app.serial_no
      }

      result = WxPay::Api.refund_query(params, options)
      store_refund_result(result)
    end

    def refund_query!
      refund_query
      save
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rails_trade-0.0.3	app/models/trade/model/refund/wxpay_refund.rb