From 3205d774875064d566f81d28e2fff3bdb8e90e42 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 22 七月 2025 18:18:00 +0800
Subject: [PATCH] 修改手动推送订单
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECUtil.java | 57 +++++++++++++++++++++++++++++++++++++++------------------
1 files changed, 39 insertions(+), 18 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECUtil.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECUtil.java
index edc211e..b338caf 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECUtil.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECUtil.java
@@ -61,12 +61,13 @@
log.info("获取三方平台授权token请求Data：" + jsonString);
post.body(request_json);
HttpResponse execute = post.execute();
+ String body = execute.body();
if(200 != execute.getStatus()){
- log.error("获取三方平台授权token失败：" + execute.body());
+ log.error("获取三方平台授权token失败：" + body);
return null;
}
- log.info("获取三方平台授权token响应参数：" + execute.body());
- BaseResult baseResult = JSON.parseObject(execute.body(), BaseResult.class);
+ log.info("获取三方平台授权token响应参数：" + body);
+ BaseResult baseResult = JSON.parseObject(body, BaseResult.class);
Integer Ret = baseResult.getRet();
if(0 != Ret){
log.error("获取三方平台授权token失败：" + baseResult.getMsg());
@@ -107,12 +108,13 @@
HttpRequest post = HttpUtil.createPost(operator.getUrl() + InterfaceUrlEnum.NOTIFICATION_STATION_STATUS.getUrl());
buildBody(post, info, operator);
HttpResponse execute = post.execute();
+ String body = execute.body();
if(200 != execute.getStatus()){
- log.error("推送三方平台设备状态失败：" + execute.body());
+ log.error("推送三方平台设备状态失败：" + body);
return null;
}
- log.info("推送三方平台设备状态响应：" + execute.body());
- BaseResult baseResult = JSON.parseObject(execute.body(), BaseResult.class);
+ log.info("推送三方平台设备状态响应：" + body);
+ BaseResult baseResult = JSON.parseObject(body, BaseResult.class);
Integer Ret = baseResult.getRet();
if(0 != Ret){
log.error("推送三方平台设备状态失败：" + baseResult.getMsg());
@@ -139,12 +141,13 @@
HttpRequest post = HttpUtil.createPost(operator.getUrl() + InterfaceUrlEnum.NOTIFICATION_START_CHARGE_RESULT.getUrl());
buildBody(post, info, operator);
HttpResponse execute = post.execute();
+ String body = execute.body();
if(200 != execute.getStatus()){
- log.error("推送三方平台启动充电结果失败：" + execute.body());
+ log.error("推送三方平台启动充电结果失败：" + body);
return null;
}
- log.info("推送三方平台启动充电结果响应：" + execute.body());
- BaseResult baseResult = JSON.parseObject(execute.body(), BaseResult.class);
+ log.info("推送三方平台启动充电结果响应：" + body);
+ BaseResult baseResult = JSON.parseObject(body, BaseResult.class);
Integer Ret = baseResult.getRet();
if(0 != Ret){
log.error("推送三方平台启动充电结果失败：" + baseResult.getMsg());
@@ -172,12 +175,13 @@
HttpRequest post = HttpUtil.createPost(operator.getUrl() + InterfaceUrlEnum.NOTIFICATION_EQUIP_CHARGE_STATUS.getUrl());
buildBody(post, info, operator);
HttpResponse execute = post.execute();
+ String body = execute.body();
if(200 != execute.getStatus()){
- log.error("推送三方平台充电状态失败：" + execute.body());
+ log.error("推送三方平台充电状态失败：" + body);
return null;
}
- log.info("推送三方平台充电状态响应：" + execute.body());
- BaseResult baseResult = JSON.parseObject(execute.body(), BaseResult.class);
+ log.info("推送三方平台充电状态响应：" + body);
+ BaseResult baseResult = JSON.parseObject(body, BaseResult.class);
Integer Ret = baseResult.getRet();
if(0 != Ret){
log.error("推送三方平台充电状态失败：" + baseResult.getMsg());
@@ -200,12 +204,13 @@
HttpRequest post = HttpUtil.createPost(operator.getUrl() + InterfaceUrlEnum.NOTIFICATION_STOP_CHARGE_RESULT.getUrl());
buildBody(post, info, operator);
HttpResponse execute = post.execute();
+ String body = execute.body();
if(200 != execute.getStatus()){
- log.error("推送三方平台停止充电结果失败：" + execute.body());
+ log.error("推送三方平台停止充电结果失败：" + body);
return null;
}
- log.info("推送三方平台停止充电结果响应：" + execute.body());
- BaseResult baseResult = JSON.parseObject(execute.body(), BaseResult.class);
+ log.info("推送三方平台停止充电结果响应：" + body);
+ BaseResult baseResult = JSON.parseObject(body, BaseResult.class);
Integer Ret = baseResult.getRet();
if(0 != Ret){
log.error("推送三方平台停止充电结果失败：" + baseResult.getMsg());
@@ -227,15 +232,17 @@
* @return
*/
public static NotificationChargeOrderInfoResult notificationChargeOrderInfo(Operator operator, NotificationChargeOrderInfo info){
+ System.out.println("推送充电订单信息:--->" + JSON.toJSONString(info));
HttpRequest post = HttpUtil.createPost(operator.getUrl() + InterfaceUrlEnum.NOTIFICATION_CHARGE_ORDER_INFO.getUrl());
buildBody(post, info, operator);
HttpResponse execute = post.execute();
+ String body = execute.body();
if(200 != execute.getStatus()){
- log.error("推送三方平台充电订单信息失败：" + execute.body());
+ log.error("推送三方平台充电订单信息失败：" + body);
return null;
}
- log.info("推送三方平台充电订单信息响应：" + execute.body());
- BaseResult baseResult = JSON.parseObject(execute.body(), BaseResult.class);
+ log.info("推送三方平台充电订单信息响应：" + body);
+ BaseResult baseResult = JSON.parseObject(body, BaseResult.class);
Integer Ret = baseResult.getRet();
if(0 != Ret){
log.error("推送三方平台充电订单信息失败：" + baseResult.getMsg());
@@ -337,6 +344,20 @@
}
return sign;
}
+ public static String ourBuildSignJianGuan(BaseModel model){
+ Operator operator = model.getOperator();
+ if(null == operator){
+ return "";
+ }
+ //签名秘钥SigSecret
+ String key = operator.getOurSigSecret();
+ String sign = "";
+ //进行字符串拼接、计算
+ String m1 = new StringBuilder(model.getOperatorID()).append(model.getData()).append(model.getTimeStamp()).append(model.getSeq()).toString();
+ sign = SignUtil.hmacSign(m1, key);
+ return sign;
+ }
+
--
Gitblit v1.7.1