From 54ea1445b408b7e530d2af0f45cf3219a195a816 Mon Sep 17 00:00:00 2001 From: Diss <1157651603@qq.com> Date: Mon, 8 Jan 2024 16:40:46 +0800 Subject: [PATCH] =?UTF-8?q?2024=E5=B9=B41=E6=9C=888=E6=97=A515:59:43=201.?= =?UTF-8?q?=E4=B8=80=E9=94=AE=E7=AD=BE=E6=94=B6=E6=97=B6=E5=80=99=E6=AC=A7?= =?UTF-8?q?=E6=B4=BE=E6=95=B0=E6=8D=AE=E6=8E=A8=E9=80=81=202.=E6=9C=BA?= =?UTF-8?q?=E5=99=A8=E7=AD=BE=E6=94=B6=E6=97=B6=E7=9A=84=E6=AC=A7=E6=B4=BE?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=8E=A8=E9=80=81=20=E8=8E=B7=E5=8F=96?= =?UTF-8?q?=E6=93=8D=E4=BD=9C=E4=BA=BA=E8=BF=98=E6=9C=89=E7=82=B9=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../oupai/feign/IOuPaiFactoryClinet.java | 13 ++- .../impl/DistributionAsyncServiceImpl.java | 49 +++++++--- .../impl/DistributionSignforServiceImpl.java | 90 +++++++++---------- .../oupai/feign/OuPaiFactoryClinet.java | 34 +++++-- .../service/impl/OuPaiFactoryServiceImpl.java | 40 +++++---- .../receiver/NewSystemReceiveInfoHandler.java | 7 +- 6 files changed, 146 insertions(+), 87 deletions(-) diff --git a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/feign/IOuPaiFactoryClinet.java b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/feign/IOuPaiFactoryClinet.java index 0fc16179d..261c3d971 100644 --- a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/feign/IOuPaiFactoryClinet.java +++ b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/feign/IOuPaiFactoryClinet.java @@ -1,14 +1,16 @@ package com.logpm.factory.oupai.feign; +import com.fasterxml.jackson.core.JsonProcessingException; import com.logpm.factory.comfac.dto.OrderStatusDTO; import org.springblade.common.constant.ModuleNameConstant; import org.springblade.core.tool.api.R; import org.springframework.cloud.openfeign.FeignClient; -import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestParam; +import java.security.NoSuchAlgorithmException; + /* * logisticsplatform-service * @Author Diss @@ -20,11 +22,16 @@ import org.springframework.web.bind.annotation.RequestParam; public interface IOuPaiFactoryClinet { String API_PREFIX = "/oupai/client"; String TOP = API_PREFIX + "/newSystemHandleStatusData"; - String TEST = API_PREFIX + "/test"; + String NEWSYSTEMHANDLESTATUSDATASIGNFORONE = API_PREFIX + "/newSystemHandleStatusDataSignforOne"; @PostMapping(TOP) R newSystemHandleStatusData(@RequestBody OrderStatusDTO orderStatusDTO); - + @PostMapping(NEWSYSTEMHANDLESTATUSDATASIGNFORONE) + R newSystemHandleStatusDataSignforOne(@RequestParam String status, // 状态 + @RequestParam String unitNo, //包条码 + @RequestParam String operationTime, // 签收时间 + @RequestParam String username) //签收人 + throws NoSuchAlgorithmException, JsonProcessingException; } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java index 4d04bf02b..907571217 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionAsyncServiceImpl.java @@ -46,7 +46,10 @@ import org.springblade.common.constant.stockup.StockupStatusConstant; import org.springblade.common.constant.stockup.StockupTypeConstant; import org.springblade.common.exception.CustomerException; import org.springblade.core.log.exception.ServiceException; +import org.springblade.core.mp.support.Condition; import org.springblade.core.tool.utils.Func; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Lazy; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; @@ -100,6 +103,9 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService { private final IDistrilbutionBillPackageService billPackageService; private final IDistributionReservationZeroPackageService zeroPackageService; +// private DistributionReservationMapper reservationService; + private final DistributionSignforMapper distributionSignforService; + @Override @Async @Transactional(isolation = Isolation.READ_UNCOMMITTED, rollbackFor = Exception.class) @@ -1453,6 +1459,19 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService { } catch (Exception e) { throw new RuntimeException(e); } + case "欧派": + //推送到欧派 + try { + DistributionReservationStockarticleEntity distributionReservationStockarticleEntity = distributionReservationStockarticleService.getOne(Wrappers.query().lambda() + .eq(DistributionReservationStockarticleEntity::getStockArticleId, distributionParcelListEntity.getStockArticleId())); + DistributionSignforEntity distributionSignfor = distributionSignforService.getByReservationId(distributionReservationStockarticleEntity.getReservationId()); + ouPaiFactoryClinet.newSystemHandleStatusDataSignforOne("7",distributionParcelListEntity.getOrderPackageCode(), signingTime, + distributionSignfor.getSigneeName() );//*签收人*// + log.info(">>>>>>>>>>>>>>>>>>>>>>>> 签收推送 欧派:{} {} {} {}", "7",distributionParcelListEntity.getOrderPackageCode(), signingTime, + distributionSignfor.getSigneeName() ); + } catch (Exception e) { + throw new RuntimeException(e); + } break; //其他..... } @@ -1465,7 +1484,7 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService { @Async public void sendReviewFactory(Long signingId, String warehouseName, Long warehouseId) { String brands = "梦天,欧派";//可追加 - + log.info(">>>>>>>>>>> 签收推送 对象tmy {}", "signingId="+signingId+"warehouseName="+warehouseName+"warehouseId="+warehouseId); //查询签收信息 DistributionSignforEntity distributionSignforEntity = distributionSignforMapper.selectById(signingId); if (Func.isNotEmpty(distributionSignforEntity)) { @@ -1535,21 +1554,23 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService { for (DistributionReservationStockarticleEntity distributionReservationStockarticleEntity : distributionReservationStockarticleEntities) { // 查询预约单下面的包间信息 - + log.info(">>>>>>>>>>>>>>>>>>>>> 欧派循环包件信息 {} ", distributionReservationStockarticleEntity); List distributionParcelListEntities = buildOpByReservationId(distributionReservationStockarticleEntity); for (DistributionParcelListEntity distributionParcelListEntity : distributionParcelListEntities) { - - - - OrderStatusDTO orderStatusDTO = new OrderStatusDTO(); - orderStatusDTO.setUnitNo(distributionParcelListEntity.getOrderPackageCode()); + log.info(">>>>>>>>>>>>>>>>>>>>>>>>>distributionParcelListEntities: {}",distributionParcelListEntities); + log.info(">>>>>>>>>>>>>>>>>>>>>>>>>distributionParcelListEntity: {}",distributionParcelListEntity); // todo 查询签收信息 - orderStatusDTO.setUsername("111"); + DistributionSignforEntity distributionSignfor = distributionSignforService.getByReservationId(distributionReservationStockarticleEntity.getReservationId()); + OrderStatusDTO orderStatusDTO = new OrderStatusDTO(); + orderStatusDTO.setUnitNo(distributionParcelListEntity.getOrderPackageCode()); //单号 + orderStatusDTO.setUsername(distributionSignfor.getSigneeName()); //操作人名称 orderStatusDTO.setStatus("7"); -// orderStatusDTO.setOperationTime(); + orderStatusDTO.setOperationTime(distributionSignfor.getSigningTime()); //时间 + System.out.println(orderStatusDTO); ouPaiFactoryClinet.newSystemHandleStatusData(orderStatusDTO); + } @@ -1570,17 +1591,17 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService { } - + //TODO 需要测试 /** * 根据预约单查询预约单下面的订单下面的包件 * 并且状态为已签收的包件 * @param distributionReservationStockarticleEntity - * @return + * @return List */ private List buildOpByReservationId(DistributionReservationStockarticleEntity distributionReservationStockarticleEntity) { - - // - return null; + Long stockArticleId = distributionReservationStockarticleEntity.getStockArticleId();//订单id + List distributionParcelListEntities = distributionParcelListService.getParcelListByStockArticleId(stockArticleId); + return distributionParcelListEntities; } @Override 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 4bfb0e5df..bfaff1eaf 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 @@ -1051,31 +1051,31 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl mapState = new HashMap<>(); - mapState.put("orderStatusDTO", orderStatusDTO); - mapState.put("brand", brand); + //TODO 在调用出库接口 通知欧派 准备删除 +// +// DistributionSignforEntity distributionSignforEntity = distributionSignforMapper.getByReservationId(distrilbutionloadingscanDTO.getReservationId()); +// +//// Long reservationId = distributionSignfor.getReservationId(); +//// DistributionSignforEntity distributionSignforEntity1 = distributionSignforMapper.getByReservationId(reservationId); +// +// BladeUser user = AuthUtil.getUser(); +// OrderStatusDTO orderStatusDTO = new OrderStatusDTO(); +// orderStatusDTO.setStatus("7");//状态 +// orderStatusDTO.setOperationTime(simpleDateFormat.format(new Date()));//操作时间 +// //orderStatusDTO.setUsername(distributionSignforEntity.getSigneeName()); //签收人(名称) +// orderStatusDTO.setUsername(user.getUserName()); //签收人(名称) +// orderStatusDTO.setUnitNo(distrilbutionloadingscanDTO.getBarcode()); //包条码 +// orderStatusDTO.setCurrentWarehouse(String.valueOf(myCurrentWarehouse.getWarehouseCode())); //当前仓库ID +// +// DistributionStockArticleEntity distributionStockArticle = new DistributionStockArticleEntity(); +// Long stockArticleId = parcelListEntity.getStockArticleId(); +// distributionStockArticle.setId(stockArticleId); // 需要一个stock_article_id` bigint(20) DEFAULT NULL COMMENT '在库订单ID', +// DistributionStockArticleEntity distributionStockArticleEntity = distributionStockArticleService.getOne(Condition.getQueryWrapper(distributionStockArticle)); +// String brand = distributionStockArticleEntity.getBrand(); +// +// Map mapState = new HashMap<>(); +// mapState.put("orderStatusDTO", orderStatusDTO); +// mapState.put("brand", brand); // rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_QUEUE, mapState); return Resp.scanSuccess("签收成功", str); @@ -2707,26 +2707,26 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl mapState = new HashMap<>(); - mapState.put("orderStatusDTO", orderStatusDTO); - mapState.put("brand", brand); - //rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_QUEUE, mapState); - rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_EXCHANGE, RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_ROUTING, mapState); - System.out.println("发送消息成功"); - } +// for (DistributionParcelListEntity distributionParcelListEntity : parcelListEntityList) { +// //根据ID获取品牌 +// DistributionStockArticleEntity distributionStockArticle = new DistributionStockArticleEntity(); +// distributionStockArticle.setId(distributionParcelListEntity.getStockArticleId()); +// DistributionStockArticleEntity distributionStockArticleEntity = distributionStockArticleService.getOne(Condition.getQueryWrapper(distributionStockArticle)); +// String brand = distributionStockArticleEntity.getBrand(); //获取品牌 +// +// OrderStatusDTO orderStatusDTO = new OrderStatusDTO(); +// orderStatusDTO.setStatus("7");//状态 +// orderStatusDTO.setOperationTime(simpleDateFormat.format(new Date()));//操作时间 +// orderStatusDTO.setUsername(user.getUserName()); //签收人(名称) +// orderStatusDTO.setUnitNo(distributionParcelListEntity.getOrderPackageCode()); //包条码 +// orderStatusDTO.setCurrentWarehouse(String.valueOf(distributionParcelListEntity.getWarehouseId())); //当前仓库ID +// Map mapState = new HashMap<>(); +// mapState.put("orderStatusDTO", orderStatusDTO); +// mapState.put("brand", brand); +// //rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_QUEUE, mapState); +// rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_EXCHANGE, RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_ROUTING, mapState); +// System.out.println("发送消息成功"); +// } //维护客户信息状态 diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/feign/OuPaiFactoryClinet.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/feign/OuPaiFactoryClinet.java index 1e996bc18..bbfd67be8 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/feign/OuPaiFactoryClinet.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/feign/OuPaiFactoryClinet.java @@ -1,18 +1,23 @@ package com.logpm.factory.oupai.feign; import com.alibaba.fastjson.JSONObject; +import com.fasterxml.jackson.core.JsonProcessingException; import com.logpm.factory.comfac.dto.OrderStatusDTO; import com.logpm.factory.oupai.service.IOuPaiFactoryService; import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.RabbitConstant; import org.springblade.core.tenant.annotation.NonDS; import org.springblade.core.tool.api.R; +import org.springblade.core.tool.utils.DateUtil; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RestController; import springfox.documentation.annotations.ApiIgnore; +import java.security.NoSuchAlgorithmException; +import java.util.Date; import java.util.HashMap; import java.util.Map; @@ -25,6 +30,7 @@ import java.util.Map; @ApiIgnore @RestController @AllArgsConstructor +@Slf4j public class OuPaiFactoryClinet implements IOuPaiFactoryClinet{ @Autowired @@ -36,22 +42,40 @@ public class OuPaiFactoryClinet implements IOuPaiFactoryClinet{ @PostMapping(TOP) public R newSystemHandleStatusData(OrderStatusDTO orderStatusDTO) { - - Map map = new HashMap(); - + log.info(">>>>>>> 文员复核 start"); + Map map = new HashMap<>(); String json = JSONObject.toJSONString(orderStatusDTO); map.put("messageData",json); - rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_EXCHANGE, RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_ROUTING, map,message -> { message.getMessageProperties() .setHeader("x-delay", 5000); return message; }); + log.info(">>>>>>>>>>>>>>>>> 文员复核 {}", DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss.SSS")); return R.success(""); -// return ouPaiFactoryService.newSystemHandleStatusData(orderStatusDTO); } + @Override + public R newSystemHandleStatusDataSignforOne(String status, String unitNo, String operationTime, String username) throws NoSuchAlgorithmException, JsonProcessingException { + log.info(">>>>>>> 签收扫描 start"); + Map map = new HashMap<>(); + + JSONObject jsonObject = new JSONObject(); + jsonObject.put("unitNo",unitNo); + jsonObject.put("operationTime",operationTime); + jsonObject.put("status",status); + jsonObject.put("username",username); + map.put("messageData",jsonObject.toJSONString()); + + rabbitTemplate.convertAndSend(RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_EXCHANGE, RabbitConstant.NEW_SYSTEM_RECEIVE_INFO_ROUTING, map,message -> { + message.getMessageProperties() + .setHeader("x-delay", 5000); + return message; + }); + log.info(">>>>>>>>>>>>>>>>> 司机扫描 {}", DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss.SSS")); + return R.success(""); + } } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryServiceImpl.java index dbbe68519..4319d4186 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryServiceImpl.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryServiceImpl.java @@ -547,6 +547,7 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService { @Override public R newSystemHandleStatusData(OrderStatusDTO orderStatusDTO) { + log.info("》》》》》》》》》》》》 newSystemHandleStatusData的DTO数据 查看是否到达方法{}", orderStatusDTO); // 推送数据 String status = orderStatusDTO.getStatus(); String unitNo = orderStatusDTO.getUnitNo(); @@ -557,29 +558,30 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService { return Resp.fail(400, "当前数据的状态不推送"); } - //继续判断是否到达目的仓 - String currentWarehouseId = orderStatusDTO.getCurrentWarehouse();//当前仓Id - //查询destinationWarehouse logiBillNo plantId数据 - log.info("oupai-handleStatusData >>> unitNo={}", unitNo); - R distributionParcelListEntity = distributionParcelListClient.queryOrderByOrderPackageCode(unitNo); - if (ObjectUtils.isEmpty(distributionParcelListEntity.getData())) { - return Resp.fail(400, "未查询到该单据信息"); - } - String destinationWarehouseId = String.valueOf(distributionParcelListEntity.getData().getAcceptWarehouseId());//目的仓id - if (StringUtil.isBlank(currentWarehouseId) || StringUtil.isBlank(destinationWarehouseId)) { - log.warn("##############oupai-handleStatusData: 仓库数据有问题currentWarehouseId={} destinationWarehouseId={}", currentWarehouseId, destinationWarehouseId); - return Resp.fail(400, "仓库数据有误"); - } - - if (!currentWarehouseId.equals(destinationWarehouseId)) { - log.info("##############oupai-handleStatusData: 不用处理的状态 currentWarehouseId={} destinationWarehouseId={}", currentWarehouseId, destinationWarehouseId); - return Resp.fail(400, "不是目的仓"); - } + //继续判断是否到达目的仓 // 不需要这个字段来判断了 +// String currentWarehouseId = orderStatusDTO.getCurrentWarehouse();//当前仓Id +// //查询destinationWarehouse logiBillNo plantId数据 +// log.info("oupai-handleStatusData >>> unitNo={}", unitNo); +// R distributionParcelListEntity = distributionParcelListClient.queryOrderByOrderPackageCode(unitNo); +// if (ObjectUtils.isEmpty(distributionParcelListEntity.getData())) { +// return Resp.fail(400, "未查询到该单据信息"); +// } +// String destinationWarehouseId = String.valueOf(distributionParcelListEntity.getData().getAcceptWarehouseId());//目的仓id +// if (StringUtil.isBlank(currentWarehouseId) || StringUtil.isBlank(destinationWarehouseId)) { +// log.warn("##############oupai-handleStatusData: 仓库数据有问题currentWarehouseId={} destinationWarehouseId={}", currentWarehouseId, destinationWarehouseId); +// return Resp.fail(400, "仓库数据有误"); +// } +// +// if (!currentWarehouseId.equals(destinationWarehouseId)) { +// log.info("##############oupai-handleStatusData: 不用处理的状态 currentWarehouseId={} destinationWarehouseId={}", currentWarehouseId, destinationWarehouseId); +// return Resp.fail(400, "不是目的仓"); +// } // 查询这个包件对应到新系统的订单 FactoryOrderEntity factoryOrder = factoryOrderService.selectEntityByOrderPackageCode(unitNo); if (Objects.isNull(factoryOrder)) { + log.info("》》》》》》》》》》》》 未查询到该单据推送订单信息", orderStatusDTO.getUnitNo()); return Resp.fail(400, "未查询到该单据推送订单信息"); } // 如何判断这个包间是非干仓配的数据 @@ -641,7 +643,7 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService { log.info(" >>>>>>>>>>>>>>>>>>>>>>> 包件 {} 已推送欧派 状态 {}", unitNo, detailObject.get("Operate")); } else { // 需要盘点这个对象的 - String resp = opPackagePushLogEntity.getResp(); + String resp = opPackagePushLogEntity.getResp(); // 转换为json // JSONObject respJson = JSONObject.parseObject(resp); log.info(" >>>>>>>>>>>>>>>>>>>>>>> 推送欧派返回数据 {}", resp); diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NewSystemReceiveInfoHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NewSystemReceiveInfoHandler.java index 6962d1798..3e321ea6c 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NewSystemReceiveInfoHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NewSystemReceiveInfoHandler.java @@ -5,6 +5,7 @@ package com.logpm.factory.receiver; * @Create 2024/1/4 17:41 */ +import com.alibaba.fastjson.JSON; import com.logpm.factory.comfac.constant.FactoryConstant; import com.logpm.factory.comfac.dto.OrderStatusDTO; import com.logpm.factory.oupai.service.IOuPaiFactoryService; @@ -33,11 +34,15 @@ public class NewSystemReceiveInfoHandler { @Autowired private IOuPaiFactoryService ouPaiFactoryService; + @RabbitHandler public void newSystemReceiveInfoHandler(Map map, Message message, Channel channel) throws IOException, NoSuchAlgorithmException { - + // 欧派的订单会进来进行推送 String json = (String) map.get("messageData"); + OrderStatusDTO orderStatusDTO = JSON.parseObject(json, OrderStatusDTO.class); log.info(">>>>>>>>>>>>> {}",json); + log.info("##################receiveInfoHandler：处理签收信息数据 {}",orderStatusDTO); + ouPaiFactoryService.newSystemHandleStatusData(orderStatusDTO); } }