zoujiajian 2 жил өмнө
parent
commit
274f1c4f97

+ 8 - 0
netflix-service/src/main/java/com/cyksj/service/distribute/impl/DistributeServiceImpl.java

@@ -258,6 +258,11 @@ public class DistributeServiceImpl implements DistributeService {
 		//特殊平台 按规格分销比例
 		List<UserPlatSkuDistributeRate> skuRates = userDistributeReq.getSkuRates();
 		if (CollUtil.isNotEmpty(skuRates)) {
+			List<Long> skuIds = skuRates.stream().map(UserPlatSkuDistributeRate::getSkuId).collect(Collectors.toList());
+			userPlatSkuDistributeRateMapper.delete(Wrappers.lambdaQuery(UserPlatSkuDistributeRate.class)
+					.notIn(UserPlatSkuDistributeRate::getSkuId, skuIds)
+					.eq(UserPlatSkuDistributeRate::getDistributeId, userDistribute.getId()));
+
 			Map<Long, GoodsDon> map = new ConcurrentHashMap<>();
 			for (UserPlatSkuDistributeRate skuRate : skuRates) {
 				if (skuRate.getRate() == null) {
@@ -287,6 +292,9 @@ public class DistributeServiceImpl implements DistributeService {
 				} catch (DuplicateKeyException e) {
 				}
 			}
+		} else {
+			userPlatSkuDistributeRateMapper.delete(Wrappers.lambdaQuery(UserPlatSkuDistributeRate.class)
+					.eq(UserPlatSkuDistributeRate::getDistributeId, userDistribute.getId()));
 		}
 		handlerDistributeOtherFunc(userDistribute, userDistributeReq);
 	}