推送测试

cmd/main.go

@@ -72,30 +72,30 @@ func main() {
 	_ = logger.InitLogger("file", logConfig)
 	_ = logger.InitLogger("file", logConfig)
 	logger.Init()
 	logger.Init()
 
 
-	err_seo := initDb("InitSeoDB", util.Configs.Seo_databases.Dns)
-	err_spu := initDb("InitSpuDB", util.Configs.Spu_databases.Dns)
-	err_goods := initDb("InitGoodsDB", util.Configs.Goods_databases.Dns)
-	err_sku := initDb("InitSkuDB", util.Configs.Sku_databases.Dns)
-	err_lx := initDb("InitLxDB", util.Configs.Liexin_databases.Dns)
-
-	if err_goods != nil {
-		fmt.Println(err_goods)
+	errSeo := initDb("InitSeoDB", util.Configs.Seo_databases.Dns)
+	errSpu := initDb("InitSpuDB", util.Configs.Spu_databases.Dns)
+	errGoods := initDb("InitGoodsDB", util.Configs.Goods_databases.Dns)
+	//errSku := initDb("InitSkuDB", util.Configs.Sku_databases.Dns)
+	errLx := initDb("InitLxDB", util.Configs.Liexin_databases.Dns)
+
+	if errGoods != nil {
+		fmt.Println(errGoods)
 	}
 	}
 
 
-	if err_spu != nil {
-		fmt.Println(err_goods)
+	if errSpu != nil {
+		fmt.Println(errGoods)
 	}
 	}
 
 
-	if err_seo != nil {
-		fmt.Println(err_seo)
+	if errSeo != nil {
+		fmt.Println(errSeo)
 	}
 	}
 
 
-	if err_sku != nil {
-		fmt.Println(err_sku)
-	}
+	//if errSku != nil {
+	//	fmt.Println(errSku)
+	//}
 
 
-	if err_lx != nil {
-		fmt.Println(err_lx)
+	if errLx != nil {
+		fmt.Println(errLx)
 	}
 	}
 
 
 	t := &RecvPro{}
 	t := &RecvPro{}

collect/mip/mip.go

@@ -80,6 +80,7 @@ func RunMipTask(remainCount int, configDir string) {
 		var cdCount, _ = strconv.Atoi(collectDbCount)
 		var cdCount, _ = strconv.Atoi(collectDbCount)
 		var sql = colsql.MipSQL(collectCode, tableIndex, cdCount, cdCount+remainCount)
 		var sql = colsql.MipSQL(collectCode, tableIndex, cdCount, cdCount+remainCount)
 		colDb = db.GetDB(collectDbConn)
 		colDb = db.GetDB(collectDbConn)
+		fmt.Println(collectDbConn + "---" + sql)
 		res, err := colDb.Queryx(sql)
 		res, err := colDb.Queryx(sql)
 
 
 		fmt.Println(sql)
 		fmt.Println(sql)