Procházet zdrojové kódy

chore: 修改日志输出级别

Marko552 před 3 roky
rodič
revize
4d2cd46bce

+ 1 - 2
abi-cloud-qr-platform-common/src/main/java/com/abi/task/common/excel/ExcelInputFactory.java

@@ -179,8 +179,7 @@ public class ExcelInputFactory {
                     }
                     //调用method
                     Method method = methodCache.get(fieldName);
-                    String str = value.toString();
-                    method.invoke(t,StrUtils.filterHtml(str));
+                    method.invoke(t,StrUtils.filterHtml(value.toString()));
                 }
                 excelPojoList.add(t);
             }

+ 2 - 3
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/aop/ControllerMethodParamLog.java

@@ -41,7 +41,6 @@ public class ControllerMethodParamLog {
         MethodSignature signature = (MethodSignature) point.getSignature();
         String urlDes = signature.getMethod().getAnnotation(ApiOperation.class).value();
         //请求路径,类名,方法名
-        log.info(" ");
         log.info("=====>请求路径:" + requestPath);
         log.info("=====>Controller方法:" + className + "." + methodName + "()");
         log.info("=====>方法描述:" + urlDes);
@@ -50,7 +49,7 @@ public class ControllerMethodParamLog {
         Object proceed = point.proceed();
         log.info(" ");
         log.info("=====>Controller结束:" + className + "." + methodName + "()");
-        log.info("=====>出参: " + JSONUtil.toJsonStr(proceed));
+        log.debug("=====>出参: " + JSONUtil.toJsonStr(proceed));
         log.info("=====>耗时 : " + (System.currentTimeMillis() - startTime));
         log.info(" ");
         return proceed;
@@ -66,7 +65,7 @@ public class ControllerMethodParamLog {
             }
             return sb.toString();
         } catch (Exception e) {
-            log.info("拼接入参异常", e);
+            log.warn("拼接入参异常", e);
             return "";
         }
     }

+ 2 - 2
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/aop/ServiceMethodParamLog.java

@@ -33,9 +33,9 @@ public class ServiceMethodParamLog {
         log.info(" ");
         Object proceed = point.proceed();
         log.info(" ");
-        log.info("--------->出参: " + JSONUtil.toJsonStr(proceed));
+        log.debug("--------->出参: " + JSONUtil.toJsonStr(proceed));
         log.info("--------->结束:" + className + "." + methodName + "()");
-        log.info(" ");
+        log.debug(" ");
         return proceed;
     }
 

+ 0 - 1
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/config/mybatis/ResultSqlInterceptor.java

@@ -38,7 +38,6 @@ public class ResultSqlInterceptor implements Interceptor {
         Object result = invocation.proceed();
         long endTime = System.currentTimeMillis();
         String str = JSONUtil.toJsonStr(result);
-//        log.info("-------------->mybatis 出参:" + str);
         log.info("-------------->mybatis 执行时间: " + (endTime - startTime) + " ms");
         return result;
     }

+ 0 - 4
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/mq/TableStoreBatchInsertConsumer.java

@@ -3,16 +3,12 @@ package com.abi.qms.platform.infrastructure.mq;
 import cn.hutool.json.JSONUtil;
 import com.abi.qms.platform.dao.tablestore.entity.QrCode;
 import com.abi.task.common.tablestore.TableStorePlusUtils;
-import com.rabbitmq.client.Channel;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.amqp.core.AcknowledgeMode;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 import java.util.List;

+ 0 - 4
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/mq/TableStoreBatchUpdateConsumer.java

@@ -1,8 +1,6 @@
 package com.abi.qms.platform.infrastructure.mq;
 
-import cn.hutool.json.JSONUtil;
 import com.abi.ootb.core.utils.JsonUtils;
-import com.abi.qms.platform.dao.tablestore.entity.QrCode;
 import com.abi.qms.platform.infrastructure.util.AsyncTableStoreUtil;
 import com.abi.task.common.tablestore.TableStorePlusUtils;
 import lombok.SneakyThrows;
@@ -13,8 +11,6 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.List;
-
 /**
  * @className: com.abi.qms.platform.infrastructure.mq-> TableStoreBatchInsertConsumer
  * @description: tableStore batchInsert

+ 19 - 0
abi-cloud-qr-platform-server/src/test/java/com/abi/qms/platform/TableStoreTest.java

@@ -2,6 +2,7 @@ package com.abi.qms.platform;
 
 import cn.hutool.json.JSONUtil;
 import com.abi.task.common.tablestore.TableStoreUtils;
+import com.alicloud.openservices.tablestore.SyncClient;
 import com.alicloud.openservices.tablestore.model.*;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
@@ -99,4 +100,22 @@ public class TableStoreTest {
         UpdateTableResponse response = tableStoreUtils.updateTable(100000,tableName);
         log.info("更新表结构吞吐:{}",JSONUtil.toJsonStr(response));
     }
+
+
+    /**
+     * ABIALI-BEES-PROD
+     * SRV_QMS_tablestoreprod@ab-inbev.onaliyun.com
+     * password: o3R)RfFIKbdmcO{bFwAXz72Tzh5Q}Rw(
+     * 公网: https://ABIALI-BEES-PROD.cn-shanghai.ots.aliyuncs.com
+     */
+
+    @Test
+    public void connectTest(){
+        SyncClient syncClient =  new SyncClient("https://ABIALI-BEES-PROD.cn-shanghai.ots.aliyuncs.com",
+                "LTAI5tEnSbbQikjB2y4W7TVx", "crgPm74zKMljrycoF2OsBGrYtkxdtY", "ABIALI-BEES-PROD");
+        syncClient.asAsyncClient();
+    }
+
+
+
 }