|
|
@@ -487,7 +487,7 @@ public class ProductBaseServiceImpl extends ServiceImpl<ProductBaseMapper, Produ
|
|
|
*/
|
|
|
private LambdaEsQueryWrapper<ProductBaseVo> buildEsQueryWrapperForPc(PcProductBo bo) {
|
|
|
LambdaEsQueryWrapper<ProductBaseVo> wrapper = new LambdaEsQueryWrapper<ProductBaseVo>()
|
|
|
-// .eq(ProductBaseVo::getProductStatus, 1)
|
|
|
+ .eq(ProductBaseVo::getProductStatus, 1)
|
|
|
;
|
|
|
|
|
|
if(ObjectUtil.isNotEmpty(bo.getProductNo())){
|
|
|
@@ -1499,7 +1499,7 @@ public class ProductBaseServiceImpl extends ServiceImpl<ProductBaseMapper, Produ
|
|
|
.or()
|
|
|
.like(ProductBaseVo::getBrandName, bo.getSearchKeyword())
|
|
|
.or()
|
|
|
- .like(ProductBaseVo::getProductNo, bo.getProductNo())
|
|
|
+ .like(ProductBaseVo::getProductNo, bo.getSearchKeyword())
|
|
|
);
|
|
|
}
|
|
|
|
|
|
@@ -1507,16 +1507,16 @@ public class ProductBaseServiceImpl extends ServiceImpl<ProductBaseMapper, Produ
|
|
|
//价格区间 1:1-100 2:100-500 3:500-1000 4:1000以上
|
|
|
switch (bo.getPriceRange()) {
|
|
|
case "1":
|
|
|
- esQueryWrapper.between(ProductBaseVo::getMarketPrice, 1, 100);
|
|
|
+ esQueryWrapper.between(ProductBaseVo::getMemberPrice, 1, 100);
|
|
|
break;
|
|
|
case "2":
|
|
|
- esQueryWrapper.between(ProductBaseVo::getMarketPrice, 100, 500);
|
|
|
+ esQueryWrapper.between(ProductBaseVo::getMemberPrice, 100, 500);
|
|
|
break;
|
|
|
case "3":
|
|
|
- esQueryWrapper.between(ProductBaseVo::getMarketPrice, 500, 1000);
|
|
|
+ esQueryWrapper.between(ProductBaseVo::getMemberPrice, 500, 1000);
|
|
|
break;
|
|
|
case "4":
|
|
|
- esQueryWrapper.ge(ProductBaseVo::getMarketPrice, 1000);
|
|
|
+ esQueryWrapper.ge(ProductBaseVo::getMemberPrice, 1000);
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
@@ -1527,11 +1527,11 @@ public class ProductBaseServiceImpl extends ServiceImpl<ProductBaseMapper, Produ
|
|
|
for (int i = 0; i < sortFields.length; i++) {
|
|
|
switch (sortFields[i]) {
|
|
|
case "1":
|
|
|
- esQueryWrapper.orderBy( true, sortOrders[i].equals("Asc"),ProductBaseVo::getId);
|
|
|
+// esQueryWrapper.orderBy( true, sortOrders[i].equals("Asc"),ProductBaseVo::getId);
|
|
|
case "2":
|
|
|
esQueryWrapper.orderBy( true, sortOrders[i].equals("Asc"),ProductBaseVo::getTotalInventory);
|
|
|
case "3":
|
|
|
- esQueryWrapper.orderBy( true, sortOrders[i].equals("Asc"),ProductBaseVo::getMarketPrice);
|
|
|
+ esQueryWrapper.orderBy( true, sortOrders[i].equals("Asc"),ProductBaseVo::getMemberPrice);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -1886,7 +1886,7 @@ public class ProductBaseServiceImpl extends ServiceImpl<ProductBaseMapper, Produ
|
|
|
* @param programId
|
|
|
*/
|
|
|
@Override
|
|
|
- public List<PcProductVo> getProductProgramProductList(Long programId) {
|
|
|
+ public Map<String, List<PcProductVo>> getProductProgramProductList(Long programId) {
|
|
|
List<ProductProgramLinkVo> productProgramLinkVos = productProgramLinkMapper.selectVoList(
|
|
|
Wrappers.lambdaQuery(ProductProgramLink.class)
|
|
|
.eq(ProductProgramLink::getProgramId, programId)
|
|
|
@@ -1897,12 +1897,15 @@ public class ProductBaseServiceImpl extends ServiceImpl<ProductBaseMapper, Produ
|
|
|
lqw.in("b.id", productIds);
|
|
|
lqw.eq("b.product_status", 1);
|
|
|
List<ProductBaseVo> productBaseVos = baseMapper.selectAllList(lqw);
|
|
|
- if (CollUtil.isNotEmpty(productBaseVos)) {
|
|
|
- return BeanUtil.copyToList(productBaseVos, PcProductVo.class);
|
|
|
+
|
|
|
+ List<PcProductVo> pcProductVos = BeanUtil.copyToList(productBaseVos, PcProductVo.class);
|
|
|
+ //通过分类名称分组
|
|
|
+ Map<String, List<PcProductVo>> map = pcProductVos.stream().collect(Collectors.groupingBy(PcProductVo::getCategoryName));
|
|
|
+ if (CollUtil.isNotEmpty(map)) {
|
|
|
+ return map;
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
- return List.of();
|
|
|
+ return Map.of();
|
|
|
}
|
|
|
/**
|
|
|
* PC端协议商品列表
|