/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IRepository;
|
using CoreCms.Net.IRepository.UnitOfWork;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.Entities.Expression;
|
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 NPOI.SS.Formula.Functions;
|
using SqlSugar;
|
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 用户积分记录表 接口实现
|
/// </summary>
|
public class CoreCmsUserPointLogServices : BaseServices<CoreCmsUserPointLog>, ICoreCmsUserPointLogServices
|
{
|
private readonly ICoreCmsUserPointLogRepository _dal;
|
private readonly IUnitOfWork _unitOfWork;
|
private readonly IServiceProvider _serviceProvider;
|
|
public CoreCmsUserPointLogServices(IUnitOfWork unitOfWork, ICoreCmsUserPointLogRepository dal,
|
IServiceProvider serviceProvider
|
)
|
{
|
this._dal = dal;
|
base.BaseDal = dal;
|
_unitOfWork = unitOfWork;
|
_serviceProvider = serviceProvider;
|
}
|
|
/// <summary>
|
/// 积分消费日志设置
|
/// </summary>
|
/// <param name="userId">用户</param>
|
/// <param name="num"></param>
|
/// <param name="type"></param>
|
/// <param name="remarks"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> SetPoint(int userId, int num, int type, string remarks)
|
{
|
using (var container = _serviceProvider.CreateScope())
|
{
|
var userServices = container.ServiceProvider.GetService<ICoreCmsUserServices>();
|
|
var res = new WebApiCallBack() { methodDescription = "积分消费日志设置" };
|
//获取积分账号信息
|
var userModel = await userServices.QueryByIdAsync(userId);
|
if (userModel == null)
|
{
|
res.msg = "更新消费积分日志获取用户信息失败";
|
return res;
|
}
|
|
var newPoint = num + userModel.point;
|
//积分余额判断
|
if (newPoint < 0)
|
{
|
res.msg = "积分余额不足";
|
return res;
|
}
|
//插入记录
|
var log = new CoreCmsUserPointLog();
|
log.userId = userId;
|
log.type = type;
|
log.num = num;
|
log.balance = newPoint;
|
log.remarks = remarks;
|
log.createTime = DateTime.Now;
|
|
await _dal.InsertAsync(log);
|
await userServices.UpdateAsync(p => new CoreCmsUser() { point = p.point + num }, p => p.id == userModel.id);
|
|
|
res.status = true;
|
res.msg = "积分更改成功";
|
return res;
|
}
|
}
|
|
/// <summary>
|
/// 订单完成送积分操作
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <param name="money"></param>
|
/// <param name="orderId"></param>
|
public async Task OrderComplete(int userId, decimal money, string orderId)
|
{
|
using (var container = _serviceProvider.CreateScope())
|
{
|
var settingServices = container.ServiceProvider.GetService<ICoreCmsSettingServices>();
|
var orderItemServices = container.ServiceProvider.GetService<ICoreCmsOrderItemServices>();
|
var productsServices = container.ServiceProvider.GetService<ICoreCmsProductsServices>();
|
var distributionServices = container.ServiceProvider.GetService<ICoreCmsDistributionServices>();
|
var allConfigs = await settingServices.GetConfigDictionaries();
|
//获取积分获取模式
|
var pointGetModel = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.PointGetModel).ObjectToInt();
|
if (pointGetModel == 1)
|
{
|
//如果是订单获取，直接走金额计算。
|
var ordersRewardProportion = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.OrdersRewardProportion).ObjectToInt();
|
if (ordersRewardProportion > 0)
|
{
|
//如果是经销商就不能获得积分
|
var user = await distributionServices.QueryListByClauseAsync(x => x.userId == userId && x.verifyStatus == 1 && x.isDelete == false );//(int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes
|
|
if (user == null || user.Count == 0)
|
{
|
//如果是普通用户则货得积分
|
var point = Convert.ToInt32(money / ordersRewardProportion);
|
await SetPoint(userId, point, (int)GlobalEnumVars.UserPointSourceTypes.PointTypeRebate,
|
"订单：" + orderId + " 奖励");
|
}
|
}
|
}
|
else if (pointGetModel == 2)
|
{
|
//如果是单品获取模式，则找订单商品详情
|
var orderItems = await orderItemServices.QueryListByClauseAsync(p => p.orderId == orderId);
|
if (orderItems.Any())
|
{
|
var productIds = orderItems.Select(p => p.productId).ToList();
|
var products = await productsServices.QueryListByClauseAsync(p => productIds.Contains(p.id));
|
var point = 0;
|
foreach (var item in orderItems)
|
{
|
var pd = products.Find(p => p.id == item.productId);
|
if (pd != null && pd.points > 0)
|
{
|
point += pd.points * item.nums;
|
}
|
}
|
if (point > 0)
|
{
|
await SetPoint(userId, point, (int)GlobalEnumVars.UserPointSourceTypes.PointTypeRebate,
|
"订单：" + orderId + " 奖励");
|
}
|
}
|
}
|
}
|
}
|
|
/// <summary>
|
/// 判断今天是否签到
|
/// </summary>
|
/// <param name="userId"></param>
|
public async Task<WebApiCallBack> IsSign(int userId)
|
{
|
var jm = new WebApiCallBack();
|
jm.msg = "今天还没有签到";
|
|
var where = PredicateBuilder.True<CoreCmsUserPointLog>();
|
where = where.And(p => p.userId == userId && p.type == (int)GlobalEnumVars.UserPointSourceTypes.PointTypeSign);
|
|
var dt = DateTime.Now;
|
var startTime = new DateTime(dt.Year, dt.Month, dt.Day, 0, 0, 0);
|
var endTime = new DateTime(dt.Year, dt.Month, dt.Day, 23, 59, 59);
|
|
where = where.And(p => p.createTime > startTime && p.createTime < endTime);
|
|
var bl = await _dal.ExistsAsync(where);
|
jm.status = bl;
|
jm.msg = bl ? "今天已经签到了" : "今天还没有签到";
|
|
return jm;
|
}
|
|
|
/// <summary>
|
/// 用户签到
|
/// </summary>
|
/// <param name="userId"></param>
|
public async Task<WebApiCallBack> Sign(int userId)
|
{
|
using var container = _serviceProvider.CreateScope();
|
var settingServices = container.ServiceProvider.GetService<ICoreCmsSettingServices>();
|
var jm = new WebApiCallBack();
|
|
var res = await IsSign(userId);
|
if (res.status)
|
{
|
jm.msg = "今天已经签到，无需重复签到";
|
return jm;
|
}
|
//获取店铺签到积分设置
|
var allConfigs = await settingServices.GetConfigDictionaries();
|
|
var signPointType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SignPointType).ObjectToInt();
|
|
//判断是固定积分计算还是随机积分计算
|
var point = 0;
|
if (signPointType == (int)GlobalEnumVars.UserPointSignTypes.RandomPoint)
|
{
|
//随机计算
|
//获取最小随机值
|
var signRandomMin = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SignRandomMin).ObjectToInt(1);
|
//获取最大随机值
|
var signRandomMax = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SignRandomMax).ObjectToInt(10);
|
Random ran = new Random();
|
point = ran.Next(signRandomMin, signRandomMax);
|
}
|
else
|
{
|
//固定计算
|
//首次签到积分
|
var firstSignPoint = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.FirstSignPoint).ObjectToInt(1);
|
//连续签到追加
|
var continuitySignAdditional = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ContinuitySignAdditional).ObjectToInt(1);
|
//签到最多积分
|
var signMostPoint = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SignMostPoint).ObjectToInt(1);
|
|
//最大连续签到天数
|
var maxContinuityDay = 0;
|
|
//获取连续签到天数
|
if (continuitySignAdditional > 0)
|
{
|
maxContinuityDay = (signMostPoint - firstSignPoint) / continuitySignAdditional;
|
}
|
else
|
{
|
//连续追加0的话说明每天签到积分都一样多，那么最大连续签到天数就是1天
|
maxContinuityDay = 1;
|
}
|
|
var day = DateTime.Now.AddDays(-maxContinuityDay);
|
|
|
var logs = await _dal.QueryListByClauseAsync(p =>
|
p.userId == userId && p.type == (int)(int)GlobalEnumVars.UserPointSourceTypes.PointTypeSign &&
|
p.createTime > day);
|
|
var newRes = new List<string>();
|
if (logs != null && logs.Any())
|
{
|
foreach (var item in logs)
|
{
|
var dtStr = item.createTime.ToString("yyyy-MM-dd");
|
if (!newRes.Contains(dtStr))
|
{
|
newRes.Add(dtStr);
|
}
|
}
|
}
|
|
var intDay = 0; //连续签到天数
|
for (int i = 1; i <= maxContinuityDay; i++)
|
{
|
var now = DateTime.Now.AddDays(-i).ToString("yyyy-MM-dd"); ;
|
if (newRes.Contains(now))
|
{
|
intDay++;
|
}
|
else
|
{
|
break;
|
}
|
}
|
//积分
|
point = firstSignPoint + continuitySignAdditional * intDay;
|
point = point > signMostPoint ? signMostPoint : point;
|
}
|
jm.data = point;
|
//插入数据库
|
var result = await SetPoint(userId, point, (int)GlobalEnumVars.UserPointSourceTypes.PointTypeSign, "积分签到，获得" + point + "积分");
|
jm.msg = result.msg;
|
jm.status = result.status;
|
return jm;
|
}
|
}
|
}
|
