Commit 902c4edf by 田超

Merge branch 'fixbug/none' into 'master'

bug: [none] 代码没有合上去

See merge request rays/pcloud-book!931
parents 14ddc99c 8684041a
package com.pcloud.book.mq.producer.impl; package com.pcloud.book.mq.producer.impl;
import com.alibaba.fastjson.JSON;
import com.pcloud.book.book.dto.BookCoverImgUpdateDTO; import com.pcloud.book.book.dto.BookCoverImgUpdateDTO;
import com.pcloud.book.book.dto.BookNameUpdateDTO; import com.pcloud.book.book.dto.BookNameUpdateDTO;
import com.pcloud.book.book.dto.CreateBookVO; import com.pcloud.book.book.dto.CreateBookVO;
...@@ -37,6 +38,6 @@ public class BookProducerImpl implements BookMQProducer { ...@@ -37,6 +38,6 @@ public class BookProducerImpl implements BookMQProducer {
@Override @Override
public void addCreateInfoToMq(List<CreateBookVO> createBookVOList) { public void addCreateInfoToMq(List<CreateBookVO> createBookVOList) {
amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.ERP_AUTO_CREATE_BOOK, createBookVOList); amqpTemplate.convertAndSend(MQTopicProducer.EXCHAGE, MQTopicProducer.ERP_AUTO_CREATE_BOOK, JSON.toJSONString(createBookVOList));
} }
} }
package com.pcloud.book.mq.topic; package com.pcloud.book.mq.topic;
import com.alibaba.fastjson.JSON;
import com.pcloud.book.book.biz.BookBiz; import com.pcloud.book.book.biz.BookBiz;
import com.pcloud.book.book.dto.CreateBookVO; import com.pcloud.book.book.dto.CreateBookVO;
import com.pcloud.book.mq.config.MQTopicConumer; import com.pcloud.book.mq.config.MQTopicConumer;
import com.pcloud.common.core.aspect.ParamLog; import com.pcloud.common.core.aspect.ParamLog;
import com.pcloud.common.exceptions.BizException; import com.pcloud.common.exceptions.BizException;
import com.pcloud.common.utils.ListUtils; import com.pcloud.common.utils.ListUtils;
import com.pcloud.common.utils.string.StringUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
...@@ -14,6 +16,7 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener; ...@@ -14,6 +16,7 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.List; import java.util.List;
@Component @Component
...@@ -30,8 +33,12 @@ public class ErpCreateBookListener { ...@@ -30,8 +33,12 @@ public class ErpCreateBookListener {
*/ */
@ParamLog("接收erp自动创建书刊") @ParamLog("接收erp自动创建书刊")
@RabbitHandler @RabbitHandler
public void onMessage(List<CreateBookVO> createBookVOList) throws BizException { public void onMessage(String json) throws BizException {
try { try {
List<CreateBookVO> createBookVOList=new ArrayList<>();
if(StringUtil.isNotBlank(json)) {
createBookVOList = JSON.parseArray(json, CreateBookVO.class);
}
LOGGER.error("接收erp自动创建书刊信息" + createBookVOList); LOGGER.error("接收erp自动创建书刊信息" + createBookVOList);
if (ListUtils.isEmpty(createBookVOList)) if (ListUtils.isEmpty(createBookVOList))
return; return;
......
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