diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/product/ProductEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/product/ProductEventHandler.java index 51978f0..8813756 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/product/ProductEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/product/ProductEventHandler.java @@ -1,5 +1,6 @@ package com.qniao.dam.application.handler.product; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.qniao.dam.application.service.product.ProductApplicationService; import com.qniao.dam.domain.aggregate.externalproduct.valueobj.ExternalProductRel; import com.qniao.dam.domain.aggregate.product.entity.Product; @@ -71,6 +72,7 @@ public class ProductEventHandler extends BaseApplicationService { siteActivityWomanProduct.setStatus(ProductStatusEnum.SOLD_OUTED); siteActivityWomanProduct.setProductSpecList(Collections.singletonList(siteActivityWomanProductSpec)); list.add(siteActivityWomanProduct); + externalProductRelDao.delete(new LambdaQueryWrapper().eq(ExternalProductRel::getExternalId, event.getSiteActivityId())); for (Product product : list) { productApplicationService.create(product, product.getProductSpecList()); ExternalProductRel externalProductRel = ExternalProductRel.build(event.getSiteActivityId(), product.getId());