eHealthAfrica/direct-delivery-dashboard

'use strict'

angular.module('reports')
  .service('packingReportService', function ($q, dbService, productService, deliveryRoundService) {
    var _this = this

    function defaultFields () {
      return {
        expectedQty: 0,
        returnedQty: 0,
        onHandQty: 0,
        deliveredQty: 0
      }
    }

    function getGrouped (group, type, row) {
      if (!group.hasOwnProperty(type)) {
        group[type] = {}
      }
      group = groupByZone(group, row, type)
      group = groupByLGA(group, row, type)
      group = groupByWard(group, row, type)

      return group
    }

    function groupByWard (group, row, type) {
      if (!group[type][row.zone][row.lga].hasOwnProperty(row.ward)) {
        group[type][row.zone][row.lga][row.ward] = {}
      }

      if (type === 'ward' && !group[type][row.zone][row.lga][row.ward].hasOwnProperty(row.productID)) {
        group[type][row.zone][row.lga][row.ward][row.productID] = defaultFields()
        group[type][row.zone][row.lga][row.ward][row.productID] = updateProductCount(group[type][row.zone][row.lga][row.ward][row.productID], row)
      }

      return group
    }

    function groupByLGA (group, row, type) {
      if (!group[type][row.zone].hasOwnProperty(row.lga)) {
        group[type][row.zone][row.lga] = {}
      }

      if (type === 'lga' && !group[type][row.zone][row.lga].hasOwnProperty(row.productID)) {
        group[type][row.zone][row.lga][row.productID] = defaultFields()
        group[type][row.zone][row.lga][row.productID] = updateProductCount(group[type][row.zone][row.lga][row.productID], row)
      }
      return group
    }

    function groupByZone (group, row, type) {
      if (!group[type].hasOwnProperty(row.zone)) {
        group[type][row.zone] = {}
      }

      if (type === 'zone' && !group[type][row.zone].hasOwnProperty(row.productID)) {
        group[type][row.zone][row.productID] = defaultFields()
        group[type][row.zone][row.productID] = updateProductCount(group[type][row.zone][row.productID], row)
      }
      return group
    }

    function getProducts (list, row) {
      var productID = row.productID.trim()
      if (list.indexOf(productID) === -1) {
        list.push(productID)
      }

      return list
    }

    function updateProductCount (object, row) {
      object.expectedQty += row.expectedQty || 0
      object.returnedQty += row.returnedQty || 0
      object.onHandQty += row.onHandQty || 0
      object.deliveredQty += row.deliveredQty || 0

      return object
    }

    function collatePackingReport (deliveries, productsList, deliveryRounds, roundKey) {
      var rows = deliveries.rows
      var orderedObject = productOrder(productsList)

      var i = rows.length
      var grouped = {
        zone: {},
        lga: {},
        ward: {}
      }
      var products = []

      while (i--) {
        var row = rows[i].value
        var roundID = rows[i].key[roundKey]
        if (deliveryRounds && roundID && deliveryRounds.indexOf(roundID) === -1) {
          continue // skip
        }
        grouped = getGrouped(grouped, 'zone', row)
        grouped = getGrouped(grouped, 'lga', row)
        grouped = getGrouped(grouped, 'ward', row)
        products = getProducts(products, row)
      }

      products = orderProducts(products, orderedObject)
      return {
        group: grouped,
        products: products
      }
    }

    function orderProducts (productList, orderedObject) {
      return productList.sort(function (a, b) {
        var aVal = orderedObject[a.toLowerCase()]
        var bVal = orderedObject[b.toLowerCase()]

        var diff = aVal - bVal
        return !isNaN(diff) ? diff : productList.length
      })
    }

    function productOrder (productList) {
      var orderedObject = {}
      var i = productList.length
      while (i--) {
        orderedObject[productList[i].altName] = productList[i].order
      }
      return orderedObject
    }

    _this.getPackingReport = function (startDate, endDate, state) {
      var view = 'reports/packing-by-date'
      startDate = new Date(startDate).toJSON()
      endDate = new Date(endDate).toJSON()
      var options = {
        startkey: [startDate],
        endkey: [endDate, {}, {}]
      }

      var params = {
        startkey: [state.name],
        endkey: [state.name, {}]
      }

      var promises = [
        dbService.getView(view, options),
        productService.getAll(),
        deliveryRoundService.getBy(params)
      ]
      return $q.all(promises)
        .then(function (response) {
          var deliveryRoundIds = []
          response[2].rows.forEach(function (row) {
            deliveryRoundIds.push(row.id)
          })
          return collatePackingReport(response[0], response[1], deliveryRoundIds, 1)
        })
    }

    _this.getPackingReportByRound = function (roundID) {
      var view = 'reports/packing-by-round'
      var options = {
        startkey: [roundID],
        endkey: [roundID, {}, {}]
      }
      var promises = [
        dbService.getView(view, options),
        productService.getAll()
      ]
      return $q.all(promises)
        .then(function (response) {
          return collatePackingReport(response[0], response[1], [roundID], 0)
        })
    }
  })