update customer rebate

app/models/customer.rb

@@ -104,13 +104,13 @@ class Customer < ApplicationRecord
                                 'Accept'       => 'application/json'
                         })
         rescue Net::OpenTimeout
-        response = { status: false }
+        response = { status: false, message: "Server Time out" }
         
         rescue OpenURI::HTTPError
-          response = { status: false}
+          response = { status: false, message: "Can't connect server"}
 
         rescue SocketError
-          response = { status: false}
+          response = { status: false, message: "Can't connect server"}
         end
 
         if response["status"] == true
@@ -120,6 +120,76 @@ class Customer < ApplicationRecord
     end
   end
 
+  def self.update_rebate
+
+    sales    = Sale.where("rebate_status = 'false'")
+    sales.each do |sale|
+      if sale.customer.membership_id
+          response = self.rebat(Sale.find(sale.sale_id))
+           puts response.to_json
+           if response["status"] == true
+             status   = sale.update_attributes(rebate_status: "true")
+           end
+      end
+    end
+  end
+
+  def self.rebat(sObj)
+    rebate_prices = SaleItem.calculate_rebate_by_account(sObj.sale_items)
+
+    generic_customer_id = sObj.customer.membership_id
+    if generic_customer_id.present?
+      paypar = sObj.sale_payments
+      payparcost = 0
+      credit = 0
+      paypar.each do |pp|
+        if pp.payment_method == "paypar"
+          payparcost = payparcost + pp.payment_amount
+        elsif pp.payment_method == "creditnote"
+          credit = 1
+        end
+      end
+      # overall_dis = SaleItem.get_overall_discount(sObj.id)
+      overall_dis = sObj.total_discount
+
+      total_amount = rebate_prices - payparcost - overall_dis
+      if credit == 1
+        total_amount = 0
+      end
+      if total_amount >= 0
+        receipt_no = sObj.receipt_no
+        membership      = MembershipSetting.find_by_membership_type("paypar_url")
+        memberaction    = MembershipAction.find_by_membership_type("rebate")
+        merchant_uid    = memberaction.merchant_account_id.to_s
+        campaign_type_id = memberaction.additional_parameter["campaign_type_id"]
+        auth_token       = memberaction.auth_token.to_s
+        url             = membership.gateway_url.to_s + memberaction.gateway_url.to_s
+
+        # Control for Paypar Cloud
+        begin
+          response        = HTTParty.post(url, :body => { generic_customer_id:generic_customer_id ,total_sale_transaction_amount: sObj.grand_total,merchant_uid:merchant_uid,total_amount: total_amount,campaign_type_id: campaign_type_id,
+                                                        receipt_no: receipt_no,auth_token:auth_token}.to_json,
+                                             :headers => {
+                                                      'Content-Type' => 'application/json',
+                                                      'Accept'       => 'application/json'
+                                              }, :timeout => 10)
+        rescue Net::OpenTimeout
+           response = { "status": false , "message": "Connect To" }
+        
+
+        rescue OpenURI::HTTPError
+           response = { "status": false, "message": "Can't connect server"}
+          
+        rescue SocketError
+           response = { "status": false, "message": "Can't connect server"}
+          
+        end
+        return response
+         puts response.to_json
+        end
+    end
+  end
+
   def self.search(search)
     if search
       # find(:all, :conditions => ['name LIKE ? OR contact_no LIKE ?', "%#{search}%", "%#{search}%"])