ats微信车主平台签约检测及返回签约参数

gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ats/weiXin/AtsVehicleUserStateRequest.java

@@ -5,6 +5,8 @@ import cn.com.taiji.core.model.comm.protocol.valid.ErrorMsgBuilder;
 import lombok.Getter;
 import lombok.Setter;
 
+import javax.validation.constraints.NotBlank;
+
 /**
  * @Author：ChenChao
  * @Date：2025/5/15 16:29
@@ -18,6 +20,28 @@ public class AtsVehicleUserStateRequest extends AbstractAtsRequest<AtsVehicleUse
     public AtsVehicleUserStateRequest() {
         super(WeiXinServiceCmd.VEHICLEUSERSTATE);
     }
+
+    @NotBlank
+    private String appId;//公众账号id 是
+    @NotBlank
+    private String subAppId;//子商户公众账号id 是
+    @NotBlank
+    private String mchId;//商户号 是
+    @NotBlank
+    private String subMchId;//子商户号 是
+    @NotBlank
+    private String signKey;//签名密钥 是
+    /**
+     * 跳转场景
+     * 商户跳转的业务场景，不传默认是小程序，也支持APP和公众号H5跳转
+     * APP:通过APP跳转
+     * H5:通过公众号H5跳转
+     */
+    private String jumpScene;//否
+    @NotBlank
+    private String plateNumber;// 是
+    @NotBlank
+    private String subOpenId;//是 主要用于返回给前端签约参数
     @Override
     protected void validate(ErrorMsgBuilder builder) {
 

gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ats/weiXin/AtsVehicleUserStateResponse.java

@@ -13,4 +13,42 @@ import lombok.Setter;
 @Getter
 @Setter
 public class AtsVehicleUserStateResponse extends AbstractAtsResponse{
+
+    //    NORMAL：正常用户，已开通车主服务，且已授权访问
+    //    PAUSED：已暂停车主服务
+    //    OVERDUE: 用户已开通车主服务，但欠费状态。提示用户还款，请跳转到车主服务
+    //    UNAUTHORIZED：用户未授权使用当前业务，或未开通车主服务。请跳转到授权接口
+    private String userState;//用户签约状态 是
+
+    private String deductMode;//发起扣费方式PROACTIVE：表示用户主动发起的免密支付 AUTOPAY：表示用户无感的支付 否
+
+    private String plateNumberInfo;//车牌信息 否
+
+    //=====================前端请求微信签约参数==============参与签名字段 +
+    private String appId;//请求appid 是 +
+
+    private String mchId;//商户号 是 +
+
+    private String subMchId;//子商户号 是 +
+
+    private String subAppId;//子商户公众账号id 是 +
+
+    private String nonceStr;//随机字符串 是 +
+
+    private String signType;//签名类型 是 +
+
+    private String sign;//签名 是
+
+    private String tradeScene = "HIGHWAY";//交易场景 写死 是 +
+
+    private String openId;//用户标识 否
+
+    private String subOpenId;//用户子标识 是 +
+
+    private String plateNumber;//车牌号 是 +
+
+    private String channelType = "ETC";//通道类型 写死 ETC +
+
+    private String path;//跳转路径 是
+
 }

gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ats/weiXin/WeiXinServiceCmd.java

@@ -9,7 +9,7 @@ public enum WeiXinServiceCmd implements SignServiceCommand {
     CREATEPAYORDERV2("V2统一下单","creatOrderV2", AtsCreatPayOrderV2Request.class),
     CREATEPAYORDERV3("V3统一下单","creatOrderV3", AtsCreatPayOrderV3Request.class),
     QUERYPAYRESULT("查询支付结果","queryPayResult", AtsQueryPayResultRequest.class),
-    VEHICLEUSERSTATE("微信车主状态查询","vehicleUserState", AtsVehicleUserStateRequest.class),
+    VEHICLEUSERSTATE("微信车主状态查询及获取签约参数","vehicleUserState", AtsVehicleUserStateRequest.class),
     ;
 
 

zhywpt-service-ats/src/main/java/cn/com/taiji/ats/manager/handler/WinXinServiceHandler.java

@@ -3,14 +3,12 @@ package cn.com.taiji.ats.manager.handler;
 import cn.com.taiji.ats.manager.weixin.CreatePayOrderV2Manager;
 import cn.com.taiji.ats.manager.weixin.CreatePayOrderV3Manager;
 import cn.com.taiji.ats.manager.weixin.QueryPayResultManager;
+import cn.com.taiji.ats.manager.weixin.VehicleUserStateManager;
 import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
 import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
 import cn.com.taiji.core.model.comm.protocol.SignJsonRequest;
 import cn.com.taiji.core.model.comm.protocol.ats.*;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsCreatPayOrderV2Request;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsCreatPayOrderV3Request;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsQueryPayResultRequest;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.WeiXinServiceCmd;
+import cn.com.taiji.core.model.comm.protocol.ats.weiXin.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.zgglyun.common.model.AbstractHttpRequestInfo;
@@ -39,6 +37,8 @@ public class WinXinServiceHandler extends AbstractAtsServiceHandler<WeiXinServic
     private CreatePayOrderV3Manager createPayOrderV3Manager;
     @Autowired
     private QueryPayResultManager queryPayResultManager;
+    @Autowired
+    private VehicleUserStateManager vehicleUserStateManager;
 
     @Override
     protected <T extends AbstractSignTypeRequest<?>> AbstractSignTypeResponse handleInternal(T request,
@@ -51,6 +51,8 @@ public class WinXinServiceHandler extends AbstractAtsServiceHandler<WeiXinServic
                 return createPayOrderV3Manager.serviceHandle((AtsCreatPayOrderV3Request) request);
             case QUERYPAYRESULT:
                 return queryPayResultManager.serviceHandle((AtsQueryPayResultRequest) request);
+            case VEHICLEUSERSTATE:
+                return vehicleUserStateManager.serviceHandle((AtsVehicleUserStateRequest) request);
             default:
                 throw FileProtocolSystemError.NOT_SUPPORT.toHandleException(jsonReq.getIfCode());
         }

zhywpt-service-ats/src/main/java/cn/com/taiji/ats/manager/weixin/VehicleUserStateManager.java

@@ -0,0 +1,181 @@
+package cn.com.taiji.ats.manager.weixin;
+
+import cn.com.taiji.ats.tools.WxVehicleUtil;
+import cn.com.taiji.common.manager.AbstractManager;
+import cn.com.taiji.common.manager.net.http.ServiceHandleException;
+import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsVehicleUserStateRequest;
+import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsVehicleUserStateResponse;
+import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError;
+import org.apache.commons.io.IOUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+
+import java.io.*;
+import java.net.*;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ * @Author：ChenChao
+ * @Date：2025/5/15 17:16
+ * @Filename：VehicleUserStateManager
+ * @description:
+ */
+@Service
+public class VehicleUserStateManager extends AbstractManager {
+
+    private static final String baseUrl = "https://api.mch.weixin.qq.com/vehicle/partnerpay/querystate";
+
+    public AtsVehicleUserStateResponse serviceHandle(AtsVehicleUserStateRequest request) throws ServiceHandleException {
+        //生成xml字符串
+        String reqXml = getXmlString(request);
+        String resXml = postData(baseUrl, reqXml, "text/xml");
+        logger.info("车主平台微信返回:{}",resXml);
+        return getResponse(resXml,request);
+    }
+
+    private AtsVehicleUserStateResponse getResponse(String resXml, AtsVehicleUserStateRequest request) throws ServiceHandleException {
+        // 返回值验签
+        Map<String, String> map = WxVehicleUtil.xmlToMap(resXml);
+        if ("FAIL".equals(map.get("return_code"))) {
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("微信返回异常:"+map.get("return_msg"));
+        }
+        String localSign = null;
+        try {
+            localSign = WxVehicleUtil.generateSignature(map, request.getSignKey(), "HMACSHA256");
+        } catch (Exception e) {
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("微信返回生成签名异常");
+        }
+        if (!localSign.equals(map.get("sign"))){
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("微信返回验签失败");
+        }
+        if ("FAIL".equals(map.get("result_code"))){
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("微信返回失败:"+map.get("err_code_des"));
+        }
+        AtsVehicleUserStateResponse res = new AtsVehicleUserStateResponse();
+        res.setAppId(map.get("appid"));
+        res.setSubAppId(map.get("sub_appid"));
+        res.setMchId(map.get("mch_id"));
+        res.setSubMchId(map.get("sub_mch_id"));
+        res.setNonceStr(map.get("nonce_str"));
+        res.setUserState(map.get("user_state"));
+        res.setOpenId(map.get("openid"));
+        res.setDeductMode(map.get("deduct_mode"));
+        res.setPath(map.get("path"));
+        res.setPlateNumberInfo(map.get("plate_number_info"));
+        res.setSubOpenId(request.getSubOpenId());
+        res.setSignType("HMAC-SHA256");
+        res.setPlateNumber(request.getPlateNumber());
+        res.setSign(getResSign(res,request.getSignKey()));
+        return res;
+    }
+
+    public  String postData(String urlStr, String data, String contentType) throws ServiceHandleException {
+        OutputStream os = null;
+        OutputStreamWriter osw = null;
+        InputStream is = null;
+        InputStreamReader isr = null;
+        BufferedReader br = null;
+        try {
+            URL url = new URL(urlStr);
+            URLConnection conn = url.openConnection();
+            conn.setDoOutput(true);
+            conn.setConnectTimeout(5000);
+            conn.setReadTimeout(5000);
+            if (StringUtils.hasText(contentType)) {
+                conn.setRequestProperty("content-type", contentType);
+            }
+            os = conn.getOutputStream();
+            osw = new OutputStreamWriter(os, "UTF-8");
+            if (data == null) data = "";
+            osw.write(data);
+            osw.flush();
+            is = conn.getInputStream();
+            isr = new InputStreamReader(is, "UTF-8");
+            br = new BufferedReader(isr);
+            StringBuilder sb = new StringBuilder();
+            String line = null;
+            while ((line = br.readLine()) != null) {
+                sb.append(line);
+            }
+            return sb.toString();
+        } catch (IOException e) {
+
+            logger.error("", e);
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("请求地址" + urlStr + "失败: " + e.getMessage());
+        } finally {
+            IOUtils.closeQuietly(os);
+            IOUtils.closeQuietly(osw);
+            IOUtils.closeQuietly(is);
+            IOUtils.closeQuietly(isr);
+            IOUtils.closeQuietly(br);
+        }
+    }
+
+    private String getXmlString(AtsVehicleUserStateRequest request) throws ServiceHandleException {
+        //随机码
+        String nonceStr = UUID.randomUUID().toString().replace("-", "");
+//        [appid, jump_scene, mch_id, nonce_str, plate_number, sign, sign_type, sub_appid, sub_mch_id,
+//                trade_scene, version]
+        StringBuilder xmlBuilder = new StringBuilder();
+        xmlBuilder.append("<xml>");
+        StringBuilder sb = new StringBuilder();
+        sb.append("appid=").append(request.getAppId());
+        if (hasText(request.getJumpScene())){
+            sb.append("&jump_scene=").append(request.getJumpScene());
+            xmlBuilder.append("<jump_scene>").append(request.getJumpScene()).append("</jump_scene>");
+        }
+        sb.append("&mch_id=").append(request.getMchId());
+        sb.append("&nonce_str=").append(nonceStr);
+        sb.append("&plate_number=").append(request.getPlateNumber());
+        sb.append("&sign_type=").append("HMAC-SHA256");
+        sb.append("&sub_appid=").append(request.getSubAppId());
+        sb.append("&sub_mch_id=").append(request.getSubMchId());
+        sb.append("&trade_scene=").append("HIGHWAY");
+        sb.append("&version=").append("2.0");
+        String signTemp = sb.append("&key=").append(request.getSignKey()).toString();
+        String sign = "";
+        try {
+            sign = WxVehicleUtil.HMACSHA256(signTemp, request.getSignKey());
+        } catch (Exception e) {
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("签名失败");
+        }
+
+        xmlBuilder.append("<appid>").append(request.getAppId()).append("</appid>");
+        xmlBuilder.append("<sign>").append(sign).append("</sign>");
+        xmlBuilder.append("<mch_id>").append(request.getMchId()).append("</mch_id>");
+        xmlBuilder.append("<nonce_str>").append(nonceStr).append("</nonce_str>");
+        xmlBuilder.append("<plate_number>").append(request.getPlateNumber()).append("</plate_number>");
+        xmlBuilder.append("<sign_type>").append("HMAC-SHA256").append("</sign_type>");
+        xmlBuilder.append("<sub_appid>").append(request.getSubAppId()).append("</sub_appid>");
+        xmlBuilder.append("<sub_mch_id>").append(request.getSubMchId()).append("</sub_mch_id>");
+        xmlBuilder.append("<trade_scene>").append("HIGHWAY").append("</trade_scene>");
+        xmlBuilder.append("<version>").append("2.0").append("</version>");
+        xmlBuilder.append("</xml>");
+        return xmlBuilder.toString();
+    }
+
+    //响应的签名
+    public String getResSign(AtsVehicleUserStateResponse res, String key) throws ServiceHandleException {
+//        [appid, channel_type, mch_id, nonce_str, plate_number, sign_type, sub_appid, sub_mch_id, sub_openid, trade_scene]
+        StringBuilder sb = new StringBuilder();
+        sb.append("appid=").append(res.getAppId());
+        sb.append("&channel_type=").append(res.getChannelType());
+        sb.append("&mch_id=").append(res.getMchId());
+        sb.append("&nonce_str=").append(res.getNonceStr());
+        sb.append("&plate_number=").append(res.getPlateNumber());
+        sb.append("&sign_type=").append(res.getSignType());
+        sb.append("&sub_appid=").append(res.getSubAppId());
+        sb.append("&sub_mch_id=").append(res.getSubMchId());
+        sb.append("&sub_openid=").append(res.getSubOpenId());
+        sb.append("&trade_scene=").append(res.getTradeScene());
+        String signTemp = sb.append("&key=").append(key).toString();
+        try {
+            return WxVehicleUtil.HMACSHA256(signTemp, key);
+        } catch (Exception e) {
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("响应签名失败");
+        }
+    }
+
+
+}

zhywpt-service-ats/src/main/java/cn/com/taiji/ats/tools/WxVehicleUtil.java

@@ -0,0 +1,334 @@
+package cn.com.taiji.ats.tools;
+
+import cn.com.taiji.common.manager.net.http.ServiceHandleException;
+import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError;
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.w3c.dom.Document;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+import org.xml.sax.SAXException;
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.transform.OutputKeys;
+import javax.xml.transform.Transformer;
+import javax.xml.transform.TransformerFactory;
+import javax.xml.transform.dom.DOMSource;
+import javax.xml.transform.stream.StreamResult;
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.StringWriter;
+import java.nio.charset.StandardCharsets;
+import java.security.MessageDigest;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+public class WxVehicleUtil {
+    private static Logger logger = LoggerFactory.getLogger(WxVehicleUtil.class);
+
+    private static final String  MD5 = "MD5";
+    private static final String  HMACSHA256 = "HMACSHA256";
+    private static final String FIELD_SIGN = "sign";
+
+    /**
+     * XML格式字符串转换为Map
+     *
+     * @param strXML XML字符串
+     * @return XML数据转换后的Map
+     * @throws Exception
+     */
+    public static Map<String, String> xmlToMap(String strXML) throws ServiceHandleException {
+        InputStream is = null;
+        try {
+            Map<String, String> data = new HashMap<String, String>();
+            DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
+            DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder();
+            is = new ByteArrayInputStream(strXML.getBytes(StandardCharsets.UTF_8));
+            Document doc = documentBuilder.parse(is);
+            doc.getDocumentElement().normalize();
+            NodeList nodeList = doc.getDocumentElement().getChildNodes();
+            for (int idx = 0; idx < nodeList.getLength(); ++idx) {
+                Node node = nodeList.item(idx);
+                if (node.getNodeType() == Node.ELEMENT_NODE) {
+                    org.w3c.dom.Element element = (org.w3c.dom.Element) node;
+                    data.put(element.getNodeName(), element.getTextContent());
+                }
+            }
+            return data;
+        } catch (ParserConfigurationException | IOException | SAXException e) {
+            logger.info("", e);
+            throw GlyServiceError.BUSINESS_VALIDATE_ERR.toHandleException("xml转换异常: " + e.getMessage());
+        } finally {
+            IOUtils.closeQuietly(is);
+        }
+
+    }
+
+    /**
+     * 将Map转换为XML格式的字符串
+     *
+     * @param data Map类型数据
+     * @return XML格式的字符串
+     * @throws Exception
+     */
+    public static String mapToXml(Map<String, String> data) throws Exception {
+        DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
+        DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder();
+        Document document = documentBuilder.newDocument();
+        org.w3c.dom.Element root = document.createElement("xml");
+        document.appendChild(root);
+        for (String key : data.keySet()) {
+            String value = data.get(key);
+            if (value == null) {
+                value = "";
+            }
+            value = value.trim();
+            org.w3c.dom.Element filed = document.createElement(key);
+            filed.appendChild(document.createTextNode(value));
+            root.appendChild(filed);
+        }
+        TransformerFactory tf = TransformerFactory.newInstance();
+        Transformer transformer = tf.newTransformer();
+        DOMSource source = new DOMSource(document);
+        transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
+        transformer.setOutputProperty(OutputKeys.INDENT, "yes");
+        StringWriter writer = new StringWriter();
+        StreamResult result = new StreamResult(writer);
+        transformer.transform(source, result);
+        String output = writer.getBuffer().toString(); //.replaceAll("\n|\r", "");
+        try {
+            writer.close();
+        } catch (Exception ex) {
+        }
+        return output;
+    }
+
+
+    /**
+     * 生成带有 sign 的 XML 格式字符串
+     *
+     * @param data Map类型数据
+     * @param key  API密钥
+     * @return 含有sign字段的XML
+     */
+    public static String generateSignedXml(final Map<String, String> data, String key) throws Exception {
+        return generateSignedXml(data, key, MD5);
+    }
+
+    /**
+     * 生成带有 sign 的 XML 格式字符串
+     *
+     * @param data     Map类型数据
+     * @param key      API密钥
+     * @param signType 签名类型
+     * @return 含有sign字段的XML
+     */
+    public static String generateSignedXml(final Map<String, String> data, String key, String signType) throws Exception {
+        String sign = generateSignature(data, key, signType);
+        data.put(FIELD_SIGN, sign);
+        return mapToXml(data);
+    }
+
+
+    /**
+     * 判断签名是否正确
+     *
+     * @param xmlStr XML格式数据
+     * @param key    API密钥
+     * @return 签名是否正确
+     * @throws Exception
+     */
+    public static boolean isSignatureValid(String xmlStr, String key) throws Exception {
+        Map<String, String> data = xmlToMap(xmlStr);
+        if (!data.containsKey(FIELD_SIGN)) {
+            return false;
+        }
+        String wxSign = data.get(FIELD_SIGN);
+        String localSign = generateSignature(data, key);
+        boolean signValid = localSign.equals(wxSign);
+
+        if (!signValid) {
+            logger.info("wxSign: {}", wxSign);
+            logger.info("localSign: {}", localSign);
+        }
+        return signValid;
+    }
+
+    /**
+     * 判断签名是否正确，必须包含sign字段，否则返回false。使用MD5签名。
+     *
+     * @param data Map类型数据
+     * @param key  API密钥
+     * @return 签名是否正确
+     * @throws Exception
+     */
+    public static boolean isSignatureValid(Map<String, String> data, String key) throws Exception {
+        return isSignatureValid(data, key, MD5);
+    }
+
+    /**
+     * 判断签名是否正确，必须包含sign字段，否则返回false。
+     *
+     * @param data     Map类型数据
+     * @param key      API密钥
+     * @param signType 签名方式
+     * @return 签名是否正确
+     * @throws Exception
+     */
+    public static boolean isSignatureValid(Map<String, String> data, String key, String signType) throws Exception {
+        if (!data.containsKey(FIELD_SIGN)) {
+            return false;
+        }
+        String sign = data.get(FIELD_SIGN);
+        return generateSignature(data, key, signType).equals(sign);
+    }
+
+    /**
+     * 生成签名
+     *
+     * @param data 待签名数据
+     * @param key  API密钥
+     * @return 签名
+     */
+    public static String generateSignature(final Map<String, String> data, String key) throws Exception {
+        return generateSignature(data, key, HMACSHA256);
+    }
+
+    /**
+     * 生成签名. 注意，若含有sign_type字段，必须和signType参数保持一致。
+     *
+     * @param data     待签名数据
+     * @param key      API密钥
+     * @param signType 签名方式
+     * @return 签名
+     */
+    public static String generateSignature(final Map<String, String> data, String key, String signType) throws Exception {
+        Set<String> keySet = data.keySet();
+        String[] keyArray = keySet.toArray(new String[keySet.size()]);
+        Arrays.sort(keyArray);
+        StringBuilder sb = new StringBuilder();
+        for (String k : keyArray) {
+            if (k.equals(FIELD_SIGN)) {
+                continue;
+            }
+            final String value = data.get(k);
+            final boolean condition = StringUtils.isEmpty(value) || value.trim().length() == 0;
+            if (!condition) // 参数值为空，则不参与签名
+                //不应使用trim() 会导致签名与微信的返回不一致
+//                sb.append(k).append("=").append(data.get(k).trim()).append("&");
+                sb.append(k).append("=").append(data.get(k)).append("&");
+        }
+        sb.append("key=").append(key);
+        if (MD5.equals(signType)) {
+            return MD5(sb.toString()).toUpperCase();
+        } else if (HMACSHA256.equals(signType)) {
+            return HMACSHA256(sb.toString(), key);
+        } else {
+            throw new Exception(String.format("Invalid sign_type: %s", signType));
+        }
+    }
+
+
+    /**
+     * 获取随机字符串 Nonce Str
+     *
+     * @return String 随机字符串
+     */
+    public static String generateNonceStr() {
+        return UUID.randomUUID().toString().replaceAll("-", "").substring(0, 32);
+    }
+
+
+    /**
+     * 生成 MD5
+     *
+     * @param data 待处理数据
+     * @return MD5结果
+     */
+    public static String MD5(String data) throws Exception {
+        MessageDigest md = MessageDigest.getInstance("MD5");
+        byte[] array = md.digest(data.getBytes("UTF-8"));
+        StringBuilder sb = new StringBuilder();
+        for (byte item : array) {
+            sb.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3));
+        }
+        return sb.toString().toUpperCase();
+    }
+
+    /**
+     * 生成 HMACSHA256
+     *
+     * @param data 待处理数据
+     * @param key  密钥
+     * @return 加密结果
+     * @throws Exception
+     */
+    public static String HMACSHA256(String data, String key) throws Exception {
+        Mac sha256_HMAC = Mac.getInstance("HmacSHA256");
+        SecretKeySpec secret_key = new SecretKeySpec(key.getBytes("UTF-8"), "HmacSHA256");
+        sha256_HMAC.init(secret_key);
+        byte[] array = sha256_HMAC.doFinal(data.getBytes("UTF-8"));
+        StringBuilder sb = new StringBuilder();
+        for (byte item : array) {
+            sb.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3));
+        }
+        return sb.toString().toUpperCase();
+    }
+
+    /**
+     * 日志
+     *
+     * @return
+     */
+    public static Logger getLogger() {
+        Logger logger = LoggerFactory.getLogger("wxpay java sdk");
+        return logger;
+    }
+
+    /**
+     * 获取当前时间戳，单位秒
+     *
+     * @return
+     */
+    public static long getCurrentTimestamp() {
+        return System.currentTimeMillis() / 1000;
+    }
+
+
+    /**
+     * 获取当前时间 yyyyMMddHHmmss
+     *
+     * @return String
+     */
+    public static String getCurrTime() {
+        Date now = new Date();
+        SimpleDateFormat outFormat = new SimpleDateFormat("yyyyMMddHHmmss");
+        String s = outFormat.format(now);
+        return s;
+    }
+
+    /**
+     * 获取当前时间戳，单位毫秒
+     *
+     * @return
+     */
+    public static long getCurrentTimestampMs() {
+        return System.currentTimeMillis();
+    }
+
+    /**
+     * 生成 uuid， 即用来标识一笔单，也用做 nonce_str
+     *
+     * @return
+     */
+    public static String generateUUID() {
+        return UUID.randomUUID().toString().replaceAll("-", "").substring(0, 32);
+    }
+
+}

