data_monitor/data_ylqx/src/main.go

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)
	}
}