Merge remote-tracking branch 'origin/master'
bynt
1 year ago
commit
a3e0166e2a
@ -1,36 +1,36 @@
|
||||
package com.baiye.aspect;
|
||||
|
||||
import com.baiye.common.CommonLog;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.aspectj.lang.JoinPoint;
|
||||
import org.aspectj.lang.annotation.*;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.Arrays;
|
||||
|
||||
/**
|
||||
* @Author YQY
|
||||
* @Date 2023/5/24
|
||||
*/
|
||||
@Component
|
||||
@Aspect
|
||||
@Slf4j
|
||||
public class BadRequestExceptionAspect {
|
||||
|
||||
/**
|
||||
* 配置切入点
|
||||
*/
|
||||
@Pointcut("execution(* com.baiye.exception.handler.GlobalExceptionHandler.badRequestException(..))")
|
||||
public void badRequestExceptionPointcut() {
|
||||
}
|
||||
|
||||
@Before("badRequestExceptionPointcut()")
|
||||
public void bb(JoinPoint joinPoint) {
|
||||
Object[] args = joinPoint.getArgs();
|
||||
if (args.length > 0) {
|
||||
String str = Arrays.toString(args);
|
||||
int index = str.indexOf(':');
|
||||
if (index != -1) CommonLog.error(str.substring(index + 1, str.length() - 1));
|
||||
}
|
||||
}
|
||||
}
|
||||
//package com.baiye.aspect;
|
||||
//
|
||||
//import com.baiye.common.CommonLog;
|
||||
//import lombok.extern.slf4j.Slf4j;
|
||||
//import org.aspectj.lang.JoinPoint;
|
||||
//import org.aspectj.lang.annotation.*;
|
||||
//import org.springframework.stereotype.Component;
|
||||
//
|
||||
//import java.util.Arrays;
|
||||
//
|
||||
///**
|
||||
// * @Author YQY
|
||||
// * @Date 2023/5/24
|
||||
// */
|
||||
//@Component
|
||||
//@Aspect
|
||||
//@Slf4j
|
||||
//public class BadRequestExceptionAspect {
|
||||
//
|
||||
// /**
|
||||
// * 配置切入点
|
||||
// */
|
||||
// @Pointcut("execution(* com.baiye.exception.handler.GlobalExceptionHandler.badRequestException(..))")
|
||||
// public void badRequestExceptionPointcut() {
|
||||
// }
|
||||
//
|
||||
// @Before("badRequestExceptionPointcut()")
|
||||
// public void badRequestExceptionBefore(JoinPoint joinPoint) {
|
||||
// Object[] args = joinPoint.getArgs();
|
||||
// if (args.length > 0) {
|
||||
// String str = Arrays.toString(args);
|
||||
// int index = str.indexOf(':');
|
||||
// if (index != -1) CommonLog.error(str.substring(index + 1, str.length() - 1));
|
||||
// }
|
||||
// }
|
||||
//}
|
||||
|
||||
@ -0,0 +1,35 @@
|
||||
package com.baiye.timed;
|
||||
|
||||
import cn.hutool.core.date.DateUtil;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.time.DateUtils;
|
||||
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @Author YQY
|
||||
* @Date 2023/5/29
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor
|
||||
@Slf4j
|
||||
public class ElasticsearchTask {
|
||||
|
||||
private final ElasticsearchOperations elasticsearchOperations;
|
||||
|
||||
/**
|
||||
* 删除一个月前es索引,索引规则在logstash应用中的规则创建
|
||||
*/
|
||||
@Scheduled(cron = "0 0 2 * * ?")
|
||||
public void removeIndex() {
|
||||
log.info("定时任务删除es索引开始");
|
||||
Date startDate = DateUtils.addDays(new Date(), -30);
|
||||
String format = DateUtil.format(startDate, "yyyy.MM.dd");
|
||||
elasticsearchOperations.deleteIndex("logstash-" + format);
|
||||
log.info("删除es索引结束");
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue