初始化仓库

.gitignore

@@ -0,0 +1,11 @@
+
+*.pid
+*.xml
+*.xml
+*.xlsx
+*.out
+*.log
+box-3rdServer-*
+conf/app.conf
+go.mod
+go.sum

conf/neo/app.conf_ali

@@ -0,0 +1,8 @@
+#
+# 订单
+#
+
+appname = box-3rdServer
+httpport = 7002
+runmode = product
+project = neo

conf/neo/app.conf_ali_test

@@ -0,0 +1,8 @@
+#
+# 订单
+#
+
+appname = box-3rdServer
+httpport = 7344
+runmode = test
+project = neo

conf/neo/cfg.conf

@@ -0,0 +1 @@
+[servers]

conf/neo/cfg_test.conf

@@ -0,0 +1,11 @@
+[servers]
+
+[redis]
+count=1
+host_0=127.0.0.1
+port_0=6381
+auth_0=aGMtbmVvLWRldi0yMDIzMDQwNw==
+
+host_account=127.0.0.1
+port_account=6381
+auth_account=aGMtbmVvLWRldi0yMDIzMDQwNw==

main.go

@@ -0,0 +1,36 @@
+/*
+ * @Descripttion:
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2020-12-16 11:22:56
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2022-04-27 20:20:13
+ */
+package main
+
+import (
+	"net/http"
+
+	"github.com/astaxie/beego"
+	"github.com/drone/routes"
+
+	"box-3rdServer/sensitive"
+	"box-3rdServer/utils"
+)
+
+func main() {
+	utils.InitProject()
+	utils.InitRedis()
+
+	mux := routes.New()
+
+	// 敏感词
+	sensitive.Init()
+	mux.Get("/sensitive/checkword", sensitive.HttpCheckWord)
+	mux.Post("/sensitive/checkword", sensitive.HttpCheckWord)
+	mux.Get("/sensitive/changeword", sensitive.HttpChangeWord)
+	mux.Post("/sensitive/changeword", sensitive.HttpChangeWord)
+
+	http.Handle("/", mux)
+	http.ListenAndServe(":"+beego.AppConfig.String("httpport"), nil)
+}

run.sh

@@ -0,0 +1,37 @@
+###
+ # @Descripttion:
+ # @version:
+ # @Author: Neo,Huang
+ # @Date: 2020-11-06 09:53:23
+ # @LastEditors: Neo,Huang
+ # @LastEditTime: 2020-12-16 11:24:17
+###
+#!/bin/bash
+
+if [ $1 == "" ]; then
+    echo "请加上环境参数"
+    exit 1
+fi
+
+proName="box-3rdServer-"$1
+
+git pull
+go build -o $proName
+
+echo "kill $proName, copy new file"
+# kill -9 `cat ./$proName.pid`
+ps -ef|grep $proName |grep -v grep |awk '{print $2}' | xargs kill -9
+# kill -9 `ps -ef|grep $proName`
+# echo $pid
+# kill -9 $pid
+sleep 0.5
+
+cp conf/$1/app.conf_ali ./conf/app.conf
+
+rm -rf ./nohup_$1.out
+
+echo "restart "$proName
+nohup ./$proName > nohup_$1.log 2>&1 &
+
+echo "ok"
+exit 0;

run_test.sh

@@ -0,0 +1,37 @@
+###
+ # @Descripttion:
+ # @version:
+ # @Author: Neo,Huang
+ # @Date: 2020-11-06 09:53:23
+ # @LastEditors: Neo,Huang
+ # @LastEditTime: 2020-12-16 11:24:24
+###
+#!/bin/bash
+
+if [ $1 == "" ]; then
+    echo "请加上环境参数"
+    exit 1
+fi
+
+proName="box-3rdServer-"$1
+
+git pull
+go build -o $proName
+
+echo "kill $proName, copy new file"
+# kill -9 `cat ./$proName.pid`
+ps -ef|grep $proName |grep -v grep |awk '{print $2}' | xargs kill -9
+# kill -9 `ps -ef|grep $proName`
+# echo $pid
+# kill -9 $pid
+sleep 0.5
+
+cp conf/$1/app.conf_ali_test ./conf/app.conf
+
+rm -rf ./nohup_$1.out
+
+echo "restart "$proName
+nohup ./$proName > nohup_$1.log 2>&1 &
+
+echo "ok"
+exit 0;

