修改消费者累计分红

Areas/Api/Controllers/v1/MainServer/ConsumersController.cs

@@ -243,7 +243,7 @@ namespace MySystem.Areas.Api.Controllers.v1
             Obj.Add("NickName", query.NickName); //昵称
             Obj.Add("HeadPhoto", DefaultPic(query.HeadPhoto)); //头像
             Obj.Add("Mobile", query.Mobile); //手机号
-            Obj.Add("TotalDividend", query.TotalDividend); //累计分红
+            Obj.Add("TotalDividend", new ConsumerProfitService().Sum("GetMoney", " and ConsumerId=" + Id)); //累计分红
             Obj.Add("TotalIntegral", query.TotalIntegral); //累计积分
             Obj.Add("CurIntgegral", query.CurIntgegral); //当前积分
             Obj.Add("CreateDate", query.CreateDate); //创建时间

Services/ConsumerProfitService.cs

@@ -4,6 +4,7 @@ using System.Linq;
 using MySystem.MainModels;
 using Library;
 using LitJson;
+using System.Data;
 
 namespace MySystem
 {
@@ -42,6 +43,26 @@ namespace MySystem
             db.Dispose();
             return editData;
         }
+        public Dictionary<string, string> Sum(string field, string condition)
+        {
+            Dictionary<string, string> result = new Dictionary<string, string>();
+            string sumString = "";
+            string[] fieldlist = field.Split(',');
+            foreach(string f in fieldlist)
+            {
+                sumString += "sum(" + f + ") " + f + ",";
+            }
+            sumString = sumString.TrimEnd(',');
+            DataTable dt = CustomerSqlConn.dtable("select " + sumString + " from ConsumerProfit where 1=1" + condition, _conn);
+            if(dt.Rows.Count > 0)
+            {
+                foreach(string f in fieldlist)
+                {
+                    result.Add(f, function.CheckNum(dt.Rows[0][f].ToString()));
+                }
+            }
+            return result;
+        }
 
         /// <summary>
         /// 添加数据