package com.iamberry.rst.utils;
import com.auth0.jwt.internal.org.apache.commons.codec.binary.Base64;
import com.auth0.jwt.internal.org.apache.commons.codec.binary.StringUtils;
import net.sf.json.JSONObject;
import org.apache.kafka.clients.consumer.ConsumerRecord;


import java.io.File;
import java.io.FileInputStream;
import java.security.Key;

import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;


public class test {
    private static final String AES = "AES";

    public static String decrypt(String encryptedData, String secretKey) throws Exception {
        Key key = new SecretKeySpec(secretKey.getBytes(), AES);
        Cipher c = Cipher.getInstance(AES);
        c.init(2, key);
        byte[] decodedValue = Base64.decodeBase64(encryptedData);
        byte[] decValue = c.doFinal(decodedValue);
        String decryptedValue = StringUtils.newStringUtf8(decValue);
        return decryptedValue;
    }


    public static void main(String[] args) throws Exception {
        ConsumerRecord<String, String> record = new ConsumerRecord<String, String>("4", 1, 1, "data", "{\"data\":\"7uiBfrOFcdy/EDWxcT6SlRwlTPRyTI7CHDtsa5VIbLtWgLCKxE4lMCo+4Njm/FyBhmZ8/vfzF9f8C5g7pKI8TvzaeeNu675pH3s5SP/5/bYUmZ5zICom6p41UxsMJ/+7uLSD3+B3uUc+buxwCELiRMiwsrdhUb4OObWd0tguFZdYQZrXGORTbQkUJIb7fctLuzR6OEBTmiC2H1/xEerFLua2LT4neI4VaHNC1MVW818=\"}");
        String appKey = "5kkyurvvtt58bbuxueee";//填APP KEY
        String secretKey = "rhj6na6u3y6uhy6qrbb3944mg5uqqpbb";//APP SECRET
        String data = decrypt(JSONObject.fromObject(record.value()).getString("data"),
                secretKey.substring(8, 24));//解析后的真正数据
System.out.println(data);
    }
}