Master.CanYinWu.DAL/RechargeRecordDAL.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

using Dapper;
using Master.CanYinWu.Entity;
using Master.CanYinWu.Utility;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Master.CanYinWu.DAL
{
    public class RechargeRecordDAL
    {


        public async Task<int> AddRechargeRecord(RechargeRecord rechargeRecord)
        {
            //添加充值记录
            string sql = @"INSERT INTO [RechargeRecord](MemberId,[StoreId],[AdminId],[RechargeMoney])VALUES(@MemberId,@StoreId,@AdminId,@RechargeMoney);";
            //修改充值剩余金额 RemainingAmount
            string updateMemberSql = @"update member set RemainingAmount = ISNULL(RemainingAmount, 0) + @RechargeMoney where memberId=@MemberId and  StoreId=@StoreId ";
            using (var conn = ConnectionFactory.Connection())
            {
                IDbTransaction tran = conn.BeginTransaction();
                try
                {
                    int row  =await conn.ExecuteAsync(sql, rechargeRecord, tran);
                    row += await conn.ExecuteAsync(updateMemberSql, rechargeRecord, tran);
                    tran.Commit();
                    return row;
                }
                catch (Exception ex)
                {
                    LogHelper.WriteLog($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}会员充值操作异常信息{ex.Message}");
                    tran.Rollback();
                    return 0;
                }
            }
        }


    }
}