@Slf4j
@Component
@SuppressWarnings(value = {"unchecked", "rawtypes"})
public class RedisService {
    @Autowired
    public RedisTemplate redisTemplate;
    /**
     * 非阻塞獲取分布式鎖（原子操作）
     * @param lockKey 鎖鍵
     * @param requestId 唯一標(biāo)識，防止誤刪鎖
     * @param expireTime 過期時(shí)間(秒)
     * @return 獲取結(jié)果
     */
    public boolean tryLock(String lockKey, String requestId, long expireTime) {
        try {
            Boolean result = redisTemplate.opsForValue().setIfAbsent(
                    lockKey,
                    requestId,
                    expireTime,
                    TimeUnit.SECONDS
            );
            return Boolean.TRUE.equals(result);
        } catch (Exception e) {
            log.error("獲取分布式鎖失敗, lockKey:{}", lockKey, e);
            return false;
        }
    }
    /**
     * 安全釋放鎖（Lua腳本保證原子性）
     * @param lockKey 鎖鍵
     * @param requestId 唯一標(biāo)識
     * @return 釋放結(jié)果
     */
    public boolean releaseLock(String lockKey, String requestId) {
        String luaScript = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
        try {
            DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
            redisScript.setScriptText(luaScript);
            redisScript.setResultType(Long.class);
            Long result = (Long) redisTemplate.execute(
                    redisScript,
                    Collections.singletonList(lockKey),
                    requestId
            );
            return result != null && result > 0;
        } catch (Exception e) {
            log.error("釋放分布式鎖失敗, lockKey:{}", lockKey, e);
            return false;
        }
    }
    // 省略其他緩存方法...
}

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.UUID;
import java.util.function.Supplier;
/**
 * 通用Redis非阻塞分布式鎖工具類
 * 適配：表單防重、接口防重復(fù)提交、并發(fā)插入控制
 */
@Slf4j
@Component
public class RedisLockUtil {
    @Autowired
    private RedisService redisService;
    /**
     * 非阻塞鎖執(zhí)行通用方法
     * @param lockKey 鎖唯一鍵（建議：lock:業(yè)務(wù)模塊:業(yè)務(wù)單號）
     * @param expireSeconds 鎖過期時(shí)間（秒，兜底防死鎖）
     * @param businessLogic 業(yè)務(wù)邏輯代碼塊
     * @param <T> 返回值泛型
     * @return 業(yè)務(wù)執(zhí)行結(jié)果
     */
    public <T> T executeWithLock(String lockKey, int expireSeconds, Supplier<T> businessLogic) {
        // 生成唯一請求ID，防止誤刪其他線程的鎖
        String requestId = UUID.randomUUID().toString();
        // 1. 非阻塞獲取鎖
        boolean isLocked = redisService.tryLock(lockKey, requestId, expireSeconds);
        if (!isLocked) {
            log.warn("[分布式鎖] 獲取失敗，鎖鍵:{}，操作進(jìn)行中", lockKey);
            throw new RuntimeException("操作進(jìn)行中，請勿重復(fù)提交！");
        }
        try {
            // 2. 執(zhí)行核心業(yè)務(wù)邏輯
            return businessLogic.get();
        } catch (Exception e) {
            log.error("[分布式鎖] 業(yè)務(wù)執(zhí)行失敗，鎖鍵:{}，允許重試", lockKey, e);
            throw new RuntimeException("提交失?。? + e.getMessage() + "，可重試！");
        } finally {
            // 3. 無論成功/失敗，必須釋放鎖
            boolean isReleased = redisService.releaseLock(lockKey, requestId);
            if (!isReleased) {
                log.warn("[分布式鎖] 釋放失敗，鎖鍵:{}，requestId:{}（可能已過期自動(dòng)釋放）", lockKey, requestId);
            }
        }
    }
}

@Service
@Slf4j
public class FormSubmitService {
    @Autowired
    private RedisLockUtil redisLockUtil;
    // 業(yè)務(wù)Mapper，隱藏具體表信息
    @Autowired
    private BizFormMapper bizFormMapper;
    /**
     * 表單提交核心方法
     * @param djbh 業(yè)務(wù)單號（唯一標(biāo)識）
     * @param formDTO 表單參數(shù)
     * @return 接口返回結(jié)果
     */
    public Result submitForm(String djbh, BizFormDTO formDTO) {
        try {
            // 構(gòu)造鎖鍵：隱藏具體業(yè)務(wù)模塊，規(guī)范命名
            String lockKey = "lock:biz_form_submit:" + djbh;
            // 調(diào)用鎖工具類，60秒過期兜底，執(zhí)行業(yè)務(wù)邏輯
            return redisLockUtil.executeWithLock(lockKey, 60, () -> {
                // ========== 核心業(yè)務(wù)邏輯 ==========
                // 1. 查詢是否已存在（成功后禁止重復(fù)提交）
                Object existData = bizFormMapper.selectByDjbh(djbh);
                if (existData != null) {
                    return Result.fail("該單據(jù)已提交，請勿重復(fù)操作！");
                }
                // 2. 執(zhí)行插入操作
                bizFormMapper.insertForm(formDTO);
                return Result.success("提交成功！");
                // ================================
            });
        } catch (RuntimeException e) {
            // 捕獲鎖異常、業(yè)務(wù)異常，統(tǒng)一返回
            return Result.fail(e.getMessage());
        }
    }
    // 省略Result成功/失敗封裝方法...
}