sensitive/dfa.go

@@ -0,0 +1,160 @@
+/*
+ * @Descripttion:敏感词
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2021-08-06 14:12:44
+ */
+package sensitive
+
+import (
+	"bufio"
+	"fmt"
+	"io"
+	"os"
+	"strings"
+)
+
+type Null struct{}
+
+var sensitiveWord = make(map[string]interface{})
+var Set = make(map[string]Null)
+
+const InvalidWords = " ,~,!,@,#,$,%,^,&,*,(,),_,-,+,=,?,<,>,.,—,，,。,/,\\,|,《,》,？,;,:,：,',‘,；,“,"
+
+var InvalidWord = make(map[string]Null) //无效词汇，不参与敏感词汇判断直接忽略
+
+// 初始化
+func InitDFA() {
+	words := strings.Split(InvalidWords, ",")
+	for _, v := range words {
+		InvalidWord[v] = Null{}
+	}
+
+	f, err := os.Open("sensitive/words.txt")
+	if err != nil {
+		return
+	}
+	defer f.Close()
+
+	buff := bufio.NewReader(f)
+	for {
+		line, err := buff.ReadString('\n')
+
+		if err != nil || io.EOF == err {
+			break
+		}
+		line = strings.TrimSpace(line)
+
+		Set[line] = Null{}
+	}
+
+	AddSensitiveToMap(Set)
+}
+
+//生成违禁词集合
+func AddSensitiveToMap(set map[string]Null) {
+	for key := range set {
+		str := []rune(key)
+		nowMap := sensitiveWord
+		for i := 0; i < len(str); i++ {
+			if _, ok := nowMap[string(str[i])]; !ok { //如果该key不存在，
+				thisMap := make(map[string]interface{})
+				thisMap["isEnd"] = false
+				nowMap[string(str[i])] = thisMap
+				nowMap = thisMap
+			} else {
+				nowMap = nowMap[string(str[i])].(map[string]interface{})
+			}
+			if i == len(str)-1 {
+				nowMap["isEnd"] = true
+			}
+		}
+
+	}
+}
+func GetSensitiveMap() map[string]interface{} {
+	return sensitiveWord
+}
+
+//敏感词汇转换为*
+func ChangeSensitiveWords(txt string, sensitive map[string]interface{}) (word string) {
+	str := []rune(txt)
+	nowMap := sensitive
+	start := -1
+	tag := -1
+	for i := 0; i < len(str); i++ {
+		if _, ok := InvalidWord[(string(str[i]))]; ok || string(str[i]) == "," {
+			continue
+		}
+		if thisMap, ok := nowMap[string(str[i])].(map[string]interface{}); ok {
+			tag++
+			if tag == 0 {
+				start = i
+			}
+			isEnd, _ := thisMap["isEnd"].(bool)
+			if isEnd {
+				for y := start; y < i+1; y++ {
+					str[y] = 42
+				}
+				nowMap = sensitive
+				start = -1
+				tag = -1
+
+			} else {
+				nowMap = nowMap[string(str[i])].(map[string]interface{})
+			}
+
+		} else {
+			if start != -1 {
+				i = start
+			}
+			nowMap = sensitive
+			start = -1
+			tag = -1
+		}
+	}
+
+	return string(str)
+}
+
+// 敏感词检查
+func CheckSensitive(txt string, sensitive map[string]interface{}) string {
+	str := []rune(txt)
+	nowMap := sensitive
+	start := -1
+	tag := -1
+	for i := 0; i < len(str); i++ {
+		// 跳过无效字符
+		if _, ok := InvalidWord[(string(str[i]))]; ok || string(str[i]) == "," {
+			continue
+		}
+		if thisMap, ok := nowMap[string(str[i])].(map[string]interface{}); ok {
+			tag++
+			if tag == 0 {
+				start = i
+			}
+			isEnd, _ := thisMap["isEnd"].(bool)
+			if isEnd {
+				sensi := ""
+				for y := start; y < i+1; y++ {
+					sensi += string(str[y])
+				}
+				fmt.Printf("敏感词:%s\n", sensi)
+				return "false"
+			} else {
+				nowMap = nowMap[string(str[i])].(map[string]interface{})
+			}
+
+		} else {
+			if start != -1 {
+				i = start
+			}
+			nowMap = sensitive
+			start = -1
+			tag = -1
+		}
+	}
+	return "true"
+}

