修改二次推送去重

src/service/second_push.go

@@ -230,7 +230,7 @@ func (s *SecondPush) SecondPushTask() {
 			endtime := qu.Int64All(c["endtime"])
 			if len(c) != 0 && c != nil {
 				if c["dep_rules"] != nil && len(c["dep_rules"].([]interface{})) != 0 {
-					idMap := map[string]bool{}
+					idMap := map[bson.ObjectId]bool{}
 					for _, m := range c["dep_rules"].([]interface{}) {
 						log.Println("ruleid", mongoutil.BsonIdToSId(m.(map[string]interface{})["_id"]))
 						q := bson.M{
@@ -244,8 +244,8 @@ func (s *SecondPush) SecondPushTask() {
 						d, _ := MgoCus.Find("usermail", q, nil, nil, false, 0, 0)
 						if len(*d) > 0 && d != nil {
 							for _, l := range *d {
-								if _,ok := idMap[l["_id"].(string)];!ok{
-									idMap[l["_id"].(string)] = true
+								if _,ok := idMap[l["_id"].(bson.ObjectId)];!ok{
+									idMap[l["_id"].(bson.ObjectId)] = true
 									xlsxArr = append(xlsxArr, l)
 								}
 							}