Subversion Repositories SmartDukaan

from sqlalchemy import create_engine
from elixir import *
from elixir.entity import Entity
from elixir.fields import Field
from elixir.options import using_options, using_table_options
from sqlalchemy.sql.expression import func
from sqlalchemy.types import Integer, String, DateTime, Float, Boolean, Enum, \
    Text
from sqlalchemy.dialects.mysql.base import LONGTEXT


class Users(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    username = Field(String(128))
    email = Field(String(128))
    password = Field(String(64))
    first_name = Field(String(64))
    last_name = Field(String(64))
    mobile_number = Field(String(15))
    referral_url = Field(String(256))
    referrer = Field(String(32))
    password_reset = Field(String(64))
    activation_code = Field(String(40))
    activated = Field(Boolean)
    group_id = Field(Integer(unsigned=True), default=1, server_default='1')
    status = Field(Boolean, default=True, server_default='1')
    utm_campaign = Field(String(128))
    activation_time = Field(DateTime)
    created = Field(DateTime)
    modified = Field(DateTime)
    usergroup_id = Field(Text)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class user_actions(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    store_product_id = Field(Integer(unsigned=True))
    action = Field(Enum('like','dislike'))
    created = Field(DateTime, default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class OnboardedRetailerChecklists(Entity):    
    id = Field(Integer(unsigned=True), primary_key=True)
    retailer_id = Field(Integer(unsigned=True))
    number_verification = Field(Boolean)
    preferences = Field(Boolean)
    doa_return_policy = Field(Boolean)
    payment_option = Field(Boolean)
    contact_us = Field(Boolean)
    product_info = Field(Boolean)
    redeem = Field(Boolean)
    created = Field(DateTime,default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class brand_preferences(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    category_id = Field(Integer(unsigned=True))
    brand = Field(String(128))
    status = Field(Enum('show','hide'),default='hide', server_default='hide')
    created = Field(DateTime)
    modified = Field(DateTime)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class price_preferences(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    category_id = Field(Integer(unsigned=True))
    min_price = Field(Float, default=0.0, server_default="0.0")
    max_price = Field(Float, default=0.0, server_default="0.0")
    created = Field(DateTime)
    modified = Field(DateTime)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class Brands(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    name = Field(String(128))
    category_id = Field(Integer)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class Feedbacks(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    email = Field(String(128))
    subject = Field(String(256))
    message = Field(Text)
    created = Field(DateTime)
    isTicketCreated = Field(Boolean, default=False, server_default='0')
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class Postoffices(Entity):
    id = Field(Integer(10, unsigned=True), primary_key=True)
    name = Field(String(128))
    pincode = Field(Integer(6, unsigned=True))
    deliverystatus = Field(Boolean)
    divisionname = Field(String(128))
    regionname = Field(String(128))
    taluk = Field(String(128))
    district = Field(String(128))
    state = Field(String(128))
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class Orders(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True), primary_key=True)
    store_id = Field(Integer(unsigned=True), primary_key=True)
    order_url = Field(String(256))
    status = Field(String(32))
    created = Field(DateTime)
    modified = Field(DateTime)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class FlipkartOrders(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    email = Field(String(128))
    subtagId= Field(String(32))
    identifier = Field(String(32))
    catalogId = Field(Integer)
    title = Field(String(128))
    brand = Field(String(64))
    model = Field(String(64))
    status = Field(String(16))
    price = Field(Float)
    category = Field(String(16))
    quantity = Field(SmallInteger)
    created = Field(DateTime)
    modified = Field(DateTime)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class OrdersRaw(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True), primary_key=True)
    store_id = Field(Integer(unsigned=True), primary_key=True)
    order_url = Field(String(256))
    sub_tag = Field(String(32))
    rawhtml = Field(LONGTEXT)
    status = Field(String(32))
    created = Field(DateTime)
    modified = Field(DateTime)
    using_options(tablename="orders")
    using_table_options(useexisting=True,mysql_engine="InnoDB")

class Retailers(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    identifier = Field(String(128))
    title = Field(String(256))
    address = Field(String(512))
    address_new = Field(String(512))
    agent_id=Field(Integer(unsigned=True))
    contact1 = Field(String(10))
    contact2 = Field(String(10))
    pin = Field(String(6))
    cod_limit = Field(Integer(10))
    city = Field(String(64))
    state = Field(String(48))
    status = Field(String(20))
    is_elavated = Field(Boolean)
    retry_count = Field(Integer(3))
    invalid_retry_count = Field(Integer(3))
    call_priority = Field(Enum('user_initiated', 'system_initiated'))
    next_call_time = Field(DateTime)
    is_std = Field(Boolean)
    is_or = Field(Boolean)
    created = Field(DateTime)
    disposition = Field(String(32))
    modified = Field(DateTime, default=func.now(), onupdate=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class RetailerAddresses(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    retailer_id = Field(Integer(unsigned=True))
    title = Field(String(128))
    agent_id=Field(Integer(unsigned=True))
    address = Field(String(512))
    city = Field(String(64))
    state = Field(String(48))
    pin = Field(String(6))
    created = Field(DateTime,default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
class DailySourcewiseOrderInfo(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    source = Field(Integer(2))
    order_count = Field(Integer(4))
    quantity_count = Field(Integer(4))
    sale_amount = Field(Integer(10))
    created = Field(DateTime)
    modified = Field(DateTime, default=func.now(), onupdate=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class AlreadyCalledNumbers(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    mobile_number = Field(String(10), unique=True)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class Pincodeavailability(Entity):
    code = Field(String(6), unique=True)
    amount = Field(Integer(11))
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class RetailerContacts(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    retailer_id = Field(Integer(unsigned=True))
    agent_id = Field(Integer(unsigned=True))
    mobile_number = Field(String(10))
    contact_type = Field(Enum('sms', 'called', 'ringing'))
    call_type = Field(String(10))
    created = Field(DateTime,default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    

class CallHistory(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    retailer_id = Field(Integer(unsigned=True))
    agent_id = Field(Integer(unsigned=True))
    mobile_number = Field(String(10))
    call_type = Field(String(10))
    sms_verified = Field(Boolean)
    call_time = Field(DateTime)
    duration_sec = Field(Integer)
    last_fetch_time = Field(DateTime) 
    call_disposition = Field(Enum('call_later','ringing_no_answer', 'not_reachable', 'switch_off', 'invalid_no', 'wrong_no', 'hang_up','retailer_not_interested', 'alreadyuser', 'verified_link_sent', 'onboarded'))
    disposition_description = Field(String(192))
    disposition_comments = Field(String(192))
    created = Field(DateTime,default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class RetryConfig(Entity):
    call_type = Field(Enum('fresh', 'followup', 'onboarding'))
    disposition_type = Field(Enum('ringing_no_answer', 'not_reachable'))
    retry_count = Field(Integer(unsigned=True))
    minutes_ahead = Field(Integer(unsigned=True))
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class RetailerLinks(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    retailer_id = Field(Integer(unsigned=True), unique=True)
    agent_id = Field(Integer(unsigned=True))
    code = Field(String(10), unique=True)
    mapped_with = Field(String)
    activated = Field(DateTime,onupdate=func.now())
    user_id = Field(Integer(unsigned=True))
    created = Field(DateTime,default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class Activation_Codes(Entity):
    code = Field(String(10))
    created = Field(DateTime, default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class Agents(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    name = Field(String(64))
    email =  Field(String(100))
    password = Field(String(64))
    type = Field(Enum('crm','fos'))
    last_login = Field(DateTime)
    login_type = Field(String(10))
    created = Field(DateTime, default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class Agent_Roles(Entity):    
    id = Field(Integer(unsigned=True), primary_key=True)
    agent_id = Field(Integer(unsigned=True))
    role = Field(Enum('fresh','followup','onboarding'))
    created = Field(DateTime, default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class AgentLoginTimings(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    agent_id = Field(Integer(unsigned=True))
    role = Field(Enum('fresh','followup','onboarding'))
    loginTime = Field(DateTime)
    logoutTime = Field(DateTime)
    created = Field(DateTime, default=func.now())   
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

class Clicks(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    tag = Field(String(20))
    created = Field(DateTime, default=func.now())   
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class FetchDataHistory(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    retailer_id = Field(Integer(unsigned=True))
    agent_id = Field(Integer(unsigned=True))
    call_type = Field(String(10))
    last_action = Field(Enum('login','disposition'))
    last_action_time = Field(DateTime)
    created = Field(DateTime,default=func.now())
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")
    
class Pushnotifications(Entity):
    id = Field(Integer(unsigned=True), primary_key=True)
    user_id = Field(Integer(unsigned=True))
    notification_campaign_id = Field(Integer(unsigned=True))
    type = Field(String(16))
    status = Field(Boolean)
    message = Field(String(64))
    response_time = Field(DateTime)
    created = Field(DateTime)
    using_options(shortnames=True)
    using_table_options(mysql_engine="InnoDB")

    
def initialize(dbname='dtr', db_hostname="localhost", echo=True):
    #metadata.bind = "sqlite:///inventory-new.sqlite" #need to read it from configserver.
    #metadata.bind = 'mysql://root:shop2020@localhost/catalog'
    cengine = create_engine('mysql://root:shop2020@' + db_hostname + '/' + dbname, pool_recycle=7200)
    metadata.bind = cengine
    metadata.bind.echo = echo
    setup_all(True)

if __name__=="__main__":
    initialize()