package main import ( "fmt" log "github.com/donnie4w/go-logger/logger" "go.mongodb.org/mongo-driver/bson" qu "qfw/util" ul "util" ) func init() { //临时测试tidb //ul.IsDev = true //ul.IsLocal = true ul.InitClass() log.Debug("测试接口...", ul.PostReliability("布展工程")) } func main() { //各种信息处理 //product.StartDealWithProductBaseInfo() //class.StartDealWithProductClassInfo() //dealer.StartDealWithDealerAllInfo() //legal.StartDealWithLegalBaseInfo() //经销商各种-标讯的标签信息 //dimension.StartBuildDealerDimensionGroupInfo() //dimension.StartSupplyDealerDimensionProductInfo() //dimension.StartDealWithDealerDimensionTagInfo() //处理标的物与中标信息 //bidding.StartDealWithPurashingInfo() //处理关系型数据 //relation.StartDealWithRelationBuyerWinnerInfo() //标的物与中标信息与关系型-增量部署 //bidding_add.BiddingRelationAddTask() //经销商相关联标签-增量部署 //dimension.DimensionAddTask() //保持活性 lock := make(chan bool) <-lock } func test() { pids := ul.MysqlSubjectTool.Find("dwd_f_yl_purchasing_baseinfo", bson.M{"buyer": "北京协和医院"}, "projectid", "", -1, -1) temp := map[string]string{} for _, v := range *pids { pid := qu.ObjToString(v["projectid"]) wins := ul.MysqlSubjectTool.Find("dwd_f_yl_purchasing_win_baseinfo", bson.M{"projectid": pid}, "winner,is_winner,projectid", "", -1, -1) for _, v1 := range *wins { winner := qu.ObjToString(v1["winner"]) is_winner := qu.IntAll(v1["is_winner"]) projectid := qu.ObjToString(v1["projectid"]) key := fmt.Sprintf("%s~%d~%s", winner, is_winner, projectid) temp[key] = key } } for _, v := range temp { log.Debug(v) } }