## 首页商品新接口；

bd-api/bd-api-member/src/main/java/com/hzs/member/base/dto/ShowWaresDTO.java

@@ -1,10 +1,4 @@
-package com.hzs.member.base.dto;/**
+package com.hzs.member.base.dto;
- * @Description:
- * @Author: yuhui
- * @Time: 2023/6/29 15:16
- * @Classname: ShowWaresDTO
- * @PackageName: com.hzs.member.base.dto
- */
 
 import com.hzs.common.domain.sale.wares.BdWaresAuthority;
 import lombok.Data;
@@ -12,14 +6,6 @@ import lombok.Data;
 import java.io.Serializable;
 import java.util.List;
 
-/**
- *@BelongsProject: hzs_cloud
- *@BelongsPackage: com.hzs.member.base.dto
- *@Author: yh
- *@CreateTime: 2023-06-29  15:16
- *@Description: TODO
- *@Version: 1.0
- */
 @Data
 public class ShowWaresDTO implements Serializable {
 

bd-api/bd-api-system/src/main/java/com/hzs/system/base/ICountryServiceApi.java

@@ -7,11 +7,7 @@ import com.hzs.system.base.dto.CountryDTO;
 import java.util.Map;
 
 /**
- * Description: 国家服务接口
+ * 国家服务接口
- * Author: jiang chao
- * Time: 2022/8/31 16:53
- * Classname: ICountryServiceApi
- * PackageName: com.hzs.system.base
  */
 public interface ICountryServiceApi {
 
@@ -25,17 +21,16 @@ public interface ICountryServiceApi {
 
     /**
      * 查询所有国家
+     *
      * @return
      */
     R<Map<Integer, BdCountry>> getAllCountryMap();
 
     /**
      * 根据业务类型更新
+     *
      * @param businessType 业务类型
-     * @param pkId 主键
+     * @param pkId         主键
-    * @return: R<Boolean>
+     */
-    * @Author: sui q
-    * @Date: 2023/3/10 15:14
-    */
     R<Boolean> updateConfigEffectById(Integer businessType, Integer pkId);
 }

bd-api/bd-api-system/src/main/java/com/hzs/system/config/IRangeServiceApi.java

@@ -1,7 +1,6 @@
 package com.hzs.system.config;
 
 import com.hzs.common.core.domain.R;
-import com.hzs.common.domain.system.config.ext.BdBonusItemsExt;
 import com.hzs.common.domain.system.config.ext.BdRangeExt;
 import com.hzs.system.config.dto.RangeDTO;
 
@@ -9,39 +8,26 @@ import java.util.List;
 import java.util.Map;
 
 /**
- * @description: 根据国家查询极差配置列表api
+ * 根据国家查询极差配置列表api
- * @author: zhang jing
- * @date: 2022/9/29 15:31
- * @param:
- * @return:
  **/
 public interface IRangeServiceApi {
 
-     /**
+    /**
-      * @description: 根据国家查询极差配置列表
+     * 根据国家查询极差配置列表
-      * @author: zhang jing
+     **/
-      * @date: 2022/9/29 15:31
+    R<List<BdRangeExt>> queryRange(Integer pkCountry);
-      * @param: [pkCountry]
-      * @return: com.hzs.common.core.domain.R<java.util.List<com.hzs.common.domain.system.config.BdAwards>>
-      **/
-     R<List<BdRangeExt>> queryRange(Integer pkCountry);
 
-     /**
+    /**
-      * 查询各个国家极差的配置  键为 国家+极差类型+等级主键
+     * 查询各个国家极差的配置  键为 国家+极差类型+等级主键
-      * @return: Map<String,RangeDTO>
+     */
-      * @Author: sui q
+    R<Map<String, RangeDTO>> queryRangeDto();
-      * @Date: 2023/1/3 14:00
-      */
-     R<Map<String, RangeDTO>> queryRangeDto();
 
-     /**
+    /**
-      * 查询各个国家极差的配置  键为 国家+极差类型+等级主键
+     * 查询各个国家极差的配置  键为 国家+极差类型+等级主键
-      * @param pkCountry 国家
+     *
-      * @param rangeType 极差类型
+     * @param pkCountry 国家
-      * @param pkLevel 等级
+     * @param rangeType 极差类型
-      * @return: Map<String,RangeDTO>
+     * @param pkLevel   等级
-      * @Author: sui q
+     */
-      * @Date: 2023/1/3 14:00
+    R<RangeDTO> queryRangeDtoByCondition(Integer pkCountry, Integer rangeType, Integer pkLevel);
-      */
-     R<RangeDTO> queryRangeDtoByCondition(Integer pkCountry, Integer rangeType, Integer pkLevel);
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/index/controller/api/ApiIndexController.java

@@ -1,39 +1,177 @@
 package com.hzs.sale.index.controller.api;
 
-import com.hzs.common.core.web.domain.AjaxResult;
+import cn.hutool.core.collection.CollectionUtil;
+import com.hzs.common.core.enums.EOrderType;
+import com.hzs.common.core.enums.ERangeType;
+import com.hzs.common.core.enums.ESpecialArea;
+import com.hzs.common.core.web.controller.BaseController;
+import com.hzs.common.core.web.page.TableDataInfo;
+import com.hzs.common.domain.member.ext.CuMemberExt;
+import com.hzs.common.domain.sale.ext.BdWaresExt;
+import com.hzs.common.domain.sale.ext.BdWaresSpecsSkuExt;
+import com.hzs.common.domain.sale.wares.BdWares;
+import com.hzs.common.domain.sale.wares.BdWaresAuthority;
+import com.hzs.common.domain.sale.wares.BdWaresRange;
+import com.hzs.common.domain.sale.wares.ext.WaresGradeAwards;
 import com.hzs.common.security.utils.SecurityUtils;
-import com.hzs.sale.order.service.ISaOrderService;
+import com.hzs.member.base.IMemberServiceApi;
+import com.hzs.member.base.dto.ShowWaresDTO;
+import com.hzs.sale.wares.service.IBdWaresGradeService;
+import com.hzs.sale.wares.service.IBdWaresRangeService;
+import com.hzs.sale.wares.service.IBdWaresService;
+import com.hzs.sale.wares.service.IBdWaresSpecsSkuService;
+import com.hzs.sale.wares.vo.WaresVo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.dubbo.config.annotation.DubboReference;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.stream.Collectors;
+
 /**
  * 会员首页
- *
- * @Description:
- * @Author: ljc
- * @Time: 2023/5/4 21:06
- * @Classname: ApiHomePageController
- * @Package_name: com.hzs.member.base.controller.api
  */
 @Slf4j
 @RequestMapping("/api/order")
 @RestController
-public class ApiIndexController {
+public class ApiIndexController extends BaseController {
 
     @Autowired
-    ISaOrderService saOrderService;
+    private IBdWaresService iBdWaresService;
+    @Autowired
+    private IBdWaresRangeService iBdWaresRangeService;
+    @Autowired
+    private IBdWaresGradeService iBdWaresGradeService;
+    @Autowired
+    private IBdWaresSpecsSkuService iBdWaresSpecsSkuService;
+
+    @DubboReference
+    IMemberServiceApi iMemberServiceApi;
 
     /**
-     * 我的市场
+     * 首页商品列表
      *
-     * @return AjaxResult
+     * @return
      */
-    @GetMapping("/index-myMarket")
+    @GetMapping("/index-wares-list")
-    public AjaxResult selectMyMarket() {
+    public TableDataInfo indexWaresList() {
-        return AjaxResult.success(saOrderService.selectMyMarket(SecurityUtils.getUserId(), SecurityUtils.getPkCountry()));
+        Long pkMember = SecurityUtils.getUserId();
+
+        // 返回数据列表
+        List<WaresVo> waresVOList = new ArrayList<>();
+
+        // 商品列表
+        List<BdWaresExt> waresList = iBdWaresService.listWares(Arrays.asList(ESpecialArea.REPURCHASE_AREA.getValue(), ESpecialArea.SPECIAL_REPURCHASE_AREA.getValue(), ESpecialArea.RESCISSION_AREA.getValue()));
+        if (CollectionUtil.isNotEmpty(waresList)) {
+            // 获取商品ID列表
+            List<Integer> waresIdList = waresList.stream().map(BdWares::getPkId).collect(Collectors.toList());
+            // 登录用户
+            CuMemberExt loginMember = iMemberServiceApi.getMemberById(pkMember).getData();
+
+            // 商品等级、奖衔、权限控制处理
+            Set<Integer> authWaresIdSet = new HashSet<>();
+            List<String> authWaresList = new ArrayList<>();
+            if (waresIdList.size() > 0) {
+                List<WaresGradeAwards> waresGradeAwardsList = iBdWaresGradeService.queryWaresGradeAwards(waresIdList);
+                waresGradeAwardsList.forEach(waresGradeAwards -> {
+                    authWaresIdSet.add(waresGradeAwards.getPkWares());
+                    String key = waresGradeAwards.getPkWares() + "_" + waresGradeAwards.getRangeType() + "_" + waresGradeAwards.getPkRange().toString();
+                    authWaresList.add(key);
+                });
+            }
+
+            // 商品是否显示（用于团队显示控制使用）
+            Map<Integer, Boolean> waresShowMap = new HashMap<>();
+            Map<Integer, List<BdWaresAuthority>> waresAuthorityMap = iBdWaresService.getWaresAuthority(waresIdList);
+            if (waresAuthorityMap.size() > 0) {
+                List<ShowWaresDTO> showWaresList = waresList.stream().map(item -> {
+                    ShowWaresDTO showWaresDTO = new ShowWaresDTO();
+                    showWaresDTO.setPkWares(item.getPkId());
+                    showWaresDTO.setLoginMember(pkMember);
+                    showWaresDTO.setWaresAuthorityList(waresAuthorityMap.get(item.getPkId()));
+                    return showWaresDTO;
+                }).collect(Collectors.toList());
+                // 商品显示权限map（key:商品ID，value:是否可见）
+                waresShowMap = iMemberServiceApi.checkIsShowWares(showWaresList).getData();
+            }
+
+            // 查询商品sku 最小值 和数量
+            Map<Integer, List<BdWaresSpecsSkuExt>> waresSpecsSkuMap = new HashMap<>();
+            if (waresIdList.size() > 0) {
+                List<BdWaresSpecsSkuExt> waresSpecsSkuArray = iBdWaresSpecsSkuService.selectByMinWaresSpecsSkuByPkWaresList(waresIdList);
+                waresSpecsSkuMap = waresSpecsSkuArray.stream().collect(Collectors.groupingBy(BdWaresSpecsSkuExt::getPkWares));
+            }
+            // 复购类商品级差价格
+            List<BdWaresRange> bdWaresRangeList = iBdWaresRangeService.queryWaresRangeByCondition(loginMember, waresIdList);
+
+            for (BdWaresExt bdWares : waresList) {
+                if (authWaresIdSet.contains(bdWares.getPkId())) {
+                    String gradeKey = bdWares.getPkId() + "_" + ERangeType.GRADE.getValue() + "_" + loginMember.getPkSettleGrade();
+                    String awardsKey = bdWares.getPkId() + "_" + ERangeType.AWARDS.getValue() + "_" + loginMember.getPkAwards();
+                    String authorityKey = bdWares.getPkId() + "_" + ERangeType.AUTHORITY.getValue() + "_" + loginMember.getRegisterAuthority();
+                    if (!authWaresList.contains(gradeKey) && !authWaresList.contains(awardsKey) && !authWaresList.contains(authorityKey)) {
+                        continue;
+                    }
+                }
+
+                Boolean isShow = waresShowMap.get(bdWares.getPkId());
+                if (null == isShow || isShow) {
+                    List<BdWaresSpecsSkuExt> waresSpecsSku = waresSpecsSkuMap.get(bdWares.getPkId());
+                    waresSpecsSku = waresSpecsSku.stream().peek(a -> a.setProductGift(a.getPkProduct() + "" + a.getIsGift())).collect(Collectors.toList());
+                    Map<String, List<BdWaresSpecsSkuExt>> col = waresSpecsSku.stream().collect(Collectors.groupingBy(BdWaresSpecsSkuExt::getProductGift));
+                    BigDecimal waresPrice = BigDecimal.ZERO;
+                    BigDecimal waresAchieve = BigDecimal.ZERO;
+                    BigDecimal assAchieve = BigDecimal.ZERO;
+                    // 会员价
+                    BigDecimal vipAchieve = BigDecimal.ZERO;
+                    // 零售价
+                    BigDecimal retailPrice = BigDecimal.ZERO;
+                    for (Map.Entry<String, List<BdWaresSpecsSkuExt>> integerListEntry : col.entrySet()) {
+                        // 取得每一个商品价格最小值
+                        Optional<BdWaresSpecsSkuExt> minBdWaresSpecsSkuExt = integerListEntry.getValue().stream().filter(Objects::nonNull).min(Comparator.comparing(BdWaresSpecsSkuExt::getPrice));
+                        BdWaresSpecsSkuExt bdWaresSpecsSkuExt = minBdWaresSpecsSkuExt.get();
+                        waresPrice = waresPrice.add(bdWaresSpecsSkuExt.getPrice().multiply(new BigDecimal(bdWaresSpecsSkuExt.getQuantity())));
+                        waresAchieve = waresAchieve.add(bdWaresSpecsSkuExt.getAchieve().multiply(new BigDecimal(bdWaresSpecsSkuExt.getQuantity())));
+                        assAchieve = assAchieve.add(bdWaresSpecsSkuExt.getAssAchieve().multiply(new BigDecimal(bdWaresSpecsSkuExt.getQuantity())));
+                        // 会员价
+                        vipAchieve = vipAchieve.add(bdWaresSpecsSkuExt.getVipPrice().multiply(BigDecimal.valueOf(bdWaresSpecsSkuExt.getQuantity())));
+                        // 零售价
+                        retailPrice = retailPrice.add(bdWaresSpecsSkuExt.getRetailPrice().multiply(BigDecimal.valueOf(bdWaresSpecsSkuExt.getQuantity())));
+                    }
+
+                    // 商品信息填充
+                    WaresVo waresVo = new WaresVo();
+                    waresVo.setCover(bdWares.getCover());
+                    waresVo.setWaresName(bdWares.getWaresName());
+                    BigDecimal price = waresPrice;
+                    if (EOrderType.REPURCHASE_ORDER.getValue() == bdWares.getSpecialArea()) {
+                        for (BdWaresRange bdWaresRange : bdWaresRangeList) {
+                            if (bdWares.getPkId().intValue() == bdWaresRange.getPkWares().intValue()) {
+                                price = price.add(bdWaresRange.getPrice());
+                            }
+                        }
+                    }
+                    waresVo.setWaresPrice(price);
+                    waresVo.setVipPrice(vipAchieve);
+                    waresVo.setRetailPrice(retailPrice);
+                    waresVo.setWaresAchieve(waresAchieve);
+                    waresVo.setPkWares(bdWares.getPkId());
+                    waresVo.setWaresCode(bdWares.getWaresCode());
+                    waresVo.setSpecialArea(bdWares.getSpecialArea());
+                    waresVo.setIsSale(bdWares.getIsSale());
+                    waresVo.setPreSaleStatus(bdWares.getPreSaleStatus());
+                    waresVo.setSales(bdWares.getSales());
+                    waresVOList.add(waresVo);
+                }
+            }
+        }
+        TableDataInfo tableDataInfo = getDataTable(waresList);
+        tableDataInfo.setRows(waresVOList);
+        return tableDataInfo;
     }
 
 

bd-business/bd-business-sale/src/main/java/com/hzs/sale/index/controller/manage/IndexController.java

@@ -16,13 +16,6 @@ import org.springframework.web.bind.annotation.RestController;
 
 import java.math.BigDecimal;
 
-/**
- * @Description:
- * @Author: yuhui
- * @Time: 2022/12/1 17:52
- * @Classname: IndexController
- * @PackageName: com.hzs.sale.index
- */
 @RestController
 @RequestMapping("/manager/index")
 public class IndexController extends BaseController {
@@ -36,7 +29,7 @@ public class IndexController extends BaseController {
      * 查询套组商品占比
      */
     @GetMapping("get-wares-scale")
-    public AjaxResult getWaresScale(){
+    public AjaxResult getWaresScale() {
         // 查询单品
         QueryWrapper<BdWares> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("IS_SINGLE", EYesNo.YES.getIntValue());
@@ -58,21 +51,21 @@ public class IndexController extends BaseController {
 
         JSONObject json = new JSONObject();
         //  总收益
-        json.put("priceSum",priceSum);
+        json.put("priceSum", priceSum);
         // 套组百分比占比
-        json.put("composeRatio",composeRatio);
+        json.put("composeRatio", composeRatio);
         // 单品百分比占比
-        json.put("singleRatio",singleRatio);
+        json.put("singleRatio", singleRatio);
         return AjaxResult.success(json);
     }
 
-
     /**
      * 产品销售比例
      */
     @GetMapping("get-product-scale")
-    public AjaxResult saleProductScale(){
+    public AjaxResult saleProductScale() {
-     //   productService.
+        //   productService.
         return AjaxResult.success();
     }
+
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/index/vo/CuMemberMyMarketDetailVO.java

@@ -1,51 +0,0 @@
-package com.hzs.sale.index.vo;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.io.Serializable;
-
-/**
- * 我的市场一下详情VO
- *
- * @Description:
- * @Author: ljc
- * @Time: 2023/5/9 14:34
- * @Classname: CuMemberMyMarketVO
- * @Package_name: com.hzs.member.base.vo
- */
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-public class CuMemberMyMarketDetailVO implements Serializable {
-    private static final long serialVersionUID = -2715842187394176784L;
-
-    /**
-     * 国家
-     */
-    private Integer pkCountry;
-
-    /**
-     * 省
-     */
-    private Integer province;
-    /**
-     * 市
-     */
-    private Integer city;
-
-    /**
-     * 县
-     */
-    private Integer county;
-
-    /**
-     * 点亮名称
-     */
-    private String lightName;
-
-
-}

bd-business/bd-business-sale/src/main/java/com/hzs/sale/index/vo/CuMemberMyMarketVO.java

@@ -1,54 +0,0 @@
-package com.hzs.sale.index.vo;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.io.Serializable;
-import java.util.List;
-
-/**
- * 我的市场VO
- *
- * @Description:
- * @Author: ljc
- * @Time: 2023/5/9 14:34
- * @Classname: CuMemberMyMarketVO
- * @Package_name: com.hzs.member.base.vo
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class CuMemberMyMarketVO implements Serializable {
-    private static final long serialVersionUID = -2715842187394176784L;
-
-    /**
-     * 国家数
-     */
-    private Integer countryNum;
-    /**
-     * 地区数
-     */
-    private Integer regionNum;
-
-    /**
-     * 我的国家数
-     */
-    private Integer myCountryNum;
-    /**
-     * 我的地区数
-     */
-    private Integer myRegionNum;
-
-    /**
-     * 国家点亮名称
-     */
-    private String countryLightName;
-
-    /**
-     * 市场详情
-     */
-    private List<CuMemberMyMarketDetailVO> myMarketDetailVOList;
-
-
-}

bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/controller/api/ApiOthSaOrderController.java

@@ -7,26 +7,19 @@ import com.hzs.common.core.constant.HttpStatus;
 import com.hzs.common.core.constant.msg.MemberMsgConstants;
 import com.hzs.common.core.constant.msg.SaOrderMsgConstants;
 import com.hzs.common.core.enums.EOrderType;
-import com.hzs.common.core.enums.ESpecialArea;
 import com.hzs.common.core.utils.StringUtils;
 import com.hzs.common.core.web.domain.AjaxResult;
 import com.hzs.common.domain.member.ext.CuMemberAccountExt;
 import com.hzs.common.domain.sale.ext.SaOrderExt;
 import com.hzs.common.domain.sale.order.SaOrder;
-import com.hzs.common.domain.sale.wares.BdWares;
 import com.hzs.common.security.utils.SecurityUtils;
 import com.hzs.sale.order.controller.ParentOrderController;
 import com.hzs.sale.order.param.OrderParam;
 import com.hzs.sale.order.param.OrderReturn;
 import com.hzs.sale.shopping.vo.ShoppingCartVO;
-import com.hzs.sale.wares.service.IBdWaresService;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.List;
-import java.util.stream.Collectors;
-
 /**
  * 其他订单（升级、复购）订单
  */
@@ -35,9 +28,6 @@ import java.util.stream.Collectors;
 @Slf4j
 public class ApiOthSaOrderController extends ParentOrderController {
 
-    @Autowired
-    private IBdWaresService iBdWaresService;
-
     /**
      * 提供确认订单的方法
      *
@@ -190,18 +180,4 @@ public class ApiOthSaOrderController extends ParentOrderController {
         return AjaxResult.error(cuMemberAccountExt.getErrorMsg());
     }
 
-    /**
-     * 查询复购商品列表
-     *
-     * @return
-     */
-    @GetMapping("/list-maker-ware")
-    public AjaxResult listMakerWare() {
-        List<BdWares> bdWaresList = iBdWaresService.queryMakerIncomeList(ESpecialArea.REPURCHASE_AREA.getValue(), SecurityUtils.getPkCountry());
-        if (CollectionUtil.isNotEmpty(bdWaresList)) {
-            return AjaxResult.success(bdWaresList.stream().map(BdWares::getWaresCode).collect(Collectors.toList()));
-        }
-        return AjaxResult.success();
-    }
-
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/mapper/SaOrderMapper.java

@@ -7,8 +7,6 @@ import com.hzs.common.domain.sale.ext.SaOrderItemsExt;
 import com.hzs.common.domain.sale.order.SaOrder;
 import com.hzs.sale.deliver.param.DeliverSecondParam;
 import com.hzs.sale.deliver.vo.DeliverSecondVO;
-import com.hzs.sale.index.vo.CuMemberMyMarketDetailVO;
-import com.hzs.sale.index.vo.CuMemberMyMarketVO;
 import com.hzs.sale.order.param.*;
 import com.hzs.sale.order.vo.*;
 import org.apache.ibatis.annotations.Param;
@@ -268,25 +266,6 @@ public interface SaOrderMapper extends BaseMapper<SaOrder> {
      */
     List<DeliverSecondVO> secondList(@Param("param") DeliverSecondParam param, @Param("pkCountry") Integer pkCountry);
 
-
-    /**
-     * 会员首页我的市场
-     *
-     * @param pkMember  用户ID
-     * @param pkCountry 国家ID
-     * @return
-     */
-    CuMemberMyMarketVO selectMyMarket(@Param("pkMember") Long pkMember, @Param("pkCountry") Integer pkCountry);
-
-    /**
-     * 会员首页我的市场
-     *
-     * @param pkMember  用户ID
-     * @param pkCountry 国家ID
-     * @return
-     */
-    List<CuMemberMyMarketDetailVO> selectMyMarketDetail(@Param("pkMember") Long pkMember, @Param("pkCountry") Integer pkCountry);
-
     /**
      * 查询当天已支付订单信息
      **/

bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/ISaOrderService.java

@@ -11,7 +11,6 @@ import com.hzs.common.domain.sale.order.SaOrder;
 import com.hzs.common.domain.sale.order.SaOrderItems;
 import com.hzs.sale.deliver.param.DeliverSecondParam;
 import com.hzs.sale.deliver.vo.DeliverSecondVO;
-import com.hzs.sale.index.vo.CuMemberMyMarketVO;
 import com.hzs.sale.order.param.*;
 import com.hzs.sale.order.vo.*;
 import com.hzs.system.config.dto.GradeDTO;
@@ -593,16 +592,6 @@ public interface ISaOrderService extends IService<SaOrder> {
      */
     List<DeliverSecondVO> secondList(DeliverSecondParam param, Integer pkCountry);
 
-
-    /**
-     * 会员首页我的市场
-     *
-     * @param pkMember  用户ID
-     * @param pkCountry 国家ID
-     * @return
-     */
-    CuMemberMyMarketVO selectMyMarket(Long pkMember, Integer pkCountry);
-
     /**
      * 查询当天已支付订单信息
      **/

bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/impl/SaOrderServiceImpl.java

@@ -54,8 +54,6 @@ import com.hzs.member.detail.ICuMemberServiceLogServiceApi;
 import com.hzs.sale.deliver.param.DeliverSecondParam;
 import com.hzs.sale.deliver.service.ISaDeliverItemsService;
 import com.hzs.sale.deliver.vo.DeliverSecondVO;
-import com.hzs.sale.index.vo.CuMemberMyMarketDetailVO;
-import com.hzs.sale.index.vo.CuMemberMyMarketVO;
 import com.hzs.sale.order.dto.OrderQueryChargeDTO;
 import com.hzs.sale.order.mapper.SaOrderMapper;
 import com.hzs.sale.order.param.*;
@@ -2352,30 +2350,6 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
         return baseMapper.secondList(param, pkCountry);
     }
 
-    @Override
-    public CuMemberMyMarketVO selectMyMarket(Long pkMember, Integer pkCountry) {
-        //查询全国市场
-        CuMemberMyMarketVO cuMemberMyMarketVO = baseMapper.selectMyMarket(null, pkCountry);
-        CountryDTO country = countryServiceApi.getCountry(pkCountry).getData();
-        //查询市场分布
-        List<CuMemberMyMarketDetailVO> cuMemberMyMarketDetailVOList = baseMapper.selectMyMarketDetail(pkMember, pkCountry);
-        cuMemberMyMarketVO.setMyMarketDetailVOList(cuMemberMyMarketDetailVOList);
-        //查询我的市场
-        if (CollectionUtil.isNotEmpty(cuMemberMyMarketDetailVOList)) {
-            List<Integer> countryNmus = cuMemberMyMarketDetailVOList.stream().map(CuMemberMyMarketDetailVO::getPkCountry).distinct().collect(Collectors.toList());
-            cuMemberMyMarketVO.setMyCountryNum(countryNmus.size());
-            cuMemberMyMarketVO.setMyRegionNum(cuMemberMyMarketDetailVOList.size());
-        } else {
-            cuMemberMyMarketVO.setMyCountryNum(1);
-            cuMemberMyMarketVO.setMyRegionNum(0);
-        }
-        //海外暂时点亮国家
-        if (!pkCountry.equals(CountryConstants.CHINA_COUNTRY)) {
-            cuMemberMyMarketVO.setMyMarketDetailVOList(Collections.singletonList(CuMemberMyMarketDetailVO.builder().lightName(country.getLightName()).build()));
-        }
-        return cuMemberMyMarketVO;
-    }
-
     @Override
     public SaOrder queryOrderTotalAchieveByTime(Date startDate, Date endDate) {
         List<Integer> orderTypeList = new ArrayList<>();

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/mapper/BdWaresGradeMapper.java

@@ -9,9 +9,6 @@ import java.util.List;
 
 /**
  * 等级配置 Mapper 接口
- *
- * @author hzs
- * @since 2023-03-13
  */
 public interface BdWaresGradeMapper extends BaseMapper<BdWaresGrade> {
 

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/mapper/BdWaresMapper.java

@@ -149,12 +149,11 @@ public interface BdWaresMapper extends BaseMapper<BdWares> {
     WaresAuthorityVo getWaresAuthorityFirst(@Param("pkWares") Integer pkWares);
 
     /**
-     * 查询上架的发起人收益商品列表
+     * 新商品列表
      *
-     * @param specialArea 所属专区（可为空）
+     * @param specialAreaList
-     * @param pkCountry   所属国家
      * @return
      */
-    List<BdWares> queryMakerIncomeList(@Param("specialArea") Integer specialArea, @Param("pkCountry") Integer pkCountry);
+    List<BdWaresExt> listWaresNew(@Param("specialAreaList") List<Integer> specialAreaList);
 
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/mapper/BdWaresRangeMapper.java

@@ -8,9 +8,6 @@ import java.util.List;
 
 /**
  * 极差明细表 Mapper 接口
- *
- * @author hzs
- * @since 2022-09-09
  */
 public interface BdWaresRangeMapper extends BaseMapper<BdWaresRange> {
 
@@ -19,9 +16,6 @@ public interface BdWaresRangeMapper extends BaseMapper<BdWaresRange> {
      *
      * @param pkRange     极差类型
      * @param pkWaresList 商品
-     * @return: List<BdWaresRange>
-     * @Author: sui q
-     * @Date: 2022/9/27 10:02
      */
     List<BdWaresRange> queryWaresRangeByCondition(@Param("pkRange") Integer pkRange, @Param("pkWaresList") List<Integer> pkWaresList);
 

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/IBdWaresGradeService.java

@@ -8,18 +8,12 @@ import java.util.List;
 
 /**
  * 等级配置 服务类
- *
- * @author hzs
- * @since 2023-03-13
  */
 public interface IBdWaresGradeService extends IService<BdWaresGrade> {
 
-    /*
+    /**
-     * @description: 查询会员权限
+     * 查询会员权限
-     * @author: sui q
+     */
-     * @date: 2023/9/5 19:49
-     * @param: null null
-     **/
     List<WaresGradeAwards> queryWaresGradeAwards(List<Integer> waresIdList);
 
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/IBdWaresRangeService.java

@@ -8,9 +8,6 @@ import java.util.List;
 
 /**
  * 极差明细表 服务类
- *
- * @author hzs
- * @since 2022-09-09
  */
 public interface IBdWaresRangeService extends IService<BdWaresRange> {
 
@@ -19,9 +16,6 @@ public interface IBdWaresRangeService extends IService<BdWaresRange> {
      *
      * @param cuMember   会员
      * @param pkWareList 商品主键
-     * @return: List<BdWaresRange>
-     * @Author: sui q
-     * @Date: 2022/9/26 16:48
      */
     List<BdWaresRange> queryWaresRangeByCondition(CuMember cuMember, List<Integer> pkWareList);
 
@@ -32,9 +26,6 @@ public interface IBdWaresRangeService extends IService<BdWaresRange> {
      * @param rangeType    类型
      * @param level        基本
      * @param specsSkuList 最小库存单位
-     * @return: List<BdWaresRange>
-     * @Author: sui q
-     * @Date: 2022/9/26 15:33
      */
     List<BdWaresRange> querySkuWaresRangeByCondition(Integer pkCountry, Integer rangeType, Integer level, List<Integer> specsSkuList);
 

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/IBdWaresService.java

@@ -211,12 +211,11 @@ public interface IBdWaresService extends IService<BdWares> {
     void bottomUp(Integer waresId, LoginUser loginUser);
 
     /**
-     * 查询上架的发起人收益商品列表
+     * 新商品列表
      *
-     * @param specialArea 所属专区（可为空）
+     * @param specialAreaList
-     * @param pkCountry   所属国家
      * @return
      */
-    List<BdWares> queryMakerIncomeList(Integer specialArea, Integer pkCountry);
+    List<BdWaresExt> listWares(List<Integer> specialAreaList);
 
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/impl/BdWaresGradeServiceImpl.java

@@ -12,9 +12,6 @@ import java.util.List;
 
 /**
  * 等级配置 服务实现类
- *
- * @author hzs
- * @since 2023-03-13
  */
 @Service
 public class BdWaresGradeServiceImpl extends ServiceImpl<BdWaresGradeMapper, BdWaresGrade> implements IBdWaresGradeService {

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/impl/BdWaresRangeServiceImpl.java

@@ -20,28 +20,25 @@ import java.util.List;
 
 /**
  * 极差明细表 服务实现类
- *
- * @author hzs
- * @since 2022-09-09
  */
 @Service
 public class BdWaresRangeServiceImpl extends ServiceImpl<BdWaresRangeMapper, BdWaresRange> implements IBdWaresRangeService {
 
     @DubboReference
-    IRangeServiceApi rangeServiceApi;
+    IRangeServiceApi iRangeServiceApi;
     @DubboReference
-    IAwardsServiceApi awardsServiceApi;
+    IAwardsServiceApi iAwardsServiceApi;
 
     @Override
     public List<BdWaresRange> queryWaresRangeByCondition(CuMember cuMember, List<Integer> pkWareList) {
         int level = cuMember.getPkSettleGrade();
         int rangeType = ERangeType.GRADE.getValue();
-//        BdAwards bdAwards = awardsServiceApi.getAwardsOne(cuMember.getPkAwards()).getData();
+//        BdAwards bdAwards = iAwardsServiceApi.getAwardsOne(cuMember.getPkAwards()).getData();
 //        if (bdAwards.getAwardsValue() > EAwards.MEMBER.getValue()) {
 //            level = cuMember.getPkAwards();
 //            rangeType = ERangeType.AWARDS.getValue();
 //        }
-        RangeDTO rangeDTO = rangeServiceApi.queryRangeDtoByCondition(cuMember.getPkSettleCountry(), rangeType, level).getData();
+        RangeDTO rangeDTO = iRangeServiceApi.queryRangeDtoByCondition(cuMember.getPkSettleCountry(), rangeType, level).getData();
         if (rangeDTO == null) {
             return new ArrayList<>();
         }
@@ -50,21 +47,16 @@ public class BdWaresRangeServiceImpl extends ServiceImpl<BdWaresRangeMapper, BdW
 
     @Override
     public List<BdWaresRange> querySkuWaresRangeByCondition(Integer pkCountry, Integer rangeType, Integer level, List<Integer> specsSkuList) {
-        RangeDTO rangeDTO = rangeServiceApi.queryRangeDtoByCondition(pkCountry, rangeType, level).getData();
+        RangeDTO rangeDTO = iRangeServiceApi.queryRangeDtoByCondition(pkCountry, rangeType, level).getData();
         QueryWrapper<BdWaresRange> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq(SystemFieldConstants.PK_RANGE, rangeDTO.getPkRange());
         queryWrapper.in(SystemFieldConstants.PK_WARES_SPECS_SKU, specsSkuList);
         return baseMapper.selectList(queryWrapper);
     }
 
-    /**
-     * 以range 为主表查询商品极差信息
-     *
-     * @param pkWares
-     * @return
-     */
     @Override
     public List<BdWaresRange> queryWaresList(Long pkWares, Integer pkCountry) {
         return baseMapper.queryWaresList(pkWares, pkCountry);
     }
+
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/impl/BdWaresServiceImpl.java

@@ -1189,7 +1189,6 @@ public class BdWaresServiceImpl extends ServiceImpl<BdWaresMapper, BdWares> impl
             if (waresIdSet.contains(waresExt.getPkId())) {
                 String gradeKey = waresExt.getPkId() + "_" + ERangeType.GRADE.getValue() + "_" + loginMember.getPkSettleGrade();
                 String awardsKey = waresExt.getPkId() + "_" + ERangeType.AWARDS.getValue() + "_" + loginMember.getPkAwards();
-                //  添加商品注册权限配置
                 String authorityKey = waresExt.getPkId() + "_" + ERangeType.AUTHORITY.getValue() + "_" + loginMember.getRegisterAuthority();
                 if (!authWaresList.contains(gradeKey) && !authWaresList.contains(awardsKey) && !authWaresList.contains(authorityKey)) {
                     continue;
@@ -1588,6 +1587,8 @@ public class BdWaresServiceImpl extends ServiceImpl<BdWaresMapper, BdWares> impl
         if (pkWaresList.size() > 0) {
             LambdaQueryWrapper<BdWaresAuthority> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper.in(BdWaresAuthority::getPkWares, pkWaresList);
+            // 只查询不为全部的，全部的话默认都是可见的
+            queryWrapper.ne(BdWaresAuthority::getAuthorityType, EWaresPermissionType.AUTH_ORITY_TYPE.getValue());
             List<BdWaresAuthority> waresAuthorityList = iBdWaresAuthorityService.list(queryWrapper);
             map = waresAuthorityList.stream().collect(Collectors.groupingBy(BdWaresAuthority::getPkWares, Collectors.toList()));
         }
@@ -1619,8 +1620,10 @@ public class BdWaresServiceImpl extends ServiceImpl<BdWaresMapper, BdWares> impl
     }
 
     @Override
-    public List<BdWares> queryMakerIncomeList(Integer specialArea, Integer pkCountry) {
+    public List<BdWaresExt> listWares(List<Integer> specialAreaList) {
-        return baseMapper.queryMakerIncomeList(specialArea, pkCountry);
+        // 商品列表（复购、乐学复购、重消）
+        return baseMapper.listWaresNew(specialAreaList);
+
     }
 
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/vo/WaresCoverInfoVo.java

@@ -4,14 +4,6 @@ import lombok.Data;
 
 import java.util.List;
 
-/**
- * @BelongsProject: hzs_cloud
- * @BelongsPackage: com.hzs.sale.wares.vo
- * @Author: yh
- * @CreateTime: 2023-05-15  11:18
- * @Description:
- * @Version: 1.0
- */
 @Data
 public class WaresCoverInfoVo {
 
@@ -24,4 +16,5 @@ public class WaresCoverInfoVo {
      * 商品图列表
      */
     private List<String> coverList;
+
 }

bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/vo/WaresVo.java

@@ -176,10 +176,10 @@ public class WaresVo {
      */
     @Excel(name = "上架状态", readConverterExp = "0=上架,1=下架")
     private Integer isPutOn;
+
     /**
      * 预售状态
      */
-
     private Integer preSaleStatus;
 
     /**
@@ -264,11 +264,13 @@ public class WaresVo {
     /**
      * 会员价
      */
+    @BigDecimalFormat
     private BigDecimal vipPrice;
 
     /**
      * 零售价
      */
+    @BigDecimalFormat
     private BigDecimal retailPrice;
 
     /**

bd-business/bd-business-sale/src/main/resources/mapper/sale/order/SaOrderMapper.xml

@@ -1470,57 +1470,6 @@
         order by so.creation_time desc
     </select>
 
-    <select id="selectMyMarket" resultType="com.hzs.sale.index.vo.CuMemberMyMarketVO">
-        select count(distinct o.pk_country) countryNum,
-        count(distinct o.rec_province) regionNum
-        from sa_order o
-        where o.del_flag = 0
-        and o.order_status = 1
-        <if test="pkMember != null">
-            and o.pk_member in
-            (select m.pk_id
-            from cu_member m
-            where m.del_flag = 0
-            and m.pay_status = 1
-            and m.category = 0
-            and m.pk_settle_country = #{pkCountry}
-            start with m.pk_id = #{pkMember}
-            connect by prior m.pk_id = m.pk_parent)
-        </if>
-        <if test="pkCountry != null">
-            and o.pk_country = #{pkCountry}
-        </if>
-    </select>
-
-    <select id="selectMyMarketDetail" resultType="com.hzs.sale.index.vo.CuMemberMyMarketDetailVO">
-        select distinct o.pk_country pkCountry,
-        o.rec_province province,
-        a.light_name lightName
-        from sa_order o
-        left join bd_area a
-        on o.rec_province = a.pk_id
-        and a.del_flag = 0
-        and a.enable_state = 0
-        where 1 = 1
-        <if test="pkMember != null">
-            and o.pk_member in
-            (select m.pk_id
-            from cu_member m
-            where m.del_flag = 0
-            and m.pay_status = 1
-            and m.category = 0
-            and m.pk_settle_country = #{pkCountry}
-            start with m.pk_id = #{pkMember}
-            connect by prior m.pk_id = m.pk_parent)
-        </if>
-        and o.del_flag = 0
-        and o.order_status = 1
-        and o.rec_province is not null
-        <if test="pkCountry != null">
-            and o.pk_country = #{pkCountry}
-        </if>
-    </select>
-
     <!--    查询当天已支付订单信息-->
     <select id="querySaOrderByOrderType" resultMap="SaOrder">
         select so.pk_member,

bd-business/bd-business-sale/src/main/resources/mapper/sale/wares/BdWaresMapper.xml

@@ -405,21 +405,22 @@
         order by wa.PK_id desc
     </select>
 
-    <!-- 查询上架的发起人收益商品列表 -->
+    <!-- 新商品列表 -->
-    <select id="queryMakerIncomeList" resultType="com.hzs.common.domain.sale.wares.BdWares">
+    <select id="listWaresNew" resultType="com.hzs.common.domain.sale.ext.BdWaresExt">
-        select bw.*
+        select bd.*, bwe.is_sale, bwe.pre_sale_status
-        from bd_wares bw
+        from bd_wares bd
-        inner join BD_WARES_EXTEND bwe
+        left join bd_wares_extend bwe
-        on bwe.pk_wares = bw.pk_id
+        on bwe.pk_wares = bd.pk_id
-        and bwe.del_flag = 0
+        where bd.del_flag = 0
-        and bwe.pk_country = 1
+        and bd.wares_status = 5
-        and bwe.IS_PUT_ON = 0
+        and bwe.is_put_on = 0
-        and bwe.MAKER_INCOME != 0
+        <if test="specialAreaList != null">
-        where bw.del_flag = 0
+            and bd.special_area in
-        and bw.pk_country = #{pkCountry}
+            <foreach collection="specialAreaList" item="item" open="(" close=")" separator=",">
-        <if test="null != specialArea">
+                #{item}
-            and bw.SPECIAL_AREA = #{specialArea}
+            </foreach>
         </if>
+        order by bd.sort desc, bd.wares_price
     </select>
 
 </mapper>

bd-business/bd-business-sale/src/main/resources/mapper/sale/wares/BdWaresRangeMapper.xml

@@ -22,7 +22,8 @@
     </resultMap>
 
     <select id="queryWaresRangeByCondition" resultMap="BdWaresRange">
-        select bd.pk_wares,(bs.price*bd.quantity) price,(bs.achieve*bd.quantity) achieve,(bs.ass_achieve*bd.quantity) ass_achieve from bd_wares_detail bd
+        select bd.pk_wares,(bs.price*bd.quantity) price,(bs.achieve*bd.quantity) achieve,(bs.ass_achieve*bd.quantity) ass_achieve
+        from bd_wares_detail bd
         inner join (
         select bs.pk_wares_detail,min(bs.price) price,max(bs.achieve) achieve,max(bs.ASS_ACHIEVE) ass_achieve from bd_wares_range bs
         left join bd_wares_specs_sku bss on bss.pk_id = bs.PK_WARES_SPECS_SKU
@@ -46,7 +47,6 @@
     </select>
 
     <select id="queryWaresList" resultType="com.hzs.common.domain.sale.wares.BdWaresRange">
-
         SELECT wr.PK_ID              pkId,
                wr.PK_WARES           pkWares,
                wr.PK_PRODUCT         pkProduct,
@@ -61,7 +61,6 @@
         FROM bd_range br
                  LEFT JOIN bd_wares_range wr ON wr.PK_RANGE = br.PK_ID
                  left join BD_WARES_DETAIL wd on wd.PK_ID = wr.PK_WARES_DETAIL
-
         WHERE br.PK_COUNTRY = #{pkCountry}
           AND br.DEL_FLAG = 0
           AND wr.PK_WARES = #{pkWares}

bd-business/bd-business-system/src/main/java/com/hzs/system/base/provider/CountryServiceProvider.java

@@ -15,27 +15,21 @@ import org.springframework.beans.factory.annotation.Autowired;
 import java.util.Map;
 
 /**
- * Description: 国家dubbo服务
+ * 国家dubbo服务
- * Author: jiang chao
- * Time: 2022/8/31 16:52
- * Classname: CountryServiceProvider
- * PackageName: com.hzs.system.base.provider
  */
 @DubboService
 public class CountryServiceProvider implements ICountryServiceApi {
 
     @Autowired
-    private IBdCountryService countryService;
+    private IBdCountryService iBdCountryService;
-
     @Autowired
-    private IBdCurrencyService currencyService;
+    private IBdCurrencyService iBdCurrencyService;
-
     @Autowired
-    private IBdAccountService accountService;
+    private IBdAccountService iBdAccountService;
 
     @Override
     public R<CountryDTO> getCountry(Integer countryId) {
-        BdCountry bdCountry = countryService.getCountry(countryId);
+        BdCountry bdCountry = iBdCountryService.getCountry(countryId);
         if (null == bdCountry) {
             return R.fail();
         }
@@ -44,17 +38,17 @@ public class CountryServiceProvider implements ICountryServiceApi {
 
     @Override
     public R<Map<Integer, BdCountry>> getAllCountryMap() {
-        return R.ok(countryService.getAllCountryMap());
+        return R.ok(iBdCountryService.getAllCountryMap());
     }
 
     @Override
     public R<Boolean> updateConfigEffectById(Integer businessType, Integer pkId) {
-        if(EDelayBusType.COUNTRY.getValue() == businessType){
+        if (EDelayBusType.COUNTRY.getValue() == businessType) {
-            countryService.updateCountryId(pkId);
+            iBdCountryService.updateCountryId(pkId);
-        }else if(EDelayBusType.CURRENCY.getValue() == businessType){
+        } else if (EDelayBusType.CURRENCY.getValue() == businessType) {
-            currencyService.updateCurrencyById(pkId);
+            iBdCurrencyService.updateCurrencyById(pkId);
-        }else if(EDelayBusType.ACCOUNT.getValue() == businessType){
+        } else if (EDelayBusType.ACCOUNT.getValue() == businessType) {
-            accountService.updateAccountById(pkId);
+            iBdAccountService.updateAccountById(pkId);
         }
         return R.ok();
     }

bd-business/bd-business-system/src/main/java/com/hzs/system/config/mapper/BdRangeMapper.java

@@ -1,35 +1,26 @@
 package com.hzs.system.config.mapper;
 
-
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.hzs.common.domain.system.config.BdRange;
 import com.hzs.system.config.dto.RangeDTO;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
-import java.util.Map;
-import java.util.Set;
 
 /**
- * <p>
  * 极差配置 Mapper 接口
- * </p>
- *
- * @author zhangjing
- * @since 2022-09-09
  */
 public interface BdRangeMapper extends BaseMapper<BdRange> {
 
     /**
      * 查询各个国家极差的配置  键为 国家+极差类型+等级主键
+     *
      * @param pkCountry 国家
      * @param rangeType 极差类型
-     * @param pkLevel 等级
+     * @param pkLevel   等级
-     * @return: Map<String,RangeDTO>
-     * @Author: sui q
-     * @Date: 2023/1/3 14:00
      */
     List<RangeDTO> queryRangeDto(@Param("pkCountry") Integer pkCountry,
-                                 @Param("rangeType") Integer rangeType, @Param("pkLevel") Integer pkLevel);
+                                 @Param("rangeType") Integer rangeType,
+                                 @Param("pkLevel") Integer pkLevel);
 
 }

bd-business/bd-business-system/src/main/java/com/hzs/system/config/provider/RangeServiceProvider.java

@@ -1,12 +1,9 @@
 package com.hzs.system.config.provider;
 
 import com.hzs.common.core.domain.R;
-import com.hzs.common.domain.system.config.ext.BdBonusItemsExt;
 import com.hzs.common.domain.system.config.ext.BdRangeExt;
-import com.hzs.system.config.IBonusItemsServiceApi;
 import com.hzs.system.config.IRangeServiceApi;
 import com.hzs.system.config.dto.RangeDTO;
-import com.hzs.system.config.service.IBdBonusItemsService;
 import com.hzs.system.config.service.IBdRangeService;
 import org.apache.dubbo.config.annotation.DubboService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -15,37 +12,27 @@ import java.util.List;
 import java.util.Map;
 
 /**
- * @description: 极差配置
+ * 极差配置
- * @author: zhang jing
- * @date: 2022/11/10 17:02
- * @param:
- * @return:
  **/
 @DubboService
 public class RangeServiceProvider implements IRangeServiceApi {
 
     @Autowired
-    private IBdRangeService rangeService;
+    private IBdRangeService iBdRangeService;
 
-    /**
-     * @description: 根据国家查询极差配置列表
-     * @author: zhang jing
-     * @date: 2022/9/29 15:17
-     * @param: [pkCountry]
-     * @return: com.hzs.common.core.domain.R<java.util.List<com.hzs.common.domain.system.config.BdAwards>>
-     **/
     @Override
     public R<List<BdRangeExt>> queryRange(Integer pkCountry) {
-        return R.ok(rangeService.queryRange(pkCountry));
+        return R.ok(iBdRangeService.queryRange(pkCountry));
     }
 
     @Override
     public R<Map<String, RangeDTO>> queryRangeDto() {
-        return R.ok(rangeService.queryRangeDto());
+        return R.ok(iBdRangeService.queryRangeDto());
     }
 
     @Override
     public R<RangeDTO> queryRangeDtoByCondition(Integer pkCountry, Integer rangeType, Integer pkLevel) {
-        return R.ok(rangeService.getRangeDTO(pkCountry, rangeType, pkLevel));
+        return R.ok(iBdRangeService.getRangeDTO(pkCountry, rangeType, pkLevel));
     }
+
 }

bd-business/bd-business-system/src/main/java/com/hzs/system/config/service/IBdRangeService.java

@@ -1,69 +1,45 @@
 package com.hzs.system.config.service;
 
-
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.hzs.common.domain.system.config.BdRange;
 import com.hzs.common.domain.system.config.ext.BdRangeExt;
 import com.hzs.system.config.dto.RangeDTO;
-import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 import java.util.Map;
-import java.util.Set;
 
 /**
- * <p>
  * 极差配置 服务类
- * </p>
- *
- * @author zhangjing
- * @since 2022-09-09
  */
 public interface IBdRangeService extends IService<BdRange> {
 
     /**
-     * @description: 新增极差
+     * 新增极差
-     * @author: zhang jing
-     * @date: 2022/10/28 14:23
-     * @param: [rangeExt]
-     * @return: boolean
      **/
     boolean saveRange(BdRangeExt rangeExt);
+
     /**
-     * @description: 修改极差
+     * 修改极差
-     * @author: zhang jing
-     * @date: 2022/10/28 14:23
-     * @param: [rangeExt]
-     * @return: boolean
      **/
     boolean updateRange(BdRangeExt rangeExt);
 
-
     /**
-     * @description: 根据国家查询极差配置列表
+     * 根据国家查询极差配置列表
-     * @author: zhang jing
-     * @date: 2022/11/11 18:02
-     * @param: [pkCountry]
-     * @return: java.util.List<com.hzs.common.domain.system.config.BdRange>
      **/
     List<BdRangeExt> queryRange(Integer pkCountry);
 
     /**
      * 查询各个国家极差的配置  键为 国家+极差类型+等级主键
-    * @return: Map<String,RangeDTO>
+     */
-    * @Author: sui q
-    * @Date: 2023/1/3 14:00
-    */
     Map<String, RangeDTO> queryRangeDto();
 
     /**
      * 根据类型获取极差等级
+     *
      * @param pkCountry 国家
      * @param rangeType 极差类型
-     * @param pkLevel 等级
+     * @param pkLevel   等级
-    * @return: RangeDTO
+     */
-    * @Author: sui q
-    * @Date: 2023/2/4 15:54
-    */
     RangeDTO getRangeDTO(Integer pkCountry, Integer rangeType, Integer pkLevel);
+
 }

bd-business/bd-business-system/src/main/java/com/hzs/system/config/service/impl/BdRangeServiceImpl.java

@@ -2,25 +2,22 @@ package com.hzs.system.config.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollectionUtil;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.hzs.common.core.constant.CacheConstants;
 import com.hzs.common.core.constant.Constants;
-import com.hzs.common.core.domain.R;
 import com.hzs.common.core.enums.*;
 import com.hzs.common.core.service.RedisService;
 import com.hzs.common.domain.system.config.BdRange;
 import com.hzs.common.domain.system.config.BdRangeDetails;
 import com.hzs.common.domain.system.config.ext.BdRangeExt;
 import com.hzs.common.security.utils.SecurityUtils;
-import com.hzs.system.base.ITransactionServiceApi;
 import com.hzs.system.config.dto.RangeDTO;
 import com.hzs.system.config.mapper.BdRangeMapper;
 import com.hzs.system.config.service.IBdRangeDetailsService;
 import com.hzs.system.config.service.IBdRangeService;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboReference;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -28,45 +25,23 @@ import java.util.*;
 import java.util.concurrent.TimeUnit;
 
 /**
- * <p>
  * 极差配置 服务实现类
- * </p>
- *
- * @author zhangjing
- * @since 2022-09-09
  */
 @Slf4j
 @Service
 public class BdRangeServiceImpl extends ServiceImpl<BdRangeMapper, BdRange> implements IBdRangeService {
 
     @Autowired
-    private IBdRangeDetailsService rangeDetailsService;
+    private IBdRangeDetailsService iBdRangeDetailsService;
-    @DubboReference
+    @Autowired
-    private ITransactionServiceApi iTransactionServiceApi;
-
     private RedisService redisService;
 
-    @Autowired
-    public void setRedisService(RedisService redisService) {
-        this.redisService = redisService;
-    }
-
-    /**
-     * @description: 新增极差
-     * @author: zhang jing
-     * @date: 2022/10/28 14:23
-     * @param: [rangeExt]
-     * @return: boolean
-     **/
     @Override
     public boolean saveRange(BdRangeExt rangeExt) {
         //字段翻译保存到数据库
-        R<Integer> pkTransaction = iTransactionServiceApi.createTransaction(rangeExt.getPkCountry(), ETransactionKey.RANGE,
+        LambdaQueryWrapper<BdRange> queryWrapper = new LambdaQueryWrapper<>();
-                rangeExt.getRangeName(), EYesNo.YES, EYesNo.NO);
+        queryWrapper.eq(BdRange::getPkCountry, rangeExt.getPkCountry());
-        rangeExt.setPkTransaction(pkTransaction.getData());
+        queryWrapper.eq(BdRange::getRangeValue, rangeExt.getRangeValue());
-        QueryWrapper<BdRange> queryWrapper = new QueryWrapper();
-        queryWrapper.eq("PK_COUNTRY", rangeExt.getPkCountry());
-        queryWrapper.eq("RANGE_VALUE", rangeExt.getRangeValue());
         List<BdRange> list = baseMapper.selectList(queryWrapper);
         if (CollectionUtil.isEmpty(list)) {
             baseMapper.insert(rangeExt);
@@ -81,7 +56,7 @@ public class BdRangeServiceImpl extends ServiceImpl<BdRangeMapper, BdRange> impl
                 rangeDetails.setPkCountry(SecurityUtils.getPkCountry());
                 rangeDetails.setPkCreator(SecurityUtils.getUserId());
                 rangeDetails.setCreationTime(new Date());
-                rangeDetailsService.save(rangeDetails);
+                iBdRangeDetailsService.save(rangeDetails);
             }
             //奖衔
             for (Integer aw : awardsList) {
@@ -92,31 +67,20 @@ public class BdRangeServiceImpl extends ServiceImpl<BdRangeMapper, BdRange> impl
                 rangeDetails.setPkCountry(SecurityUtils.getPkCountry());
                 rangeDetails.setPkCreator(SecurityUtils.getUserId());
                 rangeDetails.setCreationTime(new Date());
-                rangeDetailsService.save(rangeDetails);
+                iBdRangeDetailsService.save(rangeDetails);
             }
         }
         redisService.deleteObject(CacheConstants.BD_RANGE + rangeExt.getPkCountry());
         return true;
     }
 
-    /**
-     * @description: 修改极差
-     * @author: zhang jing
-     * @date: 2022/10/28 14:23
-     * @param: [rangeExt]
-     * @return: boolean
-     **/
     @Override
     public boolean updateRange(BdRangeExt rangeExt) {
-        //字段翻译保存到数据库
-        R<Integer> pkTransaction = iTransactionServiceApi.createTransaction(rangeExt.getPkCountry(), ETransactionKey.RANGE,
-                rangeExt.getRangeName(), EYesNo.YES, EYesNo.NO);
-        rangeExt.setPkTransaction(pkTransaction.getData());
         baseMapper.updateById(rangeExt);
-        UpdateWrapper<BdRangeDetails> updateWrapper = new UpdateWrapper();
+        LambdaUpdateWrapper<BdRangeDetails> updateWrapper = new LambdaUpdateWrapper<>();
-        updateWrapper.set("DEL_FLAG", EYesNo.NO.getIntValue());
+        updateWrapper.set(BdRangeDetails::getDelFlag, EYesNo.NO.getIntValue());
-        updateWrapper.eq("PK_RANGE", rangeExt.getPkId());
+        updateWrapper.eq(BdRangeDetails::getPkRange, rangeExt.getPkId());
-        rangeDetailsService.update(updateWrapper);
+        iBdRangeDetailsService.update(updateWrapper);
         List<Integer> gradeList = rangeExt.getGradeList();
         List<Integer> awardsList = rangeExt.getAwardsList();
         //等级
@@ -128,7 +92,7 @@ public class BdRangeServiceImpl extends ServiceImpl<BdRangeMapper, BdRange> impl
             rangeDetails.setPkCountry(SecurityUtils.getPkCountry());
             rangeDetails.setPkCreator(SecurityUtils.getUserId());
             rangeDetails.setCreationTime(new Date());
-            rangeDetailsService.save(rangeDetails);
+            iBdRangeDetailsService.save(rangeDetails);
         }
         //奖衔
         for (Integer aw : awardsList) {
@@ -139,30 +103,20 @@ public class BdRangeServiceImpl extends ServiceImpl<BdRangeMapper, BdRange> impl
             rangeDetails.setPkCountry(SecurityUtils.getPkCountry());
             rangeDetails.setPkCreator(SecurityUtils.getUserId());
             rangeDetails.setCreationTime(new Date());
-            rangeDetailsService.save(rangeDetails);
+            iBdRangeDetailsService.save(rangeDetails);
         }
         redisService.deleteObject(CacheConstants.BD_RANGE + rangeExt.getPkCountry());
         return true;
     }
 
-
-    /**
-     * @description: 根据国家查询极差配置列表
-     * @author: zhang jing
-     * @date: 2022/11/11 18:07
-     * @param: [pkCountry]
-     * @return: java.util.List<com.hzs.common.domain.system.config.BdRange>
-     **/
     @Override
     public List<BdRangeExt> queryRange(Integer pkCountry) {
-     //   redisService.deleteObject(CacheConstants.BD_RANGE + pkCountry);
         List<BdRangeExt> rangeList = redisService.getCacheList(CacheConstants.BD_RANGE + pkCountry);
-        log.info("测试："+rangeList);
         List<BdRangeExt> rangeListNew = new ArrayList<>();
         if (CollectionUtil.isEmpty(rangeList)) {
-            QueryWrapper<BdRange> queryWrapper = new QueryWrapper<>();
+            LambdaQueryWrapper<BdRange> queryWrapper = new LambdaQueryWrapper<>();
-            queryWrapper.eq("PK_COUNTRY", pkCountry);
+            queryWrapper.eq(BdRange::getPkCountry, pkCountry);
-            queryWrapper.orderByDesc("CREATION_TIME");
+            queryWrapper.orderByDesc(BdRange::getCreationTime);
             List<BdRange> list = baseMapper.selectList(queryWrapper);
             if (CollectionUtil.isNotEmpty(list)) {
                 list.forEach(item -> rangeListNew.add(BeanUtil.copyProperties(item, BdRangeExt.class)));

bd-business/bd-business-system/src/main/java/com/hzs/system/config/vo/ApiMenuVO.java

@@ -7,11 +7,7 @@ import lombok.Data;
 import lombok.NoArgsConstructor;
 
 /**
- * @Description: 会员菜单VO
+ * 会员菜单VO
- * @Author: jiang chao
- * @Time: 2023/1/12 15:32
- * @Classname: ApiMenuVO
- * @PackageName: com.hzs.system.config.vo
  */
 @NoArgsConstructor
 @AllArgsConstructor

bd-business/bd-business-system/src/main/resources/mapper/system/config/BdRangeMapper.xml

@@ -4,17 +4,17 @@
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.hzs.common.domain.system.config.BdRange">
-        <id column="PK_ID" property="pkId" />
+        <id column="PK_ID" property="pkId"/>
-        <result column="DEL_FLAG" property="delFlag" />
+        <result column="DEL_FLAG" property="delFlag"/>
-        <result column="PK_COUNTRY" property="pkCountry" />
+        <result column="PK_COUNTRY" property="pkCountry"/>
-        <result column="PK_CREATOR" property="pkCreator" />
+        <result column="PK_CREATOR" property="pkCreator"/>
-        <result column="CREATION_TIME" property="creationTime" />
+        <result column="CREATION_TIME" property="creationTime"/>
-        <result column="PK_MODIFIED" property="pkModified" />
+        <result column="PK_MODIFIED" property="pkModified"/>
-        <result column="MODIFIED_TIME" property="modifiedTime" />
+        <result column="MODIFIED_TIME" property="modifiedTime"/>
-        <result column="RANGE_NAME" property="rangeName" />
+        <result column="RANGE_NAME" property="rangeName"/>
-        <result column="PK_TRANSACTION" property="pkTransaction" />
+        <result column="PK_TRANSACTION" property="pkTransaction"/>
-        <result column="MONEY_RATIO" property="moneyRatio" />
+        <result column="MONEY_RATIO" property="moneyRatio"/>
-        <result column="ACHIEVE_RATIO" property="achieveRatio" />
+        <result column="ACHIEVE_RATIO" property="achieveRatio"/>
     </resultMap>
 
     <select id="queryRangeDto" resultType="com.hzs.system.config.dto.RangeDTO">

bd-common/bd-common-core/src/main/java/com/hzs/common/core/enums/EWaresPermissionType.java

@@ -6,12 +6,6 @@ import lombok.Getter;
 
 /**
  * 商品权限类型枚举
- *
- * @author: sui q
- * @time: 2022/8/27 10:26
- * @description: 商品权限类型
- * @classname: EWaresPermissionType
- * @package_name: com.hzs.common.core.enums
  */
 @AllArgsConstructor
 @Getter

bd-common/bd-common-core/src/main/java/com/hzs/common/core/utils/PageUtils.java

@@ -7,8 +7,6 @@ import com.hzs.common.core.web.page.TableSupport;
 
 /**
  * 分页工具类
- *
- * @author hzs
  */
 public class PageUtils extends PageHelper {
 

bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/sale/wares/ext/WaresGradeAwards.java

@@ -1,17 +1,11 @@
 package com.hzs.common.domain.sale.wares.ext;
 
-import com.baomidou.mybatisplus.annotation.TableField;
 import lombok.Data;
 
 import java.io.Serializable;
 
 /**
- * @description: 商品权限控制
+ * 商品权限控制
- * @author: sui q
- * @time: 2023/9/5 19:47
- * @classname: WaresGradeAwards
- * @package_name: com.hzs.common.domain.sale.wares.ext
- * version 1.0.0
  */
 @Data
 public class WaresGradeAwards implements Serializable {