修改日志

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/mq/MessageCallbackProducer.java

@@ -43,11 +43,11 @@ public class MessageCallbackProducer {
         message.setTag(TAG);
         message.setBody(JSON.toJSONString(param).getBytes(StandardCharsets.UTF_8));
         try {
-            log.info("MessageCallbackProducer sendMessage = {}", message);
+            log.info("sendMessage = {}", message);
             producer.send(message);
         } catch (Exception e) {
-            log.error("MessageCallbackProducer error send param = {}", param);
-            log.error("MessageCallbackProducer error", e);
+            log.error("error send param = {}", param);
+            log.error("error", e);
             //重试
             retry(message);
         }
@@ -61,7 +61,7 @@ public class MessageCallbackProducer {
                 log.info("sendResult = {}", sendResult);
                 return;
             } catch (Exception e) {
-                log.error("MessageCallbackProducer send error {}", i, e);
+                log.error("retry send error {}", i, e);
             }
         }
     }

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/strategy/reply/impl/PushMessageStrategyV1.java

@@ -219,8 +219,8 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
                 continue;
             }
             // 获取最新dt数据
-            List<AlgGhAutoreplyVideoRankData> dtVserSionStrategyData = getDtVersionStrategyData(key, dtVersion, bucketDataParam.getGhId());
-            result.addAll(dtVserSionStrategyData.stream().map(x -> {
+            List<AlgGhAutoreplyVideoRankData> dtVerSionStrategyData = getDtVersionStrategyData(key, dtVersion, bucketDataParam.getGhId());
+            result.addAll(dtVerSionStrategyData.stream().map(x -> {
                 CgiReplyBucketData cgiReplyBucketData = new CgiReplyBucketData();
                 cgiReplyBucketData.setStrategy(key);
                 cgiReplyBucketData.setSort(x.getSort());