sensitive/interface.go

@@ -0,0 +1,51 @@
+/*
+ * @Descripttion:敏感词
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2021-04-17 11:04:16
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2021-04-20 09:52:10
+ */
+package sensitive
+
+import (
+	"encoding/json"
+	"net/http"
+)
+
+// 初始化
+func Init() {
+	InitDFA()
+}
+
+// 敏感词检查
+// 方法：get
+// 参数：
+// 	word:检查字符串
+// 返回
+// 	true/false
+func HttpCheckWord(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	word := req.Get("word")
+
+	cw := CheckSensitive(word, sensitiveWord)
+	// 发送成功
+	w.Write([]byte(cw))
+}
+
+// 敏感词检查
+// 方法：get
+// 参数：
+// 	word:检查字符串
+// 返回
+// 	true/false
+func HttpChangeWord(w http.ResponseWriter, r *http.Request) {
+	req := r.URL.Query()
+	word := req.Get("word")
+
+	ret := make(map[string]string)
+	ret["word"] = ChangeSensitiveWords(word, sensitiveWord)
+	pack, _ := json.Marshal(ret)
+	// 发送成功
+	w.Write(pack)
+}

utils/mysql.go

@@ -0,0 +1,76 @@
+/*
+ * @Descripttion:
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2020-10-16 14:29:56
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2020-11-09 14:11:24
+ */
+package utils
+
+import (
+	"fmt"
+
+	"database/sql"
+	"log"
+
+	// import sql driver
+	_ "github.com/go-sql-driver/mysql"
+)
+
+// 获取数据库handler
+var mapMysql = make(map[string]*sql.DB)
+
+// GetMysqlHandler getMysqlHandler
+func GetMysqlHandler() (*sql.DB, error) {
+	var err error
+	project := GetProject()
+
+	if mapMysql[project] != nil {
+		err = mapMysql[project].Ping()
+		if err == nil {
+			return mapMysql[project], nil
+		}
+		log.Print("GetMysqlHandler PING:", err)
+		mapMysql[project].Close()
+	}
+
+	configFile := GetConfigFile()
+
+	connString := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8", //
+		GetConf("mysql::user", configFile), GetConf("mysql::password", configFile),
+		GetConf("mysql::host", configFile), GetConf("mysql::port", configFile), GetConf("mysql::database", configFile))
+
+	log.Println("GetMysqlHandler connString:", connString)
+	mapMysql[project], err = sql.Open("mysql", connString)
+	if err != nil {
+		log.Fatal("Open connection failed:", err.Error())
+		return nil, err
+	}
+	err = mapMysql[project].Ping()
+	if err != nil {
+		log.Print("PING:", err)
+		return nil, err
+	}
+
+	return mapMysql[project], nil
+}
+
+// 更新玩家状态
+func UpdatePlayerStatus(uid int, status int) error {
+	db, err := GetMysqlHandler()
+	if err != nil {
+		log.Println("UpdatePlayerStatus get_mahjong_db, Error: ", err)
+		return err
+	}
+
+	sql := fmt.Sprintf("UPDATE game_user SET status=%d WHERE uid=%d;", status, uid)
+	// log.Println("order_insert_db sql:", sql)
+	_, err = db.Exec(sql)
+	if err != nil {
+		log.Println("UpdatePlayerStatus update data Exec Failed, Error: ", err)
+		return err
+	}
+
+	return nil
+}

