客户下游接口开发

src/main/java/com/jkcredit/invoice/common/ApiResult.java

@@ -0,0 +1,180 @@
+package com.jkcredit.invoice.common;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Map;
+
+/**
+ * @Description: 接口请求返回结果
+ * @Author: junqiang.lu
+ * @Date: 2018/10/9
+ */
+@Data
+@ApiModel(value = "接口返回结果")
+public class ApiResult<T> implements Serializable {
+
+    private static final long serialVersionUID = -2953545018812382877L;
+
+    /**
+     * 返回码，200 正常
+     */
+    @ApiModelProperty(value = "返回码，200 正常", name = "code")
+    private int code = 200;
+
+    /**
+     * 返回信息
+     */
+    @ApiModelProperty(value = "返回信息", name = "msg")
+    private String msg = "成功";
+
+    /**
+     * 返回信息
+     */
+    @ApiModelProperty(value = "唯一识别码", name = "requestid")
+    private String requestid = "";
+
+
+    /**
+     * 返回数据
+     */
+    @ApiModelProperty(value = "返回数据对象", name = "data")
+    private T data;
+
+    /**
+     * 附加数据
+     */
+   /* @ApiModelProperty(value = "附加数据", name = "extraData")
+    private Map<String, Object> extraData;*/
+
+    /**
+     * 系统当前时间
+     */
+   /* @ApiModelProperty(value = "服务器系统时间，时间戳(精确到毫秒)", name = "timestamp")
+    private Long timestamp = System.currentTimeMillis();
+*/
+    /**
+     * 获取成功状态结果
+     *
+     * @return
+     */
+    public static ApiResult success() {
+        return success(null, null);
+    }
+
+    /**
+     * 获取成功状态结果
+     *
+     * @param data 返回数据
+     * @return
+     */
+    public static ApiResult success(Object data) {
+        return success(data, null);
+    }
+
+    /**
+     * 获取成功状态结果
+     *
+     * @param data 返回数据
+     * @param extraData 附加数据
+     * @return
+     */
+    public static ApiResult success(Object data, Map<String, Object> extraData) {
+        ApiResult apiResult = new ApiResult();
+        apiResult.setCode(ResponseCode.SUCCESS.getCode());
+        apiResult.setMsg(ResponseCode.SUCCESS.getMsg());
+        apiResult.setData(data);
+        //apiResult.setExtraData(extraData);
+        return apiResult;
+    }
+
+    /**
+     * 获取失败状态结果
+     *
+     * @return
+     */
+    public static ApiResult failure() {
+        return failure(ResponseCode.FAIL.getCode(), ResponseCode.FAIL.getMsg(), 0);
+    }
+
+    /**
+     * 获取失败状态结果
+     *
+     * @param msg (自定义)失败消息
+     * @return
+     */
+    public static ApiResult failure(String msg) {
+        return failure(ResponseCode.FAIL.getCode(), msg, 0);
+    }
+
+    /**
+     * 获取失败状态结果
+     *
+     * @param responseCode 返回状态码
+     * @return
+     */
+    public static ApiResult failure(ResponseCode responseCode) {
+        return failure(responseCode.getCode(), responseCode.getMsg(), responseCode.getData());
+    }
+
+
+
+
+    /**
+     * 获取失败状态结果
+     *
+     * @param dataResult 返回状态码
+     * @return
+     */
+    public static ApiResult failure(DataResult dataResult) {
+        return failure(dataResult.getData(),dataResult.getCode(), dataResult.getRequestid(),dataResult.getMsg());
+    }
+
+    /**
+     * 获取失败状态结果
+     *
+     * @param responseCode 返回状态码
+     * @param data         返回数据
+     * @return
+     */
+    public static ApiResult failure(ResponseCode responseCode, int data) {
+        return failure(responseCode.getCode(), responseCode.getMsg(), data);
+    }
+
+    /**
+     * 获取失败返回结果
+     *
+     * @param code 错误码
+     * @param msg  错误信息
+     * @param data 返回结果
+     * @return
+     */
+    public static ApiResult failure(int code, String msg, int data) {
+        ApiResult result = new ApiResult();
+        result.setCode(code);
+        result.setMsg(msg);
+        result.setData(data);
+        return result;
+    }
+
+    /**
+     * 获取失败返回结果
+     *
+     * @param code 错误码
+     * @param msg  错误信息
+     * @param data 返回结果
+     * @return
+     */
+    public static ApiResult failure( int data, int code, String requestid,String msg) {
+        ApiResult result = new ApiResult();
+        result.setCode(code);
+        result.setData(data);
+        result.setRequestid(requestid);
+        result.setMsg(msg);
+        return result;
+    }
+
+
+}

src/main/java/com/jkcredit/invoice/common/DataResult.java

@@ -0,0 +1,64 @@
+package com.jkcredit.invoice.common;
+
+import java.io.Serializable;
+
+/**
+ * Created by chenty on 16/10/30.
+ */
+
+public class DataResult implements Serializable {
+    private static final long serialVersionUID = -2002667808723112088L;
+
+    private int code;
+    private String msg;
+    private int data = 3;
+    
+  
+    /**
+     * 返回客户信息定位标记
+     */
+    private String requestid;
+
+
+    public int getCode() {
+        return code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public int getData() {
+        return data;
+    }
+
+    public void setData(int data) {
+        this.data = data;
+    }
+
+    public String getRequestid() {
+        return requestid;
+    }
+
+    public void setRequestid(String requestid) {
+        this.requestid = requestid;
+    }
+
+    @Override
+    public String toString() {
+        return "DataResult{" +
+                "code=" + code +
+                ", msg='" + msg + '\'' +
+                ", data=" + data +
+                ", requestid='" + requestid + '\'' +
+                '}';
+    }
+}

src/main/java/com/jkcredit/invoice/common/ResponseCode.java

@@ -0,0 +1,65 @@
+package com.jkcredit.invoice.common;
+
+import lombok.Getter;
+import lombok.ToString;
+
+/**
+ * @Description: 返回码枚举
+ * @Author junqiang.lu
+ * @Date 2018/5/22
+ */
+@Getter
+@ToString
+public enum ResponseCode {
+
+  /**
+     * 成功与失败
+     */
+    SUCCESS(1,200, "成功"),
+    FAILQUERYNO(2,200, "未查得"),
+    FAIL(3,200, "失败"),
+    /**
+     * 参数异常
+     */
+    ACCOUNT_NOT_EXIST(3,1000,"无效用户"),
+    PARAM_NOT_NULL(3,1010, "参数不能为空"),
+
+    MEDIA_TYPE_NOT_SUPPORT_ERROR(3,1020,"参数类型不正确"),
+    ONE_DAY_QUERY_ERROR(3,1030,"单日查询次数到达上限"),
+    SIGN_ERROR(3,1040,"appkey错误/签名校验失败"),
+    TIME_ERROR(3,1050,"账号使用时间未到"),
+    TIME_OUT_ERROR(3,1060,"账号使用时间已过"),
+    ALL_DAY_QUERY_ERROR(3,1070,"总查询次数到达上限"),
+    CUSTOMER_QUERY_ERROR(3,1080,"商户模块未配置"),
+    BALANCE_QUERY_ERROR(3,1090,"商户余额不足"),
+    API_QUERY_ERROR(3,1100,"请求的API模块不存在"),
+    TIME_QUERY_ERROR(3,1110,"商户单位时间内请求超过限制"),
+    OTHER_ERROR(3,9999,"其他异常-"),
+
+    /**
+     * 其他
+     */
+    UNKNOWN_ERROR(3,500,"系统异常,内部执行错误");
+
+    /**
+     * 返回码
+     */
+    private int code;
+
+    /**
+     * 返回信息
+     */
+    private String msg;
+
+    /**
+     * 返回状态
+     */
+    private int data;
+
+    private ResponseCode(int data ,int code, String msg) {
+        this.code = code;
+        this.msg = msg;
+        this.data = data;
+    }
+
+}

src/main/java/com/jkcredit/invoice/common/TokenConst.java

@@ -0,0 +1,32 @@
+package com.jkcredit.invoice.common;
+
+/**
+ * @Description: Token 相关常量
+ * @Author: junqiang.lu
+ * @Date: 2019/12/3
+ */
+public class TokenConst {
+
+
+    /**
+     * Token headers 字段
+     */
+    public static final String TOKEN_HEADERS_FIELD = "Authorization";
+    /**
+     * token key
+     */
+    public static final String TOKEN_KEY = "tokenPhone";
+    /**
+     * Token 刷新时间(单位: 毫秒)
+     */
+    public static final long TOKEN_REFRESH_TIME_MILLIS = 1000 * 60 * 60 * 2L;
+    /**
+     * token 有效期(单位: 毫秒)
+     */
+    public static final long TOKEN_EXPIRE_TIME_MILLIS = 1000 * 60 * 60 * 24 * 30L;
+
+
+
+
+
+}

src/main/java/com/jkcredit/invoice/credit/InterfaceCheckServer.java

@@ -0,0 +1,107 @@
+package com.jkcredit.invoice.credit;
+
+import com.jkcredit.invoice.common.DataResult;
+import com.jkcredit.invoice.credit.custInterface.CustomerInterLowerService;
+import com.jkcredit.invoice.credit.custInterface.NoCarInterService;
+import com.jkcredit.invoice.credit.custInterface.SelfCarInterService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+
+@Service("interfaceCheckServer")
+public class InterfaceCheckServer {
+
+
+     @Autowired
+     CustomerInterLowerService customerInterLowerService;
+
+     @Autowired
+     SelfCarInterService selfCarInterService;
+     @Autowired
+     NoCarInterService noCarInterService;
+
+      DataResult result = null;
+
+    //跳转到对应的Service服务处理逻辑
+    public  DataResult doJumpHandler(String appKey, String api, String data,String requestid ) {
+        switch (api){
+
+            //----------------------------自有车、无车公共接口---------------------------------//
+            case "COMPANY_ADD_V1"://无车、自有车企业注册
+                result = customerInterLowerService.customeInterRec(appKey,api,data,requestid);
+                break;
+            case "COMPANY_QUERY_V1"://无车、自有车企业查询
+                result = customerInterLowerService.customeInterRecQuery(appKey,api,data,requestid);
+                break;
+
+
+
+                //----------------------------自有车下游接口---------------------------------//
+            case "CARD_BIND_QUERY_LIST_V1"://自有车 用户卡列表查询
+                result = selfCarInterService.customerETCQuery(appKey,api,data,requestid);
+                break;
+            case "CARD_QUERY_CARD_V1"://自有车 卡信息查询
+                result = selfCarInterService.customerQueryEtcInfo(appKey,api,data,requestid);
+                break;
+            case "CARD_BINDING_V1"://自有车 下发短信验证码
+                result = selfCarInterService.customerETCRec(appKey,api,data,requestid);
+                break;
+            case "CARD_VALID_CODE_V1"://自有车 卡绑定接口 渠道调用此接口，上传用户收到的短信验证码
+                result = selfCarInterService.customerETCRecValid(appKey,api,data,requestid);
+                break;
+            case "CARD_TRADE_V1"://自有车 交易查询接口 渠道通过此接口可以查询单张卡连续90天内的交易（待开票、开票中、已开票）
+                result = selfCarInterService.getTradeList(appKey,api,data,requestid);
+                break;
+            case "B2B_INVOICE_APPLY_V1"://自有车 申请开票接口 渠道通过此接口可以对该公司绑定的单张卡连续90天内的交易进行开票。
+                result = selfCarInterService.applInvoice(appKey,api,data,requestid);
+                break;
+            case "B2B_INVOICE_QUERY_V1"://自有车 已开发票查询接口 渠道通过此接口可以根据该公司绑定的单张卡查询此卡在某个月开具的发票。
+                result = selfCarInterService.getSelfCarInvoicesByTime(appKey,api,data,requestid);
+                break;
+            case "B2B_INVOICE_PACKAGE_V1"://自有车 发票下载 渠道通过此接口可以下载某公司某个月份开具的发票。
+                result = selfCarInterService.getSelfCarInvoicePackage(appKey,api,data,requestid);
+                break;
+            case "CARD_UNBIND_V1"://自有车 卡解绑接口。
+                result = selfCarInterService.customerCarUnRec(appKey,api,data,requestid);
+                break;
+
+
+
+
+            //----------------------------无车下游接口---------------------------------//
+            case "VEHICLE_REGISTER"://无车 车辆备案接口
+                result = noCarInterService.customerCarRec(appKey,api,data,requestid);
+                break;
+            case "VEHICLE_REGISTER_QUERY"://无车 车辆备案查询接口
+                result = noCarInterService.customeRecUpperQuery(appKey,api,data,requestid);
+                break;
+            case "WAY_BILL_START"://无车 实时运单开始指令
+                result = noCarInterService.noCarBillStart(appKey,api,data,requestid);
+                break;
+            case "WAY_BILL_END"://无车 实时运单结束指令
+                result = noCarInterService.noCarBillEnd(appKey,api,data,requestid);
+                break;
+            case "WAY_BILL_HISTORY_START"://无车 历史运单开始指令
+                result = noCarInterService.noCarHisWaybillStart(appKey,api,data,requestid);
+                break;
+            case "WAY_BILL_HISTORY_END"://无车 历史运单结束指令
+                result = noCarInterService.noCarHisWaybillEnd(appKey,api,data,requestid);
+                break;
+            case "WAY_BILL_NUM_FIND_INVOICE"://无车  运单号查询发票数据
+                result = noCarInterService.noCarVoiceQuery(appKey,api,data,requestid);
+                break;
+            case "FIND_NO_SEARCH_NUM"://无车  获取未查询过发票的运单编号
+                result = noCarInterService.noCarNoVoiceQuery(appKey,api,data,requestid);
+                break;
+            case "BALANCE_QUERY"://无车   账号余额查询接口
+                result = noCarInterService.balanceQuery(appKey,api,data,requestid);
+                break;
+            default:
+                result = null;
+                break;
+        }
+
+        return result;
+
+    }
+}

src/main/java/com/jkcredit/invoice/credit/SimpleCORSFilter.java

@@ -0,0 +1,374 @@
+package com.jkcredit.invoice.credit;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.jkcredit.invoice.common.ApiResult;
+import com.jkcredit.invoice.common.DataResult;
+import com.jkcredit.invoice.common.ResponseCode;
+import com.jkcredit.invoice.model.entity.customer.Customer;
+import com.jkcredit.invoice.service.customer.CustomerService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.*;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.math.BigDecimal;
+import java.net.URLDecoder;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * @Description: 跨域请求拦截器
+ * @Author: mashengyi
+ * @Date: 2021/9/12
+ */
+@Slf4j
+public class SimpleCORSFilter implements Filter {
+
+    @Autowired
+    CustomerService customerService;
+
+    @Autowired
+    InterfaceCheckServer interfaceCheckServer;
+
+
+    String api = "";
+    String appKey = "";
+    String appSecret = "";
+    String data = "";
+
+
+
+    //全局定义ApiConstant
+    private final static Map<String, String> apiMaps=new HashMap<String, String>(){
+        {
+
+
+            //无车、自有车 公共下游客户调用接口
+            put( "COMPANY_ADD_V1" ,  "1");//自有车 无车、企业注册
+            put( "COMPANY_QUERY_V1" ,  "1");//自有车 无车、企业查询
+
+            //无车下游客户调用接口
+            put( "VEHICLE_REGISTER" ,  "1");//车辆备案
+            put( "VEHICLE_REGISTER_QUERY" ,  "1");//车辆备案查询
+            put( "WAY_BILL_START" ,  "1");// 实时运单开始指令
+            put( "WAY_BILL_END" ,  "1");//实时运单结束指令
+            put( "WAY_BILL_HISTORY_START" ,  "1");//历史运单开始指令
+            put( "WAY_BILL_HISTORY_END" ,  "1");// 历史运单结束指令
+            put( "WAY_BILL_NUM_FIND_INVOICE" ,  "1");// 运单号查询发票数据
+            put( "FIND_NO_SEARCH_NUM" ,  "1");//获取未查询过发票的运单编号
+            put( "BALANCE_QUERY" ,  "1");//账号余额查询
+
+
+            //自有车下游客户调用接口
+            put( "CARD_BIND_QUERY_LIST_V1" ,  "1"); //用户卡列表查询
+            put( "CARD_QUERY_CARD_V1" ,  "1");//卡信息查询
+            put( "CARD_BINDING_V1" ,  "1");//下发短信验证码
+            put( "CARD_VALID_CODE_V1" ,  "1");//自有车卡绑定接口、自有车输入参数接口
+            put( "CARD_TRADE_V1" ,  "1");//交易查询
+            put( "B2B_INVOICE_APPLY_V1" ,  "1");//申请开票
+            put( "B2B_INVOICE_QUERY_V1" ,  "1");//已开发票查询
+            put( "B2B_INVOICE_PACKAGE_V1" ,  "1");//发票下载
+            put( "CARD_UNBIND_V1" ,  "1");//卡解绑
+        }
+    };
+
+
+
+    /**
+     * 不需要 Token 校验的接口
+     */
+    private final static String[] NO_TOKEN_API_PATHS ={
+            "/**/favicon.ico",
+            "/swagger-ui.html",
+            "/webjars/**",
+            "/webjars/springfox-swagger-ui/springfox.css",
+            "/webjars/springfox-swagger-ui/springfox.js",
+            "/webjars/springfox-swagger-ui/swagger-ui-bundle.js",
+            "/webjars/springfox-swagger-ui/swagger-ui.css",
+            "/webjars/springfox-swagger-ui/swagger-ui-standalone-preset.js",
+            "/swagger-resources/configuration/ui",
+            "/swagger-resources/configuration/security",
+            "/swagger-resources",
+            "/v2/api-docs",
+            "/customer/findCustomer",
+            "/customer/findCustomerRecharge",
+            "/customer/findCustomerRecList",
+            "/customer/addCustomer",
+            "/customer/updateCustomer",
+            "/customer/addCustomer",
+            "/customer/customeRecStop",
+            "/customer/customerRecAdd",
+            "/customer/customRecharge",
+            "/customer/customeRec",
+            "/customer/contractAdd",
+            "/customer/contractDownload",
+            "/customer/generateWord",
+            "/customer/findCustomerRecTimeList",
+            "/customer/findCustomerMoney",
+            "/customer/customeRecQueryListByPage",
+            "/noCar/findCarRec",
+            "/noCar/findBillWay",
+            "/noCar/updateStatus",
+            "/noCar/findBillWayException",
+            "/noCar/findNocarInvoices",
+            "/noCar/findNocarCalculateInfo",
+            "/selfCar/selfCarUnBind",
+            "/selfCar/findTrades",
+            "/selfCar/findSelfCarInvoices",
+            "/selfCar/findSelfcarCalculateInfo",
+            "/selfCar/findSelfcarCalculateInfoSta",
+            "/selfCar/getTradeList",
+            "/selfCar/applTradeList",
+            "/selfCar/findSelfcarInvoiceByTime",
+            "/param",
+            "/param/page",
+            "/param/updateParam",
+            "/lowerService/customeRec",
+            "/lowerService/customeRecQueryList",
+            "/lowerService/customeRecQueryUpper",
+            "/lowerService/customeRecQuery",
+            "/noCarService/noCarBillStart",
+            "/noCarService/noCarBillEnd",
+            "/noCarService/noCarHisWaybillStart",
+            "/noCarService/noCarHisWaybillEnd",
+            "/noCarService/noCarVoiceQuery",
+            "/noCarService/hCVoiceQuery",
+            "/noCarService/monthAccQuery",
+            "/noCarService/customerCarRec",
+            "/noCarService/customeRecUpperQuery",
+            "/noCarService/customerCarRecQuery",
+            "/selfCarService/getTradeList",
+            "/selfCarService/applInvoice",
+            "/selfCarService/getSelfCarInvoicesByTime",
+            "/selfCarService/getSelfCarInvoicePackage",
+            "/selfCarService/getSelfCarInvoicesByAppl",
+            "/selfCarService/customerETCQuery",
+            "/selfCarService/queryEtcInfo",
+            "/selfCarService/customerETCRec",
+            "/selfCarService/customerETCRecValid",
+            "/selfCarService/customerCarUnRec",
+            "/auth/login",
+            "/role/list",
+            "/user",
+            "/user/updateUser",
+            "/user/page",
+            "/user/restPassword",
+            "/user/lock"
+    };
+
+    @Override
+    public void init(FilterConfig filterConfig) throws ServletException {
+
+    }
+
+    @Override
+    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
+
+        HttpServletRequest httpRequest = (HttpServletRequest) servletRequest;
+        HttpServletResponse httpResponse = (HttpServletResponse) servletResponse;
+        // *表示允许所有域名跨域
+        //httpResponse.addHeader("Access-Control-Allow-Origin", "'*");
+        //httpResponse.addHeader("Access-Control-Allow-Headers","*");
+        // 允许跨域的Http方法
+        httpResponse.addHeader("Access-Control-Allow-Methods", "GET,HEAD,POST,PUT,PATCH,DELETE,OPTIONS,TRACE");
+        // 允许浏览器访问 Token 认证响应头
+        //httpResponse.addHeader("Access-Control-Expose-Headers", TokenConst.TOKEN_HEADERS_FIELD);
+        // 默认返回原 Token
+        //httpResponse.setHeader(TokenConst.TOKEN_HEADERS_FIELD, httpRequest.getHeader(TokenConst.TOKEN_HEADERS_FIELD));
+        // 应对探针模式请求(OPTIONS)
+        String methodOptions = "OPTIONS";
+        if (httpRequest.getMethod().equals(methodOptions)) {
+            httpResponse.setStatus(HttpServletResponse.SC_ACCEPTED);
+            return;
+        }
+        /**
+         * 校验用户 Token
+         */
+
+        boolean flag = (!Arrays.asList(NO_TOKEN_API_PATHS).contains(httpRequest.getRequestURI()));
+        if(httpRequest.getRequestURI().contains("/user/")){
+            flag = false;
+        }
+        if (flag) {
+
+            long startTime = System.currentTimeMillis();
+            String flagUuid = UUID.randomUUID().toString();
+
+            ResponseCode responseCode = checkToken(httpRequest, httpResponse,startTime,flagUuid);
+            if (!Objects.equals(responseCode, ResponseCode.SUCCESS)) {
+                log.warn("SimpleCORSFilterWarn = {}", responseCode);
+                //httpResponse.setStatus(HttpServletResponse.SC_BAD_REQUEST);
+                httpResponse.setContentType("application/json; charset=utf-8");
+                httpResponse.setCharacterEncoding("utf-8");
+                PrintWriter writer = httpResponse.getWriter();
+                writer.write(new ObjectMapper().writeValueAsString(ApiResult.failure(responseCode)));
+                log.info("[-SimpleCORSFilter-] return result=" + responseCode.toString() + " , param is api="+  api + " , data=" + data + " , appKey=" + appKey + " , appSecret=" + appSecret +  " ,timeCost=" +(System.currentTimeMillis()-startTime) + "ms" +" , flag=" + flagUuid);
+                return;
+            }else{
+
+                // 创建客户唯一标识ID，以当前时间作为前缀，uuid为后缀
+                String requestid = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date()) + ","
+                        + UUID.randomUUID().toString();
+
+                DataResult dataResult =  interfaceCheckServer.doJumpHandler(appKey,api,data,requestid);
+                if(null == dataResult){
+                    dataResult.setData(3);
+                    dataResult.setCode(200);
+                    dataResult.setRequestid(requestid);
+                    dataResult.setMsg("无法认证");
+                }
+                //httpResponse.setStatus(HttpServletResponse.SC_BAD_REQUEST);
+                httpResponse.setContentType("application/json; charset=utf-8");
+                httpResponse.setCharacterEncoding("utf-8");
+                PrintWriter writer = httpResponse.getWriter();
+                writer.write(new ObjectMapper().writeValueAsString(ApiResult.failure(dataResult)));
+                log.info("[-SimpleCORSFilter-] return result=" + dataResult.toString() + " , param is api="+  api + " , data=" + data + " , appKey=" + appKey + " , appSecret=" + appSecret +  " ,timeCost=" +(System.currentTimeMillis()-startTime) + "ms" +" , flag=" + flagUuid);
+                return;
+            }
+        }
+
+        filterChain.doFilter(httpRequest, servletResponse);
+    }
+
+
+
+    @Override
+    public void destroy() {
+
+    }
+
+    private String getApi(String request){
+        String api = "";
+        Pattern p=Pattern.compile("api=(\\w+)&");
+        Matcher m=p.matcher(request);
+        while(m.find()){
+            api = m.group(1);
+        }
+        return  api;
+    }
+    private String getAppKey(String request){
+        String appkey = "";
+        Pattern p=Pattern.compile("appKey=(\\w+)&");
+        Matcher m=p.matcher(request);
+        while(m.find()){
+            appkey = m.group(1);
+        }
+        return  appkey;
+    }
+    private String getAppSecret(String request){
+        String appSecret = "";
+        Pattern p=Pattern.compile("appSecret=(\\w+)&");
+        Matcher m=p.matcher(request);
+        while(m.find()){
+            appSecret = m.group(1);
+        }
+        return  appSecret;
+    }
+    private String getData(String request){
+        String data = "";
+        Pattern p=Pattern.compile("data=([^&]*)&");
+        Matcher m=p.matcher(request);
+        while(m.find()){
+            data = m.group(1);
+        }
+        return  data;
+    }
+    /**
+     * 用户 Token 校验
+     *
+     * @param request
+     * @param response
+     * @return
+     */
+    private ResponseCode checkToken(HttpServletRequest request, HttpServletResponse response,long startTime,String flag) {
+        try {
+
+
+            if(!request.getQueryString().equals("api=credit.sec.data")){
+                return ResponseCode.UNKNOWN_ERROR;
+            };
+
+
+            String jsonObject1 = getOpenApiRequestData(request);
+            api = getApi(jsonObject1);
+            appKey = getAppKey(jsonObject1);
+            appSecret = getAppSecret(jsonObject1);
+            data = getData(jsonObject1);
+            log.info("[-SimpleCORSFilter-] query param api=" + api + " , data=" + data + " , appKey=" + appKey + " , appSecret=" + appSecret + " , flag=" + flag);
+            if (StringUtils.isEmpty(api) || StringUtils.isEmpty(data) || StringUtils.isEmpty(appKey) || StringUtils.isEmpty(appSecret)) {
+                return ResponseCode.UNKNOWN_ERROR;
+            }
+
+
+            Customer customer = new Customer();
+            customer.setCustomerName(appKey);
+            customer.setAppSecret(appSecret);
+            Customer customer1 = customerService.getCustomerByAppKeyAndAppSecret(customer);
+
+            if (null == customer1 || customer1.getAccstatus() != 0) {
+                return ResponseCode.ACCOUNT_NOT_EXIST;
+            }
+            if(null != customer1 && ! appSecret.equals(customer1.getAppSecret())){
+                return ResponseCode.SIGN_ERROR;
+            }
+            if (0 == new BigDecimal(customer1.getAccountBalance()).compareTo(new BigDecimal(0.0))) {
+                return ResponseCode.BALANCE_QUERY_ERROR;
+            }
+            if(!apiMaps.containsKey(api)){
+                return ResponseCode.API_QUERY_ERROR;
+            }
+
+        } catch (Exception e) {
+            log.error("Token 校验失败,{}:{}", e.getClass().getName(), e.getMessage());
+            return ResponseCode.MEDIA_TYPE_NOT_SUPPORT_ERROR;
+        }
+        return ResponseCode.SUCCESS;
+    }
+
+
+
+
+    public  String getOpenApiRequestData(HttpServletRequest request){
+        String str = "";
+        try {
+
+            request.setCharacterEncoding("UTF-8");
+
+            int contentLength = request.getContentLength();
+
+            if (contentLength < 0) {
+                return null;
+            }
+            byte buffer[] = new byte[contentLength];
+            for (int i = 0; i < contentLength;) {
+
+                int readlen = request.getInputStream().read(buffer, i, contentLength - i);
+                if (readlen == -1) {
+                    break;
+                }
+                i += readlen;
+            }
+
+            String charEncoding = request.getCharacterEncoding();
+            if (charEncoding == null) {
+                charEncoding = "UTF-8";
+            }
+            str = new String(buffer, charEncoding)+"&";
+            str = URLDecoder.decode(str, "UTF-8");
+
+
+            return str;
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return null;
+    }
+}

