diff --git a/blade-biz-common/src/main/java/org/springblade/common/constant/DistributionTypeConstant.java b/blade-biz-common/src/main/java/org/springblade/common/constant/DistributionTypeConstant.java index fd15d84a5..2c7035341 100644 --- a/blade-biz-common/src/main/java/org/springblade/common/constant/DistributionTypeConstant.java +++ b/blade-biz-common/src/main/java/org/springblade/common/constant/DistributionTypeConstant.java @@ -1,5 +1,7 @@ package org.springblade.common.constant; +import org.springblade.common.constant.driver.DriverApprovedDrivingModelConstant; + /** * 配送类型枚举 * 对应码表 distribution_type @@ -43,4 +45,13 @@ public enum DistributionTypeConstant { public void setValue(String value) { this.value = value; } + + public static String getName(String value) { + for (DistributionTypeConstant t : DistributionTypeConstant.values()) { + if (t.getValue().equals(value)) { + return t.getName(); + } + } + return null; + } } diff --git a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/dto/MtPushDataDTO.java b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/dto/MtPushDataDTO.java index 1b8883bbf..32fb6584d 100644 --- a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/dto/MtPushDataDTO.java +++ b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/dto/MtPushDataDTO.java @@ -9,6 +9,8 @@ public class MtPushDataDTO implements Serializable { /** 发货单编号 */ private String senderCode; + /** OMS */ + private String oms; /** 订单编号 */ private String orderCode; /** 包件码 */ diff --git a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/entity/MtFactoryOrderMain.java b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/entity/MtFactoryOrderMain.java index 912c16b92..09cfc3a3b 100644 --- a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/entity/MtFactoryOrderMain.java +++ b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/mt/entity/MtFactoryOrderMain.java @@ -20,6 +20,9 @@ public class MtFactoryOrderMain extends BaseEntity { @ApiModelProperty(value = "供应基地") private String siteName; + @ApiModelProperty(value = "OMS") + private String oms; + //@JsonProperty("发货单编号") @ApiModelProperty(value = "发货单编号") private String invoiceOrderCode; diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java index a5275a53a..de950d14f 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java @@ -111,6 +111,7 @@ public class NodeDataPushListener { .dealerName(mtPushDataDTO.getDealerName()) .inWarehouseType(finalInWarehouseType) .operatingTime(operatorTime) + .oms(mtPushDataDTO.getOms()) .operatingWarehouseName(warehouse) .orderCode(pushData.getOrderCode()) .outWarehouseType(mtPushDataDTO.getOutWarehouseType()) @@ -161,6 +162,7 @@ public class NodeDataPushListener { // 按包件分组 CentralStkInConfirmVO confirmVO = CentralStkInConfirmVO.builder() .senderCode(senderCode) + .oms(mtPushDataDTOS1.get(0).getOms()) .operatingTime(operatorTime) .operatingWarehouseName(warehouse) .inWarehouseType(inWarehouseType) @@ -217,6 +219,7 @@ public class NodeDataPushListener { MtPushDataDTO mtPushDataDTO = mtPushDataDTOMap.get(pushData.getPackageCode()); if (ObjectUtil.isNotEmpty(mtPushDataDTO)) { return SignForVO.builder() + .oms(mtPushDataDTO.getOms()) .sendTaskId(entries1.getStr("boId")) .senderCode(mtPushDataDTO.getSenderCode()) .orderCode(pushData.getOrderCode()) @@ -278,6 +281,7 @@ public class NodeDataPushListener { .packageVOS(content.stream().map( pushData -> { return SignForConfirmPackageVO.builder() + .oms(mtPushDataDTOMap.get(pushData.getPackageCode()).getOms()) .orderCode(pushData.getOrderCode()) .outWarehouseType(mtPushDataDTOMap.get(pushData.getPackageCode()).getOutWarehouseType()) .packageCode(pushData.getPackageCode()) diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInConfirmVO.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInConfirmVO.java index d82abc436..2b0db7456 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInConfirmVO.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInConfirmVO.java @@ -23,6 +23,9 @@ public class CentralStkInConfirmVO implements Serializable { @ApiModelProperty("发货单编号") @JsonProperty("发货单编号") private String senderCode; + @ApiModelProperty("OMS") + @JsonProperty("OMS") + private String oms; @ApiModelProperty("确认收货时间") @JsonProperty("确认收货时间") diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInVO.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInVO.java index 81b2f214f..092657d99 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInVO.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/CentralStkInVO.java @@ -23,6 +23,10 @@ public class CentralStkInVO implements Serializable { @JsonProperty("发货单编号") private String senderCode; + @ApiModelProperty("OMS") + @JsonProperty("OMS") + private String oms; + @ApiModelProperty("订单编号") @JsonProperty("订单编号") private String orderCode; diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForConfirmPackageVO.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForConfirmPackageVO.java index 1525311dd..335591825 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForConfirmPackageVO.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForConfirmPackageVO.java @@ -27,6 +27,10 @@ public class SignForConfirmPackageVO implements Serializable { @JsonProperty("订单编号") private String orderCode; + @ApiModelProperty("OMS") + @JsonProperty("OMS") + private String oms; + @ApiModelProperty("工厂出库方式") @JsonProperty("工厂出库方式") private String outWarehouseType; diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForVO.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForVO.java index 1f7bc0ef4..4bfb1c7e0 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForVO.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/vo/SignForVO.java @@ -27,6 +27,10 @@ public class SignForVO implements Serializable { @JsonProperty("发货单编号") private String senderCode; + @ApiModelProperty("OMS") + @JsonProperty("OMS") + private String oms; + @ApiModelProperty("订单编号") @JsonProperty("订单编号") private String orderCode; diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/controller/MtFactoryDataController.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/controller/MtFactoryDataController.java index 01f76ad73..77bfdf1fc 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/controller/MtFactoryDataController.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/controller/MtFactoryDataController.java @@ -108,7 +108,8 @@ public class MtFactoryDataController extends BladeController { @PostMapping("/data") @ApiOperationSupport(order = 1) @ApiOperation(value = "通常数据推送", notes = "传入factoryOrderDTO") - public R data(@Validated @RequestBody MtFactoryDataDTO mtFactoryDataDTO, HttpServletRequest request) { +// public R data(@Validated @RequestBody MtFactoryDataDTO mtFactoryDataDTO, HttpServletRequest request) { + public R data(@Validated @RequestBody Map mtFactoryDataDTO, HttpServletRequest request) { log.info("############data:{} ", mtFactoryDataDTO); String corpId = request.getHeader("corpId"); @@ -120,8 +121,10 @@ public class MtFactoryDataController extends BladeController { orderStatusLog.setBrand("梦天"); orderStatusLogService.save(orderStatusLog); try { + // 解析 map 为 MtFactoryDataDTO 对象 + MtFactoryDataDTO dto = JSONObject.parseObject(JSONObject.toJSONString(mtFactoryDataDTO), MtFactoryDataDTO.class); //数据存入数据库 - R r = mtFactoryDataService.dealWithData(mtFactoryDataDTO); + R r = mtFactoryDataService.dealWithData(dto); int code = r.getCode(); Map map = (Map) r.getData(); diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/dto/MtFactoryOrderMainDTO.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/dto/MtFactoryOrderMainDTO.java index 29f47fae8..2c57a3bfa 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/dto/MtFactoryOrderMainDTO.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/dto/MtFactoryOrderMainDTO.java @@ -24,6 +24,10 @@ public class MtFactoryOrderMainDTO implements Serializable { @ApiModelProperty(value = "发货单编号") private String invoiceOrderCode; + @JsonProperty("OMS") + @ApiModelProperty(value = "OMS") + private String oms; + @JsonProperty("中心仓编号") @ApiModelProperty(value = "中心仓编号") private String centerWarehouseCode; diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtFactoryOrderMainMapper.xml b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtFactoryOrderMainMapper.xml index 402b6c3fe..53f034a3b 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtFactoryOrderMainMapper.xml +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtFactoryOrderMainMapper.xml @@ -104,6 +104,7 @@