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["btime"]) ? Convert.ToDateTime(result_R["btime"]) : Convert.ToDateTime(result_R["btime"]);
Mintime = Convert.ToDateTime(result_R["btime"]) < Convert.ToDateTime(result_R["btime"]) ? Convert.ToDateTime(result_R["btime"]) : Convert.ToDateTime(result_R["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) && dtTimeConvert.ToInt32(result_F["count"]) ? Convert.ToInt32(result_F["count"]) : Convert.ToInt32(result_F["count"]);
Mincount = Convert.ToInt32(result_F["count"]) < Convert.ToInt32(result_F["count"]) ? Convert.ToInt32(result_F["count"]) : Convert.ToInt32(result_F["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) && icountConvert.ToDouble(result_M["msum"]) ? Convert.ToDouble(result_M["msum"]) : Convert.ToDouble(result_M["msum"]);
Minsum = Convert.ToDouble(result_M["msum"]) < Convert.ToDouble(result_M["msum"]) ? Convert.ToDouble(result_M["msum"]) : Convert.ToDouble(result_M["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
页:
[1]