补缴成功单车反白路网返回数据优化

src/main/java/com/qtzl/alterSales/manager/service/FssBlackListManagerImpl.java

@@ -354,7 +354,7 @@ public class FssBlackListManagerImpl implements FssBlackListManager {
 
         try {
             if (ObjectUtil.isEmpty(vehicleIdRedis)) {
-                httpJsonPost = pssSupService.pssSup(vehicleBlackListRequest, token,
+                httpJsonPost = pssSupService.pssSup2(vehicleBlackListRequest, token,
                         PlatformJsonDepartmentResponse.class);
                 // 请求结果存入对应的日志记录表
                 AflVehicleStatusHisInfo aflVehicleStatusHisInfo = new AflVehicleStatusHisInfo();

src/main/java/com/qtzl/alterSales/manager/service/center/PssSupService.java

@@ -34,4 +34,16 @@ public interface PssSupService {
      * @throws ManagerException 、
      */
     <T extends SubBaseModel, K extends SubBaseModel> K pssSup(T req, String token, Class<K> var1) throws ManagerException;
+
+    /***
+     * 部中心统一入口 需token
+     * @param req 、
+     * @param token 、
+     * @param var1 、
+     * @return 、
+     * @param <T> 、
+     * @param <K> 、
+     * @throws ManagerException 、
+     */
+    <T extends SubBaseModel, K extends SubBaseModel> K pssSup2(T req, String token, Class<K> var1) throws ManagerException;
 }

src/main/java/com/qtzl/alterSales/manager/service/center/PssSupServiceImpl.java

@@ -54,6 +54,42 @@ public class PssSupServiceImpl implements PssSupService {
         return (K) convertResponse(data.getFilename(), jsonResponse, var1, inTime);
     }
 
+    @Override
+    public <T extends SubBaseModel, K extends SubBaseModel> K pssSup2(T req, String token, Class<K> var1)
+            throws ManagerException {
+        long inTime = System.currentTimeMillis();
+        SsoJsonRequest data = convertRequest(req);
+        String jsonResponse = OKHttpClientUtil.httpPost(pssSupConfiguration.getPssUrl(), JsonUtils.toJsonStr(data), getHeaderMap(token));
+        return (K) convertResponse2(data.getFilename(), jsonResponse, var1, inTime);
+    }
+
+    private <T extends SubBaseModel> T convertResponse2(String filename, String jsonResponse, Class<T> clazz,
+                                                        long inTime) throws ManagerException {
+        log.info("pssresponse:{} filename:{} elapsed:{}", jsonResponse, filename,
+                System.currentTimeMillis() - inTime);
+        SsoJsonResponse response;
+        try {
+            response = JsonUtils.json2Object(jsonResponse, SsoJsonResponse.class);
+            System.out.println("转换后返回信息" + response);
+        } catch (Exception e) {
+            log.error("pssjsonError", e);
+            throw new ManagerException("pss请求异常", "999");
+        }
+        if (null == response) {
+            throw new ManagerException("pss请求异常", "999");
+        }
+        if (StringUtils.isNotBlank(response.getBizContent())) {
+            String bizContent = "";
+            if (1 == pssSupConfiguration.getIsSign()) {
+                bizContent = AESTools.decrypt(response.getBizContent(), pssSupConfiguration.getAesKey());
+            } else {
+                bizContent = response.getBizContent();
+            }
+            response.setBizContent(bizContent);
+            log.info("bizContent:{}", bizContent);
+        }
+        return (T) json2Model(response.toJson(), clazz);
+    }
     public <T extends SubBaseModel, K extends BaseEntity> DwonLoadBaseResponse pssSupETC(T req, String token,
                                                                                          Class<K> var1) throws Exception {
         DwonLoadBaseResponse res;