draw 规范SweetQueue名字

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

@@ -78,13 +78,13 @@ public class MQConst {
         ARTISTS_RELATION("sweet:stream:rk.artists.relation", "group.artists.relation", "用户-关系"),
         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", "提醒记录"),
-        SWEET_APPLET_USER_INSERT_DRAW("sweet:stream:rk.sweetAppletUserInsert", "group.sweetAppletUserInsert", "小程序登录记录用户解密后信息"),
+        SWEET_ANSWER_INSERT("sweet:stream:rk.answerInsert", "group.answerInsert", "答案"),
+        SWEET_WECHAT_USER_INSERT("sweet:stream:rk.sweetUserInsert", "group.sweetUserInsert", "关注服务号的用户信息"),
+        SWEET_REMIND_INSERT("sweet:stream:rk.remindInsert", "group.remindInsert", "提醒记录"),
+        SWEET_APPLET_USER_INSERT("sweet:stream:rk.sweetAppletUserInsert", "group.sweetAppletUserInsert", "小程序登录记录用户解密后信息"),
         SWEET_TEMPLATE_MSG("sweet:stream:rk.sweetTemplateMsg", "group.sweetTemplateMsg", "发送模版消息"),
-        SWEET_CITY_VOTE_DRAW("sweet:stream:rk.cityVote", "group.cityVote", "用户投票记录"),
-        SWEET_ANTIGENIC_QUESTION_DRAW("sweet:stream:rk.antigenicQuestion", "group.antigenicQuestion", "防疫答题"),
+        SWEET_CITY_VOTE("sweet:stream:rk.cityVote", "group.cityVote", "用户投票记录"),
+        SWEET_ANTIGENIC_QUESTION("sweet:stream:rk.antigenicQuestion", "group.antigenicQuestion", "防疫答题"),
         SWEET_INTEGRAL_ACTIVITY_DRAW("sweet:stream:rk.integralActivityDraw", "group.integralActivityDraw", "积分抽奖"),
         ;
 

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

@@ -17,7 +17,6 @@ import java.time.Duration;
 
 import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_RECEIVE;
 import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_USE;
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_USER_INSERT_DRAW;
 
 @Configuration
 public class ConsumerCandyCouponReceiveRedisStreamConfig {

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

@@ -15,7 +15,7 @@ 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.SWEET_ANSWER_INSERT;
 
 @Configuration
 public class ConsumerSweetAnswerRedisStreamConfig {
@@ -40,8 +40,8 @@ public class ConsumerSweetAnswerRedisStreamConfig {
      */
     private Subscription receiveSqlAnswer(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
         return listenerContainer.receiveAutoAck(
-                Consumer.from(ANSWERINSERT_DRAW.getGroup(), ANSWERINSERT_DRAW.name() + t),
-                StreamOffset.create(ANSWERINSERT_DRAW.getKey(), ReadOffset.lastConsumed()), consumerSweetAnswerRdsReceiver
+                Consumer.from(SWEET_ANSWER_INSERT.getGroup(), SWEET_ANSWER_INSERT.name() + t),
+                StreamOffset.create(SWEET_ANSWER_INSERT.getKey(), ReadOffset.lastConsumed()), consumerSweetAnswerRdsReceiver
         );
     }
 

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerAntigenicQuestionRedisStreamConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetAntigenicQuestionRedisStreamConfig.java

 package com.liquidnet.service.consumer.sweet.config;
 
-import com.liquidnet.service.consumer.sweet.receiver.ConsumerAntigenicQuestionRdsReceiver;
+import com.liquidnet.service.consumer.sweet.receiver.ConsumerSweetAntigenicQuestionRdsReceiver;
 import lombok.var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
@@ -15,12 +15,12 @@ import org.springframework.data.redis.stream.Subscription;
 
 import java.time.Duration;
 
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION_DRAW;
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION;
 
 @Configuration
-public class ConsumerAntigenicQuestionRedisStreamConfig {
+public class ConsumerSweetAntigenicQuestionRedisStreamConfig {
     @Autowired
-    ConsumerAntigenicQuestionRdsReceiver consumerAntigenicQuestionRdsReceiver;
+    ConsumerSweetAntigenicQuestionRdsReceiver consumerAntigenicQuestionRdsReceiver;
 
     private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
         var options = StreamMessageListenerContainer
@@ -40,8 +40,8 @@ public class ConsumerAntigenicQuestionRedisStreamConfig {
      */
     private Subscription receiveSqlAntigenicQuestion(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
         return listenerContainer.receiveAutoAck(
-                Consumer.from(SWEET_ANTIGENIC_QUESTION_DRAW.getGroup(), SWEET_ANTIGENIC_QUESTION_DRAW.name() + t),
-                StreamOffset.create(SWEET_ANTIGENIC_QUESTION_DRAW.getKey(), ReadOffset.lastConsumed()), consumerAntigenicQuestionRdsReceiver
+                Consumer.from(SWEET_ANTIGENIC_QUESTION.getGroup(), SWEET_ANTIGENIC_QUESTION.name() + t),
+                StreamOffset.create(SWEET_ANTIGENIC_QUESTION.getKey(), ReadOffset.lastConsumed()), consumerAntigenicQuestionRdsReceiver
         );
     }
 

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetAppletUserRedisStreamConfig.java

@@ -15,7 +15,7 @@ import org.springframework.data.redis.stream.Subscription;
 
 import java.time.Duration;
 
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_APPLET_USER_INSERT_DRAW;
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_APPLET_USER_INSERT;
 
 @Configuration
 public class ConsumerSweetAppletUserRedisStreamConfig {
@@ -36,8 +36,8 @@ public class ConsumerSweetAppletUserRedisStreamConfig {
      */
     private Subscription receiveSqlSweetAppletUser(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
         return listenerContainer.receiveAutoAck(
-                Consumer.from(SWEET_APPLET_USER_INSERT_DRAW.getGroup(), SWEET_APPLET_USER_INSERT_DRAW.name() + t),
-                StreamOffset.create(SWEET_APPLET_USER_INSERT_DRAW.getKey(), ReadOffset.lastConsumed()), consumerSweetAppletUserRdsReceiver
+                Consumer.from(SWEET_APPLET_USER_INSERT.getGroup(), SWEET_APPLET_USER_INSERT.name() + t),
+                StreamOffset.create(SWEET_APPLET_USER_INSERT.getKey(), ReadOffset.lastConsumed()), consumerSweetAppletUserRdsReceiver
         );
     }
 

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerCityVoteRedisStreamConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetCityVoteRedisStreamConfig.java

 package com.liquidnet.service.consumer.sweet.config;
 
-import com.liquidnet.service.consumer.sweet.receiver.ConsumerCityVoteRdsReceiver;
+import com.liquidnet.service.consumer.sweet.receiver.ConsumerSweetCityVoteRdsReceiver;
 import lombok.var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
@@ -15,12 +15,12 @@ import org.springframework.data.redis.stream.Subscription;
 
 import java.time.Duration;
 
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_CITY_VOTE_DRAW;
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_CITY_VOTE;
 
 @Configuration
-public class ConsumerCityVoteRedisStreamConfig {
+public class ConsumerSweetCityVoteRedisStreamConfig {
     @Autowired
-    ConsumerCityVoteRdsReceiver consumerCityVoteRdsReceiver;
+    ConsumerSweetCityVoteRdsReceiver consumerCityVoteRdsReceiver;
 
     private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
         var options = StreamMessageListenerContainer
@@ -40,8 +40,8 @@ public class ConsumerCityVoteRedisStreamConfig {
      */
     private Subscription receiveSqlCityVote(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
         return listenerContainer.receiveAutoAck(
-                Consumer.from(SWEET_CITY_VOTE_DRAW.getGroup(), SWEET_CITY_VOTE_DRAW.name() + t),
-                StreamOffset.create(SWEET_CITY_VOTE_DRAW.getKey(), ReadOffset.lastConsumed()), consumerCityVoteRdsReceiver
+                Consumer.from(SWEET_CITY_VOTE.getGroup(), SWEET_CITY_VOTE.name() + t),
+                StreamOffset.create(SWEET_CITY_VOTE.getKey(), ReadOffset.lastConsumed()), consumerCityVoteRdsReceiver
         );
     }
 

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetIntegralActivityDrawRedisStreamConfig.java

 package com.liquidnet.service.consumer.sweet.config;
 
-import com.liquidnet.service.consumer.sweet.receiver.ConsumerIntegralActivityDrawRdsReceiver;
+import com.liquidnet.service.consumer.sweet.receiver.ConsumerSweetIntegralActivityDrawRdsReceiver;
 import lombok.var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
@@ -20,7 +20,7 @@ import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_INTEG
 @Configuration
 public class ConsumerSweetIntegralActivityDrawRedisStreamConfig {
     @Autowired
-    ConsumerIntegralActivityDrawRdsReceiver consumerIntegralActivityDrawRdsReceiver;
+    ConsumerSweetIntegralActivityDrawRdsReceiver consumerIntegralActivityDrawRdsReceiver;
 
     private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
         var options = StreamMessageListenerContainer

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

@@ -15,7 +15,7 @@ import org.springframework.data.redis.stream.Subscription;
 
 import java.time.Duration;
 
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW;
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_REMIND_INSERT;
 
 @Configuration
 public class ConsumerSweetRemindRedisStreamConfig {
@@ -40,8 +40,8 @@ public class ConsumerSweetRemindRedisStreamConfig {
      */
     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
+                Consumer.from(SWEET_REMIND_INSERT.getGroup(), SWEET_REMIND_INSERT.name() + t),
+                StreamOffset.create(SWEET_REMIND_INSERT.getKey(), ReadOffset.lastConsumed()), consumerSweetRemindRdsReceiver
         );
     }
 

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

@@ -15,7 +15,7 @@ import org.springframework.data.redis.stream.Subscription;
 
 import java.time.Duration;
 
-import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_USER_INSERT_DRAW;
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT;
 
 @Configuration
 public class ConsumerSweetUserRedisStreamConfig {
@@ -40,8 +40,8 @@ public class ConsumerSweetUserRedisStreamConfig {
      */
     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
+                Consumer.from(SWEET_WECHAT_USER_INSERT.getGroup(), SWEET_WECHAT_USER_INSERT.name() + t),
+                StreamOffset.create(SWEET_WECHAT_USER_INSERT.getKey(), ReadOffset.lastConsumed()), consumerSweetUserRdsReceiver
         );
     }
 

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerSweetAnswerRdsReceiver.java

@@ -7,11 +7,11 @@ import org.springframework.stereotype.Component;
 public class ConsumerSweetAnswerRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.SweetQueue.ANSWERINSERT_DRAW.getKey();
+        return MQConst.SweetQueue.SWEET_ANSWER_INSERT.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.SweetQueue.ANSWERINSERT_DRAW.getGroup();
+        return MQConst.SweetQueue.SWEET_ANSWER_INSERT.getGroup();
     }
 }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerAntigenicQuestionRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerSweetAntigenicQuestionRdsReceiver.java

@@ -4,14 +4,14 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerAntigenicQuestionRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerSweetAntigenicQuestionRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION_DRAW.getKey();
+        return MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION_DRAW.getGroup();
+        return MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION.getGroup();
     }
 }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerSweetAppletUserRdsReceiver.java

@@ -16,12 +16,12 @@ import java.util.HashMap;
 public class ConsumerSweetAppletUserRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.SweetQueue.SWEET_APPLET_USER_INSERT_DRAW.getKey();
+        return MQConst.SweetQueue.SWEET_APPLET_USER_INSERT.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.SweetQueue.SWEET_APPLET_USER_INSERT_DRAW.getGroup();
+        return MQConst.SweetQueue.SWEET_APPLET_USER_INSERT.getGroup();
     }
 
     @Override

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerCityVoteRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerSweetCityVoteRdsReceiver.java

@@ -4,14 +4,14 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerCityVoteRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerSweetCityVoteRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.SweetQueue.SWEET_CITY_VOTE_DRAW.getKey();
+        return MQConst.SweetQueue.SWEET_CITY_VOTE.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.SweetQueue.SWEET_CITY_VOTE_DRAW.getGroup();
+        return MQConst.SweetQueue.SWEET_CITY_VOTE.getGroup();
     }
 }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerIntegralActivityDrawRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerSweetIntegralActivityDrawRdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerIntegralActivityDrawRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerSweetIntegralActivityDrawRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey();

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

@@ -7,11 +7,11 @@ import org.springframework.stereotype.Component;
 public class ConsumerSweetRemindRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW.getKey();
+        return MQConst.SweetQueue.SWEET_REMIND_INSERT.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW.getGroup();
+        return MQConst.SweetQueue.SWEET_REMIND_INSERT.getGroup();
     }
 }

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

@@ -7,11 +7,11 @@ import org.springframework.stereotype.Component;
 public class ConsumerSweetUserRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey();
+        return MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getGroup();
+        return MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getGroup();
     }
 }

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

@@ -86,7 +86,7 @@ public class SubscribeHandler implements WxMpMessageHandler {
                         sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                         sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
                 });
-                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                         SqlMapping.gets(sqls, sqlsDataA));
                 // 入缓存
                 redisDataUtils.setSweetWechatUser(sweetWechatUser);
