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))

    group_id = Field(Integer(unsigned=True), default=1, server_default='1')

    status = Field(Boolean, default=True, server_default='1')

    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)

    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 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))

    raw_html = 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))

    agent_id=Field(Integer(unsigned=True))

    contact1 = Field(String(10))

    contact2 = Field(String(10))

    pin = Field(String(6))

    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 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'))

    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'))

    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))

    agent_id = Field(Integer(unsigned=True))

    code = Field(String(10), unique=True)

    is_activated = Field(Boolean)

    activated = Field(DateTime,onupdate=func.now())

    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)

    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 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")

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()