1.取消结算事物 让审核能进行下去

blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java

@@ -47,7 +47,6 @@ public class PackageFanoutListener {
 		value = @Queue(name = FanoutConstants.trunkline.PACKAGNODE.QUEUE.PACKAGE_SIGN),
 		exchange = @Exchange(name = FanoutConstants.trunkline.PACKAGNODE.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
 	public void packageSignFanout(String msg) {
 		JSONObject jsonObject = JSONUtil.parseObj(msg);
 		JSONObject trainNumberMap = jsonObject.getJSONObject("mainMap");

blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCancleCheckListener.java

@@ -36,7 +36,6 @@ public class WaybillCancleCheckListener {
 		value = @Queue(name = FanoutConstants.trunkline.CANCLECHECKWAYBILL.QUEUE.CANCLECHECKWAYBILL_INCOMINGDATA),
 		exchange = @Exchange(name = FanoutConstants.trunkline.CANCLECHECKWAYBILL.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
 	public void cancleCheckWaybillIncomingData(String msg) {
 		log.info("#########cancleCheckWaybillIncomingData: 运单取消审核处理收入结算数据 开始 msg={}",msg);
 		JSONObject jsonObject = JSONUtil.parseObj(msg);

blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCheckListener.java

@@ -42,9 +42,7 @@ import java.util.stream.Collectors;
 @AllArgsConstructor
 public class WaybillCheckListener {
 
-	private final IBasicdataWarehouseClient basicdataWarehouseClient;
 	private final IWarehouseWaybillClient warehouseWaybillClient;
-	private final ITrunklineWaybillOrderClient trunklineWaybillOrderClient;
 	private final ITrunklineAdvanceClient trunklineAdvanceClient;
 	private final ITrunklineAdvanceDetailClient trunklineAdvanceDetailClient;
 	private final IStatisticsOrderInfoService statisticsOrderInfoService;
@@ -59,7 +57,6 @@ public class WaybillCheckListener {
 		value = @Queue(name = FanoutConstants.trunkline.CHECKWAYBILL.QUEUE.CHECKWAYBILL_INCOMINGDATA),
 		exchange = @Exchange(name = FanoutConstants.trunkline.CHECKWAYBILL.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
 	public void checkWaybillIncomingData(String msg) {
 		try{
 			log.info("#########checkWaybillIncomingData: 运单审核处理收入结算数据 msg={}", msg);

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java

@@ -43,7 +43,6 @@ public class StatusLogListener {
 		value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSignReview.QUEUE.waybillStatusLog, durable = "true"),
 		exchange = @Exchange(name = FanoutConstants.DeliveryOfPickup.BillSignReview.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
-	@Transactional(rollbackFor = Exception.class)
 	public void statusPickUpLog(String msg) {
 
 		log.info("自提复核处理运单日志和状态: {}", msg);