mq 修改

pcloud-service-book/src/main/java/com/pcloud/book/book/set/BookSet.java

@@ -6,6 +6,7 @@ package com.pcloud.book.book.set;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Lists;
 import com.pcloud.analysisengine.browse.dto.BrowseCacheRecordDto;
+import com.pcloud.analysisengine.browse.dto.SBookAnalyzeDto;
 import com.pcloud.appcenter.app.dto.AppDto;
 import com.pcloud.appcenter.assist.dto.AssistTempletDTO;
 import com.pcloud.book.appeal.dto.AppealAdviserDto;
@@ -20,6 +21,7 @@ import com.pcloud.book.book.dao.BookFreezeDao;
 import com.pcloud.book.book.dao.BookTypeDao;
 import com.pcloud.book.book.dto.AdviserManageDto;
 import com.pcloud.book.book.dto.BookAdviserDto;
+import com.pcloud.book.book.dto.BookAnlysicsDto;
 import com.pcloud.book.book.dto.BookAppDto;
 import com.pcloud.book.book.dto.BookDeleteDto;
 import com.pcloud.book.book.dto.BookDto;
@@ -39,12 +41,12 @@ import com.pcloud.book.consumer.content.ResourceConsr;
 import com.pcloud.book.consumer.message.MessageConsr;
 import com.pcloud.book.consumer.resource.ProductConsr;
 import com.pcloud.book.consumer.settlement.BookConsr;
+import com.pcloud.book.consumer.trade.OrderFormConsr;
 import com.pcloud.book.consumer.user.AdviserConsr;
 import com.pcloud.book.consumer.user.BookcaseConsr;
 import com.pcloud.book.consumer.user.ChannelConsr;
 import com.pcloud.book.consumer.user.PartyConsr;
 import com.pcloud.book.consumer.voicemessage.MerchantVideoConsr;
-import com.pcloud.book.mq.config.MqConfig;
 import com.pcloud.channelcenter.base.constants.MessageFromTypeEnum;
 import com.pcloud.channelcenter.qrcode.dto.QrcodeLocationDto;
 import com.pcloud.channelcenter.qrcode.vo.BookAssocLastQrAskVO;
@@ -52,6 +54,7 @@ import com.pcloud.channelcenter.qrcode.vo.BookAssocLastQrVO;
 import com.pcloud.channelcenter.qrcode.vo.BookAssocQRcountRequestVO;
 import com.pcloud.comment.base.enums.SysCodeEnum;
 import com.pcloud.common.core.aspect.ParamLog;
+import com.pcloud.common.core.constant.MQTopicProducer;
 import com.pcloud.common.core.constant.SystemCode;
 import com.pcloud.common.exceptions.BizException;
 import com.pcloud.common.utils.BookUtils;
@@ -75,6 +78,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.math.NumberUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.AmqpTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -138,8 +142,9 @@ public class BookSet {
 	@Autowired
 	private BookFreezeDao bookFreezeDao;
 	@Autowired
+	private AmqpTemplate amqpTemplate;
+	@Autowired
 	private OrderFormConsr orderFormConsr;
-
 	/**
 	 * 检验书号是否合法，包括ISSN,ISBN,CSSN
 	 * 
@@ -409,7 +414,7 @@ public class BookSet {
 		bookIds.add(bookId);
 		bookDeleteDto.setBookIds(bookIds);
 		try {
-			MqConfig.sendBookDeleteTopic(bookDeleteDto);
+			amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.BOOK_DELETE, bookDeleteDto);
 		} catch (Exception e) {
 			LOGGER.error("【书籍基础】发送书籍删除topic,<ERROR>", e);
 		}
@@ -426,7 +431,7 @@ public class BookSet {
 		BookDeleteDto bookDeleteDto = new BookDeleteDto();
 		bookDeleteDto.setBookIds(bookIds);
 		try {
-			MqConfig.sendBookDeleteTopic(bookDeleteDto);
+			amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.BOOK_DELETE, bookDeleteDto);
 		} catch (Exception e) {
 			LOGGER.error("【书籍基础】发送批量删除书籍topic,<ERROR>", e);
 		}
@@ -1553,6 +1558,7 @@ public class BookSet {
 		}
 		LOGGER.info("设置父模板标识.setTempletName.<END>.[bookDto]:"+bookDto);
 	}
+
 	/**
 	 * 书刊分析-设置出版信息
 	 * @param objects