红榜作书埋点修改

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

 package com.pcloud.book.book.biz.impl;
 
-import java.math.BigDecimal;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-import org.apache.commons.lang3.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.dao.DataIntegrityViolationException;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
 import com.google.common.collect.Maps;
 import com.pcloud.book.base.dto.CountDto;
 import com.pcloud.book.base.exception.BookBizException;
@@ -36,18 +20,29 @@ import com.pcloud.book.consumer.settlement.BookConsr;
 import com.pcloud.book.consumer.user.AdviserConsr;
 import com.pcloud.book.consumer.user.BookcaseConsr;
 import com.pcloud.book.consumer.user.ChannelConsr;
-import com.pcloud.common.core.biz.WeektaskQueueBiz;
 import com.pcloud.common.core.constant.SceneCode;
 import com.pcloud.common.core.constant.SendType;
 import com.pcloud.common.core.constant.SystemCode;
-import com.pcloud.common.core.constant.WeektaskBehaviorCode;
-import com.pcloud.common.core.constant.WeektaskCode;
-import com.pcloud.common.core.dto.WeektaskMessageDto;
 import com.pcloud.common.exceptions.BizException;
 import com.pcloud.common.utils.DateUtils;
 import com.pcloud.common.utils.ListUtils;
 import com.pcloud.common.utils.string.StringUtil;
 import com.pcloud.raystask.entity.AdviserDefault;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 /**
  * @描述：编辑管理书籍逻辑层接口实现类
@@ -81,9 +76,6 @@ public class BookAdviserBizImpl implements BookAdviserBiz {
 	private AdviserConsr adviserConsr;
 
 	@Autowired
-	private WeektaskQueueBiz weektaskQueueBiz;
-
-	@Autowired
 	private MainLineConsr mainLineConsr;
 
 	@Autowired
@@ -134,7 +126,7 @@ public class BookAdviserBizImpl implements BookAdviserBiz {
 			}
 
 			// 周任务书刊埋点
-			sendWeekTask(bookAdviser.getBookId(), bookAdviser.getAdviserId());
+			mainLineConsr.sendAddBookTask(bookAdviser.getBookId(), bookAdviser.getAdviserId());
 		}
 		LOGGER.info("创建编辑与书籍关联关系【END】");
 	}
@@ -167,28 +159,6 @@ public class BookAdviserBizImpl implements BookAdviserBiz {
 	}
 
 	/**
-	 * 周任务埋点
-	 * 
-	 * @param bookId
-	 *            图书标识
-	 * @param adviserId
-	 *            编辑标识
-	 */
-	private void sendWeekTask(Long bookId, Long adviserId) {
-		EXECUTOR_SERVICE.execute(new Runnable() {
-			public void run() {
-				// 一本书刊
-				WeektaskMessageDto weektaskMessageDto = new WeektaskMessageDto();
-				weektaskMessageDto.setWeektaskCode(WeektaskCode.W_ADD_ONE_BOOK);
-				weektaskMessageDto.setTargetId(bookId);
-				weektaskMessageDto.setAdviserId(adviserId);
-				weektaskMessageDto.setWeektaskBehaviorCode(WeektaskBehaviorCode.STEP_ONE);
-				weektaskQueueBiz.sendMessageQueue(weektaskMessageDto);
-			}
-		});
-	}
-
-	/**
 	 * 校验是否同一出版社
 	 * 
 	 * @param channelId

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

@@ -36,6 +36,7 @@ import com.pcloud.book.consumer.analysisengine.SceneRecordConsr;
 import com.pcloud.book.consumer.app.AssistTempletConsr;
 import com.pcloud.book.consumer.channel.QrcodeSceneConsr;
 import com.pcloud.book.consumer.isbn.IsbnConsr;
+import com.pcloud.book.consumer.raystask.MainLineConsr;
 import com.pcloud.book.consumer.user.AdviserConsr;
 import com.pcloud.book.consumer.user.AgentConsr;
 import com.pcloud.book.consumer.user.ChannelConsr;
@@ -118,6 +119,8 @@ public class BookBizImpl implements BookBiz {
 	private AssistTempletConsr assistTempletConsr;
 	@Autowired
 	private BookMQProducer bookMQProducer;
+	@Autowired
+	private MainLineConsr mainLineConsr;
 
 	/**
 	 * 创建书籍,同时建立与编辑的推广关系
@@ -1357,7 +1360,7 @@ public class BookBizImpl implements BookBiz {
 			bookDao.insert(book);
 		} else {
 			// 图书已存在
-			book.setLastModifiedUser(bookDto.getAdviserId());
+			book.setLastModifiedUser(book.getCreatedUser());
 			book.setBookId(bookDto.getBookId());
 		}
 		// 新增图书与编辑关联关系
@@ -1370,6 +1373,8 @@ public class BookBizImpl implements BookBiz {
 			checkIsUpdateCoverImgAndSendTopic(bookDto, book.getCoverImg());
 			// 修改图书基本信息
 			bookDao.updateByAdviser(book);
+			// 周任务书刊埋点
+			mainLineConsr.sendAddBookTask(bookDto.getBookId(), book.getCreatedUser());
 			// 清除redis中数据
 			bookCache.clearRedisByBook(book.getBookId(), book.getIsbn(), book.getSerialNumber());
 		}

pcloud-service-book/src/main/java/com/pcloud/book/consumer/raystask/MainLineConsr.java

@@ -3,6 +3,10 @@
  */
 package com.pcloud.book.consumer.raystask;
 
+import com.pcloud.common.core.biz.WeektaskQueueBiz;
+import com.pcloud.common.core.constant.WeektaskBehaviorCode;
+import com.pcloud.common.core.constant.WeektaskCode;
+import com.pcloud.common.core.dto.WeektaskMessageDto;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -12,6 +16,9 @@ import com.pcloud.common.exceptions.BizException;
 import com.pcloud.raystask.entity.AdviserDefault;
 import com.pcloud.raystask.task.service.MainLineService;
 
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
 /**
  * @描述：
  * @作者：songx
@@ -25,9 +32,13 @@ public class MainLineConsr {
 	 * logger
 	 */
 	private static final Logger LOGGER = LoggerFactory.getLogger(MainLineConsr.class);
+
+	private static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(5);
 	
 	@Autowired
 	private MainLineService mainLineService;
+	@Autowired
+	private WeektaskQueueBiz weektaskQueueBiz;
 
 	/**
 	 * 设置默认应用标识
@@ -41,4 +52,26 @@ public class MainLineConsr {
 		}
 	}
 
+	/**
+	 * 周任务埋点
+	 *
+	 * @param bookId
+	 *            图书标识
+	 * @param adviserId
+	 *            编辑标识
+	 */
+	public void sendAddBookTask(Long bookId, Long adviserId) {
+		EXECUTOR_SERVICE.execute(new Runnable() {
+			public void run() {
+				// 一本书刊
+				WeektaskMessageDto weektaskMessageDto = new WeektaskMessageDto();
+				weektaskMessageDto.setWeektaskCode(WeektaskCode.W_ADD_ONE_BOOK);
+				weektaskMessageDto.setTargetId(bookId);
+				weektaskMessageDto.setAdviserId(adviserId);
+				weektaskMessageDto.setWeektaskBehaviorCode(WeektaskBehaviorCode.STEP_ONE);
+				weektaskQueueBiz.sendMessageQueue(weektaskMessageDto);
+			}
+		});
+	}
+
 }