Merge pull request #42 from gomicorp/hotfix/kpi

핫픽스 : KPI 로직 추가

Author: yhk1038

app/models/cart.rb

@@ -6,23 +6,41 @@ def initialize(cart)
     @items = cart.items
   end
 
-  def price_sum
-    items.map(&:price_sum).sum
+  # def price_sum
+  #   items.map(&:price_sum).sum
+  # end
+
+  # 품목 단위 수량 합계
+  def unit_count
+    items.map(&:unit_count_sum).sum
+  end
+
+  # 정가 합계
+  def base_price
+    items.map(&:base_price).sum
   end
 
+  # 정가 총 합계
+  def base_price_sum
+    items.map(&:base_price_sum).sum
+  end
+
+  # 변동가 합계
+  # 일반적인 경우, 음수값을 가짐
   def discount_amount
-    items.map(&:discount_amount).sum
+    items.map(&:price_change_sum).sum
   end
 
   def delivery_amount
     cart.delivery_amount.to_i
   end
 
   def final_result_price
-    price_sum - discount_amount + delivery_amount
+    base_price_sum + discount_amount + delivery_amount
   end
 end
 
+
 class Cart < ApplicationRecord
   # 신규(desk) 입금대기(pay) 결제완료(paid) 배송준비(ship_ready) 배송중(ship_ing) 취소요청(cancel-request) 반품요청(refund-request) 환불실패 보관함(complete)
 
@@ -38,35 +56,48 @@ class Cart < ApplicationRecord
   enum order_status: ORDER_STATUSES
 
   belongs_to :user
-  has_many :items, class_name: CartItem.name, dependent: :destroy
+  has_many :items, class_name: 'CartItem', dependent: :destroy
   has_one :order_info, dependent: :nullify
 
   delegate :ordered_at, to: :order_info, allow_nil: true
   delegate :delivery_amount, to: :order_info, allow_nil: true
 
   scope :active, -> { where(active: true) }
+  scope :sold, -> { where(order_status: SOLD_STATUSES) }
 
   def self.current
     @_current = find_or_create_by(order_status: 0, current: true)
   end
 
-  def price_sum
-    calculator.price_sum # 총 상품 가격
+  # 품목 단위 수량 합계
+  def unit_count
+    calculator.unit_count
   end
 
-  alias_method :_delivery_amount, :delivery_amount
-  def delivery_amount
-    _delivery_amount || ShipInfo.fee_table('normal') # 배송비
+  # 총 정가 합계
+  def base_price_sum
+    calculator.base_price_sum
   end
 
+  # 총 할인 가격
   def discount_amount
-    calculator.discount_amount # 총 할인 가격
+    calculator.discount_amount
+  end
+
+  alias_method :_delivery_amount, :delivery_amount
+  def delivery_amount
+    _delivery_amount || ShipInfo.fee_table(unit_count < 3 ? 'express' : 'bulk_express') # 배송비
   end
 
+  # 총 합계 (최종 결제액)
   def final_price
-    calculator.final_result_price # 총 합계
+    calculator.final_result_price
   end
 
+  # def price_sum
+  #   calculator.price_sum # 총 상품 가격
+  # end
+
   def sender_name
     user.name
   end

app/models/cart_item.rb

@@ -5,55 +5,141 @@ class CartItem < ApplicationRecord
 
   resettable_counter_for :barcodes
 
-  belongs_to :cart
-  belongs_to :product
-  belongs_to :product_option
-  has_many :cart_item_barcodes
-  has_many :item_barcodes, class_name: 'ProductItemBarcode', through: :cart_item_barcodes
-  has_one :cancelled_tag, class_name: 'CartItemCancelledTag'
-
-
   ##========================================
   # LEGACY
+  belongs_to :product, optional: true
   has_many :barcodes, dependent: :nullify
   has_many :product_options, -> { distinct }, through: :barcodes
   ##========================================
 
-  delegate :order_info, to: :cart, allow_nil: true
+  belongs_to :cart
+  belongs_to :product_option
+  delegate :product_page, to: :product_option
+  delegate :unit_count, to: :product_option
+  has_many :bridges, through: :product_option
 
-  def _barcode_count
-    @_barcode_count ||= barcodes.length
-  end
+  has_many :cart_item_barcodes, dependent: :destroy
+  has_many :product_item_barcodes, class_name: 'ProductItemBarcode', through: :cart_item_barcodes
+  has_one :cancelled_tag, class_name: 'CartItemCancelledTag'
+
+  has_one :order_info, through: :cart
 
-  def unit_price
-    _barcode_count.zero? ? 0 : barcodes.first&.price.to_i
+  scope :cancelled, -> { where(cancelled_tag: CartItemCancelledTag.all) }
+  scope :not_cancelled, -> { where.not(cancelled_tag: CartItemCancelledTag.all) }
+
+  scope :eager_resources, -> { includes(:cancelled_tag, cart: { order_info: :payment }) }
+  scope :cancelled_at, ->(range) { includes(:cancelled_tag).where(cancelled_tag: CartItemCancelledTag.where(cancelled_at: range)) }
+  scope :ordered_at, ->(range) { includes(cart: :order_info).where(cart: Cart.sold.where(order_info: OrderInfo.where(ordered_at: range))) }
+  scope :paid_at, ->(range) { eager_resources.not_cancelled.where(carts: { order_infos: { payments: { paid: true, paid_at: range } } }) }
+  # delegate :order_info, to: :cart, allow_nil: true
+  #
+  # def _barcode_count
+  #   @_barcode_count ||= barcodes.length
+  # end
+
+  # 단위 정가 & 합계
+  delegate :base_price, to: :product_option
+  def base_price_sum
+    option_count * product_option.base_price
   end
 
