diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/activity/ActivityApplicationService.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/activity/ActivityApplicationService.java index aeccc3e..f04c9e2 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/activity/ActivityApplicationService.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/activity/ActivityApplicationService.java @@ -14,6 +14,7 @@ import com.qniao.dam.infrastructure.persistent.dao.activity.ActivityProductDao; import com.qniao.dam.infrastructure.persistent.dao.view.ProductViewDao; import com.qniao.domain.BaseApplicationService; import com.qniao.domain.QnPage; +import com.qniao.framework.exception.BizException; import com.qniao.framework.utils.PageUtil; import com.qniao.framework.utils.TypeConvertUtils; import lombok.extern.slf4j.Slf4j; @@ -43,6 +44,12 @@ public class ActivityApplicationService extends BaseApplicationService { private ActivityProductDao activityProductDao; public String saveActivity(Activity activity){ + Map> listMap = activity.getActivityProductList().stream().collect(Collectors.groupingBy(ActivityProduct::getProductId)); + listMap.forEach((k,v)->{ + if(v.size() > 1){ + throw new BizException("请不要添加相同产品"); + } + }); return aggregate.saveActivity(activity); }