autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-04-20 11:05:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

第三方推送还原为原来的版本代码,测试改到dev-zzx1分支

Browse Source
This commit is contained in:
YAS\29473
2025-09-15 09:28:46 +08:00
parent c9264800d4
commit 1d790d7761
8 changed files with 224 additions and 224 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
jsowell-admin/src/main/java/com/jsowell/service/OrderService.java
View File

@@ -810,23 +810,23 @@ public class OrderService {
log.info("人工结算订单-end orderCode:{}", dto.getOrderCode());
// 异步推送第三方平台订单信息
// CompletableFuture.runAsync(() -> {
// try {
// commonService.commonPushOrderInfo(orderBasicInfo);
// } catch (Exception e) {
// log.error("人工结算订单 推送第三方平台订单信息error, orderCode:{}", orderBasicInfo.getOrderCode(), e);
// }
// }, thirdpartyTaskExecutor);
CompletableFuture.runAsync(() -> {
try {
commonService.commonPushOrderInfo(orderBasicInfo);
} catch (Exception e) {
log.error("人工结算订单 推送第三方平台订单信息error, orderCode:{}", orderBasicInfo.getOrderCode(), e);
}
}, thirdpartyTaskExecutor);
// TODO 测试mq
// 向mq中发送实时数据消息,给第三方服务消费
CompletableFuture.runAsync(() -> {
try {
rabbitTemplate.convertAndSend(ThirdPartyRabbitConstants.WCC_THIRDPARTY_NAME , ThirdPartyRabbitConstants.ROUTING_KEY_CHARGE_ORDER_PUSH ,orderBasicInfo );
} catch (Exception e) {
log.error("向mq中发送实时数据消息供第三方服务消费 error, " , e);
}
}, thirdpartyTaskExecutor);
// CompletableFuture.runAsync(() -> {
// try {
// rabbitTemplate.convertAndSend(ThirdPartyRabbitConstants.WCC_THIRDPARTY_NAME , ThirdPartyRabbitConstants.ROUTING_KEY_CHARGE_ORDER_PUSH ,orderBasicInfo );
// } catch (Exception e) {
// log.error("向mq中发送实时数据消息供第三方服务消费 error, " , e);
// }
// }, thirdpartyTaskExecutor);
return true;
}