tfse-admin-api-v0.2/rating/db.py

import re

import pymongo

client = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format('root', 'sromitdTW569kC#M', '116.63.130.34', 27018))


def find_rating_records(query):
    """
    查询企业评价记录
    Parameters:
        query: 查询条件
    Returns:
        record: 查询结果
    """
    collection = client['评价']['评价记录']
    data = collection.find({"企业ID": query}, {'_id': False})
    record = list(data)
    if len(record) == 0:
        data = collection.find({"评价ID": query}, {'_id': False})
        record = list(data)
        if len(record) == 0:
            data = collection.find({"评价时间": re.compile(query)}, {'_id': False})
            record = list(data)
    return record


def find_rating_result_records(rid):
    """
    查询评价结果
    Parameters:
        rid: 评价ID
    Returns:
        record: 查询结果
    """
    collection = client['评价']['评价结果']
    data = collection.find({"评价ID": rid}, {'_id': False})
    record = list(data)
    return record


def find_fill_details_records(rid):
    """
    查询评填报详情信息
    Parameters:
        rid: 评价ID
    Returns:
        record: 查询结果
    """
    collection = client['评价']['综合评价填报']
    data = collection.find({"评价ID": rid}, {'_id': False})
    record = list(data)
    return record


def find_risk_info_records(rid):
    """
    查询风险数据信息
    Parameters:
        rid: 评价ID
    Returns:
        record: 查询结果
    """
    collection = client['评价']['风险数据']
    data = collection.find({"评价ID": rid}, {'_id': False})
    record = list(data)
    return record