库存

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/sweet/service/impl/SweetIntegralActivityServiceImpl.java

@@ -69,8 +69,8 @@ public class SweetIntegralActivityServiceImpl extends ServiceImpl<SweetIntegralA
                     sweetIntegralActivityPrize.setIntegralActivityId(integralActivityId);
                     sweetIntegralActivityPrizeMapper.insert(sweetIntegralActivityPrize);
                     // 奖品库存和中奖人数redis
-                    sweetRedisAdminUtils.setIntegralActivityPrizeNum(integralActivityId, sweetIntegralActivityPrize);
-                    sweetRedisAdminUtils.setIntegralActivityPrizeWinnersNum(integralActivityId, sweetIntegralActivityPrize);
+                    sweetRedisAdminUtils.incrIntegralActivityPrizeNum(integralActivityId, sweetIntegralActivityPrize.getPrizeId(), sweetIntegralActivityPrize.getPrizeNum());
+                    sweetRedisAdminUtils.incrIntegralActivityPrizeWinnersNum(integralActivityId, sweetIntegralActivityPrize.getPrizeId(), sweetIntegralActivityPrize.getWinnersNum());
                 }
             }
             // 活动redis处理
@@ -98,11 +98,31 @@ public class SweetIntegralActivityServiceImpl extends ServiceImpl<SweetIntegralA
                     SweetIntegralActivityPrize sweetIntegralActivityPrize = SweetIntegralActivityPrizeFormParam.getNew().copy(prize);
                     sweetIntegralActivityPrize.setUpdatedAt(LocalDateTime.now());
                     sweetIntegralActivityPrize.setIntegralActivityId(integralActivityId);
+                    String prizeId = prize.getPrizeId();
                     sweetIntegralActivityPrizeMapper.update(
                             sweetIntegralActivityPrize,
-                            Wrappers.lambdaUpdate(SweetIntegralActivityPrize.class).eq(SweetIntegralActivityPrize::getPrizeId, prize.getPrizeId())
+                            Wrappers.lambdaUpdate(SweetIntegralActivityPrize.class).eq(SweetIntegralActivityPrize::getPrizeId, prizeId)
                     );
-                    // TODO: 2021/10/27  处理奖品库存 
+                    // 处理奖品库存
+                    SweetIntegralActivityPrize sweetIntegralActivityPrizeOld = sweetIntegralActivityPrizeMapper.selectOne(
+                            Wrappers.lambdaQuery(SweetIntegralActivityPrize.class).eq(SweetIntegralActivityPrize::getPrizeId, prizeId)
+                    );
+                    Integer prizeNum = sweetIntegralActivityPrizeOld.getPrizeNum();
+                    Integer winnersNum = sweetIntegralActivityPrizeOld.getWinnersNum();
+                    Integer prizeNumNew = sweetIntegralActivityPrize.getPrizeNum();
+                    Integer winnersNumNew = sweetIntegralActivityPrize.getWinnersNum();
+                    int prizeNumDiff = prizeNumNew - prizeNum;
+                    int winnersNumDiff = winnersNumNew - winnersNum;
+                    if (prizeNumDiff > 0) {//增加库存
+                        sweetRedisAdminUtils.incrIntegralActivityPrizeNum(integralActivityId, prizeId, prizeNumDiff);
+                    } else if(prizeNumDiff < 0) {// 减少库存
+                        sweetRedisAdminUtils.decrIntegralActivityPrizeNum(integralActivityId, prizeId, Math.abs(prizeNumDiff));
+                    }
+                    if (winnersNumDiff > 0) {//增加中奖人数
+                        sweetRedisAdminUtils.incrIntegralActivityPrizeWinnersNum(integralActivityId, prizeId, winnersNumDiff);
+                    } else if(winnersNumDiff < 0) {// 减少中奖人数
+                        sweetRedisAdminUtils.decrIntegralActivityPrizeWinnersNum(integralActivityId, prizeId, Math.abs(winnersNumDiff));
+                    }
                 }
             }
             // 活动redis处理

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/sweet/utils/SweetRedisAdminUtils.java

@@ -3,7 +3,6 @@ package com.liquidnet.client.admin.zhengzai.sweet.utils;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.dto.vo.IntegralActivityVo;
-import com.liquidnet.service.sweet.entity.SweetIntegralActivityPrize;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.stereotype.Component;
@@ -27,19 +26,35 @@ public class SweetRedisAdminUtils {
         boolean set = redisUtil.set(redisKey, integralActivityVo);
     }
 
-    public void setIntegralActivityPrizeNum(String integralActivityId, SweetIntegralActivityPrize sweetIntegralActivityPrize) {
+    public void incrIntegralActivityPrizeNum(String integralActivityId, String prizeId, Integer num) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_PRIZE_NUM
                 .concat(integralActivityId)
                 .concat(":prizeId:")
-                .concat(sweetIntegralActivityPrize.getPrizeId());
-        redisUtil.incr(redisKey, sweetIntegralActivityPrize.getPrizeNum());
+                .concat(prizeId);
+        redisUtil.incr(redisKey, num);
     }
 
-    public void setIntegralActivityPrizeWinnersNum(String integralActivityId, SweetIntegralActivityPrize sweetIntegralActivityPrize) {
+    public void incrIntegralActivityPrizeWinnersNum(String integralActivityId, String prizeId, Integer num) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_PRIZE_WINNERS_NUM
                 .concat(integralActivityId)
                 .concat(":prizeId:")
-                .concat(sweetIntegralActivityPrize.getPrizeId());
-        redisUtil.incr(redisKey, sweetIntegralActivityPrize.getPrizeNum());
+                .concat(prizeId);
+        redisUtil.incr(redisKey, num);
+    }
+
+    public void decrIntegralActivityPrizeNum(String integralActivityId, String prizeId, Integer num) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_PRIZE_NUM
+                .concat(integralActivityId)
+                .concat(":prizeId:")
+                .concat(prizeId);
+        redisUtil.decr(redisKey, num);
+    }
+
+    public void decrIntegralActivityPrizeWinnersNum(String integralActivityId, String prizeId, Integer num) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_PRIZE_WINNERS_NUM
+                .concat(integralActivityId)
+                .concat(":prizeId:")
+                .concat(prizeId);
+        redisUtil.decr(redisKey, num);
     }
 }