暂时屏蔽代码

src/main/java/com/jkcredit/invoice/hub/controller/rest/forward/ForwardResource.java

@@ -27,31 +27,31 @@ import org.springframework.web.bind.annotation.RestController;
 @Slf4j
 @RestController
 public class ForwardResource extends RestResource {
-    @Autowired
-    ApiUserService apiUserService;
-    @Autowired
-    ApiCompanyService apiCompanyService;
-
-    @PostMapping("/rest")
-    public ApiResponseData forwardRequest(@RequestBody ApiRequestParam param) {
-        try {
-            validate(param);
-        } catch (ServiceException se) {
-            log.error("接口参数ApiRequestParam校验失败,失败原因：{}", se.getMessage());
-            return ApiResponseData.failure(ApiResponseCodeEnum.CODE_1010.getValue(), ApiResponseCodeEnum.CODE_1010.getDesc());
-        }
-
-        // 校验用户key secret, 权限，余额
-        Integer validateUserResult = apiUserService.validateUser(param.getAppKey(), param.getAppSecret(), param.getApi());
-        if (!validateUserResult.equals(ApiResponseCodeEnum.CODE_200.getValue())) {
-            return ApiResponseData.failure(validateUserResult, EnumStatusUtils.getStatusByValue(ApiResponseCodeEnum.class, validateUserResult).getDesc());
-        }
-
-        if (param.getApi().equals(CommonConstant.COMPANY_QUERY_V1)) {
-            return apiCompanyService.companyQuery(JSON.parseObject(JSON.toJSONString(param.getData())));
-        }
-
-        log.info(param.toString());
-        return new ApiResponseData();
-    }
+//    @Autowired
+//    ApiUserService apiUserService;
+//    @Autowired
+//    ApiCompanyService apiCompanyService;
+//
+//    @PostMapping("/rest")
+//    public ApiResponseData forwardRequest(@RequestBody ApiRequestParam param) {
+//        try {
+//            validate(param);
+//        } catch (ServiceException se) {
+//            log.error("接口参数ApiRequestParam校验失败,失败原因：{}", se.getMessage());
+//            return ApiResponseData.failure(ApiResponseCodeEnum.CODE_1010.getValue(), ApiResponseCodeEnum.CODE_1010.getDesc());
+//        }
+//
+//        // 校验用户key secret, 权限，余额
+//        Integer validateUserResult = apiUserService.validateUser(param.getAppKey(), param.getAppSecret(), param.getApi());
+//        if (!validateUserResult.equals(ApiResponseCodeEnum.CODE_200.getValue())) {
+//            return ApiResponseData.failure(validateUserResult, EnumStatusUtils.getStatusByValue(ApiResponseCodeEnum.class, validateUserResult).getDesc());
+//        }
+//
+//        if (param.getApi().equals(CommonConstant.COMPANY_QUERY_V1)) {
+//            return apiCompanyService.companyQuery(JSON.parseObject(JSON.toJSONString(param.getData())));
+//        }
+//
+//        log.info(param.toString());
+//        return new ApiResponseData();
+//    }
 }

src/main/java/com/jkcredit/invoice/hub/service/apiCompany/ApiCompanyService.java

@@ -1,10 +1,5 @@
 package com.jkcredit.invoice.hub.service.apiCompany;
 
-import com.alibaba.fastjson.JSONObject;
-import com.jkcredit.invoice.hub.spi.rest.data.ApiResponseData;
-
-import java.util.Map;
-
 /**
  * @description:
  * @author: xusonglin
@@ -12,5 +7,5 @@ import java.util.Map;
  * @version: V1.0
  **/
 public interface ApiCompanyService {
-    ApiResponseData companyQuery(JSONObject param);
+//    ApiResponseData companyQuery(JSONObject param);
 }

src/main/java/com/jkcredit/invoice/hub/service/apiCompany/ApiCompanyServiceImpl.java

@@ -1,54 +1,47 @@
 package com.jkcredit.invoice.hub.service.apiCompany;
 
