提交代码

Mall.Module.User/UserModule.cs

@@ -131,6 +131,10 @@ namespace Mall.Module.User
         /// 分销海报仓储层对象
         /// </summary>
         private RB_MiniProgram_FenXiaoPosterRepository fenXiaoPosterRepository = new RB_MiniProgram_FenXiaoPosterRepository();
+        /// <summary>
+        /// 会员购买仓储层
+        /// </summary>
+        private RB_Member_BuyRepository memberBuyRepository = new RB_Member_BuyRepository();
 
 
         #region 基础配置
@@ -4353,5 +4357,63 @@ namespace Mall.Module.User
         }
 
         #endregion
+
+
+        #region 会员购买
+        /// <summary>
+        /// 分页列表
+        /// </summary>
+        /// <param name="pageIndex">页码</param>
+        /// <param name="pageSize">每页显示条数</param>
+        /// <param name="rowCount">总条数</param>
+        /// <param name="dmodel">查询条件</param>
+        /// <returns></returns>
+        public List<RB_Member_Buy_Extend> GetPageList(int pageIndex, int pageSize, out long rowCount, RB_Member_Buy_Extend dmodel)
+        {
+            return memberBuyRepository.GetPageList(pageIndex, pageSize, out rowCount, dmodel);
+        }
+
+
+        /// <summary>
+        /// 新增会员购买记录
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        public bool AddMemberBuy(RB_Member_Buy_Extend model)
+        {
+            if (model.Id == 0)
+            {
+                return memberBuyRepository.Insert(model);
+            }
+            return false;
+        }
+
+        /// <summary>
+        /// 更新会员购买记录
+        /// </summary>
+        /// <param name="payTime"></param>
+        /// <param name="orderId"></param>
+        /// <returns></returns>
+        public bool UpdateMemberBuy(DateTime payTime, int orderId)
+        {
+            if (orderId > 0)
+            {
+                Dictionary<string, object> keyValues = new Dictionary<string, object>() {
+                    { nameof(RB_Member_Buy.PayTime),payTime},
+                     { nameof(RB_Member_Buy.PayState),1}
+                };
+                List<WhereHelper> wheres = new List<WhereHelper>() {
+                    new WhereHelper{
+                         FiledName=nameof(RB_Member_Footmark.Id),
+                          FiledValue=orderId,
+                           OperatorEnum=OperatorEnum.Equal
+                    }
+                };
+                return memberBuyRepository.Update(keyValues, wheres);
+            }
+            return false;
+        }
+
+        #endregion
     }
 }