|
|
|
@ -214,6 +214,8 @@ public class NodeDataPushListener {
|
|
|
|
|
// 保存推送记录
|
|
|
|
|
factoryNodePushService.save(FactoryNodePushEntity.builder() |
|
|
|
|
.orderCode(orderCode) |
|
|
|
|
.type(arriveFor) |
|
|
|
|
.warehouse(StrUtil.equals(arriveFor, "stock") ? filterDatum.getWarehouseName() : null) |
|
|
|
|
.node(FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode().toString()) |
|
|
|
|
.content(JSONUtil.toJsonStr(js)) |
|
|
|
|
.packageCode(packageCode) |
|
|
|
@ -269,6 +271,9 @@ public class NodeDataPushListener {
|
|
|
|
|
// 保存推送记录
|
|
|
|
|
factoryNodePushService.save(FactoryNodePushEntity.builder() |
|
|
|
|
.orderCode(sendOrderCode) |
|
|
|
|
.type(arriveFor) |
|
|
|
|
// 仓配数据记录仓库
|
|
|
|
|
.warehouse(StrUtil.equals(arriveFor, "stock") ? filterDatum.getWarehouseName() : null) |
|
|
|
|
.transportNo(transportNo) |
|
|
|
|
.node(FactoryNodeEnums.FINAL_NET_ARRIVE_CAR.getCode().toString()) |
|
|
|
|
.content(JSONUtil.toJsonStr(js)) |
|
|
|
@ -294,8 +299,8 @@ public class NodeDataPushListener {
|
|
|
|
|
.exchange(FactoryDataConstants.Mq.Exchanges.NODE_DATA_PUSH_DELAYED) |
|
|
|
|
.routingKey(FactoryDataConstants.Mq.RoutingKeys.JP_NODE_DATA_PUSH) |
|
|
|
|
.message(JSONUtil.toJsonStr(nodePushMsg, HutoolConfigUtil.jsonConfigByDataTimeFormat())) |
|
|
|
|
// 3-10秒随机
|
|
|
|
|
.delay(1000 * RandomUtil.randomInt(3, 11)) |
|
|
|
|
// 30-109秒随机
|
|
|
|
|
.delay(1000 * RandomUtil.randomInt(30, 110)) |
|
|
|
|
.build()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|