Jackwang
6 years ago
14 changed files with 193 additions and 1 deletions
@ -0,0 +1,64 @@ |
|||
package com.elink.esua.epdc.modules.rocketmq.consumer; |
|||
|
|||
import com.alibaba.fastjson.JSONObject; |
|||
import com.elink.esua.epdc.commons.tools.constant.RocketMqConstant; |
|||
import com.elink.esua.epdc.modules.comment.service.EventCommentService; |
|||
import com.elink.esua.epdc.modules.events.service.EpdcEventsService; |
|||
import com.elink.esua.epdc.modules.item.service.ItemService; |
|||
import com.elink.esua.epdc.modules.rocketmq.dto.RejectRecordDTO; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.rocketmq.common.message.MessageExt; |
|||
import org.apache.rocketmq.spring.annotation.MessageModel; |
|||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
|||
import org.apache.rocketmq.spring.core.RocketMQListener; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
/** |
|||
* |
|||
* 内容审核驳回信息处理-监听MQ消息 |
|||
* |
|||
* @Author：wangtong |
|||
* @Date：2020/7/14 1:54 |
|||
*/ |
|||
@Slf4j |
|||
@Component |
|||
@RocketMQMessageListener(topic = RocketMqConstant.MQ_TOPIC_ISSUE_ITEM_CONTENTSECURITY, consumerGroup = "${rocketmq.consumer.contentSecurity-group}", messageModel = MessageModel.CLUSTERING) |
|||
public class RejectCheckRecordConsumer implements RocketMQListener<MessageExt> { |
|||
|
|||
@Autowired |
|||
private EpdcEventsService epdcEventsService; |
|||
|
|||
@Autowired |
|||
private EventCommentService eventCommentService; |
|||
|
|||
@Autowired |
|||
private ItemService itemService; |
|||
|
|||
|
|||
@Override |
|||
public void onMessage(MessageExt messageExt) { |
|||
log.info("EPDC-EVENTS-SERVER消费消息START：{topic:{}, msgId:{}}", RocketMqConstant.MQ_TOPIC_ISSUE_ITEM_CONTENTSECURITY, messageExt.getMsgId()); |
|||
try { |
|||
String charset = "UTF-8"; |
|||
String body = new String(messageExt.getBody(), charset); |
|||
String tag = messageExt.getTags(); |
|||
RejectRecordDTO dto = JSONObject.parseObject(body, RejectRecordDTO.class); |
|||
if(RocketMqConstant.MQ_TAG_ISSUE_ITEM_SUBMIT_CONTENTSECURITY.equals(tag)){ |
|||
//删除 我要报事 相关信息
|
|||
epdcEventsService.rejectEventsInfo(dto); |
|||
}else if(RocketMqConstant.MQ_TAG_ISSUE_ITEM_COMMENT_CONTENTSECURITY.equals(tag)){ |
|||
//删除 议题项目评论 相关信息
|
|||
eventCommentService.rejectEventsCommentInfo(dto); |
|||
}else if(RocketMqConstant.MQ_TAG_ISSUE_ITEM_SATISFACTION_CONTENTSECURITY.equals(tag)){ |
|||
//置空 满意度评价 文本内容
|
|||
itemService.rejectItemSatisfactionInfo(dto); |
|||
} |
|||
|
|||
log.info("EPDC-EVENTS-SERVER消费消息END：{topic:{}, msgId:{}, body:{}}", RocketMqConstant.MQ_TOPIC_ISSUE_ITEM_CONTENTSECURITY, messageExt.getMsgId(), body); |
|||
} catch (Exception e) { |
|||
log.info("EPDC-EVENTS-SERVER消费消息失败：msgId:{}", messageExt.getMsgId()); |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,27 @@ |
|||
package com.elink.esua.epdc.modules.rocketmq.dto; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* |
|||
* 内容审核驳回信息处理-发送MQ消息DTO |
|||
* |
|||
* @Author： wangtong |
|||
* @Date： 2020/7/14 14:58 |
|||
*/ |
|||
@Data |
|||
public class RejectRecordDTO implements Serializable { |
|||
|
|||
private static final long serialVersionUID = 3032661994413974324L; |
|||
/** |
|||
* 用户ID |
|||
*/ |
|||
private String userId; |
|||
|
|||
/** |
|||
* 关联信息ID |
|||
*/ |
|||
private String relationId; |
|||
} |
|||
Loading…
Reference in new issue