From 3d4803829f303bcfcc91ae12d7a13c255541fdec Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Wed, 11 Dec 2024 09:50:38 +0800 Subject: [PATCH 1/4] =?UTF-8?q?feat(all):=20=E6=89=93=E5=8D=B0=E6=A8=A1?= =?UTF-8?q?=E7=89=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1 删除多余 --- .../logpm/basic/service/impl/BasicPrintTemplateServiceImpl.java | 1 - 1 file changed, 1 deletion(-) diff --git a/blade-service/logpm-basic/src/main/java/com/logpm/basic/service/impl/BasicPrintTemplateServiceImpl.java b/blade-service/logpm-basic/src/main/java/com/logpm/basic/service/impl/BasicPrintTemplateServiceImpl.java index f5cf496fc..4938e9970 100644 --- a/blade-service/logpm-basic/src/main/java/com/logpm/basic/service/impl/BasicPrintTemplateServiceImpl.java +++ b/blade-service/logpm-basic/src/main/java/com/logpm/basic/service/impl/BasicPrintTemplateServiceImpl.java @@ -27,7 +27,6 @@ import com.logpm.basic.service.IBasicPrintTemplateService; import com.logpm.basic.vo.BasicPrintTemplateVO; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.apache.calcite.schema.Function; import org.springblade.core.mp.base.BaseServiceImpl; import org.springblade.core.secure.BladeUser; import org.springblade.core.secure.utils.AuthUtil; From 84816b6c8af015168d36625983b2fa3a5506ca40 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Wed, 11 Dec 2024 11:58:01 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E9=A2=84=E7=BA=A6=E8=AF=A6=E6=83=85BUG?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml index e0415239d..8189c522f 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml @@ -623,7 +623,7 @@ LEFT JOIN logpm_distribution_parcel_list AS ldpl ON ldrp.parce_list_id = ldpl.id AND ldpl.order_package_status != 70 ldr.is_deleted = 0 - AND DATE_FORMAT( ldrp.create_time, "%y%m" ) = DATE_FORMAT( now(), "%y%m" ) + AND DATE_FORMAT( ldr.create_time, "%y%m" ) = DATE_FORMAT( now(), "%y%m" ) AND ldpl.warehouse_id = #{warehouseId} ) + (SELECT From 1925cd5b94b03bccd2f1c3ebcae3841ea57cc80b Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 11 Dec 2024 15:23:56 +0800 Subject: [PATCH 3/4] =?UTF-8?q?1.=E5=AF=B9=E6=8E=A5=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E7=9C=8B=E6=9D=BF=202.=E5=A2=9E=E5=8A=A0=E9=A6=96=E9=A1=B5?= =?UTF-8?q?=E5=85=AC=E5=91=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../vo/DistributionSignforVO.java | 5 ++ .../com/logpm/trunkline/dto/LoadCarsDTO.java | 5 ++ .../trunkline/vo/CarsLoadAllOrderVO.java | 5 ++ .../controller/BasicNoticeController.java | 22 ++++-- .../mapper/DistributionSignforMapper.xml | 6 +- .../mapper/DistributionStockArticleMapper.xml | 7 +- .../impl/DistributionSignforServiceImpl.java | 41 +---------- .../controller/WarehouseIndexController.java | 4 +- .../report/mapper/WarehouseIndexMapper.java | 4 +- .../report/mapper/WarehouseIndexMapper.xml | 10 +-- .../service/IWarehouseIndexService.java | 2 +- .../impl/WarehouseIndexServiceImpl.java | 68 +++++++++++-------- .../vo/IndexTrunklineHandOrderDataVO.java | 24 +++++++ .../mapper/TrunklineCarsLoadMapper.xml | 6 +- .../mq/waybil/StatusLogListener.java | 10 +-- 15 files changed, 124 insertions(+), 95 deletions(-) diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionSignforVO.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionSignforVO.java index 5801766a7..2f6ed1e13 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionSignforVO.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionSignforVO.java @@ -352,6 +352,11 @@ public class DistributionSignforVO extends DistributionSignforEntity { @ApiModelProperty(value = "客户订单列表") private List orderInfo; + /** + * 是否超时 + */ + private Integer isTimeOut; + } diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java index 9a285d546..6be39b08f 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java @@ -215,6 +215,11 @@ public class LoadCarsDTO implements Serializable { private String createTime; private String ids; + /** + * 是否超时 + */ + private Integer isTimeOut; + /** * 商场联系人 */ diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadAllOrderVO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadAllOrderVO.java index 3b7129886..2551d5bdf 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadAllOrderVO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/CarsLoadAllOrderVO.java @@ -44,4 +44,9 @@ public class CarsLoadAllOrderVO implements Serializable { private Date warehouseEntryTimeEnd;//入库时间 private Date warehouseEntryTimeStart;//入库时间 + /** + * 是否超时 + */ + private Integer isTimeOut; + } diff --git a/blade-service/logpm-basic/src/main/java/com/logpm/basic/controller/BasicNoticeController.java b/blade-service/logpm-basic/src/main/java/com/logpm/basic/controller/BasicNoticeController.java index 9a9b9e2b3..c91042af4 100644 --- a/blade-service/logpm-basic/src/main/java/com/logpm/basic/controller/BasicNoticeController.java +++ b/blade-service/logpm-basic/src/main/java/com/logpm/basic/controller/BasicNoticeController.java @@ -37,6 +37,8 @@ import org.springblade.core.tool.utils.Func; import org.springframework.web.bind.annotation.*; import springfox.documentation.annotations.ApiIgnore; +import java.util.ArrayList; +import java.util.List; import java.util.Map; /** @@ -80,21 +82,29 @@ public class BasicNoticeController extends BladeController { return R.data(BasicNoticeWrapper.build().pageVO(pages)); } + + /** - * 多表联合查询自定义分页 + * 分页 */ - @GetMapping("/page") + @GetMapping("/homeList") @ApiImplicitParams({ @ApiImplicitParam(name = "category", value = "公告类型", paramType = "query", dataType = "integer"), @ApiImplicitParam(name = "title", value = "公告标题", paramType = "query", dataType = "string") }) - @ApiOperationSupport(order = 3) + @ApiOperationSupport(order = 2) @ApiOperation(value = "分页", notes = "传入notice") - public R> page(@ApiIgnore BasicNoticeVO notice, Query query) { - IPage pages = noticeService.selectNoticePage(Condition.getPage(query), notice); - return R.data(pages); + public R> list() { + List list = noticeService.list(); + List data = new ArrayList<>(); + for (BasicNotice notice : list) { + BasicNoticeVO vo = BasicNoticeWrapper.build().entityVO(notice); + data.add(vo); + } + return R.data(data); } + /** * 新增 */ diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml index d2f881f82..2a2f2def0 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionSignforMapper.xml @@ -410,7 +410,8 @@ lddl.id AND lddt.is_deleted = 0) ELSE '' - END driverPhone + END driverPhone, + if( NOW() > DATE_ADD(lds.create_time, INTERVAL 24 HOUR), 1,0) isTimeOut FROM logpm_distribution_signfor lds JOIN logpm_distribution_delivery_list lddl ON lddl.id = lds.delivery_id AND lddl.is_deleted = 0 AND lddl.customers_number > 0 @@ -503,6 +504,9 @@ and lds.signing_time between #{param.signingTimeSection[0]} and #{param.signingTimeSection[1]} + + and (NOW() > DATE_ADD(lds.create_time, INTERVAL 24 HOUR))= ${param.isTimeOut} + and ldr.mall_id in diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml index 1e28804f1..7be29345a 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml @@ -2095,7 +2095,8 @@ GROUP_CONCAT( DISTINCT ldpl.dealer_name ), lww.create_time openTime, IFNULL(sum(ldpl.weight),0) weight, - IFNULL(sum(ldpl.volume),0) volume + IFNULL(sum(ldpl.volume),0) volume, + if( NOW() > DATE_ADD(ldsa.warehouse_entry_time, INTERVAL 48 HOUR), 1,0) isTimeOut from logpm_distribution_stock_article ldsa LEFT JOIN logpm_distribution_parcel_list ldpl on ldsa.id = ldpl.stock_article_id left join logpm_warehouse_waybill lww on lww.waybill_no = ldpl.waybill_number @@ -2239,6 +2240,10 @@ and lww.create_time <= #{param.openTimeEnd} + + + and (NOW() > DATE_ADD(ldsa.warehouse_entry_time, INTERVAL 48 HOUR))= ${param.isTimeOut} + group by ldpl.order_code,ldpl.waybill_number HAVING sum(ldpl.is_transfer) > 0 diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index 762a75099..ed863b25f 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -293,17 +293,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl myWatchWarehouse = basicdataWarehouseClient.getMyWatchWarehouse(); - List collect = myWatchWarehouse.stream().map(BasicdataWarehouseEntity::getId).collect(Collectors.toList()); - distributionSignfor.setWarehouseIdList(collect); - } else { - List collect = new ArrayList<>(); - collect.add(myCurrentWarehouse.getId()); - distributionSignfor.setWarehouseIdList(collect); - } + List collect = basicdataWarehouseClient.getWarehouseIds(); + distributionSignfor.setWarehouseIdList(collect); List distributionSignforVOS; @@ -326,26 +317,6 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl distributionSignforVOS, List reservationIds) { -// List distributionParcelListEntities = distributionReservationMapper.selectPackageListByReservationIds(reservationIds); -//// List list = disStockListDetailService.list(Wrappers.query().lambda() -//// .in(DisStockListDetailEntity::getReservationId, reservationIds) -//// .ne(DisStockListDetailEntity::getStockPackageStatus, ReservationPackageStatusConstant.quxiao.getValue()) -//// ); -// List reservationZeroPackageEntities = distributionReservationZeroPackageService.list(Wrappers.query().lambda() -// .in(DistributionReservationZeroPackageEntity::getReservationId, reservationIds) -// .ne(DistributionReservationZeroPackageEntity::getZeroPackageStatus, ReservationPackageStatusConstant.quxiao.getValue()) -// ); -// -// List inventoryList = disStockListDetailService.list(Wrappers.query().lambda() -// .in(DisStockListDetailEntity::getReservationId,reservationIds) -// .ne(DisStockListDetailEntity::getStockPackageStatus,ReservationPackageStatusConstant.quxiao.getValue()) -// ); - - -// Map> packageMap = distributionParcelListEntities.stream().collect(Collectors.groupingBy(DistributionParcelListVO::getReservationId)); -// Map> inventoryMap = list.stream().collect(Collectors.groupingBy(DisStockListDetailEntity::getReservationId)); -// Map> zeroPackageMap = reservationZeroPackageEntities.stream().collect(Collectors.groupingBy(DistributionReservationZeroPackageEntity::getReservationId)); - distributionSignforVOS.forEach(d -> { d.setDeliveryTypeName(getDeliveryTypeName(d.getDeliveryType())); @@ -363,14 +334,6 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl> packageMap, Map> zeroPackageMap, DistributionSignforVO d) { -// -// int fromParcelList = packageMap.getOrDefault(d.getReservationId(), Collections.emptyList()).stream().filter(f -> !f.getOrderPackageStatus().equals(OrderPackageStatusConstant.yiqianshou.getValue())).mapToInt(DistributionParcelListVO::getQuantity).sum(); -// int fromZeroPackage = calculateWeiqianshouFromZeroPackage(zeroPackageMap, d); -// -// return fromParcelList + fromZeroPackage; -// } - private int calculateWeiqianshouFromZeroPackage(Map> zeroPackageMap, DistributionSignforVO d) { if (!zeroPackageMap.containsKey(d.getReservationId())) { return 0; diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/controller/WarehouseIndexController.java b/blade-service/logpm-report/src/main/java/com/logpm/report/controller/WarehouseIndexController.java index 252a0ef31..35654ce76 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/controller/WarehouseIndexController.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/controller/WarehouseIndexController.java @@ -213,8 +213,8 @@ public class WarehouseIndexController { indexDTO.setWarehouseIds(warehouseIds); //查询订制品打托列表 - IndexTrunklineHandOrderDataVO indexTrunklineHandOrderDataVO = warehouseIndexService.trunklineHandOrderData(indexDTO); - return R.data(indexTrunklineHandOrderDataVO); + List indexTrunklineHandOrderDataVOs = warehouseIndexService.trunklineHandOrderData(indexDTO); + return R.data(indexTrunklineHandOrderDataVOs); } catch (CustomerException e) { log.warn(e.message); return R.fail(e.code, e.message); diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.java b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.java index 676ad0526..801b66f4f 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.java @@ -40,9 +40,9 @@ public interface WarehouseIndexMapper { Integer findUpshelfNum(@Param("param") IndexDTO indexDTO); - JSONObject findPackageTrunklineHandOrderData(@Param("param") IndexDTO indexDTO); + JSONObject findPackageTrunklineHandOrderData(@Param("warehouseId") Long warehouseId); - JSONObject findZeroTrunklineHandOrderData(@Param("param") IndexDTO indexDTO); + JSONObject findZeroTrunklineHandOrderData(@Param("warehouseId") Long warehouseId); IndexTrunklineCarsDataVO trunklineCarsData(@Param("param") IndexDTO indexDTO); diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml index 8189c522f..b7cea47af 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/WarehouseIndexMapper.xml @@ -147,10 +147,7 @@ where 1=1 and ldpl.order_package_code != null and ldpl.order_package_status = '20' - and ldpl.warehouse_id in - - #{item} - + and ldpl.warehouse_id =#{warehouseId} diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java index 0bbad530c..556208252 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java @@ -36,7 +36,8 @@ import java.util.stream.Collectors; @AllArgsConstructor public class StatusLogListener { - private final ITrunklineWaybillTrackClient trunklineWaybillTrackClient ; +// private final ITrunklineWaybillTrackClient trunklineWaybillTrackClient ; + private final ITrunklineWaybillTrackService trunklineWaybillTrackService; @RabbitListener(bindings = @QueueBinding( value = @Queue(name = FanoutConstants.DeliveryOfPickup.BillSignReview.QUEUE.waybillStatusLog, durable = "true"), @@ -93,7 +94,8 @@ public class StatusLogListener { t.setType(3); - trunklineWaybillTrackClient.addSignWaybillLog(t); +// trunklineWaybillTrackClient.addSignWaybillLog(t); + trunklineWaybillTrackService.addSignWaybillLog(t); } @@ -157,8 +159,8 @@ public class StatusLogListener { t.setNum(waybillCountMap.get(waybillNumber)); t.setSignOrderCode(vo.getReservationCode()); t.setType(3); - trunklineWaybillTrackClient.addSignWaybillLog(t); - +// trunklineWaybillTrackClient.addSignWaybillLog(t); + trunklineWaybillTrackService.addSignWaybillLog(t); } } From c380b90c16092d2eca6816e98f863459f64f30ef Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 11 Dec 2024 15:59:09 +0800 Subject: [PATCH 4/4] =?UTF-8?q?1.=E5=8F=96=E6=B6=88=E7=BB=93=E7=AE=97?= =?UTF-8?q?=E4=BA=8B=E7=89=A9=20=E8=AE=A9=E5=AE=A1=E6=A0=B8=E8=83=BD?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E4=B8=8B=E5=8E=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logpm/statistics/listener/mq/PackageFanoutListener.java | 1 - .../statistics/listener/mq/WaybillCancleCheckListener.java | 1 - .../com/logpm/statistics/listener/mq/WaybillCheckListener.java | 3 --- .../java/com/logpm/trunkline/mq/waybil/StatusLogListener.java | 1 - 4 files changed, 6 deletions(-) diff --git a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java index 80694dcd7..f2def8cd0 100644 --- a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java +++ b/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"); diff --git a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCancleCheckListener.java b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCancleCheckListener.java index d796428fd..f168c972b 100644 --- a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCancleCheckListener.java +++ b/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); diff --git a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCheckListener.java b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCheckListener.java index 89ce13f63..ca03ccecf 100644 --- a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillCheckListener.java +++ b/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); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java index 556208252..d77fd3a88 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/waybil/StatusLogListener.java +++ b/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);