StrayWarrior 9 mesi fa
parent
commit
1f04dc4bc1

+ 0 - 1
long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/mq/MessageCallbackCustomer.java

@@ -29,7 +29,6 @@ public class MessageCallbackCustomer implements MessageListener {
 
     @Override
     public Action consume(Message message, ConsumeContext consumeContext) {
-        System.out.println("Receive: " + message);
         CallbackParam param = JSONObject.parseObject(new String(message.getBody()), CallbackParam.class);
         log.info("param = {}", param);
         if (CollectionUtils.isEmpty(param.getReplyInfo())) {

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

@@ -46,6 +46,7 @@ public class MessageCallbackProducer {
             SendResult sendResult = producer.send(message);
             log.info("sendResult = {}", sendResult);
         } catch (Exception e) {
+            // TODO: 写阿里云日志
             log.error("MessageCallbackProducer send param = {} error", param, e);
             //重试
             retry(message);

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

@@ -195,6 +195,7 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
 
     private List<CgiReplyBucketData> readStrategyOrderSmallData(Set<String> keyedSet) {
         List<CgiReplyBucketData> result = new ArrayList<>();
+        // TODO: 只更新对应公众号的数据
         for (String key : keyedSet) {
             if ("base".equals(key)) {
                 // base作为人工控制