/***********************************************************************
|
* 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.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 SqlSugar;
|
|
namespace CoreCms.Net.Repository
|
{
|
/// <summary>
|
/// 商品表 接口实现
|
/// </summary>
|
public class CoreCmsGoodsRepository : BaseRepository<CoreCmsGoods>, ICoreCmsGoodsRepository
|
{
|
public CoreCmsGoodsRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
|
{
|
}
|
|
|
#region 重写异步插入方法
|
/// <summary>
|
/// 重写异步插入方法
|
/// </summary>
|
/// <param name="entity">实体数据</param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> 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<CoreCmsProducts>().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<CoreCmsGoodsGrade>();
|
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<CoreCmsProducts>();
|
var pds = new List<CoreCmsProductsDistribution>();
|
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;
|
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<CoreCmsProducts>().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;
|
|
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<CoreCmsGoodsCategoryExtend>();
|
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 重写异步更新方法方法
|
/// <summary>
|
/// 重写异步更新方法方法
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> 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<CoreCmsProducts>().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<CoreCmsGoods>().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<CoreCmsGoodsCategoryExtend>().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<CoreCmsGoodsCategoryExtend>();
|
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<CoreCmsGoodsGrade>().Where(p => p.goodsId == model.id).ExecuteCommandHasChangeAsync();
|
var goodsGrade = new List<CoreCmsGoodsGrade>();
|
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<CoreCmsProducts>().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<CoreCmsProducts>().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<CoreCmsProductsDistribution>().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;
|
|
}
|
});
|
|
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<CoreCmsProductsDistribution>();
|
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<CoreCmsProducts>().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<CoreCmsProducts>();
|
var pds = new List<CoreCmsProductsDistribution>();
|
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;
|
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<CoreCmsProducts>().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<CoreCmsProducts>().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;
|
if (string.IsNullOrEmpty(newObj.images))
|
{
|
obj.images = oldModel.image;
|
}
|
|
bl = await DbClient.Updateable<CoreCmsProducts>(obj).ExecuteCommandHasChangeAsync();
|
}
|
|
if (bl)
|
{
|
await DbClient.Updateable<CoreCmsProductsDistribution>().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;
|
if (string.IsNullOrEmpty(newObj.images))
|
{
|
obj.images = oldModel.image;
|
}
|
var insertId = await DbClient.Insertable<CoreCmsProducts>(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集合的数据(批量删除)
|
/// <summary>
|
/// 重写删除指定ID集合的数据(批量删除)
|
/// </summary>
|
/// <param name="ids"></param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> DeleteByIdsAsync(int[] ids)
|
{
|
var jm = new AdminUiCallBack();
|
|
var bl = await DbClient.Updateable<CoreCmsGoods>().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 获取商品重量
|
|
/// <summary>
|
/// 获取商品重量
|
/// </summary>
|
/// <param name="productsId"></param>
|
/// <returns></returns>
|
public async Task<decimal> GetWeight(int productsId)
|
{
|
decimal weight = 0;
|
//var productsModel =await DbClient.Queryable<CoreCmsProducts, CoreCmsGoods>((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<CoreCmsProducts>().FirstAsync(p => p.id == productsId);
|
if (productsModel != null)
|
{
|
weight = productsModel.weight > 0 ? productsModel.weight : 0;
|
}
|
return weight > 0 ? weight : 0;
|
}
|
#endregion
|
|
#region 库存改变机制
|
/// <summary>
|
/// 库存改变机制。
|
/// 库存机制：商品下单 总库存不变，冻结库存加1，
|
/// 商品发货：冻结库存减1，总库存减1，
|
/// 订单完成但未发货：总库存不变，冻结库存减1
|
/// 商品退款&取消订单：总库存不变，冻结库存减1,
|
/// 商品退货：总库存加1，冻结库存不变,
|
/// 可销售库存：总库存-冻结库存
|
/// </summary>
|
/// <returns></returns>
|
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<CoreCmsProducts>().InSingle(productsId);
|
var bl = false;
|
switch (type)
|
{
|
case "order": //下单
|
//更新订单购买量
|
DbClient.Updateable<CoreCmsGoods>().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<CoreCmsProducts>()
|
.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<CoreCmsProducts>()
|
.SetColumns(it => it.stock == it.stock - num)
|
.Where(p => p.freezeStock >= num && p.id == productModel.id).ExecuteCommandHasChange();
|
if (bl == true)
|
{
|
bl = DbClient.Updateable<CoreCmsProducts>()
|
.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<CoreCmsProducts>()
|
.SetColumns(it => it.freezeStock == it.freezeStock - num)
|
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
|
break;
|
case "return": //退货
|
bl = DbClient.Updateable<CoreCmsProducts>()
|
.SetColumns(it => it.stock == it.stock + num)
|
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
|
break;
|
case "cancel": //取消订单
|
bl = DbClient.Updateable<CoreCmsProducts>()
|
.SetColumns(it => it.freezeStock == it.freezeStock - num)
|
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
|
break;
|
case "complete": //完成订单
|
bl = DbClient.Updateable<CoreCmsProducts>()
|
.SetColumns(it => it.freezeStock == it.freezeStock - num)
|
.Where(p => p.id == productModel.id).ExecuteCommandHasChange();
|
break;
|
default:
|
bl = DbClient.Updateable<CoreCmsProducts>()
|
.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 获取随机推荐商品数据
|
|
/// <summary>
|
/// 获取随机推荐数据
|
/// </summary>
|
/// <param name="number"></param>
|
/// <param name="isRecommend"></param>
|
/// <returns></returns>
|
public async Task<List<GoodListDTO>> GetGoodsRecommendList(int number, bool isRecommend = false)
|
{
|
var list = new List<GoodListDTO>();
|
|
if (isRecommend)
|
{
|
var ids = await DbClient.Queryable<CoreCmsGoods>().Where(p => p.isDel == false && p.isMarketable == true && p.isRecommend == true)
|
.Select(p => p.id).ToArrayAsync();
|
var dbIds = new List<int>();
|
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<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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<CoreCmsGoods>().Where(p => p.isDel == false && p.isMarketable == true)
|
.Select(p => p.id).ToArrayAsync();
|
var dbIds = new List<int>();
|
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<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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 获取数据总数
|
/// <summary>
|
/// 获取数据总数
|
/// </summary>
|
/// <param name="predicate">条件表达式树</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<int> GetCountAsync(Expression<Func<CoreCmsGoods, bool>> predicate, bool blUseNoLock = false)
|
{
|
var count = 0;
|
if (blUseNoLock)
|
{
|
count = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods, CoreCmsProducts>((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 重写根据条件查询分页数据
|
/// <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<CoreCmsGoods>> QueryPageAsync(Expression<Func<CoreCmsGoods, bool>> predicate,
|
Expression<Func<CoreCmsGoods, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
|
int pageSize = 20, bool blUseNoLock = false)
|
{
|
RefAsync<int> totalCount = 0;
|
List<CoreCmsGoods> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods>(page.DistinctBy(o => o.id), pageIndex, pageSize, totalCount);
|
return list;
|
}
|
#endregion
|
|
#region 根据条件查询一定数量数据
|
/// <summary>
|
/// 根据条件查询一定数量数据
|
/// </summary>
|
/// <param name="predicate">条件表达式树</param>
|
/// <param name="take">获取数量</param>
|
/// <param name="orderByPredicate">排序字段</param>
|
/// <param name="orderByType">排序顺序</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<List<CoreCmsGoods>> QueryListByClauseAsync(Expression<Func<CoreCmsGoods, bool>> predicate, int take,
|
Expression<Func<CoreCmsGoods, object>> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false)
|
{
|
List<CoreCmsGoods> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods, CoreCmsProducts>((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 重写根据条件查询数据
|
/// <summary>
|
/// 重写根据条件查询数据
|
/// </summary>
|
/// <param name="predicate">条件表达式树</param>
|
/// <param name="orderBy"></param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<List<CoreCmsGoods>> QueryListByClauseAsync(Expression<Func<CoreCmsGoods, bool>> predicate, string orderBy = "",
|
bool blUseNoLock = false)
|
{
|
List<CoreCmsGoods> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods, CoreCmsProducts>((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 重写根据条件及自定义排序查询分页数据
|
/// <summary>
|
/// 重写根据条件及自定义排序查询分页数据
|
/// </summary>
|
/// <param name="predicate"></param>
|
/// <param name="orderBy"></param>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<IPageList<CoreCmsGoods>> QueryPageAsync(Expression<Func<CoreCmsGoods, bool>> predicate, string orderBy = "",
|
int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false)
|
{
|
RefAsync<int> totalCount = 0;
|
List<CoreCmsGoods> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods>(page, pageIndex, pageSize, totalCount);
|
return list;
|
|
|
}
|
|
|
#endregion
|
|
#region 重写根据条件及自定义排序查询分页数据（返回DTO）
|
/// <summary>
|
/// 重写根据条件及自定义排序查询分页数据（返回DTO）
|
/// </summary>
|
/// <param name="predicate"></param>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<IPageList<GoodListDTO>> QueryPageByDTOAsync(Expression<Func<GoodListDTO, bool>> predicate, int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false)
|
{
|
RefAsync<int> totalCount = 0;
|
List<GoodListDTO> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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,
|
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<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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(predicate)
|
.OrderBy(it => SqlFunc.Desc(it.isRecommend)).OrderBy(it => SqlFunc.Desc(it.isHot))
|
.ToPageListAsync(pageIndex, pageSize, totalCount);
|
}
|
var list = new PageList<GoodListDTO>(page, pageIndex, pageSize, totalCount);
|
return list;
|
|
|
}
|
|
|
#endregion
|
|
#region 根据条件查询代理池商品分页数据
|
/// <summary>
|
/// 根据条件查询代理池商品分页数据
|
/// </summary>
|
/// <param name="predicate"></param>
|
/// <param name="orderBy"></param>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<IPageList<CoreCmsGoods>> QueryAgentGoodsPageAsync(Expression<Func<CoreCmsGoods, bool>> predicate,
|
int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false)
|
{
|
RefAsync<int> totalCount = 0;
|
List<CoreCmsGoods> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts, CoreCmsAgentGoods>((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<CoreCmsGoods, CoreCmsProducts, CoreCmsAgentGoods>((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<CoreCmsGoods>(page, pageIndex, pageSize, totalCount);
|
return list;
|
|
|
}
|
|
#endregion
|
|
#region 根据条件查询商品及sku分页数据
|
/// <summary>
|
/// 根据条件查询商品及sku分页数据
|
/// </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<CoreCmsGoods>> QueryGoodAndSkuPageAsync(Expression<Func<CoreCmsGoods, bool>> predicate,
|
Expression<Func<CoreCmsGoods, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
|
int pageSize = 20, bool blUseNoLock = false)
|
{
|
RefAsync<int> totalCount = 0;
|
List<CoreCmsGoods> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods>()
|
.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<CoreCmsGoods>()
|
.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<CoreCmsGoods>(page, pageIndex, pageSize, totalCount);
|
return list;
|
}
|
#endregion
|
|
#region 获取下拉商品数据
|
/// <summary>
|
/// 获取下拉商品数据
|
/// </summary>
|
/// <returns></returns>
|
public async Task<List<EnumEntity>> QueryEnumEntityAsync()
|
{
|
List<EnumEntity> list = await DbClient.Queryable<CoreCmsGoods>()
|
.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 获取商品及默认货品信息
|
|
/// <summary>
|
/// 获取商品及默认货品信息
|
/// </summary>
|
/// <param name="predicate"></param>
|
/// <param name="orderByPredicate"></param>
|
/// <param name="orderByType"></param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<List<CoreCmsGoods>> QueryGoodWithDefaultProductAsync(Expression<Func<CoreCmsGoods, bool>> predicate, Expression<Func<CoreCmsGoods, object>> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false)
|
{
|
List<CoreCmsGoods> listData;
|
if (blUseNoLock)
|
{
|
listData = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsGoods, CoreCmsProducts>((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 根据条件查询一定数量数据（用于组件）
|
|
/// <summary>
|
/// 根据条件查询一定数量数据（用于组件）
|
/// </summary>
|
/// <param name="predicate">条件表达式树</param>
|
/// <param name="take">获取数量</param>
|
/// <param name="orderByPredicate">排序字段</param>
|
/// <param name="orderByType">排序顺序</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <param name="isDataCache">是否缓存</param>
|
/// <param name="cacheTimes">缓存时间（分钟）</param>
|
/// <returns></returns>
|
public async Task<List<GoodListDTO>> QueryListByComponentsAsync(Expression<Func<GoodListDTO, bool>> predicate, int take,
|
Expression<Func<GoodListDTO, object>> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false, bool isDataCache = false, int cacheTimes = int.MaxValue)
|
{
|
List<GoodListDTO> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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,
|
})
|
.With(SqlWith.NoLock)
|
.MergeTable()
|
.WhereIF(predicate != null, predicate)
|
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
|
.Take(take)
|
.WithCacheIF(isDataCache, cacheTimes)
|
.ToListAsync();
|
}
|
else
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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()
|
.WhereIF(predicate != null, predicate)
|
.OrderByIF(orderByPredicate != null, orderByPredicate, orderByType)
|
.WithCacheIF(isDataCache, cacheTimes)
|
.Take(take).ToListAsync();
|
}
|
return page;
|
|
}
|
#endregion
|
|
#region 根据条件查询一定数量数据（用于组件）
|
|
/// <summary>
|
/// 根据条件查询一定数量数据（用于组件）
|
/// </summary>
|
/// <param name="predicate">条件表达式树</param>
|
/// <param name="take">获取数量</param>
|
/// <param name="orderByType">排序顺序</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <param name="isDataCache">是否缓存</param>
|
/// <param name="cacheTimes">缓存时间（分钟）</param>
|
/// <returns></returns>
|
public async Task<List<GoodListDTO>> QueryListByComponentsAsync(Expression<Func<GoodListDTO, bool>> predicate, int take, string orderByType = "", bool blUseNoLock = false, bool isDataCache = false, int cacheTimes = int.MaxValue)
|
{
|
List<GoodListDTO> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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,
|
})
|
.With(SqlWith.NoLock)
|
.MergeTable()
|
.WhereIF(predicate != null, predicate)
|
.OrderByIF(!string.IsNullOrEmpty(orderByType), orderByType)
|
.Take(take)
|
.WithCacheIF(isDataCache, cacheTimes)
|
.ToListAsync();
|
}
|
else
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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()
|
.WhereIF(predicate != null, predicate)
|
.OrderByIF(!string.IsNullOrEmpty(orderByType), orderByType)
|
.WithCacheIF(isDataCache, cacheTimes)
|
.Take(take).ToListAsync();
|
}
|
return page;
|
|
}
|
#endregion
|
|
|
#region 根据类型获取商品数据（用于PC，H5）
|
|
/// <summary>
|
/// 根据类型获取商品数据（用于PC，H5）
|
/// </summary>
|
/// <param name="predicate">条件表达式树</param>
|
/// <param name="take">获取数量</param>
|
/// <param name="orderByPredicate">排序字段</param>
|
/// <param name="orderByType">排序顺序</param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <param name="isDataCache">是否缓存</param>
|
/// <param name="cacheTimes">缓存时间（分钟）</param>
|
/// <returns></returns>
|
public async Task<List<GoodListDTO>> QueryListByTypeAsync(Expression<Func<GoodListDTO, bool>> predicate, int take,
|
Expression<Func<GoodListDTO, object>> orderByPredicate, OrderByType orderByType, bool blUseNoLock = false, bool isDataCache = false, int cacheTimes = int.MaxValue)
|
{
|
List<GoodListDTO> page;
|
if (blUseNoLock)
|
{
|
page = await DbClient.Queryable<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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<CoreCmsPromotion>().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<CoreCmsGoods, CoreCmsProducts>((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<CoreCmsOrderItem>()
|
.LeftJoin<CoreCmsOrder>((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<CoreCmsPromotion>().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
|
|
}
|
}
|