utils/redis.go

@@ -0,0 +1,224 @@
+/*
+ * @Descripttion:
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2020-10-16 14:29:56
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2020-12-04 11:00:01
+ */
+package utils
+
+import (
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/garyburd/redigo/redis"
+	redigo "github.com/gomodule/redigo/redis"
+)
+type Redis struct {
+	pool     *redigo.Pool
+}
+// 连接池
+var mapRedisPool = make(map[string](map[int]*Redis))
+var mapAccountRedisPool = make(map[string]*Redis)
+// 实例数量
+var mapRedisCount = make(map[string]int)
+
+// InitRedis 初始化redis
+func InitRedis() bool {
+	count := StringToInt(GetKeyConf("redis", "count"))
+
+	mapRedisCount[project] = count
+	return true
+}
+// 获取玩家连接池
+func GetPlayerRedisPool(uid int) *redigo.Pool {
+	project := GetProject()
+	index := uid % mapRedisCount[project]
+	if mapRedisPool[project] == nil {
+		mapRedisPool[project] = make(map[int]*Redis)
+	}
+	redisConn := mapRedisPool[project][index]
+
+	if redisConn == nil {
+		configFile := GetConfigFile()
+		redisAddr := GetConf(fmt.Sprintf("redis::host_%d", index), configFile) + ":" + GetConf(fmt.Sprintf("redis::port_%d", index), configFile)
+		redisAuth := GetConf(fmt.Sprintf("redis::auth_%d", index), configFile)
+
+		log.Println(fmt.Sprintf("GetPlayerRedisPool project[%s] connString[%s]", project, redisAddr))
+		redisConn = new(Redis)
+
+		redisConn.pool = &redigo.Pool{
+			MaxIdle:     10,
+			IdleTimeout: 300 * time.Second,
+			MaxActive:   100,
+			Dial: func() (redigo.Conn, error) {
+				c, err := redigo.Dial("tcp", redisAddr)
+				if err != nil {
+					return nil, err
+				}
+				if redisAuth != "" {
+					_, err := c.Do("AUTH", redisAuth)
+					if err != nil {
+						c.Close()
+						return nil, err
+					}
+				}
+				return c, err
+			},
+			TestOnBorrow: func(c redigo.Conn, t time.Time) error {
+				_, err := c.Do("PING")
+				return err
+			},
+		}
+		mapRedisPool[project][index] = redisConn
+	}
+	return redisConn.pool
+}
+// 获取account redis连接池
+func GetAccountRedisPool() *redigo.Pool {
+	project := GetProject()
+	redisConn := mapAccountRedisPool[project]
+
+	if redisConn == nil {
+		configFile := GetConfigFile()
+		redisAddr := GetConf(fmt.Sprintf("redis::host_account"), configFile) + ":" + GetConf(fmt.Sprintf("redis::port_account"), configFile)
+		redisAuth := GetConf(fmt.Sprintf("redis::auth_account"), configFile)
+
+		log.Println(fmt.Sprintf("GetAccountRedisPool project[%s] connString[%s]", project, redisAddr))
+		redisConn = new(Redis)
+
+		redisConn.pool = &redigo.Pool{
+			MaxIdle:     10,
+			IdleTimeout: 300 * time.Second,
+			MaxActive:   100,
+			Dial: func() (redigo.Conn, error) {
+				c, err := redigo.Dial("tcp", redisAddr)
+				if err != nil {
+					return nil, err
+				}
+				if redisAuth != "" {
+					_, err := c.Do("AUTH", redisAuth)
+					if err != nil {
+						c.Close()
+						return nil, err
+					}
+				}
+				return c, err
+			},
+			TestOnBorrow: func(c redigo.Conn, t time.Time) error {
+				_, err := c.Do("PING")
+				return err
+			},
+		}
+		mapAccountRedisPool[project] = redisConn
+	}
+	return redisConn.pool
+}
+
+// GetPlayerInfoFromRedis do hget
+func GetPlayerInfoFromRedis(uid int, subKey string) string {
+	pool := GetPlayerRedisPool(uid)
+	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()
+	key := fmt.Sprintf("player:uid:%d", uid)
+
+	reply, err := redisConn.Do("hget", key, subKey)
+	if err != nil {
+		fmt.Println("GetPlayerInfoFromRedis err:", err)
+		return ""
+	}
+	info, _ := redis.String(reply, err)
+	// fmt.Println(info)
+	return info
+}
+
+// SetPlayerInfoFromRedis do hget
+func SetPlayerInfoFromRedis(uid int, subKey string, val string) bool {
+	pool := GetPlayerRedisPool(uid)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return false
+	}
+	redisConn := pool.Get()
+	if redisConn == nil {
+		fmt.Println("get redis conn fail")
+		return false
+	}
+	defer redisConn.Close()
+	key := fmt.Sprintf("player:uid:%d", uid)
+
+	_, err := redisConn.Do("hset", key, subKey, []byte(val))
+	if err != nil {
+		fmt.Println("SetPlayerInfoFromRedis err:", err)
+		return false
+	}
+	return true
+}
+
+// 设置玩家支付信息
+func UpdatePlayerPayInfo(uid int, pay int, payCount int, detail []byte, records []byte) bool {
+	pool := GetPlayerRedisPool(uid)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return false
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	key := fmt.Sprintf("player:uid:%d", uid)
+
+	val := IntToString(pay)
+	_, err := rd.Do("hset", key, "pay", []byte(val))
+	if err != nil {
+		log.Println("UpdatePlayerPayInfo pay hset fail!", err)
+		return false
+	}
+	val = IntToString(payCount)
+	_, err = rd.Do("hset", key, "pay_count", []byte(val))
+	if err != nil {
+		log.Println("UpdatePlayerPayInfo pay_count hset fail!", err)
+		return false
+	}
+	_, err = rd.Do("hset", key, "js:sd", detail)
+	if err != nil {
+		log.Println("UpdatePlayerPayInfo js:sd hset fail!", err)
+		return false
+	}
+	_, err = rd.Do("hset", key, "js:shop", records)
+	if err != nil {
+		log.Println("UpdatePlayerPayInfo js:shop hset fail!", err)
+		return false
+	}
+
+	return true
+}
+
+// 删除玩家
+func DelPlayerInfo(uid int) bool {
+	pool := GetPlayerRedisPool(uid)
+	if pool == nil {
+		fmt.Println("get redis pool fail")
+		return false
+	}
+	rd := pool.Get()
+	defer rd.Close()
+
+	key := fmt.Sprintf("player:uid:%d", uid)
+	_, err := rd.Do("del", key)
+	if err != nil {
+		log.Println("redis_del_order_info fail!", uid, err)
+		return false
+	}
+
+	return true
+}

