1.取消mq消费者的的方法事物，

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/WarehouseTrayAllocationListener.java

@@ -43,7 +43,7 @@ public class WarehouseTrayAllocationListener {
 		value = @Queue(name = FanoutConstants.warehouse.TRAYTYPE.QUEUE.TRAYTYPE_MESSAGE),
 		exchange = @Exchange(name = FanoutConstants.warehouse.TRAYTYPE.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void trayTypeMessage(String msg) {
 		log.info("##########trayTypeMessage: 配送消费托盘广播 开始 msg={}",msg);
 		if(StringUtil.isNotBlank(msg)){
@@ -66,7 +66,7 @@ public class WarehouseTrayAllocationListener {
 		value = @Queue(name = FanoutConstants.warehouse.ALLOCATION.QUEUE.ALLOCATION_MESSAGE),
 		exchange = @Exchange(name = FanoutConstants.warehouse.ALLOCATION.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void allocationMessage(String msg) {
 		log.info("##########allocationMessage: 配送消费库位广播 开始 msg={}", msg);
 		if(StringUtil.isNotBlank(msg)){

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/BillPlanReportListener.java

@@ -56,7 +56,7 @@ public class BillPlanReportListener {
 		value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillPlan.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillPlan.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getBillPlanReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/BillReViewReportListener.java

@@ -53,7 +53,7 @@ public class BillReViewReportListener {
 		value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSignReview.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillSignReview.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getBillReviewReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/BillSignforReportListener.java

@@ -53,7 +53,7 @@ public class BillSignforReportListener {
 		value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSign.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillSign.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getBillSignforReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/CarStartReportListener.java

@@ -47,7 +47,7 @@ public class CarStartReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndCarStart.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndCarStart.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getCarStartReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/ConsigneeArriveReportListener.java

@@ -47,7 +47,7 @@ public class ConsigneeArriveReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndConsigneeArrive.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndConsigneeArrive.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getConsigneeArriveReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/DeliverFinishReportListener.java

@@ -79,7 +79,7 @@ public class DeliverFinishReportListener {
 		value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillAndFinish.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillAndFinish.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildPickUpReport(String msg) {
 		this.buildReport(msg);
 
@@ -89,7 +89,7 @@ public class DeliverFinishReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndFinish.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndFinish.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getDeliverFinishReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/LoadingReportListener.java

@@ -53,7 +53,7 @@ public class LoadingReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndLoading.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndLoading.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getLoadingReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/PlanReportListener.java

@@ -61,7 +61,7 @@ public class PlanReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndPlan.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndPlan.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getLoadingReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/ReViewReportListener.java

@@ -53,7 +53,7 @@ public class ReViewReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndrecheck.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndrecheck.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getReViewReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/ReservationPlanReportListener.java

@@ -56,7 +56,7 @@ public class ReservationPlanReportListener {
 		value = @Queue(name = FanoutConstants.reservation.OwnReservation.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.reservation.OwnReservation.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) throws InterruptedException {
 		if (!destinationProperties.getReport().getReservationPlanReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/ReturnWarehouseReportListener.java

@@ -53,7 +53,7 @@ public class ReturnWarehouseReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndReturnWarehouse.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndReturnWarehouse.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getReturnWarehouseReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/SignforReportListener.java

@@ -54,7 +54,7 @@ public class SignforReportListener {
 		value = @Queue(name = FanoutConstants.distribution.DeliveryAndSignfor.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.DeliveryAndSignfor.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getSignforReport()) {
 			return;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/StockReportListener.java

@@ -54,7 +54,7 @@ public class StockReportListener {
 		value = @Queue(name = FanoutConstants.distribution.stock.QUEUE.REPORT, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.distribution.stock.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void buildReport(String msg) {
 		if (!destinationProperties.getReport().getStockReport()) {
 			return;

blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/FactoryOrderListener.java

@@ -52,7 +52,7 @@ public class FactoryOrderListener {
 		exchange = @Exchange(name = FactoryDataConstants.Mq.Exchanges.FACTORY_ORDER, type = ExchangeTypes.TOPIC),
 		key = FactoryDataConstants.Mq.RoutingKeys.OLO_FACTORY_ORDER
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void factoryOrder(String msg) {
 		log.info("处理我乐订单：{}", msg);
 		if (StrUtil.isEmpty(msg)) {

blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/NodeDataPushListener.java

@@ -63,7 +63,7 @@ public class NodeDataPushListener {
 		exchange = @Exchange(name = FactoryDataConstants.Mq.Exchanges.NODE_DATA_PUSH, type = ExchangeTypes.TOPIC),
 		key = FactoryDataConstants.Mq.RoutingKeys.OLO_NODE_DATA_PUSH
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void nodeDataPush(String msg) {
 		log.info("接收到节点数据推送：{}", msg);
 		if (checkData(msg)) {

blade-service/logpm-factory-data/logpm-factory-data-suofeiya/src/main/java/com/logpm/factorydata/suofeiya/mq/FactoryOrderListener.java

@@ -56,7 +56,7 @@ public class FactoryOrderListener {
 		exchange = @Exchange(name = FactoryDataConstants.Mq.Exchanges.FACTORY_ORDER, type = ExchangeTypes.TOPIC),
 		key = FactoryDataConstants.Mq.RoutingKeys.SFY_FACTORY_ORDER
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void factoryOrder(String msg) {
 		log.info("处理索菲亚订单：{}", msg);
 		if (StrUtil.isEmpty(msg)) {

blade-service/logpm-factory-data/logpm-factory-data-suofeiya/src/main/java/com/logpm/factorydata/suofeiya/mq/NodeDataPushListener.java

@@ -49,7 +49,7 @@ public class NodeDataPushListener {
 		exchange = @Exchange(name = FactoryDataConstants.Mq.Exchanges.NODE_DATA_PUSH, type = ExchangeTypes.TOPIC),
 		key = FactoryDataConstants.Mq.RoutingKeys.SFY_NODE_DATA_PUSH
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void nodeDataPush(String msg) {
 		log.info("接收到节点数据推送：{}", msg);
 		if (checkData(msg)) {

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/receiver/OldTrayTypeListener.java

@@ -36,7 +36,7 @@ public class OldTrayTypeListener {
 		exchange = @Exchange(name = RabbitConstant.OLD_TRAY_TYPE_EXCHANGE, type = ExchangeTypes.DIRECT),
 		key = RabbitConstant.OLD_TRAY_TYPE_ROUTING
 	))
-	@Transactional(rollbackFor = Exception.class)
+//	@Transactional(rollbackFor = Exception.class)
 	public void oldTrayTypeInfo(String msg) {
 
 		JSONObject jsonObject = JSONUtil.parseObj(msg);