清除测试类

src/main/java/com/sw/service/impl/SnatchMaskServiceImpl.java

@@ -37,8 +37,8 @@ public class SnatchMaskServiceImpl implements SnatchMaskService {
     private IMessageProducerService mqService;
 
     @Value("${amount}")
-    private Integer amount;
-
+    private  Integer amount;
+    Object o = new Object();
     @Override
     @Transactional
     public String doSnatch(Integer uid) {
@@ -67,13 +67,14 @@ public class SnatchMaskServiceImpl implements SnatchMaskService {
      */
     @Override
     public  Boolean checkAndDecrRemaining(Integer mid) {
-        Object o = new Object();
-        Integer remaining = 0;
+
         synchronized (o) {
-            remaining = Integer.valueOf(redisTemplate.opsForHash().get("usableMasks", "mask-" + mid).toString());
+//            Integer  remaining = 0;
+            Integer   remaining = Integer.valueOf(redisTemplate.opsForHash().get("usableMasks", "mask-" + mid).toString());
+            System.out.println("库存扣减前："+remaining+"---" + Thread.currentThread());
             if(remaining.compareTo(amount) >= 0) {
                 Long res = redisTemplate.opsForHash().increment("usableMasks", "mask-" + mid, -amount);
-                System.out.println("increment res : "+res +"---" + Thread.currentThread());//扣减之后的库存数量
+                System.out.println("库存扣减后："+"increment res : "+res +"---" + Thread.currentThread());//扣减之后的库存数量
                 return true;
             }else{
                 return false;

src/test/java/com/sw/RedisTest.java

@@ -1,5 +1,10 @@
 package com.sw;
 
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.sw.dao.SysUserDao;
+import com.sw.dao.TMaskDao;
+import com.sw.dao.TOrderDao;
+import com.sw.service.TMaskService;
 import org.junit.Assert;
 import org.junit.Test;
 import org.junit.jupiter.api.Order;
@@ -9,6 +14,7 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -22,6 +28,10 @@ import java.util.List;
 public class RedisTest {
     @Autowired
     private RedisTemplate redisTemplate;
+    @Resource
+    private TOrderDao tOrderDao;
+    @Resource
+    private TMaskService tMaskService;
 
     /**
      * 初始化合法用户uid 到redis
@@ -67,4 +77,18 @@ public class RedisTest {
 //        System.out.println(res);
         redisTemplate.opsForValue().set("remain", 100);
     }
+
+    @Test
+    public void delete(){
+        redisTemplate.delete("successUserUids");
+        redisTemplate.opsForHash().put("usableMasks", "mask-1", 100);
+        redisTemplate.opsForHash().put("usableMasks", "mask-2", 100);
+
+        UpdateWrapper updateWrapper = new UpdateWrapper();
+        updateWrapper.setSql(" mask_stock =100 ");
+        tMaskService.update(updateWrapper);
+
+        tOrderDao.delete(new UpdateWrapper<>());
+
+    }
 }