273 lines
11 KiB
Ruby
273 lines
11 KiB
Ruby
class OrderReservation < ApplicationRecord
|
|
self.primary_key = "order_reservation_id"
|
|
|
|
#primary key - need to be unique generated for multiple shops
|
|
before_create :generate_custom_id
|
|
|
|
has_many :order_reservation_items
|
|
has_one :delivery
|
|
|
|
scope :active, -> { where("created_at BETWEEN '#{DateTime.now.utc.beginning_of_day}' AND '#{DateTime.now.utc.end_of_day}'") }
|
|
scope :latest_order, -> { order("order_reservation_id desc, created_at desc") }
|
|
|
|
SEND_TO_KITCHEN = "send_to_kitchen"
|
|
READY_TO_DELIVERY = "ready_to_deliver"
|
|
DELIVERED = "delivered"
|
|
COMPLETED = "completed"
|
|
|
|
def self.addOrderReservationInfo(order_reserve)
|
|
Rails.logger.debug order_reserve.to_s
|
|
check_order_reservation = OrderReservation.where("transaction_ref = ?",order_reserve[:reference])
|
|
if check_order_reservation.empty?
|
|
order_reservation = OrderReservation.new
|
|
order_reservation.order_reservation_type = order_reserve[:order_type]
|
|
order_reservation.customer_id = order_reserve[:cus_info]
|
|
order_reservation.requested_time = Time.parse(order_reserve[:requested_time]).utc
|
|
order_reservation.callback_url = order_reserve[:callback_url]
|
|
order_reservation.transaction_ref = order_reserve[:reference]
|
|
if order_reserve[:order_info]
|
|
order_reservation.item_count = order_reserve[:order_info][:items].count
|
|
order_reservation.payment_type = order_reserve[:payment_info][:payment_type]
|
|
order_reservation.payment_status = order_reserve[:payment_info][:payment_status]
|
|
order_reservation.payment_ref = order_reserve[:payment_info][:payment_ref]
|
|
order_reservation.taxes = order_reserve[:payment_info][:taxes]
|
|
order_reservation.total_amount = order_reserve[:payment_info][:sub_total]
|
|
order_reservation.total_tax = order_reserve[:payment_info][:total_tax]
|
|
order_reservation.discount_amount = order_reserve[:payment_info][:discount_amount]
|
|
order_reservation.convenience_charge = order_reserve[:payment_info][:convenience_charge]
|
|
order_reservation.grand_total = order_reserve[:payment_info][:grand_total]
|
|
order_reservation.order_remark = order_reserve[:order_info][:order_remark]
|
|
end
|
|
if order_reserve[:reservation_info]
|
|
order_reservation.total_customer = order_reserve[:reservation_info][:total_user]
|
|
order_reservation.reservation_remark = order_reserve[:reservation_info][:reservation_note]
|
|
end
|
|
order_reservation.save!
|
|
if order_reserve[:order_info][:items]
|
|
order_reserve[:order_info][:items].each do |oritem|
|
|
OrderReservationItem.process_order_reservation_item(oritem[:product_code],oritem[:item_instance_code],oritem[:product_name],oritem[:product_alt_name],
|
|
oritem[:account_id],oritem[:qty],oritem[:price],oritem[:unit_price],
|
|
oritem[:options],nil,order_reservation.id)
|
|
end
|
|
end
|
|
if order_reserve[:delivery_info]
|
|
Delivery.addDeliveryInfo(order_reserve[:delivery_info],order_reservation.id)
|
|
end
|
|
return order_reservation.id, true
|
|
else
|
|
return check_order_reservation[0].id, false
|
|
end
|
|
end
|
|
|
|
def self.create_doemal_order(order,current_user)
|
|
is_extra_time = false
|
|
extra_time = ''
|
|
|
|
items_arr = []
|
|
count = 1
|
|
order.order_reservation_items.each { |i|
|
|
i.item_instance_code = i.item_instance_code.downcase.to_s
|
|
items = {"order_item_id": count,"item_instance_code": i.item_instance_code,"quantity": i.qty,"options": []}
|
|
count += 1
|
|
items_arr.push(items)
|
|
}
|
|
|
|
puts items_arr.to_json
|
|
puts "sssssssssssssssssssssss"
|
|
customer_id = order.customer_id
|
|
|
|
@order = Order.new
|
|
@order.source = "doemal_order"
|
|
@order.order_type = "delivery"
|
|
@order.customer_id = customer_id
|
|
@order.items = items_arr
|
|
@order.guest = ''
|
|
@order.table_id = nil # this is dining facilities's id
|
|
@order.new_booking = true
|
|
@order.waiters = current_user.name
|
|
@order.employee_name = current_user.name
|
|
|
|
@order.is_extra_time = is_extra_time
|
|
@order.extra_time = extra_time
|
|
|
|
@status, @booking = @order.generate
|
|
|
|
# Order.send_customer_view(@booking)
|
|
if @status && @booking
|
|
|
|
@status, @sale = Sale.request_bill(@order,current_user,current_user)
|
|
|
|
#order status send to doemal
|
|
callback_response = send_status_to_ordering(order.callback_url,order.transaction_ref,SEND_TO_KITCHEN)
|
|
#order reservation status updated
|
|
update_order_reservation(order.id, @sale.sale_id, SEND_TO_KITCHEN)
|
|
|
|
result = {:status=> @status, :data => @sale, :message => "created" }
|
|
return result
|
|
end
|
|
end
|
|
|
|
def self.update_doemal_payment(order,current_user)
|
|
if(Sale.exists?(order.sale_id))
|
|
saleObj = Sale.find(order.sale_id)
|
|
shop_details = Shop.first
|
|
# rounding adjustment
|
|
if shop_details.is_rounding_adj
|
|
a = saleObj.grand_total % 25 # Modulus
|
|
b = saleObj.grand_total / 25 # Division
|
|
#not calculate rounding if modulus is 0 and division is even
|
|
#calculate rounding if modulus is zero or not zero and division are not even
|
|
if (a != 0.0 && b%2 != 0.0) || (a==0.0 && b%2 !=0)
|
|
new_total = Sale.get_rounding_adjustment(saleObj.grand_total)
|
|
rounding_adj = new_total-saleObj.grand_total
|
|
saleObj.update_attributes(grand_total: new_total,old_grand_total: saleObj.grand_total,rounding_adjustment:rounding_adj)
|
|
end
|
|
end
|
|
#end rounding adjustment
|
|
|
|
sale_payment = SalePayment.new
|
|
sale_payment.process_payment(saleObj, current_user.name, saleObj.grand_total, "cash")
|
|
|
|
#order status send to doemal
|
|
callback_response = send_status_to_ordering(order.callback_url,order.transaction_ref,DELIVERED)
|
|
#order reservation status updated
|
|
update_order_reservation(order.id, saleObj.sale_id, DELIVERED)
|
|
|
|
result = {:status=> true, :message => DELIVERED }
|
|
return result
|
|
end
|
|
end
|
|
|
|
def self.send_status_to_ordering(url,ref_no,status,waiting_time=nil)
|
|
base_url = 'https://api.doemal.com'
|
|
token = '3T-tnlYtFJ-5Z1vY6XQqxQ'
|
|
order_reservation = Lookup.collection_of("order_reservation")
|
|
if !order_reservation.empty?
|
|
order_reservation.each do |order_reserve|
|
|
if order_reserve[0] == 'BaseURL'
|
|
base_url = order_reserve[1]
|
|
elsif order_reserve[0] == 'Token'
|
|
token = order_reserve[1]
|
|
end
|
|
end
|
|
else
|
|
Rails.logger.debug "Add order reservation BaseURL "
|
|
response = {status: false}
|
|
end
|
|
Rails.logger.debug "Doemal URL" + base_url
|
|
post_url = base_url + url
|
|
|
|
if !waiting_time.nil?
|
|
send_params = {id: ref_no, waiting_time: waiting_time, status: status}
|
|
else
|
|
send_params = {id: ref_no, status: status}
|
|
end
|
|
|
|
begin
|
|
response = HTTParty.post(post_url,
|
|
:body => send_params.to_json,
|
|
:headers => {
|
|
'Authorization' => 'Token token='+token,
|
|
'Content-Type' => 'application/json',
|
|
'Accept' => 'application/json; version=3'
|
|
}, :timeout => 10
|
|
)
|
|
rescue Net::OpenTimeout
|
|
response = { status: false }
|
|
|
|
rescue OpenURI::HTTPError
|
|
response = { status: false}
|
|
rescue SocketError
|
|
response = { status: false}
|
|
end
|
|
Rails.logger.debug "Get Doemal Status "
|
|
Rails.logger.debug response.to_json
|
|
return response
|
|
end
|
|
|
|
def self.update_order_reservation(id, sale_id, status, expected_waiting_time=nil)
|
|
order_reservation = OrderReservation.find(id)
|
|
if sale_id.present?
|
|
order_reservation.sale_id = sale_id
|
|
end
|
|
if !expected_waiting_time.nil?
|
|
order_reservation.expected_waiting_time = DateTime.parse(expected_waiting_time).utc
|
|
end
|
|
order_reservation.status = status
|
|
order_reservation.save
|
|
end
|
|
|
|
def self.get_count_on_order
|
|
order_reservation = OrderReservation.select("COUNT(order_reservation_id) as count, status").group("status")
|
|
end
|
|
|
|
def self.get_pending_orders
|
|
order_reservation = OrderReservation.select("order_reservations.*,del.provider,del.delivery_type")
|
|
.joins(" JOIN deliveries as del on del.order_reservation_id=order_reservations.order_reservation_id")
|
|
.where("order_reservations.status='new'")
|
|
.order("order_reservations.order_reservation_id desc, order_reservations.created_at desc")
|
|
end
|
|
|
|
def self.check_new_order
|
|
order_reservation = OrderReservation.where("status='new'")
|
|
if order_reservation.length > 0
|
|
if ENV["SERVER_MODE"] == 'cloud'
|
|
ActionCable.server.broadcast "check_new_order_channel",data: order_reservation
|
|
end
|
|
end
|
|
end
|
|
|
|
def self.check_order_send_to_kitchen
|
|
today = Time.now.utc
|
|
order_reservation = OrderReservation.where("status='accepted' and requested_time > '#{today}' and expected_waiting_time < '#{today}'")
|
|
if order_reservation.length > 0
|
|
if ENV["SERVER_MODE"] == 'cloud'
|
|
ActionCable.server.broadcast "check_order_send_to_kitchen_channel",data: order_reservation
|
|
end
|
|
end
|
|
end
|
|
|
|
def self.check_order_ready_to_delivery
|
|
today = Time.now.utc
|
|
order_reservation = OrderReservation.where("status='send_to_kitchen' and requested_time > '#{today}' and expected_waiting_time < '#{today}'")
|
|
if order_reservation.length > 0
|
|
if ENV["SERVER_MODE"] == 'cloud'
|
|
ActionCable.server.broadcast "check_order_ready_to_delivery_channel",data: order_reservation
|
|
end
|
|
end
|
|
end
|
|
|
|
def self.get_order_reservation_by_shift(shift_sale_range,shift,from,to,provider)
|
|
## => left join -> show all sales although no orders
|
|
if provider.blank?
|
|
provider = ''
|
|
else
|
|
if provider.present?
|
|
provider = " and deliveries.provider = '#{provider}'"
|
|
end
|
|
end
|
|
|
|
query = OrderReservation.joins(" JOIN deliveries on deliveries.order_reservation_id = order_reservations.order_reservation_id")
|
|
.joins(" JOIN sales on sales.sale_id = order_reservations.sale_id")
|
|
if shift.present?
|
|
query = query.where("sales.shift_sale_id in (?) #{provider} and sales.sale_status= 'completed' and sale_payments.payment_amount != 0", shift.to_a)
|
|
.joins("join sale_payments on sale_payments.sale_id = sales.sale_id")
|
|
.group("sales.sale_id")
|
|
elsif shift_sale_range.present?
|
|
query = query.where("sales.sale_status='completed' #{provider} and sale_payments.payment_amount != 0 and sales.shift_sale_id in (?)",shift_sale_range.to_a)
|
|
.joins("join sale_payments on sale_payments.sale_id = sales.sale_id")
|
|
.group("sales.sale_id")
|
|
else
|
|
query = query.where("sales.sale_status='completed' and sales.receipt_date between ? and ? #{provider} and sale_payments.payment_amount != 0",from,to)
|
|
.joins("join sale_payments on sale_payments.sale_id = sales.sale_id")
|
|
.group("sales.sale_id")
|
|
end
|
|
return query
|
|
end
|
|
|
|
private
|
|
def generate_custom_id
|
|
self.order_reservation_id = SeedGenerator.generate_id(self.class.name, "ODRS")
|
|
end
|
|
end
|