jyps/company_tidb/tools.go

package main

import "go.mongodb.org/mongo-driver/bson"

//getCompany 获取公司基本信息
func getCompany(name string) (res map[string]interface{}) {
	info, _ := MgoC.FindOne("company_base", map[string]interface{}{"company_name": name})
	return *info
}

//getInvests 获取对外投资公司
func getInvests(companyId string) []map[string]interface{} {
	q := map[string]interface{}{"stock_name_id": companyId}
	info, _ := MgoC.Find("company_partner", q, nil, nil, false, -1, -1)

	return *info
}

//getTouzi 获取投资
func getTouzi(companyId string) []map[string]interface{} {
	q := map[string]interface{}{"company_id": companyId}
	info, _ := MgoC.Find("annual_report_invest", q, nil, nil, false, -1, -1)

	return *info
}

//parsePartner 处理 投资公司，添加省市区字段
func getStd(id string) (res map[string]interface{}) {
	filter := bson.M{"_id": id}
	info, _ := MgoQ.FindOne("qyxy_std", filter)

	return *info
}

//getStdByName 获取qyxy_std
func getStdByName(companyName string) (res map[string]interface{}) {
	filter := bson.M{"company_name": companyName}
	info, _ := MgoQ.FindOne("qyxy_std", filter)

	return *info
}

//getIndustry 获取所属行业
func getIndustry(companyId string) (res map[string]interface{}) {
	filter := map[string]interface{}{"company_id": companyId}
	info, _ := MgoC.FindOne("company_industry", filter)

	return *info
}