refactor

@@ -8,8 +8,6 @@ import com.yoho.tools.docs.ApiOperation;
 import com.yoho.tools.docs.ApiParam;
 import com.yoho.tools.docs.ApiResp;
 import com.yoho.tools.docs.ApiRespCode;
-import com.yohobuy.ufo.model.GoodsBO;
-import com.yohobuy.ufo.model.GoodsSize;
 import com.yohobuy.ufo.model.ProductInfo;
 import com.yohobuy.ufo.model.request.SeekToBuyStorageBo;
 import com.yohobuy.ufo.model.request.StoragePriceBo;
@@ -21,16 +19,12 @@ import com.yohobuy.ufo.model.response.StorageInfoResp;
 import com.yohobuy.ufo.model.response.StorageCheckResp;
 
 import com.yohoufo.common.ApiResponse;
-import com.yohoufo.common.alarm.EventBusPublisher;
 import com.yohoufo.common.annotation.IgnoreSession;
 import com.yohoufo.common.annotation.IgnoreSignature;
 import com.yohoufo.common.cache.Cachable;
 import com.yohoufo.common.cache.ControllerCacheAop;
 import com.yohoufo.common.caller.UfoServiceCaller;
-import com.yohoufo.common.utils.StringUtil;
-import com.yohoufo.dal.product.model.Goods;
 import com.yohoufo.dal.product.model.StoragePrice;
-import com.yohoufo.product.event.StoragePriceUpdateEvent;
 import com.yohoufo.product.model.SkupInfo;
 import com.yohoufo.product.response.*;
 import com.yohoufo.product.service.ProductService;
@@ -42,7 +36,6 @@ import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -53,8 +46,6 @@ import org.springframework.web.servlet.ModelAndView;
 import java.lang.reflect.Method;
 import java.math.BigDecimal;
 import java.util.*;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.stream.Collectors;
 
 @RestController
@@ -608,7 +599,7 @@ public class ProductController {
                 for (Integer productId : productIdList) {
                     LOG.info("Batch clearCache queryProductDetailById productId = {}, ", productId);
 
-                    storagePriceService.publishPriceUpdateEvent(productId);
+                    storagePriceService.publishPriceUpdateEventOfClearCache(productId);
 
                     //商品详情
                     cacheAop.clearCache(

@@ -104,4 +104,14 @@ public class StoragePriceService {
         storagePriceUpdateEvent.setProductId(productId);
         EventBusPublisher.publishEvent(storagePriceUpdateEvent);
     }
+
+    public void publishPriceUpdateEventOfClearCache(Integer productId) {
+        LOGGER.info("method com.yohoufo.product.service.impl.StoragePriceService.publishPriceUpdateEvent in productId is 【{}】", productId);
+        StoragePriceUpdateEvent storagePriceUpdateEvent = new StoragePriceUpdateEvent(event->{
+            productCacheService.deleteCacheByString(UfoProductCacheKeyEnum.STORAGE_PRICE_IN_STOCK_INFO_KEY, productId.toString());
+            return true;
+        });
+        storagePriceUpdateEvent.setProductId(productId);
+        EventBusPublisher.publishEvent(storagePriceUpdateEvent);
+    }
 }