@Table(name = "asset_loan_invoice_lock_info")
@Getter
@Setter
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class AssetLoanInvoiceLockInfoDo extends AssetLoanInvoiceLockInfoKeyDo implements Serializable {
    private static final long serialVersionUID = 1101362594517114915L;
    /**
     * 借據(jù)鎖鎖狀態(tài) EnumBool 0-否 1-是
     */
    @Column(name = "lock_status")
    private String lockStatus;
    /**
     * 鎖定流水
     */
    @Column(name = "lock_serial_no")
    private String lockSerialNo;
    /**
     * 鎖定交易碼
     */
    @Column(name = "lock_trade_code")
    private String lockTradeCode;
    /**
     * 鎖定交易描述
     */
    @Column(name = "lock_trade_description")
    private String lockTradeDescription;
    /**
     * 樂觀鎖版本
     */
    @Column(name = "lock_version")
    private Integer lockVersion;
    /**
     * 創(chuàng)建時(shí)間
     */
    @Column(name = "create_time")
    private java.util.Date createTime;
    /**
     * 更新時(shí)間
     */
    @Column(name = "update_time")
    private java.util.Date updateTime;
    /**
     * 鎖定時(shí)間
     */
    @Column(name = "lock_time")
    private java.util.Date lockTime;
}

/**
 * 加鎖方法：通過數(shù)據(jù)庫UPDATE的原子性保證不會(huì)重復(fù)加鎖
 * @param loanId 借據(jù)ID
 * @param tradeCode 交易碼
 * @param serialNo 流水號(hào)
 * @return true=加鎖成功，false=已被鎖定
 */
public boolean lockLoanInvoice(String loanId, String tradeCode, String serialNo) {
    // 1. 先查詢當(dāng)前鎖信息（獲取舊版本號(hào)）
    AssetLoanInvoiceLockInfoDo lockInfo = lockInfoMapper.selectByLoanId(loanId);
    if (lockInfo == null) {
        // 首次加鎖，初始化記錄
        lockInfo = new AssetLoanInvoiceLockInfoDo();
        lockInfo.setLoanId(loanId);
        lockInfo.setLockStatus("1");
        lockInfo.setLockSerialNo(serialNo);
        lockInfo.setLockTradeCode(tradeCode);
        lockInfo.setLockVersion(1);
        lockInfo.setLockTime(new Date());
        lockInfoMapper.insert(lockInfo);
        return true;
    }
    
    // 2. 原子更新：帶版本號(hào)+鎖狀態(tài)條件
    int updateCount = lockInfoMapper.updateLockStatus(
        loanId, 
        "0",          // 原狀態(tài)：未鎖定
        lockInfo.getLockVersion(), // 原版本號(hào)
        "1",          // 新狀態(tài)：鎖定
        serialNo,
        tradeCode,
        new Date()
    );
    
    // 3. 只有更新成功（影響行數(shù)=1），才代表加鎖成功
    return updateCount == 1;
}

<update id="updateLockStatus">
    UPDATE asset_loan_invoice_lock_info
    SET lock_status = #{newLockStatus},
        lock_serial_no = #{serialNo},
        lock_trade_code = #{tradeCode},
        lock_time = #{lockTime},
        lock_version = lock_version + 1,
        update_time = NOW()
    WHERE loan_id = #{loanId}
      AND lock_status = #{oldLockStatus}
      AND lock_version = #{oldVersion}
</update>

public boolean unlockLoanInvoice(String loanId, String serialNo) {
    int updateCount = lockInfoMapper.updateUnlockStatus(
        loanId,
        "1",          // 原狀態(tài)：已鎖定
        serialNo,     // 必須是加鎖時(shí)的流水號(hào)
        "0"           // 新狀態(tài)：未鎖定
    );
    return updateCount == 1;
}

/**
 * 定時(shí)任務(wù)：解鎖超過30分鐘的借據(jù)鎖
 */
@Scheduled(fixedRate = 5 * 60 * 1000) // 每5分鐘執(zhí)行一次
public void unlockTimeoutLock() {
    // 計(jì)算超時(shí)時(shí)間：當(dāng)前時(shí)間 - 30分鐘
    Date timeoutTime = new Date(System.currentTimeMillis() - 30 * 60 * 1000);
    // 只解鎖超時(shí)且未解鎖的鎖
    lockInfoMapper.unlockTimeoutLock(timeoutTime);
}

<update id="unlockTimeoutLock">
    UPDATE asset_loan_invoice_lock_info
    SET lock_status = '0',
        lock_serial_no = '',
        lock_trade_code = '',
        lock_version = lock_version + 1,
        update_time = NOW()
    WHERE lock_status = '1'
      AND lock_time < #{timeoutTime}
</update>