统一分销比例变更记录

netflix-dao/src/main/java/com/cyksj/mapper/manage/distribute/UserDistributeMapper.java

@@ -41,4 +41,8 @@ public interface UserDistributeMapper extends BaseMapper<UserDistribute> {
 	List<UserDistribute> selectNoSetGoodsRateDistirbutors(Long goodsId);
 
 	List<UserDistribute> selectNoSetGoodsSkuRateDistirbutors(Long skuId);
+
+	List<UserDistribute> selectGoodsRateDistributors(@Param("goodsId") Long goodsId, @Param("rate") Integer rate);
+
+	List<UserDistribute> selectSkuRateDistributors(@Param("skuId") Long skuId, @Param("rate") Integer rate);
 }

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

@@ -131,4 +131,18 @@
                  left join user_plat_sku_distribute_rate ur on ur.distribute_id = ud.id and ur.sku_id = #{skuId}
         where ur.id is null
     </select>
+
+    <select id="selectGoodsRateDistributors" resultType="com.cyksj.model.entity.UserDistribute">
+        select ud.*
+        from (select id,user_id from user_distribute where deleted) ud
+                 inner join user_plat_distribute_rate ur on ur.distribute_id = ud.id and ur.goods_id = #{goodsId}
+        and ur.rate != #{rate}
+    </select>
+
+    <select id="selectSkuRateDistributors" resultType="com.cyksj.model.entity.UserDistribute">
+        select ud.*
+        from (select id,user_id from user_distribute where deleted) ud
+                 inner join user_plat_sku_distribute_rate ur on ur.distribute_id = ud.id and ur.sku_id = #{skuId}
+        and ur.rate != #{rate}
+    </select>
 </mapper>

netflix-service/src/main/java/com/cyksj/service/distribute/UserDistributeRateChangeRecordService.java

@@ -18,4 +18,8 @@ public interface UserDistributeRateChangeRecordService extends IService<UserDist
 	void recordDefaultGoodsSkuRate(Long goodsId, Long skuId, Integer rate);
 
 	void recordDefaultGoodsSkuDelRate(List<BusinessDistributeDefaultSkuRateConfig> delLists);
+
+	void unifiedSetDsRate(Long goodsId, Integer rate);
+
+	void unifiedSetDsSkuRate(Long skuId, Integer rate);
 }

netflix-service/src/main/java/com/cyksj/service/distribute/impl/UserDistributeRateChangeRecordServiceImpl.java

@@ -1,16 +1,21 @@
 package com.cyksj.service.distribute.impl;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.cyksj.mapper.GoodsDonMapper;
 import com.cyksj.mapper.GoodsDonSkuMapper;
 import com.cyksj.mapper.UserDistributeRateChangeRecordMapper;
 import com.cyksj.mapper.manage.distribute.UserDistributeMapper;
+import com.cyksj.mapper.manage.distribute.UserPlatDistributeRateMapper;
+import com.cyksj.mapper.manage.distribute.UserPlatSkuDistributeRateMapper;
 import com.cyksj.model.entity.*;
 import com.cyksj.service.distribute.UserDistributeRateChangeRecordService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 项目名: yhlxj11111111
@@ -29,6 +34,10 @@ public class UserDistributeRateChangeRecordServiceImpl extends ServiceImpl<UserD
 
 	private final GoodsDonSkuMapper skuMapper;
 
+	private final UserPlatDistributeRateMapper userPlatDistributeRateMapper;
+
+	private final UserPlatSkuDistributeRateMapper userPlatSkuDistributeRateMapper;
+
 	@Override
 	public void recordDefaultGoodsRate(Long goodsId, Integer rate) {
 		List<UserDistribute> userDistributeList = userDistributeMapper.selectNoSetGoodsRateDistirbutors(goodsId);
@@ -67,4 +76,45 @@ public class UserDistributeRateChangeRecordServiceImpl extends ServiceImpl<UserD
 			userDistributeRateChangeRecordMapper.batchInsertGoodsRateChangeNoSetSkuRecord(userDistributeList, goodsId, skuId, changeInfo);
 		}
 	}
