修改缓存可以删除

 package com.yohoufo.product.controller;
 package com.yohoufo.product.controller;
 
 
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -13,8 +18,11 @@ import com.yoho.tools.docs.ApiOperation;
 import com.yohoufo.common.ApiResponse;
 import com.yohoufo.common.ApiResponse;
 import com.yohoufo.common.annotation.IgnoreSession;
 import com.yohoufo.common.annotation.IgnoreSession;
 import com.yohoufo.common.annotation.IgnoreSignature;
 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.caller.UfoServiceCaller;
 import com.yohoufo.common.utils.UfoJsonUtil;
 import com.yohoufo.common.utils.UfoJsonUtil;
+import com.yohoufo.dal.product.model.StoragePrice;
 import com.yohoufo.product.request.StoragePriceBo;
 import com.yohoufo.product.request.StoragePriceBo;
 import com.yohoufo.product.response.ProductDetailResp;
 import com.yohoufo.product.response.ProductDetailResp;
 import com.yohoufo.product.response.ProductSeriesTemplateResp;
 import com.yohoufo.product.response.ProductSeriesTemplateResp;
@@ -38,7 +46,7 @@ public class ProductController {
 	@IgnoreSignature
 	@IgnoreSignature
 	@IgnoreSession
 	@IgnoreSession
 	@RequestMapping(params = "method=ufo.product.data")
 	@RequestMapping(params = "method=ufo.product.data")
-	//@Cachable(expire=600)
+	@Cachable(expire=600)
 	public ApiResponse queryProductDetailById(
 	public ApiResponse queryProductDetailById(
 			@RequestParam(value = "product_id", required = false) Integer productId) {
 			@RequestParam(value = "product_id", required = false) Integer productId) {
 
 
@@ -78,8 +86,6 @@ public class ProductController {
 
 
 
 
 	@ApiOperation(name = "ufo.product.storage.leastprice", desc="sku的最低价")
 	@ApiOperation(name = "ufo.product.storage.leastprice", desc="sku的最低价")
-	@IgnoreSignature
-	@IgnoreSession
 	@RequestMapping(params = "method=ufo.product.storage.leastprice")
 	@RequestMapping(params = "method=ufo.product.storage.leastprice")
 	//@Cachable(expire=600)
 	//@Cachable(expire=600)
 	public ApiResponse queryStorageLeastprice(
 	public ApiResponse queryStorageLeastprice(
@@ -96,8 +102,6 @@ public class ProductController {
 	}
 	}
 
 
 	@ApiOperation(name = "ufo.product.storage.data", desc="sku信息")
 	@ApiOperation(name = "ufo.product.storage.data", desc="sku信息")
-	@IgnoreSignature
-	@IgnoreSession
 	@RequestMapping(params = "method=ufo.product.storage.data")
 	@RequestMapping(params = "method=ufo.product.storage.data")
 	//@Cachable(expire=600)
 	//@Cachable(expire=600)
 	public ApiResponse queryStorageInfo(
 	public ApiResponse queryStorageInfo(
@@ -113,8 +117,7 @@ public class ProductController {
 		return resp;
 		return resp;
 	}
 	}
 
 
-	@IgnoreSignature
-	@IgnoreSession
+	// 增加库存
 	@RequestMapping(params = "method=ufo.product.createSkup")
 	@RequestMapping(params = "method=ufo.product.createSkup")
 	public ApiResponse createSkup(@RequestBody StoragePriceBo skupBo) {
 	public ApiResponse createSkup(@RequestBody StoragePriceBo skupBo) {
 		try {
 		try {
@@ -127,8 +130,7 @@ public class ProductController {
 		}
 		}
 	}
 	}
 	
 	
-	@IgnoreSignature
-	@IgnoreSession
+	// 售卖
 	@RequestMapping(params = "method=ufo.product.saleSkup")
 	@RequestMapping(params = "method=ufo.product.saleSkup")
 	public ApiResponse saleSkup(
 	public ApiResponse saleSkup(
 			@RequestParam(value = "product_id", required = false) Integer productId,
 			@RequestParam(value = "product_id", required = false) Integer productId,
@@ -143,13 +145,13 @@ public class ProductController {
 		}
 		}
 	}
 	}
 	
 	
-	@IgnoreSignature
-	@IgnoreSession
+	// 取消售卖
 	@RequestMapping(params = "method=ufo.product.cancelSaleSkup")
 	@RequestMapping(params = "method=ufo.product.cancelSaleSkup")
 	public ApiResponse cancelSaleSkup(
 	public ApiResponse cancelSaleSkup(
 			@RequestParam(value = "skup", required = false) Integer skup) {
 			@RequestParam(value = "skup", required = false) Integer skup) {
 		try {
 		try {
 			productService.cancelSaleSkup(skup);
 			productService.cancelSaleSkup(skup);
+			clearProductCache(skup);
 			return new ApiResponse(200, "取消卖出成功！", Boolean.TRUE);
 			return new ApiResponse(200, "取消卖出成功！", Boolean.TRUE);
 		} catch (Exception e) {
 		} catch (Exception e) {
 			LOG.error("取消卖出SKUP失败！", e);
 			LOG.error("取消卖出SKUP失败！", e);
@@ -158,4 +160,23 @@ public class ProductController {
 		}
 		}
 	}
 	}
 	
 	
+	@Autowired
+	private ControllerCacheAop cacheAop;
+	private ExecutorService executors = Executors.newFixedThreadPool(1);
+	
+	private void clearProductCache(Integer skup) {
+		executors.execute(() -> {
+			try {
+				StoragePrice sp = productService.getStoragePriceBySkup(skup);
+				if (sp != null) {
+					Integer storageId = sp.getStorageId();
+					cacheAop.clearCache(
+							ProductController.class.getMethod("queryStorageInfo", new Class[] { Integer.class }),
+							new Object[] { storageId });
+				}
+			} catch (Exception e) {
+				LOG.error("删除商品缓存失败！", e);
+			}
+		});
+	}
 }
 }

 package com.yohoufo.product.service;
 package com.yohoufo.product.service;
 
 
+import com.yohoufo.dal.product.model.StoragePrice;
 import com.yohoufo.product.request.StoragePriceBo;
 import com.yohoufo.product.request.StoragePriceBo;
 import com.yohoufo.product.response.ProductDetailResp;
 import com.yohoufo.product.response.ProductDetailResp;
 
 
@@ -15,5 +16,7 @@ public interface ProductService {
 
 
 	void cancelSaleSkup(Integer skup);
 	void cancelSaleSkup(Integer skup);
 	
 	
+	StoragePrice getStoragePriceBySkup(Integer skup);
+
 
 
 }
 }

@@ -35,6 +35,11 @@ public class ProductServiceImpl implements ProductService{
     }
     }
 
 
     @Override
     @Override
+	public StoragePrice getStoragePriceBySkup(Integer skup) {
+		return storagePriceMapper.selectBySkup(skup);
+	}
+    
+	@Override
 	public void createSkup(StoragePriceBo skupBo) {
 	public void createSkup(StoragePriceBo skupBo) {
 		storagePriceMapper.insert(exchangeCreateSkupBo(skupBo));
 		storagePriceMapper.insert(exchangeCreateSkupBo(skupBo));
 	}
 	}
@@ -160,4 +165,5 @@ public class ProductServiceImpl implements ProductService{
 		sp.setStatus(1);
 		sp.setStatus(1);
 		return sp;
 		return sp;
 	}
 	}
+
 }
 }