|
@@ -84,7 +84,7 @@ func biddingTask(data []byte, mapInfo map[string]interface{}) {
|
|
|
}
|
|
|
log.Println("bidding sync...over all", count, "extract sync ", c)
|
|
|
NextNode(mapInfo, stype)
|
|
|
- NextNodePro(mapInfo, stype)
|
|
|
+ // NextNodePro(mapInfo, stype)
|
|
|
NextNodeTidb(mapInfo, stype)
|
|
|
if stype == "bidding_history" {
|
|
|
NextNodeBidData(mapInfo) // bidding-data数据
|