Commit b4e2691a by 刘正

添加使用bookId和adviserId查询社群书信息的接口

parent d16fdff2
package com.pcloud.book.group.dto;
import java.util.List;
import lombok.Data;
/**
* 用于根据bookId和adviserId查询BookGroup相关信息
*/
@Data
public class QueryByBookAdviserDTO {
List<Long> bookIds;
List<Long> adviserIds;
}
...@@ -7,6 +7,7 @@ import java.util.Map; ...@@ -7,6 +7,7 @@ import java.util.Map;
import com.pcloud.book.group.dto.PersonalQrcodeDTO; import com.pcloud.book.group.dto.PersonalQrcodeDTO;
import com.pcloud.book.group.dto.GroupCipherDTO; import com.pcloud.book.group.dto.GroupCipherDTO;
import com.pcloud.book.group.dto.GroupUseDTO; import com.pcloud.book.group.dto.GroupUseDTO;
import com.pcloud.book.group.dto.QueryByBookAdviserDTO;
import com.pcloud.book.group.dto.ResourceBrowseParamDto; import com.pcloud.book.group.dto.ResourceBrowseParamDto;
import org.springframework.cloud.netflix.feign.FeignClient; import org.springframework.cloud.netflix.feign.FeignClient;
...@@ -37,6 +38,10 @@ public interface BookGroupService { ...@@ -37,6 +38,10 @@ public interface BookGroupService {
@RequestMapping(value = "getBookGroupInfoByIds", method = RequestMethod.POST) @RequestMapping(value = "getBookGroupInfoByIds", method = RequestMethod.POST)
ResponseEntity<ResponseDto<Map<Long, BookGroupDTO>>> getBookGroupInfoByIds(@RequestBody List<Long> bookGroupIds) throws BizException; ResponseEntity<ResponseDto<Map<Long, BookGroupDTO>>> getBookGroupInfoByIds(@RequestBody List<Long> bookGroupIds) throws BizException;
@ApiOperation("根据bookId和AdviserId批量获取社群书基本信息")
@PostMapping(value = "getBookGroupInfoByBookIdAndAdviserId")
ResponseEntity<ResponseDto<List<BookGroupDTO>>> getBookGroupInfoByBookIdAndAdviserId(@RequestBody QueryByBookAdviserDTO queryByBookAdviserDTO) throws BizException;
@ApiOperation("为信息流批量获取社群书基本信息") @ApiOperation("为信息流批量获取社群书基本信息")
@RequestMapping(value = "getFlowInfoByBookGroupIds", method = RequestMethod.POST) @RequestMapping(value = "getFlowInfoByBookGroupIds", method = RequestMethod.POST)
ResponseEntity<ResponseDto<Map<Long, StoreFlowInfoDto>>> getFlowInfoByBookGroupIds(@RequestBody List<Long> bookGroupIds) throws BizException; ResponseEntity<ResponseDto<Map<Long, StoreFlowInfoDto>>> getFlowInfoByBookGroupIds(@RequestBody List<Long> bookGroupIds) throws BizException;
......
...@@ -66,6 +66,11 @@ public interface BookGroupBiz { ...@@ -66,6 +66,11 @@ public interface BookGroupBiz {
Map<Long, BookGroupDTO> getBookGroupInfoByIds(List<Long> bookGroupIds) throws BizException; Map<Long, BookGroupDTO> getBookGroupInfoByIds(List<Long> bookGroupIds) throws BizException;
/** /**
* 根据bookId和AdviserId批量获取社群书基本信息
*/
List<BookGroupDTO> getBookGroupInfoByBookIdAndAdviserId(List<Long> bookIds, List<Long> adviserIds);
/**
* 获取社群书群二维码信息 * 获取社群书群二维码信息
* @param bookGroupId 群二维码ID * @param bookGroupId 群二维码ID
* @return * @return
......
...@@ -334,6 +334,15 @@ public class BookGroupBizImpl implements BookGroupBiz { ...@@ -334,6 +334,15 @@ public class BookGroupBizImpl implements BookGroupBiz {
return list.stream().collect(Collectors.toMap(BookGroupDTO::getId, dto -> dto)); return list.stream().collect(Collectors.toMap(BookGroupDTO::getId, dto -> dto));
} }
@Override
public List<BookGroupDTO> getBookGroupInfoByBookIdAndAdviserId(List<Long> bookIds, List<Long> adviserIds){
if(ListUtils.isEmpty(bookIds) || ListUtils.isEmpty(adviserIds)) {
return null;
}
return bookGroupDao.getDTOByBookIdsAnsAdviserIds(bookIds,adviserIds);
}
/** /**
* 获取社群书群二维码信息 * 获取社群书群二维码信息
*/ */
......
...@@ -39,6 +39,13 @@ public interface BookGroupDao extends BaseDao<BookGroup> { ...@@ -39,6 +39,13 @@ public interface BookGroupDao extends BaseDao<BookGroup> {
BookGroupDTO getDTOByBookId(Long bookId, Long channelId, Long adviserId); BookGroupDTO getDTOByBookId(Long bookId, Long channelId, Long adviserId);
/** /**
*
* @param bookIds 书刊ID
* @param adviserIds 编辑ID
*/
List<BookGroupDTO> getDTOByBookIdsAnsAdviserIds(List<Long> bookIds, List<Long> adviserIds);
/**
* 根据书刊ID删除 * 根据书刊ID删除
* @param bookId 书刊ID * @param bookId 书刊ID
* @param channelId 运营ID * @param channelId 运营ID
......
...@@ -47,6 +47,14 @@ public class BookGroupDaoImpl extends BaseDaoImpl<BookGroup> implements BookGrou ...@@ -47,6 +47,14 @@ public class BookGroupDaoImpl extends BaseDaoImpl<BookGroup> implements BookGrou
return super.getSqlSession().selectOne(getStatement("getDTOByBookId"), paramMap); return super.getSqlSession().selectOne(getStatement("getDTOByBookId"), paramMap);
} }
@Override
public List<BookGroupDTO> getDTOByBookIdsAnsAdviserIds(List<Long> bookIds, List<Long> adviserIds) {
Map<String, Object> paramMap = new HashMap<>();
paramMap.put("bookIds",bookIds);
paramMap.put("adviserIds",adviserIds);
return super.getSqlSession().selectList(getStatement("getDTOByBookIdsAnsAdviserIds"),paramMap);
}
/** /**
* 根据书刊ID删除 * 根据书刊ID删除
*/ */
......
...@@ -8,6 +8,7 @@ import com.pcloud.book.group.dto.GroupCipherDTO; ...@@ -8,6 +8,7 @@ import com.pcloud.book.group.dto.GroupCipherDTO;
import com.pcloud.book.group.dto.GroupUseDTO; import com.pcloud.book.group.dto.GroupUseDTO;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import com.pcloud.book.group.dto.QueryByBookAdviserDTO;
import com.pcloud.book.group.dto.ResourceBrowseParamDto; import com.pcloud.book.group.dto.ResourceBrowseParamDto;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
...@@ -51,6 +52,15 @@ public class BookGroupServiceImpl implements BookGroupService { ...@@ -51,6 +52,15 @@ public class BookGroupServiceImpl implements BookGroupService {
} }
/** /**
* 根据bookId和AdviserId批量获取社群书基本信息
*/
@Override
@PostMapping(value = "getBookGroupInfoByBookIdAndAdviserId")
public ResponseEntity<ResponseDto<List<BookGroupDTO>>> getBookGroupInfoByBookIdAndAdviserId(@RequestBody QueryByBookAdviserDTO queryByBookAdviserDTO) throws BizException {
return ResponseHandleUtil.toResponse(bookGroupBiz.getBookGroupInfoByBookIdAndAdviserId(queryByBookAdviserDTO.getBookIds(),queryByBookAdviserDTO.getAdviserIds()));
}
/**
* 为信息流批量获取社群书基本信息 * 为信息流批量获取社群书基本信息
*/ */
@Override @Override
......
...@@ -90,6 +90,21 @@ ...@@ -90,6 +90,21 @@
and create_user = #{adviserId,jdbcType=BIGINT} and create_user = #{adviserId,jdbcType=BIGINT}
ORDER BY create_time ASC limit 1 ORDER BY create_time ASC limit 1
</select> </select>
<select id="getDTOByBookIdsAnsAdviserIds" resultMap="BookGroupDTO" parameterType="map">
select
<include refid="Base_Column_List"/>
from book_group
where is_delete = 0
and book_id in
<foreach collection="bookIds" open="(" close=")" item="item" separator=",">
${item}
</foreach>
and create_user in
<foreach collection="adviserIds" open="(" close=")" item="item" separator=",">
${item}
</foreach>
</select>
<select id="getBookGroupCount" resultType="Integer" parameterType="Long"> <select id="getBookGroupCount" resultType="Integer" parameterType="Long">
SELECT SELECT
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment