Skip to content

M
midjourney-proxy
Commit 15fb7c8d by lili
Options

删除不用的方法

parent 94ec948a
Showing with 11 additions and 445 deletions
pcloud-service-book/src/main/java/com/pcloud/book/book/biz/BookBiz.java
......@@ -241,16 +241,6 @@ public interface BookBiz {
List<Long> getIdsByName(String bookName, Long adviserId) throws BizException;
/**
* 图书收益，获取书籍列表(编辑)
*
* @param paramMap
* @param pageParam
* 分页参数传递工具类
* @return
*/
PageBean getListPage4AdviserProfit(Map<String, Object> paramMap, PageParam pageParam) throws BizException;
/**
* 图书收益，获取单个书籍基础信息(包含统计信息)
*
* @param bookId
......@@ -505,15 +495,6 @@ public interface BookBiz {
void updateTimeByIds(BookAdviserUpdateTimeDTO bookAdviserUpdateTimeDTO)throws BizException;
/**
* 平台端--数据分析-书刊分析
* @param pageParam
* @param bookAnalysic4PCVO
* @return
* @throws BizException
*/
PageBean getBookAnalysis4PC(PageParam pageParam, BookAnalysic4PCVO bookAnalysic4PCVO)throws BizException;
/**
* 获取书刊信息
* @return
* @throws BizException
......
pcloud-service-book/src/main/java/com/pcloud/book/book/biz/impl/BookBizImpl.java
......@@ -32,8 +32,6 @@ import com.pcloud.book.book.dto.BookInfoAnalysicsDTO;
import com.pcloud.book.book.entity.Book;
import com.pcloud.book.book.entity.BookAdviser;
import com.pcloud.book.book.set.BookSet;
import com.pcloud.book.book.tools.BookTools;
import com.pcloud.book.book.vo.BookAnalysic4PCVO;
import com.pcloud.book.consumer.analysisengine.SceneRecordConsr;
import com.pcloud.book.consumer.app.AssistTempletConsr;
import com.pcloud.book.consumer.channel.QrcodeSceneConsr;
......@@ -812,20 +810,6 @@ public class BookBizImpl implements BookBiz {
}
/**
* 图书收益，获取书籍列表(编辑)
*/
@Override
public PageBean getListPage4AdviserProfit(Map<String, Object> paramMap, PageParam pageParam) throws BizException {
LOGGER.info("【书籍收益】获取书籍列表,<START>.[START]=" + paramMap.toString());
try {
return bookDao.listPage(pageParam, paramMap, "getList4AdviserProfit");
} catch (Exception e) {
LOGGER.error("【书籍收益】获取书籍列表,<ERROR>.[getList4AdviserProfit]:" + e.getMessage(), e);
throw BizException.DB_SELECT_IS_FAIL;
}
}
/**
* 图书收益，获取单个书籍基础信息(包含统计信息)
*/
@Override
......@@ -1491,73 +1475,6 @@ public class BookBizImpl implements BookBiz {
bookDao.updateTimeByIds(paramMap);
}
@ParamLog(description = "平台端--数据分析-书刊分析")
@Override
public PageBean getBookAnalysis4PC(PageParam pageParam, BookAnalysic4PCVO bookAnalysic4PCVO) throws BizException {
Map<String,Object> paramMap = Maps.newHashMap();
if(!StringUtil.isEmpty(bookAnalysic4PCVO.getBookName())){
paramMap.put("bookName",bookAnalysic4PCVO.getBookName());
}
if(!StringUtil.isEmpty(bookAnalysic4PCVO.getStatisTime())){
if(BookTools.isValidDate(bookAnalysic4PCVO.getStatisTime(),"yyyy-MM")){
paramMap.put("statisTime",bookAnalysic4PCVO.getStatisTime());
}else{
throw new BookBizException(BookBizException.PARAM_IS_ERROR,"请检查数据统计年月格式~");
}
}
if(!StringUtil.isEmpty(bookAnalysic4PCVO.getIsbn())){
paramMap.put("isbn",bookAnalysic4PCVO.getIsbn());
}
if(null != bookAnalysic4PCVO.getTempletId()){
/*List<Long> ids = assistTempletConsr.getChildIdListByParentId(bookAnalysic4PCVO.getTempletId());
if(!ListUtils.isEmpty(ids)){
paramMap.put("templetId",bookAnalysic4PCVO.getTempletId());
}*/
paramMap.put("templetId",bookAnalysic4PCVO.getTempletId());
}
if(!ListUtils.isEmpty(bookAnalysic4PCVO.getAgentIds())){
List<Long> channelIds = Lists.newArrayList();
List<Long> agentIds = bookAnalysic4PCVO.getAgentIds();
for(Long agentId:agentIds){
List<Long> ids = channelConsr.getApproveIdList(agentId);
if(!ListUtils.isEmpty(ids)){
channelIds.addAll(ids);
}
}
if(!ListUtils.isEmpty(channelIds)){
paramMap.put("channelIds",channelIds);
}else{
return new PageBean();
}
}
if(!ListUtils.isEmpty(bookAnalysic4PCVO.getAdviserIds())){
paramMap.put("adviserIds",bookAnalysic4PCVO.getAdviserIds());
}
if(null != bookAnalysic4PCVO.getIsFundSupport()){
paramMap.put("isFundSupport",bookAnalysic4PCVO.getIsFundSupport());
}
PageBean pageBean = bookDao.listPage(pageParam,paramMap,"getBookAnalysis4PC");
if(null != pageBean && !ListUtils.isEmpty(pageBean.getRecordList())){
// 设置出版信息
bookSet.setAgentInfo4Anlysics(pageBean.getRecordList());
// 设置编辑信息
bookSet.setAdviserInfo4Anlysics(pageBean.getRecordList());
// 设置书刊分类信息
bookSet.setTempletName4Anlysics(pageBean.getRecordList());
// 设置关联二维码数量
bookSet.setBookAssocQRCount(pageBean.getRecordList(),bookAnalysic4PCVO.getStatisTime());
// 设置浏览量 设置读者量 扫码平均转化率
bookSet.setAnalysicsInfo(pageBean.getRecordList(),bookAnalysic4PCVO.getStatisTime());
// 设置累计收益
bookSet.setBookIncome4Analysics(pageBean.getRecordList(),bookAnalysic4PCVO.getStatisTime());
//设置默认值
bookSet.setDefaultValue(pageBean.getRecordList());
}
return pageBean;
}
@ParamLog(description = "获取书刊信息")
@Override
public Map<String, BookInfoAnalysicsDTO> getBookInfoBy(List<BookInfoAnalysicsDTO> bookInfoAnalysicsDTOS, String
......
pcloud-service-book/src/main/java/com/pcloud/book/book/service/impl/BookServiceImpl.java
......@@ -3,17 +3,6 @@
*/
package com.pcloud.book.book.service.impl;
import java.util.List;
import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import com.pcloud.book.book.biz.BookBiz;
import com.pcloud.book.book.dto.BookAdviserUpdateTimeDTO;
import com.pcloud.book.book.dto.BookDetialDTO;
......@@ -24,6 +13,17 @@ import com.pcloud.book.book.service.BookService;
import com.pcloud.common.dto.ResponseDto;
import com.pcloud.common.exceptions.BizException;
import com.pcloud.common.utils.ResponseHandleUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.Map;
/**
* @描述：
......
pcloud-service-book/src/main/java/com/pcloud/book/book/set/BookSet.java
......@@ -6,7 +6,6 @@ package com.pcloud.book.book.set;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists;
import com.pcloud.analysisengine.browse.dto.BrowseCacheRecordDto;
import com.pcloud.analysisengine.browse.dto.SBookAnalyzeDto;
import com.pcloud.appcenter.app.dto.AppDto;
import com.pcloud.appcenter.assist.dto.AssistTempletDTO;
import com.pcloud.book.appeal.dto.AppealAdviserDto;
......@@ -21,7 +20,6 @@ import com.pcloud.book.book.dao.BookFreezeDao;
import com.pcloud.book.book.dao.BookTypeDao;
import com.pcloud.book.book.dto.AdviserManageDto;
import com.pcloud.book.book.dto.BookAdviserDto;
import com.pcloud.book.book.dto.BookAnlysicsDto;
import com.pcloud.book.book.dto.BookAppDto;
import com.pcloud.book.book.dto.BookDeleteDto;
import com.pcloud.book.book.dto.BookDto;
......@@ -41,7 +39,6 @@ import com.pcloud.book.consumer.content.ResourceConsr;
import com.pcloud.book.consumer.message.MessageConsr;
import com.pcloud.book.consumer.resource.ProductConsr;
import com.pcloud.book.consumer.settlement.BookConsr;
import com.pcloud.book.consumer.trade.OrderFormConsr;
import com.pcloud.book.consumer.user.AdviserConsr;
import com.pcloud.book.consumer.user.BookcaseConsr;
import com.pcloud.book.consumer.user.ChannelConsr;
......@@ -51,9 +48,7 @@ import com.pcloud.channelcenter.base.constants.MessageFromTypeEnum;
import com.pcloud.channelcenter.qrcode.dto.QrcodeLocationDto;
import com.pcloud.channelcenter.qrcode.vo.BookAssocLastQrAskVO;
import com.pcloud.channelcenter.qrcode.vo.BookAssocLastQrVO;
import com.pcloud.channelcenter.qrcode.vo.BookAssocQRcountRequestVO;
import com.pcloud.comment.base.enums.SysCodeEnum;
import com.pcloud.common.core.aspect.ParamLog;
import com.pcloud.common.core.constant.MQTopicProducer;
import com.pcloud.common.core.constant.SystemCode;
import com.pcloud.common.exceptions.BizException;
......@@ -63,7 +58,6 @@ import com.pcloud.common.utils.ListUtils;
import com.pcloud.common.utils.number.AmountUtil;
import com.pcloud.common.utils.string.StringUtil;
import com.pcloud.contentcenter.resource.dto.ResourceDTO;
import com.pcloud.facade.tradecenter.dto.BookIncomeQueryVo;
import com.pcloud.resourcecenter.product.dto.ProductDto;
import com.pcloud.resourcecenter.product.dto.ProductTypeDto;
import com.pcloud.resourcecenter.product.dto.SpecificationDto;
......@@ -143,8 +137,6 @@ public class BookSet {
private BookFreezeDao bookFreezeDao;
@Autowired
private AmqpTemplate amqpTemplate;
@Autowired
private OrderFormConsr orderFormConsr;
/**
* 检验书号是否合法，包括ISSN,ISBN,CSSN
*
......@@ -439,42 +431,6 @@ public class BookSet {
}
/**
* 设置录音基本信息
*
* @param bookProductsMap
*/
public void setSoundInfo(Map<Long, BookProductDto> bookProductsMap) {
if (!MapUtils.isEmpty(bookProductsMap)) {
List<Long> soundIds = new ArrayList<>();
for (Long productId : bookProductsMap.keySet()) {
BookProductDto bookProductDto = bookProductsMap.get(productId);
if (bookProductDto != null && bookProductDto.getSoundId() != null) {
soundIds.add(bookProductDto.getSoundId());
}
}
// 调用用户中心查询录音信息
Map<Long, MerchantVideo> soundInfos = merchantVideoConsr.getVideoById(new ArrayList<Long>(soundIds));
if (!MapUtils.isEmpty(soundInfos)) {
for (Long productId : bookProductsMap.keySet()) {
BookProductDto bookProductDto = bookProductsMap.get(productId);
if (bookProductDto != null && bookProductDto.getSoundId() != null
&& soundInfos.containsKey(bookProductDto.getSoundId())) {
MerchantVideo merchantVideo = soundInfos.get(bookProductDto.getSoundId());
if (bookProductDto != null && merchantVideo != null) {
bookProductDto.setSoundType(merchantVideo.getVideoType());
bookProductDto.setSoundUrl(merchantVideo.getVideoPath());
bookProductDto.setFileSize(merchantVideo.getVideoSize());
bookProductDto.setSoundName(merchantVideo.getVideoShortName());
bookProductsMap.put(productId, bookProductDto);
}
}
}
}
}
}
/**
* 设置被诉方
*
* @param adviserBooks
......@@ -1538,230 +1494,4 @@ public class BookSet {
LOGGER.info("设置父模板标识.setTempleParentId.<END>.[bookDto]:"+bookDto);
}
/**
* 设置父模板标识
* @param bookDto
*/
public void setTempleParentIdAndTempletName(BookDto bookDto){
LOGGER.info("设置分类名称..<START>.[bookDto]:"+bookDto);
if(null != bookDto && null != bookDto.getTempletId()){
List<Long> assistTempletIds = Lists.newArrayList();
assistTempletIds.add(bookDto.getTempletId());
Map<Long, AssistTempletDTO> templeMap = assistTempletConsr.mapByIds(assistTempletIds);
if(!MapUtils.isEmpty(templeMap)){
AssistTempletDTO templetDTO = templeMap.get(bookDto.getTempletId());
if(null != templetDTO){
bookDto.setTempletName(templetDTO.getTempletName());
bookDto.setTempleParentId(templetDTO.getParentId());
}
}
}
LOGGER.info("设置父模板标识.setTempletName.<END>.[bookDto]:"+bookDto);
}
/**
* 书刊分析-设置出版信息
* @param objects
*/
public void setAgentInfo4Anlysics(List<Object> objects){
if(ListUtils.isEmpty(objects)){
return;
}
List<Long> channelIds = Lists.newArrayList();
for(Object object:objects){
BookAnlysicsDto bookAnlysicsDto = (BookAnlysicsDto) object;
channelIds.add(bookAnlysicsDto.getChannelId());
}
if(ListUtils.isEmpty(channelIds)){
return;
}
Map<Long, String> channelNameMap = channelConsr.getNamesByIdList(channelIds);
Map<Long, Agent> agentInfoMap = partyConsr.getAgentByPartyId(channelIds, SysCodeEnum.CHANNEL.value.toLowerCase());
for (Object object : objects) {
BookAnlysicsDto bookAnlysicsDto = (BookAnlysicsDto) object;
Agent agent = null;
if(!MapUtils.isEmpty(agentInfoMap)){
agent = agentInfoMap.get(bookAnlysicsDto.getChannelId());
}
if(!MapUtils.isEmpty(channelNameMap)){
bookAnlysicsDto.setChannelName(channelNameMap.get(bookAnlysicsDto.getChannelId()));
}
if (null != agent) {
bookAnlysicsDto.setAgentId(agent.getAgentId());
bookAnlysicsDto.setAgentName(agent.getName());
}
}
}
/**
* 书刊分析-设置编辑信息
* @param objects
*/
public void setAdviserInfo4Anlysics(List<Object> objects){
if(ListUtils.isEmpty(objects)){
return;
}
List<Long> adviserIds = Lists.newArrayList();
for(Object object:objects){
BookAnlysicsDto bookAnlysicsDto = (BookAnlysicsDto) object;
adviserIds.add(bookAnlysicsDto.getAdviserId());
}
if(ListUtils.isEmpty(adviserIds)){
return;
}
Map<Long,String> adviserNameMap = adviserConsr.getNames(adviserIds);
if(!MapUtils.isEmpty(adviserNameMap)){
for(Object object:objects){
BookAnlysicsDto bookAnlysicsDto = (BookAnlysicsDto) object;
bookAnlysicsDto.setAdviserName(adviserNameMap.get(bookAnlysicsDto.getAdviserId()));
}
}
}
/**
* 书刊分析-设置书刊分类名字
* @param objects
*/
public void setTempletName4Anlysics(List<Object> objects){
if(ListUtils.isEmpty(objects)){
return;
}
List<Long> assistTempletIds = Lists.newArrayList();
BookAnlysicsDto bookAnlysicsDto = null;
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
assistTempletIds.add(bookAnlysicsDto.getTempletId());
}
if(ListUtils.isEmpty(assistTempletIds)){
return;
}
Map<Long, AssistTempletDTO> templeMap = assistTempletConsr.mapByIds(assistTempletIds);
if(!MapUtils.isEmpty(templeMap)){
AssistTempletDTO assistTempletDTO = null;
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
assistTempletDTO = templeMap.get(bookAnlysicsDto.getTempletId());
if(null != assistTempletDTO){
bookAnlysicsDto.setTempleName(assistTempletDTO.getTempletName());
}
}
}
}
@ParamLog(description = "设置书刊分析-分析引擎相关数据")
public void setAnalysicsInfo(List<Object> objects,String monthDate){
if(ListUtils.isEmpty(objects)){
return;
}
List<SBookAnalyzeDto> sBookAnalyzeDtos = Lists.newArrayList();
BookAnlysicsDto bookAnlysicsDto = null;
SBookAnalyzeDto sBookAnalyzeDto = null;
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
sBookAnalyzeDto = new SBookAnalyzeDto();
sBookAnalyzeDto.setBookId(bookAnlysicsDto.getBookId());
sBookAnalyzeDto.setAdviserId(bookAnlysicsDto.getAdviserId());
sBookAnalyzeDto.setChannelId(bookAnlysicsDto.getChannelId());
sBookAnalyzeDtos.add(sBookAnalyzeDto);
}
if(ListUtils.isEmpty(sBookAnalyzeDtos)){
return;
}
Map<String,SBookAnalyzeDto> sBookAnalyzeDtoMap = browseRecordConsr.getMonthBookPvUvSuScvr(sBookAnalyzeDtos,monthDate);
if(!MapUtils.isEmpty(sBookAnalyzeDtoMap)){
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
String key = new StringBuffer().append(bookAnlysicsDto.getBookId()).append("_").append(bookAnlysicsDto.getChannelId()).append("_").append(bookAnlysicsDto.getAdviserId()).toString();
sBookAnalyzeDto = sBookAnalyzeDtoMap.get(key);
if(null != sBookAnalyzeDto){
bookAnlysicsDto.setScanNum(sBookAnalyzeDto.getPv());
bookAnlysicsDto.setReaderNum(sBookAnalyzeDto.getUv());
bookAnlysicsDto.setScvr(sBookAnalyzeDto.getScvr());
}
}
}
}
public void setDefaultValue(List<Object> objects){
if(ListUtils.isEmpty(objects)){
return;
}
BookAnlysicsDto bookAnlysicsDto = null;
SBookAnalyzeDto sBookAnalyzeDto = null;
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
if(null == bookAnlysicsDto.getIncome()){
bookAnlysicsDto.setIncome(new BigDecimal(0));
}
if(null == bookAnlysicsDto.getReaderNum()){
bookAnlysicsDto.setReaderNum(0L);
}
if(null == bookAnlysicsDto.getScanNum()){
bookAnlysicsDto.setScanNum(0L);
}
if(null == bookAnlysicsDto.getSceneCount()){
bookAnlysicsDto.setSceneCount(0L);
}
if(null == bookAnlysicsDto.getScvr()){
bookAnlysicsDto.setScvr(0.00);
}
}
}
@ParamLog(description = "设置图书关联二维码个数")
public void setBookAssocQRCount(List<Object> objects,String monthDate){
if(ListUtils.isEmpty(objects)){
return;
}
List<BookAssocQRcountRequestVO> bookAssocQRcountRequestVOS = Lists.newArrayList();
BookAssocQRcountRequestVO bookAssocQRcountRequestVO = null;
BookAnlysicsDto bookAnlysicsDto = null;
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
bookAssocQRcountRequestVO = new BookAssocQRcountRequestVO();
bookAssocQRcountRequestVO.setChannelId(bookAnlysicsDto.getChannelId());
bookAssocQRcountRequestVO.setBookId(bookAnlysicsDto.getBookId());
bookAssocQRcountRequestVO.setAdviserId(bookAnlysicsDto.getAdviserId());
bookAssocQRcountRequestVOS.add(bookAssocQRcountRequestVO);
}
if(ListUtils.isEmpty(bookAssocQRcountRequestVOS)){
return;
}
Map<String,Long> qrCountMap = qrcodeSceneConsr.getBookQRCountByMap(bookAssocQRcountRequestVOS,monthDate);
if(!MapUtils.isEmpty(qrCountMap)){
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
String key = new StringBuffer().append(bookAnlysicsDto.getChannelId()).append("_").append(bookAnlysicsDto.getBookId()).append("_").append(bookAnlysicsDto.getAdviserId()).toString();
bookAnlysicsDto.setSceneCount(qrCountMap.get(key));
}
}
}
@ParamLog(description = "设置书刊收益")
public void setBookIncome4Analysics(List<Object> objects,String monthDate){
if(ListUtils.isEmpty(objects)){
return;
}
List<BookIncomeQueryVo> bookIncomeQueryVos = Lists.newArrayList();
BookIncomeQueryVo bookIncomeQueryVo = null;
BookAnlysicsDto bookAnlysicsDto = null;
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
bookIncomeQueryVo = new BookIncomeQueryVo();
bookIncomeQueryVo.setChannelId(bookAnlysicsDto.getChannelId());
bookIncomeQueryVo.setBookId(bookAnlysicsDto.getBookId());
bookIncomeQueryVo.setAdviserId(bookAnlysicsDto.getAdviserId());
bookIncomeQueryVos.add(bookIncomeQueryVo);
}
if(ListUtils.isEmpty(bookIncomeQueryVos)){
return;
}
Map<String,BigDecimal> incomeMap = orderFormConsr.getBookIncome(bookIncomeQueryVos,monthDate);
if(!MapUtils.isEmpty(incomeMap)){
for(Object object:objects){
bookAnlysicsDto = (BookAnlysicsDto) object;
String key = new StringBuffer().append(bookAnlysicsDto.getBookId()).append("_").append(bookAnlysicsDto.getChannelId()).append("_").append(bookAnlysicsDto.getAdviserId()).toString();
bookAnlysicsDto.setIncome(incomeMap.get(key));
}
}
}
}
pcloud-service-book/src/main/java/com/pcloud/book/consumer/message/TemplateConsr.java
......@@ -59,30 +59,4 @@ public class TemplateConsr {
LOGGER.info("【模板消息(消)】发送模板消息topic(管理公众号),<END>");
}
/**
* 发送模板消息topic(运营公众号)
*/
public void sendChannel(String SceneCode, Long wechatUserId, Long sendPartyId, String url,
Map<String, String> temParam, boolean isApp, String appType) throws BizException {
LOGGER.info("【模板消息(消)】发送模板消息topic(运营公众号),<START>.[wechatUserId]=" + wechatUserId + ",[sendPartyId]="
+ sendPartyId + ",[temParam]=" + temParam.toString());
// 组装参数对象
TemplateMessageDto templateMessageDto = new TemplateMessageDto();
templateMessageDto.setSceneCode(SceneCode);
templateMessageDto.setWechatUserId(wechatUserId);
templateMessageDto.setSendPartyId(sendPartyId);
templateMessageDto.setSendPartyRole(WechatCode.CHANNEL.value);
templateMessageDto.setUrl(url);
templateMessageDto.setTemParam(temParam);
templateMessageDto.setSendType(SendType.SEND_BY_WECHAT_USER_ID.value);
templateMessageDto.setIsApp(isApp);
templateMessageDto.setAppType(appType);
try {
templateQueueBiz.sendMessageQueue(templateMessageDto);
} catch (Exception e) {
LOGGER.error("【模板消息(消)】发送模板消息topic(运营公众号),<ERROR>.[sendMessageQueue]:" + e.getMessage(), e);
}
LOGGER.info("【模板消息(消)】发送模板消息topic(运营公众号),<END>");
}
}
pcloud-service-book/src/main/java/com/pcloud/book/consumer/trade/OrderFormConsr.java deleted 100644 → 0
package com.pcloud.book.consumer.trade;
import com.pcloud.common.core.aspect.ParamLog;
import com.pcloud.common.exceptions.BizException;
import com.pcloud.common.utils.ResponseHandleUtil;
import com.pcloud.facade.tradecenter.dto.BookIncomeQueryVo;
import com.pcloud.facade.tradecenter.service.OrderFormService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
@Component("orderFormConsr")
public class OrderFormConsr {
@Autowired
private OrderFormService orderFormService;
private static final Logger LOGGER = LoggerFactory.getLogger(OrderFormConsr.class);
@ParamLog(description = "获取图书收益")
public Map<String, BigDecimal> getBookIncome(List<BookIncomeQueryVo> bookIncomeQueryVos,String date)throws BizException {
Map<String, BigDecimal> incomeMap = null;
try {
incomeMap = ResponseHandleUtil.parseMapResponse(orderFormService.getBookIncome(bookIncomeQueryVos,date),String.class,BigDecimal.class);
} catch (Exception e) {
LOGGER.error("[消TRADECENTER.orderFormService.getBookIncome]出现异常，信息为:"+e.getMessage(),e);
}
return incomeMap;
}
}
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