# -*- coding: utf-8 -*-
##############################################################################
#
# Copyright (c) 2010 Nexedi SA and Contributors. All Rights Reserved.
#
# WARNING: This program as such is intended to be used by professional
# programmers who take the whole responsibility of assessing all potential
# consequences resulting from its eventual inadequacies and bugs
# End users who are looking for a ready-to-use solution with commercial
# guarantees and support are strongly advised to contract a Free Software
# Service Company
#
# This program is Free Software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; either version 2
# of the License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
#
##############################################################################

import zope.interface
from AccessControl import ClassSecurityInfo
from Products.ERP5Type import Permissions, PropertySheet, interfaces
from Products.ERP5Type.XMLObject import XMLObject
from Products.ERP5.mixin.solver import SolverMixin
from Products.ERP5.mixin.configurable import ConfigurableMixin
from Products.ERP5Type.UnrestrictedMethod import UnrestrictedMethod
from Products.ERP5Type.Message import translateString

class MovementSplitSolver(SolverMixin, ConfigurableMixin, XMLObject):
  meta_type = 'ERP5 Movement Split Solver'
  portal_type = 'Movement Split Solver'
  add_permission = Permissions.AddPortalContent
  isIndexable = 0 # We do not want to fill the catalog with objects on which we need no reporting

  # Declarative security
  security = ClassSecurityInfo()
  security.declareObjectProtected(Permissions.AccessContentsInformation)

  # Default Properties
  property_sheets = ( PropertySheet.Base
                    , PropertySheet.XMLObject
                    , PropertySheet.CategoryCore
                    , PropertySheet.DublinCore
                    , PropertySheet.Arrow
                    , PropertySheet.TargetSolver
                    )
  # Declarative interfaces
  zope.interface.implements(interfaces.ISolver,
                            interfaces.IConfigurable,
                           )

  def _solve(self, activate_kw=None):
    """
    This method splits a Delivery and move movements in to a new
    Delivery. Splitting is done by duplicating the Delivery, removing
    needless lines excess and updating related content.
    """
    delivery_dict = {}
    for simulation_movement in self.getDeliveryValueList():
      movement = simulation_movement.getDeliveryValue()
      delivery = movement.getRootDeliveryValue()
      delivery_dict.setdefault(delivery, []).append(simulation_movement)

    for delivery, split_simulation_movement_list \
        in delivery_dict.iteritems():
      # First, duplicate the whole delivery document including its
      # sub objects.
      applied_rule = delivery.getCausalityRelatedValue(
          portal_type='Applied Rule')
      parent = delivery.getParentValue()
      cp, = UnrestrictedMethod(lambda parent, *ids:
          parent._duplicate(parent.manage_copyObjects(ids=ids))
        )(parent, delivery.getId())
      new_delivery = parent[cp['new_id']]
      old_delivery_url = delivery.getRelativeUrl()
      new_delivery_url = new_delivery.getRelativeUrl()

      reindex_path_list = [new_delivery.getPath()]
      update_related_content_tag_list = []

      old_simulation_movement_list = []
      new_simulation_movement_list = []

      def _isDescendant(parent, child):
        """
        /1 and /1/2 => True
        /1 and /1 => True
        /1/2 and /1 => False
        """
        return ('%s/' % child.getRelativeUrl()).startswith(
          '%s/' % parent.getRelativeUrl())

      def _delete(obj):
        parent = obj.getParentValue()
        parent.deleteContent(obj.getId())
        if len(parent) == 0 and parent != parent.getRootDeliveryValue():
          _delete(parent)

      for movement in delivery.getMovementList():
        simulation_movement_list = movement.getDeliveryRelatedValueList()
        old = []
        new = []
        for simulation_movement in simulation_movement_list:
          for parent in split_simulation_movement_list:
            if _isDescendant(parent, simulation_movement):
              new.append(simulation_movement)
              break
          else:
            old.append(simulation_movement)
        if len(new) == 0:
          # Case 1. the movement is only used for the old delivery.
          # * remove from the new delivery
          old_simulation_movement_list.extend(
            [x.getRelativeUrl() for x in simulation_movement_list])
          _delete(delivery.unrestrictedTraverse(
            movement.getRelativeUrl().replace(
            old_delivery_url, new_delivery_url)))
        elif len(old) == 0:
          # Case 2. the movement is only used for the new delivery.
          # * update related content on the new movement
          # * remove from the old delivery
          new_movement_url = movement.getRelativeUrl().replace(
            old_delivery_url, new_delivery_url)
          movement.updateRelatedContent(movement.getRelativeUrl(),
                                        new_movement_url)
          update_related_content_tag_list.append('%s_updateRelatedContent'
                                                 % movement.getPath())
          new_movement_path = movement.getPath().replace(
            old_delivery_url, new_delivery_url)
          reindex_path_list.append(new_movement_path)
          reindex_path_list.extend(
            [x.getPath() for x in simulation_movement_list])
          new_simulation_movement_list.extend(
            [x.getRelativeUrl() for x in simulation_movement_list])
          _delete(movement)
        else:
          # Case 3. the movement is used for both the old and the new
          # delivery.
          # * modify 'delivery' value on simulation movements that are
          #   related to the new delivery.
          # * recalculate quantity on simulation movements
          for simulation_moment in new:
            simulation_movement.setDelivery(
              simulation_movement.getDelivery().replace(
              '%s/' % old_delivery_url, '%s/' % new_delivery_url))
            reindex_path_list.append(simulation_movement.getRelativeUrl())
          quantity_dict = {}
          for simulation_movement in simulation_movement_list:
            delivery_movement = simulation_movement.getDeliveryValue()
            quantity_dict[delivery_movement] = \
                quantity_dict.get(delivery_movement, 0) + \
                simulation_movement.getQuantity()
          for simulation_movement in simulation_movement_list:
            delivery_movement = simulation_movement.getDeliveryValue()
            total_quantity = quantity_dict[delivery_movement]
            quantity = simulation_movement.getQuantity()
            delivery_ratio = quantity / total_quantity
            delivery_error = total_quantity * delivery_ratio - quantity
            simulation_movement.edit(delivery_ratio=delivery_ratio,
                                     delivery_error=delivery_error)
          for movement, quantity in quantity_dict.iteritems():
            movement.setQuantity(quantity)

      assert delivery.getMovementList() and new_delivery.getMovementList()

      # check if root applied rule exists and needs to be modified
      if applied_rule is not None:
        movement_list = [x.getRelativeUrl() for x in \
                         applied_rule.objectValues()]
        new_root_simulation_movement_list = \
            [x for x in new_simulation_movement_list if x in movement_list]
        old_root_simulation_movement_list = \
            [x for x in old_simulation_movement_list if x in movement_list]

        if len(new_root_simulation_movement_list) == 0:
          # we need to do nothing
          pass
        elif len(old_root_simulation_movement_list) == 0:
          # we need to modify the causality to the new delivery
          applied_rule.setCausality(new_delivery_url)
        else:
          # we need to split simulation movement tree
          new_applied_rule = delivery.getPortalObject().portal_simulation.newContent(
            portal_type='Applied Rule',
            specialise=applied_rule.getSpecialise(),
            causality=new_delivery_url)
          id_list = [x.rsplit('/', 1)[-1] for x in \
                     new_root_simulation_movement_list]
          cut_data = applied_rule.manage_cutObjects(id_list)
          new_applied_rule.manage_pasteObjects(cut_data)
          reindex_path_list = [\
            x.replace('%s/' % applied_rule.getRelativeUrl(),
                      '%s/' % new_applied_rule.getRelativeUrl()) for x in \
            reindex_path_list]

      # Update variation category list
      def _updateVariationCategoryList(document):
        line_dict = {}
        for movement in document.getMovementList():
          parent = movement.getParentValue()
          if getattr(parent, 'setVariationCategoryList', None) is not None:
            line_dict.setdefault(parent, []).extend(
              movement.getVariationCategoryList())
        for line, category_list in line_dict.iteritems():
          line.setVariationCategoryList(sorted(set(category_list)))
      _updateVariationCategoryList(delivery)
      _updateVariationCategoryList(new_delivery)

      # Set comment on old and new delivery explaining what (and when) happened
      doActionFor = delivery.getPortalObject().portal_workflow.doActionFor
      doActionFor(delivery, 'edit_action', comment=translateString(
        'Split to Delivery ${new_delivery_url}',
        mapping={'new_delivery_url':new_delivery_url}))
      doActionFor(new_delivery, 'edit_action', comment=translateString(
        'Split from Delivery ${old_delivery_url}',
        mapping={'old_delivery_url':old_delivery_url}))

      # Update causality state
      activate_kw = dict(after_tag_list=update_related_content_tag_list,
        after_path_and_method_id=(reindex_path_list,
          ('immediateReindexObject','recursiveImmediateReindexObject')))
      delivery.activate(**activate_kw).updateCausalityState()
      new_delivery.activate(**activate_kw).updateCausalityState()

      # Update causality values
      delivery.activate(**activate_kw).fixConsistency(
          filter={'id':'causality_validity'})
      new_delivery.activate(**activate_kw).fixConsistency(
          filter={'id':'causality_validity'})
      for related_value in delivery.getCausalityRelatedValueList():
        if related_value.getPortalType() == 'Applied Rule':
          continue
        related_value.activate(**activate_kw).fixConsistency(
            filter={'id':'causality_validity'})

    # Finish solving
    if self.getPortalObject().portal_workflow.isTransitionPossible(
      self, 'succeed'):
      self.succeed()