@@ -120,7 +120,7 @@ public class SubscribeHandler implements WxMpMessageHandler {
                         sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                         sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
                 });
-                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                         SqlMapping.gets(sqls, sqlsDataA));
                 // 入缓存
                 redisDataUtils.setSweetWechatUserModernsky(sweetWechatUser);

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

@@ -68,7 +68,7 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
                     sqlsDataA.add(new Object[]{
                             2, now, sweetWechatUserUnionid, 1
                     });
-                    queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                    queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                             SqlMapping.gets(sqls, sqlsDataA));
                     redisDataUtils.delSweetWechatUser(sweetWechatUserUnionid, wxMpUser.getOpenId());
                 }
@@ -86,7 +86,7 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
                     sqlsDataA.add(new Object[]{
                             2, now, sweetWechatUserUnionid, 2
                     });
-                    queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                    queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                             SqlMapping.gets(sqls, sqlsDataA));
                     redisDataUtils.delSweetWechatUserModernsky(sweetWechatUserUnionid, wxMpUser.getOpenId());
                 }

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

@@ -59,7 +59,7 @@ public class SweetAnswerServiceImpl extends ServiceImpl<SweetAnswerMapper, Sweet
         sqlsDataA.add(new Object[]{
                 sweetAnswer.getAnswerId(), phone, answerJson, imgUrl
         });
