Subversion Repositories SmartDukaan

'''

Created on 14-Jul-2010

@author: ashish

'''

from sqlalchemy import create_engine

from elixir import *

import elixir

from shop2020.helpers.impl.model import DashboardUser

class Message(Entity):

    id = Field(Integer, primary_key=True, autoincrement=True)

    message_id = Field(Integer)

    message = Field(String(200))

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class LogisticsUser(Entity):

    username = Field(String(30), primary_key=True)

    password = Field(String(30))

    providerId = Field(Integer)

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class StatisticsUser(Entity):

    username = Field(String(30), primary_key=True)

    password = Field(String(30))

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class Report(Entity):

    id = Field(Integer, primary_key=True, autoincrement=True)

    description = Field(String(100))

    controller = Field(String(100))

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class ReportUser(Entity):

    username = Field(String(30), primary_key=True)

    password = Field(String(30))

    role = Field(Integer)

    email = Field(String(50))

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class ReportRoleAuthority(Entity):

    report = ManyToOne("Report", primary_key=True)

    role = Field(Integer, primary_key=True)

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class UserEmail(Entity):

    id = Field(Integer, primary_key=True, autoincrement=True)

    emailTo = Field(String(256))

    emailFrom = Field(String(60))

    subject = Field(String(120))

    body = Field(Text())

    source = Field(String(20))

    emailType = Field(String(40))

    status = Field(Boolean())

    timestamp = Field(DateTime())

    cc = Field(String(256))

    bcc = Field(String(256))

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class UserEmailArchive(Entity):

    id = Field(Integer, primary_key=True)

    emailTo = Field(String(256))

    emailFrom = Field(String(60))

    subject = Field(String(120))

    body = Field(Text())

    source = Field(String(20))

    emailType = Field(String(40))

    status = Field(Boolean())

    timestamp = Field(DateTime())

    cc = Field(String(256))

    bcc = Field(String(256))

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class CatalogDashboardUser(Entity):

    username = Field(String(30), primary_key=True)

    password =  Field(String(30))

    loggedOn = Field(DateTime)

    role = Field(Integer)

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class EntitiesShared(Entity):

    entityIds = Field(String(100))

    email = Field(String(100))

    isEmailed = Field(Boolean)

    using_options(shortnames=True)

    using_table_options(mysql_engine="InnoDB")

class QuickLink(Entity):

    id = Field(Integer, primary_key=True)

    url = Field(String(220))

    text = Field(String(220))

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB")

class AgentWarehouseMapping(Entity):

    agentId = Field(Integer, primary_key=True)

    warehouseId = Field(Integer, primary_key=True)

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB")

class DealerAuth(Entity):

    username = Field(String(100), primary_key=True)

    password = Field(String(100))

    role = Field(Integer)

    createdOn = Field(DateTime)

    lastLoggedIn = Field(DateTime)

    lattitude = Field(Float)

    longitude = Field(Float)

    isActive = Field(Boolean)

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB")

class UserSms(Entity):

    id = Field(Integer, primary_key=True, autoincrement=True)

    user_id = Field(Integer)

    mobileNumber = Field(String(20))

    smsText = Field(String(800))

    type = Field(Enum('TRANSACTIONAL','PROMOTIONAL','SERVICE_ALERT'))

    status = Field(Enum('IN_PROCESS','DELIVERED','UNDELIVERED','SERVICE_ERROR','UNVALID_NUMBER'))

    attempts = Field(Integer)

    createdTimestamp = Field(DateTime)

    responseId = Field(String(30))

    responseText = Field(String(150))

    deliveryStatus = Field(Enum('NOT_SENT','SENT_TO_OPERATOR','SUBMITTED_TO_SMSC','GOT_STATUS_CODE'))

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB") 

class UserSmsInfo(Entity):

    userId = Field(Integer, primary_key=True, autoincrement=False)

    mobileNo = Field(String(20))

    dailyCount = Field(Integer)

    weeklyCount = Field(Integer)

    dndStatus = Field(Boolean)

    smsSubscribed = Field(Boolean)

    createdTimestamp = Field(DateTime) 

    updateTimestamp = Field(DateTime)

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB")

class UserSmsArchive(Entity):

    id = Field(Integer, primary_key=True, autoincrement=True)

    user_id = Field(Integer)

    mobileNumber = Field(String(20))

    smsText = Field(String(800))

    type = Field(Enum('TRANSACTIONAL','PROMOTIONAL','SERVICE_ALERT'))

    status = Field(Enum('IN_PROCESS','DELIVERED','UNDELIVERED','SERVICE_ERROR','UNVALID_NUMBER'))

    attempts = Field(Integer)

    createdTimestamp = Field(DateTime)

    responseId = Field(String(30))

    responseText = Field(String(150))

    deliveryStatus = Field(Enum('NOT_SENT','SENT_TO_OPERATOR','SUBMITTED_TO_SMSC','GOT_STATUS_CODE'))

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB")

class Campaigns(Entity):

    userEmail = Field(String(256),primary_key=True)

    campaignType = Field(Integer,primary_key=True,autoincrement=False)

    using_options(shortnames = True)

    using_table_options(mysql_engine = "InnoDB")

def initialize(dbname='helper', db_hostname='localhost'):

    #metadata.bind = "sqlite:///message.sqlite" #need to read it from configserver.

    engine = create_engine('mysql://root:shop2020@' + db_hostname + '/' + dbname,

                           pool_recycle=3600, pool_timeout=30)

    metadata.bind = engine

    metadata.bind.echo = False

    setup_all(True)

if __name__=="__main__":

    initialize()