/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Collections.Generic;
|
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.Model.Entities;
|
using CoreCms.Net.Model.ViewModels.Basics;
|
using CoreCms.Net.Utility.Extensions;
|
using SqlSugar;
|
|
namespace CoreCms.Net.Repository
|
{
|
/// <summary>
|
/// 促销表 接口实现
|
/// </summary>
|
public class CoreCmsPromotionRepository : BaseRepository<CoreCmsPromotion>, ICoreCmsPromotionRepository
|
{
|
public CoreCmsPromotionRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
|
{
|
|
}
|
|
|
//判断商品是否参加团购
|
/// <summary>
|
/// 判断商品是否参加团购/秒杀
|
/// </summary>
|
/// <param name="goodId">商品序列</param>
|
/// <param name="promotionId">关联促销信息</param>
|
/// <param name="type">类型</param>
|
/// <returns></returns>
|
public bool IsInGroup(int goodId, out int promotionId,int type)
|
{
|
promotionId = 0;
|
if (goodId == 0)
|
{
|
return false;
|
}
|
var dt = DateTime.Now;
|
var goodIds = "\"" + goodId + "\"";
|
|
var model = DbClient.Queryable<CoreCmsPromotion, CoreCmsPromotionCondition>(
|
(pro, ccpc) => new object[] {
|
JoinType.Inner, pro.id == ccpc.promotionId
|
}
|
)
|
.Where((pro, ccpc) => pro.isEnable == true && pro.isDel == false)
|
.Where((pro, ccpc) => ccpc.parameters.Contains(goodIds))
|
.Where((pro, ccpc) => pro.type == type)
|
.Select((pro, ccpc) => ccpc)
|
.First();
|
|
if (model != null)
|
{
|
promotionId = model.promotionId.ObjectToInt();
|
}
|
return model != null;
|
}
|
|
|
#region 查询查了并获取导航下级数据
|
|
/// <summary>
|
/// 查询查了并获取导航下级数据
|
/// </summary>
|
/// <param name="predicate">判断集合</param>
|
/// <param name="orderByType">排序方式</param>
|
/// <param name="isToPage">是否分页</param>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <param name="orderByExpression"></param>
|
/// <returns></returns>
|
public async Task<IPageList<CoreCmsPromotion>> QueryPageAndChildsAsync(Expression<Func<CoreCmsPromotion, bool>> predicate,
|
Expression<Func<CoreCmsPromotion, object>> orderByExpression, OrderByType orderByType, bool isToPage = false, int pageIndex = 1,
|
int pageSize = 20)
|
{
|
RefAsync<int> totalCount = 0;
|
List<CoreCmsPromotion> page;
|
if (isToPage)
|
{
|
page = await DbClient.Queryable<CoreCmsPromotion>()
|
.OrderByIF(orderByExpression != null, orderByExpression, orderByType)
|
.WhereIF(predicate != null, predicate).Select(p => new CoreCmsPromotion
|
{
|
id = p.id,
|
name = p.name,
|
type = p.type,
|
sort = p.sort,
|
parameters = p.parameters,
|
maxNums = p.maxNums,
|
maxGoodsNums = p.maxGoodsNums,
|
maxRecevieNums = p.maxRecevieNums,
|
startTime = p.startTime,
|
endTime = p.endTime,
|
isExclusive = p.isExclusive,
|
isAutoReceive = p.isAutoReceive,
|
isEnable = p.isEnable,
|
isDel = p.isDel,
|
getNumber = SqlFunc.Subqueryable<CoreCmsCoupon>().Where(o => o.promotionId == p.id).Count()
|
})
|
.Mapper(p => p.promotionCondition, p => p.promotionCondition.First().promotionId)
|
.Mapper(p => p.promotionResult, p => p.promotionResult.First().promotionId)
|
.ToPageListAsync(pageIndex, pageSize, totalCount);
|
}
|
else
|
{
|
page = await DbClient.Queryable<CoreCmsPromotion>()
|
.OrderByIF(orderByExpression != null, orderByExpression, orderByType)
|
.WhereIF(predicate != null, predicate)
|
.Take(pageSize)
|
.Select(p => new CoreCmsPromotion
|
{
|
id = p.id,
|
name = p.name,
|
type = p.type,
|
sort = p.sort,
|
parameters = p.parameters,
|
maxNums = p.maxNums,
|
maxGoodsNums = p.maxGoodsNums,
|
maxRecevieNums = p.maxRecevieNums,
|
startTime = p.startTime,
|
endTime = p.endTime,
|
isExclusive = p.isExclusive,
|
isAutoReceive = p.isAutoReceive,
|
isEnable = p.isEnable,
|
isDel = p.isDel,
|
getNumber = SqlFunc.Subqueryable<CoreCmsCoupon>().Where(o => o.promotionId == p.id).Count()
|
})
|
.Mapper(p => p.promotionCondition, p => p.promotionCondition.First().promotionId)
|
.Mapper(p => p.promotionResult, p => p.promotionResult.First().promotionId)
|
.ToListAsync();
|
}
|
|
var list = new PageList<CoreCmsPromotion>(page, pageIndex, pageSize, totalCount);
|
return list;
|
}
|
|
#endregion
|
|
|
}
|
}
|
