Merge branch 'feature/exportAllBookAndServe' into 'master'

feat: [none] 导出所有书刊及资源

See merge request rays/pcloud-book!1220

pcloud-service-book/src/main/java/com/pcloud/book/book/biz/BookAdviserBiz.java

@@ -22,6 +22,8 @@ import com.pcloud.book.book.dto.QrcodeStatisticsDTO;
 import com.pcloud.book.book.entity.Book;
 import com.pcloud.book.book.entity.BookAdviser;
 import com.pcloud.book.book.vo.AgentBookStatsDetailVO;
+import com.pcloud.book.book.vo.BookServeInfo;
+import com.pcloud.book.book.vo.BookServesListDTO;
 import com.pcloud.book.book.vo.ErpAdviserBookVO;
 import com.pcloud.book.book.vo.PcloudAdviserBookVO;
 import com.pcloud.book.book.vo.QrCodeVO;
@@ -365,4 +367,6 @@ public interface BookAdviserBiz {
 	 *erp获取二维码下面配置了企业微信的二维码
 	 */
 	List<Long> getHasWxWorkCode(List<Long> sceneIds);
+
+	BookServeInfo listBookServes4Book(String cursor, Integer limit);
 }

pcloud-service-book/src/main/java/com/pcloud/book/book/dao/BookAdviserDao.java

@@ -16,6 +16,7 @@ import com.pcloud.book.book.dto.ErpBookInfoDTO;
 import com.pcloud.book.book.entity.BookAdviser;
 import com.pcloud.book.book.vo.AgentBookStatsDetailVO;
 import com.pcloud.book.book.vo.BookInfo4ScanCount;
+import com.pcloud.book.book.vo.BookServesListDTO;
 import com.pcloud.book.book.vo.ErpAdviserBookVO;
 import com.pcloud.book.es.entity.ESBookAndAdviser;
 import com.pcloud.common.core.dao.BaseDao;
@@ -317,4 +318,6 @@ public interface BookAdviserDao extends BaseDao<BookAdviser> {
 	BookDto getBookByBookIdAdviserIdChannelId(Long bookId, Long channelId, Long adviserId1);
 
 	BookDto getLatestAdviserBookByIsbn(String isbn);
+
+	List<BookServesListDTO> listBookServes4Book(Long cursor, Integer limit);
 }

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

@@ -21,6 +21,7 @@ import com.pcloud.book.book.dto.ErpBookInfoDTO;
 import com.pcloud.book.book.entity.BookAdviser;
 import com.pcloud.book.book.vo.AgentBookStatsDetailVO;
 import com.pcloud.book.book.vo.BookInfo4ScanCount;
+import com.pcloud.book.book.vo.BookServesListDTO;
 import com.pcloud.book.book.vo.ErpAdviserBookVO;
 import com.pcloud.book.es.entity.ESBookAndAdviser;
 import com.pcloud.common.core.dao.BaseDaoImpl;
@@ -402,4 +403,11 @@ public class BookAdviserDaoImpl extends BaseDaoImpl<BookAdviser> implements Book
 	public BookDto getLatestAdviserBookByIsbn(String isbn) {
 		return getSessionTemplate().selectOne(getStatement("getLatestAdviserBookByIsbn"), isbn);
 	}
+
+	@Override
+	public List<BookServesListDTO> listBookServes4Book(Long cursor, Integer limit) {
+		HashMap<String, Object> params = MapUtil.of("cursor", cursor);
+		params.put("limit", limit);
+		return getSessionTemplate().selectList(getStatement("listBookServes4Book"), params);
+	}
 }

pcloud-service-book/src/main/java/com/pcloud/book/book/facade/impl/BookAdviserFacadeImpl.java

@@ -19,6 +19,7 @@ import com.pcloud.book.book.dto.QrcodeStatisticsDTO;
 import com.pcloud.book.book.entity.BookAdviser;
 import com.pcloud.book.book.facade.BookAdviserFacade;
 import com.pcloud.book.book.vo.AgentBookStatsDetailVO;
+import com.pcloud.book.book.vo.BookServeInfo;
 import com.pcloud.book.book.vo.PcloudAdviserBookVO;
 import com.pcloud.book.book.vo.QrCodeVO;
 import com.pcloud.book.book.vo.request.UpdateBookRobotProcessDto;
