# encoding: utf-8 # noinspection RubyResolve require 'net/http' # noinspection RubyResolve require 'net/https' # noinspection RubyResolve require 'uri' # noinspection RubyResolve require 'json' # RetailCRM API Client # noinspection ALL class Retailcrm def initialize(url, key) @version = 3 @url = "#{url}/api/v#{@version}/" @key = key @params = { :apiKey => @key } @filter = nil @ids = nil end ## # === Get orders by filter # # Example: # >> Retailcrm.orders({:email => 'test@example.com', :status => 'new'}, 50, 2) # => {...} # # Arguments: # filter (Hash) # limit (Integer) (20|50|100) # page (Integer) def orders(filter = nil, limit = 20, page = 1) url = "#{@url}orders" @params[:limit] = limit @params[:page] = page @filter = filter.to_a.map { |x| "filter[#{x[0]}]=#{x[1]}" }.join('&') make_request(url) end ## # === Get orders statuses # # Example: # >> Retailcrm.orders_statuses([26120, 19282]) # => {...} # # Arguments: # ids (Array) def orders_statuses(ids = []) @ids = ids.map { |x| "ids[]=#{x}" }.join('&') url = "#{@url}orders/statuses" make_request(url) end ## # === Get orders by id (or externalId) # # Example: # >> Retailcrm.orders_get(345, 'id') # => {...} # # Arguments: # id (Integer) # by (String) # site (String) def orders_get(id, by = 'externalId', site = nil) url = "#{@url}orders/#{id}" if by != 'externalId' @params[:by] = by @params[:site] = site end make_request(url) end ## # === Create order # # Example: # >> Retailcrm.orders_create(order) # => {...} # # Arguments: # order (Array) # site (String) def orders_create(order, site = nil) url = "#{@url}orders/create" @params[:order] = order.to_json @params[:site] = site make_request(url, 'post') end ## # === Edit order # # Example: # >> Retailcrm.orders_edit(order) # => {...} # # Arguments: # order (Array) # site (String) def orders_edit(order, site = nil) id = order[:externalId] url = "#{@url}orders/#{id}/edit" @params[:order] = order.to_json @params[:site] = site make_request(url, 'post') end ## # === Upload orders # # Example: # >> Retailcrm.orders_upload(orders) # => {...} # # Arguments: # orders (Array) # site (String) def orders_upload(orders, site = nil) url = "#{@url}orders/upload" @params[:orders] = orders.to_json @params[:site] = site make_request(url, 'post') end ## # === Set external ids for orders created into CRM # # Example: # >> Retailcrm.orders_fix_external_ids([{:id => 200, :externalId => 334}, {:id => 201, :externalId => 364}]) # => {...} # # Arguments: # orders (Array) def orders_fix_external_ids(orders) url = "#{@url}orders/fix-external-ids" @params[:orders] = orders.to_json make_request(url, 'post') end ## # === Get orders history # # Example: # >> Retailcrm.orders_history('2015-04-10 22:23:12', '2015-04-10 23:33:12') # => {...} # # Arguments: # start_date (Time) (Time.strftime('%Y-%m-%d %H:%M:%S')) # end_date (Time) (Time.strftime('%Y-%m-%d %H:%M:%S')) # limit (Integer) (20|50|100) # offset (Integer) # skip_my_changes (Boolean) def orders_history(start_date = nil, end_date = nil, limit = 100, offset = 0, skip_my_changes = true) url = "#{@url}orders/history" @params[:startDate] = start_date @params[:endDate] = end_date @params[:limit] = limit @params[:offset] = offset @params[:skipMyChanges] = skip_my_changes make_request(url) end ## # === Get customers by filter # # Example: # >> Retailcrm.customers({:email => 'test@example.com'}, 50, 2) # => {...} # # Arguments: # filter (Hash) # limit (Integer) (20|50|100) # page (Integer) def customers(filter = nil, limit = 20, page = 1) url = "#{@url}customers" @params[:limit] = limit @params[:page] = page @filter = filter.to_a.map { |x| "filter[#{x[0]}]=#{x[1]}" }.join('&') make_request(url) end ## # === Get customers by id (or externalId) # # Example: # >> Retailcrm.customers_get(345, 'id') # => {...} # # Arguments: # id (Integer) # by (String) # site (String) def customers_get(id, by = 'externalId', site = nil) url = "#{@url}customers/#{id}" @params[:site] = site if by != 'externalId' @params[:by] = by end make_request(url) end ## # === Create customer # # Example: # >> Retailcrm.customer_create(customer) # => {...} # # Arguments: # customer (Array) # site (String) def customers_create(customer, site = nil) url = "#{@url}customers/create" @params[:customer] = customer.to_json @params[:site] = site make_request(url, 'post') end ## # === Edit customer # # Example: # >> Retailcrm.customers_edit(customer) # => {...} # # Arguments: # customer (Array) # site (String) def customers_edit(customer, site = nil) id = customer[:externalId] url = "#{@url}customers/#{id}/edit" @params[:customer] = customer.to_json @params[:site] = site make_request(url, 'post') end ## # === Upload customers # # Example: # >> Retailcrm.customers_upload(customers) # => {...} # # Arguments: # customers (Array) # site (String) def customers_upload(customers, site = nil) url = "#{@url}customers/upload" @params[:customers] = customers.to_json @params[:site] = site make_request(url, 'post') end ## # === Set external ids for customers created into CRM # # Example: # >> Retailcrm.customers_fix_external_ids([{:id => 200, :externalId => 334}, {:id => 201, :externalId => 364}]) # => {...} # # Arguments: # customers (Array) def customers_fix_external_ids(customers) url = "#{@url}customers/fix-external-ids" @params[:customers] = customers.to_json make_request(url, 'post') end ## # === Get purchace prices & stock balance # # Example: # >> Retailcrm.store_inventories({:productExternalId => 26120, :details => 1}, 50, 2) # => {...} # # Arguments: # filter (Hash) # limit (Integer) (20|50|100) # page (Integer) def store_inventories(filter = nil, limit = 20, page = 1) url = "#{@url}store/inventories" @params[:limit] = limit @params[:page] = page @filter = filter.to_a.map { |x| "filter[#{x[0]}]=#{x[1]}" }.join('&') make_request(url) end ## # === Set purchace prices & stock balance # # Example: # >> Retailcrm.store_inventories_upload({:offers => [{:externalId => 123, :stores => [{:code => 'store_1', :available => 15, :purchasePrice => 1000}]}]}, :site => 'main_site') # => {...} # # Arguments: # offers (Array) # site (String) def store_inventories_upload(offers = [], site = nil) url = "#{@url}store/inventories/upload" @params[:offers] = offers @params[:site] = site make_request(url, 'post') end ## # === Get packs by filter # # Example: # >> Retailcrm.packs({:store => 'main'}, 50, 2) # => {...} # # Arguments: # filter (Hash) # limit (Integer) (20|50|100) # page (Integer) def packs(filter = nil, limit = 20, page = 1) url = "#{@url}orders/packs" @params[:limit] = limit @params[:page] = page @filter = filter.to_a.map { |x| "filter[#{x[0]}]=#{x[1]}" }.join('&') make_request(url) end ## # === Create pack # # Example: # >> Retailcrm.packs_create(pack) # => {...} # # Arguments: # pack (Array) # site (String) def packs_create(pack, site = nil) url = "#{@url}orders/packs/create" @params[:pack] = pack.to_json @params[:site] = site make_request(url, 'post') end ## # === Get orders assembly history # # Example: # >> Retailcrm.packs_history({:orderId => 26120, :startDate => '2015-04-10 23:33:12'}, 50, 2) # => {...} # # Arguments: # filter (Hash) # limit (Integer) (20|50|100) # page (Integer) def packs_history(filter = nil, limit = 20, page = 1) url = "#{@url}orders/packs/history" @params[:limit] = limit @params[:page] = page @filter = filter.to_a.map { |x| "filter[#{x[0]}]=#{x[1]}" }.join('&') make_request(url) end ## # === Get pack by id # # Example: # >> Retailcrm.packs_get(345) # => {...} # # Arguments: # id (Integer) # site (String) def packs_get(id, site = nil) url = "#{@url}orders/packs/#{id}" @params[:site] = site make_request(url) end ## # === Edit pack # # Example: # >> Retailcrm.packs_edit(pack) # => {...} # # Arguments: # pack (Array) # site (String) def packs_edit(pack, site = nil) id = pack[:id] url = "#{@url}orders/packs/#{id}/edit" @params[:pack] = pack.to_json @params[:site] = site make_request(url, 'post') end ## # === Delete pack # # Example: # >> Retailcrm.packs_delete(14) # => {...} # # Arguments: # id (Integer) # site (String) def packs_delete(id, site = nil) url = "#{@url}orders/packs/#{id}/delete" @params[:site] = site make_request(url, 'post') end ## # === Get delivery services # def delivery_services url = "#{@url}reference/delivery-services" make_request(url) end ## # === Edit delivery service # def delivery_services_edit(delivery_service) code = delivery_service[:code] url = "#{@url}reference/delivery-services/#{code}/edit" @params[:deliveryService] = delivery_service.to_json make_request(url, 'post') end # Get delivery types # def delivery_types url = "#{@url}reference/delivery-types" make_request(url) end ## # === Edit delivery type # def delivery_types_edit(delivery_type) code = delivery_type[:code] url = "#{@url}reference/delivery-types/#{code}/edit" @params[:deliveryType] = delivery_type.to_json make_request(url, 'post') end ## # === Get order methods # def order_methods url = "#{@url}reference/order-methods" make_request(url) end ## # === Edit order method # def order_methods_edit(order_method) code = order_method[:code] url = "#{@url}reference/order-methods/#{code}/edit" @params[:orderMethod] = order_method.to_json make_request(url, 'post') end ## # === Get order types # def order_types url = "#{@url}reference/order-types" make_request(url) end ## # === Edit order type # def order_types_edit(order_type) code = order_type[:code] url = "#{@url}reference/order-types/#{code}/edit" @params[:orderType] = order_type.to_json make_request(url, 'post') end # Get payment statuses # def payment_statuses url = "#{@url}reference/payment-statuses" make_request(url) end ## # === Edit payment status # def payment_statuses_edit(payment_status) code = payment_status[:code] url = "#{@url}reference/payment-statuses/#{code}/edit" @params[:paymentStatus] = payment_status.to_json make_request(url, 'post') end ## # === Get payment types # def payment_types url = "#{@url}reference/payment-types" make_request(url) end ## # === Edit payment type # def payment_types_edit(payment_type) code = payment_type[:code] url = "#{@url}reference/payment-types/#{code}/edit" @params[:paymentType] = payment_type.to_json make_request(url, 'post') end ## # === Get product statuses # def product_statuses url = "#{@url}reference/product-statuses" make_request(url) end ## # === Edit product status # def product_statuses_edit(product_status) code = product_status[:code] url = "#{@url}reference/product-statuses/#{code}/edit" @params[:productStatus] = product_status.to_json make_request(url, 'post') end # Get sites list # def sites url = "#{@url}reference/sites" make_request(url) end ## # === Edit site # def sites_edit(site) code = site[:code] url = "#{@url}reference/sites/#{code}/edit" @params[:site] = site.to_json make_request(url, 'post') end ## # === Get status groups # def status_groups url = "#{@url}reference/status-groups" make_request(url) end # Get statuses # def statuses url = "#{@url}reference/statuses" make_request(url) end ## # === Edit status # def statuses_edit(status) code = status[:code] url = "#{@url}reference/statuses/#{code}/edit" @params[:status] = status.to_json make_request(url, 'post') end ## # === Get stores # def stores url = "#{@url}reference/stores" make_request(url) end ## # === Edit store # def stores_edit(store) code = store[:code] url = "#{@url}reference/stores/#{code}/edit" @params[:store] = store.to_json make_request(url, 'post') end # Get countries list # def countries url = "#{@url}reference/countries" make_request(url) end ## # === Statistic update # def statistic_update url = "#{@url}statistic/update" make_request(url) end protected def make_request(url, method='get') raise ArgumentError, 'url must be not empty' unless !url.empty? uri = URI.parse(url) https = Net::HTTP.new(uri.host, uri.port) https.use_ssl = true if method == 'post' request = Net::HTTP::Post.new(uri) request.set_form_data(@params) elsif method == 'get' request = Net::HTTP::Get.new(uri.path) request.set_form_data(@params) data = "#{request.body}" unless @filter.nil? data = data + "&#{@filter}" end unless @ids.nil? data = data + "&#{@ids}" end request = Net::HTTP::Get.new("#{uri.path}?#{data}") end response = https.request(request) Retailcrm::Response.new(response.code, response.body) end end class Retailcrm::Response attr_reader :status, :response def initialize(status, body) @status = status @response = body.empty? ? [] : JSON.parse(body) end def is_successfull? @status.to_i < 400 end end