|
|
@ -87,15 +87,15 @@ public class PointsModifyConsumer implements RocketMQListener<MessageExt> { |
|
|
|
**/ |
|
|
|
@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<MessageExt> { |
|
|
|
* 根据动作编码和用户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(); |
|
|
|