admin
2021-01-19 8f1b5245c592cd6dc5eb5a73f9a0ceb2a85f2048
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());
    }