@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Log {
    String value() default "";
}

@Aspect
@Slf4j
@Component
public class LogAspect {
    /**
     * 切入點(diǎn)
     */
    @Pointcut("execution(* com.zh.cn.*.*.*(..)) && @annotation(com.zh.cn.annotation.Log)")
    public void LogAspect(){
    }
    @Before("LogAspect()")
    public void before(JoinPoint joinPoint){
        //收集日志系統(tǒng)
        log.info("日志收集---前置通知");
        //獲取日志收集中的實(shí)體類
        log.info("參數(shù)：{}",joinPoint);
        //獲取basePojo實(shí)體類
        Object[] args = joinPoint.getArgs();
        Object entity = args[0];
        try {
            Method setUpdateTime = entity.getClass().getDeclaredMethod("setUpdateTime", Date.class);
            Method setUpdateName = entity.getClass().getDeclaredMethod("setUpdateName", String.class);
            //通過反射為對象賦值
            setUpdateTime.invoke(entity,new Date());
            setUpdateName.invoke(entity,"zh");
        } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
            throw new RuntimeException(e);
        }
        //收集日志
        //~~~~
        log.info("日志收集---后置通知");
    }
}

/**
 * @Description:
 * @author:<a href="2358853434@qq.com"></a> zh
 * @Create : 2024/10/5
 **/
@RestController
@RequestMapping("/order/v1")
public class OrderController {
    @Resource
    private OrderService orderService;
    @GetMapping("/update")
    public Result update() {
        Order order = new Order();
        order.setId(1292071939041697792L);
        order.setName("測試商品");
        order.setNum(128L);
        return orderService.update(order);
    }
    @GetMapping("/insert")
    public Result insert(){
        return  Result.success();
    }
}

@Service
@Slf4j
public class OrderServiceimpl implements OrderService {
    @Resource
    RedisTemplate<String,String> redisTemplate;
    @Resource
    RedisDistributedLock redisDistributedLock;
    /**
     * 更新訂單接口
     * @param order
     * @return
     */
    @Log
    public Result update(Order order) {
        log.info("update開始，訂單號：{}",order.getId()+"order:"+order);
        //加鎖成功
        while(redisDistributedLock.tryLock("order:"+order.getId()+":"+Thread.currentThread().getId(), "requestId", 10)) {
            //執(zhí)行訂單減減
            log.info("加鎖成功"+Thread.currentThread().getId());
            redisTemplate.opsForValue().set("order:"+order.getId(), order.toString());
            break;
        }
        if (redisDistributedLock.unlock("order:"+order.getId()+":"+Thread.currentThread().getId(),"requestId")) {
            log.info("update結(jié)束，訂單號：{}",order.getId());
            return Result.success();
        }
        return Result.error("下單失敗");
    }
}

GET http://localhost:19002/order/v1/update
Authorization: Basic cm9vdDpyb290