提交 6b15eb85 编写于 作者: zc's avatar zc

update:代码完善

上级 e4635431
...@@ -99,8 +99,7 @@ public class ResultMQMsgListener implements RocketMQListener<MessageExt> { ...@@ -99,8 +99,7 @@ public class ResultMQMsgListener implements RocketMQListener<MessageExt> {
execlog.setRetCode(10); execlog.setRetCode(10);
ruExecLogService.updateById(execlog); ruExecLogService.updateById(execlog);
} else { } else {
ResultsMQMsg resultsMQMsg = JSON.parseObject(body, new TypeReference<ResultsMQMsg>() { ResultsMQMsg resultsMQMsg = JSON.parseObject(body, new TypeReference<ResultsMQMsg>() {});
});
if (!StringUtils.isEmpty(resultsMQMsg.getKeyValueField())) { if (!StringUtils.isEmpty(resultsMQMsg.getKeyValueField())) {
execResultRepository.saveResultsMQMsg(resultsMQMsg); execResultRepository.saveResultsMQMsg(resultsMQMsg);
} }
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册