WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py

     CreditTxnType.LOAN_CANCELLED : -1,
     CreditTxnType.PAID : -1,
     CreditTxnType.CORRECTION : -1
+}
+creditorTicketSizeMap = {}
+creditorDueDateMap = {}
 stateIdMap = {}
 def fetchStateMaster():
     global stateIdMap
     if stateIdMap:
             glob_inventory_client = InventoryClient().get_client()
             stateIdMap = glob_inventory_client.getStateMaster()
             return stateIdMap
         except:
             print "Could not fetch"
+def fetchCreditorTicketSizeMap():
+    global creditorTicketSizeMap
+    allCreditors = Creditor.query.all()
+    for creditor in allCreditors:
+        creditorTicketSizeMap[creditor.id] = creditor.ticket_size
+def fetchCreditorDueDateMap():
+    global creditorDueDateMap
+    allCreditors = Creditor.query.all()
+    for creditor in allCreditors:
+        creditorDueDateMap[creditor.id] = creditor.credit_due_days
 delhi_pincodes = ['110001','110002','110003','110004','110005','110006','110007','110008','110009','110010','110011','110012','110013','110014','110015',\
                 '110016','110017','110018','110019','110020','110021','110022','110023','110024','110025','110026','110027','110028','110029','110030',\
                 '110031','110032','110033','110034','110035','110037','110038','110041','110042','110044','110045','110046','110047','110048','110049',\
                 '110051','110052','110053','110054','110055','110056','110057','110058','110059','110060','110061','110062','110063','110064','110065',\
     us_query = UserSanction.query
     if userId:
         us_query = us_query.filter(UserSanction.user_id == userId)
     if creditorId:
         us_query = us_query.filter(UserSanction.creditor_id == creditorId)
-    return us_query.all()
+    allSanctions = us_query.all()
+    returnMap = {}
+    for sanction in allSanctions:
+        ticket_size = -1
+        if creditorTicketSizeMap.has_key(sanction.creditor_id):
+            ticket_size = creditorTicketSizeMap.get(sanction.creditor_id)
+        else:
+            fetchCreditorTicketSizeMap()
+            ticket_size = creditorTicketSizeMap.get(sanction.creditor_id)
+        if returnMap.has_key(sanction.creditor_id):
+            creditorMap = returnMap.get(sanction.creditor_id)
+            creditorMap['TicketSize'] = ticket_size
+            if creditorMap.has_key('Sanctions'):
+                sanctionsList = creditorMap.get('Sanctions')
+                sanctionsList.append(sanction)
+                creditorMap['Sanctions'] = sanctionsList
+            else:
+                sanctionsList =[]
+                sanctionsList.append(sanction)
+                creditorMap['Sanctions'] = sanctionsList
+            returnMap[sanction.creditor_id] = creditorMap
+        else:
+            creditorMap
+            creditorMap['TicketSize'] = ticket_size
+            sanctionsList =[]
+            sanctionsList.append(sanction)
+            creditorMap['Sanctions'] = sanctionsList
+            returnMap[sanction.creditor_id] = creditorMap
+    return returnMap
 def update_user_sanction(userSanction):
     userS = UserSanction.get_by(id=userSanction.id)
     if userS is None:
         return False
                 loanHistoryRec.creditor_id = creditorId
                 loanHistoryRec.payment_id = paymentId
                 loanHistoryRec.amount = creditTxn.amount * loanTxnMultplierMap.get(creditTxn.credit_type)
                 loanHistoryRec.credit_type = CreditTxnType._VALUES_TO_NAMES[creditTxn.credit_type]
                 loanHistoryRec.loan_id = creditTxn.loan_id
+                if creditorDueDateMap.has_key(creditorId):
+                    due_days = creditorDueDateMap.get(creditorId)
-                loanHistoryRec.due_date = datetime.datetime.now()+timedelta(days=30)
+                    loanHistoryRec.due_date = datetime.datetime.now()+timedelta(days=due_days)
+                else:
+                    fetchCreditorDueDateMap()
+                    due_days = creditorDueDateMap.get(creditorId)
+                    loanHistoryRec.due_date = datetime.datetime.now()+timedelta(days=due_days)
         else:
             logging.info("Error: Entry already existed for "+str(paymentId) + " Shipping Id:- "+str(creditTxns[0].shipping_id) +" Credit Txn Type:- "+CreditTxnType._VALUES_TO_NAMES[creditTxn.credit_type]+ " in Credit History ")
             raise TransactionServiceException(227, "Error: Entry already existed for "+str(paymentId) + " Shipping Id:- "+str(creditTxns[0].shipping_id) +" Credit Txn Type:- "+CreditTxnType._VALUES_TO_NAMES[creditTxn.credit_type]+ " in Credit History ")
     session.commit()
     return True
                 loanHistoryRec.payment_id = paymentId
                 loanHistoryRec.amount = loanTxn.amount * loanTxnMultplierMap.get(loanTxn.credit_type)
                 loanHistoryRec.credit_type = CreditTxnType._VALUES_TO_NAMES[loanTxn.credit_type]
                 loanHistoryRec.loan_id = loanTxn.loan_id
                 if loanTxn.credit_type in [CreditTxnType.LOAN]:
+                    if creditorDueDateMap.has_key(creditorId):
+                        due_days = creditorDueDateMap.get(creditorId)
-                    loanHistoryRec.due_date = datetime.datetime.now()+timedelta(days=30)
+                        loanHistoryRec.due_date = datetime.datetime.now()+timedelta(days=due_days)
+                    else:
+                        fetchCreditorDueDateMap()
+                        due_days = creditorDueDateMap.get(creditorId)
+                        loanHistoryRec.due_date = datetime.datetime.now()+timedelta(days=due_days)
                 if loanTxn.credit_type in [CreditTxnType.CORRECTION]:
                     loanRec = LoanHistory.get_by(payment_id=paymentId,loan_id=loanTxn.loan_id, credit_type='LOAN')
                     loanRec.updated = datetime.datetime.now()
                     userSanction.loan = userSanction.loan + (loanTxn.amount * loanTxnMultplierMap.get(loanTxn.credit_type))
             else:

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py – Rev 18664 → 18677