C#代码 利用MongoDB中Group聚合函数查询

　　例子：
　　public static void getUserRFM(DateTime beginTime, DateTime endTime)
        {
            MongoDatabase mongoDB = getConnection();
　　//会员消费明细的实体类
            List shopplist = new List();
　　//获得Ky_shopplist集合
            MongoCollection col = mongoDB.GetCollection("Ky_Shopplist");
　　//获得Ky_UserRFM的集合
            MongoCollection colRFM = mongoDB.GetCollection("Ky_UserRFM");
　　//删除Ky_UserRFM集合中所有的数据
            colRFM.RemoveAll();
　　//定义获取“buyTime”相关的查询条件
            var query = Query.And(Query.GTE("buyTime", beginTime.ToString("yyyy-MM-dd HH:mm:ss")), Query.LTE("buyTime", endTime.ToString("yyyy-MM-dd HH:mm:ss")));
　　//var result = col.FindAs(query).ToList();
            //var result_all = col.FindAllAs().ToList();
　　//会员RFM值实体类
            List userRFMlist = new List();
　　//GroupBy的字段
            GroupByBuilder groupbyBuilder = new GroupByBuilder(new string[] { "userId" });
　　#region 计算会员R值
　　try
            {
　　//计算每组UserId的最大时间
                Dictionary dic_R = new Dictionary();
                dic_R["time"] = DateTime.Now.ToString();
                var result_R = col.Group(query, groupbyBuilder, BsonDocument.Create(dic_R),
                                    BsonJavaScript.Create("function(obj,prev){if(prev.time>obj.buyTime){prev.time=obj.buyTime;}}"),
                                    BsonJavaScript.Create("function(obj){ obj.btime=obj.time;delete obj.time; }")).ToList();
　　if (result_R.Count != 0)
                 {
                    //计算出会员距今最近的消费时间和最远的消费时间
                    DateTime Mintime = DateTime.Now;
                    DateTime Maxtime = DateTime.Now;
                    for (int i = 1; i < result_R.Count; i++)
                    {
                        if (i == 1)
                        {
                            Maxtime = Convert.ToDateTime(result_R["btime"]) > Convert.ToDateTime(result_R[0]["btime"]) ? Convert.ToDateTime(result_R["btime"]) : Convert.ToDateTime(result_R[0]["btime"]);
　　Mintime = Convert.ToDateTime(result_R["btime"]) < Convert.ToDateTime(result_R[0]["btime"]) ? Convert.ToDateTime(result_R["btime"]) : Convert.ToDateTime(result_R[0]["btime"]);
　　}
                        else
                        {
                            Maxtime = Maxtime > Convert.ToDateTime(result_R["btime"]) ? Maxtime : Convert.ToDateTime(result_R["btime"]);
　　Mintime = Mintime < Convert.ToDateTime(result_R["btime"]) ? Mintime : Convert.ToDateTime(result_R["btime"]);
                        }
                    }
　　double R_interval = 0.0;
                    R_interval = (Maxtime - Mintime).TotalSeconds / 5;
　　//计算会员R值
                    for (int i = 0; i < result_R.Count; i++)
                    {
                        DateTime dtTime = Convert.ToDateTime(result_R["btime"]);
                        string userId = result_R["userId"].ToString();
                        string struser_R = "0";
　　if (dtTime >= Mintime && dtTime = Mintime.AddSeconds(R_interval) && dtTime = Mintime.AddSeconds(R_interval * 2) && dtTime = Mintime.AddSeconds(R_interval * 3) && dtTime = Mintime.AddSeconds(R_interval * 4) && dtTime  Convert.ToInt32(result_F[0]["count"]) ? Convert.ToInt32(result_F["count"]) : Convert.ToInt32(result_F[0]["count"]);
　　Mincount = Convert.ToInt32(result_F["count"]) < Convert.ToInt32(result_F[0]["count"]) ? Convert.ToInt32(result_F["count"]) : Convert.ToInt32(result_F[0]["count"]);
                        }
                        else
                        {
                            Maxcount = Maxcount > Convert.ToInt32(result_F["count"]) ? Maxcount : Convert.ToInt32(result_F["count"]);
　　Mincount = Mincount < Convert.ToInt32(result_F["count"]) ? Mincount : Convert.ToInt32(result_F["count"]);
                        }
                    }
　　double F_inteval = 0.0;
                    F_inteval = (Maxcount - Mincount) / 5;
　　//计算每个会员的F值
                    for (int i = 1; i < result_F.Count; i++)
                    {
                        string strUserid = result_F["userId"].ToString();
                        int icount = Convert.ToInt32(result_F["count"]);
                        string strUser_F = "0";
　　if (icount >= Mincount && icount = F_inteval && icount = (F_inteval * 2) && icount = (F_inteval * 3) && icount = (F_inteval * 4) && icount  Convert.ToDouble(result_M[0]["msum"]) ? Convert.ToDouble(result_M["msum"]) : Convert.ToDouble(result_M[0]["msum"]);
　　Minsum = Convert.ToDouble(result_M["msum"]) < Convert.ToDouble(result_M[0]["msum"]) ? Convert.ToDouble(result_M["msum"]) : Convert.ToDouble(result_M[0]["msum"]);
                        }
                        else
                        {
                            Maxsum = Maxsum > Convert.ToDouble(result_M["msum"]) ? Maxsum : Convert.ToDouble(result_M["msum"]);
　　Minsum = Minsum < Convert.ToDouble(result_M["msum"]) ? Minsum : Convert.ToDouble(result_M["msum"]);
                        }
                    }
　　double M_interval = 0.0;
                    M_interval = (Maxsum - Minsum) / 5;
　　//计算每个会员的M值
                    for (int i = 0; i < result_M.Count; i++)
                    {
                        string strUserId = result_M["userId"].ToString();
                        double dsum = Convert.ToDouble(result_M["msum"]);
　　string struser_M = "0";
                        if (dsum >= Minsum && dsum = M_interval && dsum = (M_interval * 2) && dsum = (M_interval * 3) && dsum = (M_interval * 4) && dsum