新增中宣部实名认证

main.go

@@ -14,6 +14,7 @@ import (
 	"github.com/astaxie/beego"
 	"github.com/drone/routes"
 
+	"box-3rdServer/nppa"
 	"box-3rdServer/sensitive"
 	"box-3rdServer/utils"
 )
@@ -30,6 +31,19 @@ func main() {
 	mux.Post("/sensitive/checkword", sensitive.HttpCheckWord)
 	mux.Get("/sensitive/changeword", sensitive.HttpChangeWord)
 	mux.Post("/sensitive/changeword", sensitive.HttpChangeWord)
+	// 实名认证
+	if nppa.IsModule() {
+		nppa.Init()
+		mux.Get("/nppa/check_id", nppa.HttpCheckPlayerID)
+		mux.Post("/nppa/check_id", nppa.HttpCheckPlayerID)
+		mux.Get("/nppa/query_id", nppa.HttpQueryPlayerID)
+		mux.Post("/nppa/query_id", nppa.HttpQueryPlayerID)
+		mux.Get("/nppa/loginout", nppa.HttpLoginout)
+		mux.Post("/nppa/loginout", nppa.HttpLoginout)
+		mux.Get("/nppa/test_check_id", nppa.HttpTestCheckPlayerID)
+		mux.Get("/nppa/test_query_id", nppa.HttpTestQueryPlayerID)
+		mux.Get("/nppa/test_loginout", nppa.HttpTestLoginout)
+	}
 
 	http.Handle("/", mux)
 	http.ListenAndServe(":"+beego.AppConfig.String("httpport"), nil)

nppa/interface.go

@@ -0,0 +1,258 @@
+/*
+ * @Descripttion:实名认证
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2022-07-06 14:32:44
+ */
+package nppa
+
+import (
+	"crypto/md5"
+	"encoding/hex"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/http"
+
+	"box-3rdServer/utils"
+)
+
+// 是否开启功能
+func IsModule() bool {
+	status := utils.StringToInt(utils.GetKeyConf("nppa", "status"))
+	return status > 0
+}
+
+// 初始化
+func Init() {
+	log.Println("nppa:Init")
+	initConf()
+
+	mapAidToConf.Range(func(k, v interface{}) bool {
+		aid := k.(int)
+		key := fmt.Sprintf(aidKey, aid)
+		for utils.Zcard(key) > 0 {
+			sendCollections(aid, key)
+		}
+		return true
+	})
+
+	ReportCollections()
+	// InitRecheckProc()
+}
+
+// 实名认证 - 校验
+// 方法：get/post
+// 参数：
+//
+//	uid:玩家ID
+//	channel:渠道
+//	name:实名-姓名
+//	idNum:实名-身份证ID
+//
+// 返回
+//
+//	true/false
+func HttpCheckPlayerID(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	uid := utils.StringToInt(req.Get("uid"))
+	chn := utils.StringToInt(req.Get("channel"))
+	name := req.Get("name")
+	idNum := req.Get("idNum")
+
+	ret := CheckPlayerId(uid, chn, name, idNum)
+	log.Printf("玩家[%d] 实名认证结果[%d] msg[%s]", uid, utils.StringToInt(ret["status"]), ret["msg"])
+
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}
+
+// 实名认证 - 查询
+// 方法：get/post
+// 参数：
+//
+//	uid:玩家ID
+//	channel:渠道
+//
+// 返回
+//
+//	ture/false
+func HttpQueryPlayerID(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	uid := utils.StringToInt(req.Get("uid"))
+	chn := utils.StringToInt(req.Get("channel"))
+
+	ret := QueryPlayerId(uid, chn)
+
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}
+
+// 实名认证 - 用户行为数据上报
+// 方法：get/post
+// 参数：
+//
+//	 channel:渠道
+//		si:游戏内部会话标识
+//	 bt:用户行为类型 0:下线 1:上线
+//	 ot:行为发生时间戳
+//	 ct:用户行为数据上报类型 0:已认证用户 2:游客
+//	 di:游客模式设备标识
+//	 pi:实名用户唯一标识
+func HttpLoginout(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	channel := req.Get("channel")
+	si := req.Get("si")
+	bt := utils.StringToInt(req.Get("bt"))
+	ot := utils.StringToInt(req.Get("ot"))
+	ct := utils.StringToInt(req.Get("ct"))
+	di := req.Get("di")
+	pi := req.Get("pi")
+
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+	if channel == "" {
+		log.Println("参数错误 channel")
+		ret["msg"] = "缺少参数 channel"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+	if si == "" {
+		log.Println("参数错误 si")
+		ret["msg"] = "缺少参数 uid"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+	if bt != 0 && bt != 1 {
+		log.Println("参数错误 bt")
+		ret["msg"] = "参数值错误 bt"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+	if ct != 0 && ct != 2 {
+		log.Println("参数错误 ct")
+		ret["msg"] = "参数值错误 ct"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+	if ct == 0 && pi == "" {
+		log.Println("参数错误 pi")
+		ret["msg"] = "缺少参数 pi"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+	if ct == 2 && di == "" {
+		log.Println("参数错误 di si:", si)
+		ret["msg"] = "缺少参数 di"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+
+	chn := utils.StringToInt(channel)
+	v, ok := mapChannelToConf.Load(chn)
+	if !ok {
+		ret["msg"] = "服务器缺少渠道配置"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+
+	v, ok = mapCollections.Load(v.(*ConfApp).aId)
+	if !ok {
+		// log.Println(fmt.Sprintf("缺少渠道配置 %d", chn))
+		ret["msg"] = "服务器缺少渠道配置"
+		pack, _ := json.Marshal(ret)
+		// 发送成功
+		w.Write(pack)
+		return
+	}
+
+	go func() {
+		if ct == 2 {
+			h := md5.Sum([]byte(di))
+			di = hex.EncodeToString(h[:])
+		}
+
+		v.(*nppaCollections).collection <- &Collection{
+			Si: si,
+			Bt: bt,
+			Ot: ot,
+			Ct: ct,
+			Di: di,
+			Pi: pi,
+		}
+	}()
+
+	ret["code"] = 200
+	ret["msg"] = "成功"
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}
+
+// 实名认证 - 配置更新
+func HttpUpdateConfig(w http.ResponseWriter, r *http.Request) {
+	ConfUpdate()
+	ReportCollections()
+}
+
+// 实名认证 - 测试校验
+func HttpTestCheckPlayerID(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	testCode := req.Get("testCode")
+	uid := req.Get("uid")
+	name := req.Get("name")
+	idNum := req.Get("idNum")
+
+	ret := TestCheckPlayerId(testCode, uid, name, idNum)
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}
+
+// 实名认证 - 测试查询结果
+func HttpTestQueryPlayerID(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	testCode := req.Get("testCode")
+	uid := req.Get("uid")
+
+	ret := TestQueryPlayerId(testCode, uid)
+
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}
+
+// 实名认证 - 测试数据上报
+func HttpTestLoginout(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	testCode := req.Get("testCode")
+	si := req.Get("si")
+	bt := utils.StringToInt(req.Get("bt"))
+	ct := utils.StringToInt(req.Get("ct"))
+	di := req.Get("di")
+	pi := req.Get("pi")
+
+	ret := TestLoginout(testCode, si, bt, ct, di, pi)
+
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}

nppa/interface_test.go

@@ -0,0 +1,90 @@
+/*
+ * @Author: zkj
+ * @Date: 2021-04-25 13:38:31
+ * @LastEditTime: 2021-04-25 15:50:07
+ * @LastEditors: Please set LastEditors
+ * @Description: 实名认证测试
+ * @FilePath: /order-server/nppa/interface_test.go
+ */
+package nppa
+
+import (
+	"crypto/aes"
+	"crypto/cipher"
+	"crypto/rand"
+	"crypto/sha256"
+	"encoding/base64"
+	"encoding/hex"
+	"encoding/json"
+	"io"
+	"sort"
+	"testing"
+
+	"box-3rdServer/utils"
+)
+
+func TestMakeRequestBody(t *testing.T) {
+	mapBody := make(map[string]string)
+	mapBody["ai"] = "test-accountId"
+	mapBody["name"] = "用户姓名"
+	mapBody["idNum"] = "371321199012310912"
+
+	pack, _ := json.Marshal(mapBody)
+
+	secretKey := "2836e95fcd10e04b0069bb1ee659955b"
+	key, _ := hex.DecodeString(secretKey)
+	block, err := aes.NewCipher(key)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	aesGcm, err := cipher.NewGCM(block)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	nonce := make([]byte, aesGcm.NonceSize())
+	if _, err := io.ReadFull(rand.Reader, nonce); err != nil {
+		t.Fatal(err)
+	}
+
+	cipherText := aesGcm.Seal(nonce, nonce, pack, nil)
+
+	// encode as base64 string
+	encoded := base64.StdEncoding.EncodeToString(cipherText)
+
+	ret := make(map[string]string)
+	ret["data"] = encoded
+	pack, _ = json.Marshal(ret)
+
+	t.Log(string(pack))
+}
+
+func TestMakeRequestSign(t *testing.T) {
+	secretKey := "2836e95fcd10e04b0069bb1ee659955b"
+	body := `{"data":"CqT/33f3jyoiYqT8MtxEFk3x2rlfhmgzhxpHqWosSj4d3hq2EbrtVyx2aLj565ZQNTcPrcDipnvpq/D/vQDaLKW70O83Q42zvR0//OfnYLcIjTPMnqa+SOhsjQrSdu66ySSORCAo"}`
+
+	var kvs utils.Kvs
+	kvs = append(kvs, &utils.Kv{Key: "appId", Value: "test-appId"})
+	kvs = append(kvs, &utils.Kv{Key: "bizId", Value: "test-bizId"})
+	kvs = append(kvs, &utils.Kv{Key: "timestamps", Value: "1584949895758"})
+	kvs = append(kvs, &utils.Kv{Key: "id", Value: "test-id"})
+	kvs = append(kvs, &utils.Kv{Key: "name", Value: "test-name"})
+	sort.Sort(kvs)
+
+	key := ""
+	for i := 0; i < kvs.Len(); i++ {
+		key += kvs[i].Key + kvs[i].Value
+	}
+
+	strEncode := secretKey + key + body
+
+	t.Log(strEncode, strEncode == `2836e95fcd10e04b0069bb1ee659955bappIdtest-appIdbizIdtest-bizIdidtest-idnametest-nametimestamps1584949895758{"data":"CqT/33f3jyoiYqT8MtxEFk3x2rlfhmgzhxpHqWosSj4d3hq2EbrtVyx2aLj565ZQNTcPrcDipnvpq/D/vQDaLKW70O83Q42zvR0//OfnYLcIjTPMnqa+SOhsjQrSdu66ySSORCAo"}`)
+
+	h2 := sha256.New()
+	h2.Write([]byte(strEncode))
+	hashed := h2.Sum(nil)
+
+	sign := hex.EncodeToString(hashed)
+	t.Log(string(sign), string(sign) == "386c03b776a28c06b8032a958fbd89337424ef45c62d0422706cca633d8ad5fd")
+}

nppa/realname.go

@@ -0,0 +1,165 @@
+/*
+ * @Descripttion:实名认证
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2021-05-10 15:52:40
+ */
+package nppa
+
+import (
+	"fmt"
+	"log"
+
+	"box-3rdServer/utils"
+
+	"github.com/bitly/go-simplejson"
+)
+
+type NppaInfo struct {
+	Ai     string `json:"ai,omitempty"`
+	Name   string `json:"name,omitempty"`
+	IdNum  string `json:"idNum,omitempty"`
+	Status int    `json:"status,omitempty"` // -1 未认证 0 认证成功 1 认证中 2 认证失败
+	Pi     string `json:"pi,omitempty"`
+}
+
+// 公安部实名认证 - 校验
+func NppaCheckPlayerId(chn int, ai string, name string, idNum string) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+	// 参数错误
+	if name == "" || idNum == "" {
+
+		log.Println("NppaCheckPlayerId 参数错误")
+		// 未响应
+		ret["msg"] = "参数错误"
+		return ret
+	}
+
+	mapHead := ConfGetInfoByChannel(chn)
+	if mapHead == nil {
+		ret["code"] = 200
+		ret["status"] = 0
+		// 未响应
+		ret["msg"] = "配置错误"
+		return ret
+	}
+
+	mapBody := make(map[string]interface{})
+	mapBody["ai"] = ai
+	mapBody["name"] = name
+	mapBody["idNum"] = idNum
+
+	body := MakeRequestBody(mapBody, mapHead["secretKey"])
+	sign := MakeRequestSign(mapHead, nil, body)
+	mapHead["sign"] = sign
+
+	buff, _ := Send2Nppa("POST", utils.GetKeyConf("nppa", "host_check"), mapHead, nil, body)
+	j, err := simplejson.NewJson(buff)
+	if err != nil {
+		log.Println("NppaCheckPlayerId err", err)
+		// 未响应
+		ret["msg"] = "未响应"
+		return ret
+	}
+	code, _ := j.Get("errcode").Int()
+	if code == 0 {
+		ret["code"] = 200
+		ret["status"], _ = j.Get("data").Get("result").Get("status").Int()
+		if ret["status"] == 0 {
+			ret["pi"], _ = j.Get("data").Get("result").Get("pi").String()
+		}
+	} else {
+		log.Println(fmt.Sprintf("NppaCheckPlayerId chn[%d] ai[%s] name[%s] idNum[%s] ret[%v]", chn, ai, name, idNum, j))
+		if code == 2001 || code == 2002 || code == 2003 || code == 2004 {
+			ret["code"] = 200
+			ret["status"] = 2 // 这几种情况默认认证失败
+		}
+	}
+	ret["msg"], _ = j.Get("errmsg").String()
+	return ret
+}
+
+// 公安部实名认证 - 查询结果
+func NppaQueryPlayerId(uid string, chn int) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+
+	mapHead := ConfGetInfoByChannel(chn)
+	if mapHead == nil {
+		ret["code"] = 200
+		ret["status"] = 0
+		// 未响应
+		ret["msg"] = "配置错误"
+		return ret
+	}
+
+	mapParam := make(map[string]string)
+	mapParam["ai"] = uid
+
+	sign := MakeRequestSign(mapHead, mapParam, "")
+	mapHead["sign"] = sign
+
+	buff, _ := Send2Nppa("GET", utils.GetKeyConf("nppa", "host_query"), mapHead, mapParam, "")
+	j, err := simplejson.NewJson(buff)
+	if err != nil {
+		log.Println("NppaQueryPlayerId err", err)
+		// 未响应
+		ret["msg"] = "未响应"
+		return ret
+	}
+	code, _ := j.Get("errcode").Int()
+	if code == 0 {
+		ret["code"] = 200
+		ret["status"], _ = j.Get("data").Get("result").Get("status").Int()
+		if ret["status"] == 0 {
+			ret["pi"], _ = j.Get("data").Get("result").Get("pi").String()
+		}
+	} else {
+		log.Println(fmt.Sprintf("NppaQueryPlayerId chn[%d] uid[%s] ret[%v]", chn, uid, j))
+		if code == 2001 || code == 2002 || code == 2003 || code == 2004 {
+			ret["code"] = 200
+			ret["status"] = 2 // 这几种情况默认认证失败
+		}
+	}
+	ret["msg"], _ = j.Get("errmsg").String()
+	return ret
+}
+
+// 实名认证 - 校验
+func CheckPlayerId(uid int, chn int, name string, idNum string) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+	if uid < 1000000 {
+		log.Println("参数错误 uid")
+		ret["msg"] = "参数错误 uid"
+		return ret
+	}
+	if name == "" {
+		log.Println("参数错误 name uid:", uid)
+		ret["msg"] = "缺少参数 name"
+		return ret
+	}
+	if idNum == "" {
+		log.Println("参数错误 idNum")
+		ret["msg"] = "缺少参数 idNum"
+		return ret
+	}
+
+	return NppaCheckPlayerId(chn, fmt.Sprintf("%032d", uid), name, idNum)
+}
+
+// 实名认证 - 查询
+func QueryPlayerId(uid int, chn int) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+	if uid < 1000000 {
+		log.Println("参数错误 uid")
+		ret["msg"] = "参数错误 uid"
+		return ret
+	}
+
+	return NppaQueryPlayerId(fmt.Sprintf("%032d", uid), chn)
+}

nppa/recheck.go

@@ -0,0 +1,254 @@
+/*
+ * @Descripttion:实名认证
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2022-04-12 20:27:24
+ */
+package nppa
+
+import (
+	"bufio"
+	"encoding/json"
+	"fmt"
+	"io"
+	"log"
+	"os"
+	"strconv"
+	"strings"
+	"time"
+
+	"box-3rdServer/utils"
+
+	"github.com/astaxie/beego"
+	"github.com/bitly/go-simplejson"
+	"github.com/garyburd/redigo/redis"
+)
+
+func getNextTime(now time.Time, startTime string) time.Time {
+	arr := strings.Split(startTime, ":")
+	hour, _ := strconv.Atoi(arr[0])
+	min, _ := strconv.Atoi(arr[1])
+	next := time.Date(now.Year(), now.Month(), now.Day(), hour, min, 0, 0, now.Location())
+	if now.Before(next) {
+		return next
+	}
+
+	next = now.Add(time.Hour * 24)
+	next = time.Date(next.Year(), next.Month(), next.Day(), hour, min, 0, 0, next.Location())
+	return next
+}
+
+// 备份程序初始化
+func InitRecheckProc() {
+	title := "存量用户实名认证数据检验"
+	timeBackup := utils.GetKeyConf("nppa", "recheck_time")
+	if timeBackup == "" {
+		// 不开启存量用户同步
+		return
+	}
+	go func() {
+		for {
+			now := time.Now()
+			//返回一个指定时间的下次执行的时间戳
+			next := getNextTime(now, timeBackup)
+			t := time.NewTimer(next.Sub(now))
+			log.Printf("下一次【麻将】 [%s] 开始时间为[%s]", title, next.String())
+			<-t.C
+			log.Printf("%s--> 神手麻将", title)
+			RecheckTimeout()
+		}
+	}()
+}
+
+// 存量用户 - 重新校验玩家列表key
+func RecheckDataKey(isAddDay bool) string {
+	now := time.Now()
+	if isAddDay {
+		now = now.Add(time.Hour * 24)
+	}
+	keyRecheck := fmt.Sprintf("idRecheck:%d%02d%02d", now.Year(), now.Month(), now.Day())
+
+	return keyRecheck
+}
+
+// 通知游戏服 - 存量用户验证结果
+func UpdatePlayerIdentifyInfo(uid int, m map[string]interface{}) {
+	idInfo := utils.GetPlayerInfoFromRedis(uid, utils.GetKeyConf("nppa", "key_id_info"))
+	if idInfo == "" {
+		idInfo = "{}"
+	}
+
+	j, err := simplejson.NewJson([]byte(idInfo))
+	if err != nil {
+		log.Println("UpdatePlayerIdentifyInfo err:", err)
+		return
+	}
+	if m["status"] == 0 || m["status"] == 1 {
+		j.Set("nppaStatus", m["status"])
+		j.Set("pi", m["pi"])
+		j.Set("jmIDName", m["name"])
+		j.Set("jmIDCard", m["idNum"])
+		j.Set("lastCheckTime", time.Now().Unix())
+		j.Set("award", true)
+	} else {
+		j.Del("nppaStatus")
+		j.Del("birthType")
+		j.Del("jmBirthDate")
+		j.Del("jmName")
+		j.Del("jmIDCard")
+	}
+	buff, _ := json.Marshal(j)
+	idInfo = string(buff)
+
+	utils.SetPlayerInfoFromRedis(uid, utils.GetKeyConf("nppa", "key_id_info"), idInfo)
+}
+
+// 存量玩家重新实名认证
+func RecheckPlayerId(uid int) {
+	// 玩家信息是否已备份
+	if !utils.IsPlayerExistInRedis(uid) {
+		return
+	}
+	// 根据项目获取玩家已实名认证数据
+	// name:玩家实名认证姓名
+	// idNum:玩家实名认证身份证号码
+	idInfo := GetJiamiIdInfo(uid)
+	if idInfo["name"] == "" || idInfo["idNum"] == "" || idInfo["chn"] == "" {
+		return
+	}
+
+	ret := NppaCheckPlayerId(utils.StringToInt(idInfo["chn"]), fmt.Sprintf("%032d", uid), idInfo["name"], idInfo["idNum"])
+	// log.Printf("RecheckPlayerId uid[%d] ret[%v]", uid, ret)
+
+	keyRecheck := RecheckDataKey(true)
+	// 认证中 - 放入重新校验列表
+	if ret["code"] == 200 {
+		if ret["status"] == 1 {
+			utils.Sadd(keyRecheck, utils.IntToString(uid))
+
+		} else {
+			ret["name"] = idInfo["name"]
+			ret["idNum"] = idInfo["idNum"]
+			UpdatePlayerIdentifyInfo(uid, ret)
+		}
+	}
+}
+
+// 存量玩家重新实名认证
+func RecheckQueryPlayerId(uid int) {
+	// 根据项目获取玩家已实名认证数据
+	// name:玩家实名认证姓名
+	// idNum:玩家实名认证身份证号码
+	idInfo := GetJiamiIdInfo(uid)
+	if idInfo["name"] == "" || idInfo["idNum"] == "" || idInfo["chn"] == "" {
+		// 旧数据已删除
+		return
+	}
+
+	ret := NppaQueryPlayerId(fmt.Sprintf("%032d", uid), utils.StringToInt(idInfo["chn"]))
+
+	keyRecheck := RecheckDataKey(true)
+	// 失败 - 放入重新校验列表
+	if ret["code"] == 200 {
+		if ret["status"] == 1 {
+			utils.Sadd(keyRecheck, utils.IntToString(uid))
+
+		} else {
+			ret["name"] = idInfo["name"]
+			ret["idNum"] = idInfo["idNum"]
+			UpdatePlayerIdentifyInfo(uid, ret)
+		}
+	}
+}
+
+// 获取玩家uid列表 - 文件形式
+func RecheckPlayersFromFile() {
+	// 已经跑过文件
+	if utils.GetAccountKeyInfo("idRecheck") != "" {
+		return
+	}
+	project := utils.GetConfigPath()
+	sFile := fmt.Sprintf("%srecheck_uids.txt", project)
+	if beego.AppConfig.String("runmode") == "test" {
+		sFile = fmt.Sprintf("%srecheck_uids_test.txt", project)
+	}
+	// 重新创建
+	f, err2 := os.OpenFile(sFile, os.O_CREATE|os.O_RDONLY, 0666)
+	if err2 != nil {
+		log.Println("打开配置文件失败 ", sFile)
+		return
+	}
+	defer f.Close()
+
+	title := "重新验证玩家实名认证数据"
+
+	log.Printf("开始 - %s - 文件", title)
+	buff := bufio.NewReader(f)
+	pos := 0
+	for {
+		// line, err := buff.ReadString('\n')
+		line, _, err := buff.ReadLine()
+
+		if err != nil || io.EOF == err {
+			break
+		}
+		// line = strings.TrimSpace(line)
+
+		uid := utils.StringToInt(strings.TrimSpace(string(line)))
+		log.Printf("%s uid[%d]", title, uid)
+		pos += 1
+		if uid >= 1000000 {
+			RecheckPlayerId(uid)
+			time.Sleep(100 * time.Millisecond)
+		}
+	}
+
+	utils.SetAccountKeyInfo("idRecheck", time.Now().Format("2006-01-02"))
+
+	log.Printf("结束 - %s - 文件", title)
+}
+
+// key数据是否存在
+func IsKeyExistInRedis(key string) bool {
+	pool := utils.GetAccountRedisPool()
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return false
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	is_key_exit, _ := redis.Bool(rd.Do("EXISTS", key))
+
+	return is_key_exit
+}
+
+// 定时器 - 结束
+func RecheckTimeout() {
+	keyRecheck := RecheckDataKey(false)
+	if IsKeyExistInRedis(keyRecheck) {
+		pool := utils.GetAccountRedisPool()
+		if pool == nil {
+			fmt.Println("get redis pool fail")
+			return
+		}
+		rd := pool.Get()
+		defer rd.Close()
+
+		title := "查询结果玩家实名认证数据"
+		log.Printf("开始 - %s - 查询结果", title)
+		result, _ := redis.Values(rd.Do("smembers", keyRecheck))
+		for _, v2 := range result {
+			uid := utils.StringToInt(string(v2.([]byte)))
+			log.Printf("%s uid[%d]", title, uid)
+			RecheckQueryPlayerId(uid)
+
+			time.Sleep(100 * time.Millisecond)
+		}
+		log.Printf("结束 - %s - 查询结果", title)
+	} else {
+		RecheckPlayersFromFile()
+	}
+}

nppa/report.go

@@ -0,0 +1,155 @@
+/*
+ * @Descripttion:实名认证
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Please set LastEditors
+ * @LastEditTime: 2021-05-10 16:12:02
+ */
+package nppa
+
+import (
+	"encoding/json"
+	"fmt"
+	"log"
+	"math/rand"
+	"sync"
+	"time"
+
+	"box-3rdServer/utils"
+
+	"github.com/bitly/go-simplejson"
+)
+
+type Collection struct {
+	No int    `json:"no,omitempty"` //条目编号
+	Si string `json:"si,omitempty"` //游戏内部会话标识
+	Bt int    `json:"bt"`           //用户行为类型
+	Ot int    `json:"ot,omitempty"` //行为发生时间
+	Ct int    `json:"ct"`           //上报类型
+	Di string `json:"di,omitempty"` //设备标识
+	Pi string `json:"pi,omitempty"` //用户唯一标识
+}
+
+type nppaCollections struct {
+	aid        int
+	collection chan *Collection
+	timer      *time.Timer
+	close      chan int
+}
+
+var mapCollections sync.Map
+
+var aidKey = "nppa:aid:%d"
+
+var interval = time.Duration(120) //秒
+
+func sendCollections(aid int, key string) {
+	infos := utils.Zrange(key, 0, 127)
+	collections := []*Collection{}
+	for k, v := range infos {
+		collection := Collection{No: k + 1}
+		json.Unmarshal([]byte(v), &collection)
+		collections = append(collections, &collection)
+	}
+	NppaReportCollections(aid, collections)
+	utils.Zremrangebyrank(key, 0, len(infos)-1)
+}
+
+func getRandomInterval() time.Duration {
+	rand.Seed(time.Now().UnixNano())
+	return time.Duration(rand.Intn(21) - 10)
+}
+
+func ReportCollections() {
+	mapCollections.Range(func(k, v interface{}) bool {
+		_, ok := mapAidToConf.Load(k)
+		if !ok {
+			nppaCollections := v.(*nppaCollections)
+			nppaCollections.close <- 1
+			mapCollections.Delete(k)
+		}
+		return true
+	})
+
+	mapAidToConf.Range(func(k, v interface{}) bool {
+		_, ok := mapCollections.Load(k)
+		if !ok {
+			nppaCollections := nppaCollections{
+				aid:        k.(int),
+				collection: make(chan *Collection),
+				timer:      time.NewTimer(interval * time.Second),
+				close:      make(chan int),
+			}
+
+			key := fmt.Sprintf(aidKey, nppaCollections.aid)
+
+			go func() {
+				for {
+					select {
+					case collection := <-nppaCollections.collection:
+						info, _ := json.Marshal(collection)
+						utils.Zadd(key, collection.Ot, string(info))
+						if utils.Zcard(key) >= 128 {
+							sendCollections(nppaCollections.aid, key)
+							if len(nppaCollections.timer.C) > 0 {
+								<-nppaCollections.timer.C
+							}
+							nppaCollections.timer.Reset((interval + getRandomInterval()) * time.Second)
+						}
+					case <-nppaCollections.timer.C:
+						if utils.Zcard(key) > 0 {
+							sendCollections(nppaCollections.aid, key)
+						}
+						nppaCollections.timer.Reset((interval + getRandomInterval()) * time.Second)
+					case <-nppaCollections.close:
+						return
+					}
+				}
+			}()
+
+			mapCollections.Store(k, &nppaCollections)
+		}
+		return true
+	})
+}
+
+// 玩家行为数据上报
+func NppaReportCollections(aid int, collections []*Collection) {
+	mapHead := ConfGetInfoByAid(aid)
+	if mapHead == nil {
+		return
+	}
+
+	mapBody := make(map[string]interface{})
+	mapBody["collections"] = collections
+
+	body := MakeRequestBody(mapBody, mapHead["secretKey"])
+	sign := MakeRequestSign(mapHead, nil, body)
+	mapHead["sign"] = sign
+
+	buff, errReq := Send2Nppa("POST", utils.GetKeyConf("nppa", "host_loginout"), mapHead, nil, body)
+	j, err := simplejson.NewJson(buff)
+	if err != nil {
+		log.Printf("NppaReportCollections err[%v] errReq[%v]", err, errReq)
+		return
+	}
+	code, _ := j.Get("errcode").Int()
+	msg, _ := j.Get("errmsg").String()
+	if code != 0 {
+		log.Println(fmt.Sprintf("NppaReportCollections err code[%d] msg[%s]", code, msg))
+		for _, v := range collections {
+			log.Println(fmt.Sprintf("collection %v", v))
+		}
+		return
+	}
+	for _, v := range j.Get("data").Get("results").MustArray() {
+		result, _ := v.(map[string]interface{})
+		no := utils.JsonNumberToInt(result["no"])
+		errcode := utils.JsonNumberToInt(result["errcode"])
+		errmsg := result["errmsg"].(string)
+		if errcode != 0 {
+			log.Println(fmt.Sprintf("NppaReportCollections err collection[%v] ot[%d] code[%d] msg[%s]", collections[no-1], collections[no-1].Ot, errcode, errmsg))
+		}
+	}
+}

nppa/test.go

@@ -0,0 +1,162 @@
+/*
+ * @Descripttion:实名认证
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2021-05-06 14:46:17
+ */
+package nppa
+
+import (
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/bitly/go-simplejson"
+)
+
+// 实名认证 - 测试校验
+func TestCheckPlayerId(testCode string, uid string, name string, idNum string) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+
+	url := fmt.Sprintf("https://wlc.nppa.gov.cn/test/authentication/check/%s", testCode)
+	log.Println("TestCheckPlayerId url:", url)
+
+	chn := -1
+	mapHead := ConfGetInfoByChannel(chn)
+	if mapHead == nil {
+		// 未响应
+		ret["msg"] = "配置错误"
+		return ret
+	}
+
+	mapBody := make(map[string]interface{})
+	mapBody["ai"] = uid
+	mapBody["name"] = name
+	mapBody["idNum"] = idNum
+
+	body := MakeRequestBody(mapBody, mapHead["secretKey"])
+	sign := MakeRequestSign(mapHead, nil, body)
+	log.Println(fmt.Sprintf("TestCheckPlayerId body[%s] sign[%s]", body, sign))
+	mapHead["sign"] = sign
+
+	buff, _ := Send2Nppa("POST", url, mapHead, nil, body)
+	j, err := simplejson.NewJson(buff)
+	if err != nil {
+		log.Println("TestCheckPlayerId err", err)
+		// 未响应
+		ret["msg"] = "未响应"
+		return ret
+	}
+	code, _ := j.Get("errcode").Int()
+	if code == 0 {
+		ret["code"] = 200
+	} else {
+		log.Println("TestCheckPlayerId ret:", j)
+	}
+	ret["msg"], _ = j.Get("errmsg").String()
+
+	return ret
+}
+
+// 实名认证 - 测试查询结果
+func TestQueryPlayerId(testCode string, uid string) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+
+	url := fmt.Sprintf("https://wlc.nppa.gov.cn/test/authentication/query/%s", testCode)
+	log.Println("TestQueryPlayerId url:", url)
+
+	chn := -1
+	mapHead := ConfGetInfoByChannel(chn)
+	if mapHead == nil {
+		// 未响应
+		ret["msg"] = "配置错误"
+		return ret
+	}
+
+	mapParam := make(map[string]string)
+	mapParam["ai"] = uid
+
+	sign := MakeRequestSign(mapHead, mapParam, "")
+	log.Println(fmt.Sprintf("TestQueryPlayerId uid[%s] sign[%s]", uid, sign))
+	mapHead["sign"] = sign
+
+	buff, _ := Send2Nppa("GET", url, mapHead, mapParam, "")
+	j, err := simplejson.NewJson(buff)
+	if err != nil {
+		log.Println("TestQueryPlayerId err", err)
+		// 未响应
+		ret["msg"] = "未响应"
+
+		return ret
+	}
+	code, _ := j.Get("errcode").Int()
+	if code == 0 {
+		ret["code"] = 200
+	} else {
+		log.Println("TestQueryPlayerId ret:", j)
+	}
+	ret["msg"], _ = j.Get("errmsg").String()
+
+	return ret
+}
+
+// 实名认证 - 测试数据上报
+func TestLoginout(testCode string, si string, bt int, ct int, di string, pi string) map[string]interface{} {
+	ret := make(map[string]interface{})
+	ret["code"] = 400
+
+	url := fmt.Sprintf("https://wlc.nppa.gov.cn/test/collection/loginout/%s", testCode)
+	log.Println("TestLoginout url:", url)
+
+	chn := -1
+	mapHead := ConfGetInfoByChannel(chn)
+	if mapHead == nil {
+		// 未响应
+		ret["msg"] = "配置错误"
+		return ret
+	}
+
+	mapBody := make(map[string]interface{})
+	collections := []map[string]interface{}{}
+	collection := make(map[string]interface{})
+	collection["no"] = 1
+	collection["si"] = si
+	collection["bt"] = bt
+	collection["ot"] = time.Now().Unix()
+	collection["ct"] = ct
+	if ct == 0 {
+		collection["pi"] = pi
+	} else if ct == 2 {
+		collection["di"] = di
+	}
+	collections = append(collections, collection)
+	mapBody["collections"] = collections
+
+	body := MakeRequestBody(mapBody, mapHead["secretKey"])
+	sign := MakeRequestSign(mapHead, nil, body)
+	log.Println(fmt.Sprintf("TestLoginout body[%s] sign[%s]", body, sign))
+	mapHead["sign"] = sign
+
+	buff, _ := Send2Nppa("POST", url, mapHead, nil, body)
+	j, err := simplejson.NewJson(buff)
+	if err != nil {
+		log.Println("TestLoginout err", err)
+		// 未响应
+		ret["msg"] = "未响应"
+
+		return ret
+	}
+	code, _ := j.Get("errcode").Int()
+	if code == 0 {
+		ret["code"] = 200
+	} else {
+		log.Println("TestLoginout ret:", j)
+	}
+	ret["msg"], _ = j.Get("errmsg").String()
+
+	return ret
+}

nppa/util.go

@@ -0,0 +1,317 @@
+/*
+ * @Descripttion:实名认证
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2022-04-12 20:27:43
+ */
+package nppa
+
+import (
+	"crypto/aes"
+	"crypto/cipher"
+	"crypto/rand"
+	"crypto/sha256"
+	"encoding/base64"
+	"encoding/hex"
+	"encoding/json"
+	"fmt"
+	"io"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"net/url"
+	"sort"
+	"strconv"
+	"strings"
+	"sync"
+	"time"
+
+	"box-3rdServer/utils"
+
+	"github.com/bitly/go-simplejson"
+)
+
+type ConfApp struct {
+	aId       int
+	appId     string
+	appName   string
+	bizId     string
+	secretKey string
+}
+
+var mapAidToConf sync.Map
+var mapChannelToConf sync.Map
+
+// 初始化
+func initConf() {
+	path := utils.GetConfigPath()
+	j := utils.LoadJsonFile(path + "NppaAppConfig.json")
+	tmpMapAidToConf := make(map[int]*ConfApp)
+	mapAppNameToConf := make(map[string]*ConfApp)
+	for _, v := range j.MustArray() {
+		item, _ := v.(map[string]interface{})
+		val, ok := item["aId"]
+		if !ok {
+			continue
+		}
+		aId := utils.JsonNumberToInt(val)
+		conf := &ConfApp{aId: aId}
+		val, ok = item["appId"]
+		if ok {
+			conf.appId = val.(string)
+		}
+		val, ok = item["appName"]
+		if ok {
+			conf.appName = val.(string)
+		}
+		val, ok = item["bizId"]
+		if ok {
+			conf.bizId = val.(string)
+		}
+		val, ok = item["secretKey"]
+		if ok {
+			conf.secretKey = val.(string)
+		}
+		tmpMapAidToConf[aId] = conf
+		mapAppNameToConf[conf.appName] = conf
+	}
+
+	j = utils.LoadJsonFile(path + "NppaChannelConfig.json")
+	mapChannelToAid := make(map[int]int)
+	mapChannelToAppName := make(map[int]string)
+	for _, v := range j.MustArray() {
+		item, _ := v.(map[string]interface{})
+		val, ok := item["channel"]
+		if !ok {
+			continue
+		}
+		channel := utils.JsonNumberToInt(val)
+		val, ok = item["aId"]
+
+		if ok {
+			mapChannelToAid[channel] = utils.JsonNumberToInt(val)
+		}
+		val, ok = item["appName"]
+		if ok {
+			mapChannelToAppName[channel] = val.(string)
+		}
+	}
+
+	mapAidToConf.Range(func(k, v interface{}) bool {
+		_, ok := tmpMapAidToConf[k.(int)]
+		if !ok {
+			mapAidToConf.Delete(k)
+		}
+		return true
+	})
+	for k, v := range tmpMapAidToConf {
+		mapAidToConf.Store(k, v)
+	}
+
+	mapTmp := make(map[int]*ConfApp)
+	for k, v := range mapChannelToAid {
+		conf, ok := tmpMapAidToConf[v]
+		if ok {
+			mapTmp[k] = conf
+		}
+	}
+
+	mapChannelToConf.Range(func(k, v interface{}) bool {
+		_, ok := mapTmp[k.(int)]
+		if !ok {
+			mapChannelToConf.Delete(k)
+		}
+		return true
+	})
+	for k, v := range mapTmp {
+		mapChannelToConf.Store(k, v)
+	}
+}
+
+// 配置更新
+func ConfUpdate() {
+	initConf()
+}
+
+// 渠道配置
+func ConfGetInfoByAid(aid int) map[string]string {
+	v, ok := mapAidToConf.Load(aid)
+	if !ok {
+		return nil
+	}
+	conf := v.(*ConfApp)
+
+	info := make(map[string]string)
+	info["appId"] = conf.appId
+	info["bizId"] = conf.bizId
+	info["secretKey"] = conf.secretKey
+	info["timestamps"] = fmt.Sprintf("%v", time.Now().UnixNano()/1e6)
+
+	return info
+}
+
+// 渠道配置
+func ConfGetInfoByChannel(chn int) map[string]string {
+	v, ok := mapChannelToConf.Load(chn)
+	if !ok {
+		return nil
+	}
+	conf := v.(*ConfApp)
+
+	info := make(map[string]string)
+	info["appId"] = conf.appId
+	info["bizId"] = conf.bizId
+	info["secretKey"] = conf.secretKey
+	info["timestamps"] = fmt.Sprintf("%v", time.Now().UnixNano()/1e6)
+
+	return info
+}
+
+// 创建请求消息body
+func MakeRequestBody(m map[string]interface{}, secretKey string) string {
+	pack, _ := json.Marshal(m)
+
+	key, _ := hex.DecodeString(secretKey)
+	block, err := aes.NewCipher(key)
+	if err != nil {
+		return ""
+	}
+
+	aesGcm, err := cipher.NewGCM(block)
+	if err != nil {
+		return ""
+	}
+	// 向量
+	nonce := make([]byte, aesGcm.NonceSize())
+	if _, err := io.ReadFull(rand.Reader, nonce); err != nil {
+		return ""
+	}
+
+	cipherText := aesGcm.Seal(nonce, nonce, pack, nil)
+
+	// encode as base64 string
+	encoded := base64.StdEncoding.EncodeToString(cipherText)
+
+	ret := make(map[string]string)
+	ret["data"] = encoded
+	pack, _ = json.Marshal(ret)
+
+	return string(pack)
+}
+
+// 签名
+func MakeRequestSign(heads map[string]string, params map[string]string, body string) string {
+	var kvs utils.Kvs
+	kvs = append(kvs, &utils.Kv{Key: "appId", Value: heads["appId"]})
+	kvs = append(kvs, &utils.Kv{Key: "bizId", Value: heads["bizId"]})
+	kvs = append(kvs, &utils.Kv{Key: "timestamps", Value: heads["timestamps"]})
+	for k, v := range params {
+		kvs = append(kvs, &utils.Kv{Key: k, Value: url.QueryEscape(v)})
+	}
+	sort.Sort(kvs)
+
+	key := ""
+	for i := 0; i < kvs.Len(); i++ {
+		key += kvs[i].Key + kvs[i].Value
+	}
+
+	strEncode := heads["secretKey"] + key + body
+
+	h2 := sha256.New()
+	h2.Write([]byte(strEncode))
+	hashed := h2.Sum(nil)
+
+	sign := hex.EncodeToString(hashed)
+	// log.Println(fmt.Sprintf("MakeRequestSign strEncode[%s] sign[%s]", strEncode, sign))
+
+	return sign
+}
+
+// 请求 网络游戏防沉迷实名认证系统
+func Send2Nppa(method string, url string, heads map[string]string, params map[string]string, body string) ([]byte, error) {
+	if len(params) > 0 {
+		url += "?"
+		for k, v := range params {
+			url += k + "=" + v + "&"
+		}
+		url = url[:len(url)-1]
+	}
+	req, err1 := http.NewRequest(method, url, strings.NewReader(body))
+	if err1 != nil {
+		return nil, err1
+	}
+	req.Header.Set("Content-Type", "application/json;charset=utf-8")
+	req.Header.Set("appId", heads["appId"])
+	req.Header.Set("bizId", heads["bizId"])
+	req.Header.Set("timestamps", heads["timestamps"])
+	req.Header.Set("sign", heads["sign"])
+
+	client := &http.Client{}
+	resp, err2 := client.Do(req)
+	if err2 != nil {
+		return nil, err2
+	}
+	defer resp.Body.Close()
+
+	return ioutil.ReadAll(resp.Body)
+}
+
+// 测试签名
+func TestSign() string {
+	mapBody := make(map[string]interface{})
+	mapBody["id"] = "test-id"
+	mapBody["name"] = "test-name"
+	mapInfo := make(map[string]string)
+	mapInfo["appId"] = "test-appId"
+	mapInfo["bizId"] = "test-bizId"
+	mapInfo["secretKey"] = "2836e95fcd10e04b0069bb1ee659955b"
+	mapInfo["timestamps"] = "1584949895758"
+
+	body := MakeRequestBody(mapBody, mapInfo["secretKey"])
+	sign := MakeRequestSign(mapInfo, nil, body)
+	// log.Println(fmt.Sprintf("TestSign sign[%s]", sign))
+
+	return sign
+}
+
+// 获取玩家嘉米实名认证信息
+func GetJiamiIdInfo(uid int) map[string]string {
+	project := utils.GetProject()
+
+	idInfo := make(map[string]string)
+	// 麻将
+	if project == "mahjong" {
+		idInfo = GetMahjongIdInfo(uid)
+	} else if project == "H5ddz" {
+		idInfo = GetH5ddzIdInfo(uid)
+	}
+
+	return idInfo
+}
+func GetMahjongIdInfo(uid int) map[string]string {
+	idInfo := make(map[string]string)
+	idInfo["name"] = utils.GetPlayerInfoFromRedis(uid, "jmIDName")
+	idInfo["idNum"] = utils.GetPlayerInfoFromRedis(uid, "jmIDCard")
+	idInfo["chn"] = utils.GetPlayerInfoFromRedis(uid, "channel")
+
+	return idInfo
+}
+func GetH5ddzIdInfo(uid int) map[string]string {
+	idInfo := make(map[string]string)
+	info := utils.GetPlayerInfoFromRedis(uid, "info")
+
+	j, err := simplejson.NewJson([]byte(info))
+	if err != nil {
+		log.Println("GetH5ddzIdInfo err:", err)
+		return idInfo
+	}
+
+	idInfo["name"], _ = j.Get("antiAddiData").Get("identityName").String()
+	idInfo["idNum"], _ = j.Get("antiAddiData").Get("identity").String()
+	strChannel, _ := j.Get("channel").Int()
+	idInfo["chn"] = strconv.Itoa(strChannel)
+
+	return idInfo
+}

utils/redis.go

@@ -16,12 +16,15 @@ import (
 	"github.com/garyburd/redigo/redis"
 	redigo "github.com/gomodule/redigo/redis"
 )
+
 type Redis struct {
-	pool     *redigo.Pool
+	pool *redigo.Pool
 }
+
 // 连接池
 var mapRedisPool = make(map[string](map[int]*Redis))
 var mapAccountRedisPool = make(map[string]*Redis)
+
 // 实例数量
 var mapRedisCount = make(map[string]int)
 
@@ -32,6 +35,7 @@ func InitRedis() bool {
 	mapRedisCount[project] = count
 	return true
 }
+
 // 获取玩家连接池
 func GetPlayerRedisPool(uid int) *redigo.Pool {
 	project := GetProject()
@@ -76,6 +80,7 @@ func GetPlayerRedisPool(uid int) *redigo.Pool {
 	}
 	return redisConn.pool
 }
+
 // 获取account redis连接池
 func GetAccountRedisPool() *redigo.Pool {
 	project := GetProject()
@@ -221,4 +226,166 @@ func DelPlayerInfo(uid int) bool {
 	}
 
 	return true
-}
+}
+
+// 获取玩家信息key
+func KeyPlayerInfo(uid int) string {
+	keyPrefix := GetKeyConf("player", "key_player_info_prefix")
+	if keyPrefix == "" {
+		keyPrefix = "player:uid:"
+	}
+	return fmt.Sprintf("%s%d", keyPrefix, uid)
+}
+
+// key数据是否存在
+func IsPlayerExistInRedis(uid int) bool {
+	pool := GetPlayerRedisPool(uid)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return false
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	key := KeyPlayerInfo(uid)
+	is_key_exit, _ := redis.Bool(rd.Do("EXISTS", key))
+
+	return is_key_exit
+}
+
+// Zadd
+func Zadd(key string, score int, value string) {
+	pool := GetPlayerRedisPool(0)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return
+	}
+	redisConn := pool.Get()
+	if redisConn == nil {
+		fmt.Println("get redis conn fail")
+		return
+	}
+	defer redisConn.Close()
+
+	_, err := redisConn.Do("zadd", key, score, value)
+	if err != nil {
+		fmt.Println("Zadd err:", err)
+	}
+}
+
+// Zcard
+func Zcard(key string) int {
+	pool := GetPlayerRedisPool(0)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return 0
+	}
+	redisConn := pool.Get()
+	if redisConn == nil {
+		fmt.Println("get redis conn fail")
+		return 0
+	}
+	defer redisConn.Close()
+
+	reply, err := redisConn.Do("zcard", key)
+	if err != nil {
+		fmt.Println("Zcard err:", err)
+		return 0
+	}
+	count, _ := redis.Int(reply, err)
+	return count
+}
+
+// Zrange
+func Zrange(key string, start int, end int) []string {
+	pool := GetPlayerRedisPool(0)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return nil
+	}
+	redisConn := pool.Get()
+	if redisConn == nil {
+		fmt.Println("get redis conn fail")
+		return nil
+	}
+	defer redisConn.Close()
+
+	reply, err := redisConn.Do("zrange", key, start, end)
+	if err != nil {
+		fmt.Println("Zrange err:", err)
+		return nil
+	}
+	result, _ := redis.Strings(reply, err)
+	return result
+}
+
+// Zremrangebyrank
+func Zremrangebyrank(key string, start int, end int) {
+	pool := GetPlayerRedisPool(0)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return
+	}
+	redisConn := pool.Get()
+	if redisConn == nil {
+		fmt.Println("get redis conn fail")
+		return
+	}
+	defer redisConn.Close()
+
+	_, err := redisConn.Do("zremrangebyrank", key, start, end)
+	if err != nil {
+		fmt.Println("Zremrangebyrank err:", err)
+	}
+}
+
+// sadd
+func Sadd(key string, val string) {
+
+	pool := GetAccountRedisPool()
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	rd.Do("sadd", key, val)
+}
+
+// 获取redis key信息
+func GetAccountKeyInfo(key string) string {
+	pool := GetAccountRedisPool()
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return ""
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	val, err1 := redis.String(rd.Do("GET", key))
+	if err1 != nil {
+		log.Printf("redis GET %s fail! err:%v", key, err1)
+		return ""
+	}
+	return val
+}
+
+// 设置redis key信息
+func SetAccountKeyInfo(key string, val string) bool {
+	pool := GetAccountRedisPool()
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return false
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	_, err := rd.Do("SET", key, val)
+	if err != nil {
+		log.Printf("设置 key[%s] 信息fail! err:%s", key, err)
+		return false
+	}
+
+	return true
+}

