jyps/test/company.go

package main

import (
	util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
)

// getCompany  获取公司信息
func getCompany() {
	//本地
	Mgo := &mongodb.MongodbSim{
		MongodbAddr: "127.0.0.1:27017",
		DbName:      "wcc",
		Size:        10,
		UserName:    "",
		Password:    "",
		//Direct:      true,
	}
	Mgo.InitPool()

	// 181 凭安库
	Mgo2 := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.4.181:27001",
		MongodbAddr: "127.0.0.1:27001",
		DbName:      "mixdata",
		Size:        10,
		UserName:    "",
		Password:    "",
		Direct:      true,
	}
	Mgo2.InitPool()

	//1.获取凭安特企，河南数据
	where := map[string]interface{}{
		"province_short": "HEN",
	}

	defer util.Catch()
	sess := Mgo2.GetMgoConn()
	defer Mgo2.DestoryMongoConn(sess)
	count := 0
	it := sess.DB("mixdata").C("special_gov_unit").Find(where).Select(nil).Iter()
	for tmp := make(map[string]interface{}); it.Next(&tmp); count++ {

	}
}