integral tmpMsg AbstractBizRedisReceiver onMessage

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

@@ -4,24 +4,20 @@ import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import com.liquidnet.service.consumer.base.receiver.AbstractBizRedisReceiver;
 import com.liquidnet.service.feign.stone.api.FeignStoneIntegralClient;
 import com.liquidnet.service.sweet.param.SweetStoneIntegralParam;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.stream.MapRecord;
 import org.springframework.data.redis.connection.stream.StreamRecords;
-import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.util.HashMap;
 
 @Slf4j
 @Component
-public class ConsumerSweetStoneIntegralReceiver extends AbstractSqlRedisReceiver {
-
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
+public class ConsumerSweetStoneIntegralReceiver extends AbstractBizRedisReceiver {
 
     @Autowired
     private FeignStoneIntegralClient feignStoneIntegralClient;
@@ -36,7 +32,7 @@ public class ConsumerSweetStoneIntegralReceiver extends AbstractSqlRedisReceiver
         return MQConst.SweetQueue.SWEET_STONE_INTEGRAL.getGroup();
     }
 
-    @Override
+    /*@Override
     public void onMessage(MapRecord<String, String, String> message) {
         String redisStreamKey = this.getRedisStreamKey();
         log.debug("CONSUMER MSG[streamKey:{},messageId:{},stream:{},body:{}]", redisStreamKey, message.getId(), message.getStream(), message.getValue());
@@ -53,9 +49,9 @@ public class ConsumerSweetStoneIntegralReceiver extends AbstractSqlRedisReceiver
         } catch (Exception e) {
             log.error("#CONSUMER MSG EX_DEL ==> [{}]RESULT:{},MESSAGE:{}", redisStreamKey, result, message.getValue(), e);
         }
-    }
+    }*/
 
-    private boolean consumerMessageHandler(String msg) {
+    protected boolean consumerMessageHandler(String msg) {
         boolean aBoolean = false;
         try {
             SweetStoneIntegralParam param = JsonUtils.fromJson(msg, SweetStoneIntegralParam.class);

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

@@ -3,24 +3,20 @@ package com.liquidnet.service.consumer.base.receiver.sweet;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import com.liquidnet.service.consumer.base.receiver.AbstractBizRedisReceiver;
 import com.liquidnet.service.consumer.base.service.impl.sweet.SweetWechatTemplateMsgServiceImpl;
 import com.liquidnet.service.sweet.dto.param.SweetOpenSendMsgParam;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.stream.MapRecord;
 import org.springframework.data.redis.connection.stream.StreamRecords;
-import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.util.HashMap;
 
 @Slf4j
 @Component
-public class ConsumerSweetTemplateMsgReceiver extends AbstractSqlRedisReceiver {
-
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
+public class ConsumerSweetTemplateMsgReceiver extends AbstractBizRedisReceiver {
 
     @Autowired
     SweetWechatTemplateMsgServiceImpl sweetWechatTemplateService;
@@ -35,7 +31,7 @@ public class ConsumerSweetTemplateMsgReceiver extends AbstractSqlRedisReceiver {
         return MQConst.SweetQueue.SWEET_TEMPLATE_MSG.getGroup();
     }
 
-    @Override
+    /*@Override
     public void onMessage(MapRecord<String, String, String> message) {
         String redisStreamKey = this.getRedisStreamKey();
         log.debug("CONSUMER MSG[streamKey:{},messageId:{},stream:{},body:{}]", redisStreamKey, message.getId(), message.getStream(), message.getValue());
@@ -52,9 +48,9 @@ public class ConsumerSweetTemplateMsgReceiver extends AbstractSqlRedisReceiver {
         } catch (Exception e) {
             log.error("#CONSUMER MSG EX_DEL ==> [{}]RESULT:{},MESSAGE:{}", redisStreamKey, result, message.getValue(), e);
         }
-    }
+    }*/
 
-    private boolean consumerMessageHandler(String msg) {
+    protected boolean consumerMessageHandler(String msg) {
         boolean aBoolean = false;
         try {
             SweetOpenSendMsgParam sweetOpenSendMsgParam = JsonUtils.fromJson(msg, SweetOpenSendMsgParam.class);