添加产品下架时同步推荐产品的功能

src/main/java/com/uas/platform/b2c/advertise/ad/service/impl/RecommendProductServiceImpl.java

@@ -70,7 +70,7 @@ public class RecommendProductServiceImpl implements RecommendProductService {
 		message.setBatchCodes(batchCodes);
 		System.out.println(JacksonUtils.toJson(message));
 
-		String topic = "recommend-products-delete" + "-" + profile;
+		String topic = "recommend-products-delete" + "-" + ("prod".equals(profile) ? "prod" : "test");
 
 		kafkaTemplate.send(topic, "batchCode", JacksonUtils.toJson(message));
 	}

src/main/java/com/uas/platform/b2c/prod/commodity/service/impl/GoodsServiceImpl.java

@@ -1873,17 +1873,29 @@ public class GoodsServiceImpl implements GoodsService {
 		}
 		Set<String> uuids = new HashSet<>();
 		List<String> batchCodeList = new ArrayList<>();
+
+		String storeUuid = "";
+
 		for (String batchCode : batchCodeArr) {
 			ResultMap resultMap = offShelfOneGoodsByProvider(batchCode);
 			if (resultMap.isSuccess()) {
 				Goods goods = (Goods) resultMap.getData();
 				uuids.add(goods.getUuid());
 				batchCodeList.add(goods.getBatchCode());
+
+				storeUuid = goods.getStoreid();
 			}
 		}
 		for (String uuid : uuids) {
 			updateComponentTradeInfos(uuid);
 		}
+
+		if (!StringUtils.isEmpty(storeUuid)) {
+			List<String> list = Arrays.asList(batchCodeArr);
+			Set<String> batchCodeSet = new HashSet<>(list);
+			recommendProductService.deleteProductsWhenSellerUpdateReserve(storeUuid, batchCodeSet);
+		}
+
 		if (batchCodeList.size() == 0) {
 			return new ResultMap(CodeType.ERROR_STATE.code(), "下架商品失败");
 		} else {
@@ -1897,7 +1909,7 @@ public class GoodsServiceImpl implements GoodsService {
 	 * @param batchCode		商品批次号
 	 */
 	@Transactional
-	private ResultMap offShelfOneGoodsByProvider(String batchCode) {
+	public ResultMap offShelfOneGoodsByProvider(String batchCode) {
 		if (StringUtils.isEmpty(batchCode)) {
 			return new ResultMap(CodeType.NO_INFO.code(), "待下架批次号不能为空");
 		}