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()); }