utils/sign.go

@@ -0,0 +1,115 @@
+/*
+ * @Descripttion:
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2020-10-16 14:29:56
+ * @LastEditors: Neo,Huang
+ * @LastEditTime: 2020-12-16 14:27:06
+ */
+package utils
+
+import (
+	"crypto/md5"
+	"fmt"
+	"io"
+	"net/url"
+	"sort"
+	"github.com/astaxie/beego"
+	"strconv"
+	"encoding/hex"
+)
+
+// Kv struct
+type Kv struct {
+	Key, Value string
+}
+
+// Kvs typenmae
+type Kvs []*Kv
+
+func (a Kvs) Len() int           { return len(a) }
+func (a Kvs) Swap(i, j int)      { a[i], a[j] = a[j], a[i] }
+func (a Kvs) Less(i, j int) bool { return a[i].Key < a[j].Key }
+
+var secrets map[string]string
+
+func init_secrets()  {
+	secrets = make(map[string]string)
+	secrets["101"] = "39baf5e79adac446131b7c78608cfe3d"
+	secrets["102"] = "51f4e76fc3b42c56243e9aa504ddfc9e"
+}
+
+// 获取appkey对应的appSecret
+func GetSecretByKey(appKey string) string {
+	if appKey == "" {
+		return ""
+	}
+	secret, ok := secrets[appKey]
+	if ok == false {
+		init_secrets()
+		secret, ok = secrets[appKey]
+	}
+	return secret
+}
+
+//Md5 md5散列函数
+func Md5(str string) string {
+	h := md5.New()
+	io.WriteString(h, str)
+	return fmt.Sprintf("%x", h.Sum(nil))
+}
+
+var keyMahjong = "am0xNjAzOTUxODE2"
+
+// MakeSign 生成签名秘钥
+func MakeSign(m map[string]string, appKey string) string {
+	var kvs Kvs
+	for k, v := range m {
+		kvs = append(kvs, &Kv{k, url.QueryEscape(v)})
+	}
+	sort.Sort(kvs)
+
+	key := ""
+	for i := 0; i < kvs.Len(); i++ {
+		key += kvs[i].Key + kvs[i].Value
+	}
+	if appKey != "" {
+		key += appKey
+	}
+
+	return Md5(key)
+}
+
+// MakeSign 生成签名秘钥
+func MakeKeySign(m map[string]interface{}) string {
+	var kvs Kvs
+	for k, v := range m {
+		switch val := v.(type) {
+		case int:
+			kvs = append(kvs, &Kv{k, IntToString(val)})
+		case int64:
+			kvs = append(kvs, &Kv{k, strconv.FormatInt(val, 10)})
+		case string:
+			kvs = append(kvs, &Kv{k, url.QueryEscape(val)})
+		}
+	}
+	sort.Sort(kvs)
+
+	key := ""
+	for i := 0; i < kvs.Len(); i++ {
+		key += kvs[i].Key + kvs[i].Value
+	}
+	if beego.AppConfig.String("project") == "mj" {
+		key += keyMahjong
+	}
+
+	return Md5(key)
+}
+
+// Strtomd5 md5
+func Strtomd5(s string) string {
+	h := md5.New()
+	h.Write([]byte(s))
+	rs := hex.EncodeToString(h.Sum(nil))
+	return rs
+}

