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

例子：

public static void getUserRFM(DateTime beginTime, DateTime endTime)
        {
            MongoDatabase mongoDB = getConnection();

            //会员消费明细的实体类
            List<Ky_Shopplist> shopplist = new List<Ky_Shopplist>();

            //获得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<Ky_Shopplist>(query).ToList();
            //var result_all = col.FindAllAs<Ky_Shopplist>().ToList();

            //会员RFM值实体类
            List<Ky_UserRFM> userRFMlist = new List<Ky_UserRFM>();

            //GroupBy的字段
            GroupByBuilder groupbyBuilder = new GroupByBuilder(new string[] { "userId" });

            #region 计算会员R值

            try
            {

                //计算每组UserId的最大时间
                Dictionary<string, string> dic_R = new Dictionary<string, string>();
                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[i]["btime"]) > Convert.ToDateTime(result_R[0]["btime"]) ? Convert.ToDateTime(result_R[i]["btime"]) : Convert.ToDateTime(result_R[0]["btime"]);

                            Mintime = Convert.ToDateTime(result_R[i]["btime"]) < Convert.ToDateTime(result_R[0]["btime"]) ? Convert.ToDateTime(result_R[i]["btime"]) : Convert.ToDateTime(result_R[0]["btime"]);

                        }
                        else
                        {
                            Maxtime = Maxtime > Convert.ToDateTime(result_R[i]["btime"]) ? Maxtime : Convert.ToDateTime(result_R[i]["btime"]);

                            Mintime = Mintime < Convert.ToDateTime(result_R[i]["btime"]) ? Mintime : Convert.ToDateTime(result_R[i]["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[i]["btime"]);
                        string userId = result_R[i]["userId"].ToString();
                        string struser_R = "0";

                        if (dtTime >= Mintime && dtTime <= Mintime.AddSeconds(R_interval))
                        {
                            struser_R = "1";
                        }
                        if (dtTime >= Mintime.AddSeconds(R_interval) && dtTime <= Mintime.AddSeconds(R_interval * 2))
                        {
                            struser_R = "2";
                        }
                        if (dtTime >= Mintime.AddSeconds(R_interval * 2) && dtTime <= Mintime.AddSeconds(R_interval * 3))
                        {
                            struser_R = "3";
                        }
                        if (dtTime >= Mintime.AddSeconds(R_interval * 3) && dtTime <= Mintime.AddSeconds(R_interval * 4))
                        {
                            struser_R = "4";
                        }
                        if (dtTime >= Mintime.AddSeconds(R_interval * 4) && dtTime <= Maxtime)
                        {
                            struser_R = "5";
                        }

                        Ky_UserRFM userRFM = new Ky_UserRFM();

                        userRFM.user_R = struser_R;
                        userRFM.user_F = "0";
                        userRFM.user_M = "0";

                        userRFM.user_Tagid = "";
                        userRFM.user_Id = userId;
                        userRFM.current_Time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");

                        userRFMlist.Add(userRFM);
                    }

                    //批量插入会员RFM表
                    colRFM.InsertBatch(typeof(Ky_UserRFM), userRFMlist);
                }
            }
            catch (Exception ex)
            {
                throw;
            }

            #endregion

            #region 计算会员F值

            try
            {

　　　　　　//计算每组UserId的次数

                Dictionary<string, int> dic_F = new Dictionary<string, int>();
                dic_F["num"] = 0;
                var result_F = col.Group(query, groupbyBuilder, BsonDocument.Create(dic_F),
                                               BsonJavaScript.Create("function(doc,prev){prev.num++;}"),
                                               BsonJavaScript.Create("function(doc){ doc.count=doc.num;delete doc.num; }")).ToList();

                if (result_F.Count != 0)
                {
                    //计算出会员最大消费频率和最小消费频率
                    double Maxcount = 0;
                    double Mincount = 0;
                    for (int i = 1; i < result_F.Count; i++)
                    {
                        if (i == 1)
                        {
                            Maxcount = Convert.ToInt32(result_F[i]["count"]) > Convert.ToInt32(result_F[0]["count"]) ? Convert.ToInt32(result_F[i]["count"]) : Convert.ToInt32(result_F[0]["count"]);

                            Mincount = Convert.ToInt32(result_F[i]["count"]) < Convert.ToInt32(result_F[0]["count"]) ? Convert.ToInt32(result_F[i]["count"]) : Convert.ToInt32(result_F[0]["count"]);
                        }
                        else
                        {
                            Maxcount = Maxcount > Convert.ToInt32(result_F[i]["count"]) ? Maxcount : Convert.ToInt32(result_F[i]["count"]);

                            Mincount = Mincount < Convert.ToInt32(result_F[i]["count"]) ? Mincount : Convert.ToInt32(result_F[i]["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[i]["userId"].ToString();
                        int icount = Convert.ToInt32(result_F[i]["count"]);
                        string strUser_F = "0";

                        if (icount >= Mincount && icount <= F_inteval)
                        {
                            strUser_F = "1";
                        }
                        if (icount >= F_inteval && icount <= (F_inteval * 2))
                        {
                            strUser_F = "2";
                        }
                        if (icount >= (F_inteval * 2) && icount <= (F_inteval * 3))
                        {
                            strUser_F = "3";
                        }
                        if (icount >= (F_inteval * 3) && icount <= (F_inteval * 4))
                        {
                            strUser_F = "4";
                        }
                        if (icount >= (F_inteval * 4) && icount <= Maxcount)
                        {
                            strUser_F = "5";
                        }

                        //执行更新操作
                        var query_F = Query.EQ("user_Id", strUserid);
                        var update_F = new UpdateDocument { { "$set", new QueryDocument { { "user_F", strUser_F } } } };

                        colRFM.Update(query_F, update_F);
                    }
                }
            }
            catch (Exception ex)
            {
                throw;
            }

            #endregion

            #region 计算会员M值

            try
            {

　　　　　　//计算每组UserId中price（金额）的总和
                //var query_price = new QueryDocument{{"price",true}};
                //var update_price = new UpdateDocument{{"price",BsonType.Double}};
                //colRFM.Update(query_price, update_price);

                Dictionary<string, double> dic_M = new Dictionary<string, double>();
                dic_M["msum"] = 0.0;
                var result_M = col.Group(query, groupbyBuilder, BsonDocument.Create(dic_M),
                                                BsonJavaScript.Create("function(obj,prev){prev.msum += obj.price;}"),
                                                BsonJavaScript.Create("function(obj){obj.sum=obj.msum;delete obj.sum;}")).ToList();

                if (result_M.Count != 0)
                {
                    //计算出会员最大的消费金额和最小的消费金额
                    double Maxsum = 0.0;
                    double Minsum = 0.0;
                    for (int i = 1; i < result_M.Count; i++)
                    {
                        if (i == 1)
                        {
                            Maxsum = Convert.ToDouble(result_M[i]["msum"]) > Convert.ToDouble(result_M[0]["msum"]) ? Convert.ToDouble(result_M[i]["msum"]) : Convert.ToDouble(result_M[0]["msum"]);

                            Minsum = Convert.ToDouble(result_M[i]["msum"]) < Convert.ToDouble(result_M[0]["msum"]) ? Convert.ToDouble(result_M[i]["msum"]) : Convert.ToDouble(result_M[0]["msum"]);
                        }
                        else
                        {
                            Maxsum = Maxsum > Convert.ToDouble(result_M[i]["msum"]) ? Maxsum : Convert.ToDouble(result_M[i]["msum"]);

                            Minsum = Minsum < Convert.ToDouble(result_M[i]["msum"]) ? Minsum : Convert.ToDouble(result_M[i]["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[i]["userId"].ToString();
                        double dsum = Convert.ToDouble(result_M[i]["msum"]);

                        string struser_M = "0";
                        if (dsum >= Minsum && dsum <= M_interval)
                        {
                            struser_M = "1";
                        }
                        if (dsum >= M_interval && dsum <= (M_interval * 2))
                        {
                            struser_M = "2";
                        }
                        if (dsum >= (M_interval * 2) && dsum <= (M_interval * 3))
                        {
                            struser_M = "3";
                        }
                        if (dsum >= (M_interval * 3) && dsum <= (M_interval * 4))
                        {
                            struser_M = "4";
                        }
                        if (dsum >= (M_interval * 4) && dsum <= Maxsum)
                        {
                            struser_M = "5";
                        }

                        //执行更新操作
                        var query_M = Query.EQ("user_Id", strUserId);
                        var update_M = new UpdateDocument { { "$set", new QueryDocument { { "user_M", struser_M } } } };

                        colRFM.Update(query_M, update_M);
                    }
                }
            }
            catch (Exception ex)
            {
                throw;
            }

            #endregion

        }