提交 a939ab7c authored 作者: 艾庆国's avatar 艾庆国

Merge branch 'refs/heads/v20.9_settlement_20240805' into test

Former-commit-id: d7d6b827
...@@ -48,6 +48,14 @@ public class TempSettlementController { ...@@ -48,6 +48,14 @@ public class TempSettlementController {
return Result.ok(); return Result.ok();
} }
@ApiOperation(value = "结算单新增", notes = "<br>By:艾庆国")
@RequestMapping(value = "/settlementDetailAdd", method = RequestMethod.GET)
public Result settlementDetailAdd(Integer settlementOwnerDetailId, Integer settlementDriverDetailId) {
settlementMqService.settlementDetailAdd(settlementOwnerDetailId, settlementDriverDetailId);
return Result.ok();
}
@ApiOperation(value = "运单同步broker", notes = "<br>By:艾庆国") @ApiOperation(value = "运单同步broker", notes = "<br>By:艾庆国")
@RequestMapping(value = "/orderChildSync", method = RequestMethod.GET) @RequestMapping(value = "/orderChildSync", method = RequestMethod.GET)
public Result orderChildSync(String childNo) { public Result orderChildSync(String childNo) {
......
...@@ -43,7 +43,7 @@ public class OrderChildBrokerMqServiceImpl implements OrderChildBrokerMqService ...@@ -43,7 +43,7 @@ public class OrderChildBrokerMqServiceImpl implements OrderChildBrokerMqService
MqDelay delay = MqDelay delay =
new MqDelay<>(RabbitKeyBrokerConstants.DEFAULT_EXCHANGE, new MqDelay<>(RabbitKeyBrokerConstants.DEFAULT_EXCHANGE,
RabbitKeyBrokerConstants.ORDER_CHILD_SYNC_ROUTING_KEY, new MqWrapper<>(mq)); RabbitKeyBrokerConstants.ORDER_CHILD_UPDATE_ROUTING_KEY, new MqWrapper<>(mq));
Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(delay)).getBytes()).build(); Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(delay)).getBytes()).build();
message.getMessageProperties().setExpiration("5000"); message.getMessageProperties().setExpiration("5000");
rabbitTemplate.send(RabbitKeyBrokerConstants.DEFAULT_EXCHANGE, rabbitTemplate.send(RabbitKeyBrokerConstants.DEFAULT_EXCHANGE,
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论