feat:[1005011]二维码关联书刊

pcloud-service-book/src/main/java/com/pcloud/book/BookApplication.java

@@ -325,4 +325,14 @@ public class BookApplication {
     public Binding erpCreateBookBind() {
         return RabbitMQFactory.bindingExchange(erpCreateBookQueue(), MQTopicProducer.ERP_AUTO_CREATE_BOOK);
     }
+
+    @Bean
+    public Queue qrcodeBookUpdateQueue() {
+        return RabbitMQFactory.queueBuilder(MQTopicConumer.QRCODE_BOOK_UPDATE);
+    }
+
+    @Bean
+    public Binding qrcodeBookUpdateBind() {
+        return RabbitMQFactory.bindingExchange(qrcodeBookUpdateQueue(), MQTopicProducer.QRCODE_BOOK_UPDATE);
+    }
 }

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

@@ -352,4 +352,12 @@ public interface ResourcePageBiz {
      *  * @param null
      */
     Map<String, Object> hasOfficialAccountsTool(Long resourcePageId);
+
+    /**
+     * 更新bookId
+     * @author：zhuyajie
+     * @date：2021/7/2 10:58
+     *  * @param null
+     */
+    void updateBookId(Long bookId, Long sceneId);
 }

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

@@ -1899,4 +1899,16 @@ public class ResourcePageBizImpl implements ResourcePageBiz {
         result.put("hasOfficialAccountsTool", hasOfficialAccountsTool);
         return result;
     }
+
+    @Override
+    public void updateBookId(Long bookId, Long sceneId) {
+        ResourcePage resourcePage = resourcePageDao.getBySceneId(sceneId);
+        if (null != resourcePage) {
+            resourcePageDao.updateBookIdBySceneId(bookId, sceneId);
+        }
+        Long bookGroupId = this.getBookGroupIdBySceneId(sceneId);
+        if (null != bookGroupId) {
+            bookGroupDao.updateBookIdById(bookGroupId, bookId);
+        }
+    }
 }

pcloud-service-book/src/main/java/com/pcloud/book/group/dao/BookGroupDao.java

@@ -404,4 +404,6 @@ public interface BookGroupDao extends BaseDao<BookGroup> {
     List<RaysSceneCatalogDto> listRaysSceneCatalogDto(List<Long> sceneIds);
 
     List<BookGroupDTO> getNotXiaoRui(List<Long> bookIds, List<Long> adviserIds, List<Long> channelIds);
+
+    void updateBookIdById(Long bookGroupId, Long bookId);
 }

pcloud-service-book/src/main/java/com/pcloud/book/group/dao/ResourcePageDao.java

@@ -111,4 +111,6 @@ public interface ResourcePageDao extends BaseDao<ResourcePage>{
     Map<String, BookGroupServeCountDTO> mapRaysCodeServeCount(List<Long> adviserIds, List<Long> bookIds, List<Long> channelIds);
 
     List<ResourcePageVO> getAllBook4OpenFood();
+
+    void updateBookIdBySceneId(Long bookId, Long sceneId);
 }

pcloud-service-book/src/main/java/com/pcloud/book/group/dao/impl/BookGroupDaoImpl.java

@@ -579,4 +579,12 @@ public class BookGroupDaoImpl extends BaseDaoImpl<BookGroup> implements BookGrou
         paramMap.put("channelIds",channelIds);
         return super.getSqlSession().selectList(getStatement("getNotXiaoRui"),paramMap);
     }
+
+    @Override
+    public void updateBookIdById(Long bookGroupId, Long bookId) {
+        Map<String, Object> paramMap = new HashMap<>();
+        paramMap.put("bookId", bookId);
+        paramMap.put("id", bookGroupId);
+        getSessionTemplate().update(getStatement("updateBookIdById"), paramMap);
+    }
 }

pcloud-service-book/src/main/java/com/pcloud/book/group/dao/impl/ResourcePageDaoImpl.java

