timed_tasks/faren_tidb/main.go

package main

import (
	"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
	"gorm.io/gorm"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
)

var (
	GF      GlobalConf
	MysqlDB *gorm.DB
	MgoQY   *mongodb.MongodbSim //181凭安
	Mgo     *mongodb.MongodbSim //标讯地址-凭安库 mixdata
	//Esa            *es.Elastic
	//Esb            *es.Elastic
	ClickHouseConn driver.Conn
	entLabelMap    = make(map[uint64]string)
	nameBitMap     = make(map[string]uint64) //和上面k-v 反过来
	//更新es
	updateEsPool   = make(chan []map[string]interface{}, 5000)
	updateEsSp     = make(chan bool, 5) //保存协程
	RegionCodeData = map[string]string{}

	//
	nameNorm = make(map[string]EntInfoNorm) //存储叶子节点标准
)

func main() {
	dealAllFromCompanyBase() //企业法人存量数据

}