src/main/java/com/jkcredit/invoice/credit/custInterface/CustomerInterLowerService.java

@@ -0,0 +1,14 @@
+package com.jkcredit.invoice.credit.custInterface;
+
+import com.jkcredit.invoice.common.DataResult;
+
+public interface CustomerInterLowerService {
+
+    //自有车、无车 客户企业备案接口；
+    DataResult customeInterRec(String appKey, String api, String data,String requestid);
+
+
+    //自有车、无车 客户企业查询接口；
+    DataResult customeInterRecQuery(String appKey, String api, String data,String requestid);
+
+}

src/main/java/com/jkcredit/invoice/credit/custInterface/CustomerInterLowerServiceImpl.java

@@ -0,0 +1,216 @@
+package com.jkcredit.invoice.credit.custInterface;
+
+import com.alibaba.fastjson.JSONObject;
+import com.jkcredit.invoice.common.DataResult;
+import com.jkcredit.invoice.common.ResponseCode;
+import com.jkcredit.invoice.model.entity.customer.CustomerRec;
+import com.jkcredit.invoice.service.customer.CustomerService;
+import com.jkcredit.invoice.service.lowerService.CustomeLowerService;
+import com.jkcredit.invoice.util.RespR;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.UUID;
+
+
+@Slf4j
+@Service("customerInterLowerService")
+public class CustomerInterLowerServiceImpl implements CustomerInterLowerService {
+
+    @Autowired
+    CustomeLowerService lowerService;
+
+    @Autowired
+    CustomerService customerService;
+
+
+    /**
+     * 无车 自有车 企业注册
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customeInterRec(String appKey, String api, String data,String requestid) {
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-CustomerInterLowerServiceImpl.customeInterRec-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+
+            Integer interType =  0;//0-接口 1-平台 3.手工录入
+
+            String  name = jsonObject.getString("name");//公司名称 companyName
+            String  taxpayerCode = jsonObject.getString("taxpayerCode");//企业税号 companyReferencenum
+            String  customerName = appKey;//客户名称
+
+            /**
+             * 所属类型：
+             *1-行业用户  2-自营平台 3-合作商户
+             */
+            Integer  companyType = jsonObject.getInteger("companyType");
+            /**
+             * 运用类型:
+             * 1-快递
+             2-速运
+             3-货运代理
+             4-普通货运
+             5-专线运输
+             6-其他
+             * 运营范围
+             */
+            Integer  operatingRangeType = jsonObject.getInteger("operatingRangeType");
+            String  emergencyContact = jsonObject.getString("emergencyContact");//紧急联系人  companyLeader
+            String  emergencyTel = jsonObject.getString("emergencyTel");//紧急联系人电话 companyLeaderPhone
+
+            String  companyOpenbank = jsonObject.getString("companyOpenbank");//公司开户行
+            String  companyOpenbankAcc = jsonObject.getString("companyOpenbankAcc");//公司开户行电话
+            String  companyAdress = jsonObject.getString("companyAdress");//公司地址
+            String  companyPhone = jsonObject.getString("companyPhone");//公司电话
+            String  bussinessType = jsonObject.getString("bussinessType");//业务类型 0 -自有车 1-外协车 2-无车
+
+
+
+            String  serviceStartTime = jsonObject.getString("serviceStartTime");//服务开始时间
+            String  serviceEndTime = jsonObject.getString("serviceEndTime");//服务结束时间
+            Integer  serviceType = jsonObject.getInteger("serviceType");//协议类型
+            String  contractFileName = jsonObject.getString("contractFileName");//协议文件名
+            String  base64Str = jsonObject.getString("base64Str");//协议base64编码
+
+
+
+            if(StringUtils.isEmpty(data)|| null == jsonObject
+                    || StringUtils.isEmpty(name)
+                    || StringUtils.isEmpty(taxpayerCode)
+                    || StringUtils.isEmpty(customerName)
+                    || null == companyType
+                    || null == operatingRangeType
+                    || StringUtils.isEmpty(emergencyContact)
+                    || StringUtils.isEmpty(emergencyTel)
+                    || StringUtils.isEmpty(companyOpenbank)
+                    || StringUtils.isEmpty(companyOpenbankAcc)
+                    || StringUtils.isEmpty(companyAdress)
+                    || StringUtils.isEmpty(companyPhone)
+                    || StringUtils.isEmpty(bussinessType)
+                    || StringUtils.isEmpty(serviceStartTime)
+                    || StringUtils.isEmpty(serviceEndTime)
+                    || null == serviceType
+                    || StringUtils.isEmpty(contractFileName)
+                    || StringUtils.isEmpty(base64Str)
+                    ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(customerName);//客户名称
+            customerRec.setCompanyLeader(emergencyContact);//紧急联系人
+            customerRec.setCompanyLeaderPhone(emergencyTel);//紧急联系人电话
+            customerRec.setCompanyName(name);//企业名称
+            customerRec.setCompanyReferencenum(taxpayerCode);//企业税号
+            customerRec.setCompanyOpenbank(companyOpenbank);//公司开户行
+            customerRec.setCompanyOpenbankAcc(companyOpenbankAcc);//公司开户行电话
+            customerRec.setCompanyAdress(companyAdress);//公司地址
+            customerRec.setCompanyPhone(companyPhone);//公司电话
+            customerRec.setInterType(interType);////0-接口 1-平台 3.手工录入
+            customerRec.setBussinessType(bussinessType);//业务类型 0 -自有车 1-外协车 2-无车
+            customerRec.setOperatingRangeType(operatingRangeType);//运用类型
+            customerRec.setCompanyType(companyType);//所属类型
+            customerRec.setServiceStartTime(serviceStartTime);//服务开始时间
+            customerRec.setServiceEndTime(serviceEndTime);//服务结束时间
+            customerRec.setServiceType(serviceType);//协议类型
+            customerRec.setContractFileName(contractFileName);//协议名称
+            customerRec.setBase64Str(base64Str);//协议base64编码
+
+            List<CustomerRec> customerRecs = new ArrayList<CustomerRec>();
+            customerRecs.add(customerRec);
+            RespR rs = lowerService.customeRec(customerRecs);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-CustomerInterLowerServiceImpl.customeInterRec-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getMsg());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-CustomerInterLowerServiceImpl.customeInterRec-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+    /**
+     * 无车 自有车企业查询
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customeInterRecQuery(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+        log.info("[-CustomerInterLowerServiceImpl.customeInterRecQuery-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+        JSONObject jsonObject = JSONObject.parseObject(data);
+        String companyName =  jsonObject.getString("companyName");//企业名称
+        String taxpayerCode = jsonObject.getString("taxpayerCode");//企业税号
+        if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyName) || StringUtils.isEmpty(taxpayerCode)){
+            return  result;
+        }
+
+
+        CustomerRec customerRec = new CustomerRec();
+        customerRec.setCompanyName(companyName);
+        customerRec.setCompanyReferencenum(taxpayerCode);
+        RespR rs = customerService.customerRecQuery(customerRec);
+        long costtimeend = System.currentTimeMillis();
+        log.info("[-CustomerInterLowerServiceImpl.customeInterRecQuery-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+        if(null != rs && rs.getCode() == 0){
+           result.setData(1);
+           result.setCode(200);
+           result.setMsg(rs.getData().toString());
+           return result;
+        } else {
+            result.setData(3);
+            result.setCode(200);
+            result.setMsg("无法认证");
+            return result;
+        }
+        } catch (Exception e) {
+            log.error("[-CustomerInterLowerServiceImpl.customeInterRecQuery-] get httpclient exception is "
+                            + e + ", request is " + data);
+        }
+        return result;
+    }
+}

src/main/java/com/jkcredit/invoice/credit/custInterface/NoCarInterService.java

@@ -0,0 +1,33 @@
+package com.jkcredit.invoice.credit.custInterface;
+
+import com.jkcredit.invoice.common.DataResult;
+
+public interface NoCarInterService {
+
+    //无车 车辆备案接口
+    DataResult customerCarRec(String appKey, String api, String data, String requestid);
+
+    //无车 车辆备案查询接口
+    DataResult customeRecUpperQuery(String appKey, String api, String data, String requestid);
+
+    //无车 实时运单开始指令
+    DataResult noCarBillStart(String appKey, String api, String data, String requestid);
+
+    //无车 实时运单结束指令
+    DataResult noCarBillEnd(String appKey, String api, String data, String requestid);
+
+    //无车 历史运单开始指令
+    DataResult noCarHisWaybillStart(String appKey, String api, String data, String requestid);
+
+    //无车 历史运单结束指令
+    DataResult noCarHisWaybillEnd(String appKey, String api, String data, String requestid);
+
+    //无车  运单号查询发票数据
+    DataResult noCarVoiceQuery(String appKey, String api, String data, String requestid);
+
+    //无车  获取未查询过发票的运单编号
+    DataResult noCarNoVoiceQuery(String appKey, String api, String data, String requestid);
+
+    //无车 账户余额查询接口
+    DataResult balanceQuery(String appKey, String api, String data, String requestid);
+}

src/main/java/com/jkcredit/invoice/credit/custInterface/NoCarInterServiceImpl.java

@@ -0,0 +1,777 @@
+package com.jkcredit.invoice.credit.custInterface;
+
+import cn.com.taiji.sdk.model.comm.protocol.tts.trade.service.CardTradeModel;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.jkcredit.invoice.common.DataResult;
+import com.jkcredit.invoice.mapper.Binvoce.BillInvoiceMapper;
+import com.jkcredit.invoice.mapper.customer.CustomerCarRecMapper;
+import com.jkcredit.invoice.mapper.customer.CustomerMapper;
+import com.jkcredit.invoice.mapper.customer.CustomerRecMapper;
+import com.jkcredit.invoice.mapper.waybill.NoCarWaybillMapper;
+import com.jkcredit.invoice.model.entity.customer.Customer;
+import com.jkcredit.invoice.model.entity.customer.CustomerCarRec;
+import com.jkcredit.invoice.model.entity.customer.CustomerRec;
+import com.jkcredit.invoice.model.entity.invoice.BillInvoice;
+import com.jkcredit.invoice.model.entity.waybill.NoCarWayBill;
+import com.jkcredit.invoice.service.lowerService.NoCarService;
+import com.jkcredit.invoice.service.lowerService.SelfCarServiceL;
+import com.jkcredit.invoice.service.lowerService.vo.*;
+import com.jkcredit.invoice.util.RespR;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static java.util.stream.Collectors.toList;
+
+
+@Slf4j
+@Service("noCarInterService")
+public class NoCarInterServiceImpl implements NoCarInterService {
+
+    @Autowired
+    private NoCarService noCarService;
+
+    @Autowired
+    CustomerCarRecMapper customerCarRecMapper;
+
+    @Autowired
+    NoCarWaybillMapper noCarWaybillMapper;
+
+
+    @Autowired
+    BillInvoiceMapper billInvoiceMapper;
+
+
+    @Autowired
+    CustomerMapper customerMapper;
+
+
+    /**
+     * 无车 车辆备案接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customerCarRec(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.customerCarRec-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyName =  jsonObject.getString("companyName");//企业名称 选输
+            String plateNumber =  jsonObject.getString("plateNumber");//plateNumber 必输
+            String plateColor =  jsonObject.getString("plateColor");//plateColor 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(plateNumber)
+                    || StringUtils.isEmpty(plateColor)
+
+            ){
+                return  result;
+            }
+
+            CustomerCarRec customerCarRec1 = customerCarRecMapper.selectByCarNum(plateNumber);
+
+            if (null == customerCarRec1){
+                return result;
+            }
+
+            List<CustomerCarRec> customerCarRecList = new ArrayList<CustomerCarRec>();
+            CustomerCarRec customerCarRec = new CustomerCarRec();
+            customerCarRec.setCustomerName(appKey);
+            if(StringUtils.isEmpty(companyName)){
+                customerCarRec.setCompanyName(customerCarRec1.getCompanyName());
+            }else {
+                customerCarRec.setCompanyName(companyName);
+            }
+
+            customerCarRec.setBusinessType(customerCarRec1.getBusinessType());
+            customerCarRec.setCarColor(plateColor);
+            customerCarRec.setCarNum(plateNumber);
+            customerCarRec.setServiceOperation(customerCarRec1.getServiceOperation());
+
+            customerCarRecList.add(customerCarRec);
+
+            RespR rs = noCarService.customerCarRec(customerCarRecList);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.customerCarRec-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.customerCarRec-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+    /**
+     * 无车 车辆备案查询接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customeRecUpperQuery(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.customeRecUpperQuery-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String waybillSource =  jsonObject.getString("waybillSource");//备案来源 选输
+            String plateNumber =  jsonObject.getString("plateNumber");//plateNumber 必输
+            String plateColor =  jsonObject.getString("plateColor");//plateColor 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(plateNumber)
+                    || StringUtils.isEmpty(plateColor)
+
+            ){
+                return  result;
+            }
+
+            CustomerCarRec customerCarRec1 = customerCarRecMapper.selectByCarNum(plateNumber);
+            if (null == customerCarRec1){
+                return result;
+            }
+
+            CustomerCarRec customerCarRec = new CustomerCarRec();
+
+            customerCarRec.setCompanyNum(customerCarRec1.getCompanyNum());
+            customerCarRec.setCarColor(plateColor);
+            customerCarRec.setCarNum(plateNumber);
+            customerCarRec.setCustomerName(appKey);
+            customerCarRec.setCompanyName(customerCarRec1.getCompanyName());
+
+            RespR rs = noCarService.customerCarRecQueryUpper(customerCarRec);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.customeRecUpperQuery-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.customeRecUpperQuery-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 无车 实时运单开始指令接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult noCarBillStart(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.noCarBillStart-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String num =  jsonObject.getString("num");//运单编号 必选
+            String plateNumber =  jsonObject.getString("plateNumber");//车牌号 必选
+            String plateColor =  jsonObject.getString("plateColor");//车牌颜色 必选
+            String startTime =  jsonObject.getString("startTime");//运单开始时间 必选
+            String sourceAddr =  jsonObject.getString("sourceAddr");//运单开始地址 必选
+            String destAddr =  jsonObject.getString("destAddr");//运单目的地址 必选
+            String predictEndTime =  jsonObject.getString("predictEndTime");//运单预计完成时间 必选
+            Integer fee =  jsonObject.getInteger("fee");//运单费用 必选
+            Integer titleType =  jsonObject.getInteger("titleType");//发票抬头类型 必选
+            String taxplayerCode =  jsonObject.getString("taxplayerCode");//税号 必选
+            if(StringUtils.isEmpty(data)|| null == jsonObject
+                    || StringUtils.isEmpty(num)
+                    || StringUtils.isEmpty(plateNumber)
+                    || StringUtils.isEmpty(plateColor)
+                    || StringUtils.isEmpty(startTime)
+                    || StringUtils.isEmpty(sourceAddr)
+                    || StringUtils.isEmpty(destAddr)
+                    || StringUtils.isEmpty(predictEndTime)
+                    || null == fee
+                    || null == titleType
+                    || StringUtils.isEmpty(taxplayerCode)
+
+            ){
+                return  result;
+            }
+
+            CustomerCarRec customerCarRec1 = customerCarRecMapper.selectByCarNum(plateNumber);
+            if (null == customerCarRec1){
+                return result;
+            }
+
+            NoCarWayBill noCarWayBill = new NoCarWayBill();
+            noCarWayBill.setStartTime(startTime);
+            noCarWayBill.setCustomerName(appKey);
+            noCarWayBill.setCompanyName(customerCarRec1.getCompanyName());
+            noCarWayBill.setPlateNum(plateNumber);
+            noCarWayBill.setBillNum(num);
+            noCarWayBill.setPlateColor(plateColor);
+            noCarWayBill.setStartTime(startTime);
+            noCarWayBill.setSourceAddr(sourceAddr);
+            noCarWayBill.setDestAddr(destAddr);
+            noCarWayBill.setPredictEndTime(predictEndTime);
+            noCarWayBill.setFee(fee.longValue());
+            noCarWayBill.setTitleType(titleType);
+            noCarWayBill.setTaxplayerCode(taxplayerCode);
+
+
+            RespR rs = noCarService.noCarWaybillStart(noCarWayBill);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.noCarBillStart-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.noCarBillStart-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+    /**
+     * 无车 实时运单结束指令接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult noCarBillEnd(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.noCarBillEnd-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String num =  jsonObject.getString("num");//运单号 必输
+            String realDestAddr =  jsonObject.getString("realDestAddr");//运单实际目的地址 必输
+            String endTime =  jsonObject.getString("endTime");//运单实际结束时间 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(num)
+                    || StringUtils.isEmpty(realDestAddr)
+                    || StringUtils.isEmpty(endTime)
+
+            ){
+                return  result;
+            }
+
+
+            NoCarWayBill noCarWayBill1 = noCarWaybillMapper.selectByBillNum(num);
+            if (null == noCarWayBill1){
+                return result;
+            }
+
+
+            NoCarWayBill noCarWayBill = new NoCarWayBill();
+            noCarWayBill.setBillNum(num);
+            noCarWayBill.setDestAddr(realDestAddr);
+            noCarWayBill.setPredictEndTime(endTime);
+            noCarWayBill.setStartTime(noCarWayBill1.getStartTime());
+            noCarWayBill.setHisFlag(noCarWayBill1.getHisFlag());
+
+            RespR rs = noCarService.noCarWaybillEnd(noCarWayBill);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.noCarBillEnd-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.noCarBillEnd-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+    /**
+     * 无车 历史运单开始指令接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult noCarHisWaybillStart(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.noCarHisWaybillStart-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String num =  jsonObject.getString("num");//运单编号 必选
+            String plateNumber =  jsonObject.getString("plateNumber");//车牌号 必选
+            String plateColor =  jsonObject.getString("plateColor");//车牌颜色 必选
+            String startTime =  jsonObject.getString("startTime");//运单开始时间 必选
+            String sourceAddr =  jsonObject.getString("sourceAddr");//运单开始地址 必选
+            String destAddr =  jsonObject.getString("destAddr");//运单目的地址 必选
+            String predictEndTime =  jsonObject.getString("predictEndTime");//运单预计完成时间 必选
+            Integer fee =  jsonObject.getInteger("fee");//运单费用 必选
+            Integer titleType =  jsonObject.getInteger("titleType");//发票抬头类型 必选
+            String taxplayerCode =  jsonObject.getString("taxplayerCode");//税号 必选
+            if(StringUtils.isEmpty(data)|| null == jsonObject
+                    || StringUtils.isEmpty(num)
+                    || StringUtils.isEmpty(plateNumber)
+                    || StringUtils.isEmpty(plateColor)
+                    || StringUtils.isEmpty(startTime)
+                    || StringUtils.isEmpty(sourceAddr)
+                    || StringUtils.isEmpty(destAddr)
+                    || StringUtils.isEmpty(predictEndTime)
+                    || null == fee
+                    || null == titleType
+                    || StringUtils.isEmpty(taxplayerCode)
+
+            ){
+                return  result;
+            }
+
+            CustomerCarRec customerCarRec1 = customerCarRecMapper.selectByCarNum(plateNumber);
+            if (null == customerCarRec1){
+                return result;
+            }
+
+            NoCarWayBill noCarWayBill = new NoCarWayBill();
+            noCarWayBill.setStartTime(startTime);
+            noCarWayBill.setCustomerName(appKey);
+            noCarWayBill.setCompanyName(customerCarRec1.getCompanyName());
+            noCarWayBill.setPlateNum(plateNumber);
+            noCarWayBill.setBillNum(num);
+            noCarWayBill.setPlateColor(plateColor);
+            noCarWayBill.setStartTime(startTime);
+            noCarWayBill.setSourceAddr(sourceAddr);
+            noCarWayBill.setDestAddr(destAddr);
+            noCarWayBill.setPredictEndTime(predictEndTime);
+            noCarWayBill.setFee(fee.longValue());
+            noCarWayBill.setTitleType(titleType);
+            noCarWayBill.setTaxplayerCode(taxplayerCode);
+
+
+            RespR rs = noCarService.noCarHisWaybillStart(noCarWayBill);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.noCarHisWaybillStart-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.noCarHisWaybillStart-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 无车 历史运单结束指令接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult noCarHisWaybillEnd(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.noCarHisWaybillEnd-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String num =  jsonObject.getString("num");//运单号 必输
+            String realDestAddr =  jsonObject.getString("realDestAddr");//运单实际目的地址 必输
+            String endTime =  jsonObject.getString("endTime");//运单实际结束时间 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(num)
+                    || StringUtils.isEmpty(realDestAddr)
+                    || StringUtils.isEmpty(endTime)
+
+            ){
+                return  result;
+            }
+
+
+            NoCarWayBill noCarWayBill1 = noCarWaybillMapper.selectByBillNum(num);
+            if (null == noCarWayBill1){
+                return result;
+            }
+
+
+            NoCarWayBill noCarWayBill = new NoCarWayBill();
+            noCarWayBill.setBillNum(num);
+            noCarWayBill.setDestAddr(realDestAddr);
+            noCarWayBill.setPredictEndTime(endTime);
+            noCarWayBill.setStartTime(noCarWayBill1.getStartTime());
+            noCarWayBill.setHisFlag(noCarWayBill1.getHisFlag());
+
+            RespR rs = noCarService.noCarHisWaybillEnd(noCarWayBill);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.noCarHisWaybillEnd-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.noCarHisWaybillEnd-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+    /**
+     * 无车 运单号查询发票数据
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult noCarVoiceQuery(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.noCarVoiceQuery-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String num =  jsonObject.getString("num");//运单号 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(num)
+
+            ){
+                return  result;
+            }
+
+
+            NoCarWayBill noCarWayBill1 = noCarWaybillMapper.selectByBillNum(num);
+            if (null == noCarWayBill1){
+                return result;
+            }
+
+
+            NoCarWayBill noCarWayBill = new NoCarWayBill();
+            noCarWayBill.setBillNum(num);
+            noCarWayBill.setCustomerName(appKey);
+            noCarWayBill.setCompanyName(noCarWayBill1.getCompanyName());
+            noCarWayBill.setPlateNum(noCarWayBill1.getPlateNum());
+
+
+            RespR rs = noCarService.getInvoiceByWayBillNumReal(noCarWayBill,true);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.noCarVoiceQuery-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.noCarVoiceQuery-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+
+
+    /**
+     * 无车  获取未查询过发票的运单编号
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult noCarNoVoiceQuery(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.noCarNoVoiceQuery-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+
+
+
+
+            List<NoCarWayBill> noCarWayBills = noCarWaybillMapper.getNoCarNoVoiceQuery(appKey);
+            List<String> list1 = new ArrayList<String>();
+
+            for (NoCarWayBill noCarWayBill:noCarWayBills
+                 ) {
+                list1.add(noCarWayBill.getBillNum());
+
+            }
+            List<BillInvoice>  billInvoices =  billInvoiceMapper.selectNoCarNoVoiceQuery(appKey);
+            List<String> list2 = new ArrayList<String>();
+            for (BillInvoice billInvoice:billInvoices
+            ) {
+                list2.add(billInvoice.getWaybillNum());
+
+            }
+
+            List<String> reduce1 = list1.stream().filter(item -> !list2.contains(item)).collect(toList());
+
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.noCarNoVoiceQuery-] result is "
+                    + reduce1.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != reduce1 && reduce1.size() > 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(reduce1.toString());
+                return result;
+            } else {
+                result.setData(2);
+                result.setCode(200);
+                result.setMsg("未查得");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.noCarNoVoiceQuery-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 无车  账户余额查询接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult balanceQuery(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-NoCarInterServiceImpl.balanceQuery-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+
+
+            Customer customer = customerMapper.selectByCustomerName(appKey);
+
+
+
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-NoCarInterServiceImpl.balanceQuery-] result is "
+                    + customer.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != customer){
+                result.setData(1);
+                result.setCode(200);
+                JSONObject jb = new JSONObject();
+                jb.put("balance",customer.getAccountBalance());
+                jb.put("lastDeductionTime",customer.getInvoiceTime());
+                result.setMsg(jb.toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-NoCarInterServiceImpl.balanceQuery-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+    public static void main(String[] args) {
+            List<String> list1 = new ArrayList<String>();
+            list1.add("1");
+            list1.add("2");
+            list1.add("3");
+            list1.add("5");
+            list1.add("6");
+
+            List<String> list2 = new ArrayList<String>();
+            list2.add("2");
+            list2.add("3");
+            list2.add("7");
+            list2.add("8");
+
+            // 交集
+            List<String> intersection = list1.stream().filter(item -> list2.contains(item)).collect(toList());
+            System.out.println("---交集 intersection---");
+            intersection.parallelStream().forEach(System.out :: println);
+
+            // 差集 (list1 - list2)
+            List<String> reduce1 = list1.stream().filter(item -> !list2.contains(item)).collect(toList());
+            System.out.println("---差集 reduce1 (list1 - list2)---");
+            reduce1.parallelStream().forEach(System.out :: println);    // 并集
+            List<String> listAll = list1.parallelStream().collect(toList());
+            List<String> listAll2 = list2.parallelStream().collect(toList());
+            listAll.addAll(listAll2);
+            System.out.println("---并集 listAll---");
+            listAll.parallelStream().forEachOrdered(System.out :: println);
+
+            // 去重并集
+            List<String> listAllDistinct = listAll.stream().distinct().collect(toList());
+            System.out.println("---得到去重并集 listAllDistinct---");
+            listAllDistinct.parallelStream().forEachOrdered(System.out :: println);
+
+            System.out.println("---原来的List1---");
+            list1.parallelStream().forEachOrdered(System.out :: println);
+            System.out.println("---原来的List2---");
+            list2.parallelStream().forEachOrdered(System.out :: println);
+
+    }
+
+
+}

src/main/java/com/jkcredit/invoice/credit/custInterface/SelfCarInterService.java

@@ -0,0 +1,35 @@
+package com.jkcredit.invoice.credit.custInterface;
+
+import com.jkcredit.invoice.common.DataResult;
+
+public interface SelfCarInterService {
+
+    //自有车 用户卡列表查询接口；
+    DataResult customerETCQuery(String appKey, String api, String data, String requestid);
+
+
+    //自有车 卡信息查询接口
+    DataResult customerQueryEtcInfo(String appKey, String api, String data, String requestid);
+
+    //自有车下发短信通知接口
+    DataResult customerETCRec(String appKey, String api, String data, String requestid);
+
+    //自有车 卡绑定接口 渠道调用此接口，上传用户收到的短信验证码
+    DataResult customerETCRecValid(String appKey, String api, String data, String requestid);
+
+    //自有车 交易查询接口 渠道通过此接口可以查询单张卡连续90天内的交易（待开票、开票中、已开票）
+    DataResult getTradeList(String appKey, String api, String data, String requestid);
+
+    //自有车 申请开票接口 渠道通过此接口可以对该公司绑定的单张卡连续90天内的交易进行开票。
+    DataResult applInvoice(String appKey, String api, String data, String requestid);
+
+    //自有车 已开发票查询接口 渠道通过此接口可以根据该公司绑定的单张卡查询此卡在某个月开具的发票。
+    DataResult getSelfCarInvoicesByTime(String appKey, String api, String data, String requestid);
+
+    //自有车 发票下载 渠道通过此接口可以下载某公司某个月份开具的发票。
+    DataResult getSelfCarInvoicePackage(String appKey, String api, String data, String requestid);
+
+
+    //自有车 卡解绑接口。
+    DataResult customerCarUnRec(String appKey, String api, String data, String requestid);
+}

src/main/java/com/jkcredit/invoice/credit/custInterface/SelfCarInterServiceImpl.java

@@ -0,0 +1,763 @@
+package com.jkcredit.invoice.credit.custInterface;
+
+import cn.com.taiji.sdk.model.comm.protocol.tts.trade.service.CardTradeModel;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.jkcredit.invoice.common.DataResult;
+import com.jkcredit.invoice.mapper.customer.CustomerRecMapper;
+import com.jkcredit.invoice.model.entity.customer.CustomerCarRec;
+import com.jkcredit.invoice.model.entity.customer.CustomerRec;
+import com.jkcredit.invoice.service.lowerService.SelfCarServiceL;
+import com.jkcredit.invoice.service.lowerService.vo.*;
+import com.jkcredit.invoice.service.selfCar.SelfCarService;
+import com.jkcredit.invoice.util.RespR;
+import com.mysql.cj.xdevapi.JsonArray;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+@Slf4j
+@Service("selfCarInterService")
+public class SelfCarInterServiceImpl implements SelfCarInterService {
+
+
+    @Autowired
+    SelfCarServiceL selfCarService;
+
+    @Autowired
+    CustomerRecMapper customerRecMapper;
+
+    /**
+     * 自有车 用户卡列表查询接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customerETCQuery(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+        log.info("[-SelfCarInterServiceImpl.customerETCQuery-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+        JSONObject jsonObject = JSONObject.parseObject(data);
+        String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+        String cardId = jsonObject.getString("cardId");//卡号  非必输
+        String plateNum = jsonObject.getString("plateNum");//车牌号 非必输
+        Integer plateColor = jsonObject.getInteger("plateColor");//车牌颜色 非必输
+        if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)){
+            return  result;
+        }
+
+        CustomerRec customerRec = new CustomerRec();
+        customerRec.setCustomerName(appKey);
+        customerRec.setCompanyNum(companyNum);
+        CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+
+            EtcQueryVo etcQueryVo = new EtcQueryVo();
+            etcQueryVo.setCustomerName(appKey);//客户名称
+            etcQueryVo.setCompanyName(customerRec1.getCompanyName());//企业名称
+            etcQueryVo.setPlateNum(plateNum);//车牌号 非必输
+            etcQueryVo.setCardId(cardId);//卡号 非必输
+            etcQueryVo.setPlateColor(plateColor);//车牌颜色 非必输
+        RespR rs = selfCarService.getEtcInfo(etcQueryVo);
+        long costtimeend = System.currentTimeMillis();
+        log.info("[-SelfCarInterServiceImpl.customerETCQuery-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+        if(null != rs && rs.getCode() == 0){
+           result.setData(1);
+           result.setCode(200);
+           result.setMsg(rs.getData().toString());
+           return result;
+        } else {
+            result.setData(3);
+            result.setCode(200);
+            result.setMsg("无法认证");
+            return result;
+        }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.customerETCQuery-] get httpclient exception is "
+                            + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 自有车 卡信息查询接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customerQueryEtcInfo(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.customerQueryEtcInfo-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            JSONArray vehicleList = jsonObject.getJSONArray("vehicleList");//车牌的json字符串 必输
+            //JSONObject jb = vehicleList.getJSONObject(0);
+          //  String plateNum = jb.getString("plateNum");//车牌号
+            //Integer plateColor = jb.getInteger("plateColor");//车牌颜色
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || null == vehicleList
+                     ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+
+            if (null == customerRec1){
+                return result;
+            }
+
+            EtcBindVo etcQueryVo = new EtcBindVo();
+            etcQueryVo.setCustomerName(appKey);//客户名称
+            etcQueryVo.setCompanyName(customerRec1.getCompanyName());//企业名称
+
+            List<CarVo> cards = new ArrayList<CarVo>();
+            for(int i=0;i<vehicleList.size();i++) {
+                JSONObject jb = vehicleList.getJSONObject(i);
+                String plateNum = jb.getString("plateNum");//车牌号
+                Integer plateColor = jb.getInteger("plateColor");//车牌颜色
+                if(null == jb || StringUtils.isEmpty(plateNum)
+                        || null == plateColor
+                ){
+                    return  result;
+                }
+
+                CarVo carVo = new CarVo();
+                carVo.setNum(plateNum);
+                carVo.setColor(plateColor);
+                cards.add(carVo);
+            }
+            etcQueryVo.setCards(cards);
+            RespR rs = selfCarService.queryEtcInfo(etcQueryVo);
+
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.customerQueryEtcInfo-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.customerQueryEtcInfo-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 自有车下发短信通知接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customerETCRec(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.customerETCRec-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String mobile =  jsonObject.getString("mobile");//企业预留手机号 必输
+            JSONArray cardIdList = jsonObject.getJSONArray("cardIdList");//ETC卡编号列表 必输
+            //JSONObject jb = cardIdList.getJSONObject(0);
+           // String cardId = jb.getString("cardId");//用户卡Id
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(mobile)
+                    || null == cardIdList
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            EtcBindVo etcQueryVo = new EtcBindVo();
+            etcQueryVo.setCustomerName(appKey);//客户名称
+            etcQueryVo.setCompanyName(customerRec1.getCompanyName());//企业名称
+            etcQueryVo.setMobile(mobile);//企业预留手机号
+            List<CarVo> cards = new ArrayList<CarVo>();
+            for(int i=0;i<cardIdList.size();i++) {
+                JSONObject jb = cardIdList.getJSONObject(i);
+                String cardId = jb.getString("cardId");//用户卡Id
+
+                if(null == jb || StringUtils.isEmpty(cardId)
+                ){
+                    return  result;
+                }
+
+
+                CarVo carVo = new CarVo();
+                carVo.setEtcNum(cardId);
+                cards.add(carVo);
+            }
+            etcQueryVo.setCards(cards);
+            RespR rs = selfCarService.customerEtcRec(etcQueryVo);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.customerETCRec-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.customerETCRec-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+    /**
+     * 自有车 卡绑定接口 渠道调用此接口，上传用户收到的短信验证码
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customerETCRecValid(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.customerETCRecValid-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String mobile =  jsonObject.getString("mobile");//企业预留手机号 必输
+            String validCode =  jsonObject.getString("validCode");//验证码 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(mobile)
+                    || StringUtils.isEmpty(validCode)
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            EtcValidVo etcValidVo  = new EtcValidVo();
+            etcValidVo.setCustomerName(appKey);
+            etcValidVo.setCompanyName(customerRec1.getCompanyName());
+            etcValidVo.setValidCode(validCode);
+            etcValidVo.setMobile(mobile);
+
+            RespR rs = selfCarService.customerEtcRecValid(etcValidVo);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.customerETCRecValid-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.customerETCRecValid-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 自有车 交易查询接口 渠道通过此接口可以查询单张卡连续90天内的交易（待开票、开票中、已开票）
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult getTradeList(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.getTradeList-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String cardId =  jsonObject.getString("cardId");//卡号 必输
+            Integer tradeStatus =  jsonObject.getInteger("tradeStatus");//交易状态 必输
+            String startExTime =  jsonObject.getString("startExTime");//开始时间 必输
+            String endExTime =  jsonObject.getString("endExTime");//结束时间 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(cardId)
+                    || null == tradeStatus
+                    || StringUtils.isEmpty(startExTime)
+                    || StringUtils.isEmpty(endExTime)
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            TradeRequestVo tradeRequestVo  = new TradeRequestVo();
+            tradeRequestVo.setCustomerName(appKey);
+            tradeRequestVo.setCompanyName(customerRec1.getCompanyName());
+            tradeRequestVo.setStartTime(startExTime);
+            tradeRequestVo.setEndTime(endExTime);
+            tradeRequestVo.setEtcId(cardId);
+            tradeRequestVo.setTradeStatus(tradeStatus);
+
+            if(tradeRequestVo.getTradeStatus() ==null){
+                tradeRequestVo.setTradeStatus(1);
+                RespR<List<CardTradeModel>> respRbefore = selfCarService.getTradeList(tradeRequestVo);
+                tradeRequestVo.setTradeStatus(2);
+                RespR<List<CardTradeModel>> respRUnder = selfCarService.getTradeList(tradeRequestVo);
+                tradeRequestVo.setTradeStatus(3);
+                RespR<List<CardTradeModel>> respRAfter = selfCarService.getTradeList(tradeRequestVo);
+                //合并展示
+                List<CardTradeModel> cardTradeModels = new ArrayList<>();
+                if(respRbefore.getCode() == 0){
+                    cardTradeModels.addAll(respRbefore.getData());
+                }
+                if(respRUnder.getCode() == 0){
+                    cardTradeModels.addAll(respRUnder.getData());
+                }
+                if(respRAfter.getCode() == 0){
+                    cardTradeModels.addAll(respRAfter.getData());
+                }
+
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(cardTradeModels.toString());
+                return result;
+            }
+            RespR rs = selfCarService.getTradeList(tradeRequestVo);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.getTradeList-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.getTradeList-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+    /**
+     * 自有车 交易查询接口 渠道通过此接口可以查询单张卡连续90天内的交易（待开票、开票中、已开票）
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult applInvoice(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.applInvoice-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String cardId =  jsonObject.getString("cardId");//卡号 必输
+            JSONArray tradeIdModel = jsonObject.getJSONArray("tradeIdModel");//交易ID集合 必输
+
+            String startExTime =  jsonObject.getString("startExTime");//开始时间 必输
+            String endExTime =  jsonObject.getString("endExTime");//结束时间 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(cardId)
+                    || null == tradeIdModel
+                    || StringUtils.isEmpty(startExTime)
+                    || StringUtils.isEmpty(endExTime)
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            InvoiceApplVo invoiceApplVo  = new InvoiceApplVo();
+            invoiceApplVo.setCustomerName(appKey);
+            invoiceApplVo.setCompanyName(customerRec1.getCompanyName());
+            invoiceApplVo.setCardId(cardId);
+
+
+            List<String> tradeIds = new ArrayList<String>();
+            for(int i=0;i<tradeIdModel.size();i++) {
+                JSONObject jb = tradeIdModel.getJSONObject(i);
+                String tradeId = jb.getString("tradeId");//交易ID
+                if(null == jb || StringUtils.isEmpty(tradeId)
+                ){
+                    return  result;
+                }
+                tradeIds.add(tradeId);
+            }
+
+            invoiceApplVo.setTradeIds(tradeIds);
+            RespR rs = selfCarService.applInvoice(invoiceApplVo);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.applInvoice-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.applInvoice-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+    /**
+     * 自有车 已开发票查询接口 渠道通过此接口可以根据该公司绑定的单张卡查询此卡在某个月开具的发票
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult getSelfCarInvoicesByTime(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.getSelfCarInvoicesByTime-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String cardId =  jsonObject.getString("cardId");//卡号 必输
+            String startInvoiceMakeTime =  jsonObject.getString("startInvoiceMakeTime");//开始时间 必输
+            String endInvoiceMakeTime =  jsonObject.getString("endInvoiceMakeTime");//结束时间 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(cardId)
+                    || StringUtils.isEmpty(startInvoiceMakeTime)
+                    || StringUtils.isEmpty(endInvoiceMakeTime)
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            SelfCarDueQueryVo selfCarDueQueryVo  = new SelfCarDueQueryVo();
+            selfCarDueQueryVo.setCustomername(appKey);
+            selfCarDueQueryVo.setCompanyName(customerRec1.getCompanyName());
+            selfCarDueQueryVo.setCardId(cardId);
+            selfCarDueQueryVo.setStartTime(startInvoiceMakeTime);
+            selfCarDueQueryVo.setEndTime(endInvoiceMakeTime);
+
+            RespR rs = selfCarService.getSelfCarInvoicesByTime(selfCarDueQueryVo);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.getSelfCarInvoicesByTime-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.getSelfCarInvoicesByTime-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 自有车 发票下载 渠道通过此接口可以下载某公司某个月份开具的发票。
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult getSelfCarInvoicePackage(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.getSelfCarInvoicePackage-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String makeMonth =  jsonObject.getString("makeMonth");//发票开具月份 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(makeMonth)
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            InvoicePackageVo invoicePackageVo  = new InvoicePackageVo();
+            invoicePackageVo.setCustomerName(appKey);
+            invoicePackageVo.setCompanyName(customerRec1.getCompanyName());
+            invoicePackageVo.setMonth(makeMonth);
+
+            RespR rs = selfCarService.getInvoicePackge(invoicePackageVo);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.getSelfCarInvoicePackage-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.getSelfCarInvoicePackage-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+
+
+
+
+
+    /**
+     * 自有车 卡解绑接口
+     * @param appKey
+     * @param api
+     * @param data
+     * @return
+     */
+    @Override
+    public DataResult customerCarUnRec(String appKey, String api, String data,String requestid) {
+
+        long costtimestart = System.currentTimeMillis();
+
+        DataResult result = new DataResult();
+
+        result.setData(3);
+        result.setCode(200);
+        result.setRequestid(requestid);
+        result.setMsg("无法认证");
+
+        try {
+            log.info("[-SelfCarInterServiceImpl.customerCarUnRec-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            String companyNum =  jsonObject.getString("companyNum");//企业编号 必输
+            String cardId =  jsonObject.getString("cardId");//Etc卡号 必输
+            if(StringUtils.isEmpty(data)|| null == jsonObject || StringUtils.isEmpty(companyNum)
+                    || StringUtils.isEmpty(cardId)
+
+            ){
+                return  result;
+            }
+
+            CustomerRec customerRec = new CustomerRec();
+            customerRec.setCustomerName(appKey);
+            customerRec.setCompanyNum(companyNum);
+            CustomerRec customerRec1 = customerRecMapper.selectByCustomerNameAndCompanyNum(customerRec);
+            if (null == customerRec1){
+                return result;
+            }
+            List<CustomerCarRec> customerCarRecList = new ArrayList<CustomerCarRec>();
+
+            CustomerCarRec customerCarRec  = new CustomerCarRec();
+            customerCarRec.setCustomerName(appKey);
+            customerCarRec.setCompanyName(customerRec1.getCompanyName());
+            customerCarRec.setEtcNum(cardId);
+            customerCarRecList.add(customerCarRec);
+
+            RespR rs = selfCarService.customerCarUnRec(customerCarRecList);
+            long costtimeend = System.currentTimeMillis();
+            log.info("[-SelfCarInterServiceImpl.customerCarUnRec-] result is "
+                    + rs.toString() + ", request is " + data + " ,costtime="
+                    + (costtimeend - costtimestart));
+            if(null != rs && rs.getCode() == 0){
+                result.setData(1);
+                result.setCode(200);
+                result.setMsg(rs.getData().toString());
+                return result;
+            } else {
+                result.setData(3);
+                result.setCode(200);
+                result.setMsg("无法认证");
+                return result;
+            }
+        } catch (Exception e) {
+            log.error("[-SelfCarInterServiceImpl.customerCarUnRec-] get httpclient exception is "
+                    + e + ", request is " + data);
+        }
+        return result;
+    }
+}