ソースを参照

fix(charging): 优化渠道方推送接口采用postJson

wzq 4 週間 前
コミット
bb0b768b80

+ 1 - 1
src/main/java/com/zsElectric/boot/business/service/impl/ChargeOrderInfoServiceImpl.java

@@ -1393,7 +1393,7 @@ public class ChargeOrderInfoServiceImpl extends ServiceImpl<ChargeOrderInfoMappe
             int retryIntervalMs = 5000;
             for (int attempt = 1; attempt <= maxRetries; attempt++) {
                 try {
-                    JsonNode response = okHttpUtil.doPostForm(url, pushJson, null);
+                    JsonNode response = okHttpUtil.doPostJson(url, pushJson, null);
                     log.info("补偿任务: 渠道方推送充电订单信息成功 - chargeOrderNo: {}, firmId: {}, response: {}",
                             order.getChargeOrderNo(), order.getFirmId(), response);
                     return;

+ 3 - 2
src/main/java/com/zsElectric/boot/charging/service/impl/ChargingReceptionServiceImpl.java

@@ -375,7 +375,7 @@ public class ChargingReceptionServiceImpl implements ChargingReceptionService {
                             }
                         }
 
-                        log.info("计算后的平台服务:{}", serviceFee);
+                        log.info("计算后的平台服务:{}", serviceFee);
                         if (chargeOrderInfo.getOrderType().equals(SystemConstants.CHARGE_ORDER_TYPE_PLATFORM)) {
                             chargeOrderInfo.setDiscountMoney(discountFee);
                             chargeOrderInfo.setRealServiceCost(serviceFee.setScale(2, RoundingMode.HALF_UP));
@@ -913,7 +913,8 @@ public class ChargingReceptionServiceImpl implements ChargingReceptionService {
 
                     // 推送充电状态
                     try {
-                        JsonNode response = okHttpUtil.doPostForm(channelUrl, BeanUtil.beanToMap(chargeStatus), null);
+                        String requestBody = objectMapper.writeValueAsString(BeanUtil.beanToMap(chargeStatus));
+                        JsonNode response = okHttpUtil.doPostJson(channelUrl, requestBody, null);
                         log.info("推送充电状态成功 - startChargeSeq: {}, firmId: {}, channelUrl: {}, response: {}", 
                                 startChargeSeq, firmId, channelUrl, response);
                     } catch (Exception e) {