Commit 8921bc82 by lili

删除activemq相关

parent 15fb7c8d
...@@ -338,7 +338,6 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -338,7 +338,6 @@ public class BookAppealBizImpl implements BookAppealBiz {
public void setOnlyOneAdviser(Long bookId, Long declarant, Long channelId, Long templetId, List<BookAdviserDto> adviserBooks) { public void setOnlyOneAdviser(Long bookId, Long declarant, Long channelId, Long templetId, List<BookAdviserDto> adviserBooks) {
//删除其余编辑与图书关联关系 //删除其余编辑与图书关联关系
bookAdviserBiz.deleteByBook(bookId); bookAdviserBiz.deleteByBook(bookId);
//批量删除书架书籍 //批量删除书架书籍
adviserBooks.stream().forEach( adviserBooks.stream().forEach(
adviserBook->{ adviserBook->{
......
package com.pcloud.book.mq.topic; package com.pcloud.book.mq.topic;
import javax.jms.Message; import com.pcloud.book.book.biz.BookAdviserBiz;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
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.usercenter.common.enums.ResourceEnum; import com.pcloud.usercenter.common.enums.ResourceEnum;
import com.pcloud.usercenter.system.entity.ExtraSetting;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitHandler;
...@@ -14,11 +13,6 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener; ...@@ -14,11 +13,6 @@ 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 com.pcloud.book.base.exception.BookBizException;
import com.pcloud.book.book.biz.BookAdviserBiz;
import com.pcloud.common.exceptions.BizException;
import com.pcloud.usercenter.system.entity.ExtraSetting;
/** /**
* @描述: 选择默认渠道 * @描述: 选择默认渠道
*/ */
......
...@@ -3,11 +3,9 @@ ...@@ -3,11 +3,9 @@
*/ */
package com.pcloud.book.mq.topic; package com.pcloud.book.mq.topic;
import javax.jms.Message; import com.pcloud.book.book.biz.BookProductBiz;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import com.pcloud.book.mq.config.MQTopicConumer; import com.pcloud.book.mq.config.MQTopicConumer;
import com.pcloud.common.exceptions.BizException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitHandler;
...@@ -15,10 +13,6 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener; ...@@ -15,10 +13,6 @@ 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 com.pcloud.book.base.exception.BookBizException;
import com.pcloud.book.book.biz.BookProductBiz;
import com.pcloud.common.exceptions.BizException;
/** /**
* @描述: * @描述:
* *
......
package com.pcloud.book.mq.topic; package com.pcloud.book.mq.topic;
import javax.jms.Message; import com.pcloud.book.book.biz.BookAdviserBiz;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
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.core.constant.SystemCode;
import com.pcloud.usercenter.common.enums.ResourceEnum; import com.pcloud.usercenter.common.enums.ResourceEnum;
import org.slf4j.Logger; import com.pcloud.usercenter.party.common.entity.Party;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener; 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 com.pcloud.appcenter.base.exception.AppBizException;
import com.pcloud.book.book.biz.BookAdviserBiz;
import com.pcloud.common.core.constant.SystemCode;
import com.pcloud.usercenter.party.common.entity.Party;
@Component("registerPartyListener") @Component("registerPartyListener")
@RabbitListener(queues = MQTopicConumer.REGISTER_PARTY) @RabbitListener(queues = MQTopicConumer.REGISTER_PARTY)
public class RegisterPartyListener{ public class RegisterPartyListener{
......
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