From 664184af3e070dee665ee736caffa0297804975f Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 18 Mar 2025 11:46:02 +0800
Subject: [PATCH] perf(mall): 移除会员利润计算中的异步执行

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallGoodsService.java |  575 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 562 insertions(+), 13 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallGoodsService.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallGoodsService.java
index ea09b5f..10cd251 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallGoodsService.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallGoodsService.java
@@ -12,6 +12,8 @@
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -38,6 +40,10 @@
     private final MallGoodsStyleMapper mallGoodsStyleMapper;
     private final MallGoodsImagesMapper mallGoodsImagesMapper;
     private final MallShoppingCartMapper mallShoppingCartMapper;
+    private final MallCarriageRuleMapper mallCarriageRuleMapper;
+    private final MallCarriageRuleInfoMapper mallCarriageRuleInfoMapper;
+    private final MallGoodsCouponMapper mallGoodsCouponMapper;
+    private final CouponGoodsMapper couponGoodsMapper;
 
     @Override
     public IPage<AdminMallGoodsVo> getCategoryListInPage(MallGoods mallGoods, QueryRequest request) {
@@ -65,6 +71,22 @@
         if (mallGoodsByGoodsNo > 0) {
             return new FebsResponse().fail().message("商品编号不能重复");
         }
+        Integer carriageType = addMallGoodsDto.getCarriageType();
+        if (addMallGoodsDto.getGoodsType() == 1) {
+            if (1 == carriageType) {
+                if (ObjectUtil.isEmpty(addMallGoodsDto.getCarriageAmount())
+                        || BigDecimal.ZERO.compareTo(addMallGoodsDto.getCarriageAmount()) > 0) {
+                    return new FebsResponse().fail().message("固定邮费不能小于零");
+                }
+            } else {
+                Long carriageRuleId = addMallGoodsDto.getCarriageRuleId();
+                MallCarriageRule mallCarriageRule = mallCarriageRuleMapper.selectById(carriageRuleId);
+                if (ObjectUtil.isEmpty(mallCarriageRule)) {
+                    return new FebsResponse().fail().message("邮费模板不能为空");
+                }
+            }
+        }
+
 
         // 付费商品
         if (addMallGoodsDto.getGoodsType() != 2) {
@@ -103,6 +125,15 @@
                     if (StrUtil.isEmpty(presentPrice)) {
                         return new FebsResponse().fail().message("商品规格现价不能为空");
                     }
+//                    if (StrUtil.isEmpty(addSku.getLevelOnePrice())
+//                    || StrUtil.isEmpty(addSku.getLevelTwoPrice())
+//                            || StrUtil.isEmpty(addSku.getLevelThreePrice())) {
+//                        return new FebsResponse().fail().message("商品规格级别价格不能为空");
+//                    }
+                    BigDecimal goodsWeight = addSku.getGoodsWeight();
+                    if(BigDecimal.ZERO.compareTo(goodsWeight) > 0){
+                        return new FebsResponse().fail().message("重量不能小于零");
+                    }
                 }
             }
         }
@@ -110,9 +141,9 @@
         MallGoods mallGoods = MallGoodsConversion.INSTANCE.dtoToEntity(addMallGoodsDto);
         mallGoods.setIsSale(MallGoods.ISSALE_STATUS_DISABLED);
 
-        if (mallGoods.getHasCarriage() == 2) {
-            mallGoods.setCarriage(BigDecimal.ZERO);
-        }
+//        if (mallGoods.getHasCarriage() == 2) {
+//            mallGoods.setCarriage(BigDecimal.ZERO);
+//        }
         mallGoodsMapper.insert(mallGoods);
 
         String thumbs = addMallGoodsDto.getThumbs();
@@ -128,6 +159,25 @@
                     mallGoodsImagesMapper.insert(mallGoodsImages);
                     i++;
                 }
+            }
+        }
+
+        Long goodsId = mallGoods.getId();
+        QueryWrapper<CouponGoods> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("goods_id",goodsId);
+        List<CouponGoods> mallGoodsCoupons = couponGoodsMapper.selectList(objectQueryWrapper);
+        if(CollUtil.isNotEmpty(mallGoodsCoupons)){
+            for(CouponGoods couponGoods : mallGoodsCoupons){
+                couponGoodsMapper.deleteById(couponGoods);
+            }
+        }
+        if(CollUtil.isNotEmpty(addMallGoodsDto.getCouponIds())){
+            List<Long> couponIds = addMallGoodsDto.getCouponIds();
+            for(Long couponId : couponIds){
+                CouponGoods couponGoods = new CouponGoods();
+                couponGoods.setGoodsId(goodsId);
+                couponGoods.setCouponId(couponId);
+                couponGoodsMapper.insert(couponGoods);
             }
         }
 
@@ -147,11 +197,15 @@
             sku.setSkuImage(mallGoods.getThumb());
             sku.setSkuName(mallGoods.getGoodsName());
             sku.setCostPrice(mallGoods.getCostPrice());
-            sku.setPresentPrice(new BigDecimal(mallGoods.getPresentPrice()));
             sku.setOriginalPrice(new BigDecimal(mallGoods.getOriginalPrice()));
