/***********************************************************************
|
* Project: CoreCms
|
* ProjectName: 百分兵法管理系统
|
* Web: hhtp://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
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.Model.Entities;
|
using CoreCms.Net.Model.ViewModels.Basics;
|
using CoreCms.Net.Model.ViewModels.DTO;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Helper;
|
using SqlSugar;
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 代理商表 接口实现
|
/// </summary>
|
public class CoreCmsAgentServices : BaseServices<CoreCmsAgent>, ICoreCmsAgentServices
|
{
|
private readonly ICoreCmsAgentGoodsServices _agentGoodsServices;
|
private readonly ICoreCmsAgentGradeServices _agentGradeServices;
|
private readonly ICoreCmsAgentOrderServices _agentOrderServices;
|
private readonly ICoreCmsAgentRepository _dal;
|
private readonly ICoreCmsGoodsServices _goodsServices;
|
|
private readonly ICoreCmsSettingServices _settingServices;
|
private readonly IUnitOfWork _unitOfWork;
|
private readonly ICoreCmsUserServices _userServices;
|
|
|
public CoreCmsAgentServices(IUnitOfWork unitOfWork, ICoreCmsAgentRepository dal,
|
ICoreCmsSettingServices settingServices, ICoreCmsAgentOrderServices agentOrderServices,
|
ICoreCmsUserServices userServices, ICoreCmsAgentGradeServices agentGradeServices,
|
ICoreCmsGoodsServices goodsServices, ICoreCmsAgentGoodsServices agentGoodsServices)
|
{
|
_dal = dal;
|
_settingServices = settingServices;
|
_agentOrderServices = agentOrderServices;
|
_userServices = userServices;
|
_agentGradeServices = agentGradeServices;
|
_goodsServices = goodsServices;
|
_agentGoodsServices = agentGoodsServices;
|
BaseDal = dal;
|
_unitOfWork = unitOfWork;
|
}
|
|
|
#region 获取经销商信息
|
|
/// <summary>
|
/// 获取经销商信息
|
/// </summary>
|
/// <param name="userId">用户id</param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetInfo(int userId)
|
{
|
var jm = new WebApiCallBack();
|
|
//var allConfigs = await _settingServices.GetConfigDictionaries();
|
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
|
if (info is { verifyStatus: (int)GlobalEnumVars.AgentVerifyStatus.VerifyYes })
|
{
|
//总金额
|
info.TotalSettlementAmount = await _agentOrderServices.GetSumAsync(
|
p => p.isSettlement != (int)GlobalEnumVars.AgentOrderSettlementStatus.SettlementCancel &&
|
p.userId == userId, p => p.amount);
|
//已结算金额
|
info.SettlementAmount = await _agentOrderServices.GetSumAsync(
|
p => p.isSettlement == (int)GlobalEnumVars.AgentOrderSettlementStatus.SettlementYes &&
|
p.userId == userId, p => p.amount);
|
//冻结金额
|
info.FreezeAmount = await _agentOrderServices.GetSumAsync(
|
p => p.isSettlement == (int)GlobalEnumVars.AgentOrderSettlementStatus.SettlementNo &&
|
p.userId == userId, p => p.amount);
|
|
var dt = DateTime.Now;
|
//本月第一天时间
|
var dtFirst = dt.AddDays(1 - dt.Day);
|
//获得某年某月的天数
|
var year = dt.Year;
|
var month = dt.Month;
|
var dayCount = DateTime.DaysInMonth(year, month);
|
var dtLast = dtFirst.AddDays(dayCount - 1);
|
|
//本月订单数
|
info.CurrentMonthOrder = await _agentOrderServices.GetCountAsync(p =>
|
p.createTime >= dtFirst && p.createTime < dtLast && p.userId == userId);
|
|
info.Store = UserHelper.GetShareCodeByUserId(userId).ToString();
|
|
//本日开始结束时间
|
var day = dt.Day;
|
var dayStart = new DateTime(year, month, day, 0, 0, 0);
|
var datEnd = new DateTime(year, month, day, 23, 59, 59);
|
|
//今日收益
|
info.TodayFreezeAmount = await _agentOrderServices.GetSumAsync(
|
p => p.createTime > dayStart && p.createTime <= datEnd && p.userId == userId, p => p.amount);
|
//今日订单
|
info.TodayOrder = await _agentOrderServices.GetCountAsync(p =>
|
p.createTime > dayStart && p.createTime <= datEnd && p.userId == userId);
|
//今日会员
|
info.TodayUser = await _userServices.GetCountAsync(p =>
|
p.parentId == userId && p.createTime > dayStart && p.createTime <= datEnd);
|
}
|
|
info ??= new CoreCmsAgent();
|
|
info.TotalGoods = await _agentGoodsServices.GetCountAsync(p => p.isEnable);
|
if (info.gradeId > 0)
|
{
|
var userGrade = await _agentGradeServices.QueryByIdAsync(info.gradeId);
|
if (userGrade != null) info.GradeName = userGrade.name;
|
}
|
|
jm.msg = "获取成功";
|
jm.status = true;
|
jm.data = info;
|
|
return jm;
|
}
|
|
#endregion
|
|
#region 添加用户信息
|
|
/// <summary>
|
/// 添加用户信息
|
/// </summary>
|
/// <param name="iData"></param>
|
/// <param name="userId"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> AddData(CoreCmsAgent iData, int userId)
|
{
|
var jm = new WebApiCallBack();
|
if (string.IsNullOrEmpty(iData.mobile))
|
{
|
jm.msg = "请填写手机号";
|
return jm;
|
}
|
|
if (CommonHelper.IsMobile(iData.mobile) == false)
|
{
|
jm.msg = "请填写正确的手机号";
|
return jm;
|
}
|
|
if (string.IsNullOrEmpty(iData.name))
|
{
|
jm.msg = "请填写您的姓名";
|
return jm;
|
}
|
|
iData.userId = userId;
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
if (info != null)
|
{
|
jm.status = false;
|
jm.msg = "您已申请，请勿重复提交";
|
return jm;
|
}
|
|
//默认等级处理
|
if (iData.gradeId == 0)
|
{
|
var disGradeModel = await _agentGradeServices.QueryByClauseAsync(p => p.isDefault);
|
if (disGradeModel != null) iData.gradeId = disGradeModel.id;
|
}
|
|
if (iData.verifyStatus == 0) iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyWait;
|
iData.isDelete = false;
|
iData.createTime = DateTime.Now;
|
|
//判断是否存在
|
var bl = await _dal.InsertAsync(iData) > 0;
|
jm.status = bl;
|
jm.msg = bl ? "申请成功" : "申请失败";
|
|
return jm;
|
}
|
|
#endregion
|
|
#region 获取我的推广订单
|
|
/// <summary>
|
/// 获取我的推广订单
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <param name="page"></param>
|
/// <param name="limit"></param>
|
/// <param name="typeId"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetMyOrderList(int userId, int page, int limit = 10, int typeId = 0)
|
{
|
var jm = new WebApiCallBack();
|
|
jm.status = true;
|
jm.msg = "获取成功";
|
var pageList = await _dal.QueryOrderPageAsync(userId, page, limit, typeId);
|
jm.data = pageList;
|
jm.code = pageList.TotalCount;
|
|
return jm;
|
}
|
|
#endregion
|
|
#region 获取店铺信息
|
|
/// <summary>
|
/// 获取店铺信息
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetStore(int userId)
|
{
|
var jm = new WebApiCallBack();
|
|
jm.status = true;
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
if (info != null)
|
//info.TotalGoods = await _agentGoodsServices.GetCountAsync(p => p.isEnable == true);
|
jm.data = new
|
{
|
info.createTime,
|
info.name,
|
info.storeBanner,
|
info.storeDesc,
|
info.storeLogo,
|
info.storeName
|
//info.TotalGoods
|
};
|
|
return jm;
|
}
|
|
#endregion
|
|
|
#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 async Task<IPageList<CoreCmsAgent>> QueryPageAsync(Expression<Func<CoreCmsAgent, bool>> predicate,
|
Expression<Func<CoreCmsAgent, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
|
int pageSize = 20, bool blUseNoLock = false)
|
{
|
return await _dal.QueryPageAsync(predicate, orderByExpression, orderByType, pageIndex, pageSize,
|
blUseNoLock);
|
}
|
|
#endregion
|
|
|
/// <summary>
|
/// 获取代理商排行
|
/// </summary>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <returns></returns>
|
public async Task<IPageList<AgentRankingDTO>> QueryRankingPageAsync(int pageIndex = 1, int pageSize = 20)
|
{
|
return await _dal.QueryRankingPageAsync(pageIndex, pageSize);
|
}
|
}
|
}
|
