wip:提交

doFreeClueSign/public/getAgainSubUser.go

@@ -19,16 +19,16 @@ func GetAgainSubUser(st, ed time.Time) (rData []*AgainSubUserMsg) {
 	if sess != nil {
 		defer db.MG.DB().DestoryMongoConn(sess)
 	}
+	g.Dump("GetAgainSubUser-start", g.Map{"s_event": "subscribe", "l_date": g.Map{"$gte": st.Unix(), "$lt": ed.Unix()}})
 	it := sess.DB("qfw").C("jy_subscribe").Find(g.Map{"s_event": "subscribe", "l_date": g.Map{"$gte": st.Unix(), "$lt": ed.Unix()}}).
 		Select(g.Map{"s_m_openid": 1, "l_date": 1}).Iter()
-
 	for _temp := make(map[string]interface{}); it.Next(&_temp); {
 		var (
 			s_m_openid = gconv.String(_temp["s_m_openid"])
 			timeStamp  = gconv.Int64(_temp["l_date"])
 		)
 		//是否有取关记录
-		if count := db.MG.DB().Count("jy_subscribe", g.Map{"s_event": "unsubscribe", "l_date": g.Map{"$lt": st.Unix()}}); count == 0 {
+		if count := db.MG.DB().Count("jy_subscribe", g.Map{"s_m_openid": s_m_openid, "s_event": "unsubscribe", "l_date": g.Map{"$lt": st.Unix()}}); count == 0 {
 			continue
 		}
 		if mgoUserID := getUserIdByOpenid(s_m_openid); mgoUserID != "" {
@@ -39,6 +39,7 @@ func GetAgainSubUser(st, ed time.Time) (rData []*AgainSubUserMsg) {
 		}
 		_temp = make(map[string]interface{})
 	}
+	g.Dump("GetAgainSubUser-finish")
 	return rData
 }