From 13f9d3466febf6ce4e14aa6f181dc389e9f8d7f8 Mon Sep 17 00:00:00 2001 From: songyunpeng Date: Sat, 9 May 2020 11:08:23 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A7=AF=E5=88=86=E5=9F=8B=E7=82=B9=20?= =?UTF-8?q?=E6=B6=88=E8=B4=B9=E6=A8=A1=E5=9D=97=E5=8F=82=E6=95=B0=E5=8A=A0?= =?UTF-8?q?=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/elink/esua/epdc/mq/PointsModifyConsumer.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java b/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java index 48b68c7c..05eac126 100644 --- a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java +++ b/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java @@ -87,15 +87,15 @@ public class PointsModifyConsumer implements RocketMQListener { **/ @Override public void onMessage(MessageExt messageExt) { - log.info("EPDC-NEWS-SERVER消费消息START：{topic:{}, msgId:{}}", RocketMqConstant.MQ_TOPIC_ORGANIZATION, messageExt.getMsgId()); + log.info("EPDC-POINTS-SERVER消费消息START：{topic:{}, msgId:{}}", RocketMqConstant.MQ_TOPIC_ORGANIZATION, messageExt.getMsgId()); try { String charset = "UTF-8"; String body = new String(messageExt.getBody(), charset); BehaviorDto dto = JSONObject.parseObject(body, BehaviorDto.class); this.handlePoints(dto); - log.info("EPDC-NEWS-SERVER消费消息END：{topic:{}, msgId:{}, body:{}}", RocketMqConstant.MQ_TOPIC_ORGANIZATION, messageExt.getMsgId(), body); + log.info("EPDC-POINTS-SERVER消费消息END：{topic:{}, msgId:{}, body:{}}", RocketMqConstant.MQ_TOPIC_ORGANIZATION, messageExt.getMsgId(), body); } catch (Exception e) { - log.info("EPDC-NEWS-SERVER消费消息失败：msgId:{}", messageExt.getMsgId()); + log.info("EPDC-POINTS-SERVER消费消息失败：msgId:{}", messageExt.getMsgId()); e.printStackTrace(); } } @@ -108,6 +108,10 @@ public class PointsModifyConsumer implements RocketMQListener { * 根据动作编码和用户ID获取此动作在一定时限内的总分，然后根据上线统计指标判断是否到达上限值，未到达加分或减分，达到则不进行操作 */ private void handlePoints(BehaviorDto dto) { + //解析参数 + if(StringUtils.isBlank(dto.getReferenceId()) || StringUtils.isBlank(dto.getUserId()) || StringUtils.isBlank(dto.getBehavior())){ + return; + } //计算是否超过该动作的积分上限 -- 开始 //1.根据行为编码获取积分规则 PointsLogsFormDTO pointsLogsFormDTO = new PointsLogsFormDTO();