-import cn.com.taiji.sdk.comm.ETCCommHelper;
-import cn.com.taiji.sdk.model.comm.protocol.eoms.company.CompanyQueryRequest;
-import cn.com.taiji.sdk.model.comm.protocol.eoms.company.CompanyQueryResponse;
-import com.alibaba.fastjson.JSONObject;
-import com.jkcredit.invoice.hub.enums.ApiResponseCodeEnum;
-import com.jkcredit.invoice.hub.spi.rest.data.ApiResponseData;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
-import java.io.IOException;
-
 /**
  * @description:
  * @author: xusonglin
  * @create: 2020/1/15 23:50
  * @version: V1.0
  **/
-@Service
 @Slf4j
+@Service
 public class ApiCompanyServiceImpl implements ApiCompanyService {
-    @Override
-    public ApiResponseData companyQuery(JSONObject param) {
-        long costTimeStart = System.currentTimeMillis();
-        String result;
-
-        CompanyQueryRequest request = new CompanyQueryRequest();
-        request.setCompanyName(param.get("companyName").toString().trim());
-        request.setTaxpaterCode(param.get("taxplayerCode").toString().trim());
-        String fileName = request.getFilename();
-
-        try {
-            // (4)指定协议的响应模型（IssuerUploadResponse），调用upload 发送数据
-            CompanyQueryResponse response = ETCCommHelper.upload(fileName, request, CompanyQueryResponse.class);
 
-            // (5)发送成功处理（这里为示例，简单的将响应模型转为json字符串输出，各省根据实际情况处理）
-            result = response.toJson();
-            long costTimeEnd = System.currentTimeMillis();
-            log.info("[-companyQuery-] result is " + result.replaceAll("\r|\n", "") + " , request is "
-                    + param + ",costtime=" + (costTimeEnd - costTimeStart) + ",startTime=" + costTimeStart
-                    + ",endTime=" + costTimeEnd);
-        } catch (IOException e) {
-            // todo 失败返回码和信息
-            log.info("[-companyQuery-] 网络异常 " + e);
-            return ApiResponseData.failure(1, "");
-        } catch (Exception apie) {
-            // todo 失败返回码和信息
-            log.info("[-companyQuery-] 错误信息：" + apie.getMessage());
-            return ApiResponseData.failure(1, "");
-        }
-        return ApiResponseData.success(ApiResponseCodeEnum.CODE_200.getValue(), result);
-    }
+//    @Override
+//    public ApiResponseData companyQuery(JSONObject param) {
+//        long costTimeStart = System.currentTimeMillis();
+//        String result;
+//
+//        CompanyQueryRequest request = new CompanyQueryRequest();
+//        request.setCompanyName(param.get("companyName").toString().trim());
+//        request.setTaxpaterCode(param.get("taxplayerCode").toString().trim());
+//        String fileName = request.getFilename();
+//
+//        try {
+//            // (4)指定协议的响应模型（IssuerUploadResponse），调用upload 发送数据
+//            CompanyQueryResponse response = ETCCommHelper.upload(fileName, request, CompanyQueryResponse.class);
+//
+//            // (5)发送成功处理（这里为示例，简单的将响应模型转为json字符串输出，各省根据实际情况处理）
+//            result = response.toJson();
+//            long costTimeEnd = System.currentTimeMillis();
+//            log.info("[-companyQuery-] result is " + result.replaceAll("\r|\n", "") + " , request is "
+//                    + param + ",costtime=" + (costTimeEnd - costTimeStart) + ",startTime=" + costTimeStart
+//                    + ",endTime=" + costTimeEnd);
+//        } catch (IOException e) {
+//            // todo 失败返回码和信息
+//            log.info("[-companyQuery-] 网络异常 " + e);
+//            return ApiResponseData.failure(1, "");
+//        } catch (Exception apie) {
+//            // todo 失败返回码和信息
+//            log.info("[-companyQuery-] 错误信息：" + apie.getMessage());
+//            return ApiResponseData.failure(1, "");
+//        }
+//        return ApiResponseData.success(ApiResponseCodeEnum.CODE_200.getValue(), result);
+//    }
 }