|
|
|
@ -182,6 +182,15 @@ public class CheckResultServiceImpl extends BaseServiceImpl<CheckResultDao, Chec |
|
|
|
}else if(ModuleName.WORK_MONTH.getCode().equals(record.getModule())){ |
|
|
|
topic = RocketMqConstant.MQ_TOPIC_WORKRECORD_CONTENTSECURITY; |
|
|
|
tag = RocketMqConstant.MQ_TAG_WORKRECORD_MONTH_ORGANIZATION; |
|
|
|
}else if(ModuleName.WORK_MONTH_CASE.getCode().equals(record.getModule())){ |
|
|
|
topic = RocketMqConstant.MQ_TOPIC_WORKRECORD_CONTENTSECURITY; |
|
|
|
tag = RocketMqConstant.MQ_TAG_WORKRECORD_MONTH_CASE_ORGANIZATION; |
|
|
|
}else if(ModuleName.WORK_MONTH_GRID.getCode().equals(record.getModule())){ |
|
|
|
topic = RocketMqConstant.MQ_TOPIC_WORKRECORD_CONTENTSECURITY; |
|
|
|
tag = RocketMqConstant.MQ_TAG_WORKRECORD_MONTH_GRID_ORGANIZATION; |
|
|
|
}else if(ModuleName.WORK_MONTH_PERSON.getCode().equals(record.getModule())){ |
|
|
|
topic = RocketMqConstant.MQ_TOPIC_WORKRECORD_CONTENTSECURITY; |
|
|
|
tag = RocketMqConstant.MQ_TAG_WORKRECORD_MONTH_PERSON_ORGANIZATION; |
|
|
|
}//书记在线
|
|
|
|
else if(ModuleName.SECRETARY_NOTICE.getCode().equals(record.getModule())){ |
|
|
|
topic = RocketMqConstant.MQ_TOPIC_SECRETARY_CONTENTSECURITY; |
|
|
|
|