289 lines
12 KiB
C#
289 lines
12 KiB
C#
/***********************************************************************
|
||
* Project: CoreCms
|
||
* ProjectName: 核心内容管理系统
|
||
* Web: https://www.corecms.net
|
||
* Author: 大灰灰
|
||
* Email: jianweie@163.com
|
||
* CreateTime: 2021/1/31 21:45:10
|
||
* Description: 暂无
|
||
***********************************************************************/
|
||
|
||
using System;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using System.Threading.Tasks;
|
||
using CoreCms.Net.Configuration;
|
||
using CoreCms.Net.IRepository;
|
||
using CoreCms.Net.IRepository.UnitOfWork;
|
||
using CoreCms.Net.IServices;
|
||
using CoreCms.Net.Loging;
|
||
using CoreCms.Net.Model.Entities;
|
||
using CoreCms.Net.Model.Entities.Expression;
|
||
using CoreCms.Net.Model.ViewModels.Basics;
|
||
using CoreCms.Net.Model.ViewModels.UI;
|
||
using CoreCms.Net.Utility.Extensions;
|
||
using CoreCms.Net.Utility.Helper;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using Microsoft.Extensions.Hosting;
|
||
using SqlSugar;
|
||
|
||
|
||
namespace CoreCms.Net.Services
|
||
{
|
||
/// <summary>
|
||
/// 用户提现记录表 接口实现
|
||
/// </summary>
|
||
public class CoreCmsUserTocashServices : BaseServices<CoreCmsUserTocash>, ICoreCmsUserTocashServices
|
||
{
|
||
private readonly ICoreCmsUserTocashRepository _dal;
|
||
private readonly IUnitOfWork _unitOfWork;
|
||
private readonly IServiceProvider _serviceProvider;
|
||
private readonly ICoreCmsSettingServices _settingServices;
|
||
private readonly ICoreCmsUserServices _userServices;
|
||
private readonly ICoreCmsUserBalanceServices _userBalanceServices;
|
||
|
||
|
||
|
||
public CoreCmsUserTocashServices(IUnitOfWork unitOfWork, ICoreCmsUserTocashRepository dal,
|
||
IServiceProvider serviceProvider, ICoreCmsSettingServices settingServices, ICoreCmsUserServices userServices, ICoreCmsUserBalanceServices userBalanceServices)
|
||
{
|
||
this._dal = dal;
|
||
base.BaseDal = dal;
|
||
_unitOfWork = unitOfWork;
|
||
_serviceProvider = serviceProvider;
|
||
_settingServices = settingServices;
|
||
_userServices = userServices;
|
||
_userBalanceServices = userBalanceServices;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 提现申请
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<WebApiCallBack> Tocash(int userId, decimal money, int bankCardsId)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
using var container = _serviceProvider.CreateScope();
|
||
|
||
var settingServices = container.ServiceProvider.GetService<ICoreCmsSettingServices>();
|
||
var userServices = container.ServiceProvider.GetService<ICoreCmsUserServices>();
|
||
var userBankCardServices = container.ServiceProvider.GetService<ICoreCmsUserBankCardServices>();
|
||
var balanceServices = container.ServiceProvider.GetService<ICoreCmsUserBalanceServices>();
|
||
|
||
var allConfigs = await settingServices.GetConfigDictionaries();
|
||
|
||
//最小提现金额
|
||
var tocashMoneyLow = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.TocashMoneyLow).ObjectToDecimal((decimal)0.01);
|
||
//每日提现上线
|
||
var tocashMoneyLimit = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.TocashMoneyLimit).ObjectToDecimal(0);
|
||
//提现手续费
|
||
var tocashMoneyRate = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.TocashMoneyRate).ObjectToDecimal(0);
|
||
//最低提现金额
|
||
if (money < tocashMoneyLow)
|
||
{
|
||
jm.msg = "提现最低不能少于" + tocashMoneyLow + "元";
|
||
return jm;
|
||
}
|
||
//每日提现上限，默认0不限制
|
||
if (tocashMoneyLimit > 0)
|
||
{
|
||
var dt = DateTime.Now;
|
||
var starTime = new DateTime(dt.Year, dt.Month, dt.Day, 0, 0, 0);
|
||
var endTime = new DateTime(dt.Year, dt.Month, dt.Day, 23, 59, 59);
|
||
//判断历史提现金额
|
||
var todayMoney = await _dal.GetSumAsync(p => p.createTime >= starTime && p.createTime <= endTime && p.userId == userId, p => p.money);
|
||
todayMoney = todayMoney + money; //历史今天提现加上本次提现;
|
||
if (todayMoney > tocashMoneyLimit)
|
||
{
|
||
jm.msg = "每日提现不能超过" + tocashMoneyLimit + "元";
|
||
return jm;
|
||
}
|
||
}
|
||
var userInfo = await userServices.QueryByIdAsync(userId);
|
||
if (userInfo == null)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11004;
|
||
return jm;
|
||
}
|
||
if (money > userInfo.balance)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11015;
|
||
return jm;
|
||
}
|
||
// 计算提现服务费(金额)
|
||
var cateMoney = money * (tocashMoneyRate / 100);
|
||
if (cateMoney + money > userInfo.balance)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11015;
|
||
return jm;
|
||
}
|
||
//获取银行卡信息
|
||
var bankcardsInfo = await userBankCardServices.QueryByClauseAsync(p => p.userId == userId && p.id == bankCardsId);
|
||
if (bankcardsInfo == null)
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11016;
|
||
return jm;
|
||
}
|
||
var cashModel = new CoreCmsUserTocash();
|
||
cashModel.userId = userId;
|
||
cashModel.money = money;
|
||
cashModel.bankName = bankcardsInfo.bankName;
|
||
cashModel.bankCode = bankcardsInfo.bankCode;
|
||
cashModel.bankAreaId = bankcardsInfo.bankAreaId;
|
||
cashModel.accountBank = bankcardsInfo.accountBank;
|
||
cashModel.accountName = bankcardsInfo.accountName;
|
||
cashModel.cardNumber = bankcardsInfo.cardNumber;
|
||
cashModel.status = (int)GlobalEnumVars.UserTocashTypes.待审核;
|
||
cashModel.withdrawals = cateMoney;
|
||
cashModel.createTime = DateTime.Now;
|
||
|
||
var res = await _dal.InsertAsync(cashModel);
|
||
if (res > 0)
|
||
{
|
||
var change = await balanceServices.Change(userId, (int)GlobalEnumVars.UserBalanceSourceTypes.Tocash, money, res.ToString(), cateMoney);
|
||
jm.status = change.status;
|
||
jm.msg = jm.status ? "提现申请成功" : "提现申请失败";
|
||
jm.data = change.data;
|
||
jm.otherData = change.otherData;
|
||
}
|
||
else
|
||
{
|
||
jm.msg = "提现申请失败";
|
||
}
|
||
|
||
return jm;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 获取用户提现列表记录
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="page"></param>
|
||
/// <param name="limit"></param>
|
||
/// <param name="status"></param>
|
||
/// <returns></returns>
|
||
public async Task<WebApiCallBack> UserToCashList(int userId = 0, int page = 1, int limit = 10, int status = 0)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var where = PredicateBuilder.True<CoreCmsUserTocash>();
|
||
if (status > 0)
|
||
{
|
||
where = where.And(p => p.status == status);
|
||
}
|
||
if (userId > 0)
|
||
{
|
||
where = where.And(p => p.userId == userId);
|
||
}
|
||
var list = await _dal.QueryPageAsync(where, p => p.createTime, OrderByType.Desc, page, limit);
|
||
if (list.Any())
|
||
{
|
||
foreach (var item in list)
|
||
{
|
||
item.statusName = EnumHelper.GetEnumDescriptionByValue<GlobalEnumVars.UserTocashTypes>(item.status);
|
||
item.cardNumber = UserHelper.BankCardNoFormat(item.cardNumber);
|
||
}
|
||
}
|
||
|
||
jm.status = true;
|
||
jm.data = list;
|
||
jm.otherData = new
|
||
{
|
||
list.TotalPages
|
||
};
|
||
|
||
return jm;
|
||
|
||
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 提现审核
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <param name="status"></param>
|
||
/// <returns></returns>
|
||
public async Task<WebApiCallBack> Examine(int id = 0, int status = 0)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
|
||
var info = await _dal.QueryByClauseAsync(p =>
|
||
p.id == id && p.status == (int)GlobalEnumVars.UserTocashTypes.待审核);
|
||
if (info == null)
|
||
{
|
||
jm.msg = "没有此记录或不是待审核状态";
|
||
return jm;
|
||
}
|
||
|
||
if (status > 0)
|
||
{
|
||
var bl = await _dal.UpdateAsync(p => new CoreCmsUserTocash() { status = status, updateTime = DateTime.Now }, p =>
|
||
p.id == id && p.status == (int)GlobalEnumVars.UserTocashTypes.待审核);
|
||
jm.status = bl;
|
||
jm.data = status;
|
||
if (bl)
|
||
{
|
||
//失败给用户退钱到余额
|
||
if (status == (int)GlobalEnumVars.UserTocashTypes.提现失败)
|
||
{
|
||
var toCashInfo = await _dal.QueryByIdAsync(id);
|
||
|
||
// 提现金额 加 服务费返还
|
||
var newMoney = toCashInfo.money + toCashInfo.withdrawals;
|
||
var up = await _userServices.UpdateAsync(p => new CoreCmsUser() { balance = p.balance + newMoney }, p => p.id == toCashInfo.userId);
|
||
if (up)
|
||
{
|
||
//添加记录
|
||
var user = await _userServices.QueryByIdAsync(toCashInfo.userId);
|
||
|
||
var balance = new CoreCmsUserBalance();
|
||
balance.type = (int)GlobalEnumVars.UserBalanceSourceTypes.Tocash;
|
||
balance.userId = toCashInfo.userId;
|
||
balance.balance = user.balance;
|
||
balance.createTime = DateTime.Now;
|
||
balance.memo = UserHelper.GetMemo(balance.type, toCashInfo.money);
|
||
balance.money = newMoney;
|
||
balance.sourceId = id.ToString();
|
||
|
||
await _userBalanceServices.InsertAsync(balance);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10000;
|
||
jm.status = false;
|
||
}
|
||
|
||
return jm;
|
||
|
||
|
||
}
|
||
|
||
|
||
#region 重写根据条件查询分页数据
|
||
/// <summary>
|
||
/// 重写根据条件查询分页数据
|
||
/// </summary>
|
||
/// <param name="predicate">判断集合</param>
|
||
/// <param name="orderByType">排序方式</param>
|
||
/// <param name="pageIndex">当前页面索引</param>
|
||
/// <param name="pageSize">分布大小</param>
|
||
/// <param name="orderByExpression"></param>
|
||
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
||
/// <returns></returns>
|
||
public new async Task<IPageList<CoreCmsUserTocash>> QueryPageAsync(Expression<Func<CoreCmsUserTocash, bool>> predicate,
|
||
Expression<Func<CoreCmsUserTocash, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
|
||
int pageSize = 20, bool blUseNoLock = false)
|
||
{
|
||
return await _dal.QueryPageAsync(predicate, orderByExpression, orderByType, pageIndex, pageSize, blUseNoLock);
|
||
}
|
||
#endregion
|
||
|
||
}
|
||
}
|