fix

netflix-dao/src/main/java/com/cyksj/mapper/YhShopGeneralGoodsRateMapper.java

@@ -0,0 +1,18 @@
+package com.cyksj.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.YhShopGeneralGoodsRate;
+import com.cyksj.model.request.ShopGeneralGoodsRate;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/*
+ *项目名: yhlxj
+ *文件名: YhShopGeneralGoodsRateMapper
+ *创建者: JavaZou
+ *创建时间:2023/9/15 17:35
+ */
+public interface YhShopGeneralGoodsRateMapper extends BaseMapper<YhShopGeneralGoodsRate> {
+	void saveOrUpdateBatch(@Param("list") List<ShopGeneralGoodsRate> saveShopGoodsRate);
+}

netflix-dao/src/main/java/com/cyksj/model/entity/YhShopGeneralGoodsRate.java

@@ -0,0 +1,18 @@
+package com.cyksj.model.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/*
+ *项目名: yhlxj
+ *文件名: YhShopGeneralGoodsRate
+ *创建者: JavaZou
+ *创建时间:2023/9/15 17:35
+ */
+@Getter
+@Setter
+public class YhShopGeneralGoodsRate extends BaseEntity{
+	private Long goodsId;
+
+	private Integer rate;
+}

netflix-dao/src/main/java/com/cyksj/model/request/ShopGeneralGoodsRate.java

@@ -0,0 +1,20 @@
+package com.cyksj.model.request;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/*
+ *项目名: yhlxj
+ *文件名: ShopGeneralGoodsRate
+ *创建者: JavaZou
+ *创建时间:2023/9/15 17:25
+ */
+@Getter
+@Setter
+public class ShopGeneralGoodsRate {
+	private Long id;
+
+	private Long goodsId;
+
+	private Integer rate;
+}

netflix-dao/src/main/resources/mapper/YhShopGeneralGoodsRateMapper.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.cyksj.mapper.YhShopGeneralGoodsRateMapper">
+    <insert id="saveOrUpdateBatch">
+        insert into yh_shop_general_goods_rate(`goods_id`,`rate`,`created_time`,`update_time`)
+        values
+        <foreach collection="list" item="entity" separator=",">
+            (#{entity.goodsId},#{entity.rate},now(),now())
+        </foreach>
+        ON DUPLICATE KEY update rate = values(rate),
+        update_time = values(update_time)
+    </insert>
+</mapper>

netflix-service/src/main/java/com/cyksj/service/mange/CmsYhShopCommonService.java

@@ -0,0 +1,15 @@
+package com.cyksj.service.mange;
+
+import com.cyksj.model.request.ShopGeneralGoodsRate;
+
+import java.util.List;
+
+/*
+ *项目名: yhlxj
+ *文件名: CmsYhShopCommonService
+ *创建者: JavaZou
+ *创建时间:2023/9/15 17:26
+ */
+public interface CmsYhShopCommonService {
+	void setGeneralGoodsRate(List<ShopGeneralGoodsRate> rates);
+}

netflix-service/src/main/java/com/cyksj/service/mange/goods/CmsYhShopCommonServiceImpl.java

@@ -0,0 +1,46 @@
+package com.cyksj.service.mange.goods;
+
+import cn.hutool.core.collection.CollUtil;
+import com.cyksj.mapper.GoodsDonMapper;
+import com.cyksj.mapper.YhShopGeneralGoodsRateMapper;
+import com.cyksj.model.entity.GoodsDon;
+import com.cyksj.model.request.ShopGeneralGoodsRate;
+import com.cyksj.service.mange.CmsYhShopCommonService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/*
+ *项目名: yhlxj
+ *文件名: CmsYhShopCommonServiceImpl
+ *创建者: JavaZou
+ *创建时间:2023/9/15 17:27
+ */
+@Service
+@RequiredArgsConstructor
+public class CmsYhShopCommonServiceImpl implements CmsYhShopCommonService {
+	private final GoodsDonMapper goodsDonMapper;
+
+	private final YhShopGeneralGoodsRateMapper yhShopGeneralGoodsRateMapper;
+
+	@Override
+	public void setGeneralGoodsRate(List<ShopGeneralGoodsRate> rates) {
+		List<ShopGeneralGoodsRate> saveShopGoodsRate = new ArrayList<>(rates.size());
+		rates.forEach(data -> {
+			Integer rate = data.getRate();
+			Long goodsId = data.getGoodsId();
+			if (goodsId != null && rate >= 0 && rate <= 100) {
+				GoodsDon goodsDon = goodsDonMapper.selectById(goodsId);
+				if (goodsDon != null) {
+					saveShopGoodsRate.add(data);
+				}
+			}
+		});
+
+		if (CollUtil.isNotEmpty(saveShopGoodsRate)) {
+			yhShopGeneralGoodsRateMapper.saveOrUpdateBatch(saveShopGoodsRate);
+		}
+	}
+}

netflix-web/src/main/java/com/cyksj/web/controller/manage/goods/CmsYhShopGoodsController.java

@@ -5,7 +5,9 @@ import com.cyksj.dto.Result;
 import com.cyksj.enums.GatewayResponse;
 import com.cyksj.model.entity.YhShopGoodsRate;
 import com.cyksj.model.request.GoodsDonShopRateReq;
+import com.cyksj.model.request.ShopGeneralGoodsRate;
 import com.cyksj.model.views.YhShopGoodsRateView;
+import com.cyksj.service.mange.CmsYhShopCommonService;
 import com.cyksj.service.mange.CmsYhShopGoodsRateService;
 import com.ejlchina.searcher.BeanSearcher;
 import com.ejlchina.searcher.SearchResult;
@@ -14,6 +16,8 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 
 /**
  * @author zwhui
@@ -29,6 +33,8 @@ public class CmsYhShopGoodsController {
 
     private final CmsYhShopGoodsRateService yhShopGoodsRateService;
 
+    private final CmsYhShopCommonService cmsYhShopCommonService;
+
 
     /**
      * 获取店铺平台价格
@@ -54,4 +60,13 @@ public class CmsYhShopGoodsController {
         }
         return GatewayResponse.SUCCESS.newBuilder().toResult();
     }
+
+    /**
+     * 店铺通用平台分销比例配置
+     */
+    @PutMapping("/set/general/goods/rate")
+    public Result<String> setGeneralGoodsRate(@RequestBody List<ShopGeneralGoodsRate> rates) {
+        cmsYhShopCommonService.setGeneralGoodsRate(rates);
+        return GatewayResponse.SUCCESS.newBuilder().toResult();
+    }
 }