提交支付查询

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/service/receiver/RedisPayReceiver.java

@@ -26,7 +26,7 @@ public class RedisPayReceiver implements StreamListener<String, MapRecord<String
 
     @Override
     public void onMessage(MapRecord<String, String, String> message) {
-        log.info("接受到来自redis REFUND 的消息");
+        log.info("接受到来自redis PAY 的消息");
         System.out.println("message id " + message.getId());
         System.out.println("stream " + message.getStream());
         System.out.println("body " + message.getValue());
@@ -42,8 +42,6 @@ public class RedisPayReceiver implements StreamListener<String, MapRecord<String
             log.debug("CONSUMER SQL result of execution:{}", rstBatchSqls);
             if (rstBatchSqls) {
                 //应答
-            } else {
-                sendMySqlRedis(msg);
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -60,7 +58,7 @@ public class RedisPayReceiver implements StreamListener<String, MapRecord<String
         try {
             HashMap<String, String> map = new HashMap<>();
             map.put("message", msg);
-            MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(DragonConstant.MysqlRedisQueueEnum.DRAGON_REFUND_KEY.getCode());
+            MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_KEY.getCode());
             stringRedisTemplate.opsForStream().add(record);
             return true;
         } catch (Exception e) {