我先贴代码：

    /**
     * 核心处理卡的逻辑
     * @param {object} reqCard
     * @returns {Promise<*>}
     * @private
     */
    async handleCallbackCard(reqCard) {
        const {app, ctx} = this;
        const logger = this.app.getLogger('myLogger');
        logger.info(`卡回调：${reqCard.order_no},状态：${reqCard.status}`);
        //1.获取卡，然后获取卡的用户最后进行加锁,也需要给这个订单加锁
        await this.getLock(reqCard.order_no, 10000);
        const card = await app.mysql.get('ey_cards', {
            order_no: reqCard.order_no,
            status: 0,
            money_status: 0
        });
        if (null === card) {
            logger.info(`未处理的卡订单并没有找到:${reqCard.order_no},状态:${reqCard.status}`);
            //释放订单锁
            await this.freeLock(card.order_no);
            return false;
        }
        //2.给用户加锁
        await this.getLock(card.uid, 10000);//获取锁,10s超时

        //3.开启事务
        const conn = await app.mysql.beginTransaction();//开启事务

        const groupId = parseInt(card.group_id);
        reqCard.status = parseInt(reqCard.status);//状态
        try {
            //conn
            let user = await conn.get('ey_user', {id: card.uid});
            if (!user) {
                throw new Error('未获取到相关用户');
            }
            const beforeMoney = user.money;

            //如果卡成功了的话
            if (reqCard.status === 1) {
                //处理成功了
                card.real_price = reqCard.real_price;
                card.api_callback_result = reqCard.api_callback_result;
                card.api_msg = reqCard.api_msg;
                //card.money = card.real_price * card.money_rate / 100;
                card.money = (card.real_price * card.money_rate / 100).toFixed(2);
                card.money = parseFloat(card.money);

                //给用户发钱
                const afterMoney = parseFloat(user.money) + card.money;//计算理当增加金额后的钱

                //同步更新用户的金额数据，当时为了防止脏数据使用的这种更新方式
                // const result = await conn.query('UPDATE ey_user SET money=(money+?),score=(score+?),used_money=(used_money+?) where id=?', [
                //     card.money,
                //     card.money,
                //     card.money,
                //     card.uid
                // ]);
                //换一种更新算法
                user.money = afterMoney;
                user.score += card.money;
                user.used_money += card.money;

                const result = await conn.update('ey_user', user);//更新用户数据

                const updateSuccess = result.affectedRows === 1;//是否更新成功
                if (!updateSuccess) {
                    throw new Error(`用户:${card.uid}增加金额失败：${result.message}`);
                }

                //异步写入财务日志
                await app.mysql.insert('ey_user_financial_logs', {
                    uid: card.uid,
                    create_time: new Date().getTime() / 1000,
                    money_before: beforeMoney,
                    money_after: afterMoney,
                    bound_data: card.money,
                    bound_type: 'CARD_MONEY',
                    type: groupId === 0 ? 1 : 2,//1：单卡,2:多卡,3:提现
                    do_note: '销卡入账',
                    note: '销卡入账 ' + card.money + ' 元',
                    status: 0
                });

                card.money_status = 1;
                card.status = 1;
            }

            //如果status==2 就是失败了
            if (reqCard.status === 2) {
                card.status = 2;
                card.real_price = reqCard.real_price;
                card.api_callback_result = reqCard.api_callback_result;
                card.api_msg = reqCard.api_msg;
            }

            //事务进行更新卡,如果是发了钱的状态
            await conn.update('ey_cards', card);//更新卡的事务状态
            const cres = await conn.commit();//提交事务

            //获取更新后的金额
            user = await app.mysql.get('ey_user', {id: card.uid});

            //最后获取一遍金额
            logger.info(`用户：${card.uid},金额增加：${card.money} ,之前：${beforeMoney} ,现在：${user.money},卡ID:${card.id}，卡状态: ${card.status}, 钱状态:${card.money_status}，处理卡组:${groupId}`);

            //最终销卡组无论成功还是失败他的状态改变
            this.handleCardGroup(card).then(res => {
                console.log("处理卡组", res);
            }).catch((err) => {
                logger.error("处理卡组失败:" + err.message);
            });
        } catch (e) {
            await conn.rollback();//回滚
            logger.error(`${card.uid}回调错误,Err:` + e.message);
        }

        //最后进行提交
        if (card.status === 1 && card.money_status === 1) {
            //发送金豆
            this.sendGold(card.uid, card.money).then((res) => {
                console.log("发送金豆");
            });
            //更新用户的登陆
            this.upUserLevel(card.uid).then(() => {
                console.log("检查用户等级");
            });
        }

        //6.free 释放用户锁，释放订单锁
        await this.freeLock(card.uid);
        await this.freeLock(card.order_no);

        return card;
    }

以上的逻辑是一个支付回调的逻辑，本身之前用的FOR UPDATE 用户行级别锁，但是发现不是很好，后续调整到redis setnx lock。

问题如下

偶尔会发现如图所示卡壳现象，我提取了mysqlbinlog，发现如下问题

mysqlbinlog