admin
2021-06-24 df4441322e9801c102299451da41d7c40b4502e9
service-lucky/src/main/java/com/ks/lucky/service/impl/LuckyMQServiceImpl.java
@@ -52,7 +52,6 @@
        return luckyMQMapper.count(query);
    }
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void removeUnSendMsg(String taskId) throws LuckyMQException {
        LuckyMQ old = luckyMQMapper.selectByTaskIdForUpdate(taskId);
@@ -60,7 +59,7 @@
            return;
        }
        if (old.getState() != LuckyMQ.STATE_NOT_SEND) {
            throw new LuckyMQException(1, "消息不是待发送状态");
            return;
        }
        luckyMQMapper.deleteByPrimaryKey(old.getId());
    }