admin
2021-02-06 6c09cbd70388ae53ec593de253f69cfa1a3eeda7
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());
    }