-        queueUtils.sendMsgByRedis(MQConst.SweetQueue.ANSWERINSERT_DRAW.getKey(),
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_ANSWER_INSERT.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA));
 
         SweetAnswerVo sweetAnswerVo = SweetAnswerVo.getNew().copy(sweetAnswer);

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

@@ -40,7 +40,7 @@ public class SweetAntigenicQuestionServiceImpl extends ServiceImpl<SweetAntigeni
                 param.getUrgentPhone(), param.getKeyword1(), param.getKeyword11(), param.getKeyword2(), param.getKeyword3(), param.getKeyword4(), param.getKeyword5(),
                 param.getKeyword6(), param.getKeyword7()
         });
-        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION_DRAW.getKey(),
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA));
         return ResponseDto.success();
     }

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

@@ -105,7 +105,7 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
                     IDGenerator.nextSnowId(), aNew.getCityCode(), aNew.getCityName(), 1, aNew.getType()
             });
         }
-        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_CITY_VOTE_DRAW.getKey(),
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_CITY_VOTE.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA, sqlsDataB));
 
         redisDataUtils.incrSweetCityVote(aNew.getCityCode(), aNew.getType());

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

@@ -86,7 +86,7 @@ public class SweetWechatLoginServiceImpl {
                     IDGenerator.nextSnowId(), openId, unionId, wxMaPhoneNumberInfo.getPhoneNumber(), wxMaPhoneNumberInfo.getPurePhoneNumber()
                     , wxMaPhoneNumberInfo.getCountryCode(), type
             });
