好像把日志输出的改了一点点

pcloud-common-core/src/main/java/com/pcloud/common/core/aspect/ParamLogAspect.java

@@ -31,7 +31,7 @@ public class ParamLogAspect {
 	/**
 	 * 
 	 */
-	private final static Logger LOGGER = LoggerFactory.getLogger(ParamLogAspect.class);
+	private final static Logger LOGGER = LoggerFactory.getLogger("");
 
 	@Pointcut("execution(* com.pcloud..*(..))")
 	public void bizPoint() {
@@ -52,10 +52,8 @@ public class ParamLogAspect {
 		String methodName = signature.getName();
 		String description = paramLog.description();
 		description = StringUtil.isEmpty(description) ? paramLog.value() : description;
-		StringBuffer msg = new StringBuffer("【" + methodName + " before】");
-		if (StringUtil.isEmpty(description)) {
-			msg.append(joinPoint.getSignature().toString());
-		} else {
+		StringBuffer msg = new StringBuffer(signature.getDeclaringTypeName()).append(" 【" + methodName + " before】");
+		if (!StringUtil.isEmpty(description)) {
 			msg.append(description);
 		}
 		if (!paramLog.isBefore()) {
@@ -81,10 +79,9 @@ public class ParamLogAspect {
 		String methodName = signature.getName();
 		String description = paramLog.description();
 		description = StringUtil.isEmpty(description) ? paramLog.value() : description;
-		StringBuffer msg = new StringBuffer("【" + methodName + " afterReturn】");
-		if (StringUtil.isEmpty(description)) {
-			msg.append(joinPoint.getSignature().toString());
-		} else {
+		StringBuffer msg = new StringBuffer(signature.getDeclaringTypeName())
+				.append(" 【" + methodName + " afterReturn】");
+		if (!StringUtil.isEmpty(description)) {
 			msg.append(description);
 		}
 		if (!paramLog.isAfterReturn()) {

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/impl/TranscodeQueueBizImpl.java

@@ -31,6 +31,9 @@ public class TranscodeQueueBizImpl implements TranscodeQueueBiz {
 	@Override
 	@ParamLog(description = "文件转码QUEUE")
 	public void sendTranscodeQueue(TranscodeMQDTO transcodeMQDTO) throws BizException {
+		if (transcodeMQDTO == null) {
+			throw BizException.PARAM_IS_NULL;
+		}
 		amqpTemplate.convertAndSend(MQQueueConstant.TRANSCODE, transcodeMQDTO);
 	}
 

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/MQQueueConstant.java

@@ -26,14 +26,59 @@ public class MQQueueConstant {
 	public static final String CONVERT = "convertQueue";
 
 	/**
-	 * 文件转码结束(音视频)->应用中心
+	 * 文件转码结束(音视频)->内容中心
 	 */
-	public static final String CONVERT_TO_APP = "convert2AppQueue";
+	public static final String CONVERT_TO_CONTENT = "convert2ContentQueue";
 
 	/**
-	 * 文件转码结束(音视频)->内容中心
+	 * 文件转码结束(音视频)->教育表格
 	 */
-	public static final String CONVERT_TO_CONTENT = "convert2ContentQueue";
+	public static final String CONVERT_TO_EFAPP = "convert2EfAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->圈子应用
+	 */
+	public static final String CONVERT_TO_GROUPAPP = "convert2GroupAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->直播应用
+	 */
+	public static final String CONVERT_TO_LIVEAPP = "convert2LiveAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->报名应用
+	 */
+	public static final String CONVERT_TO_MATCHAPP = "convert2MatchAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->题库文件溢出
+	 */
+	public static final String CONVERT_TO_PRETEST_FILEMEMORY = "convert2PretestFilememoryQueue";
+
+	/**
+	 * 文件转码结束(音视频)->小游戏
+	 */
+	public static final String CONVERT_TO_RAYSTASK = "convert2RaystaskQueue";
+
+	/**
+	 * 文件转码结束(音视频)->资源中心
+	 */
+	public static final String CONVERT_TO_RESOURCE = "convert2ResourceQueue";
+
+	/**
+	 * 文件转码结束(音视频)->测试应用
+	 */
+	public static final String CONVERT_TO_TESTAPP = "convert2TestAppQueue";
+
+	/**
+	 * 文件转码结束(音视频)->视频课
+	 */
+	public static final String CONVERT_TO_VIDEOLESSON = "convert2VideoLessonQueue";
+
+	/**
+	 * 文件转码结束(音视频)->投票应用
+	 */
+	public static final String CONVERT_TO_VOTEAPP = "convert2VoteAppQueue";
 
 	/**
 	 * 数据埋点
@@ -41,6 +86,61 @@ public class MQQueueConstant {
 	public static final String FRONT_EVENT = "frontEventQueue";
 
 	/**
+	 * 对外API
+	 */
+	public static final String EXAPI = "exapiQueue";
+
+	/**
+	 * 基金监控
+	 */
+	public static final String FUND = "fundQueue";
+
+	/**
+	 * 用户漏斗
+	 */
+	public static final String FUNNEL_FLOW = "funnelFlowQueue";
+
+	/**
+	 * 标签使用量
+	 */
+	public static final String LABEL_USED = "labelUsedQueue";
+
+	/**
+	 * 日志
+	 */
+	public static final String LOG = "logQueue";
+
+	/**
+	 * 动态监控
+	 */
+	public static final String MERCHANT_DYNAMIC = "merchantDynamicQueue";
+
+	/**
+	 * 系统消息
+	 */
+	public static final String MESSAGE = "messageQueue";
+
+	/**
+	 * 促销任务
+	 */
+	public static final String PROMOTION_TASK = "promotionTaskQueue";
+
+	/**
+	 * 促销终止
+	 */
+	public static final String PROMOTION_TERMINATE = "promotionTerminateQueue";
+
+	/**
+	 * 用户行为
+	 */
+	public static final String USER_ACTION = "userActionQueue";
+
+	/**
+	 * 周任务
+	 */
+	public static final String WEEK_TASK = "weekTaskQueue";
+
+	/**
 	 * 死信队列名称(勿改)
 	 */
 	public static final String DEAD = "rays.dlq";

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/MQTopicProducer.java

@@ -4,7 +4,7 @@
 package com.pcloud.common.core.constant;
 
 /**
- * RabbitMQ 交换机名称常量类
+ * RabbitMQ Topic路由名称常量类
  * 
  * @author：songx
  * @date：2018年8月17日,上午10:48:18
@@ -12,14 +12,239 @@ package com.pcloud.common.core.constant;
 public class MQTopicProducer {
 
 	/**
+	 * 文件转码结束(PDF、EXCEL)
+	 */
+	public static final String FILE_TRANSCODE = "topic.fileTranscode";
+
+	/**
+	 * 报名新增用户
+	 */
+	public static final String BM_ADD_USER = "topic.bmAddUser";
+
+	/**
 	 * 应用新增
 	 */
 	public static final String APP_ADD = "topic.appAdd";
 
 	/**
-	 * 文件转码结束(PDF、EXCEL)
+	 * 应用修改
 	 */
-	public static final String FILE_TRANSCODE = "topic.fileTranscode";
+	public static final String APP_UPDATE = "topic.appUpdate";
+
+	/**
+	 * 应用删除
+	 */
+	public static final String APP_DELETE = "topic.appDelete";
+
+	/**
+	 * 应用删除(新)
+	 */
+	public static final String APP_DELETE_NEW = "topic.appDeleteNew";
+
+	/**
+	 * 应用审核
+	 */
+	public static final String APP_AUDIT = "topic.appAudit";
+
+	/**
+	 * 选择默认渠道
+	 */
+	public static final String CHOOSE_DEFAULT_CHANNEL = "topic.chooseDefaultChannel";
+
+	/**
+	 * 删除视频
+	 */
+	public static final String DELETE_VIDEO = "topic.deleteVideo";
+
+	/**
+	 * 标签修改
+	 */
+	public static final String LABEL_UPDATE = "topic.labelUpdate";
+
+	/**
+	 * 支付
+	 */
+	public static final String PAYMENT = "topic.payment";
+
+	/**
+	 * TIP
+	 */
+	public static final String TIP = "topic.tip";
+
+	/**
+	 * 订单完成
+	 */
+	public static final String FINISH_ORDER = "topic.finishOrder";
+
+	/**
+	 * 资源修改
+	 */
+	public static final String RESOURCE_UPDATE = "topic.resourceUpdate";
+
+	/**
+	 * 资源删除
+	 */
+	public static final String RESOURCE_DELETE = "topic.resourceDelete";
+
+	/**
+	 * 扫码记录
+	 */
+	public static final String SCAN_RECORD = "topic.scanRecord";
+
+	/**
+	 * 图书删除
+	 */
+	public static final String BOOK_DELETE = "topic.bookDelete";
+
+	/**
+	 * BOOKTHAW
+	 */
+	public static final String BOOK_THAW = "topic.bookThaw";
+
+	/**
+	 * TEMPLETAPPCREATE
+	 */
+	public static final String TEMPLET_APP_CREATE = "topic.templetAppCreate";
+
+	/**
+	 * PERMISSION
+	 */
+	public static final String PERMISSION = "topic.permission";
+
+	/**
+	 * PROMOTION_EXPIRE
+	 */
+	public static final String PROMOTION_EXPIRE = "topic.promotionExpire";
+
+	/**
+	 * 商品修改
+	 */
+	public static final String PRODUCT_UPDATE = "topic.productUpdate";
+
+	/**
+	 * 商品删除
+	 */
+	public static final String PRODUCT_DELETE = "topic.productDelete";
+
+	/**
+	 * 商品审核
+	 */
+	public static final String PRODUCT_AUDIT = "topic.productAudit";
+
+	/**
+	 * 商品图片1修改
+	 */
+	public static final String PRODUCT_PIC1_UPDATE = "topic.productPic1Update";
+
+	/**
+	 * 用户注册
+	 */
+	public static final String REGISTER_PARTY = "topic.registerParty";
+
+	/**
+	 * 用户修改
+	 */
+	public static final String UPDATE_PARTY = "topic.updateParty";
+
+	/**
+	 * 问答确认
+	 */
+	public static final String QA_ASK = "topic.qaAsk";
+
+	/**
+	 * 问答完成
+	 */
+	public static final String QA_FINISH = "topic.qaFinish";
+
+	/**
+	 * 问答答案
+	 */
+	public static final String QA_ANSWER = "topic.qaAnswer";
+
+	/**
+	 * 问答取消
+	 */
+	public static final String QA_REFUSE = "topic.qaRefuse";
+
+	/**
+	 * QR_MESSAGE_UPDATE
+	 */
+	public static final String QR_MESSAGE_UPDATE = "topic.qrMessageUpdate";
+
+	/**
+	 * GIVE_GIFT
+	 */
+	public static final String GIVE_GIFT = "topic.giveGift";
+
+	/**
+	 * 修改密码
+	 */
+	public static final String UPDATE_PWD = "topic.updatePwd";
+
+	/**
+	 * 管理消息
+	 */
+	public static final String MANAGE_MESSAGE = "topic.manageMessage";
+
+	/**
+	 * RETURN_4_ADVISER
+	 */
+	public static final String RETURN_4_ADVISER = "topic.return4adviser";
+
+	/**
+	 * REFUND
+	 */
+	public static final String REFUND = "topic.refund";
+
+	/**
+	 * REFUNDPRODUCT
+	 */
+	public static final String REFUND_PRODUCT = "topic.refundProduct";
+
+	/**
+	 * 模板二维码扫描
+	 */
+	public static final String TEMP_QRCODE_SCAN = "topic.tempQrcodeScan";
+
+	/**
+	 * 删除二维码
+	 */
+	public static final String DELETE_QRCODE = "topic.deleteQrcode";
+
+	/**
+	 * 二维码图书修改
+	 */
+	public static final String QRCODE_BOOK_UPDATE = "topic.qrcodeBookUpdate";
+
+	/**
+	 * 重置
+	 */
+	public static final String RECHARGE = "topic.recharge";
+
+	/**
+	 * 改变显示状态
+	 */
+	public static final String CHANGE_SHOW_STATE = "topic.changeShowState";
+
+	/**
+	 * 删除合作出版社
+	 */
+	public static final String DELETE_COOPERATIVE_AGENT = "topic.deleteCooperativeAgent";
+
+	/**
+	 * TASK_BONUS
+	 */
+	public static final String TASK_BONUS = "topic.taskBonus";
+
+	/**
+	 * 读者消息
+	 */
+	public static final String READER_MESSAGE = "topic.readerMessage";
+
+	/**
+	 * 记录用户习惯
+	 */
+	public static final String RECORD_USER_HABIT = "topic.recordUserHabit";
 
 	/**
 	 * topic交换机名称(勿改)