Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

国网上送接口，代码更新

Browse Source
This commit is contained in:
wr
2023-08-01 15:35:47 +08:00
parent 1c086b9719
commit 4448638a48
2 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/SupvPushGwServiceImpl.java
View File

@@ -228,10 +228,10 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
return "操作成功:成功数据"+count+"条";
} else {
String errors = mapData.get("errors").toString();
return "操作失败:"+status+"_"+errors;
throw new BusinessException("操作失败:"+status+"_"+errors);
}
} else {
return "出现未知错误";
throw new BusinessException("出现未知错误");
}
}
@@ -285,7 +285,6 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
send = send(param, getUrl(2), "pqProblemCreate");
log.info(Thread.currentThread().getName() + "获取返回体 接收电能质量技术监督实施问题数据接口响应结果：" + send + "结束----！");
}else{
System.out.println(1);
send = send(param, getUrl(3), "pqProblemUpdate");
log.info(Thread.currentThread().getName() + "获取返回体 接收电能质量技术监督实施问题整改数据接口响应结果：" + send + "结束----！");
}
@@ -309,13 +308,14 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
Map mapCount = JSON.parseObject(result, Map.class);
String count = mapCount.get("count").toString();
return "操作成功:成功数据"+count+"条";
} else {
}else {
String errors = map.get("errors").toString();
return "操作失败:"+status+"_"+errors;
throw new BusinessException("操作失败:"+status+"_"+errors);
}
} else {
return "出现未知错误";
throw new BusinessException("出现未知错误");
}
}
@Override
@@ -375,7 +375,7 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
log.info(Thread.currentThread().getName() + "获取返回体 取消电能质量技术监督工作计划接口数据：" + s + "结束----！");
Map<String, String> send = send(param, getUrl(5), "pqMonthReportCreate");
// Map<String, String> send = new HashMap<>();
log.info(Thread.currentThread().getName() + "获取返回体 取消电能质量技术监督工作计划接口响应结果：" + s + "结束----！");
log.info(Thread.currentThread().getName() + "获取返回体 取消电能质量技术监督工作计划接口响应结果：" + send + "结束----！");
if (send.containsKey("succeed")) {
String succeed = send.get("succeed");
if(succeed.indexOf("\\\"")!=-1){
@@ -396,10 +396,10 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
return "操作成功:成功数据"+count+"条";
} else {
String errors = map.get("errors").toString();
return "操作失败:"+status+"_"+errors;
throw new BusinessException("操作失败:"+status+"_"+errors);
}
} else {
return "出现未知错误";
throw new BusinessException("出现未知错误");
}
}
@@ -429,7 +429,7 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
log.info(Thread.currentThread().getName() + "获取返回体 删除电能质量技术监督工作计划接口数据：" + s + "结束----！");
Map<String, String> send = send(param, getUrl(6), "pqPlanDelete");
// Map<String, String> send = new HashMap<>();
log.info(Thread.currentThread().getName() + "获取返回体 删除电能质量技术监督工作计划接口响应结果：" + s + "结束----！");
log.info(Thread.currentThread().getName() + "获取返回体 删除电能质量技术监督工作计划接口响应结果：" + send + "结束----！");
if (send.containsKey("succeed")) {
String succeed = send.get("succeed");
if(succeed.indexOf("\\\"")!=-1){
@@ -448,10 +448,10 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
return "操作成功:成功数据"+countNum+"条";
} else {
String errors = map.get("errors").toString();
return "操作失败:"+status+"_"+errors;
throw new BusinessException("操作失败:"+status+"_"+errors);
}
} else {
return "出现未知错误";
throw new BusinessException("出现未知错误");
}
}