+            sku.setPresentPrice(new BigDecimal(mallGoods.getPresentPrice()));
+            sku.setLevelOnePrice(new BigDecimal(mallGoods.getPresentPrice()));
+            sku.setLevelTwoPrice(new BigDecimal(mallGoods.getPresentPrice()));
+            sku.setLevelThreePrice(new BigDecimal(mallGoods.getPresentPrice()));
             sku.setSkuVolume(mallGoods.getVolume());
             sku.setStock(mallGoods.getStock());
             sku.setStyleId(style.getId());
+            sku.setGoodsWeight(mallGoods.getGoodsWeight());
             mallGoodsSkuMapper.insert(sku);
             return new FebsResponse().success().message("添加成功");
         }
@@ -185,9 +239,15 @@
                 mallGoodsSku.setSkuVolume(addMallGoodsSkuDto.getSkuVolume() == null ? 0 : addMallGoodsSkuDto.getSkuVolume());
                 mallGoodsSku.setOriginalPrice(new BigDecimal(addMallGoodsSkuDto.getOriginalPrice()));
                 mallGoodsSku.setPresentPrice(new BigDecimal(addMallGoodsSkuDto.getPresentPrice()));
-                mallGoodsSku.setStyleId(mallGoodsStyleSku.getId());
                 mallGoodsSku.setCostPrice(addMallGoodsSkuDto.getCostPrice());
+
+                mallGoodsSku.setLevelOnePrice(new BigDecimal(addMallGoodsSkuDto.getPresentPrice()));
+                mallGoodsSku.setLevelTwoPrice(new BigDecimal(addMallGoodsSkuDto.getPresentPrice()));
+                mallGoodsSku.setLevelThreePrice(new BigDecimal(addMallGoodsSkuDto.getPresentPrice()));
+                mallGoodsSku.setStyleId(mallGoodsStyleSku.getId());
                 mallGoodsSku.setGoodsId(mallGoods.getId());
+                mallGoodsSku.setGoodsWeight(addMallGoodsSkuDto.getGoodsWeight());
+                mallGoodsSku.setSample(addMallGoodsSkuDto.getSample());
                 mallGoodsSkuMapper.insert(mallGoodsSku);
             }
         }
@@ -265,8 +325,10 @@
 
         List<MallGoodsSku> skus = mallGoodsSkuMapper.selectSkuByGoodsId(mallGoods.getId());
         List<String> thumbs = mallGoodsImagesMapper.selectByGoodId(mallGoods.getId());
+        List<Long> couponIds = couponGoodsMapper.selectByGoodId(mallGoods.getId());
         mallGoods.setImages(thumbs);
         mallGoods.setSkus(skus);
+        mallGoods.setCouponIds(couponIds);
         return mallGoods;
     }
 
@@ -288,6 +350,19 @@
         Integer mallGoodsByGoodsNo = mallGoodsMapper.selectMallGoodsCountByGoodsNoAndGoodId(goodsNo, mallGoodsUpdateDto.getId());
         if (mallGoodsByGoodsNo > 0) {
             return new FebsResponse().fail().message("商品编号不能重复");
+        }
+        Integer carriageType = mallGoodsUpdateDto.getCarriageType();
+        if(1 == carriageType){
+            if(ObjectUtil.isEmpty(mallGoodsUpdateDto.getCarriageAmount())
+            || BigDecimal.ZERO.compareTo(mallGoodsUpdateDto.getCarriageAmount()) > 0){
+                return new FebsResponse().fail().message("固定邮费不能小于零");
+            }
+        }else{
+            Long carriageRuleId = mallGoodsUpdateDto.getCarriageRuleId();
+            MallCarriageRule mallCarriageRule = mallCarriageRuleMapper.selectById(carriageRuleId);
+            if(ObjectUtil.isEmpty(mallCarriageRule)){
+                return new FebsResponse().fail().message("邮费模板不能为空");
+            }
         }
 
         if (mallGoodsUpdateDto.getGoodsType() != 2) {
@@ -323,8 +398,12 @@
                         return new FebsResponse().fail().message("商品规格原价不能小于0");
                     }
                     BigDecimal presentPrice = addSku.getPresentPrice();
-                    if (presentPrice.compareTo(BigDecimal.ZERO) <= 0) {
+                    if (presentPrice.compareTo(BigDecimal.ZERO) < 0) {
                         return new FebsResponse().fail().message("商品规格现价不能小于0");
+                    }
+                    BigDecimal goodsWeight = addSku.getGoodsWeight();
+                    if(BigDecimal.ZERO.compareTo(goodsWeight) > 0){
+                        return new FebsResponse().fail().message("重量不能小于零");
                     }
 
                 }
@@ -341,11 +420,17 @@
         }
 
         BeanUtil.copyProperties(mallGoodsUpdateDto, mallGoods);
-        if (mallGoods.getHasCarriage() == 2) {
-            mallGoods.setCarriage(BigDecimal.ZERO);
-        }
+//        if (mallGoods.getHasCarriage() == 2) {
+//            mallGoods.setCarriage(BigDecimal.ZERO);
+//        }
 
         mallGoodsMapper.updateById(mallGoods);
+
+        if( 1 == mallGoods.getCarriageType()){
+            mallGoodsMapper.updateCarriageRuleId(mallGoods.getId());
+        }else{
+            mallGoodsMapper.updateCarriageAmount(mallGoods.getId());
+        }
 
         mallGoodsImagesMapper.deleteByGoodsId(mallGoodsUpdateDto.getId());
         String thumbs = mallGoodsUpdateDto.getThumbs();
@@ -361,6 +446,25 @@
                     mallGoodsImagesMapper.insert(mallGoodsImages);
                     i++;
                 }
+            }
+        }
+
+        Long goodsId = mallGoodsUpdateDto.getId();
+        QueryWrapper<CouponGoods> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("goods_id",goodsId);
+        List<CouponGoods> mallGoodsCoupons = couponGoodsMapper.selectList(objectQueryWrapper);
+        if(CollUtil.isNotEmpty(mallGoodsCoupons)){
+            for(CouponGoods couponGoods : mallGoodsCoupons){
+                couponGoodsMapper.deleteById(couponGoods);
+            }
+        }
+        if(CollUtil.isNotEmpty(mallGoodsUpdateDto.getCouponIds())){
+            List<Long> couponIds = mallGoodsUpdateDto.getCouponIds();
+            for(Long couponId : couponIds){
+                CouponGoods couponGoods = new CouponGoods();
+                couponGoods.setGoodsId(goodsId);
+                couponGoods.setCouponId(couponId);
+                couponGoodsMapper.insert(couponGoods);
             }
         }
 
@@ -382,14 +486,16 @@
             sku.setCostPrice(mallGoods.getCostPrice());
             sku.setPresentPrice(new BigDecimal(mallGoods.getPresentPrice()));
             sku.setOriginalPrice(new BigDecimal(mallGoods.getOriginalPrice()));
+            sku.setLevelOnePrice(new BigDecimal(mallGoods.getPresentPrice()));
+            sku.setLevelTwoPrice(new BigDecimal(mallGoods.getPresentPrice()));
+            sku.setLevelThreePrice(new BigDecimal(mallGoods.getPresentPrice()));
             sku.setSkuVolume(mallGoods.getVolume());
             sku.setStock(mallGoods.getStock());
             sku.setStyleId(style.getId());
+            sku.setGoodsWeight(mallGoods.getGoodsWeight());
             mallGoodsSkuMapper.insert(sku);
             return new FebsResponse().success().message("添加成功");
         }
-
-
 
         // 删除已存在sku
         List<Long> delSkuIds = mallGoodsUpdateDto.getDelSkuId();
@@ -419,6 +525,10 @@
                     if (ObjectUtil.isEmpty(mallGoodsStyleSku)) {
                         styles.add(addStyleDto.getStyleName());
                     }
+                }else{
+                    MallGoodsStyle mallGoodsStyle = mallGoodsStyleMapper.selectById(addStyleDto.getStyleId());
+                    mallGoodsStyle.setName(addStyleDto.getStyleName());
+                    mallGoodsStyleMapper.updateById(mallGoodsStyle);
                 }
             }
         }
@@ -443,9 +553,14 @@
                         mallGoodsSku.setSkuVolume(addMallGoodsSkuDto.getSkuVolume() == null ? 0 : addMallGoodsSkuDto.getSkuVolume());
                         mallGoodsSku.setOriginalPrice(addMallGoodsSkuDto.getOriginalPrice());
                         mallGoodsSku.setPresentPrice(addMallGoodsSkuDto.getPresentPrice());
+                        mallGoodsSku.setCostPrice(addMallGoodsSkuDto.getCostPrice());
+                        mallGoodsSku.setLevelOnePrice(addMallGoodsSkuDto.getPresentPrice());
+                        mallGoodsSku.setLevelTwoPrice(addMallGoodsSkuDto.getPresentPrice());
+                        mallGoodsSku.setLevelThreePrice(addMallGoodsSkuDto.getPresentPrice());
                         mallGoodsSku.setStyleId(addMallGoodsSkuDto.getStyleId());
                         mallGoodsSku.setGoodsId(mallGoods.getId());
-                        mallGoodsSku.setCostPrice(addMallGoodsSkuDto.getCostPrice());
+                        mallGoodsSku.setGoodsWeight(addMallGoodsSkuDto.getGoodsWeight());
+                        mallGoodsSku.setSample(addMallGoodsSkuDto.getSample());
                         mallGoodsSkuMapper.updateById(mallGoodsSku);
                     } else {
                         //新增商品规格
@@ -457,9 +572,14 @@
                         mallGoodsSku.setSkuVolume(addMallGoodsSkuDto.getSkuVolume() == null ? 0 : addMallGoodsSkuDto.getSkuVolume());
                         mallGoodsSku.setOriginalPrice(addMallGoodsSkuDto.getOriginalPrice());
                         mallGoodsSku.setPresentPrice(addMallGoodsSkuDto.getPresentPrice());
-                        mallGoodsSku.setStyleId(mallGoodsStyleSku.getId());
                         mallGoodsSku.setCostPrice(addMallGoodsSkuDto.getCostPrice());
+                        mallGoodsSku.setLevelOnePrice(addMallGoodsSkuDto.getPresentPrice());
+                        mallGoodsSku.setLevelTwoPrice(addMallGoodsSkuDto.getPresentPrice());
+                        mallGoodsSku.setLevelThreePrice(addMallGoodsSkuDto.getPresentPrice());
+                        mallGoodsSku.setStyleId(mallGoodsStyleSku.getId());
                         mallGoodsSku.setGoodsId(mallGoods.getId());
+                        mallGoodsSku.setGoodsWeight(addMallGoodsSkuDto.getGoodsWeight());
+                        mallGoodsSku.setSample(addMallGoodsSkuDto.getSample());
                         mallGoodsSkuMapper.insert(mallGoodsSku);
                     }
                 }
