WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py

 '''
 Created on 23-Mar-2010
 @author: ashish
 '''
-import datetime
-from functools import partial
-import math
-import operator
-from string import Template
-import sys
-import threading
-import traceback
-import urllib2
 from elixir import *
-from sqlalchemy import desc, asc
-from sqlalchemy.orm import aliased
+from functools import partial
-from sqlalchemy.sql.expression import or_, distinct, func, and_, exists
-from sqlalchemy.sql.functions import now
 from shop2020.clients.CatalogClient import CatalogClient
 from shop2020.clients.HelperClient import HelperClient
 from shop2020.clients.InventoryClient import InventoryClient
 from shop2020.clients.UserClient import UserClient
 from shop2020.config.client.ConfigClient import ConfigClient
     CentralGstMaster, CategoryHsnCodes, Tag_Listing, StateGstRate
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException, BannerType, InsurerType, \
     Banner as t_banner, CompetitorPricing as TCompetitorPricing, AmazonPromotionType, \
-    ItemCondition, StateGstRates, GstRate
+    ItemCondition, StateGstRates, GstRate, StateGstRate as TStateGstRate
 from shop2020.thriftpy.model.v1.inventory.ttypes import VatType, \
     InventoryServiceException, IgnoredInventoryUpdateItems, SnapdealInventoryItem
 from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
 from shop2020.thriftpy.utils.ttypes import UserSmsInfo, SmsType
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
 from shop2020.utils.Utils import to_py_date, log_risky_flag, to_java_date
+from sqlalchemy import desc, asc
+from sqlalchemy.orm import aliased
+from sqlalchemy.sql.expression import or_, distinct, func, and_, exists
+from sqlalchemy.sql.functions import now
+from string import Template
+import datetime
+import math
+import operator
+import sys
+import threading
+import traceback
+import urllib2
 sourceId = int(ConfigClient().get_property("sourceid"))
 to_addresses = ["khushal.bhatia@shop2020.in", "chandan.kumar@shop2020.in",  "chaitnaya.vats@shop2020.in",'manoj.kumar@shop2020.in']
 to_store_addresses = ["rajveer.singh@shop2020.in"]
         if itemIdIgstTaxRateMap.get(k) is None and itemIdItemMap[k].category==10006:
             itemIdIgstTaxRateMap[k] = 12
     return itemIdIgstTaxRateMap
-def add_state_gst_rate(stateGstRate):
+def add_state_gst_rates(stateGstRates):
+    #lets keep rates only for haryana and delhi i.e. 0 and 3
+    stateIds = [-1, 0, 3]
+    s = StateGstRate()
-    if stateGstRate is not None:
+    for stateGstRate in stateGstRates:
+        session.query(StateGstRate).filter(StateGstRate.item_id==stateGstRate.itemId).delete()
+        for sid in stateIds:
-        sgr = StateGstRate()
+            sgr = StateGstRate()
-        sgr.item_id = stateGstRate.item_id;
+            sgr.item_id = stateGstRate.itemId
+            sgr.state_id = sid
+            if sid==-1:
-        sgr.state_id = stateGstRate.state_id;
+                sgr.igst_rate = stateGstRate.igstRate
-        sgr.igst_rate = stateGstRate.igst_rate;
+                sgr.cgst_rate = stateGstRate.igstRate
-        sgr.igst_rate = stateGstRate.igst_rate;
+                sgr.sgst_rate = stateGstRate.igstRate
+            else:
+                sgr.igst_rate = 0
+                sgr.cgst_rate = stateGstRate.igstRate/2
-        sgr.igst_rate = stateGstRate.igst_rate;
+                sgr.sgst_rate = stateGstRate.igstRate/2
-        session.commit()
+    session.commit()
 def get_interstate_gst_rates():
     #CategoryState.query.filter_by(stateId=stateId)
     centralGstMap = {}
     alias1 = aliased(CentralGstMaster)
     return returnMap
 if __name__=='__main__':
     DataService.initialize()
-    itemIds = [26821]
+#    itemIds = [26821]
-    tagIds = [4,7]
+#    tagIds = [4,7]
-    tagListings = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status.in_([status.ACTIVE, status.PAUSED_BY_RISK])).filter(Tag_Listing.active==True).filter(Item.id.in_(itemIds)).filter(Tag_Listing.tag_id.in_(tagIds))
+#    tagListings = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status.in_([status.ACTIVE, status.PAUSED_BY_RISK])).filter(Tag_Listing.active==True).filter(Item.id.in_(itemIds)).filter(Tag_Listing.tag_id.in_(tagIds))
-    for tagListing in tagListings.all():
+#    for tagListing in tagListings.all():
-        print tagListing
+#        print tagListing
     #update_bulk_prices_on_production(21053,[])
     #search_terms = ["12206"]
     #print search_items(search_terms, 0, 20)
     #print get_search_result_count(search_terms)
+    rate = TStateGstRate()
+    rate.igstRate = 12
+    rate.itemId = 27702
+    add_state_gst_rates([rate])

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py – Rev 23310 → 23313