+
+	@Override
+	@Transactional(rollbackFor = Throwable.class)
+	public void unifiedSetDsRate(Long goodsId, Integer rate) {
+		List<UserDistribute> userDistributeList = userDistributeMapper.selectGoodsRateDistributors(goodsId, rate);
+		if (userDistributeList.isEmpty()) {
+			return;
+		}
+		GoodsDon goodsDon = goodsDonMapper.selectById(goodsId);
+		String changeInfo = String.format("%s全规格分销比例变为%s%%", goodsDon.getTitle(), rate);
+		userDistributeRateChangeRecordMapper.batchInsertGoodsRateChangeRecord(userDistributeList, goodsId, null, changeInfo, rate);
+
+		List<Long> distributors = userDistributeList.stream().map(UserDistribute::getId).collect(Collectors.toList());
+		userPlatDistributeRateMapper.update(null, Wrappers.lambdaUpdate(UserPlatDistributeRate.class)
+				.set(UserPlatDistributeRate::getRate, rate)
+				.in(UserPlatDistributeRate::getDistributeId, distributors)
+				.eq(UserPlatDistributeRate::getGoodsId, goodsId)
+				.ne(UserPlatDistributeRate::getRate, rate));
+	}
+
+	@Override
+	@Transactional(rollbackFor = Throwable.class)
+	public void unifiedSetDsSkuRate(Long skuId, Integer rate) {
+		GoodsDonSku sku = skuMapper.selectById(skuId);
+		List<UserDistribute> userDistributeList = userDistributeMapper.selectSkuRateDistributors(skuId, rate);
+		if (userDistributeList.isEmpty()) {
+			return;
+		}
+		Long goodsId = sku.getGoodsId();
+		GoodsDon goodsDon = goodsDonMapper.selectById(goodsId);
+		String changeInfo = String.format("%s%s规格分销比例变为%s%%", goodsDon.getTitle(), sku.getSpecVal(), rate);
+		userDistributeRateChangeRecordMapper.batchInsertGoodsRateChangeRecord(userDistributeList, goodsId, skuId, changeInfo, rate);
+
+		List<Long> distributors = userDistributeList.stream().map(UserDistribute::getId).collect(Collectors.toList());
+		userPlatSkuDistributeRateMapper.update(null, Wrappers.lambdaUpdate(UserPlatSkuDistributeRate.class)
+				.set(UserPlatSkuDistributeRate::getRate, rate)
+				.in(UserPlatSkuDistributeRate::getDistributeId, distributors)
+				.eq(UserPlatSkuDistributeRate::getGoodsId, goodsId)
+				.eq(UserPlatSkuDistributeRate::getSkuId, skuId)
+				.ne(UserPlatSkuDistributeRate::getRate, rate));
+	}
 }

netflix-web/src/main/java/com/cyksj/web/controller/manage/distribute/DistributeController.java

@@ -1382,4 +1382,35 @@ public class DistributeController {
 		});
 		return GatewayResponse.SUCCESS.newBuilder().toResult(search);
 	}
+
+	/**
+	 * 固定渠道
+	 * 已有平台分销比例 统一编辑比例
+	 */
+	@PutMapping("/unified/set/ds/rate")
+	public Result<String> unifiedSetDsRate(Map<String, Object> params) {
+		Long goodsId = (Long) params.get("goodsId");
+		Integer rate = (Integer) params.get("rate");
+		if (rate < 0 || rate > 30) {
+			return GatewayResponse.SUCCESS.newBuilder().toResult();
+		}
+		changeRecordService.unifiedSetDsRate(goodsId, rate);
+		return GatewayResponse.SUCCESS.newBuilder().toResult();
+	}
+
+
+	/**
+	 * 固定渠道
+	 * 已有平台规格分销比例 统一编辑规格比例
+	 */
+	@PutMapping("/unified/set/ds/sku/rate")
+	public Result<String> unifiedSetDsSkuRate(Map<String, Object> params) {
+		Long skuId = (Long) params.get("skuId");
+		Integer rate = (Integer) params.get("rate");
+		if (rate < 0 || rate > 30) {
+			return GatewayResponse.SUCCESS.newBuilder().toResult();
+		}
+		changeRecordService.unifiedSetDsSkuRate(skuId, rate);
+		return GatewayResponse.SUCCESS.newBuilder().toResult();
+	}
 }