省平台接口服务
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
jiazx0107@163.com
2023-11-18 328eba66ddc6fdf2f324b9cd04cd6acec9f642de 
 src/main/java/com/fzzy/gateway/hx2023/service/HxGatewayRemoteServiceImpl.java


@@ -2,11 +2,9 @@




import com.alibaba.fastjson2.JSONObject;


import com.fzzy.api.data.PushProtocol;


import com.fzzy.api.utils.MyMD5Util;


import com.fzzy.api.utils.RSAUtils;


import com.fzzy.api.utils.RedisConst;


import com.fzzy.api.utils.RedisUtil;


import com.fzzy.api.utils.*;


import com.fzzy.api.view.repository.ApiLogRep;


import com.fzzy.gateway.data.BaseResp;


import com.fzzy.gateway.service.GatewayConfService;


import com.fzzy.gateway.util.GatewayHttpUtil;


import com.fzzy.gateway.api.GatewayRemoteService;


@@ -20,8 +18,11 @@


import org.springframework.stereotype.Component;




import javax.annotation.Resource;


import java.io.UnsupportedEncodingException;


import java.util.Comparator;


import java.util.HashMap;


import java.util.Map;


import java.util.TreeMap;






@Slf4j


@@ -61,7 +62,7 @@




            CloudResp respKey = JSONObject.parseObject(jsonStr, CloudResp.class);




            if (ScConstant.CODE_200 == respKey.getCode()) {


            if (BaseResp.CODE_200 == respKey.getCode()) {


                JSONObject object = respKey.getData();


                String pubKey = (String) object.get("pubKey");


                String priKey = (String) object.get("priKey");


@@ -79,7 +80,7 @@


            log.info("---获取AccessToken接口-返回---{}", jsonStr);


            CloudResp respToken = JSONObject.parseObject(jsonStr, CloudResp.class);




            if (ScConstant.CODE_200 == respToken.getCode()) {


            if (BaseResp.CODE_200 == respToken.getCode()) {


                JSONObject object = respKey.getData();


                if (null != object) {


                    String token = (String) object.get("token");


@@ -119,7 +120,7 @@


            String url = gatewayConf.getApiUrl() + "reserver/api/iot/equipment/heartbeat";




            String jsonStr = GatewayHttpUtil.doGet(url, params);


            log.info("---网关心跳接口-返回---{}", jsonStr);


           // log.info("---网关心跳接口-返回---{}", jsonStr);




        } catch (Exception e) {


            log.error("------网关心跳接口--执行失败-----{}", e);


@@ -164,6 +165,28 @@


    public String getSign(Map<String, String> parames, String priKey) {


        //参数拼接


        String msg = "";


        parames = sortMapKey(parames);


        for (Map.Entry<String, String> param : parames.entrySet()) {


            msg += param.getKey() + "=" + param.getValue() + "&";


        }


        msg = msg.substring(0, msg.length() - 1);




        log.debug("------待加密信息-----{}", msg);




        //MD5加密


        String md5sign = MyMD5Util.getMD5(msg);


        log.debug("------md5加密-----{}", md5sign);




        //RSA加密


        String result = GatewayRSAUtils.encryptByPrivate(md5sign, priKey);


        log.debug("------RSA加密-----{}", result);




        return result;


    }


    public static String getSign2(Map<String, String> parames, String priKey) {


        //参数拼接


        String msg = "";


        parames = sortMapKey(parames);


        for (Map.Entry<String, String> param : parames.entrySet()) {


            msg += param.getKey() + "=" + param.getValue() + "&";


        }


@@ -182,7 +205,6 @@


        return result;


    }






    /**


     * @param kqdm


     * @return


@@ -197,5 +219,51 @@




    }




    private static Map<String, String> sortMapKey(Map<String, String> map){


        if(map == null || map.isEmpty()){


            return  null;


        }






        Map<String, String> sortMap = new TreeMap<>(new Comparator<String>() {


            @Override


            public int compare(String o1, String o2) {


                return o1.compareTo(o2);


            }


        });


        sortMap.putAll(map);


        return sortMap;


    }






    public static void main(String[] args) throws UnsupportedEncodingException {


        //网关心跳接口


//        Map<String, String> params = new HashMap<>();


//        //params.put("token", "");


//        params.put("gatewayId", "6e3d92ff71b911eea5e50250f2000002");


//        params.put("gatewayIp", "123");


//        params.put("gatewayMac", "123");


//        params.put("gatewayCPU","123");


//        params.put("gatewayMem", "123");


//        params.put("gatewayHardDisk", "123");


//        params.put("timestamp", "2023-10-31 12:12:12");


//        String sign = getSign2(params,"MIIBVQIBADANBgkqhkiG9w0BAQEFAASCAT8wggE7AgEAAkEA0lg35sJGRyUFEDzt\np9pWvc0JD+0+SmiZIgMbUaEM5gqBsvUJ9LnzB0rpMTbuqAxAFbUH1Nw4qXdJVnKS\nRYfPgQIDAQABAkBPkxIq2Uou9gFRYEtkGcSA70VDYjQTgDiWVmiKXAv+JkEJmOno\\nMrHYQGAiP0q4xW66F+CLNCrGPVJns2ywMxwxAiEA/vyNX5M0/t+RHAxpMp484i9T\nb5Qf+HvepOV3c0UGZx0CIQDTLj4+qgoXGOLCM9/dzVJZ04VIjK6u546z22hXFWgI\ntQIhAMWFP8JMlx3kc1UF7Cuw1jrkLD7fwJBM7CBSPODHFHmlAiEAhv4Hcf02B/+z\nbBrG3rzSCHOKvo6XV1zTvqrhLtGTOAUCIGmoaIDgTuS0ZF71+c9mYvPVNL0T02GQ\nE8Y3ExreQphx");


//        params.put("sign", sign);


//


//        System.out.println(sign);


        byte[] encryptedData = GatewayRSAUtils.decryptBase64("yx7jNj9DGS7AkH/sXo5IrwaGNCSUnAZFmjXwWovMBfvYGVQur1RELXUu4fqIMZZ/ck6CAA3ESOJCS+aCD0aVdA==");


        StringBuilder hexString = new StringBuilder();


        for (byte b : encryptedData) {


            String hex = Integer.toHexString(0xFF & b);


            if (hex.length() == 1) {


                hexString.append('0');


            }


            hexString.append(hex);


        }


        String hexStringResult = hexString.toString();


        System.out.println(hexStringResult);


        System.out.println(BytesUtil.bytesToString(GatewayRSAUtils.decryptBase64("mgtJOOn5iZBvmQI3hzvaw2J4BiZUcXhLTsgLk8++Ig2iIZcPaky7V+ylkA+BAYxIBS5ovHXjRo4w26TTEq9k7Q==")));




    }




}