-            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_APPLET_USER_INSERT_DRAW.getKey(),
+            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_APPLET_USER_INSERT.getKey(),
                     SqlMapping.gets(sqls, sqlsDataA));
 
             return ResponseDto.success(userInfo);

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

@@ -79,7 +79,7 @@ public class UserDataServiceImpl {
                                     sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                                     sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
                             });
-                            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                                     SqlMapping.gets(sqls, sqlsDataA));
                             // 入缓存
                             redisDataUtils.setSweetWechatUser(sweetWechatUser);
@@ -110,7 +110,7 @@ public class UserDataServiceImpl {
                                     sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                                     sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
                             });
-                            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                                     SqlMapping.gets(sqls, sqlsDataA));
                             // 入缓存
                             redisDataUtils.setSweetWechatUserModernsky(sweetWechatUser);
@@ -156,7 +156,7 @@ public class UserDataServiceImpl {
                     sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
                     sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
             });
-            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                     SqlMapping.gets(sqls, sqlsDataA));
             // 入缓存
             redisDataUtils.setSweetWechatUser(sweetWechatUser);

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

@@ -321,7 +321,7 @@ public class RedisDataUtils {
         sqlsDataA.add(new Object[]{
                 sweetRemindVo.getRemindId(), sweetRemindVo.getOpenId(), sweetRemindVo.getUnionId(), sweetRemindVo.getPerformancesId(),
         });
-        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_REMIND_INSERT_DRAW.getKey(),
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_REMIND_INSERT.getKey(),
                 SqlMapping.gets(sqls, sqlsDataA));
     }