data_monitor/data_tower/src/main.go

package main

import (
	log "github.com/donnie4w/go-logger/logger"
	"go.mongodb.org/mongo-driver/bson"
	qu "qfw/util"
	u "ul"
)

func init() {
	//u.IsLocal = true
	//u.IsDev = true
	u.InitVar()
}

func main() {
	readTowerBxInfo()
	writeTowerBxInfo()

	//readTowerNhInfo()
	writeTowerNhInfo()

	return
	lock := make(chan bool)
	<-lock
}

func test1() {
	dataArr := u.MysqlBiTool.Find("customer_data_ttzl_project", map[string]interface{}{}, "area,msg_id", "msg_id", -1, -1)
	log.Debug(len(*dataArr))
	for k, v := range *dataArr {
		if k%1000 == 0 {
			log.Debug("cur index ", k)
		}
		msg_id := qu.IntAll(v["msg_id"])
		area := qu.ObjToString(v["area"])
		new_area := ""
		if area == "" {
			new_area = "全国"
		} else {
			if u.Regions[area] != "" {
				new_area = u.Regions[area]
			}
		}
		u.MysqlBiTool.Update("customer_data_ttzl_project", bson.M{"msg_id": msg_id}, bson.M{"area": new_area})
	}
	log.Debug("is over ...")
}

func test() {
	dataArr := u.MysqlBiTool.Find("customer_data_ttzl_project", map[string]interface{}{}, "zb_infoid,infoid,msg_id", "msg_id", -1, -1)
	log.Debug(len(*dataArr))
	for k, v := range *dataArr {
		if k%1000 == 0 {
			log.Debug("cur index ", k)
		}
		msg_id := qu.IntAll(v["msg_id"])
		update := map[string]interface{}{}
		if zb_infoid := qu.ObjToString(v["zb_infoid"]); zb_infoid != "" {
			zb_jybxhref := "https://www.jianyu360.cn/succbi/ttzl/app/dzbi.app/detail.spg?I_id=" + zb_infoid
			update["zb_jybxhref"] = zb_jybxhref
		}
		if infoid := qu.ObjToString(v["infoid"]); infoid != "" {
			jybxhref := "https://www.jianyu360.cn/succbi/ttzl/app/dzbi.app/detail.spg?I_id=" + infoid
			update["jybxhref"] = jybxhref
		}
		if len(update) > 0 && msg_id > 0 {
			u.MysqlBiTool.Update("customer_data_ttzl_project", bson.M{"msg_id": msg_id}, update)
		}
	}
	log.Debug("is over ...")

	//dataArr := u.MysqlBiTool.Find("customer_data_ttzl", map[string]interface{}{}, "id,msg_id", "msg_id", -1, -1)
	//log.Debug(len(*dataArr))
	//for k, v := range *dataArr {
	//	if k%1000 == 0 {
	//		log.Debug("cur index ", k)
	//	}
	//	msg_id := qu.IntAll(v["msg_id"])
	//	jybxhref := "https://www.jianyu360.cn/succbi/ttzl/app/dzbi.app/detail.spg?I_id=" + qu.ObjToString(v["id"])
	//	u.MysqlBiTool.Update("customer_data_ttzl", bson.M{"msg_id": msg_id}, bson.M{"jybxhref": jybxhref})
	//}
	//log.Debug("is over ...")
}