-  def price_sum
-    _barcode_count * unit_price
+  # 구성 품목 수량 & 합계
+  # A.K.A. EA (e.g. 10 EA)
+  # 몇 개의 ProductItem 재고단위로 구성되었는가.
+  delegate :unit_count, to: :product_option
+  def unit_count_sum
+    option_count * unit_count
   end
 
-  def discount_amount
-    0
+  # 단위 변동가 & 합계
+  # 일반적인 경우, 음수값을 가짐
+  delegate :price_change, to: :product_option
+  def price_change_sum
+    option_count * price_change
   end
 
+  # 합산 가격
   def result_price
-    price_sum - discount_amount
+    base_price_sum + price_change_sum
+  end
+
+  # def unit_price
+  #   option_count.zero? ? 0 : product_option.retail_price
+  # end
+
+  # def price_sum
+  #   option_count * product_option.base_price
+  # end
+
+  # # 할인 가액
+  # def discount_amount
+  #   option_count * product_option.discount_price
+  # end
+
+  # def retail_price_sum
+  #
+  # end
+
+  def cancel!
+    CartItemCancelledTag.create(cart_item: self, cancelled_at: Time.zone.now).persisted? unless cancelled
+    true
   end
 
-  def similar_barcodes
-    Barcode.options_with(product_options.ids)
+  def cancelled
+    cancelled_tag.present?
   end
 
-  def stat
-    @stat = StatReportService.new(self)
+  alias cancelled? cancelled
+
+  def cancelled_rollback
+    cancelled_tag.destroy!
   end
 
-  def self.migrate_cart_items
-    CartItem.where('created_at > ?', 4.months.ago).each do |cart_item|
-      cart_item.product_option = cart_item.product_options.first
-      cart_item.save!
+  def should_expired?
+    barcode_items = []
+    product_item_barcodes.each { |barcode| barcode_items << barcode.product_item }
+    bridge_items = product_option.bridges.map(&:items) * option_count
+    return true if barcode_items.flatten.pluck(:id).sort != bridge_items.flatten.pluck(:id).sort
+    return true unless product_option.is_active?
+    return true if updated_at < 3.days.ago
+
+    false
+  end
+
+  def expire!
+    ActiveRecord::Base.transaction do
+      product_item_barcodes.map(&:disexpire!)
+      destroy
     end
   end
+  #def similar_barcodes
+  #  Barcode.options_with(product_options.ids)
+  #end
+
+  def item_count(product_item)
+    product_option.items.count(product_item) * option_count
+  end
+
+  def self.item_count(product_item)
+    all.map { |cart_item| cart_item.item_count(product_item) }.sum
+  end
 
+  # def _barcode_count
+  #   @_barcode_count ||= barcodes.length
+  # end
+  #
+  # def unit_price
+  #   _barcode_count.zero? ? 0 : barcodes.first&.price.to_i
+  # end
+  #
+  # def price_sum
+  #   _barcode_count * unit_price
+  # end
+  #
+  # def self.migrate_cart_items
+  #   CartItem.where('created_at > ?', 4.months.ago).each do |cart_item|
+  #     cart_item.product_option = cart_item.product_options.first
+  #     cart_item.save!
+  #   end
+  # end
 end

app/services/business/kpi_report.rb

@@ -0,0 +1,44 @@
+module Business
+  class KpiReport
+    def self.call(date = Date.today)
+      date = date.in_time_zone
+      data_format = lambda do |orders|
+        {
+          count: orders.count,
+          price: orders.map { |order| order.cart.final_price }.sum
+        }
+      end
+
+      orders = OrderInfo.includes(:ship_info, cart: { items: [:product_option, :cancelled_tag] })
+      users = User.where(is_admin: [false, nil], is_manager: [false, nil], is_seller: [false, nil])
+
+
+      # 기간
+      range = date.beginning_of_month..date.end_of_month
+
+      # 주문 완료
+      complete_data = data_format.call(orders.where(ordered_at: range).sold)
+
+      # 주문 취소
+      cancelled_data = data_format.call(orders.where(cart: Cart.where(items: CartItem.cancelled_at(range))))
+
+      {
+        duration: {
+          from: range.first.strftime('%F'),
+          to: range.last.strftime('%F'),
+          length: 1.month
+        },
+        orders: {
+          complete: complete_data,
+          cancelled: cancelled_data,
+          GMV: complete_data[:price] - cancelled_data[:price],
+        },
+        users: {
+          newbie_count: users.where(created_at: range).count,
+          buyer_count: users.where(carts: Cart.where(order_info: OrderInfo.where(ordered_at: range))).count,
+          newbie_buyer_count: users.where(created_at: range).where(carts: Cart.where(order_info: OrderInfo.where(ordered_at: range))).count
+        }
+      }
+    end
+  end
+end