utils/util.go

@@ -27,6 +27,7 @@ import (
 
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/config"
+	"github.com/bitly/go-simplejson"
 )
 
 // StringToInt string to int
@@ -53,6 +54,12 @@ func Int64ToString(number int64) string {
 	return strconv.FormatInt(number, 10)
 }
 
+func JsonNumberToInt(itf interface{}) int {
+	str := itf.(json.Number).String()
+
+	return StringToInt(str)
+}
+
 // GetConf config
 func GetConf(key string, file string) string {
 	iniconf, err := config.NewConfig("ini", file)
@@ -240,7 +247,7 @@ func pKCS5UnPadding(origData []byte) []byte {
 	return origData[:(length - unpadding)]
 }
 
-//AesEncrypt aes加密函数，返回加密后的结果长度是16的倍数
+// AesEncrypt aes加密函数，返回加密后的结果长度是16的倍数
 func AesEncrypt(origData, key []byte) ([]byte, error) {
 	block, err := aes.NewCipher(key)
 	if err != nil {
@@ -257,7 +264,7 @@ func AesEncrypt(origData, key []byte) ([]byte, error) {
 	return crypted, nil
 }
 
-//AesDecrypt aes解密函数，传入解密内容长度必须是16的倍数
+// AesDecrypt aes解密函数，传入解密内容长度必须是16的倍数
 func AesDecrypt(crypted, key []byte) ([]byte, error) {
 	block, err := aes.NewCipher(key)
 	if err != nil {
@@ -300,4 +307,21 @@ func DecodeData(ts string, data string) (string, error) {
 	}
 
 	return string(de), nil
-}
+}
+
+// 加载json配置文件
+func LoadJsonFile(fileName string) *simplejson.Json {
+	data, err := ioutil.ReadFile(fileName)
+	if err != nil {
+		fmt.Println("load readFile", fileName, "err:", err)
+		return nil
+	}
+
+	j, err := simplejson.NewJson(data)
+	if err != nil {
+		fmt.Println("load unmarshal", fileName, "err:", err)
+		return nil
+	}
+
+	return j
+}