合并代码

pcloud-facade-book/src/main/java/com/pcloud/book/book/dto/BookNameUpdateDTO.java

+package com.pcloud.book.book.dto;
+
+import java.io.Serializable;
+
+/**
+ * @author 戴兴
+ * @description TODO
+ * @date 2019/3/14 14:49
+ */
+public class BookNameUpdateDTO implements Serializable {
+
+    private String bookName;
+
+    private Long bookId;
+
+    public String getBookName() {
+        return bookName;
+    }
+
+    public void setBookName(String bookName) {
+        this.bookName = bookName;
+    }
+
+    public Long getBookId() {
+        return bookId;
+    }
+
+    public void setBookId(Long bookId) {
+        this.bookId = bookId;
+    }
+
+    @Override
+    public String toString() {
+        return "BookNameUpdateDTO{" +
+                "bookName='" + bookName + '\'' +
+                ", bookId=" + bookId +
+                '}';
+    }
+}
\ No newline at end of file

pcloud-service-book/src/main/java/com/pcloud/book/book/biz/impl/BookBizImpl.java

@@ -21,17 +21,7 @@ import com.pcloud.book.book.biz.BookResourceBiz;
 import com.pcloud.book.book.cache.BookCache;
 import com.pcloud.book.book.constant.BookConstant;
 import com.pcloud.book.book.dao.BookDao;
-import com.pcloud.book.book.dto.BookAdviserDto;
-import com.pcloud.book.book.dto.BookAdviserUpdateTimeDTO;
-import com.pcloud.book.book.dto.BookAssocCount;
-import com.pcloud.book.book.dto.BookCoverImgUpdateDTO;
-import com.pcloud.book.book.dto.BookDetialDTO;
-import com.pcloud.book.book.dto.BookDto;
-import com.pcloud.book.book.dto.BookFreezeDto;
-import com.pcloud.book.book.dto.BookFundDto;
-import com.pcloud.book.book.dto.BookInfo4AnlysicsDTO;
-import com.pcloud.book.book.dto.BookInfoAnalysicsDTO;
-import com.pcloud.book.book.dto.BookInfoAndAuthStatusDTO;
+import com.pcloud.book.book.dto.*;
 import com.pcloud.book.book.entity.Book;
 import com.pcloud.book.book.entity.BookAdviser;
 import com.pcloud.book.book.set.BookSet;
@@ -192,12 +182,24 @@ public class BookBizImpl implements BookBiz {
 		//获取图书基本信息
 		BookDto bookDto = this.getBaseById(book.getBookId());
 		checkIsUpdateCoverImgAndSendTopic(bookDto, book.getCoverImg());
+		checkIsUpdateBookNameAndSendTopic(bookDto, book.getBookName());
 		bookDao.update(book);
 		// 清除redis中数据
 		bookCache.clearRedisByBook(book.getBookId(), book.getIsbn(), book.getSerialNumber());
 		LOGGER.info("【书籍基础】修改书籍基础信息,<END>");
 	}
 
