TIDB 版本数据 通讯录

ent_contact/contact_full.go

@@ -9,19 +9,30 @@ import (
 )
 
 // from tidb
-func InjectContactTidbInfo(tmp map[string]interface{}) {
+func InjectContactTidbInfo() {
 	index, total := 0, 0
-	query := map[string]interface{}{}
 L:
 	for {
-		dataArr := ul.MysqlGlobalTool.Find(ul.G_Units_Baseinfo, query, "", "id", index*50000, 50000)
+		dataArr := ul.MysqlGlobalTool.Find(ul.G_Units_Contact, map[string]interface{}{}, "name_id,contact_name,contact_tel,contact_email,source_type", "id", index*50000, 50000)
 		if dataArr != nil {
 			if len(*dataArr) == 0 {
 				break
 			}
-			//for _, v := range *dataArr {
-			//	tel :=
-			//}
+
+			for _, v := range *dataArr {
+				name_id := qu.ObjToString(v["name_id"])
+				name := qu.ObjToString(v["contact_name"])
+				phone := qu.ObjToString(v["contact_tel"])
+				email := qu.ObjToString(v["contact_email"])
+				source_type := qu.IntAll(v["source_type"])
+				createtime := time.Now().Unix()
+				query := "INSERT INTO information.ent_contact(id,phone,name,email,source_type,create_time,update_time) VALUES(?,?,?,?,?,?,?)"
+				//插入数据
+				err := ul.ClickHouseConn.Exec(context.Background(), query, name_id, phone, name, email, source_type, createtime, createtime)
+				if err != nil {
+					log.Debug(err)
+				}
+			}
 		} else {
 			break L
 		}
@@ -31,6 +42,7 @@ L:
 			log.Debug("cur idx ", total)
 		}
 	}
+	log.Debug("is over ...")
 }
 
 // from 凭安库

ent_util/init.go

@@ -36,7 +36,7 @@ const (
 func InitGlobalVar() {
 	IsLocal = true
 	initMgo()
-	//initMysql()
+	initMysql()
 	//initVCode()
 	initClickHouse()
 	//initEs()

main.go

@@ -14,7 +14,7 @@ func init() {
 
 func main() {
 	log.Debug("main...")
-	ent_contact.InjectContactMaKeInfo("12345", map[string]interface{}{"company_phone": "158···"})
+	ent_contact.InjectContactTidbInfo()
 
 	log.Debug("......")
 	lock := make(chan bool)