2021-12-02 17:20:48 +08:00
|
|
|
|
import pymongo
|
|
|
|
|
|
2022-03-18 16:44:35 +08:00
|
|
|
|
DB_HOST = "116.63.130.34"
|
|
|
|
|
DB_PASS = "UTlC9cCoglD1cI1*"
|
|
|
|
|
DB_USER = "root"
|
|
|
|
|
DB_PORT = "27021"
|
|
|
|
|
client = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format(DB_USER, DB_PASS, DB_HOST, DB_PORT))
|
2021-12-02 17:20:48 +08:00
|
|
|
|
|
|
|
|
|
|
2022-03-21 17:07:03 +08:00
|
|
|
|
def FIND_SINGLE_COLUMN_BY_REQ(param1, param2, param3, param4):
|
|
|
|
|
"""
|
|
|
|
|
查询符合条件的第一条数据的某个制定字段值
|
|
|
|
|
Parameters:
|
|
|
|
|
param1: str 数据库
|
|
|
|
|
param2: str 数据表
|
|
|
|
|
param3: dict 查询条件
|
|
|
|
|
param4: str 一个指定查询字段
|
|
|
|
|
Returns:
|
|
|
|
|
record: 查询结果为空,返回None; 查询结果正常,返回查询结果的第一条数据;
|
|
|
|
|
"""
|
|
|
|
|
collection = client[param1][param2]
|
|
|
|
|
column = {**{'_id': False}, **{param4: 1}}
|
|
|
|
|
record = list(collection.find(param3, column))
|
|
|
|
|
return None if record == [] else record[0][param4]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def FIND_SINGLE_DATA_BY_REQ(param1, param2, param3, param4):
|
2022-03-18 16:44:35 +08:00
|
|
|
|
"""
|
|
|
|
|
查询符合条件的第一条数据
|
|
|
|
|
Parameters:
|
|
|
|
|
param1: str 数据库
|
|
|
|
|
param2: str 数据表
|
|
|
|
|
param3: dict 查询条件
|
2022-03-21 17:07:03 +08:00
|
|
|
|
param4: list 查询字段
|
2022-03-18 16:44:35 +08:00
|
|
|
|
Returns:
|
|
|
|
|
record: 查询结果为空,返回False; 查询结果正常,返回查询结果的第一条数据;
|
|
|
|
|
"""
|
|
|
|
|
collection = client[param1][param2]
|
2022-03-21 17:07:03 +08:00
|
|
|
|
columns = {**{'_id': False}, **dict(zip(param4, [1] * len(param4)))}
|
|
|
|
|
record = list(collection.find(param3, columns))
|
2022-03-18 16:44:35 +08:00
|
|
|
|
return False if record == [] else record[0]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def FIND_ALL_DATA_BY_REQ(param1, param2, param3):
|
|
|
|
|
"""
|
|
|
|
|
查询符合条件的所有数据
|
|
|
|
|
Parameters:
|
|
|
|
|
param1: str 数据库
|
|
|
|
|
param2: str 数据表
|
|
|
|
|
param3: dict 查询条件
|
|
|
|
|
Returns:
|
|
|
|
|
record: list 查询结果
|
|
|
|
|
"""
|
|
|
|
|
collection = client[param1][param2]
|
|
|
|
|
record = list(collection.find(param3, {'_id': False}))
|
|
|
|
|
return record
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def FIND_RATING_RECORDS(param):
|
2021-12-02 17:20:48 +08:00
|
|
|
|
"""
|
|
|
|
|
查询评价记录
|
|
|
|
|
Parameters:
|
|
|
|
|
param: 查询条件
|
|
|
|
|
Returns:
|
|
|
|
|
record: 查询结果
|
|
|
|
|
"""
|
2022-03-18 16:44:35 +08:00
|
|
|
|
collection = client['企业数据']['评价记录']
|
2021-12-02 17:20:48 +08:00
|
|
|
|
data = collection.find(param, {'_id': False})
|
|
|
|
|
record = list(data)
|
|
|
|
|
return record
|
2021-12-03 14:15:24 +08:00
|
|
|
|
|
|
|
|
|
|
2022-03-18 16:44:35 +08:00
|
|
|
|
def FIND_CC_RATING_PROCESS_DATA(param1, param2):
|
2022-03-10 15:56:57 +08:00
|
|
|
|
"""
|
|
|
|
|
查询流程记录
|
|
|
|
|
Parameters:
|
|
|
|
|
param1: 数据集名称
|
|
|
|
|
param2: 查询条件
|
|
|
|
|
Returns:
|
|
|
|
|
record: 查询结果
|
|
|
|
|
"""
|
|
|
|
|
collection = client['评价'][param1]
|
|
|
|
|
data = collection.find(param2, {'_id': False})
|
|
|
|
|
record = list(data)
|
|
|
|
|
return record
|
|
|
|
|
|
|
|
|
|
|
2021-12-03 14:15:24 +08:00
|
|
|
|
def find_rating_inputs(param):
|
|
|
|
|
"""
|
|
|
|
|
查询填报信息记录
|
|
|
|
|
Parameters:
|
|
|
|
|
param: 查询条件
|
|
|
|
|
Returns:
|
|
|
|
|
records: 查询结果
|
|
|
|
|
"""
|
|
|
|
|
collection = client['评价']['综合评价填报']
|
|
|
|
|
data = collection.find(param, {'_id': False})
|
|
|
|
|
record = list(data)
|
|
|
|
|
return record
|
|
|
|
|
|
|
|
|
|
|
2022-03-21 17:07:03 +08:00
|
|
|
|
def INSERT_COMPREHENSIVE_INPUT_DATA(data):
|
2021-12-03 14:15:24 +08:00
|
|
|
|
"""
|
|
|
|
|
插入一条新综合填报
|
|
|
|
|
Parameters:
|
|
|
|
|
data: 新综合填报数据
|
|
|
|
|
Returns:
|
|
|
|
|
-
|
|
|
|
|
"""
|
|
|
|
|
collection = client['评价']['综合评价填报']
|
|
|
|
|
collection.insert_one(data)
|
2021-12-03 17:11:23 +08:00
|
|
|
|
|
|
|
|
|
|
2022-03-18 16:44:35 +08:00
|
|
|
|
def UPDATE_COMPREHENSIVE_CREDIT_INPUT_DATA(rid, data):
|
2021-12-03 17:11:23 +08:00
|
|
|
|
"""
|
2022-03-18 16:44:35 +08:00
|
|
|
|
更新综合信用填报数据
|
2021-12-03 17:11:23 +08:00
|
|
|
|
Parameters:
|
|
|
|
|
rid: 评价ID
|
|
|
|
|
data: 综合填报数据
|
|
|
|
|
Returns:
|
2022-03-18 16:44:35 +08:00
|
|
|
|
res: None
|
2021-12-03 17:11:23 +08:00
|
|
|
|
"""
|
|
|
|
|
collection = client['评价']['综合评价填报']
|
|
|
|
|
collection.update_one({"评价ID": rid}, {"$set": data})
|
2021-12-15 10:55:20 +08:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def find_risk_data(rid):
|
|
|
|
|
"""
|
|
|
|
|
查找评价所需的风险数据
|
|
|
|
|
"""
|
|
|
|
|
collection = client['评价']['风险数据']
|
|
|
|
|
data = collection.find({"评价ID": rid}, {'_id': False})
|
|
|
|
|
record = list(data)
|
|
|
|
|
return record
|
|
|
|
|
|
|
|
|
|
|
2021-12-15 16:07:05 +08:00
|
|
|
|
def update_rating_records(find, data):
|
2021-12-15 10:55:20 +08:00
|
|
|
|
"""
|
|
|
|
|
更新评价记录
|
|
|
|
|
Parameters:
|
2021-12-15 16:07:05 +08:00
|
|
|
|
find 查询条件
|
|
|
|
|
data 更新数据
|
2021-12-15 10:55:20 +08:00
|
|
|
|
Returns:
|
|
|
|
|
-
|
|
|
|
|
"""
|
|
|
|
|
collection = client['评价']['评价记录']
|
2021-12-15 16:07:05 +08:00
|
|
|
|
collection.update_one(find, {"$set": data})
|
2022-03-21 17:07:03 +08:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def UPSERT_SINGLE_DATA(param1, param2, param3, param4):
|
|
|
|
|
"""
|
|
|
|
|
插入单条数据
|
|
|
|
|
Parameters:
|
|
|
|
|
param1: str 数据库
|
|
|
|
|
param2: str 数据表
|
|
|
|
|
param3: dict 查询条件
|
|
|
|
|
param4: dict 更新或新插入的数据
|
|
|
|
|
"""
|
|
|
|
|
collection = client[param1][param2]
|
|
|
|
|
collection.insert_one(param3, {"$set": param4}, upsert=True)
|