+	@ParamLog("校验是否修改图书名称并发送修改名称topic")
+	private void checkIsUpdateBookNameAndSendTopic(BookDto oldBook, String newBookName) {
+		if (newBookName != null && !newBookName.equalsIgnoreCase(oldBook.getBookName())){
+			BookNameUpdateDTO bookNameUpdateDTO = new BookNameUpdateDTO();
+			bookNameUpdateDTO.setBookId(oldBook.getBookId());
+			bookNameUpdateDTO.setBookName(newBookName);
+			bookMQProducer.sendUpdateBookNameTopic(bookNameUpdateDTO);
+		}
+	}
+
+	@ParamLog("校验是否修改图书封面图并发送修改封面图topic")
 	void checkIsUpdateCoverImgAndSendTopic(BookDto oldBook, String newCoverImg){
 		if(newCoverImg != null && !newCoverImg.equalsIgnoreCase(oldBook.getCoverImg())){
 			BookCoverImgUpdateDTO bookCoverImgUpdateDTO = new BookCoverImgUpdateDTO();
@@ -248,6 +250,7 @@ public class BookBizImpl implements BookBiz {
 		// 清除redis中数据
 		bookCache.clearRedisByBook(book.getBookId(), book.getIsbn(), book.getSerialNumber());
 		checkIsUpdateCoverImgAndSendTopic(bookDto, book.getCoverImg());
+		checkIsUpdateBookNameAndSendTopic(bookDto, book.getBookName());
 		LOGGER.info("【书籍基础】修改书籍基础信息,<END>");
 		return bookDto;
 	}
@@ -1381,6 +1384,7 @@ public class BookBizImpl implements BookBiz {
 			bookCache.incrObject(BookConstant.BOOK_CACHE + "PLATFORM_BOOK_COUNT");
 		} else {
 			checkIsUpdateCoverImgAndSendTopic(bookDto, book.getCoverImg());
+			checkIsUpdateBookNameAndSendTopic(bookDto, book.getBookName());
 			// 修改图书基本信息
 			bookDao.updateByAdviser(book);
 			// 周任务书刊埋点
@@ -1407,6 +1411,7 @@ public class BookBizImpl implements BookBiz {
 		//获取图书基本信息
 		BookDto bookDto = this.getBaseById(book.getBookId());
 		checkIsUpdateCoverImgAndSendTopic(bookDto, book.getCoverImg());
+		checkIsUpdateBookNameAndSendTopic(bookDto, book.getBookName());
 		// 修改图书基本信息
 		bookDao.updateByAdviser(book);
         // 清除redis中数据

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

@@ -1487,12 +1487,8 @@ public class BookSet {
         }
     }
 
-    /**
-     * 设置父模板标识
-     * @param bookDto
-     */
+    @ParamLog(value = "设置父模板标识", isBefore = false)
     public void setTempleParentId(BookDto bookDto) {
-        LOGGER.info("设置父模板标识.setTempleParentId.<START>.[bookDto]:" + bookDto);
         if (null != bookDto && null != bookDto.getTempletId()) {
             List<Long> assistTempletIds = Lists.newArrayList();
             assistTempletIds.add(bookDto.getTempletId());
@@ -1504,7 +1500,6 @@ public class BookSet {
                 }
             }
         }
-        LOGGER.info("设置父模板标识.setTempleParentId.<END>.[bookDto]:" + bookDto);
     }
 
 

pcloud-service-book/src/main/java/com/pcloud/book/mq/producer/BookMQProducer.java

 package com.pcloud.book.mq.producer;
 
 import com.pcloud.book.book.dto.BookCoverImgUpdateDTO;
+import com.pcloud.book.book.dto.BookNameUpdateDTO;
 
 public interface BookMQProducer {
 
   void sendUpdateBookCoverImgTopic(BookCoverImgUpdateDTO bookCoverImgUpdateDTO);
+
+  void sendUpdateBookNameTopic(BookNameUpdateDTO bookNameUpdateDTO);
 }

pcloud-service-book/src/main/java/com/pcloud/book/mq/producer/impl/BookProducerImpl.java

 package com.pcloud.book.mq.producer.impl;
 
 import com.pcloud.book.book.dto.BookCoverImgUpdateDTO;
+import com.pcloud.book.book.dto.BookNameUpdateDTO;
 import com.pcloud.book.mq.producer.BookMQProducer;
 import com.pcloud.common.core.constant.MQTopicProducer;
 import org.springframework.amqp.core.AmqpTemplate;
@@ -18,4 +19,8 @@ public class BookProducerImpl implements BookMQProducer {
     public void sendUpdateBookCoverImgTopic(BookCoverImgUpdateDTO bookCoverImgUpdateDTO) {
         amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.UPDATE_BOOK_COVERIMG, bookCoverImgUpdateDTO);
     }
+    @Override
+    public void sendUpdateBookNameTopic(BookNameUpdateDTO bookNameUpdateDTO) {
+        amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.UPDATE_BOOK_NAME, bookNameUpdateDTO);
+    }
 }