exit

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinGoodsAnticipateServiceImpl.java

@@ -71,7 +71,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                     goodsAnticipateVo.getAboutStartDate(),
                     goodsAnticipateVo.getAboutEndDate()
             });
-            sendRedis(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(), "goblin_goods_anticipate", sqlAnt);
+            sendRedis("goblin_goods_anticipate", sqlAnt);
 
             //redis消息
             goodsAnticipateValues.forEach(goodsAnticipateValueVo -> {
@@ -84,7 +84,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                         goodsAnticipateValueVo.getAboutStartDate(),
                         goodsAnticipateValueVo.getAboutEndDate(),
                 });
-                sendRedis(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(), "goblin_goods_anticipate_value", sqlValue);
+                sendRedis("goblin_goods_anticipate_value", sqlValue);
             });
 
             //更新mongodb
@@ -94,15 +94,6 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
         return ResponseDto.failure("参数有误");
     }
 
-    public void sendRedis(String rediskey, String sqlKey, LinkedList<Object[]> sqlData) {
-        LinkedList<String> sql = CollectionUtil.linkedListString();
-        sql.add(SqlMapping.get(sqlKey));
-        String sqlStr = SqlMapping.gets(sql, sqlData);
-        queueUtils.sendMsgByRedis(
-                rediskey,
-                sqlStr);
-    }
-
     @Override
     public ResponseDto<Object> updatePeople(Long people) {
         //修改Mongodb
@@ -119,4 +110,13 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
     }
 
 
+    public void sendRedis(String sqlKey, LinkedList<Object[]> sqlData) {
+        LinkedList<String> sql = CollectionUtil.linkedListString();
+        sql.add(SqlMapping.get(sqlKey));
+        String sqlStr = SqlMapping.gets(sql, sqlData);
+        queueUtils.sendMsgByRedis(
+                MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(),
+                sqlStr);
+    }
+
 }