set redis 中奖记录

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/utils/SweetNewObjectUtil.java

@@ -6,19 +6,20 @@ import com.liquidnet.service.sweet.entity.SweetIntegralActivityDraw;
 import com.liquidnet.service.sweet.entity.SweetIntegralActivityPrize;
 
 import java.util.ArrayList;
+import java.util.LinkedList;
 
 public class SweetNewObjectUtil {
     private static final ArrayList<SweetIntegralActivityPrizeVo> sweetIntegralActivityPrizeVoArrayList = new ArrayList<>();
     private static final ArrayList<SweetIntegralActivityPrize> sweetIntegralActivityPrizeArrayList = new ArrayList<>();
-    private static final ArrayList<SweetIntegralActivityDraw> sweetIntegralActivityDrawArrayList = new ArrayList<>();
+    private static final LinkedList<SweetIntegralActivityDraw> sweetIntegralActivityDrawArrayList = new LinkedList<>();
     private static final PagedResult<SweetIntegralActivityDraw> sweetIntegralActivityDrawPagedResult = new PagedResult<>();
 
     public static ArrayList<SweetIntegralActivityPrizeVo> getSweetIntegralActivityPrizeVoArrayList() {
         return (ArrayList<SweetIntegralActivityPrizeVo>) sweetIntegralActivityPrizeVoArrayList.clone();
     }
 
-    public static ArrayList<SweetIntegralActivityDraw> getSweetIntegralActivityDrawArrayList() {
-        return (ArrayList<SweetIntegralActivityDraw>) sweetIntegralActivityDrawArrayList.clone();
+    public static LinkedList<SweetIntegralActivityDraw> getSweetIntegralActivityDrawLinkedList() {
+        return (LinkedList<SweetIntegralActivityDraw>) sweetIntegralActivityDrawArrayList.clone();
     }
 
     public static PagedResult<SweetIntegralActivityDraw> getSweetIntegralActivityDrawPagedResult() {

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/RedisDataUtils.java

@@ -346,6 +346,7 @@ public class RedisDataUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO.concat(unionid);
         return (SweetWechatUser) redisUtil.get(redisKey);
     }
+
     public String getSweetWechatOpenId(String unionid) {
         if (unionid.isEmpty()) {
             return "";
@@ -405,10 +406,10 @@ public class RedisDataUtils {
     public int getLuckDrawStatus(String mobile, String luckDrawNum) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_LUCK_DRAW.concat(mobile).concat(":luckDrawNum:" + luckDrawNum);
         Object obj = redisUtil.get(redisKey);
-        if(obj==null){
-            redisUtil.set(redisKey,0);
+        if (obj == null) {
+            redisUtil.set(redisKey, 0);
             return 0;
-        }else{
+        } else {
             return (int) redisUtil.get(redisKey);
         }
     }
@@ -417,15 +418,15 @@ public class RedisDataUtils {
     public int getLuckDrawResult(String mobile, String luckDrawNum) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_LUCK_DRAW_RESULT.concat(luckDrawNum).concat(":mobile:" + mobile);
         Object obj = redisUtil.get(redisKey);
-        if(obj==null){
+        if (obj == null) {
             return 0;
-        }else{
+        } else {
             return (int) redisUtil.get(redisKey);
         }
     }
 
     //修改抽奖状态
-    public SweetPrizeVo changeLuckDrawStatus(String mobile, String unionId,String luckDrawNum) {
+    public SweetPrizeVo changeLuckDrawStatus(String mobile, String unionId, String luckDrawNum) {
         LinkedList<String> sqls = CollectionUtil.linkedListString();
         LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
         LocalDateTime now = LocalDateTime.now();
@@ -464,14 +465,14 @@ public class RedisDataUtils {
                 if (surplus < prizeALl) {
                     prize = (int) redisUtil.incr(redisSurplus, 1);
                     redisUtil.set(redisKey, 2);
-                    redisUtil.set(SweetConstant.REDIS_KEY_SWEET_LUCK_DRAW_RESULT.concat(luckDrawNum).concat(":mobile:" + mobile),prize);
+                    redisUtil.set(SweetConstant.REDIS_KEY_SWEET_LUCK_DRAW_RESULT.concat(luckDrawNum).concat(":mobile:" + mobile), prize);
                 }
             }
         }
 
         sqls.add(SqlMapping.get("sweet_luck_draw.insert"));
         sqlsDataA.add(new Object[]{
-                mobile,unionId, luckDrawNum, prize, prizeALl, now
+                mobile, unionId, luckDrawNum, prize, prizeALl, now
         });
         queueUtils.sendMsgByRedis(MQConst.SweetQueue.LUCK_DRAW.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA));
@@ -486,6 +487,7 @@ public class RedisDataUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_ANSWER_PHONE.concat(sweetAnswerVo.getPhone());
         redisUtil.set(redisKey, sweetAnswerVo);
     }
+
     public SweetAnswerVo getSweetAnswer(String phone) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_ANSWER_PHONE.concat(phone);
         SweetAnswerVo sweetAnswerVo = (SweetAnswerVo) redisUtil.get(redisKey);
@@ -498,6 +500,7 @@ public class RedisDataUtils {
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_STAT_LIST);
         redisUtil.set(redisKey, sweetCItyVoteStatVo);
     }
+
     public List<SweetCItyVoteStatVo> getSweetCityVoteStatList(Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(type))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_STAT_LIST);
@@ -508,11 +511,13 @@ public class RedisDataUtils {
         }
         return sweetCityVoteStatList;
     }
+
     public void incrSweetCityVote(String cityCode, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(type))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_CITY_CODE).concat(cityCode);
         redisUtil.incr(redisKey, 1);
     }
