answer redis q

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/MQConst.java

@@ -75,6 +75,8 @@ public class MQConst {
         ARTISTS_RELATION_MDSK("sweet:stream:rk.artists.mdsk.relation", "group.artists.mdsk.relation", "用户-关系"),
         LUCK_DRAW("sweet:stream:rk.luckDraw", "group.luckDraw", "用户-抽奖"),
         ANSWERINSERT_DRAW("sweet:stream:rk.answerInsert", "group.answerInsert", "答案"),
+        SWEET_USER_INSERT_DRAW("sweet:stream:rk.sweetUserInsert", "group.sweetUserInsert", "关注服务号的用户信息"),
+        SWEET_REMIND_INSERT_DRAW("sweet:stream:rk.remindInsert", "group.remindInsert", "提醒记录"),
         ;
 
         private final String key;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSweetAnswerRedisStreamConfig.java

@@ -17,7 +17,6 @@ import org.springframework.data.redis.stream.Subscription;
 import java.time.Duration;
 
 import static com.liquidnet.service.base.constant.MQConst.SweetQueue.ANSWERINSERT_DRAW;
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.ARTISTS_RELATION;
 
 @Configuration
 public class ConsumerSweetAnswerRedisStreamConfig {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSweetRemindRedisStreamConfig.java

+package com.liquidnet.service.consumer.kylin.config;
+
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerSweetRemindRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.time.Duration;
+
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW;
+
+@Configuration
+public class ConsumerSweetRemindRedisStreamConfig {
+    @Autowired
+    ConsumerSweetRemindRdsReceiver consumerSweetRemindRdsReceiver;
+
+    private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
+        var options = StreamMessageListenerContainer
+                .StreamMessageListenerContainerOptions
+                .builder()
+                .pollTimeout(Duration.ofMillis(1))
+                .build();
+        return StreamMessageListenerContainer.create(factory, options);
+    }
+
+    /**
+     * 缺票登记
+     *
+     * @param listenerContainer
+     * @param t
+     * @return
+     */
+    private Subscription receiveSqlRemind(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+        return listenerContainer.receiveAutoAck(
+                Consumer.from(SWEET_REMIND_INSERT_DRAW.getGroup(), SWEET_REMIND_INSERT_DRAW.name() + t),
+                StreamOffset.create(SWEET_REMIND_INSERT_DRAW.getKey(), ReadOffset.lastConsumed()), consumerSweetRemindRdsReceiver
+        );
+    }
+
+    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+
+    /* -------------------------------------------------------- ｜ 缺票登记 */
+
+    @Bean
+    public Subscription subscriptionSqlRemind(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlRemind(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlRemind2(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlRemind(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlRemind3(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlRemind(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    /* -------------------------------------------------------- ｜  */
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSweetUserRedisStreamConfig.java

+package com.liquidnet.service.consumer.kylin.config;
+
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerSweetUserRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.time.Duration;
+
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_USER_INSERT_DRAW;
+
+@Configuration
+public class ConsumerSweetUserRedisStreamConfig {
+    @Autowired
+    ConsumerSweetUserRdsReceiver consumerSweetUserRdsReceiver;
+
+    private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
+        var options = StreamMessageListenerContainer
+                .StreamMessageListenerContainerOptions
+                .builder()
+                .pollTimeout(Duration.ofMillis(1))
+                .build();
+        return StreamMessageListenerContainer.create(factory, options);
+    }
+
+    /**
+     * 缺票登记
+     *
+     * @param listenerContainer
+     * @param t
+     * @return
+     */
+    private Subscription receiveSqlSweetUser(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+        return listenerContainer.receiveAutoAck(
+                Consumer.from(SWEET_USER_INSERT_DRAW.getGroup(), SWEET_USER_INSERT_DRAW.name() + t),
+                StreamOffset.create(SWEET_USER_INSERT_DRAW.getKey(), ReadOffset.lastConsumed()), consumerSweetUserRdsReceiver
+        );
+    }
+
+    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+
+    /* -------------------------------------------------------- ｜ 缺票登记 */
+
+    @Bean
+    public Subscription subscriptionSqlSweetUser(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlSweetUser(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlSweetUser2(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlSweetUser(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlSweetUser3(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlSweetUser(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    /* -------------------------------------------------------- ｜  */
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerSweetRemindRdsReceiver.java

+package com.liquidnet.service.consumer.kylin.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerSweetRemindRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerSweetUserRdsReceiver.java

+package com.liquidnet.service.consumer.kylin.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerSweetUserRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getGroup();
+    }
+}

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

@@ -427,6 +427,7 @@ CREATE TABLE `sweet_wechat_user`
     `city`           varchar(200)    NOT NULL DEFAULT '' COMMENT '市',
     `subscribeTime`  datetime        NULL     DEFAULT null COMMENT '关注时间',
     `subscribeScene` varchar(200)    NOT NULL DEFAULT '' COMMENT 'ADD_SCENE_SEARCH 关注方式',
+    `is_cancel`      tinyint         NOT NULL DEFAULT 1 COMMENT '是否取关 1关注 2已取消',
     `created_at`     datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
     `updated_at`     datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
     PRIMARY KEY (`mid`),
@@ -454,7 +455,7 @@ CREATE TABLE `sweet_answer`
   COLLATE utf8mb4_unicode_ci
   ROW_FORMAT = DYNAMIC COMMENT '答题表';
 
--- 关注
+-- 提醒记录
 drop TABLE if exists `sweet_remind`;
 CREATE TABLE `sweet_remind`
 (

liquidnet-bus-service/liquidnet-service-sweet/docu/redis_queue_create.txt

@@ -7,4 +7,16 @@ XGROUP CREATE sweet:stream:rk.artists.mdsk.relation group.artists.mdsk.relation
 
 --     抽奖     --
 XADD sweet:stream:rk.luckDraw * 0 0
-XGROUP CREATE sweet:stream:rk.luckDraw group.luckDraw 0
+XGROUP CREATE sweet:stream:rk.luckDraw group.luckDraw 0
\ No newline at end of file
+
+--     答案     --
+XADD sweet:stream:rk.answerInsert * 0 0
+XGROUP CREATE sweet:stream:rk.answerInsert group.answerInsert 0
+
+--     关注服务号的用户信息     --
+XADD sweet:stream:rk.sweetUserInsert * 0 0
+XGROUP CREATE sweet:stream:rk.sweetUserInsert group.sweetUserInsert 0
+
+--     提醒记录     --
+XADD sweet:stream:rk.remindInsert * 0 0
+XGROUP CREATE sweet:stream:rk.remindInsert group.remindInsert 0
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/SubscribeHandler.java

 package com.liquidnet.service.sweet.handler;
 
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.sweet.entity.SweetWechatUser;
 import com.liquidnet.service.sweet.mapper.SweetWechatUserMapper;
 import com.liquidnet.service.sweet.service.impl.SweetWechatTemplateServiceImpl;
+import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.RedisDataUtils;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
@@ -19,6 +23,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
+import java.util.LinkedList;
 import java.util.Map;
 
 /**
@@ -36,6 +41,8 @@ public class SubscribeHandler implements WxMpMessageHandler {
     private SweetWechatUserMapper sweetWechatUserMapper;
     @Autowired
     private RedisDataUtils redisDataUtils;
+    @Autowired
+    private QueueUtils queueUtils;
 
     @Autowired
     private SweetWechatTemplateServiceImpl sweetWechatTemplateService;
@@ -52,7 +59,7 @@ public class SubscribeHandler implements WxMpMessageHandler {
         }
         log.info("根据 openId:[{}]获取到的微信用户信息:[{}]", wxMessage.getFromUser(), wxMpUser.toString());
         // 记录用户信息
-        SweetWechatUser userInfo = sweetWechatUserMapper.selectOne(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getOpenId, wxMpUser.getOpenId()));
+        SweetWechatUser userInfo = redisDataUtils.getSweetWechatUser(wxMpUser.getUnionId());
         SweetWechatUser sweetWechatUser = SweetWechatUser.getNew();
         sweetWechatUser.setOpenId(wxMpUser.getOpenId());
         sweetWechatUser.setUnionId(wxMpUser.getUnionId());
@@ -68,20 +75,22 @@ public class SubscribeHandler implements WxMpMessageHandler {
         sweetWechatUser.setSubscribeScene(wxMpUser.getSubscribeScene());
         if (null == userInfo) {
             sweetWechatUser.setUserId(IDGenerator.nextSnowId());
-            sweetWechatUserMapper.insert(sweetWechatUser);
-            sweetWechatTemplateService.subscribeSend(sweetWechatUser);
-        } else {
-            sweetWechatUser.setUpdatedAt(LocalDateTime.now());
-            sweetWechatUserMapper.update(sweetWechatUser, Wrappers.lambdaUpdate(SweetWechatUser.class).eq(SweetWechatUser::getUserId, userInfo.getUserId()));
-        }
-        String unionId = wxMpUser.getUnionId();
-        if (!unionId.isEmpty()) {
-            if (null != userInfo) {
-                sweetWechatUser.setMid(userInfo.getMid());
-                sweetWechatUser.setUserId(userInfo.getUserId());
-                sweetWechatUser.setCreatedAt(userInfo.getCreatedAt());
-            }
+            LinkedList<String> sqls = CollectionUtil.linkedListString();
+            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+            LocalDateTime now = LocalDateTime.now();
+            sqls.add(SqlMapping.get("sweet_user.insert"));
+            sqlsDataA.add(new Object[]{
+                    sweetWechatUser.getUserId(), sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
+                    sweetWechatUser.getSexDesc(), sweetWechatUser.getSex(), sweetWechatUser.getHeadImgUrl(), sweetWechatUser.getLanguage(),
+                    sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
+                    sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
+            });
+            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                    SqlMapping.gets(sqls, sqlsDataA));
+            // 入缓存
             redisDataUtils.setSweetWechatUser(sweetWechatUser);
+            //发送模版消息
+            sweetWechatTemplateService.subscribeSend(sweetWechatUser);
         }
 
         return null;

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/UnsubscribeHandler.java

 package com.liquidnet.service.sweet.handler;
 
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.sweet.entity.SweetWechatUser;
 import com.liquidnet.service.sweet.mapper.SweetWechatUserMapper;
+import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.RedisDataUtils;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
@@ -15,6 +19,8 @@ import me.chanjar.weixin.mp.bean.result.WxMpUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDateTime;
+import java.util.LinkedList;
 import java.util.Map;
 
 /**
@@ -33,6 +39,8 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
     private SweetWechatUserMapper sweetWechatUserMapper;
     @Autowired
     private RedisDataUtils redisDataUtils;
+    @Autowired
+    private QueueUtils queueUtils;
 
     @Override
     public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService,
@@ -47,14 +55,20 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
         }
         log.info("根据 openId:[{}]获取到的微信用户信息:[{}]", wxMessage.getFromUser(), wxMpUser.toString());
         // 删除用户信息
-        SweetWechatUser userInfo = sweetWechatUserMapper.selectOne(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getOpenId, wxMpUser.getOpenId()));
+        SweetWechatUser userInfo = redisDataUtils.getSweetWechatUser(wxMpUser.getUnionId());
         if (null != userInfo) {
-            int resNum = sweetWechatUserMapper.delete(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getUserId, userInfo.getUserId()));
-        }
-        String unionId = wxMpUser.getUnionId();
-        if (!unionId.isEmpty()) {
-            redisDataUtils.delSweetRemind(unionId);
+            LinkedList<String> sqls = CollectionUtil.linkedListString();
+            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+            LocalDateTime now = LocalDateTime.now();
+            sqls.add(SqlMapping.get("sweet_user.update"));
+            sqlsDataA.add(new Object[]{
+                    2, now, wxMpUser.getUnionId()
+            });
+            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                    SqlMapping.gets(sqls, sqlsDataA));
+//            int resNum = sweetWechatUserMapper.delete(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getUserId, userInfo.getUserId()));
         }
+        redisDataUtils.delSweetWechatUser(wxMpUser.getUnionId());
         return null;
     }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetAnswerServiceImpl.java

@@ -57,7 +57,7 @@ public class SweetAnswerServiceImpl extends ServiceImpl<SweetAnswerMapper, Sweet
         LocalDateTime now = LocalDateTime.now();
         sqls.add(SqlMapping.get("sweet_answer.insert"));
         sqlsDataA.add(new Object[]{
-                IDGenerator.nextSnowId(), phone, answerJson, imgUrl
+                sweetAnswer.getAnswerId(), phone, answerJson, imgUrl
         });
         queueUtils.sendMsgByRedis(MQConst.SweetQueue.ANSWERINSERT_DRAW.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA));

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

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
@@ -306,11 +307,22 @@ public class RedisDataUtils {
     public void setSweetRemind(String openId, String unionId, String performancesId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_REMIND.concat(unionId);
         SweetRemindVo sweetRemindVo = SweetRemindVo.getNew();
+        sweetRemindVo.setRemindId(IDGenerator.nextSnowId());
         sweetRemindVo.setCreatedAt(DateUtil.getNowTime());
         sweetRemindVo.setPerformancesId(performancesId);
         sweetRemindVo.setUnionId(unionId);
         sweetRemindVo.setOpenId(openId);
 
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+        LocalDateTime now = LocalDateTime.now();
+        sqls.add(SqlMapping.get("sweet_remind.insert"));
+        sqlsDataA.add(new Object[]{
+                sweetRemindVo.getRemindId(), sweetRemindVo.getOpenId(), sweetRemindVo.getUnionId(), sweetRemindVo.getPerformancesId(),
+        });
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW.getKey(),
+                SqlMapping.gets(sqls, sqlsDataA));
+
 //        if (null != performanceInfo) {
 //            sweetRemindVo.setFieldName(performanceInfo.getFieldName());
 //            sweetRemindVo.setTitle(performanceInfo.getTitle());
@@ -330,7 +342,6 @@ public class RedisDataUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO.concat(sweetWechatUser.getUnionId());
         redisUtil.set(redisKey, sweetWechatUser);
     }
-
     public SweetWechatUser getSweetWechatUser(String unionid) {
         if (unionid.isEmpty()) {
             return null;
@@ -338,6 +349,12 @@ public class RedisDataUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO.concat(unionid);
         return (SweetWechatUser) redisUtil.get(redisKey);
     }
+    public void delSweetWechatUser(String unionid) {
+        if (!unionid.isEmpty()) {
+            String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO.concat(unionid);
+            redisUtil.del(redisKey);
+        }
+    }
 
     // 艺人详情
     public SweetArtists setArtistsDetails(String artistsId) {

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/vo/SweetRemindVo.java

@@ -9,6 +9,7 @@ public class SweetRemindVo implements Serializable, Cloneable {
     private String performancesId;
     private String openId;
     private String unionId;
+    private String remindId;
     /*private String title;
     private String timeStart;
     private String sellTime;

liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties

@@ -61,4 +61,9 @@ sweet_user_relation_mdsk.delete=DELETE FROM  sweet_user_relation_mdsk WHERE user
 sweet_luck_draw.insert=INSERT INTO sweet_luck_draw (user_id,luck_draw_num,status,created_at) VALUES (?,?,1,?)
 
 # --------------------------答案--------------------------
-sweet_answer.insert=INSERT INTO sweet_answer (answer_id,phone,answer_json,img_url) VALUES (?,?,?,?)
+sweet_answer.insert=INSERT INTO sweet_answer (answer_id,phone,answer_json,img_url) VALUES (?,?,?,?)
\ No newline at end of file
+# --------------------------关注/取消服务号的用户信息--------------------------
+sweet_user.insert=INSERT INTO sweet_wechat_user (user_id,openId,unionId,nickname,sexDesc,sex,headImgUrl,language,country,province,city,subscribeTime,subscribeScene) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)
+sweet_user.update=UPDATE sweet_wechat_user SET is_cancel = ?, updated_at = ?  WHERE unionId = ?
+# --------------------------提醒记录--------------------------
+sweet_remind.insert=INSERT INTO sweet_remind (remind_id,openId,unionId,performancesId) VALUES (?,?,?,?)
\ No newline at end of file