book 索引对接

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

@@ -13,9 +13,6 @@ import com.pcloud.book.es.biz.ESBookAndAdviserBiz;
 import com.pcloud.book.es.entity.ESBookAndAdviser;
 import com.pcloud.book.rightsSetting.constants.RightsSettingConstant;
 import com.pcloud.book.util.common.Converter;
-import com.pcloud.book.util.common.ThreadPoolUtils;
-import com.pcloud.book.util.common.YesOrNoEnums;
-import com.pcloud.book.util.properties.BookProps;
 import com.pcloud.common.core.aspect.ParamLog;
 import com.pcloud.common.exceptions.BizException;
 import com.pcloud.common.utils.ListUtils;
@@ -24,18 +21,17 @@ import com.pcloud.common.utils.string.StringUtil;
 import com.pcloud.universe.commons.paging.Pagination;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
-import org.elasticsearch.index.query.BoolQueryBuilder;
-import org.elasticsearch.index.query.QueryBuilders;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
-import org.springframework.data.domain.PageImpl;
-import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.*;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
 import java.util.stream.Collectors;
 
 import static com.pcloud.book.book.constant.BookConstant.IGNOR_BOOK_KEY;
@@ -67,7 +63,7 @@ public class ESBookAndAdviserBizImpl implements ESBookAndAdviserBiz {
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void addAllBookAndAdviserToES() {
-        ThreadPoolUtils.OTHER_THREAD_POOL.execute(() -> es7BookSyncService.syncAllBooks());
+        es7BookSyncService.asyncAllBooks();
     }
 
     @ParamLog("更新书和编辑书")