xg

udpcreateindex/src/biddingall.go

@@ -77,7 +77,7 @@ func biddingAllTask(data []byte, mapInfo map[string]interface{}) {
 	arr := [][]map[string]interface{}{}
 	arrEs := []map[string]interface{}{}
 	//对比两张表数据，减少查询次数
-	var compare bson.M
+	var compare map[string]interface{}
 	bnil := false
 	for tmp := make(map[string]interface{}); query.Next(tmp); n++ {
 		// if qutil.IntAll(tmp["dataging"]) == 1 { //dataging=1不生索引
@@ -94,7 +94,7 @@ func biddingAllTask(data []byte, mapInfo map[string]interface{}) {
 		//对比方法----------------
 		for {
 			if compare == nil {
-				compare = make(bson.M)
+				compare = make(map[string]interface{})
 				if !extractquery.Next(compare) {
 					break
 				}
@@ -309,7 +309,7 @@ func biddingAllTask(data []byte, mapInfo map[string]interface{}) {
 							if winnerorder, _ := tmp[v].([]interface{}); len(winnerorder) > 0 {
 								for _, win := range winnerorder {
 									winMap_new := make(map[string]interface{})
-									winMap := win.(bson.M)
+									winMap := win.(map[string]interface{})
 									for _, wf := range winnerorderlistFields {
 										if winMap[wf] != nil {
 											winMap_new[wf] = winMap[wf]