db_news.py 文件源码

def add_news(update, detail, link, unique_hash):
    session = models.Session()
    qkou = session.query(models.News)
    # utf-8?????????????
    update = update.encode('utf-8')
    detail = detail.encode('utf-8')
    unique_hash = unique_hash.encode('utf-8')
    if len(link) is not 0:
        link = link.encode('utf-8')
    newinfo = models.News(update, detail, link, unique_hash, settings.now)
    try:
        ex_info = qkou.filter(models.News.unique_hash == unique_hash).first()
        if ex_info is None:
            # ?????
            log.debug('News: %s %s … [??]', update, detail[0:10])
            session.add(newinfo)
            session.commit()
            new_id = newinfo.id
            return new_id
        else:
            # ?????
            log.debug('News: %s %s … [??]', update, detail[0:10])
            ex_info.up_time = settings.now
            session.commit()
            return False
    except Exception as e:
        log.exception(e)
        return False
    finally:
        session.close()