备份

udpfilterdup/src/main.go

@@ -58,7 +58,7 @@ var (
 
 
 func init() {
-	
+
 	flag.StringVar(&lastid, "id", "", "增量加载的lastid") //增量
 	flag.StringVar(&gtid, "gtid", "", "历史增量的起始id")	//历史
 	flag.StringVar(&gtept, "gtept", "", "全量gte发布时间")//全量区间pt
@@ -132,11 +132,6 @@ func init() {
 
 func main() {
 
-	//exportAllBuyerAlias()
-	////testmain()
-	//return
-
-
 	go checkMapJob()
 	updport := Sysconfig["udpport"].(string)
 	udpclient = mu.UdpClient{Local: updport, BufSize: 1024}
@@ -171,6 +166,20 @@ func main() {
 
 //测试组人员使用
 func mainT() {
+	//dealBuyerAlias() //生成别名
+	//dealWithBuyerNameAliasRecord()//处理数据-别名相关
+	//dealRepeatAliasBuyerName() //处理多余重复
+	//exportXiuFuData()
+	//buyerRedisXiuFuData()//更新别名
+	//exportAllBuyerAlias() //导出测试数据
+
+
+	dealWithAddressData()//城市
+
+
+
+	return
+
 	if TimingTask {
 		go historyTaskDay()
 		time.Sleep(99999 * time.Hour)

udps/main.go

@@ -18,14 +18,14 @@ var startDate, endDate string
 
 func main() {
 	ip, p, tmptime, tmpkey, id1, id2, stype, q, bkey, param, ids := "", 0, 0, "", "", "", "", "", "", "", ""
-	flag.StringVar(&startDate, "start", "2020-10-10", "开始日期2006-01-02")
+	flag.StringVar(&startDate, "start", "", "开始日期2006-01-02")
 	flag.StringVar(&endDate, "end", "", "结束日期2006-01-02")
-	flag.StringVar(&ip, "ip", "127.0.0.1", "ip")
-	flag.IntVar(&p, "p", 1483, "端口")
+	flag.StringVar(&ip, "ip", "192.168.3.205", "ip")
+	flag.IntVar(&p, "p", 1484, "端口")
 	flag.IntVar(&tmptime, "tmptime", 0, "时间查询")
 	flag.StringVar(&tmpkey, "tmpkey", "", "时间字段")
-	flag.StringVar(&id1, "gtid", "5ed869759e628c5991636bca", "gtid")
-	flag.StringVar(&id2, "lteid", "5eec14bd4c87bb08581c03cb", "lteid")
+	flag.StringVar(&id1, "gtid", "5a86328a40d2d9bbe88e4138", "gtid")
+	flag.StringVar(&id2, "lteid", "5a8f8cd340d2d9bbe8a21400", "lteid")
 	flag.StringVar(&ids, "ids", "", "id1,id2")
 	flag.StringVar(&stype, "stype", "biddingall", "stype,传递类型")
 	flag.StringVar(&bkey, "bkey", "", "bkey,加上此参数表示不生关键词和摘要")