1.MANGO_DATAbaseS["HOST"] 是主机IP
2.MANGO_DATAbaseS["DB"] 是数据库名字
3.MANGO_DATAbaseS["db3"]是表名
class MangoOperationMoney:
"""操作mango数据库返回字典
"""
def __init__(self):
self.myclient = pymongo.MongoClient(MANGO_DATAbaseS["HOST"], MANGO_DATAbaseS['PORT'])
self.mydb = self.myclient[MANGO_DATAbaseS["DB"]]
def handle_doctor(self, doctor_id, comty_id):
"""
根据医生ID和社区ID去mango表查询对应的标签
:param doctor_id: 医生ID
:param comty_id: 社区ID
:return:
"""
label_mycol = self.mydb[MANGO_DATAbaseS["db4"]]
dict_mycol = self.mydb[MANGO_DATAbaseS["db5"]]
str_label = ""
for i in label_mycol.find():
if doctor_id == i['userId'] and comty_id == i['comtyId']:
for j in dict_mycol.find():
if str(i['labelId']) == str(j['_id']):
str_label += j['labelName'] + ','
return str_label
if __name__ == '__main__':
doctor_id ='医生ID'
comty_id = '社区ID'
C = MangoOperationMoney().handle_doctor(doctor_id, comty_id)


