修改 redis key

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/constant/SweetConstant.java

@@ -66,7 +66,7 @@ public class SweetConstant {
     //猫登活动-触发活动
     public final static String REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER = "sweet:maoDeng:open:userId";
     //猫登活动整体
-    public final static String REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER = "sweet:maoDeng:naneAndImg:userId";
+    public final static String REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER = "sweet:maoDeng:naneAndImg:openId";
     //猫登活动整体
     public final static String REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER_TRANSFER = "sweet:maoDeng:naneAndImg:userId:transfer";
 

liquidnet-bus-service/liquidnet-service-sweet/docu/db_maodeng.sql

@@ -3,7 +3,7 @@ DROP TABLE IF EXISTS `sweet_wechat_maodeng`;
 CREATE TABLE `sweet_wechat_maodeng`  (
   `mid` int UNSIGNED NOT NULL AUTO_INCREMENT,
   `mao_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL,
-  `user_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL,
+  `user_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '微信openId',
   `text_msg` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '猫名字',
   `pic_url` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '图片url',
   `img_url` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '生成的图',

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

@@ -27,6 +27,7 @@ public class WechatUsersRedisUtils {
             return sweetWechatUsersVo;
         }
     }
+
     public SweetWechatUsersVo getSweetWechatUsersOfOpenId(String openId, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_OPENID.concat(openId)
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
@@ -38,6 +39,7 @@ public class WechatUsersRedisUtils {
             return sweetWechatUsersVo;
         }
     }
+
     public void setSweetWechatUsers(SweetWechatUsersVo sweetWechatUsersVo) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(sweetWechatUsersVo.getUnionId())
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
@@ -47,6 +49,7 @@ public class WechatUsersRedisUtils {
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
         redisUtil.set(redisKeyOpenId, sweetWechatUsersVo);
     }
+
     public void delSweetWechatUsers(String unionId, String openId, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(unionId)
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
@@ -67,6 +70,7 @@ public class WechatUsersRedisUtils {
             return sweetAppletUsersVo;
         }
     }
+
     public SweetAppletUsersVo getSweetAppletUsersOfUnionId(String unionId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_UNIONID.concat(unionId);
         Object obj = redisUtil.get(redisKey);
@@ -77,6 +81,7 @@ public class WechatUsersRedisUtils {
             return sweetAppletUsersVo;
         }
     }
+
     public void setSweetAppletUsers(SweetAppletUsersVo sweetAppletUsersVo) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_PHONE.concat(sweetAppletUsersVo.getPurePhoneNumber());
         redisUtil.set(redisKey, sweetAppletUsersVo);
@@ -89,14 +94,16 @@ public class WechatUsersRedisUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_STRAWBERRY_POSTER_CLICK.concat(openId);
         redisUtil.set(redisKey, 1, time);
     }
+
     public void delStrawberryPosterClick(String openId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_STRAWBERRY_POSTER_CLICK.concat(openId);
         redisUtil.del(redisKey);
     }
+
     public boolean getStrawberryPosterClick(String openId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_STRAWBERRY_POSTER_CLICK.concat(openId);
         Object obj = redisUtil.get(redisKey);
-        if(null == obj) {
+        if (null == obj) {
             return false;
         } else {
             return true;
@@ -127,7 +134,7 @@ public class WechatUsersRedisUtils {
 
     //整体取
     public SweetMaoDengVo getSweetMaoDeng(String fromUser) {
-        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER.concat(fromUser);
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER.concat(":" + fromUser);
         SweetMaoDengVo obj = (SweetMaoDengVo) redisUtil.get(redisKey);
         if (null == obj) {
             return null;
@@ -135,26 +142,30 @@ public class WechatUsersRedisUtils {
             return obj;
         }
     }
+
     //整体存
     public void setSweetMaoDeng(SweetMaoDengVo sweetMaoDengVo) {
-        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER.concat(sweetMaoDengVo.getUserId());
-        redisUtil.set(redisKey,sweetMaoDengVo);
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER.concat(":" + sweetMaoDengVo.getUserId());
+        redisUtil.set(redisKey, sweetMaoDengVo);
     }
 
     //开启猫登天空活动
     public void setSweetMaoDengOpen(String fromUser, long time) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER.concat(fromUser);
-        redisUtil.set(redisKey,"1",time);
+        redisUtil.set(redisKey, "1", time);
     }
+
     public void delSweetMaoDengOpen(String fromUser) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER.concat(fromUser);
         redisUtil.del(redisKey);
     }
+
     //临时数据中转
     public void setSweetMaoDengTransfer(SweetMaoDengVo sweetMaoDengVo, long expire) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER_TRANSFER.concat(sweetMaoDengVo.getUserId());
-        redisUtil.set(redisKey,sweetMaoDengVo,expire);
+        redisUtil.set(redisKey, sweetMaoDengVo, expire);
     }
+
     //临时数据中转
     public SweetMaoDengVo getSweetMaoDengTransfer(String fromUser) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER_TRANSFER.concat(fromUser);