log

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinBizIntegralReceiver.java

@@ -32,14 +32,18 @@ public class ConsumerGoblinBizIntegralReceiver extends AbstractBizRedisReceiver
 
     @Override
     protected boolean consumerMessageHandler(String msg) {
+        long s = System.currentTimeMillis();
         boolean aBoolean = false;
         try {
             GoblinQueueBizIntegralDto fromJsonObj = JsonUtils.fromJson(msg, GoblinQueueBizIntegralDto.class);
+            log.info("转换s:{}", System.currentTimeMillis() - s);
             if (fromJsonObj == null) {
                 log.warn("CONSUMER MSG NULL_DTO ==> [{}]:{}", this.getRedisStreamKey(), msg);
                 aBoolean = true;
             } else {
+                log.info("开始请求s:{}", System.currentTimeMillis() - s);
                 aBoolean = this.bizIntegralProcessing(fromJsonObj);
+                log.info("请求结束s:{}", System.currentTimeMillis() - s);
             }
         } catch (Exception e) {
             log.error("CONSUMER MSG EX_HANDLE ==> [{}]:{}", this.getRedisStreamKey(), msg, e);
@@ -65,11 +69,14 @@ public class ConsumerGoblinBizIntegralReceiver extends AbstractBizRedisReceiver
             params.add("content", content);
             params.add("uid", uid);
             String resultData = "";
+            long ss = System.currentTimeMillis();
+            log.info("HttpUtil s:{}", ss);
             if (type == 1) {
                 resultData = HttpUtil.post(stoneUrl + "/user/logs/in2111", params, header);
             } else {
                 resultData = HttpUtil.post(stoneUrl + "/user/logs/de2111", params, header);
             }
+            log.info("HttpUtil e:{}", System.currentTimeMillis() - ss);
             log.info("bizIntegralProcessing result:{}", resultData);
             return true;
         } catch (Exception e) {