zhywpt-service-ats/src/main/java/cn/com/taiji/ats/web/TestController.java

@@ -1,14 +1,11 @@
 package cn.com.taiji.ats.web;
 
-import cn.com.taiji.ats.manager.weixin.CreatePayOrderV3Manager;
 import cn.com.taiji.ats.manager.weixin.CreatePayOrderV3Manager2;
 import cn.com.taiji.ats.manager.weixin.QueryPayResultManager;
+import cn.com.taiji.ats.manager.weixin.VehicleUserStateManager;
 import cn.com.taiji.common.manager.net.http.ServiceHandleException;
 import cn.com.taiji.core.entity.dict.pay.TradeType;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsCreatPayOrderV3Request;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsCreatPayOrderV3Response;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsQueryPayResultRequest;
-import cn.com.taiji.core.model.comm.protocol.ats.weiXin.AtsQueryPayResultResponse;
+import cn.com.taiji.core.model.comm.protocol.ats.weiXin.*;
 import com.google.zxing.BarcodeFormat;
 import com.google.zxing.EncodeHintType;
 import com.google.zxing.MultiFormatWriter;
@@ -86,6 +83,21 @@ public class TestController {
         return orderV3Response;
     }
 
+    @Autowired
+    private VehicleUserStateManager vehicleUserStateManager;
+    @RequestMapping(value = "/common/test3", method = {RequestMethod.GET})
+    public AtsVehicleUserStateResponse tes3(@RequestBody AtsVehicleUserStateRequest request) {
+
+        AtsVehicleUserStateResponse atsVehicleUserStateResponse = null;
+        try {
+            atsVehicleUserStateResponse = vehicleUserStateManager.serviceHandle(request);
+        } catch (ServiceHandleException e) {
+            e.printStackTrace();
+            logger.error(e.getMessage());
+        }
+        return atsVehicleUserStateResponse;
+    }
+
     @GetMapping("qrCode")
     public void qrcode(HttpServletResponse response) throws Exception {
         String data = "weixin://wxpay/bizpayurl?pr=OeLKIGGz1";