|
|
|
@ -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<Long,List<ActivityProduct>> listMap = activity.getActivityProductList().stream().collect(Collectors.groupingBy(ActivityProduct::getProductId)); |
|
|
|
listMap.forEach((k,v)->{ |
|
|
|
if(v.size() > 1){ |
|
|
|
throw new BizException("请不要添加相同产品"); |
|
|
|
} |
|
|
|
}); |
|
|
|
return aggregate.saveActivity(activity); |
|
|
|
} |
|
|
|
|
|
|
|
|