Commit b8f935d3 authored by 胡建龙's avatar 胡建龙

[fix]中登网接口升级联调通过版本

parent 1494b56d
......@@ -144,16 +144,19 @@ public class ZdwNewWsRequestsServiceImpl implements IZdwNewWsRequestsService {
jsonObject.put("username",userName);
jsonObject.put("password",encryptPassword);
jsonObject.put("platformAuthCode",authCode);
String param = Base64.getEncoder().encodeToString(requestJson.toJSONString().getBytes());
String param = Base64.getEncoder().encodeToString(requestJson.toJSONString().getBytes("utf-8"));
/*发送初始登记接口请求*/
URL urlObj = new URL(initUrl);
JSONObject reqParam = new JSONObject();
reqParam.put("data",param);
URL urlObj = new URL(url);
System.out.println(jsonObject.toJSONString());
System.out.println(param);
HttpURLConnection connection = (HttpURLConnection) urlObj.openConnection();
connection.setRequestMethod("POST");
connection.setRequestProperty("Content-Type", "application/json");
connection.setDoOutput(true);
OutputStream outputStream = connection.getOutputStream();
outputStream.write(param.getBytes());
outputStream.write(reqParam.toJSONString().getBytes());
outputStream.flush();
int statusCode = connection.getResponseCode();
......@@ -164,10 +167,11 @@ public class ZdwNewWsRequestsServiceImpl implements IZdwNewWsRequestsService {
responseBody.append(inputLine);
}
in.close();
String res = new String(Base64.getDecoder().decode(responseBody.toString()));
System.out.println("Response Code: " + statusCode);
System.out.println("Response Body: " + responseBody.toString());
System.out.println("Response Body: " + res);
connection.disconnect();
return responseBody.toString();
return res;
}
/*初始登记*/
......@@ -182,7 +186,7 @@ public class ZdwNewWsRequestsServiceImpl implements IZdwNewWsRequestsService {
switch (line.getUpStage()){
case "01" : requestUrl = initUrl;break;
case "03" : requestUrl = renewalUrl;break;
case "04" : requestUrl = cancelUrl;break;
case "05" : requestUrl = cancelUrl;break;
default: requestUrl = null;
}
......@@ -196,6 +200,7 @@ public class ZdwNewWsRequestsServiceImpl implements IZdwNewWsRequestsService {
String resData = sendPostRequest(requestUrl, line.getRequestJson());
setResData(resultJson, hlsWsRequests, resData);
System.out.println(resData);
logger.info("register init success line_id:{}, returns: {}", line.getLineId(), resData);
} catch (Exception e) {
e.printStackTrace();
......@@ -236,7 +241,7 @@ public class ZdwNewWsRequestsServiceImpl implements IZdwNewWsRequestsService {
/*解析接口返回结果*/
JSONObject returnJson = JSONArray.parseArray(resultJson.getString("info")).getJSONObject(0);
JSONObject returnJson = JSONObject.parseObject(resultJson.getString("info"));
String registerResult = returnJson.getString("regResult");
......@@ -247,6 +252,7 @@ public class ZdwNewWsRequestsServiceImpl implements IZdwNewWsRequestsService {
if (!StringUtils.isEmpty(returnJson.getString("registerNo"))) {
String registerNumber = returnJson.getString("registerNo");
fndZhongDengLines.setRegisterNumber(registerNumber);
/*初始登记*/
if ("01".equalsIgnoreCase(fndZhongDengLines.getUpStage())) {
fndZhongDengHeads.setInitRegisterNumber(registerNumber);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment