123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222 |
- package utils
- import (
- "crypto/md5"
- "encoding/hex"
- "fmt"
- "io/ioutil"
- "log"
- "net/http"
- "os"
- "os/exec"
- "path/filepath"
- "strconv"
- "strings"
- "time"
- "github.com/astaxie/beego"
- "github.com/astaxie/beego/config"
- )
- type RTLogStruct struct {
- ActionName string `json:"ty,omitempty"`
- Date string `json:"date,omitempty"`
- Event string `json:"cnt,omitempty"`
- }
- type RespondData struct {
- Code int `json:"Code,omitempty"`
- Message string `json:"Message,omitempty"`
- }
- func GetCurrentDirectory() string {
- file, err := exec.LookPath(os.Args[0])
- if err != nil {
- return ""
- }
- path, err := filepath.Abs(file)
- if err != nil {
- return ""
- }
- i := strings.LastIndex(path, "/")
- if i < 0 {
- i = strings.LastIndex(path, "\\")
- }
- if i < 0 {
- return ""
- }
- return string(path[0 : i+1])
- }
- // StringToInt string to int
- func StringToInt(itf interface{}) int {
- str, _ := itf.(string)
- i, _ := strconv.Atoi(str)
- return i
- }
- func StringToInt64(itf interface{}) int64 {
- str, _ := itf.(string)
- i, _ := strconv.ParseInt(str, 10, 64)
- return i
- }
- func StringToFloat(itf interface{}) float64 {
- str, _ := itf.(string)
- i, _ := strconv.ParseFloat(str, 64)
- return i
- }
- // IntToString int to string
- func IntToString(number int) string {
- return strconv.Itoa(number)
- }
- func Int64ToString(number int64) string {
- return fmt.Sprintf("%d", number)
- }
- // 项目
- 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
- }
- // 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)
- }
- // 获取配置参数
- func GetKeyConf(key string, subKey string) string {
- configFile := GetConfigFile()
- host := GetConf(fmt.Sprintf("%s::%s", key, subKey), configFile)
- return host
- }
- // 获取天开始时间
- func GetTimeDayStartTime(ti int) int {
- if ti == 0 {
- ti = int(time.Now().Unix())
- }
- str := time.Unix(int64(ti), 0).Format("2006-01-02") + " 00:00:00"
- loc, _ := time.LoadLocation("Local")
- theTime, err := time.ParseInLocation("2006-01-02 15:04:05", str, loc)
- if err == nil {
- return int(theTime.Unix())
- } else {
- return 0
- }
- }
- // 获取时间间隔天数
- func GetDiffDays(t1 int, t2 int) int {
- st1 := GetTimeDayStartTime(t1)
- st2 := GetTimeDayStartTime(t2)
- secs := 0
- if st2 > st1 {
- secs = st2 - st1
- } else {
- secs = st1 - st2
- }
- return secs / 86400
- }
- func IsSameDay(t1 int, t2 int) bool {
- deltaDays := GetDiffDays(t1, t2)
- if deltaDays == 0 {
- return true
- }
- return false
- }
- func GetTime(timeStr string) int {
- loc, _ := time.LoadLocation("Local")
- theTime, err := time.ParseInLocation("2006-01-02 15:04:05", timeStr, loc)
- if err == nil {
- return int(theTime.Unix())
- } else {
- return 0
- }
- }
- func GetTime64(timeStr string) int64 {
- loc, _ := time.LoadLocation("Local")
- theTime, err := time.ParseInLocation("2006-01-02 15:04:05", timeStr, loc)
- if err == nil {
- return theTime.Unix()
- }
- return int64(0)
- }
- // 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 WriteLog(action *RTLogStruct) {
- path := GetKeyConf("events", "path")
- if err := os.MkdirAll(path, 0766); err != nil {
- log.Printf("创建路径 [%s] 失败", path)
- return
- }
- fileName := fmt.Sprintf("%s/%s-%s.log", GetKeyConf("events", "path"), action.ActionName, action.Date)
- file, err := os.OpenFile(fileName, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
- if err != nil {
- log.Printf("打开文件 %s 失败", fileName)
- return
- }
- defer file.Close()
- file.WriteString(action.Event + "\n")
- }
- // InSlice 判断字符串是否在 slice 中。
- func InSlice(items []string, item string) bool {
- for _, eachItem := range items {
- if eachItem == item {
- return true
- }
- }
- return false
- }
- // Strtomd5 md5
- func Strtomd5(s string) string {
- h := md5.New()
- h.Write([]byte(s))
- rs := hex.EncodeToString(h.Sum(nil))
- return rs
- }
|