@@ -473,5 +593,434 @@
         return mallGoodsMapper.getAllGoodsTree();
     }
 
+    @Override
+    public FebsResponse goodsHot(Long id) {
+        MallGoods mallGoods = mallGoodsMapper.selectById(id);
+        if (ObjectUtil.isEmpty(mallGoods)) {
+            return new FebsResponse().fail().message("商品不存在,请刷新当前页面");
+        }
+        mallGoods.setIsHot(MallGoods.ISHOT_STATE_YES);
+        mallGoodsMapper.updateById(mallGoods);
+        return new FebsResponse().success();
+    }
 
+    @Override
+    public FebsResponse goodsNotHot(Long id) {
+        MallGoods mallGoods = mallGoodsMapper.selectById(id);
+        if (ObjectUtil.isEmpty(mallGoods)) {
+            return new FebsResponse().fail().message("商品不存在,请刷新当前页面");
+        }
+        mallGoods.setIsHot(MallGoods.ISHOT_STATE_NO);
+        mallGoodsMapper.updateById(mallGoods);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public IPage<AdminHomeDeliverySettingVo> getDeliveryHomeListInPage(AdminHomeDeliverySettingVo adminHomeDeliverySetting, QueryRequest request) {
+        Page<DataDictionaryCustom> page = new Page<>(request.getPageNum(), request.getPageSize());
+        IPage<DataDictionaryCustom> dataDictionaryCustomIPage = this.baseMapper.getDeliveryHomeListInPage(page, adminHomeDeliverySetting);
+        List<DataDictionaryCustom> records = dataDictionaryCustomIPage.getRecords();
+        List<AdminHomeDeliverySettingVo> adminHomeDeliverySettingVos = new ArrayList<>();
+        if(CollUtil.isNotEmpty(records)){
+            for(DataDictionaryCustom dataDictionaryCustom : records){
+                AdminHomeDeliverySettingVo adminHomeDeliverySettingVo = JSONUtil.toBean(dataDictionaryCustom.getValue(), AdminHomeDeliverySettingVo.class);
+                adminHomeDeliverySettingVo.setId(dataDictionaryCustom.getId());
+                adminHomeDeliverySettingVos.add(adminHomeDeliverySettingVo);
+            }
+        }
+        IPage<AdminHomeDeliverySettingVo> adminHomeDeliverySettingVoIPage = new Page<>();
+        adminHomeDeliverySettingVoIPage.setRecords(adminHomeDeliverySettingVos);
+        adminHomeDeliverySettingVoIPage.setTotal(dataDictionaryCustomIPage.getTotal());
+        return adminHomeDeliverySettingVoIPage;
+    }
+
+
+    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
+    @Override
+    public FebsResponse deliveryHomeUpdate(AdminHomeDeliverySettingVo adminHomeDeliverySettingVo) {
+        DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectById(adminHomeDeliverySettingVo.getId());
+        adminHomeDeliverySettingVo.setId(null);
+        dataDictionaryCustom.setValue(JSONUtil.toJsonStr(adminHomeDeliverySettingVo));
+        dataDictionaryCustomMapper.updateById(dataDictionaryCustom);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public IPage<MallCarriageRule> getMallCarriageRuleListInPage(MallCarriageRule mallCarriageRule, QueryRequest request) {
+        Page<MallCarriageRule> page = new Page<>(request.getPageNum(), request.getPageSize());
+        IPage<MallCarriageRule> mallCarriageRules = mallCarriageRuleMapper.selectMallCarriageRuleListInPage(page, mallCarriageRule);
+        return mallCarriageRules;
+    }
+
+    @Override
+    @Transactional
+    public FebsResponse carriageRuleDelById(Long id) {
+        MallCarriageRule mallCarriageRule = mallCarriageRuleMapper.selectById(id);
+        if(ObjectUtil.isEmpty(mallCarriageRule)){
+            return new FebsResponse().fail().message("操作失败");
+        }
+        List<MallGoods> mallGoods = this.baseMapper.selectMallGoodsListQueryByRuleId(id);
+        if(CollUtil.isNotEmpty(mallGoods)){
+            StringBuffer goodsNameBuffer = new StringBuffer();
+            for(MallGoods goods : mallGoods){
+                goodsNameBuffer.append(goods.getGoodsName());
+                goodsNameBuffer.append(",");
+            }
+            return new FebsResponse().fail().message(goodsNameBuffer+"正在使用当前模板,请先编辑商品信息");
+        }
+        QueryWrapper<MallCarriageRuleInfo> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("rule_id",id);
+        mallCarriageRuleInfoMapper.delete(objectQueryWrapper);
+
+        mallCarriageRuleMapper.deleteById(id);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    @Transactional
+    public FebsResponse carriageRuleAdd(AdminCarriageRuleAddDto adminCarriageRuleAddDto) {
+        String ruleName = adminCarriageRuleAddDto.getRuleName();
+        QueryWrapper<MallCarriageRule> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("name",ruleName);
+        List<MallCarriageRule> mallCarriageRules = mallCarriageRuleMapper.selectList(objectQueryWrapper);
+        if(CollUtil.isNotEmpty(mallCarriageRules)){
+            return new FebsResponse().fail().message("标题不能重复");
+        }
+
+        MallCarriageRule mallCarriageRule = new MallCarriageRule();
+        mallCarriageRule.setName(ruleName);
+        mallCarriageRuleMapper.insert(mallCarriageRule);
+
+        Long ruleId = mallCarriageRule.getId();
+        /**
+         * 生成默认的运费规则
+         */
+        MallCarriageRuleInfo mallCarriageRuleInfoDefault = new MallCarriageRuleInfo();
+        mallCarriageRuleInfoDefault.setRuleId(ruleId);
+        //计价方式(1:按件算 2:按重量算)
+        mallCarriageRuleInfoDefault.setValuationType(adminCarriageRuleAddDto.getValuationType());
+        mallCarriageRuleInfoDefault.setValuationUnit(
+                adminCarriageRuleAddDto.getValuationType() == 1?"件":"千克"
+        );
+        mallCarriageRuleInfoDefault.setBasicCnt(adminCarriageRuleAddDto.getBasicCntDefault());
+        mallCarriageRuleInfoDefault.setBasicPrice(adminCarriageRuleAddDto.getBasicPriceDefault());
+        mallCarriageRuleInfoDefault.setMoreCnt(adminCarriageRuleAddDto.getMoreCntDefault());
+        mallCarriageRuleInfoDefault.setMorePrice(adminCarriageRuleAddDto.getMorePriceDefault());
+        mallCarriageRuleInfoMapper.insert(mallCarriageRuleInfoDefault);
+
+        List<AdminCarriageRuleAddInfoDto> adminCarriageRuleAddInfoDtos = adminCarriageRuleAddDto.getAdminCarriageRuleAddInfoDtos();
+        if(CollUtil.isNotEmpty(adminCarriageRuleAddInfoDtos)){
+            for(AdminCarriageRuleAddInfoDto adminCarriageRuleAddInfoDto : adminCarriageRuleAddInfoDtos){
+                MallCarriageRuleInfo mallCarriageRuleInfo = new MallCarriageRuleInfo();
+                mallCarriageRuleInfo.setRuleId(ruleId);
+                mallCarriageRuleInfo.setAreaAddress(adminCarriageRuleAddInfoDto.getAreaAddress());
+                //计价方式(1:按件算 2:按重量算)
+                mallCarriageRuleInfo.setValuationType(adminCarriageRuleAddDto.getValuationType());
+                mallCarriageRuleInfo.setValuationUnit(
+                        adminCarriageRuleAddDto.getValuationType() == 1?"件":"千克"
+                );
+                mallCarriageRuleInfo.setBasicCnt(adminCarriageRuleAddInfoDto.getBasicCnt());
+                mallCarriageRuleInfo.setBasicPrice(adminCarriageRuleAddInfoDto.getBasicPrice());
+                mallCarriageRuleInfo.setMoreCnt(adminCarriageRuleAddInfoDto.getMoreCnt());
+                mallCarriageRuleInfo.setMorePrice(adminCarriageRuleAddInfoDto.getMorePrice());
+                mallCarriageRuleInfoMapper.insert(mallCarriageRuleInfo);
+            }
+        }
+        return new FebsResponse().success().message("操作成功");
+    }
+
+    @Override
+    public AdminMallCarriageRuleVo selectCarriageRuleByRuleId(long id) {
+        AdminMallCarriageRuleVo adminMallCarriageRuleVo = new AdminMallCarriageRuleVo();
+
+        MallCarriageRule mallCarriageRule = mallCarriageRuleMapper.selectById(id);
+        adminMallCarriageRuleVo.setId(id);
+        adminMallCarriageRuleVo.setRuleName(mallCarriageRule.getName());
+
+        List<MallCarriageRuleInfo> mallCarriageRuleInfos = mallCarriageRuleInfoMapper.selectMallCarriageRuleInfoByRuleIdAndAreaAddress(id,null);
+        if(CollUtil.isNotEmpty(mallCarriageRuleInfos)){
+            StringBuffer areaAddressStr = new StringBuffer();
+            List<AdminMallCarriageRuleInfoVo> adminCarriageRuleInfoVos = new ArrayList<>();
+            for(MallCarriageRuleInfo mallCarriageRuleInfo : mallCarriageRuleInfos){
+                if(StrUtil.isNotEmpty(mallCarriageRuleInfo.getAreaAddress())){
+                    AdminMallCarriageRuleInfoVo adminMallCarriageRuleInfoVo = new AdminMallCarriageRuleInfoVo();
+                    adminMallCarriageRuleInfoVo.setId(mallCarriageRuleInfo.getId());
+                    adminMallCarriageRuleInfoVo.setAreaAddress(mallCarriageRuleInfo.getAreaAddress());
+                    adminMallCarriageRuleInfoVo.setBasicCnt(mallCarriageRuleInfo.getBasicCnt());
+                    adminMallCarriageRuleInfoVo.setBasicPrice(mallCarriageRuleInfo.getBasicPrice());
+                    adminMallCarriageRuleInfoVo.setMoreCnt(mallCarriageRuleInfo.getMoreCnt());
+                    adminMallCarriageRuleInfoVo.setMorePrice(mallCarriageRuleInfo.getMorePrice());
+                    adminCarriageRuleInfoVos.add(adminMallCarriageRuleInfoVo);
+
+                    areaAddressStr.append(mallCarriageRuleInfo.getAreaAddress());
+                }else{
+                    //默认规则
+                    adminMallCarriageRuleVo.setBasicCntDefault(mallCarriageRuleInfo.getBasicCnt());
+                    adminMallCarriageRuleVo.setBasicPriceDefault(mallCarriageRuleInfo.getBasicPrice());
+                    adminMallCarriageRuleVo.setMoreCntDefault(mallCarriageRuleInfo.getMoreCnt());
+                    adminMallCarriageRuleVo.setMorePriceDefault(mallCarriageRuleInfo.getMorePrice());
+                    adminMallCarriageRuleVo.setValuationType(mallCarriageRuleInfo.getValuationType());
+                }
+            }
+            adminMallCarriageRuleVo.setAdminCarriageRuleInfoVos(adminCarriageRuleInfoVos);
+            adminMallCarriageRuleVo.setAreaAddressStr(areaAddressStr.toString());
+        }
+        return adminMallCarriageRuleVo;
+    }
+
+    @Override
+    @Transactional
+    public FebsResponse carriageRuleUpdate(AdminCarriageRuleUpdateDto adminCarriageRuleUpdateDto) {
+        Long id = adminCarriageRuleUpdateDto.getId();
+        MallCarriageRule mallCarriageRule = mallCarriageRuleMapper.selectById(id);
+        if(ObjectUtil.isEmpty(mallCarriageRule)){
+            return new FebsResponse().fail().message("运费模板不存在");
+        }
+
+        List<MallGoods> mallGoods = this.baseMapper.selectMallGoodsListQueryByRuleIdAndIsSale(id,MallGoods.ISHOT_STATE_YES);
+        if(CollUtil.isNotEmpty(mallGoods)){
+            StringBuffer goodsNameBuffer = new StringBuffer();
+            for(MallGoods goods : mallGoods){
+                goodsNameBuffer.append(goods.getGoodsName());
+                goodsNameBuffer.append(",");
+            }
+            return new FebsResponse().fail().message(goodsNameBuffer+"正在使用当前模板,请先下架商品");
+        }
+
+        mallCarriageRule.setName(adminCarriageRuleUpdateDto.getRuleName());
+        mallCarriageRuleMapper.updateById(mallCarriageRule);
+        //删除现有的所有运费模板子表数据
+        List<MallCarriageRuleInfo> mallCarriageRuleInfos = mallCarriageRuleInfoMapper.selectMallCarriageRuleInfoByRuleIdAndAreaAddress(id, null);
+        if(CollUtil.isNotEmpty(mallCarriageRuleInfos)){
+            for(MallCarriageRuleInfo mallCarriageRuleInfo : mallCarriageRuleInfos){
+                mallCarriageRuleInfoMapper.deleteById(mallCarriageRuleInfo.getId());
+            }
+        }
+
+        /**
+         * 生成运费模板子表数据
+         */
+        MallCarriageRuleInfo mallCarriageRuleInfoDefault = new MallCarriageRuleInfo();
+        mallCarriageRuleInfoDefault.setRuleId(id);
+        //计价方式(1:按件算 2:按重量算)
+        mallCarriageRuleInfoDefault.setValuationType(adminCarriageRuleUpdateDto.getValuationType());
+        mallCarriageRuleInfoDefault.setValuationUnit(
+                adminCarriageRuleUpdateDto.getValuationType() == 1?"件":"千克"
+        );
+        mallCarriageRuleInfoDefault.setBasicCnt(adminCarriageRuleUpdateDto.getBasicCntDefault());
+        mallCarriageRuleInfoDefault.setBasicPrice(adminCarriageRuleUpdateDto.getBasicPriceDefault());
+        mallCarriageRuleInfoDefault.setMoreCnt(adminCarriageRuleUpdateDto.getMoreCntDefault());
+        mallCarriageRuleInfoDefault.setMorePrice(adminCarriageRuleUpdateDto.getMorePriceDefault());
+        mallCarriageRuleInfoMapper.insert(mallCarriageRuleInfoDefault);
+
+        List<AdminCarriageRuleAddInfoDto> adminCarriageRuleAddInfoDtos = adminCarriageRuleUpdateDto.getAdminCarriageRuleAddInfoDtos();
+        if(CollUtil.isNotEmpty(adminCarriageRuleAddInfoDtos)){
+            for(AdminCarriageRuleAddInfoDto adminCarriageRuleAddInfoDto : adminCarriageRuleAddInfoDtos){
+                MallCarriageRuleInfo mallCarriageRuleInfo = new MallCarriageRuleInfo();
+                mallCarriageRuleInfo.setRuleId(id);
+                mallCarriageRuleInfo.setAreaAddress(adminCarriageRuleAddInfoDto.getAreaAddress());
+                //计价方式(1:按件算 2:按重量算)
+                mallCarriageRuleInfo.setValuationType(mallCarriageRuleInfoDefault.getValuationType());
+                mallCarriageRuleInfo.setValuationUnit(
+                        mallCarriageRuleInfoDefault.getValuationType() == 1?"件":"千克"
+                );
+                mallCarriageRuleInfo.setBasicCnt(adminCarriageRuleAddInfoDto.getBasicCnt());
+                mallCarriageRuleInfo.setBasicPrice(adminCarriageRuleAddInfoDto.getBasicPrice());
+                mallCarriageRuleInfo.setMoreCnt(adminCarriageRuleAddInfoDto.getMoreCnt());
+                mallCarriageRuleInfo.setMorePrice(adminCarriageRuleAddInfoDto.getMorePrice());
+                mallCarriageRuleInfoMapper.insert(mallCarriageRuleInfo);
+            }
+        }
+
+        return new FebsResponse().success().message("操作成功");
+    }
+
+    @Override
+    public List<MallCarriageRule> findAllCarriageRuleTree() {
+        List<MallCarriageRule> mallCarriageRules = mallCarriageRuleMapper.selectList(new QueryWrapper<>());
+        return mallCarriageRules;
+    }
+
+    @Override
+    public IPage<MallGoodsCoupon> getMallGoodsCouponListInPage(MallGoodsCoupon mallGoodsCoupon, QueryRequest request) {
+        Page<MallGoodsCoupon> page = new Page<>(request.getPageNum(), request.getPageSize());
+        IPage<MallGoodsCoupon> mallGoodsCouponIPage = mallGoodsCouponMapper.selectMallGoodsCouponListInPage(page, mallGoodsCoupon);
+        return mallGoodsCouponIPage;
+    }
+
+    @Override
+    public FebsResponse couponRuleAdd(CouponRuleAddDto couponRuleAddDto) {
+        String name = couponRuleAddDto.getName();
+        QueryWrapper<MallGoodsCoupon> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("name",name);
+        List<MallGoodsCoupon> mallGoodsCoupons = mallGoodsCouponMapper.selectList(objectQueryWrapper);
+        if(CollUtil.isNotEmpty(mallGoodsCoupons)){
+            return new FebsResponse().fail().message("名称不能重复");
+        }
+
+        MallGoodsCoupon mallGoodsCoupon = new MallGoodsCoupon();
+        mallGoodsCoupon.setName(name);
+        mallGoodsCoupon.setExpireDay(couponRuleAddDto.getExpireDay());
+        mallGoodsCoupon.setCostAmount(couponRuleAddDto.getCostAmount());
+        mallGoodsCoupon.setType(couponRuleAddDto.getType());
+        mallGoodsCoupon.setRealAmount(couponRuleAddDto.getRealAmount());
+        mallGoodsCouponMapper.insert(mallGoodsCoupon);
+
+        Long couponId = mallGoodsCoupon.getId();
+        QueryWrapper<CouponGoods> objectQueryWrapperCoupon = new QueryWrapper<>();
+        objectQueryWrapperCoupon.eq("coupon_id",couponId);
+        List<CouponGoods> couponGoodsList = couponGoodsMapper.selectList(objectQueryWrapperCoupon);
+        if(CollUtil.isNotEmpty(couponGoodsList)){
+            for(CouponGoods couponGoods : couponGoodsList){
+                couponGoodsMapper.deleteById(couponGoods);
+            }
+        }
+        if(CollUtil.isNotEmpty(couponRuleAddDto.getGoodsIds())){
+            List<Long> goodsIds = couponRuleAddDto.getGoodsIds();
+            for(Long goodsId : goodsIds){
+                CouponGoods couponGoods = new CouponGoods();
+                couponGoods.setGoodsId(goodsId);
+                couponGoods.setCouponId(couponId);
+                couponGoodsMapper.insert(couponGoods);
+            }
+        }
+        return new FebsResponse().success().message("操作成功");
+    }
+
+    @Override
+    public FebsResponse couponRuleDel(Long id) {
+        MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(id);
+        if (ObjectUtil.isEmpty(mallGoodsCoupon)) {
+            return new FebsResponse().fail().message("优惠卷不存在,请刷新当前页面");
+        }
+        Integer state = mallGoodsCoupon.getState();
+        if(2 == state){
+            return new FebsResponse().fail().message("请先下架优惠卷");
+        }
+        mallGoodsCouponMapper.deleteById(id);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse upCoupon(Long id) {
+        MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(id);
+        if (ObjectUtil.isEmpty(mallGoodsCoupon)) {
+            return new FebsResponse().fail().message("优惠卷不存在,请刷新当前页面");
+        }
+        mallGoodsCoupon.setState(2);
+        mallGoodsCouponMapper.updateById(mallGoodsCoupon);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse downCoupon(Long id) {
+        MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(id);
+        if (ObjectUtil.isEmpty(mallGoodsCoupon)) {
+            return new FebsResponse().fail().message("优惠卷不存在,请刷新当前页面");
+        }
+        mallGoodsCoupon.setState(1);
+        mallGoodsCouponMapper.updateById(mallGoodsCoupon);
+        return new FebsResponse().success().message("操作成功");
+    }
+
+    @Override
+    public AdminMallGoodsCouponVo selectGoodsCouponById(long id) {
+        List<Long> goodsIds = couponGoodsMapper.selectByCouponId(id);
+        AdminMallGoodsCouponVo adminMallGoodsCouponVo = mallGoodsCouponMapper.selectGoodsCouponById(id);
+        adminMallGoodsCouponVo.setGoodsIds(goodsIds);
+        return adminMallGoodsCouponVo;
+    }
+
+    @Override
+    public FebsResponse couponUpdate(AdminMallGoodsCouponVo adminMallGoodsCouponVo) {
+        Long id = adminMallGoodsCouponVo.getId();
+        MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(id);
+        if (ObjectUtil.isEmpty(mallGoodsCoupon)) {
+            return new FebsResponse().fail().message("优惠卷不存在,请刷新当前页面");
+        }
+        Integer state = mallGoodsCoupon.getState();
+        if(2 == state){
+            return new FebsResponse().fail().message("请先下架优惠卷");
+        }
+        mallGoodsCoupon.setName(adminMallGoodsCouponVo.getName());
+        mallGoodsCoupon.setExpireDay(adminMallGoodsCouponVo.getExpireDay());
+        mallGoodsCoupon.setCostAmount(adminMallGoodsCouponVo.getCostAmount());
+        mallGoodsCoupon.setType(adminMallGoodsCouponVo.getType());
+        mallGoodsCoupon.setRealAmount(adminMallGoodsCouponVo.getRealAmount());
+        mallGoodsCouponMapper.updateById(mallGoodsCoupon);
+
+        Long couponId = mallGoodsCoupon.getId();
+        QueryWrapper<CouponGoods> objectQueryWrapperCoupon = new QueryWrapper<>();
+        objectQueryWrapperCoupon.eq("coupon_id",couponId);
+        List<CouponGoods> couponGoodsList = couponGoodsMapper.selectList(objectQueryWrapperCoupon);
+        if(CollUtil.isNotEmpty(couponGoodsList)){
+            for(CouponGoods couponGoods : couponGoodsList){
+                couponGoodsMapper.deleteById(couponGoods);
+            }
+        }
+        if(CollUtil.isNotEmpty(adminMallGoodsCouponVo.getGoodsIds())){
+            List<Long> goodsIds = adminMallGoodsCouponVo.getGoodsIds();
+            for(Long goodsId : goodsIds){
+                CouponGoods couponGoods = new CouponGoods();
+                couponGoods.setGoodsId(goodsId);
+                couponGoods.setCouponId(couponId);
+                couponGoodsMapper.insert(couponGoods);
+            }
+        }
+        return new FebsResponse().success().message("操作成功");
+    }
+
+    @Override
+    public List<AdminMallGoodsCouponTreeVo> findAdminMallGoodsCouponVoTree() {
+        QueryWrapper<MallGoodsCoupon> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("state",2);
+        List<MallGoodsCoupon> mallGoodsCoupons = mallGoodsCouponMapper.selectList(objectQueryWrapper);
+
+        List<AdminMallGoodsCouponTreeVo> objects = new ArrayList<>();
+        if(CollUtil.isNotEmpty(mallGoodsCoupons)){
+            for(MallGoodsCoupon mallGoodsCoupon : mallGoodsCoupons){
+                AdminMallGoodsCouponTreeVo adminMallGoodsCouponTreeVo = new AdminMallGoodsCouponTreeVo();
+                adminMallGoodsCouponTreeVo.setCouponId(mallGoodsCoupon.getId());
+                adminMallGoodsCouponTreeVo.setCouponName(mallGoodsCoupon.getName());
+                objects.add(adminMallGoodsCouponTreeVo);
+            }
+        }
+        return objects;
+    }
+
+    @Override
+    public List<AdminMallGoodsCouponTreeListVo> findAdminMallGoodsCouponVoTreeList() {
+        QueryWrapper<MallGoodsCoupon> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("state",2);
+        List<MallGoodsCoupon> mallGoodsCoupons = mallGoodsCouponMapper.selectList(objectQueryWrapper);
+
+        List<AdminMallGoodsCouponTreeListVo> objects = new ArrayList<>();
+        if(CollUtil.isNotEmpty(mallGoodsCoupons)){
+            for(MallGoodsCoupon mallGoodsCoupon : mallGoodsCoupons){
+                AdminMallGoodsCouponTreeListVo adminMallGoodsCouponTreeListVo = new AdminMallGoodsCouponTreeListVo();
+                adminMallGoodsCouponTreeListVo.setId(mallGoodsCoupon.getId());
+                adminMallGoodsCouponTreeListVo.setName(mallGoodsCoupon.getName());
+                objects.add(adminMallGoodsCouponTreeListVo);
+            }
+        }
+        return objects;
+    }
+
+    @Override
+    public List<AdminMallGoodsCouponTreeListVo> findAdminMallGoodsVoTreeList() {
+        QueryWrapper<MallGoods> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("is_sale",1);
+        List<MallGoods> mallGoodsList = mallGoodsMapper.selectList(objectQueryWrapper);
+
+        List<AdminMallGoodsCouponTreeListVo> objects = new ArrayList<>();
+        if(CollUtil.isNotEmpty(mallGoodsList)){
+            for(MallGoods mallGoods : mallGoodsList){
+                AdminMallGoodsCouponTreeListVo adminMallGoodsCouponTreeListVo = new AdminMallGoodsCouponTreeListVo();
+                adminMallGoodsCouponTreeListVo.setId(mallGoods.getId());
+                adminMallGoodsCouponTreeListVo.setName(mallGoods.getGoodsName());
+                objects.add(adminMallGoodsCouponTreeListVo);
+            }
+        }
+        return objects;
+    }
 }

--
Gitblit v1.9.1