+
     public Integer getSweetCityVote(String cityCode, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(type))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_CITY_CODE).concat(cityCode);
@@ -523,11 +528,13 @@ public class RedisDataUtils {
             return (Integer) obj;
         }
     }
+
     public void setUserVote(String phone, String openId, SweetCityVoteParam param) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(param.getType()))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_USER).concat(phone).concat("-").concat(openId);
         redisUtil.set(redisKey, param);
     }
+
     public SweetCityVoteParam getUserVote(String phone, String openId, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(type))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_USER).concat(phone).concat("-").concat(openId);
@@ -538,11 +545,13 @@ public class RedisDataUtils {
             return (SweetCityVoteParam) obj;
         }
     }
+
     public void setSweetCityVoteStatUpdateTime(Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(type))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_STAT_UPDATE_TIME);
         redisUtil.set(redisKey, DateUtil.getNowTime());
     }
+
     public String getSweetCityVoteStatUpdateTime(Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE.concat(String.valueOf(type))
                 .concat(SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_STAT_UPDATE_TIME);
@@ -555,7 +564,7 @@ public class RedisDataUtils {
     }
 
 
-//    wechat user 摩登
+    //    wechat user 摩登
     public void setSweetWechatUserModernsky(SweetWechatUser sweetWechatUser) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO_MODERNSKY.concat(sweetWechatUser.getUnionId());
         String redisKeyUnid = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_UNIONID_MODERNSKY.concat(sweetWechatUser.getOpenId());
@@ -578,6 +587,7 @@ public class RedisDataUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO_MODERNSKY.concat(unionid);
         return (SweetWechatUser) redisUtil.get(redisKey);
     }
