Go

代码示例

package main

import (
    "crypto/aes"
    "crypto/cipher"
    "crypto/rand"
    "crypto/sha1"
    "encoding/base64"
    "encoding/json"
    "fmt"
    "io"
    "io/ioutil"
    mrand "math/rand"
    "net/http"
    "strings"
    "time"
)

const (
    c_url    = "https://api.yazx.com/phone/check/v3/"
    c_snuser = "xxx"
    c_snkey  = "xxx"
)

func AESDecrypt(ciphertxt string, keystr string) string {
    // prepare cipher text
    cipherbyte, _ := base64.StdEncoding.DecodeString(ciphertxt)
    // prepare the key
    block, _ := aes.NewCipher([]byte(keystr))

    if len(cipherbyte) < aes.BlockSize {
        return ""
    }

    // split iv and ciphertext
    iv := cipherbyte[:aes.BlockSize]
    cipherbyte = cipherbyte[aes.BlockSize:]
    stream := cipher.NewCFBDecrypter(block, iv)

    // XORKeyStream can work in-place if the two arguments are the same.
    stream.XORKeyStream(cipherbyte, cipherbyte)
    return string(cipherbyte)
}

func AESEncrypt(plaintxt string, keystr string) string {
    block, _ := aes.NewCipher([]byte(keystr))
    ciphertext := make([]byte, aes.BlockSize+len(plaintxt))
    iv := ciphertext[:aes.BlockSize]
    io.ReadFull(rand.Reader, iv)

    randobj := mrand.New(mrand.NewSource(time.Now().UnixNano()))
    randobj.Read(iv)

    stream := cipher.NewCFBEncrypter(block, iv)
    stream.XORKeyStream(ciphertext[aes.BlockSize:], []byte(plaintxt))
    return base64.StdEncoding.EncodeToString([]byte(ciphertext))
}

func TestGetStatus(countryCode, nationalNumber string) {
    var users []map[string]string
    
        h := sha1.New()
        h.Write([]byte(nationalNumber))

        var m = map[string]string{
            "country_code": countryCode,
            "national_number_sha1": string(fmt.Sprintf("%x", h.Sum(nil))),
        }
        users = append(users, m)
    }

    jsusers, _ := json.Marshal(users)
    encryptData := AESEncrypt(string(jsusers), c_snkey)

    payload := strings.NewReader(
        "{\"snuser\": \"" + c_snuser + "\", \"data\": \"" + encryptData + "\"}")

    req, _ := http.NewRequest("POST", c_url, payload)

    req.Header.Add("content-type", "application/json")
    req.Header.Add("cache-control", "no-cache")

    res, _ := http.DefaultClient.Do(req)

    defer res.Body.Close()
    body, _ := ioutil.ReadAll(res.Body)

    fmt.Println(string(body))
    var response map[string]interface{}
    if err := json.Unmarshal(body, &response); err != nil {
        panic(err)
    }

    if response["status"].(float64) != 200 {
        fmt.Println("get status failed")
    } else {
        fmt.Println("get status success =>>>")
        fmt.Println(AESDecrypt(response["data"].(string), c_snkey))
    }
}

func main() {
    TestGetStatus("86", "13800000000")
}