#
#    Copyright (C) 2002-2014  Corporation of Balclutha. All rights Reserved.
#
#    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.
#
#    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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
#
#    THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
#    AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
#    IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
#    ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
#    LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
#    CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
#    GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
#    HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
#    LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
#    OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
#
 
import unittest
 
from LedgerTestCase import LedgerTestCase
 
from Acquisition import aq_base
from DateTime import DateTime
from Products.BastionBanking.ZCurrency import ZCurrency
from Products.BastionLedger.utils import floor_date
from Products.AdvancedQuery import Between, Eq
from Products.BastionLedger.BLGlobals import EPOCH
 
def txnQ(ledger, effective):
    return map(lambda x: x.getObject(),
               ledger.bastionLedger().evalAdvancedQuery(Eq('meta_type', 'BLEntry') & Between('effective', effective -1 , effective + 1)))
 
def accQ(ledger, effective):
    return map(lambda x: x.getObject(),
               ledger.bastionLedger().evalAdvancedQuery(Eq('meta_type', 'BLEntry') & Between('effective', effective -1 , effective + 1)))
 
class TestTransaction(LedgerTestCase):
    """
    verify transaction workflow
    """
    def _mkTxn(self, effective, acc1, acc2, amount, title='My Txn'):
        txn = self.ledger.Ledger.createTransaction(title=title, effective=effective)
        txn.createEntry(acc1, amount)
        txn.createEntry(acc2, -amount)
        return txn
 
    def testCataloging(self):
        ledger = self.portal.ledger.Ledger
        effective = DateTime('2012/01/01')
 
        self.loginAsPortalOwner()
 
        INDEX_COUNT = len(self.ledger.evalAdvancedQuery(Eq('status', 'posted')))
 
        txn = self._mkTxn(effective, 'A000001', 'A000002', ZCurrency('GBP 10.00'))
 
        self.assertEqual(txn.isMultiCurrency(), False)
 
        self.assertEqual(len(txnQ(ledger, effective)), 2)
        self.assertEqual(len(ledger.A000002.entryValues()), 0)
 
        self.assertEqual(len(self.ledger.evalAdvancedQuery(Eq('status', 'posted'))), INDEX_COUNT)
        self.assertEqual(len(txnQ(ledger, effective)), 2)
        self.assertEqual(len(ledger.A000002.entryValues()), 0)
 
        txn.manage_post()
 
        # TODO - figure out how to differentiate between acc & txn entries
        self.assertEqual(len(txnQ(ledger, effective)), 2)
 
        self.assertEqual(len(self.ledger.evalAdvancedQuery(Eq('accountId', 'A000002'))), 1)
        self.assertEqual(len(self.ledger.evalAdvancedQuery(Eq('status', 'posted'))), INDEX_COUNT + 3) # txn + 2 entries
        self.assertEqual(len(self.ledger.evalAdvancedQuery(Between('effective', effective-1, effective+1))), 3)
 
        self.assertEqual(len(ledger.A000002.entryValues()), 1)
        self.assertEqual(len(ledger.A000002.entryValues(effective + 1)), 1)
        self.assertEqual(len(ledger.A000002.entryValues((effective-1, effective+1))), 1)
 
        # enforce deletion/reversal
        ledger.manage_delObjects([txn.getId()])
        self.assertEqual(len(ledger.A000002.entryValues()), 0)
        self.assertEqual(len(self.ledger.evalAdvancedQuery(Eq('status', 'posted'))), INDEX_COUNT) # 2 entries
 
 
    def testAggregates(self):
        ledger = self.portal.ledger.Ledger
        self.failUnless(getattr(ledger, 'portal_workflow', False))
        dt = DateTime()
        tid = ledger.manage_addProduct['BastionLedger'].manage_addBLTransaction(effective=dt)
	txn = ledger._getOb(tid)
        txn.manage_addProduct['BastionLedger'].manage_addBLEntry('A000001', 'GBP 10.00')
        self.assertEqual(txn.total(), ZCurrency('GBP10.00'))
        txn.manage_addProduct['BastionLedger'].manage_addBLEntry('A000001', 'GBP 10.00')
        self.assertEqual(txn.total(), ZCurrency('GBP 20.00'))
        self.assertEqual(txn.effective(), floor_date(dt))
 
    def testWorkflow(self):
        ledger = self.portal.ledger.Ledger
        self.loginAsPortalOwner()
 
        now = DateTime('2011/01/01')
 
        tid = ledger.manage_addProduct['BastionLedger'].manage_addBLTransaction(title='My Txn',
                                                                                effective=now)
	txn = ledger._getOb(tid)
 
        self.assertEqual(txn.status(), 'incomplete')
 
        txn.manage_addProduct['BastionLedger'].manage_addBLEntry('A000001', 'GBP 10.00')
        self.assertEqual(txn.status(), 'incomplete')
 
        txn.manage_addProduct['BastionLedger'].manage_addBLEntry('A000002', -ZCurrency('GBP 10.00'))
        self.assertEqual(txn.debitTotal(), ZCurrency('GBP 10.00'))
        self.assertEqual(txn.creditTotal(), -ZCurrency('GBP 10.00'))
        self.assertEqual(txn.status(), 'complete')
        self.assertEqual(txn.CreationDate()[:10], DateTime().strftime('%Y-%m-%d'))
 
        txn.content_status_modify(workflow_action='post')
        self.assertEqual(txn.status(), 'posted')
 
        # ensure it's not trashing the title (and effective date)
        self.assertEqual(txn.Title(), 'My Txn') 
 
        account = self.ledger.Ledger.A000001
        entry = account.blEntry(tid)
 
        self.assertEqual(entry.status(), 'posted')
        self.assertEqual(entry.account, account.getId())
        self.assertEqual(entry.accountId(), account.getId())
        self.assertEqual(entry.blAccount(), account)
        self.assertEqual(entry.blTransaction(), txn)
        self.assertEqual(entry.blLedger(), self.ledger.Ledger)
        self.assertEqual(entry.effective(), txn.effective())
        self.assertEqual(entry.amount, ZCurrency('GBP 10.00'))
        self.assertEqual(entry.isControlEntry(), False)
 
        #
        # hmmm - AEDT timezone's inconsistently f**k these tests ...
        #
        #now = DateTime()
        #self.assertEqual(entry.asCSV(),
        #                 'T000000000001,Ledger,T000000000001,"My Txn","%s", GBP 10.00 ,Ledger/A000001,posted' % now.strftime('%Y/%m/%d'))
        #self.assertEqual(entry.asCSV(datefmt='%Y', curfmt="%0.1f"),
        #                 'T000000000001,Ledger,T000000000001,"My Txn","%s",10.0,Ledger/A000001,posted' % now.strftime('%Y'))
 
        self.assertEqual(account.entryIds(), [tid])
        self.assertEqual(account.entryValues(), [entry])
        self.assertEqual(account.sum('A000002'), -ZCurrency('GBP10.00'))
        self.assertEqual(account.sum('A000002', debits=False), -ZCurrency('GBP10.00'))
        self.assertEqual(account.sum('A000002', credits=False), ZCurrency('GBP0.00'))
        self.assertEqual(account.entryValues(), [entry])
        self.assertEqual(account.entryValues([now - 1, now + 1]), [entry])        
	self.assertEqual(account.openingBalance(), ZCurrency('GBP 0.00'))
	self.assertEqual(account.openingDate(), EPOCH)
	self.assertEqual(account.openingBalance(EPOCH), ZCurrency('GBP 0.00'))
        self.assertEqual(account.entryValues([EPOCH, now+1]), [entry])
	self.assertEqual(account.total(effective=[EPOCH, now+1]), ZCurrency('GBP 10.00'))
	self.assertEqual(account.balance(), ZCurrency('GBP 10.00'))
 
        self.assertEqual(entry, txn.blEntry(account.getId()))
 
        self.assertEqual(len(ledger.transactionValues()), 1)
 
	txn.content_status_modify(workflow_action='reverse')
	self.assertEqual(txn.status(), 'reversed')
 
        self.assertEqual(len(ledger.transactionValues()), 2)
 
        self.assertEqual(len(account.entryValues()), 0), 
        self.assertEqual(len(account.entryValues(status=['postedreversal'])), 1)
        self.assertEqual(len(account.entryValues(status=['reversed'])), 1)
 
	self.assertEqual(account.balance(), 0)
 
        reversal_txn = txn.referenceObject()
        self.assertEqual(reversal_txn.status(), 'postedreversal')
        self.assertEqual(txn.status(), 'reversed')
 
        # see if reset ain't broke ...
        self.assertEqual(filter(lambda x: x.startswith('T'),
                                map(lambda x: x['id'],
                                    self.ledger.searchResults(meta_type=('BLTransaction', 
                                                                         'BLSubsidiaryTransaction',
                                                                         'BLEntry',
                                                                         'BLSubsidiaryEntry')))), 
                                ['T000000000001', 'T000000000002'])
        self.assertEqual(list(ledger.transactionIds()), 
                         ['T000000000001', 'T000000000002'])
 
        self.ledger.manage_reset()
 
        self.assertEqual(list(ledger.transactionIds()), [])
        self.assertEqual(filter(lambda x: x.startswith('T'),
                                map(lambda x: x['id'],
                                    self.ledger.searchResults(meta_type=('BLTransaction', 
                                                                         'BLSubsidiaryTransaction',
                                                                         'BLEntry',
                                                                         'BLSubsidiaryEntry')))), [])
 
    def testAccountToggling(self):
        ledger = self.portal.ledger.Ledger
        effective = DateTime('2012/01/01')
 
        self.loginAsPortalOwner()
 
        txn = self._mkTxn(effective, 'A000001', 'A000002', ZCurrency('GBP 10.00'))
        txn.manage_toggleAccount('A000002', 'A000003')
        self.assertEqual(txn.blEntry('A000002'), None)
        self.failUnless(txn.blEntry('A000003'))
        self.assertEqual(txn.blEntry('A000003').amount, -ZCurrency('GBP 10.00'))
 
        txn.manage_post()
        txn.manage_toggleAccount('A000003', 'A000002')
        self.failUnless(txn.blEntry('A000002'))
        self.assertEqual(txn.status(), 'posted')
 
    def testPortalFactoryCreation(self):
        self.loginAsPortalOwner()
        ledger = self.ledger.Ledger
        # doCreate should create the real object
        dt = DateTime('2000/01/01')
        temp_object = ledger.restrictedTraverse('portal_factory/BLTransaction/T000000000099')
        self.failUnless('T000000000099' in ledger.restrictedTraverse('portal_factory/BLTransaction').objectIds())
        A222222 = temp_object.portal_factory.doCreate(temp_object, 'T000000000099')
        self.failUnless('T000000000099' in ledger.objectIds())
 
        # document_edit should create the real object
        temp_object = ledger.restrictedTraverse('portal_factory/BLTransaction/T000000000100')
        self.failUnless('T000000000100' in ledger.restrictedTraverse('portal_factory/BLTransaction').objectIds())
        temp_object.bltransaction_edit(title='Foo', effective=dt)
        self.assertEqual(ledger.transactionValues(effective=dt)[0].title, 'Foo')
        self.failUnless('T000000000100' in ledger.objectIds())
 
        self.failUnless(abs(temp_object.created()-self.now) < self.RUN_TIME)
 
def test_suite():
    suite = unittest.TestSuite()
    suite.addTest(unittest.makeSuite(TestTransaction))
    return suite
 
 
if __name__ == '__main__':
    unittest.main()