Compare commits
No commits in common. 'bfe97d5184fcaefd48ddaec4b2080078d9fbdc80' and '9f11e1a05d2f917c05ce3a8278192e8739bedce9' have entirely different histories.
bfe97d5184
...
9f11e1a05d
@ -1,108 +0,0 @@ |
||||
# ---> JetBrains |
||||
# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and WebStorm |
||||
# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839 |
||||
|
||||
# User-specific stuff |
||||
.idea/**/workspace.xml |
||||
.idea/**/tasks.xml |
||||
.idea/**/usage.statistics.xml |
||||
.idea/**/dictionaries |
||||
.idea/**/shelf |
||||
|
||||
# Generated files |
||||
.idea/**/contentModel.xml |
||||
|
||||
# Sensitive or high-churn files |
||||
.idea/**/dataSources/ |
||||
.idea/**/dataSources.ids |
||||
.idea/**/dataSources.local.xml |
||||
.idea/**/sqlDataSources.xml |
||||
.idea/**/dynamic.xml |
||||
.idea/**/uiDesigner.xml |
||||
.idea/**/dbnavigator.xml |
||||
|
||||
# Gradle |
||||
.idea/**/gradle.xml |
||||
.idea/**/libraries |
||||
|
||||
# Gradle and Maven with auto-import |
||||
# When using Gradle or Maven with auto-import, you should exclude module files, |
||||
# since they will be recreated, and may cause churn. Uncomment if using |
||||
# auto-import. |
||||
# .idea/artifacts |
||||
# .idea/compiler.xml |
||||
# .idea/jarRepositories.xml |
||||
# .idea/modules.xml |
||||
# .idea/*.iml |
||||
# .idea/modules |
||||
# *.iml |
||||
# *.ipr |
||||
|
||||
# CMake |
||||
cmake-build-*/ |
||||
|
||||
# Mongo Explorer plugin |
||||
.idea/**/mongoSettings.xml |
||||
|
||||
# File-based project format |
||||
*.iws |
||||
|
||||
# IntelliJ |
||||
out/ |
||||
|
||||
# mpeltonen/sbt-idea plugin |
||||
.idea_modules/ |
||||
|
||||
# JIRA plugin |
||||
atlassian-ide-plugin.xml |
||||
|
||||
# Cursive Clojure plugin |
||||
.idea/replstate.xml |
||||
|
||||
# Crashlytics plugin (for Android Studio and IntelliJ) |
||||
com_crashlytics_export_strings.xml |
||||
crashlytics.properties |
||||
crashlytics-build.properties |
||||
fabric.properties |
||||
|
||||
# Editor-based Rest Client |
||||
.idea/httpRequests |
||||
|
||||
# Android studio 3.1+ serialized cache file |
||||
.idea/caches/build_file_checksums.ser |
||||
|
||||
# Reference https://github.com/github/gitignore/blob/master/Go.gitignore |
||||
# Binaries for programs and plugins |
||||
*.exe |
||||
*.exe~ |
||||
*.dll |
||||
*.so |
||||
*.dylib |
||||
|
||||
# Test binary, built with `go test -c` |
||||
*.test |
||||
|
||||
# Output of the go coverage tool, specifically when used with LiteIDE |
||||
*.out |
||||
|
||||
# Dependency directories (remove the comment below to include it) |
||||
vendor/ |
||||
|
||||
# Compiled Object files, Static and Dynamic libs (Shared Objects) |
||||
*.o |
||||
*.a |
||||
|
||||
# OS General |
||||
Thumbs.db |
||||
.DS_Store |
||||
|
||||
# project |
||||
*.cert |
||||
*.key |
||||
*.log |
||||
bin/ |
||||
|
||||
# Develop tools |
||||
.vscode/ |
||||
.idea/ |
||||
*.swp |
||||
@ -1,58 +1,3 @@ |
||||
# utils通用包 |
||||
# utils |
||||
|
||||
<!-- TOC --> |
||||
* [utils通用包](#utils通用包) |
||||
* [安装](#安装) |
||||
* [通用包](#通用包) |
||||
* [pagination](#pagination) |
||||
* [transport：通用http ResponseEncoder](#transport通用http-responseencoder) |
||||
* [meta：跨服务meta信息设置和获取](#meta跨服务meta信息设置和获取) |
||||
* [encrypt：对称加密](#encrypt对称加密) |
||||
<!-- TOC --> |
||||
|
||||
## 安装 |
||||
|
||||
1. 设置私有仓库 |
||||
|
||||
```shell |
||||
go env -w GOPRIVATE=gitea.drugeyes.vip |
||||
``` |
||||
|
||||
2. 设置git |
||||
|
||||
```shell |
||||
git config --global url."ssh://gitea@gitea.drugeyes.vip".insteadOf "https://gitea.drugeyes.vip" |
||||
``` |
||||
|
||||
3. 拉取对应版本 |
||||
|
||||
```shell |
||||
go get gitea.drugeyes.vip/pharnexbase/tools@v1.0.0 |
||||
``` |
||||
|
||||
## 通用包 |
||||
|
||||
### pagination |
||||
|
||||
* v1 |
||||
|
||||
> 说明 |
||||
|
||||
### transport：通用http ResponseEncoder |
||||
|
||||
* v1 |
||||
|
||||
> 通用http ResponseEncoder |
||||
|
||||
### meta：跨服务meta信息设置和获取 |
||||
|
||||
* v1 |
||||
|
||||
> 跨服务meta信息设置和获取 |
||||
> - user（基础用户信息） |
||||
|
||||
### encrypt：对称加密 |
||||
|
||||
* v1 |
||||
|
||||
> 对称加密，目前包含：SHA1PRNG |
||||
通用包 |
||||
@ -1,102 +0,0 @@ |
||||
package encrypt |
||||
|
||||
import ( |
||||
"crypto/aes" |
||||
"crypto/hmac" |
||||
"crypto/sha1" |
||||
"errors" |
||||
) |
||||
|
||||
//AesEncryptECBSha1prng java AES 加密 SHA1PRNG
|
||||
func AesEncryptECBSha1prng(src []byte, key []byte) ([]byte, error) { |
||||
sha1prngKey, err := GetSha1prngKey(key, 128) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
|
||||
return AesEncryptECB(src, sha1prngKey), nil |
||||
} |
||||
|
||||
//AesDecryptECBSha1prng java AES 解密 SHA1PRNG
|
||||
func AesDecryptECBSha1prng(encrypted []byte, key []byte) ([]byte, error) { |
||||
sha1prngKey, err := GetSha1prngKey(key, 128) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
|
||||
return AesDecryptECB(encrypted, sha1prngKey), nil |
||||
} |
||||
|
||||
//AesEncryptECB AES-128-ECB 加密，（php:openssl_encrypt($string, 'AES-128-ECB', $key, OPENSSL_RAW_DATA)）
|
||||
func AesEncryptECB(src []byte, key []byte) []byte { |
||||
c, _ := aes.NewCipher(generateKey(key)) |
||||
length := (len(src) + aes.BlockSize) / aes.BlockSize |
||||
plain := make([]byte, length*aes.BlockSize) |
||||
copy(plain, src) |
||||
pad := byte(len(plain) - len(src)) |
||||
for i := len(src); i < len(plain); i++ { |
||||
plain[i] = pad |
||||
} |
||||
encrypted := make([]byte, len(plain)) |
||||
// 分组分块加密
|
||||
for bs, be := 0, c.BlockSize(); bs <= len(src); bs, be = bs+c.BlockSize(), be+c.BlockSize() { |
||||
c.Encrypt(encrypted[bs:be], plain[bs:be]) |
||||
} |
||||
|
||||
return encrypted |
||||
} |
||||
|
||||
//AesDecryptECB AES-128-ECB 解密
|
||||
func AesDecryptECB(encrypted []byte, key []byte) []byte { |
||||
c, _ := aes.NewCipher(generateKey(key)) |
||||
decrypted := make([]byte, len(encrypted)) |
||||
|
||||
for bs, be := 0, c.BlockSize(); bs < len(encrypted); bs, be = bs+c.BlockSize(), be+c.BlockSize() { |
||||
c.Decrypt(decrypted[bs:be], encrypted[bs:be]) |
||||
} |
||||
|
||||
trim := 0 |
||||
if len(decrypted) > 0 { |
||||
trim = len(decrypted) - int(decrypted[len(decrypted)-1]) |
||||
} |
||||
|
||||
return decrypted[:trim] |
||||
} |
||||
|
||||
// GetSha1prngKey 模拟 java SHA1PRNG 处理，（php:substr(openssl_digest(openssl_digest($key, 'sha1', true), 'sha1', true), 0, 16)）
|
||||
func GetSha1prngKey(keyBytes []byte, encryptLength int) ([]byte, error) { |
||||
hashs := Sha1(Sha1(keyBytes)) |
||||
maxLen := len(hashs) |
||||
realLen := encryptLength / 8 |
||||
if realLen > maxLen { |
||||
return nil, errors.New("invalid length") |
||||
} |
||||
|
||||
return hashs[0:realLen], nil |
||||
} |
||||
|
||||
//Sha1 Sha1
|
||||
func Sha1(data []byte) []byte { |
||||
h := sha1.New() |
||||
h.Write(data) |
||||
return h.Sum(nil) |
||||
} |
||||
|
||||
// HmacSha1 HmacSha1
|
||||
func HmacSha1(string, secret string) []byte { |
||||
mac := hmac.New(sha1.New, []byte(secret)) |
||||
mac.Write([]byte(string)) |
||||
|
||||
return mac.Sum(nil) |
||||
} |
||||
|
||||
func generateKey(key []byte) (genKey []byte) { |
||||
genKey = make([]byte, 16) |
||||
copy(genKey, key) |
||||
for i := 16; i < len(key); { |
||||
for j := 0; j < 16 && i < len(key); j, i = j+1, i+1 { |
||||
genKey[j] ^= key[i] |
||||
} |
||||
} |
||||
return genKey |
||||
} |
||||
@ -1,75 +0,0 @@ |
||||
package meta |
||||
|
||||
import ( |
||||
"context" |
||||
"encoding/json" |
||||
"errors" |
||||
"github.com/go-kratos/kratos/v2/metadata" |
||||
) |
||||
|
||||
const ( |
||||
userMetaKey = "x-md-global-user" |
||||
) |
||||
|
||||
var UserErr = errors.New("userinfo error") |
||||
|
||||
// User 用户信息
|
||||
type User struct { |
||||
// 用户id
|
||||
Id int32 `json:"id"` |
||||
// 邮箱
|
||||
Email string `json:"email"` |
||||
// 账号
|
||||
Username string `json:"username"` |
||||
// 手机号
|
||||
Phone string `json:"phone"` |
||||
// 昵称
|
||||
Nickname string `json:"nickname"` |
||||
// 头像
|
||||
Avatar string `json:"avatar"` |
||||
// 状态 1=正常;2=封禁
|
||||
Status int32 `json:"status"` |
||||
} |
||||
|
||||
// SetUserMetaClient 设置用户meta信息
|
||||
func SetUserMetaClient(ctx context.Context, user *User) context.Context { |
||||
userInfo, _ := json.Marshal(user) |
||||
return metadata.AppendToClientContext(ctx, userMetaKey, string(userInfo)) |
||||
} |
||||
|
||||
// GetUserMetaClient 获取用户meta信息
|
||||
func GetUserMetaClient(ctx context.Context) (*User, error) { |
||||
if meta, ok := metadata.FromClientContext(ctx); ok { |
||||
user := &User{} |
||||
if json.Unmarshal([]byte(meta.Get(userMetaKey)), user) != nil { |
||||
return nil, UserErr |
||||
} |
||||
return user, nil |
||||
} |
||||
return nil, UserErr |
||||
} |
||||
|
||||
// SetUserMetaServer 设置用户meta信息
|
||||
func SetUserMetaServer(ctx context.Context, user *User) context.Context { |
||||
userInfo, _ := json.Marshal(user) |
||||
|
||||
var meta metadata.Metadata |
||||
var ok bool |
||||
if meta, ok = metadata.FromServerContext(ctx); ok { |
||||
meta.Set(userMetaKey, string(userInfo)) |
||||
} |
||||
|
||||
return metadata.NewServerContext(ctx, meta) |
||||
} |
||||
|
||||
// GetUserMetaServer 获取用户meta信息
|
||||
func GetUserMetaServer(ctx context.Context) (*User, error) { |
||||
if meta, ok := metadata.FromServerContext(ctx); ok { |
||||
user := &User{} |
||||
if json.Unmarshal([]byte(meta.Get(userMetaKey)), user) != nil { |
||||
return nil, UserErr |
||||
} |
||||
return user, nil |
||||
} |
||||
return nil, UserErr |
||||
} |
||||
Loading…
Reference in new issue