models.py

# --*-- coding: utf-8 --*--

import os
import sys
BASE_DIR = os.path.abspath(os.path.join(os.path.dirname(__file__),".."))
sys.path.append(BASE_DIR)

from CONFIG.config import DB

from sqlalchemy import ForeignKey
from sqlalchemy import create_engine
from sqlalchemy import Column, Integer, String, Text, DateTime, Boolean, Sequence
from sqlalchemy import func
from sqlalchemy.orm import scoped_session, sessionmaker, relationship
from sqlalchemy.ext.declarative import declarative_base

# engine = create_engine('mysql+pymysql://{USERNAME}:{PASSWORD}@{HOST}:{PORT}/{DB_NAME}?charset=utf8'.format(
engine = create_engine('mysql+mysqldb://{USERNAME}:{PASSWORD}@{HOST}:{PORT}/{DB_NAME}?charset=utf8'.format(
    USERNAME=DB['USER'],
    PASSWORD=DB['PASSWORD'],
    HOST=DB['HOST'],
    PORT=DB['PORT'],
    DB_NAME=DB['DB_NAME'],
), convert_unicode=True, echo=False)


DBSession = scoped_session(sessionmaker(autocommit=True, autoflush=False, bind=engine))
Base = declarative_base()
Base.query = DBSession.query_property()

Base = declarative_base()

def init_db(db_engine):
  Base.metadata.create_all(bind=db_engine)
  # Base.metadata.tables["log"].create(bind=db_engine)


class User(Base):
    __tablename__ = 'user'
    id = Column(Integer, Sequence('user_id_seq'), primary_key=True)
    username = Column(String(128))
    email = Column(String(128))
    password = Column(String(128))
    is_admin = Column(Boolean(), default=False)
    last_login = Column(DateTime(timezone=True), default=func.now())
    create_at = Column(DateTime(timezone=True), default=func.now())
    update_at = Column(DateTime(timezone=True), default=func.now())

    def __repr__(self):
        return "<User(username='%s', email='%s')>" % (self.username, self.email)


class Company(Base):
    __tablename__ = 'company'
    id = Column(Integer, Sequence('company_id_seq'), primary_key=True)
    name_cn = Column(String(128))
    name_en = Column(String(128))
    industry = Column(String(256))
    website = relationship("Website", uselist=False, back_populates="company")
    info_feed = relationship("InfoFeed", back_populates="company")
    create_at = Column(DateTime(timezone=True), default=func.now())
    update_at = Column(DateTime(timezone=True), default=func.now())

    def __repr__(self):
        return "<Company(name='%s')>" % self.name_en


class CompanyProfle(Base):
    # 企业、网址、公关联系人、股市代码
    __tablename__ = 'company_profile'
    id = Column(Integer, Sequence('company_profile_id_seq'), primary_key=True)
    company_id = Column(Integer)
    portal = Column(String(1024))
    contact = Column(String(128))
    stock_code = Column(String(128))



class Website(Base):
    __tablename__ = 'website'
    id = Column(Integer, Sequence('website_id_seq'), primary_key=True)
    url = Column(String(1024))
    company_id  = Column(Integer, ForeignKey('company.id'))
    company = relationship("Company", back_populates="website")
    info_feed = relationship("InfoFeed", back_populates="website")
    html_content = relationship("HtmlContent", uselist=False, back_populates="website")
    create_at = Column(DateTime(timezone=True), default=func.now())
    update_at = Column(DateTime(timezone=True), default=func.now())

    def __repr__(self):
        return "<Website(id='%s')>" % self.id


class HtmlContent(Base):
    """
    注意：!!! content字段需要手动改Mysql Column类型为LONGTEXT
    """
    __tablename__ = 'html_content'
    id = Column(Integer, Sequence('html_id_seq'), primary_key=True)
    content = Column(Text)
    website_id = Column(Integer, ForeignKey('website.id'))
    website = relationship("Website", uselist=False, back_populates="html_content")
    update_at = Column(DateTime(timezone=True), default=func.now())


class InfoFeed(Base):
    __tablename__ = 'info_feed'
    id = Column(Integer, Sequence('info_id_seq'), primary_key=True)
    url = Column(String(1024))
    text = Column(String(1024))
    company_id = Column(Integer, ForeignKey('company.id'))
    company = relationship("Company", back_populates="info_feed")
    website_id = Column(Integer, ForeignKey('website.id'))
    website = relationship("Website", back_populates="info_feed")
    create_at = Column(DateTime(timezone=True), default=func.now())


class Keyword(Base):
    __tablename__ = 'keyword'
    id = Column(Integer, Sequence('keyword_id_seq'), primary_key=True)
    text = Column(String(256))
    create_at = Column(DateTime(timezone=True), default=func.now())


class ContactPerson(Base):
    __tablename__ = 'contact_person'
    id = Column(Integer, Sequence('contact_id_seq'), primary_key=True)
    company_id = Column(Integer, ForeignKey('company.id'))
    name = Column(String(1024)) #姓名
    gender = Column(String(1024))  # 性别
    age = Column(Integer)
    position = Column(String(1024)) #职位
    phone_number = Column(String(1024)) #电话
    wechat = Column(String(1024)) #微信
    email = Column(String(1024)) #邮箱
    comment = Column(String(1024)) #备注
    create_at = Column(DateTime(timezone=True), default=func.now())


class Report(Base):
    """
    标题 导语 作者 责任编辑 关键字 正文
    """
    __tablename__ = 'report'
    id = Column(Integer, Sequence('report_id_seq'), primary_key=True)
    title = Column(String(1024))
    lead = Column(Text)
    author = Column(String(256))
    editor = Column(String(256))
    tags = Column(String(1024))
    content = Column(Text)
    update_at = Column(DateTime(timezone=True), default=func.now())
    create_at = Column(DateTime(timezone=True), default=func.now())


class CrawlerLOG(Base):
    __tablename__ = 'log'
    id = Column(Integer, Sequence('log_id_seq'), primary_key=True)
    level = Column(Integer)
    text = Column(Text)
    create_at = Column(DateTime(timezone=True), default=func.now())










if __name__ == '__main__':
    init_db(engine)
    # pass