@@ -379,4 +380,12 @@ public class BookAdviserFacadeImpl implements BookAdviserFacade {
 	public ResponseDto<?> getHasWxWorkCode4Erp(@RequestBody List<Long> sceneIds) {
 		return new ResponseDto<>(bookAdviserBiz.getHasWxWorkCode(sceneIds));
 	}
+
+	@ApiOperation("获取图书及其资源")
+	@GetMapping("listBookServes4Book")
+	public ResponseDto<BookServeInfo> listBookServes4Book(@RequestParam(value = "cursor",required = false) String cursor,
+														  @RequestParam(value = "limit",required = false) Integer limit){
+		return new ResponseDto<>(bookAdviserBiz.listBookServes4Book(cursor,limit));
+	}
+
 }

pcloud-service-book/src/main/java/com/pcloud/book/book/vo/BookServeInfo.java

+package com.pcloud.book.book.vo;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class BookServeInfo {
+
+    private List<BookServesListDTO> bookServesListDTOS;
+
+    private String cursor;
+
+}

pcloud-service-book/src/main/java/com/pcloud/book/book/vo/BookServesListDTO.java

+package com.pcloud.book.book.vo;
+
+import com.pcloud.book.group.dto.BookServeLabelDTO;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class BookServesListDTO {
+    private Long bookAdviserId;
+
+    private Long bookId;
+
+    private Long channelId;
+
+    private Long adviserId;
+
+    private Long templateId;
+
+    private Long graLabelId;
+
+    private String graLabelName;
+
+    private Long subLabelId;
+
+    private String subLabelName;
+
+    private Long verLabelId;
+
+    private String verLabelName;
+
+    private Long volLabelId;
+
+    private String volLabelName;
+
+    private Long depLabelId;
+
+    private String depLabelName;
+
+    private Long proLabelId;
+
+    private String proLabelName;
+
+    private Long purLabelId;
+
+    private String purLabelName;
+
+    private String bookName;
+
+    private List<BookServeLabelDTO> bookServeList;
+
+}

pcloud-service-book/src/main/java/com/pcloud/book/group/dto/BookServeLabelDTO.java

+package com.pcloud.book.group.dto;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class BookServeLabelDTO extends BookServeDTO{
+
+    private Long depLabelId;
+
+    private String depLabelName;
+
+    private Long proLabelId;
+
+    private String proLabelName;
+
+    private Long purLabelId;
+
+    private String purLabelName;
+
+}

pcloud-service-book/src/main/java/com/pcloud/book/util/common/ThreadPoolUtils.java

@@ -72,4 +72,8 @@ public class ThreadPoolUtils {
             new LinkedBlockingQueue<>(), new ThreadFactoryBuilder().setNameFormat("book_read_record-%d").build(), new ThreadPoolExecutor.CallerRunsPolicy());
 
 
+    public static final ExecutorService SMALL_THREAD_POOL = new ThreadPoolExecutor(8, 8, 0L, TimeUnit.SECONDS,
+            new LinkedBlockingQueue<>(), new ThreadFactoryBuilder().setNameFormat("small-pool-%d").build(), new ThreadPoolExecutor.CallerRunsPolicy());
+
+
 }

pcloud-service-book/src/main/resources/mapper/book/BookAdviser.Mapper.xml

@@ -1100,4 +1100,30 @@
 			a.CREATED_DATE DESC
 		LIMIT 1
 	</select>
+
+	<select id="listBookServes4Book" parameterType="map" resultType="com.pcloud.book.book.vo.BookServesListDTO">
+		SELECT
+			BOOK_ADVISER_ID bookAdviserId,
+			a.BOOK_ID bookId,
+			CHANNEL_ID channelId,
+			ADVISER_ID adviserId,
+			TEMPLET_ID templateId,
+			GRA_LABEL_ID graLabelId,
+			SUB_LABEL_ID subLabelId,
+			VER_LABEL_ID verLabelId,
+			vol_label_id volLabelId,
+			pro_label_id proLabelId,
+			pur_label_id purLabelId,
+			dep_label_id depLabelId,
+			BOOK_NAME bookName
+		FROM
+			book_adviser a LEFT JOIN book b on a.BOOK_ID = b.BOOK_ID
+		WHERE
+			a.IS_DELETE = 0
+		<if test="cursor != null">
+			AND BOOK_ADVISER_ID > ${cursor}
+		</if>
+		ORDER BY BOOK_ADVISER_ID
+		limit ${limit}
+	</select>
 </mapper>