diff --git a/lms/nladmin-system/src/main/java/org/nl/modules/logging/aspect/LogAspect.java b/lms/nladmin-system/src/main/java/org/nl/modules/logging/aspect/LogAspect.java index 76053b8cd..1e279badd 100644 --- a/lms/nladmin-system/src/main/java/org/nl/modules/logging/aspect/LogAspect.java +++ b/lms/nladmin-system/src/main/java/org/nl/modules/logging/aspect/LogAspect.java @@ -74,9 +74,10 @@ public class LogAspect { String methodName = joinPoint.getTarget().getClass().getName() + "." + signature.getName() + "()"; String params = getParameter(method, joinPoint.getArgs()); HttpServletRequest request = RequestHolder.getHttpServletRequest(); + String url = request.getRequestURI(); String requestIp = StringUtils.getIp(request); - MDC.put("requestMethod",methodName); + MDC.put("requestMethod",url); MDC.put("requestIp", StringUtils.getIp(request)); MDC.put("traceId", BaseCode.intToChars(IdUtil.getLongId())); MDC.put("requestTime", DateUtil.now()); @@ -84,7 +85,7 @@ public class LogAspect { Object result = null; long comming = System.currentTimeMillis(); try { - log.info("[--request--][请求方法:{}][请求参数:{}]",methodName,params); + log.info("[--request--][请求接口:{}][请求参数:{}]",url,params); result = joinPoint.proceed(); //是否把日志存到日志表 if (logInfo.isAddLogTable()) { @@ -112,17 +113,16 @@ public class LogAspect { json.put("return_result", parse); interfaceLog.insert(json); } catch (Exception e) { - } } }catch (Exception ex){ - log.error("[--requestError--][请求方法:{}][请求参数:{}]【异常信息 :{}】", methodName,params, ex); + log.error("[--requestError--][请求接口:{}][请求参数:{}]【异常信息 :{}】", url,params, ex); Log log = new Log("ERROR", System.currentTimeMillis() - comming); log.setExceptionDetail(ThrowableUtil.getStackTrace(ex).getBytes()); logService.save(getUsername(), StringUtils.getBrowser(request), StringUtils.getIp(request), (ProceedingJoinPoint) joinPoint, log); throw ex; }finally { - log.info("[--response--][请求方法:{}][请求参数:{}],请求执行结束",methodName,params); + log.info("[--response--][请求接口:{}][请求参数:{}],请求执行结束",url,params); MDC.clear(); } return result; diff --git a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/dto/LogQuery.java b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/dto/LogQuery.java index 9523a2480..bc006286d 100644 --- a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/dto/LogQuery.java +++ b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/dto/LogQuery.java @@ -38,5 +38,5 @@ public class LogQuery { private Integer size = 20; - private Integer page = 0; + private Integer page = 1; } diff --git a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java index d8a10dcdb..d0f550a69 100644 --- a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java +++ b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java @@ -43,7 +43,7 @@ public class EsLogServiceImpl implements EsLogService { if (logQuery != null){ BoolQueryBuilder query = QueryBuilders.boolQuery(); //requestMethod extractedParam(logQuery, query); - Iterable all = esLogRepository.search(query, PageRequest.of(logQuery.getPage(),logQuery.getSize(), Sort.by("@timestamp").descending())); + Iterable all = esLogRepository.search(query, PageRequest.of(logQuery.getPage()-1,logQuery.getSize(), Sort.by("@timestamp").descending())); page.setRecords(((AggregatedPageImpl) all).getContent()); page.setTotal(((AggregatedPageImpl) all).getTotalElements()); page.setPages(logQuery.getPage()); @@ -63,6 +63,7 @@ public class EsLogServiceImpl implements EsLogService { if (logQuery.getFilterSql()){ query.mustNot().add(QueryBuilders.wildcardQuery("logger","org.nl.modules.wql.core.engine.*")); } + query.mustNot().add(QueryBuilders.matchPhraseQuery("logger","org.elasticsearch.client.RestClient")); if (StringUtils.isNotEmpty(logQuery.getTraceId())){ query.must().add(QueryBuilders.matchQuery("traceId", logQuery.getTraceId())); } @@ -85,7 +86,7 @@ public class EsLogServiceImpl implements EsLogService { for (LevelEnum value : LevelEnum.values()) { JSONObject level = new JSONObject(); level.put("label", value.name()); - level.put("Value", value.name()); + level.put("value", value.name()); result.add(level); } return result; diff --git a/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/ExecutionJob.java b/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/ExecutionJob.java index f24515c21..9a289805c 100644 --- a/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/ExecutionJob.java +++ b/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/ExecutionJob.java @@ -56,8 +56,6 @@ public class ExecutionJob extends QuartzJobBean { logDto.setCronExpression(quartzJob.getCronExpression()); try { // 执行任务 - System.out.println("--------------------------------------------------------------"); - System.out.println("任务开始执行，任务名称：" + quartzJob.getJobName()); QuartzRunnable task = new QuartzRunnable(quartzJob.getBeanName(), quartzJob.getMethodName(), quartzJob.getParams()); Future future = EXECUTOR.submit(task); @@ -69,8 +67,6 @@ public class ExecutionJob extends QuartzJobBean { } // 任务状态 logDto.setIsSuccess(true); - System.out.println("任务执行完毕，任务名称：" + quartzJob.getJobName() + ", 执行时间：" + times + "毫秒"); - System.out.println("--------------------------------------------------------------"); // 判断是否存在子任务 if (StrUtil.isNotEmpty(quartzJob.getSubTask())) { String[] tasks = quartzJob.getSubTask().split("[,，]"); @@ -81,8 +77,6 @@ public class ExecutionJob extends QuartzJobBean { if (StrUtil.isNotEmpty(uuid)) { redisUtils.set(uuid, false); } - System.out.println("任务执行失败，任务名称：" + quartzJob.getJobName()); - System.out.println("--------------------------------------------------------------"); long times = System.currentTimeMillis() - startTime; logDto.setTime(times); // 任务状态 0：成功 1：失败 @@ -95,7 +89,7 @@ public class ExecutionJob extends QuartzJobBean { quartzJobService.updateIsPause(quartzJob); } //异常时候打印日志 - log.info(logDto.toString()); + log.error(logDto.toString()); quartzLogMapper.insert(logDto); } finally { diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/BookTwoConfirmTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/BookTwoConfirmTask.java index f16bb8c18..3b075623f 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/BookTwoConfirmTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/BookTwoConfirmTask.java @@ -6,11 +6,9 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; -import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.nl.modules.common.exception.BadRequestException; import org.nl.common.utils.SecurityUtils; -import org.nl.modules.system.util.CodeUtil; import org.nl.modules.wql.core.bean.WQLObject; import org.nl.modules.wql.util.SpringContextHolder; import org.nl.wms.sch.AcsTaskDto; @@ -18,6 +16,7 @@ import org.nl.wms.sch.manage.AbstractAcsTask; import org.nl.wms.sch.manage.TaskStatusEnum; import org.nl.wms.sch.service.PointService; import org.nl.wms.sch.service.dto.PointDto; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -26,11 +25,12 @@ import java.util.HashMap; import java.util.List; @Service -@RequiredArgsConstructor @Slf4j public class BookTwoConfirmTask extends AbstractAcsTask { private final String THIS_CLASS = BookTwoConfirmTask.class.getName(); - private final CutConveyorTask conveyorTask; + @Autowired + private CutConveyorTask conveyorTask; + @Override public List addTask() { diff --git a/lms/nladmin-system/src/main/resources/logback-spring.xml b/lms/nladmin-system/src/main/resources/logback-spring.xml index 075f0ab5c..e86c14ebe 100644 --- a/lms/nladmin-system/src/main/resources/logback-spring.xml +++ b/lms/nladmin-system/src/main/resources/logback-spring.xml @@ -85,7 +85,7 @@ https://juejin.cn/post/6844903775631572999 requestTime - %X{requestTime} + %d{yyyy-MM-dd HH:mm:ss.SSS} requestIp