红榜任务埋点

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

@@ -74,4 +74,26 @@ public class MainLineConsr {
 		});
 	}
 
+	/**
+	 * 周任务埋点
+	 *
+	 * @param bookId
+	 *            图书标识
+	 * @param adviserId
+	 *            编辑标识
+	 */
+	public void sendAddBookGroupTask(Long bookId, Long adviserId) {
+		EXECUTOR_SERVICE.execute(new Runnable() {
+			public void run() {
+				// 一本书刊
+				WeektaskMessageDto weektaskMessageDto = new WeektaskMessageDto();
+				weektaskMessageDto.setWeektaskCode(WeektaskCode.W6_CREATE_BOOK_GROUP);
+				weektaskMessageDto.setTargetId(bookId);
+				weektaskMessageDto.setAdviserId(adviserId);
+				weektaskMessageDto.setWeektaskBehaviorCode(WeektaskBehaviorCode.STEP_ONE);
+				weektaskQueueBiz.sendMessageQueue(weektaskMessageDto);
+			}
+		});
+	}
+
 }

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

@@ -9,6 +9,7 @@ import com.pcloud.book.book.dto.BookDto;
 import com.pcloud.book.book.set.BookSet;
 import com.pcloud.book.consumer.app.AppConsr;
 import com.pcloud.book.consumer.channel.QrcodeSceneConsr;
+import com.pcloud.book.consumer.raystask.MainLineConsr;
 import com.pcloud.book.consumer.resource.ProductConsr;
 import com.pcloud.book.consumer.settlement.SettlementConsr;
 import com.pcloud.book.consumer.trade.TradeConsr;
@@ -122,6 +123,8 @@ public class BookGroupBizImpl implements BookGroupBiz {
     @Autowired
     private ProductConsr productConsr;
     @Autowired
+    private MainLineConsr mainLineConsr;
+    @Autowired
     private MessageBiz messageBiz;
 
 
@@ -160,6 +163,9 @@ public class BookGroupBizImpl implements BookGroupBiz {
             bookGroupDao.update(group);
             bookGroup.setGroupQrcodeUrl(groupQrcodeUrl);
         }
+        if (null != bookId && !bookId.equals(0L)) {
+            mainLineConsr.sendAddBookGroupTask(bookId, adviserId);
+        }
         return bookGroup;
     }