@@ -130,4 +130,12 @@ public class ResourcePageDaoImpl extends BaseDaoImpl<ResourcePage> implements Re
     public List<ResourcePageVO> getAllBook4OpenFood() {
         return getSessionTemplate().selectList(getStatement("getAllBook4OpenFood"));
     }
+
+    @Override
+    public void updateBookIdBySceneId(Long bookId, Long sceneId) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("bookId", bookId);
+        map.put("sceneId", sceneId);
+        getSessionTemplate().update(getStatement("updateBookIdBySceneId"), map);
+    }
 }

pcloud-service-book/src/main/java/com/pcloud/book/mq/config/MQTopicConumer.java

@@ -109,4 +109,8 @@ public class MQTopicConumer {
      * erp端创建书刊
      */
     public static final String ERP_AUTO_CREATE_BOOK = PREFIX + MQTopicProducer.ERP_AUTO_CREATE_BOOK;
+    /**
+     * 二维码图书变更
+     */
+    public static final String QRCODE_BOOK_UPDATE = PREFIX + MQTopicProducer.QRCODE_BOOK_UPDATE;
 }

pcloud-service-book/src/main/java/com/pcloud/book/mq/topic/QrcodeBookUpdateListener.java

+/**
+ * 
+ */
+package com.pcloud.book.mq.topic;
+
+import com.pcloud.book.group.biz.ResourcePageBiz;
+import com.pcloud.book.mq.config.MQTopicConumer;
+import com.pcloud.channelcenter.qrcode.dto.BookQrcodeUpdateDto;
+import com.pcloud.common.exceptions.BizException;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 二维码变更书刊
+ * @author：zhuyajie
+ * @date：2021/7/2 10:51
+ *  * @param null
+ */
+@Component
+@RabbitListener(queues = MQTopicConumer.QRCODE_BOOK_UPDATE)
+public class QrcodeBookUpdateListener {
+
+	/**
+	 * 
+	 */
+	private static final Logger LOGGER = LoggerFactory.getLogger(QrcodeBookUpdateListener.class);
+
+	@Autowired
+	private ResourcePageBiz resourcePageBiz;
+
+	/**
+	 * 二维码变更书刊消息
+	 */
+	@RabbitHandler
+	public void process(BookQrcodeUpdateDto bookQrcodeUpdateDto) throws BizException {
+		if (null == bookQrcodeUpdateDto || null == bookQrcodeUpdateDto.getBookId()
+				|| null == bookQrcodeUpdateDto.getSceneId()) {
+			return;
+		}
+		try {
+			Long bookId = bookQrcodeUpdateDto.getBookId();
+			Long sceneId = bookQrcodeUpdateDto.getSceneId();
+			//book_group表/resource_page更新bookid
+			resourcePageBiz.updateBookId(bookId, sceneId);
+		} catch (Exception e) {
+			LOGGER.error("【二维码变更书刊】消费topic,JMS异常,<ERROR>:" + e.getMessage(), e);
+		}
+	}
+}

pcloud-service-book/src/main/resources/mapper/group/BookGroupMapper.xml

@@ -1436,4 +1436,12 @@
         </foreach>
         and join_group_type!=4
     </select>
+
+    <update id="updateBookIdById" parameterType="map">
+        UPDATE book_group
+        SET book_id=#{bookId},
+        update_time=NOW()
+        WHERE id=#{id}
+    </update>
+
 </mapper>

pcloud-service-book/src/main/resources/mapper/group/ResourcePageDao.xml

@@ -272,4 +272,13 @@
 		GROUP BY book_id
 		ORDER BY id
 	</select>
+
+    <update id="updateBookIdBySceneId" parameterType="map">
+        UPDATE resource_page
+        SET book_id = #{bookId},
+         update_time = NOW()
+        WHERE
+        scene_id = #{sceneId}
+    </update>
+
 </mapper>