+
     public String getSweetWechatOpenIdModernsky(String unionid) {
         if (unionid.isEmpty()) {
             return "";
@@ -591,6 +601,7 @@ public class RedisDataUtils {
             return sweetWechatUser.getOpenId();
         }
     }
+
     public void delSweetWechatUserModernsky(String unionid, String openid) {
         if (!unionid.isEmpty()) {
             String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO_MODERNSKY.concat(unionid);
@@ -621,38 +632,58 @@ public class RedisDataUtils {
     }
 
     public void setIntegralActivityDraw(SweetIntegralActivityDraw sweetIntegralActivityDraw) {
-        // TODO: 2021/10/26 1用户中奖列表 2用户抽奖列表 3all用户中奖列表 
-        String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_ALL_LIST
-                .concat(sweetIntegralActivityDraw.getIntegralActivityId());
-        String redisKey1 = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_USER
-                .concat(sweetIntegralActivityDraw.getIntegralActivityId())
-                .concat(":userId:")
-                .concat(sweetIntegralActivityDraw.getUserId());
-        String redisKey2 = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_IN_USER
-                .concat(sweetIntegralActivityDraw.getIntegralActivityId())
-                .concat(":userId:")
-                .concat(sweetIntegralActivityDraw.getUserId());
-        // TODO: 2021/10/26 先获取set到10条
-        // TODO: 2021/10/27 判断是否中奖 再看写入中奖还是抽奖
-        ArrayList<SweetIntegralActivityDraw> sweetIntegralActivityDrawArrayList = SweetNewObjectUtil.getSweetIntegralActivityDrawArrayList();
-        sweetIntegralActivityDrawArrayList.add(sweetIntegralActivityDraw);
-        redisUtil.set(redisKey, sweetIntegralActivityDrawArrayList);
-        redisUtil.set(redisKey1, sweetIntegralActivityDrawArrayList);
-        redisUtil.set(redisKey2, sweetIntegralActivityDrawArrayList);
-    }
-
-    public List<SweetIntegralActivityDraw> getIntegralActivityDrawAll(String integralActivityId) {
+        Integer prizeType = sweetIntegralActivityDraw.getPrizeType();
+        String redisKey = "";
+        String userId = sweetIntegralActivityDraw.getUserId();
+        String integralActivityId = sweetIntegralActivityDraw.getIntegralActivityId();
+        LinkedList<SweetIntegralActivityDraw> activityDrawArrayList = SweetNewObjectUtil.getSweetIntegralActivityDrawLinkedList();
+        if (prizeType == 1) {// 谢谢惠顾 写入抽奖列表
+            redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_USER
+                    .concat(integralActivityId)
+                    .concat(":userId:")
+                    .concat(userId);
+            activityDrawArrayList = this.getIntegralActivityDrawList(2, userId, integralActivityId, 1);
+        } else {// 中奖列表
+            redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_IN_USER
+                    .concat(integralActivityId)
+                    .concat(":userId:")
+                    .concat(userId);
+            activityDrawArrayList = this.getIntegralActivityDrawList(1, userId, integralActivityId, 1);
+
+            // all用户中奖列表
+            String redisKeyAll = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_ALL_LIST
+                    .concat(integralActivityId);
+            LinkedList<SweetIntegralActivityDraw> integralActivityDrawAll = this.getIntegralActivityDrawAll(integralActivityId);
+            if (!CollectionUtil.isEmpty(integralActivityDrawAll)) {
+                if (integralActivityDrawAll.size() >= 20) {
+                    integralActivityDrawAll.remove(0);
+                }
+            }
+            integralActivityDrawAll.addFirst(sweetIntegralActivityDraw);
+            redisUtil.set(redisKeyAll, integralActivityDrawAll);
+        }
+        // 先获取set到20条
+        if (!CollectionUtil.isEmpty(activityDrawArrayList)) {
+            if (activityDrawArrayList.size() >= 20) {
+                activityDrawArrayList.remove(0);
+            }
+        }
+        activityDrawArrayList.addFirst(sweetIntegralActivityDraw);
+        redisUtil.set(redisKey, activityDrawArrayList);
+    }
+
+    public LinkedList<SweetIntegralActivityDraw> getIntegralActivityDrawAll(String integralActivityId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_ALL_LIST
                 .concat(integralActivityId);
         Object obj = redisUtil.get(redisKey);
         if (null == obj) {
             return null;
         } else {
-            return (List<SweetIntegralActivityDraw>) obj;
+            return (LinkedList<SweetIntegralActivityDraw>) obj;
         }
     }
 
-    public List<SweetIntegralActivityDraw> getIntegralActivityDrawList(Integer type, String uid, String integralActivityId, Integer pageNum) {
+    public LinkedList<SweetIntegralActivityDraw> getIntegralActivityDrawList(Integer type, String uid, String integralActivityId, Integer pageNum) {
         String redisKey = "";
         if (type == 1) {
             redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_IN_USER
@@ -669,7 +700,7 @@ public class RedisDataUtils {
         if (null == obj) {
             return null;
         } else {
-            return (List<SweetIntegralActivityDraw>) obj;
+            return (LinkedList<SweetIntegralActivityDraw>) obj;
         }
         // TODO: 2021/10/27 page大于1 去mongo里面取
     }