utils/util.go

@@ -0,0 +1,303 @@
+/*
+ * @Descripttion:
+ * @version:
+ * @Author: Neo,Huang
+ * @Date: 2020-10-20 14:01:47
+ * @LastEditors: Please set LastEditors
+ * @LastEditTime: 2021-04-19 15:09:30
+ */
+package utils
+
+import (
+	"bytes"
+	"crypto/aes"
+	"crypto/cipher"
+	"encoding/hex"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"net/url"
+	"os"
+	"sort"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/config"
+)
+
+// StringToInt string to int
+func StringToInt(itf interface{}) int {
+	str, _ := itf.(string)
+	i, _ := strconv.Atoi(str)
+	return i
+}
+
+// IntToString int to string
+func IntToString(number int) string {
+	return strconv.Itoa(number)
+}
+
+// StringToInt64 string to int64
+func StringToInt64(itf interface{}) int64 {
+	str, _ := itf.(string)
+	i, _ := strconv.ParseInt(str, 10, 64)
+	return i
+}
+
+// Int64ToString int64 to string
+func Int64ToString(number int64) string {
+	return strconv.FormatInt(number, 10)
+}
+
+// GetConf config
+func GetConf(key string, file string) string {
+	iniconf, err := config.NewConfig("ini", file)
+	if err != nil {
+		fmt.Println(err.Error())
+	}
+	return iniconf.String(key)
+}
+
+// ResponseHTTPJSON return json
+func ResponseHTTPJSON(w http.ResponseWriter, m map[string]interface{}) {
+	str, _ := json.Marshal(m)
+	w.Header().Set("Content-Length", IntToString(len(str)))
+	w.Header().Set("Content-Type", "text/json")
+	w.Write([]byte(str))
+}
+
+// SendAndRecvHTTP send
+func SendAndRecvHTTP(method string, url string, body string) ([]byte, error) {
+	client := &http.Client{}
+	req, err1 := http.NewRequest(method, url, strings.NewReader(body))
+	if err1 != nil {
+		return nil, err1
+	}
+	req.Header.Set("Content-Type", "application/json")
+	req.Header.Set("Content-Length", IntToString(len(body)))
+	req.Header.Set("Connection", "close")
+
+	resp, err2 := client.Do(req)
+	if err2 != nil {
+		return nil, err2
+	}
+	defer resp.Body.Close()
+
+	return ioutil.ReadAll(resp.Body)
+}
+
+// 日志输出
+func SetEventLog(strLog string, strFile string) {
+	// 创建日志文件
+	filepath := fmt.Sprintf("/alidata/log/order/%s-%s.log", strFile, time.Now().Format("2006-01-02"))
+	file, err := os.OpenFile(filepath, os.O_CREATE|os.O_APPEND|os.O_RDWR, 0666)
+	if err != nil {
+		log.Println("create log file failed! err:", err)
+	}
+	defer file.Close()
+
+	//获取当前程序执行的绝对路径
+	_, err = file.WriteString(strLog + "\n")
+	if err != nil {
+		log.Println("write string err:", err)
+	}
+}
+
+// 应答 - 无签名
+func ResponseUnsign(w http.ResponseWriter, m map[string]string) {
+	str, _ := json.Marshal(m)
+
+	w.Header().Set("Content-Length", IntToString(len(str)))
+	w.Header().Set("Content-Type", "text/plain")
+	w.Write([]byte(str))
+}
+
+// http请求 - json参数
+func RequestHttpJson(method string, url string, body string) ([]byte, error) {
+	client := &http.Client{}
+	req, err1 := http.NewRequest(method, url, strings.NewReader(body))
+	if err1 != nil {
+		return nil, err1
+	}
+	req.Header.Set("Content-Type", "application/json")
+	req.Header.Set("Content-Length", IntToString(len(body)))
+	req.Header.Set("Connection", "close")
+
+	resp, err2 := client.Do(req)
+	if err2 != nil {
+		return nil, err2
+	}
+	defer resp.Body.Close()
+
+	return ioutil.ReadAll(resp.Body)
+}
+
+// http请求 - url加密参数
+func RequestHttpEncoded(method string, url string, body string) ([]byte, error) {
+	client := &http.Client{}
+	req, err1 := http.NewRequest(method, url, strings.NewReader(body))
+	if err1 != nil {
+		return nil, err1
+	}
+	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+	req.Header.Set("Content-Length", IntToString(len(body)))
+	req.Header.Set("Connection", "close")
+
+	resp, err2 := client.Do(req)
+	if err2 != nil {
+		return nil, err2
+	}
+	defer resp.Body.Close()
+
+	return ioutil.ReadAll(resp.Body)
+}
+
+// 序列化url参数
+func UrlSerial(values url.Values) (r string) {
+	keys := make([]string, 0, len(values))
+	for k := range values {
+		keys = append(keys, k)
+	}
+	sort.Strings(keys)
+	for _, v := range keys {
+		if r != "" {
+			r += "&"
+		}
+		r += v + "=" + values.Get(v)
+	}
+	return
+}
+
+// 获取游戏密钥
+func GetGameKey() string {
+	configFile := GetConfigFile()
+	gameKey := GetConf("servers::gameKey", configFile)
+	return gameKey
+}
+
+// 获取游戏服地址
+func GetGameHost() string {
+	configFile := GetConfigFile()
+	host := GetConf("servers::game", configFile)
+	return host
+}
+
+// 获取趣头条参数
+func GetQttConf(channel string, key string) string {
+	configFile := GetConfigFile()
+	host := GetConf(fmt.Sprintf("qttgame%s::%s", channel, key), configFile)
+	return host
+}
+
+// 获取配置参数
+func GetKeyConf(key string, subKey string) string {
+	configFile := GetConfigFile()
+	host := GetConf(fmt.Sprintf("%s::%s", key, subKey), configFile)
+	return host
+}
+
+// 项目
+var project string
+
+func InitProject() {
+	project = beego.AppConfig.String("project")
+}
+func GetProject() string {
+	return project
+}
+
+// 配置文件
+func GetConfigFile() string {
+	project := GetProject()
+	configFile := fmt.Sprintf("conf/%s/cfg.conf", project)
+	if beego.AppConfig.String("runmode") == "test" {
+		configFile = fmt.Sprintf("conf/%s/cfg_test.conf", project)
+	}
+
+	return configFile
+}
+
+// 获取配置文件目录
+func GetConfigPath() string {
+	project := GetProject()
+	return fmt.Sprintf("conf/%s/", project)
+}
+
+func pKCS5Padding(ciphertext []byte, blockSize int) []byte {
+	padding := blockSize - len(ciphertext)%blockSize
+	padtext := bytes.Repeat([]byte{byte(padding)}, padding)
+	return append(ciphertext, padtext...)
+}
+
+func pKCS5UnPadding(origData []byte) []byte {
+	length := len(origData)
+	// 去掉最后一个字节 unpadding 次
+	unpadding := int(origData[length-1])
+	return origData[:(length - unpadding)]
+}
+
+//AesEncrypt aes加密函数，返回加密后的结果长度是16的倍数
+func AesEncrypt(origData, key []byte) ([]byte, error) {
+	block, err := aes.NewCipher(key)
+	if err != nil {
+		return nil, err
+	}
+	blockSize := block.BlockSize()
+	origData = pKCS5Padding(origData, blockSize)
+
+	// iv := make([]byte, aes.BlockSize)
+	iv := []byte("0304050607080910")
+	blockMode := cipher.NewCBCEncrypter(block, iv)
+	crypted := make([]byte, len(origData))
+	blockMode.CryptBlocks(crypted, origData)
+	return crypted, nil
+}
+
+//AesDecrypt aes解密函数，传入解密内容长度必须是16的倍数
+func AesDecrypt(crypted, key []byte) ([]byte, error) {
+	block, err := aes.NewCipher(key)
+	if err != nil {
+		return nil, err
+	}
+	// iv := make([]byte, aes.BlockSize)
+	iv := []byte("0304050607080910")
+	blockMode := cipher.NewCBCDecrypter(block, iv)
+	origData := make([]byte, len(crypted))
+	blockMode.CryptBlocks(origData, crypted)
+	origData = pKCS5UnPadding(origData)
+	return origData, nil
+}
+
+func EncodeData(ts string, data string, appKey string) string {
+	key := Md5(appKey + ts)
+	en, err := AesEncrypt([]byte(data), []byte(key))
+	if err != nil {
+		return ""
+	}
+	return strings.ToUpper(hex.EncodeToString(en))
+}
+
+func DecodeData(ts string, data string) (string, error) {
+	l := len(data)
+	if l == 0 || (l%16) != 0 {
+		return "", fmt.Errorf("decrype data error")
+	}
+
+	redAppKey := GetKeyConf("servers", "redAppKey")
+	key := Md5(redAppKey + ts)
+	buf, err1 := hex.DecodeString(data)
+	if err1 != nil {
+		return "", err1
+	}
+
+	de, err2 := AesDecrypt(buf, []byte(key))
+	if err2 != nil {
+		return "", err2
+	}
+
+	return string(de), nil
+}