novel-plus.zip

package com.java2nb.novel.service.impl; import com.fasterxml.jackson.databind.ObjectMapper; import com.github.pagehelper.PageHelper; import com.java2nb.novel.core.cache.CacheKey; import com.java2nb.novel.core.cache.CacheService; import com.java2nb.novel.core.config.BookPriceProperties; import com.java2nb.novel.core.enums.ResponseStatus; import io.github.xxyopen.web.util.BeanUtil; import com.java2nb.novel.core.utils.Constants; import com.java2nb.novel.core.utils.StringUtil; import com.java2nb.novel.entity.Book; import com.java2nb.novel.entity.*; import com.java2nb.novel.mapper.*; import com.java2nb.novel.service.AuthorService; import com.java2nb.novel.service.BookService; import com.java2nb.novel.service.FileService; import com.java2nb.novel.service.SearchService; import com.java2nb.novel.vo.BookCommentVO; import com.java2nb.novel.vo.BookSettingVO; import com.java2nb.novel.vo.BookSpVO; import com.java2nb.novel.vo.BookVO; import io.github.xxyopen.model.page.PageBean; import io.github.xxyopen.model.page.builder.pagehelper.PageBuilder; import io.github.xxyopen.util.IdWorker; import io.github.xxyopen.web.exception.BusinessException; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.mybatis.dynamic.sql.SortSpecification; import org.mybatis.dynamic.sql.render.RenderingStrategies; import org.mybatis.dynamic.sql.select.render.SelectStatementProvider; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import tk.mybatis.orderbyhelper.OrderByHelper; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import static com.java2nb.novel.mapper.BookCategoryDynamicSqlSupport.bookCategory; import static com.java2nb.novel.mapper.BookCommentDynamicSqlSupport.bookComment; import static com.java2nb.novel.mapper.BookContentDynamicSqlSupport.bookContent; import static com.java2nb.novel.mapper.BookContentDynamicSqlSupport.content; import static com.java2nb.novel.mapper.BookDynamicSqlSupport.*; import static com.java2nb.novel.mapper.BookIndexDynamicSqlSupport.bookIndex; import static org.mybatis.dynamic.sql.SqlBuilder.*; import static org.mybatis.dynamic.sql.select.SelectDSL.select; /** * @author 11797 */ @Service @RequiredArgsConstructor @Slf4j public class BookServiceImpl implements BookService { /** * 本地图片保存路径 */ @Value("${pic.save.path}") private String picSavePath; @Value("${spring.elasticsearch.enable}") private Integer esEnable; private final FrontBookSettingMapper bookSettingMapper; private final FrontBookMapper bookMapper; private final BookCategoryMapper bookCategoryMapper; private final BookIndexMapper bookIndexMapper; private final BookContentMapper bookContentMapper; private final FrontBookCommentMapper bookCommentMapper; private final BookAuthorMapper bookAuthorMapper; private final CacheService cacheService; private final AuthorService authorService; private final SearchService searchService; private final FileService fileService; private final BookPriceProperties bookPriceConfig; @SneakyThrows @Override public Map<Byte, List<BookSettingVO>> listBookSettingVO() { String result = cacheService.get(CacheKey.INDEX_BOOK_SETTINGS_KEY); if (result == null || result.length() < Constants.OBJECT_JSON_CACHE_EXIST_LENGTH) { List<BookSettingVO> list = bookSettingMapper.listVO(); if (list.size() == 0) { //如果首页小说没有被设置，则初始化首页小说设置 list = initIndexBookSetting(); } result = new ObjectMapper().writeValueAsString(list.stream().collect(Collectors.groupingBy(BookSettingVO::getType))); cacheService.set(CacheKey.INDEX_BOOK_SETTINGS_KEY, result); } return new ObjectMapper().readValue(result, Map.class); } /** * 初始化首页小说设置 */ private List<BookSettingVO> initIndexBookSetting() { Date currentDate = new Date(); List<Book> books = bookMapper.selectIdsByScoreAndRandom(Constants.INDEX_BOOK_SETTING_NUM); if (books.size() == Constants.INDEX_BOOK_SETTING_NUM) { List<BookSetting> bookSettingList = new ArrayList<>(Constants.INDEX_BOOK_SETTING_NUM); List<BookSettingVO> bookSettingVOList = new ArrayList<>(Constants.INDEX_BOOK_SETTING_NUM); for (int i = 0; i < books.size(); i++) { Book book = books.get(i); byte type; if (i < 4) { type = 0; } else if (i < 14) { type = 1; } else if (i < 19) { type = 2; } else if (i < 25) { type = 3; } else { type = 4; } BookSettingVO bookSettingVO = new BookSettingVO(); BookSetting bookSetting = new BookSetting(); bookSetting.setType(type); bookSetting.setSort((byte) i); bookSetting.setBookId(book.getId()); bookSetting.setCreateTime(currentDate); bookSetting.setUpdateTime(currentDate); bookSettingList.add(bookSetting); BeanUtils.copyProperties(book, bookSettingVO); BeanUtils.copyProperties(bookSetting, bookSettingVO); bookSettingVOList.add(bookSettingVO); } bookSettingMapper.insertMultiple(bookSettingList); return bookSettingVOList; } return new ArrayList<>(0); } @Override public List<Book> listClickRank() { List<Book> result = (List<Book>) cacheService.getObject(CacheKey.INDEX_CLICK_BANK_BOOK_KEY); if (result == null || result.size() == 0) { result = listRank((byte) 0, 10); cacheService.setObject(CacheKey.INDEX_CLICK_BANK_BOOK_KEY, result, 5000); } return result; } @Override public List<Book> listNewRank() { List<Book> result = (List<Book>) cacheService.getObject(CacheKey.INDEX_NEW_BOOK_KEY); if (result == null || result.size() == 0) { result = listRank((byte) 1, 10); cacheService.setObject(CacheKey.INDEX_NEW_BOOK_KEY, result, 3600); } return result; } @Override public List<BookVO> listUpdateRank() { List<BookVO> result = (List<BookVO>) cacheService.getObject(CacheKey.INDEX_UPDATE_BOOK_KEY); if (result == null || result.size() == 0) { List<Book> bookPOList = listRank((byte) 2, 23); result = BeanUtil.copyList(bookPOList, BookVO.class); cacheService.setObject(CacheKey.INDEX_UPDATE_BOOK_KEY, result, 60 * 10); } return result; } @Override public PageBean<?> searchByPage(BookSpVO params, int page, int pageSize) { if (params.getUpdatePeriod() != null) { long cur = System.currentTimeMillis(); long period = params.getUpdatePeriod() * 24 * 3600 * 1000; long time = cur - period; params.setUpdateTimeMin(new Date(time)); } if (esEnable == 1) { try { return searchService.searchBook(params,page,pageSize); }catch (Exception e){ log.error(e.getMessage(),e); } } PageHelper.startPage(page, pageSize); if (StringUtils.isNotBlank(params.getSort())) { OrderByHelper.orderBy(params.getSort() + " desc"); } return PageBuilder.b