/***********************************************************************
* 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.DTO.ComponentsDTO;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices.baifenbingfa;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.FromBody;
using CoreCms.Net.Model.ViewModels.Basics;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Helper;
using Newtonsoft.Json;
using NPOI.POIFS.Properties;
using SqlSugar;
namespace CoreCms.Net.Repository
{
///
/// 商品表 接口实现
///
public class CoreCmsGoodsRepository : BaseRepository, ICoreCmsGoodsRepository
{
private readonly IBfbfComAPIService _bfbfComAPIService;
public CoreCmsGoodsRepository(IUnitOfWork unitOfWork,IBfbfComAPIService bfbfComAPIService) : base(unitOfWork)
{
_bfbfComAPIService = bfbfComAPIService;
}
#region 重写异步插入方法
///
/// 重写异步插入方法
///
/// 实体数据
///
public async Task InsertAsync(FMGoodsInsertModel entity)
{
var jm = new AdminUiCallBack();
//基础验证
if (!entity.products.Any())
{
jm.msg = "请设置至少一个货品信息！";
return jm;
}
if (entity.products.Any())
{
var haveDefault = entity.products.Exists(p => p.isDefalut == true);
if (haveDefault == false)
{
jm.msg = "请设置某个货品为默认！";
return jm;
}
}
if (string.IsNullOrEmpty(entity.goods.image))
{
jm.msg = "请上传封面图！";
return jm;
}
if (string.IsNullOrEmpty(entity.goods.images))
{
jm.msg = "请上传图集！";
return jm;
}
//检查数据
foreach (var item in entity.products)
{
//if (!item.sn.Contains("sn") && !item.sn.Contains("SN"))
//{
// jm.msg = "请键入货品货号！货号为SN英文开头";
// return jm;
//}
//else
if (item.stock < 0)
{
jm.msg = "库存不能为0！";
return jm;
}
else if (item.price <= 0)
{
jm.msg = "货品销售价格不能为0！";
return jm;
}
else if (item.mktprice < 0)
{
jm.msg = "市场价格不能小于0！";
return jm;
}
else if (item.costprice < 0)
{
jm.msg = "成本价格不能小于0！";
return jm;
}
else if (item.levelOne < 0 || item.levelTwo < 0 || item.levelThree < 0)
{
jm.msg = "返现金额不能小于0！";
return jm;
}
}
//本社不允许重复
var snsGroup = entity.products.GroupBy(x => x.sn).Where(x => x.Count() > 1).ToList();
if (snsGroup.Count > 0)
{
jm.msg = "货品货号禁止存在重复";
return jm;
}
//数据库不能存在已经有的编码
var snsArr = entity.products.Select(p => p.sn).ToList();
var blsn = await DbClient.Queryable().Where(p => snsArr.Contains(p.sn)).AnyAsync();
if (blsn)
{
jm.msg = "系统中存在相同的货品货号，请重新生成货品货号。";
return jm;
}
var bl = false;
var goods = entity.goods;
//goods.freezeStock = 0;
goods.createTime = DateTime.Now;
goods.commentsCount = 0;
goods.buyCount = 0;
goods.viewCount = 0;
goods.goodsParamsIds = entity.goods.goodsParamsIds;
goods.parameters = entity.goods.parameters;
if (goods.openSpec == 1)
{
goods.newSpec = entity.goods.newSpec;
goods.spesDesc = entity.goods.spesDesc;
goods.goodsTypeId = entity.goods.goodsTypeId;
}
else
{
goods.newSpec = "";
goods.spesDesc = "";
goods.goodsTypeId = 0;
}
goods.isDel = false;
goods.isMarketable = entity.goods.isMarketable;
goods.isRecommend = entity.goods.isRecommend;
goods.isHot = entity.goods.isHot;
var id = await DbClient.Insertable(goods).ExecuteReturnIdentityAsync();
bl = id > 0;
if (id > 0)
{
if (entity.gradePrice.Any())
{
var goodsGrade = new List();
entity.gradePrice.ForEach(p =>
{
goodsGrade.Add(new CoreCmsGoodsGrade()
{
goodsId = id,
gradeId = Convert.ToInt16(p.key),
gradePrice = Convert.ToDecimal(p.value)
});
});
bl = await DbClient.Insertable(goodsGrade).ExecuteCommandAsync() > 0;
}
if (goods.openSpec == 1)
{
var products = new List();
var pds = new List();
entity.products.ForEach(p =>
{
var obj = new CoreCmsProducts();
obj.goodsId = id;
obj.barcode = goods.bn;
obj.sn = p.sn;
obj.price = p.price;
obj.costprice = p.costprice;
obj.mktprice = p.mktprice;
obj.marketable = true;
obj.stock = p.stock;
obj.weight = p.weight;
obj.freezeStock = 0;
obj.spesDesc = p.spesDesc;
obj.pointsDeduction = p.pointsDeduction;
obj.points = p.points;
obj.isDefalut = p.isDefalut;
obj.isDel = false;
obj.images = p.images;
//百分兵法添加
obj.distributionCutMoney = p.distributionCutMoney;
obj.cutMoney = p.cutMoney;
obj.distributionPrice= p.distributionPrice;
products.Add(obj);
var pd = new CoreCmsProductsDistribution();
pd.createTime = DateTime.Now;
pd.productsSN = p.sn;
pd.levelOne = p.levelOne;
pd.levelTwo = p.levelTwo;
pd.levelThree = p.levelThree;
pds.Add(pd);
});
//存入数据
var insertProducts = await DbClient.Insertable(products).ExecuteCommandAsync() > 0;
if (insertProducts)
{
//获取存入的数据，拿到序列，存储到分销表。因为sn可能前端会变更。所以只能用序列做唯一识别
var snArrys = products.Select(p => p.sn).ToList();
var results = await DbClient.Queryable().Where(p => snArrys.Contains(p.sn))
.ToListAsync();
foreach (var p in results)
{
foreach (var o in pds.Where(o => o.productsSN == p.sn))
{
o.productsId = p.id;
}
}
bl = await DbClient.Insertable(pds).ExecuteCommandAsync() > 0;
}
}
else
{
var oldObj = entity.products[0];
var obj = new CoreCmsProducts();
obj.goodsId = id;
obj.barcode = goods.bn;
obj.sn = oldObj.sn;
obj.price = oldObj.price;
obj.costprice = oldObj.costprice;
obj.mktprice = oldObj.mktprice;
obj.marketable = true;
obj.stock = oldObj.stock;
obj.weight = oldObj.weight;
obj.freezeStock = 0;
obj.spesDesc = oldObj.spesDesc;
obj.pointsDeduction = oldObj.pointsDeduction;
obj.points = oldObj.points;
obj.isDefalut = true;
obj.isDel = false;
obj.images = oldObj.images;
obj.distributionCutMoney = oldObj.distributionCutMoney;
obj.cutMoney = oldObj.cutMoney;
obj.distributionPrice = oldObj.distributionPrice;
if (string.IsNullOrEmpty(obj.images))
{
obj.images = goods.image;
}
var insertId = await DbClient.Insertable(obj).ExecuteReturnIdentityAsync();
if (insertId > 0)
{
var pd = new CoreCmsProductsDistribution();
pd.createTime = DateTime.Now;
pd.productsId = insertId;
pd.productsSN = oldObj.sn;
pd.levelOne = oldObj.levelOne;
pd.levelTwo = oldObj.levelTwo;
pd.levelThree = oldObj.levelThree;
bl = await DbClient.Insertable(pd).ExecuteCommandAsync() > 0;
}
}
if (!string.IsNullOrEmpty(entity.goodsCategoryExtendIds))
{
var ids = CommonHelper.StringToIntArray(entity.goodsCategoryExtendIds);
if (ids.Any())
{
var extendIds = new List();
foreach (var t in ids)
{
extendIds.Add(new CoreCmsGoodsCategoryExtend()
{
goodsCategroyId = t,
goodsId = id
});
}
bl = await DbClient.Insertable(extendIds).ExecuteCommandAsync() > 0;
}
}
}
//删除dto缓存
DbClient.DataCache.RemoveDataCache(nameof(GoodListDTO));
jm.data = entity;
jm.code = bl ? 0 : 1;
jm.msg = bl ? GlobalConstVars.CreateSuccess : GlobalConstVars.CreateFailure;
return jm;
}
#endregion
#region 重写异步更新方法方法
///
/// 重写异步更新方法方法
///
///
///
public async Task UpdateAsync(FMGoodsInsertModel entity)
{
var jm = new AdminUiCallBack();
//基础验证
if (!entity.products.Any())
{
jm.msg = "请设置至少一个货品信息！";
return jm;
}
if (entity.products.Any())
{
var haveDefault = entity.products.Exists(p => p.isDefalut == true);
if (haveDefault == false)
{
jm.msg = "请设置一个货品为默认！";
return jm;
}
}
if (string.IsNullOrEmpty(entity.goods.image))
{
jm.msg = "请上传封面图！";
return jm;
}
if (string.IsNullOrEmpty(entity.goods.images))
{
jm.msg = "请上传图集！";
return jm;
}
//检查数据
foreach (var item in entity.products)
{
//if (!item.sn.Contains("sn") && !item.sn.Contains("SN"))
//{
// jm.msg = "请键入货品货号！货号为SN英文开头";
// return jm;
//}
//else
if (item.stock < 0)
{
jm.msg = "库存不能为0！";
return jm;
}
else if (item.price <= 0)
{
jm.msg = "货品销售价格不能为0！";
return jm;
}
else if (item.mktprice < 0)
{
jm.msg = "市场价格不能小于0！";
return jm;
}
else if (item.costprice < 0)
{
jm.msg = "成本价格不能小于0！";
return jm;
}
else if (item.levelOne < 0 || item.levelTwo < 0 || item.levelThree < 0)
{
jm.msg = "返现金额不能小于0！";
return jm;
}
}
var sns = entity.products.GroupBy(x => x.sn).Where(x => x.Count() > 1).ToList();
if (sns.Count > 0)
{
jm.msg = "货品货号禁止存在重复";
return jm;
}
//数据库不能存在已经有的编码
var snsArr = entity.products.Select(p => p.sn).ToList();
var blsn = await DbClient.Queryable().Where(p => snsArr.Contains(p.sn) && p.goodsId != entity.goods.id).AnyAsync();
if (blsn)
{
jm.msg = "系统中存在相同的货品货号，请重新生成货品货号。";
return jm;
}
var model = entity.goods;
var oldModel = await DbClient.Queryable().In(model.id).SingleAsync();
if (oldModel == null)
{
jm.msg = "不存在此信息";
return jm;
}
//事物处理过程开始
//oldModel.id = model.id;
oldModel.areaCode = model.areaCode;
oldModel.bn = model.bn;
oldModel.name = model.name;
oldModel.brief = model.brief;
//oldModel.price = model.price;
//oldModel.costprice = model.costprice;
//oldModel.mktprice = model.mktprice;
oldModel.images = model.images;
oldModel.image = model.image;
oldModel.video = model.video;
oldModel.goodsCategoryId = model.goodsCategoryId;
oldModel.brandId = model.brandId;
oldModel.isNomalVirtual = model.isNomalVirtual;
oldModel.isMarketable = model.isMarketable;
//oldModel.stock = model.stock;
//oldModel.freezeStock = model.freezeStock;
//oldModel.weight = model.weight;
oldModel.unit = model.unit;
oldModel.intro = model.intro;
oldModel.productsDistributionType = model.productsDistributionType;
//oldModel.commentsCount = model.commentsCount;
//oldModel.viewCount = model.viewCount;
//oldModel.buyCount = model.buyCount;
//oldModel.uptime = model.uptime;
//oldModel.downtime = model.downtime;
oldModel.sort = model.sort;
//oldModel.labelIds = model.labelIds;
//oldModel.createTime = model.createTime;
oldModel.goodsParamsIds = model.goodsParamsIds;
oldModel.parameters = model.parameters;
oldModel.openSpec = model.openSpec;
if (oldModel.openSpec == 1)
{
oldModel.newSpec = model.newSpec;
oldModel.spesDesc = model.spesDesc;
oldModel.goodsTypeId = model.goodsTypeId;
oldModel.goodsSkuIds = model.goodsSkuIds;
}
else
{
oldModel.newSpec = "";
oldModel.spesDesc = "";
oldModel.goodsTypeId = 0;
oldModel.goodsSkuIds = "";
}
oldModel.updateTime = DateTime.Now;
oldModel.isRecommend = model.isRecommend;
oldModel.isHot = model.isHot;
oldModel.isDel = model.isDel;
oldModel.initialSales = model.initialSales;
var bl = await DbClient.Updateable(oldModel).ExecuteCommandHasChangeAsync();
if (bl)
{
bl = await DbClient.Deleteable().Where(p => p.goodsId == model.id).ExecuteCommandHasChangeAsync();
if (!string.IsNullOrEmpty(entity.goodsCategoryExtendIds))
{
var ids = CommonHelper.StringToIntArray(entity.goodsCategoryExtendIds);
if (ids.Any())
{
var extendIds = new List();
foreach (var t in ids)
{
extendIds.Add(new CoreCmsGoodsCategoryExtend()
{
goodsCategroyId = t,
goodsId = model.id
});
}
bl = await DbClient.Insertable(extendIds).ExecuteCommandAsync() > 0;
}
}
if (entity.gradePrice.Any())
{
await DbClient.Deleteable().Where(p => p.goodsId == model.id).ExecuteCommandHasChangeAsync();
var goodsGrade = new List();
entity.gradePrice.ForEach(p =>
{
goodsGrade.Add(new CoreCmsGoodsGrade()
{
goodsId = model.id,
gradeId = Convert.ToInt16(p.key),
gradePrice = Convert.ToDecimal(p.value)
});
});
bl = await DbClient.Insertable(goodsGrade).ExecuteCommandAsync() > 0;
}
//商品信息处理
var products = await DbClient.Queryable().Where(p => p.goodsId == model.id && p.isDel == false).ToListAsync();
if (oldModel.openSpec == 1)
{
var oldPostProducts = entity.products.Where(p => p.id > 0).ToList();
if (oldPostProducts.Any())
{
var oldPostProductsIds = oldPostProducts.Select(p => p.id).ToList();
//需要删除的数据
var deletes = products.Where(p => !oldPostProductsIds.Contains(p.id)).ToList();
if (deletes.Any())
{
var deleteIds = deletes.Select(p => p.id).ToList();
bl = await DbClient.Updateable().SetColumns(p => p.isDel == true).Where(p => deleteIds.Contains(p.id)).ExecuteCommandHasChangeAsync();
}
//剩余的老数据
var oldDataProducts = products.Where(p => oldPostProductsIds.Contains(p.id)).ToList();
var oldDistributions = await DbClient.Queryable().Where(p => oldPostProductsIds.Contains(p.productsId)).ToListAsync();
if (oldDataProducts.Any())
{
oldDataProducts.ForEach(p =>
{
var child = oldPostProducts.Find(o => o.id == p.id);
if (child != null)
{
p.isDefalut = child.isDefalut;
if (!string.IsNullOrEmpty(child.images))
{
p.images = child.images;
}
else
{
p.images = oldModel.image;
}
p.sn = child.sn;
p.costprice = child.costprice;
p.mktprice = child.mktprice;
p.price = child.price;
p.spesDesc = child.spesDesc;
p.pointsDeduction = child.pointsDeduction;
p.points = child.points;
p.stock = child.stock;
p.weight = child.weight;
p.distributionPrice = child.distributionPrice;
p.cutMoney = child.cutMoney;
p.distributionCutMoney = child.distributionCutMoney;
}
});
oldDistributions.ForEach(o =>
{
var oldPost = oldPostProducts.Find(p => p.id == o.productsId);
if (oldPost != null)
{
o.levelOne = oldPost.levelOne;
o.levelTwo = oldPost.levelTwo;
o.levelThree = oldPost.levelThree;
o.updateTime = DateTime.Now;
o.productsSN = oldPost.sn;
}
});
//极端情况下，如果不存在三级佣金明细，则创建.
var newDt = new List();
if (oldDistributions.Any())
{
//获取已经存在的序列
var ids = oldDistributions.Select(p => p.productsId).ToList();
//判断货品里面是否存在三级分销细则没有对应的数据，如果存在未对应的，就新增。
var oldNoDtProduts = oldPostProducts.Where(p => !ids.Contains(p.id)).ToList();
if (oldNoDtProduts.Any())
{
oldNoDtProduts.ForEach(p =>
{
var pd = new CoreCmsProductsDistribution();
pd.createTime = DateTime.Now;
pd.productsSN = p.sn;
pd.levelOne = p.levelOne;
pd.levelTwo = p.levelTwo;
pd.levelThree = p.levelThree;
pd.productsId = p.id;
newDt.Add(pd);
});
}
}
var upOldData = await DbClient.Updateable(oldDataProducts).ExecuteCommandHasChangeAsync();
if (upOldData)
{
await DbClient.Updateable(oldDistributions).ExecuteCommandHasChangeAsync();
if (newDt.Any())
{
await DbClient.Insertable(newDt).ExecuteCommandAsync();
}
}
}
}
else
{
var pIds = products.Select(p => p.id).ToList();
bl = await DbClient.Updateable().SetColumns(p => p.isDel == true).Where(p => pIds.Contains(p.id)).ExecuteCommandHasChangeAsync();
}
//新数据
var newPostProducts = entity.products.Where(p => p.id == 0).ToList();
var newProducts = new List();
var pds = new List();
if (newPostProducts.Any())
{
newPostProducts.ForEach(p =>
{
var obj = new CoreCmsProducts();
obj.goodsId = model.id;
obj.barcode = model.bn;
obj.sn = p.sn;
obj.price = p.price;
obj.costprice = p.costprice;
obj.mktprice = p.mktprice;
obj.marketable = true;
obj.stock = p.stock;
obj.weight = p.weight;
obj.freezeStock = 0;
obj.spesDesc = p.spesDesc;
obj.pointsDeduction = p.pointsDeduction;
obj.points = p.points;
obj.isDefalut = p.isDefalut;
obj.images = p.images;
obj.distributionPrice = p.distributionPrice;
obj.cutMoney = p.cutMoney;
obj.distributionCutMoney = p.distributionCutMoney;
if (string.IsNullOrEmpty(p.images))
{
obj.images = oldModel.image;
}
obj.isDel = false;
newProducts.Add(obj);
var pd = new CoreCmsProductsDistribution();
pd.createTime = DateTime.Now;
pd.productsSN = p.sn;
pd.levelOne = p.levelOne;
pd.levelTwo = p.levelTwo;
pd.levelThree = p.levelThree;
pds.Add(pd);
});
var insertProducts = await DbClient.Insertable(newProducts).ExecuteCommandAsync() > 0;
if (insertProducts)
{
//获取存入的数据，拿到序列，存储到分销表。因为sn可能前端会变更。所以只能用序列做唯一识别
var snArrys = newProducts.Select(p => p.sn).ToList();
var results = await DbClient.Queryable().Where(p => snArrys.Contains(p.sn))
.ToListAsync();
foreach (var p in results)
{
foreach (var o in pds.Where(o => o.productsSN == p.sn))
{
o.productsId = p.id;
}
}
bl = await DbClient.Insertable(pds).ExecuteCommandAsync() > 0;
}
}
}
else
{
await DbClient.Updateable().SetColumns(p => p.isDel == true).Where(p => p.goodsId == model.id).ExecuteCommandHasChangeAsync();
var newObj = entity.products.FirstOrDefault();
if (newObj is { id: > 0 })
{
var obj = products.Find(p => p.id == newObj.id);
//obj.barcode = model.bn;
if (obj != null)
{
obj.sn = newObj.sn;
obj.price = newObj.price;
obj.costprice = newObj.costprice;
obj.mktprice = newObj.mktprice;
obj.marketable = true;
obj.stock = newObj.stock;
obj.weight = newObj.weight;
obj.pointsDeduction = newObj.pointsDeduction;
obj.points = newObj.points;
obj.images = newObj.images;
obj.isDefalut = true;
obj.isDel = false;
obj.distributionPrice = newObj.distributionPrice;
obj.cutMoney = newObj.cutMoney;
obj.distributionCutMoney = newObj.distributionCutMoney;
if (string.IsNullOrEmpty(newObj.images))
{
obj.images = oldModel.image;
}
bl = await DbClient.Updateable(obj).ExecuteCommandHasChangeAsync();
}
if (bl)
{
await DbClient.Updateable().SetColumns(p => new CoreCmsProductsDistribution { levelOne = newObj.levelOne, levelTwo = newObj.levelTwo, levelThree = newObj.levelThree, productsSN = newObj.sn }).Where(p => p.productsId == newObj.id).ExecuteCommandHasChangeAsync();
}
}
else
{
var obj = new CoreCmsProducts();
obj.goodsId = model.id;
obj.barcode = model.bn;
obj.sn = newObj.sn;
obj.price = newObj.price;
obj.costprice = newObj.costprice;
obj.mktprice = newObj.mktprice;
obj.images = newObj.images;
obj.marketable = true;
obj.stock = newObj.stock;
obj.weight = newObj.weight;
obj.pointsDeduction = newObj.pointsDeduction;
obj.points = newObj.points;
obj.freezeStock = 0;
obj.spesDesc = "";
obj.isDefalut = true;
obj.isDel = false;
obj.distributionPrice = newObj.distributionPrice;
obj.cutMoney = newObj.cutMoney;
obj.distributionCutMoney = newObj.distributionCutMoney;
if (string.IsNullOrEmpty(newObj.images))
{
obj.images = oldModel.image;
}
var insertId = await DbClient.Insertable(obj).ExecuteReturnIdentityAsync();
if (insertId > 0)
{
var pd = new CoreCmsProductsDistribution();
pd.createTime = DateTime.Now;
pd.productsId = insertId;
pd.productsSN = newObj.sn;
pd.levelOne = newObj.levelOne;
pd.levelTwo = newObj.levelTwo;
pd.levelThree = newObj.levelThree;
bl = await DbClient.Insertable(pd).ExecuteCommandAsync() > 0;
}
}
}
}
//事物处理过程结束
//删除dto缓存
DbClient.DataCache.RemoveDataCache(nameof(GoodListDTO));
jm.code = bl ? 0 : 1;
jm.msg = bl ? GlobalConstVars.EditSuccess : GlobalConstVars.EditFailure;
return jm;
}
#endregion
#region 重写删除指定ID集合的数据(批量删除)
///
/// 重写删除指定ID集合的数据(批量删除)
///
///
///
public async Task DeleteByIdsAsync(int[] ids)
{
var jm = new AdminUiCallBack();
var bl = await DbClient.Updateable().SetColumns(p => p.isDel == true).Where(p => ids.Contains(p.id)).ExecuteCommandHasChangeAsync();
jm.code = bl ? 0 : 1;
jm.msg = bl ? GlobalConstVars.DeleteSuccess : GlobalConstVars.DeleteFailure;
if (bl)
{
//删除dto缓存
DbClient.DataCache.RemoveDataCache(nameof(GoodListDTO));
}
return jm;
}
#endregion
#region 获取商品重量
///
/// 获取商品重量
///
///
///
public async Task GetWeight(int productsId)
{
decimal weight = 0;
//var productsModel =await DbClient.Queryable((products, goods) => new object[]
// {
// JoinType.Left, products.goodsId == goods.id
// }).Where((products, goods) => products.id == productsId)
// .Select((products, goods) => new { goodsWeight = goods.weight, productsWeight = products.weight }).FirstAsync();
//if (productsModel != null)
//{
// weight = productsModel.productsWeight > 0 ? productsModel.productsWeight : productsModel.goodsWeight > 0 ? productsModel.goodsWeight : 0;
//}
var productsModel = await DbClient.Queryable().FirstAsync(p => p.id == productsId);
if (productsModel != null)
{
weight = productsModel.weight > 0 ? productsModel.weight : 0;
}
return weight > 0 ? weight : 0;
}
#endregion
#region 库存改变机制
///
/// 库存改变机制。
/// 库存机制：商品下单 总库存不变，冻结库存加1，
/// 商品发货：冻结库存减1，总库存减1，
/// 订单完成但未发货：总库存不变，冻结库存减1
/// 商品退款&取消订单：总库存不变，冻结库存减1,
/// 商品退货：总库存加1，冻结库存不变,
/// 可销售库存：总库存-冻结库存
///
///
public WebApiCallBack ChangeStock(int productsId, string type = "order", int num = 0)
{
var res = new WebApiCallBack() { methodDescription = "库存改变机制" };
if (productsId == 0)
{
res.msg = "货品ID不能为空";
return res;
}
var productModel = DbClient.Queryable().InSingle(productsId);
var bl = false;
switch (type)
{
case "order": //下单
//更新订单购买量
DbClient.Updateable().SetColumns(it => it.buyCount == it.buyCount + num).Where(p => p.id == productModel.goodsId).ExecuteCommand();
//判断是否有足够量去处理冻结库存变化
var insertNum = productModel.stock < productModel.freezeStock ? 0 : productModel.stock - productModel.freezeStock;
//更新记录。
bl = DbClient.Updateable()
.SetColumns(it => it.freezeStock == it.freezeStock + num)
.Where(p => p.id == productModel.id && insertNum >= num && p.freezeStock < p.stock).ExecuteCommandHasChange();
break;
case "send": //发货
bl = DbClient.Updateable()
.SetColumns(it => it.stock == it.stock - num)
.Where(p => p.freezeStock >= num && p.id == productModel.id).ExecuteCommandHasChange();
if (bl == true)
{
bl = DbClient.Updateable()
.SetColumns(it => it.freezeStock == it.freezeStock - num)
.Where(p => p.freezeStock >= num && p.id == productModel.id).ExecuteCommandHasChange();
}
else
{
res.status = true;
res.msg = "库存更新成功";
return res;
}
break;
case "refund": //退款
bl = DbClient.Updateable()
.SetColumns(it => it.freezeStock == it.freezeStock - num)
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
break;
case "return": //退货
bl = DbClient.Updateable()
.SetColumns(it => it.stock == it.stock + num)
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
break;
case "cancel": //取消订单
bl = DbClient.Updateable()
.SetColumns(it => it.freezeStock == it.freezeStock - num)
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
break;
case "complete": //完成订单
bl = DbClient.Updateable()
.SetColumns(it => it.freezeStock == it.freezeStock - num)
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
break;
default:
bl = DbClient.Updateable()
.SetColumns(it => it.freezeStock == it.freezeStock + num)
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
break;
}
res.status = bl;
res.msg = bl ? "库存更新成功" : "库存不足";
return res;
}
#endregion
#region 获取随机推荐商品数据
///
/// 获取随机推荐数据
///
///
///
///
public async Task> GetGoodsRecommendList(int number, bool isRecommend = false)
{
var list = new List();
if (isRecommend)
{
var ids = await DbClient.Queryable().Where(p => p.isDel == false && p.isMarketable == true && p.isRecommend == true)
.Select(p => p.id).ToArrayAsync();
var dbIds = new List();
if (!ids.Any()) return list;
{
if (ids.Length < number)
{
number = ids.Length;
}
for (int i = 0; i < number; i++)
{
var id = GetRandomNumber(ids);
while (dbIds.Contains(id))//判断集合中有没有生成的随机数，如果有，则重新生成一个随机数，直到生成的随机数list集合中没有才退出循环
{
id = GetRandomNumber(ids);
}
dbIds.Add(id);
}
if (dbIds.Any())
{
list = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isRecommend == true && good.isDel == false && good.isMarketable == true)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.Where(p => dbIds.Contains(p.id)).ToListAsync();
}
}
}
else
{
var ids = await DbClient.Queryable().Where(p => p.isDel == false && p.isMarketable == true)
.Select(p => p.id).ToArrayAsync();
var dbIds = new List();
if (!ids.Any()) return list;
{
if (ids.Length < number)
{
number = ids.Length;
}
for (int i = 0; i < number; i++)
{
var id = GetRandomNumber(ids);
while (dbIds.Contains(id))//判断集合中有没有生成的随机数，如果有，则重新生成一个随机数，直到生成的随机数list集合中没有才退出循环
{
id = GetRandomNumber(ids);
}
dbIds.Add(id);
}
if (dbIds.Any())
{
list = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isRecommend == true && good.isDel == false && good.isMarketable == true)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.Where(p => dbIds.Contains(p.id)).ToListAsync();
}
}
}
return list;
}
// 随机抽取数组中的数据
static int GetRandomNumber(int[] a)
{
Random rnd = new Random();
int index = rnd.Next(a.Length);
return a[index];
}
#endregion
#region 获取数据总数
///
/// 获取数据总数
///
/// 条件表达式树
/// 是否使用WITH(NOLOCK)
///
public async Task GetCountAsync(Expression> predicate, bool blUseNoLock = false)
{
var count = 0;
if (blUseNoLock)
{
count = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
stock = pd.stock,
freezeStock = pd.freezeStock,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.CountAsync(predicate);
}
else
{
count = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
stock = pd.stock,
freezeStock = pd.freezeStock,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.CountAsync(predicate);
}
return count;
}
#endregion
#region 重写根据条件查询分页数据
///
/// 重写根据条件查询分页数据
///
/// 判断集合
/// 排序方式
/// 当前页面索引
/// 分布大小
///
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryPageAsync(Expression> predicate,
Expression> orderByExpression, OrderByType orderByType, int pageIndex = 1,
int pageSize = 20, bool blUseNoLock = false)
{
RefAsync totalCount = 0;
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.OrderByIF(orderByExpression != null, orderByExpression, orderByType)
.WhereIF(predicate != null, predicate)
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.OrderByIF(orderByExpression != null, orderByExpression, orderByType)
.WhereIF(predicate != null, predicate)
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
var list = new PageList(page.DistinctBy(o => o.id), pageIndex, pageSize, totalCount);
return list;
}
#endregion
#region 根据条件查询一定数量数据
///
/// 根据条件查询一定数量数据
///
/// 条件表达式树
/// 获取数量
/// 排序字段
/// 排序顺序
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryListByClauseAsync(Expression> predicate, int take,
Expression> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false)
{
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.WhereIF(predicate != null, predicate)
.Take(take).ToListAsync();
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.WhereIF(predicate != null, predicate)
.Take(take).ToListAsync();
}
return page;
}
#endregion
#region 重写根据条件查询数据
///
/// 重写根据条件查询数据
///
/// 条件表达式树
///
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryListByClauseAsync(Expression> predicate, string orderBy = "",
bool blUseNoLock = false)
{
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.OrderByIF(!string.IsNullOrEmpty(orderBy), orderBy)
.WhereIF(predicate != null, predicate)
.ToListAsync();
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.OrderByIF(!string.IsNullOrEmpty(orderBy), orderBy)
.WhereIF(predicate != null, predicate)
.ToListAsync();
}
return page;
}
#endregion
#region 重写根据条件及自定义排序查询分页数据
///
/// 重写根据条件及自定义排序查询分页数据
///
///
///
/// 当前页面索引
/// 分布大小
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryPageAsync(Expression> predicate, string orderBy = "",
int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false)
{
RefAsync totalCount = 0;
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.Where(predicate)
.OrderBy(orderBy)
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.Where(predicate)
.OrderBy(orderBy)
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
var list = new PageList(page, pageIndex, pageSize, totalCount);
return list;
}
#endregion
#region 重写根据条件及自定义排序查询分页数据（返回DTO）
///
/// 重写根据条件及自定义排序查询分页数据（返回DTO）
///
///
/// 当前页面索引
/// 分布大小
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryPageByDTOAsync(Expression> predicate, int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false)
{
RefAsync totalCount = 0;
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
distributionCutMoney = pd.distributionCutMoney,
cutMoney = pd.cutMoney,
distributionPrice = pd.distributionPrice,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
areaCode = good.areaCode,
})
.With(SqlWith.NoLock)
.MergeTable()
.Where(predicate)
.OrderBy(it => SqlFunc.Desc(it.isRecommend)).OrderBy(it => SqlFunc.Desc(it.isHot))
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
distributionCutMoney = pd.distributionCutMoney,
cutMoney = pd.cutMoney,
distributionPrice = pd.distributionPrice,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.Where(predicate)
.OrderBy(it => SqlFunc.Desc(it.isRecommend)).OrderBy(it => SqlFunc.Desc(it.isHot))
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
var list = new PageList(page, pageIndex, pageSize, totalCount);
return list;
}
#endregion
#region 根据条件查询代理池商品分页数据
///
/// 根据条件查询代理池商品分页数据
///
///
///
/// 当前页面索引
/// 分布大小
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryAgentGoodsPageAsync(Expression> predicate,
int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false)
{
RefAsync totalCount = 0;
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd, aGood) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId, JoinType.Left, good.id == aGood.goodId))
.Where((good, pd, aGood) => pd.isDefalut == true && pd.isDel == false && aGood.isEnable == true)
.Select((good, pd, aGood) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.Where(predicate)
.OrderBy(it => SqlFunc.Desc(it.isRecommend)).OrderBy(it => SqlFunc.Desc(it.isHot))
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
else
{
page = await DbClient.Queryable((good, pd, aGood) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId, JoinType.Left, good.id == aGood.goodId))
.Where((good, pd, aGood) => pd.isDefalut == true && pd.isDel == false && aGood.isEnable == true)
.Select((good, pd, aGood) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.Where(predicate)
.OrderBy(it => SqlFunc.Desc(it.isRecommend)).OrderBy(it => SqlFunc.Desc(it.isHot))
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
var list = new PageList(page, pageIndex, pageSize, totalCount);
return list;
}
#endregion
#region 根据条件查询商品及sku分页数据
///
/// 根据条件查询商品及sku分页数据
///
/// 判断集合
/// 排序方式
/// 当前页面索引
/// 分布大小
///
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryGoodAndSkuPageAsync(Expression> predicate,
Expression> orderByExpression, OrderByType orderByType, int pageIndex = 1,
int pageSize = 20, bool blUseNoLock = false)
{
RefAsync totalCount = 0;
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable()
.Where(p => p.isDel == false)
.Select(good => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
initialSales = good.initialSales,
})
//.Mapper(p => p.sku, p => p.sku.First().goodsId)
//.Mapper(it =>
//{
// it.sku = it.sku.Where(o => o.isDel == false).ToList();
//})
.With(SqlWith.NoLock)
.OrderByIF(orderByExpression != null, orderByExpression, orderByType)
.WhereIF(predicate != null, predicate)
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
else
{
page = await DbClient.Queryable()
.Where(p => p.isDel == false)
.Select(good => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
initialSales = good.initialSales,
})
//.Mapper(p => p.sku, p => p.sku.First().goodsId)
//.Mapper(it =>
//{
// it.sku = it.sku.Where(o => o.isDel == false).ToList();
//})
.OrderByIF(orderByExpression != null, orderByExpression, orderByType)
.WhereIF(predicate != null, predicate)
.ToPageListAsync(pageIndex, pageSize, totalCount);
}
var list = new PageList(page, pageIndex, pageSize, totalCount);
return list;
}
#endregion
#region 获取下拉商品数据
///
/// 获取下拉商品数据
///
///
public async Task> QueryEnumEntityAsync()
{
List list = await DbClient.Queryable()
.Where(p => p.isDel == false)
.Select(p => new EnumEntity
{
value = p.id,
title = p.name,
description = p.image,
})
.With(SqlWith.NoLock).OrderBy(p => p.value, OrderByType.Desc).ToListAsync();
return list;
}
#endregion
#region 获取商品及默认货品信息
///
/// 获取商品及默认货品信息
///
///
///
///
/// 是否使用WITH(NOLOCK)
///
public async Task> QueryGoodWithDefaultProductAsync(Expression> predicate, Expression> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false)
{
List listData;
if (blUseNoLock)
{
listData = await DbClient.Queryable((good, pd) => new JoinQueryInfos(JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.ToListAsync();
}
else
{
listData = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false)
.Select((good, pd) => new CoreCmsGoods
{
id = good.id,
bn = good.bn,
name = good.name,
brief = good.brief,
image = good.image,
images = good.images,
video = good.video,
productsDistributionType = good.productsDistributionType,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
isMarketable = good.isMarketable,
unit = good.unit,
//intro = good.intro,
spesDesc = good.spesDesc,
parameters = good.parameters,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = good.buyCount,
uptime = good.uptime,
downtime = good.downtime,
sort = good.sort,
labelIds = good.labelIds,
newSpec = good.newSpec,
openSpec = good.openSpec,
createTime = good.createTime,
updateTime = good.updateTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
isDel = good.isDel,
sn = pd.sn,
price = pd.price,
costprice = pd.costprice,
mktprice = pd.mktprice,
stock = pd.stock,
freezeStock = pd.freezeStock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.ToListAsync();
}
return listData;
}
#endregion
#region 根据条件查询一定数量数据（用于组件）
///
/// 根据条件查询一定数量数据（用于组件）
///
/// 条件表达式树
/// 获取数量
/// 排序字段
/// 排序顺序
/// 是否使用WITH(NOLOCK)
/// 是否缓存
/// 缓存时间（分钟）
///
public async Task> QueryListByComponentsAsync(Expression> predicate, int take,
Expression> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false, bool isDataCache = false, int cacheTimes = int.MaxValue)
{
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
distributionPrice = pd.distributionPrice,
distributionCutMoney = pd.distributionCutMoney,
cutMoney = pd.cutMoney,
isHot = good.isHot,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.Take(take)
.WithCacheIF(isDataCache, cacheTimes)
.ToListAsync();
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
distributionPrice = pd.distributionPrice,
distributionCutMoney = pd.distributionCutMoney,
cutMoney = pd.cutMoney,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.WithCacheIF(isDataCache, cacheTimes)
.Take(take).ToListAsync();
}
return page;
}
#endregion
#region 根据条件查询一定数量数据（用于组件）
///
/// 根据条件查询一定数量数据（用于组件）
///
/// 条件表达式树
/// 获取数量
/// 排序顺序
/// 是否使用WITH(NOLOCK)
/// 是否缓存
/// 缓存时间（分钟）
///
public async Task> QueryListByComponentsAsync(Expression> predicate, int take, string orderByType = "", bool blUseNoLock = false, bool isDataCache = false, int cacheTimes = int.MaxValue)
{
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
distributionCutMoney = pd.distributionCutMoney,
cutMoney = pd.cutMoney,
distributionPrice=pd.distributionPrice,
isHot = good.isHot,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.With(SqlWith.NoLock)
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(!string.IsNullOrEmpty(orderByType), orderByType)
.Take(take)
.WithCacheIF(isDataCache, cacheTimes)
.ToListAsync();
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
distributionCutMoney = pd.distributionCutMoney,
cutMoney = pd.cutMoney,
distributionPrice = pd.distributionPrice,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
})
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(!string.IsNullOrEmpty(orderByType), orderByType)
.WithCacheIF(isDataCache, cacheTimes)
.Take(take).ToListAsync();
}
return page;
}
#endregion
#region 根据类型获取商品数据（用于PC，H5）
///
/// 根据类型获取商品数据（用于PC，H5）
///
/// 条件表达式树
/// 获取数量
/// 排序字段
/// 排序顺序
/// 是否使用WITH(NOLOCK)
/// 是否缓存
/// 缓存时间（分钟）
///
public async Task> QueryListByTypeAsync(Expression> predicate, int take,
Expression> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false, bool isDataCache = false, int cacheTimes = int.MaxValue)
{
List page;
if (blUseNoLock)
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
isInActivity = SqlFunc.Subqueryable().Where(o => o.parameters.Contains(good.id.ToString())).Any()
})
.With(SqlWith.NoLock)
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.Take(take)
.WithCacheIF(isDataCache, cacheTimes)
.ToListAsync();
}
else
{
page = await DbClient.Queryable((good, pd) => new JoinQueryInfos(
JoinType.Left, good.id == pd.goodsId))
.Where((good, pd) => pd.isDefalut == true && pd.isDel == false && good.isMarketable == true && good.isDel == false)
.Select((good, pd) => new GoodListDTO
{
id = good.id,
name = good.name,
brief = good.brief,
image = !SqlFunc.IsNullOrEmpty(good.image) ? good.image : EmptyOrNullImagePath.GoodImage,
video = good.video,
goodsCategoryId = good.goodsCategoryId,
goodsTypeId = good.goodsTypeId,
brandId = good.brandId,
isNomalVirtual = good.isNomalVirtual,
unit = good.unit,
commentsCount = good.commentsCount,
viewCount = good.viewCount,
buyCount = SqlFunc.Subqueryable()
.LeftJoin((sOrderItem, sOrder) => sOrder.orderId == sOrderItem.orderId)
.Where((sOrderItem, sOrder) => sOrderItem.goodsId == good.id && (sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes || sOrder.payStatus == (int)GlobalEnumVars.OrderPayStatus.PartialYes))
.Sum((sOrderItem, sOrder) => sOrderItem.nums),
sort = good.sort,
labelIds = good.labelIds,
createTime = good.createTime,
isRecommend = good.isRecommend,
isHot = good.isHot,
price = pd.price,
mktprice = pd.mktprice,
stock = pd.stock,
pointsDeduction = pd.pointsDeduction,
points = pd.points,
weight = pd.weight,
initialSales = good.initialSales,
isInActivity = SqlFunc.Subqueryable().Where(o => o.parameters.Contains(good.id.ToString())).Any()
})
.MergeTable()
.WhereIF(predicate != null, predicate)
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
.WithCacheIF(isDataCache, cacheTimes)
.Take(take).ToListAsync();
}
return page;
}
#endregion
}
}