生成新消息输出日志
This commit is contained in:
@ -31,7 +31,7 @@ public class BizMessageProducerController {
|
||||
@ResponseStatus(code = HttpStatus.OK)
|
||||
public DescribeSiteMsgDetailVO produce(
|
||||
@ApiParam(value = "消息内容", required = true) @Validated @RequestBody BizMessageRawDTO raw) {
|
||||
log.debug("user send raw message: {}", raw);
|
||||
log.info("user send raw message: {}", raw);
|
||||
|
||||
return service.produce(raw).map(source -> {
|
||||
DescribeSiteMsgDetailVO vo = new DescribeSiteMsgDetailVO();
|
||||
|
@ -59,7 +59,7 @@ public class BizMessageProducerServiceImpl implements BizMessageProducerService
|
||||
@Override
|
||||
public Optional<BizMessage> produce(BizMessageRawDTO messageRaw) {
|
||||
return Optional.ofNullable(messageRaw).map(this::evaluate).map(message -> {
|
||||
log.debug("ready to save: {}", message);
|
||||
log.info("ready to save: {}", message);
|
||||
return messageMapper.insert(message) > 0 ? message : null;
|
||||
});
|
||||
}
|
||||
|
Reference in New Issue
Block a user