函数	入参数	返回值	方法说明
CheckFileExist	filename string	bool	检测文件是否存在
MakeDir	dirPath string	error	递归创建文件夹
ReadFile	filename string	string	读取文件
ReadFileByte	filename string	[]byte	读取byte文件
WriteFile	filename string, value string	error	写文件（追加）
WriteFileCover	filename string, value string	error	写文件（覆盖）
WriteFileByte	filename string, value []byte	error	写文件,字符类型

dlog

设置日志信息

	dlog.SetLog(dlog.SetLogConf{
		LogType: dlog.LOG_TYPE_LOCAL,
		LogPath: "/Users/caoshuyu/WorkSpace/GoWork/Csy/src/logs",
		Prefix:  "id_generator",
	})

参数	说明	可选值	默认值
LogType	日志存储类型	LOG_TYPE_LOCAL 本地文件存储,LOG_TYPE_NET 网络存储（暂不支持）	LOG_TYPE_LOCAL
LogPath	日志存储位置	实际存储位置	/data/logs
Prefix	项目名称	-	-

调用日志存储

日志级别	调用方法
DEBUG	dlog.DEBUG("funcName", "GetIdUseSnowflake", "info", info)
INFO	dlog.INFO("funcName", "GetIdUseSnowflake", "info", info)
WARN	dlog.WARN("funcName", "GetIdUseSnowflake", "warn", warn)
ERROR	dlog.ERROR("funcName", "GetIdUseSnowflake", "error", err)

uuid

函数	入参数	返回值	方法说明
NewV1	-	UUID	基于当前时间戳和MAC地址
NewV2	domain byte	UUID	返回基于POSIX UID/GID的DCE安全UUID
NewV3	ns UUID, name string	UUID	基于命名空间UUID和名称的MD5哈希
NewV4	-	UUID	随机生成的UUID
NewV5	ns UUID, name string	基于命名空间UUID和名称的SHA-1散列

inttools

函数	入参数	返回值	方法说明
Int64ArrToString	data []int64, split string	string	数字数组转字符串;input [3306,4450,3,12],-;out 3306-4450-3-12
StringToInt64Arr	data string, split string	[]int64	字符串分割为数字数组;input 3306-4450-3-12,-;out [3306,4450,3,12]
GetPageNum	page int64, pageContext int64	newPage int64, newPageContext int64, startLine int64	通过页码和每页数量计算起始行数
Intersect	arr1 []int64, arr2 []int64	[]int64	Intersect 取两个数组交集

stringtools

函数	入参数	返回值	方法说明
InitialUpdateStr	string	string	首字母大写，有_的去掉后第一个字母大写
InitialLowStr	string	string	首字母小写，有_的去掉后第一个字母大写
UpperToUnderlineToUpper	string	string	变成大写字母，用_分割
UpperToUnderline	string	string	变成小写字母，用_分割
MakeRoundabout	int	string	制作问号
Md5	string	string	MD5加密
Time33	string	int64	Time33加密算法
IsNum	string	bool	判断字符串是不是数字
RemoveSliceRepeatStr	[]string,[]string	[]string	去除数组中重复的字符串

timetools

函数	入参数	返回值	方法说明
GetConstellation	month int64, day int64	int64	查询星座，具体返回值星座见文件内
GetNowDateTime	-	time.Time	获取当前时间
GetBeforeTime	beforeSecond int	time.Time	获取当前时间之前时间
GetNextTime	nextSecond int	time.Time	获取当前时间之后时间
TimeStamp	layout string, value string	time.Time, error	时间类型转时间
GetDayStart	time.Time	time.Time	获取零晨时间
GetDayEnd	time.Time	time.Time	获取一天最后一刻时间
SecondToDateTime	int64	time.Time	时间戳转时间
TimeFormat	t time.Time, layout string	string	格式化时间

参数	类型	可选值	说明
layout	string	RFC3339/TT/TTDAY/NOSPLITT	时间格式
value	string	-	时间值

调用方法示例

	var (
		t  time.Time
		tn int64
		ts string
	)

	//获取当前时间
	t = timetools.GetNowDateTime()
	fmt.Println("获取当前时间:", t)
	//获取当前时间戳
	tn = timetools.GetNowDateTime().Unix()
	fmt.Println("获取当前时间戳:", tn)
	//获取一小时前时间
	t = timetools.GetBeforeTime(timetools.ONE_HOURS_SECOND)
	fmt.Println("获取一小时前时间:", t)
	//获取一小时后时间
	t = timetools.GetNextTime(timetools.ONE_HOURS_SECOND)
	fmt.Println("获取一小时后时间:", t)
	//获取今天日期 2006-01-02
	ts = timetools.TimeFormat(timetools.TTDAY, timetools.GetNowDateTime())
	fmt.Println("获取今天日期 2006-01-02:", ts)
	//获取今天日期 20060102
	ts = timetools.TimeFormat(timetools.NOSPLITTDAY, timetools.GetNowDateTime())
	fmt.Println("获取今天日期 20060102:", ts)
	//2006-01-02T15:04:05Z07:00 转 时间
	t, err := timetools.TimeStamp(timetools.RFC3339, "2006-01-02T15:04:05Z07:00")
	if nil != err {
		fmt.Println(err)
		return
	}
	fmt.Println("2006-01-02T15:04:05Z07:00 转 时间:", t)

	//2006-01-02T15:04:05Z07:00 转 时间戳
	tn, err = timetools.TimeStampUnix(timetools.RFC3339, "2006-01-02T15:04:05Z07:00")
	if nil != err {
		fmt.Println(err)
		return
	}
	fmt.Println("2006-01-02T15:04:05Z07:00 转 时间戳:", tn)
	//2006-01-02 15:04:05 转 时间戳
	tn, err = timetools.TimeStampUnix(timetools.TT, "2006-01-02 15:04:05")
	if nil != err {
		fmt.Println(err)
		return
	}
	fmt.Println("2006-01-02 15:04:05 转 时间戳:", tn)

	//获取昨日零晨时间
	t = timetools.GetDayStart(timetools.GetBeforeTime(timetools.ONE_DAY_SECOND))
	fmt.Println("昨日零晨时间:", t)

	//获取昨日最后一刻时间
	t = timetools.GetDayEnd(timetools.GetBeforeTime(timetools.ONE_DAY_SECOND))
	fmt.Println("获取昨日最后一刻时间:", t)

	//时间戳转时间 1613802876
	t = timetools.SecondToDateTime(1613802876)
	fmt.Println("时间戳转时间 1613802876:", t)

	//格式化时间
	ts = timetools.TimeFormat(timetools.TT, timetools.GetNowDateTime())
	fmt.Println("格式化时间:", ts)

	_, _, _ = t, tn, ts

etcdclient

初始化客户端

	//添加一个节点
	//etcdclient.AddEndpoint("127.0.0.1:2379")
	//设置多个节点，默认值为"127.0.0.1:2379"
	etcdclient.SetEndpoints([]string{
		"127.0.0.1:2379",
	})
	//设置超时时间，秒 ，默认值为5
	etcdclient.SetTimeOutSecond(5)
	//设置etcd用户名，没有可忽略
	etcdclient.SetUsername("root")
	//设置etcd密码，没有可忽略
	etcdclient.SetPassword("root")
	//初始化客户端
	etcdclient.InitClient()

使用客户端

    //使用客户端读取数据
	etcdclient.GetValue("key")

	//使用客户端监听数据
	listeningChan := make(chan []byte, 100)
	etcdclient.WatchValue("key", listeningChan)
	select {
	case val := <-listeningChan:
		fmt.Println(val)
	}

exceltools

函数	入参数	返回值	方法说明
SaveExcel	filename string, data []*Sheet	error	存储excel
GetExcel	filename string	data []*Sheet, err error	读取excel
GetXls	filename string, charset string	data []*Sheet, err error	读取xls

httptools

函数	入参数	返回值	方法说明
HTTPRequest	*ExternalHttpRequest	*ExternalHttpResponse,error	发起http请求

ExternalHttpRequest

type ExternalHttpRequest struct {
	Jar          *cookiejar.Jar
	Method       string
	Header       map[string]string
	TimeOut      int
	Domain       string
	Uri          string
	Body         string
	ReqUriParams string
}

+ Jar 需要多次请求使用同一个cookie的情况下使用

ExternalHttpResponse

type ExternalHttpResponse struct {
	StatusCode int
	Header     map[string][]string
	Body       []byte
	UseTime    int64
}

使用方法

	jar, _ := cookiejar.New(nil)
	header := make(map[string]string)
	request := &httptools.ExternalHttpRequest{
		Jar:          jar,
		Method:       http.MethodPost,            //请求类型
		Header:       header,                     //请求头
		TimeOut:      6,                          //超时时间
		Domain:       "http://127.0.0.1:3000",    //请求domain
		Uri:          "/test",                    //请求uri
		Body:         "{\"body_info\":\"json\"}", //请求体
		ReqUriParams: "a=b",                      //用于在url上添加信息，http://127.0.0.1:3000/test?a=b
	}
	response, err := httptools.HTTPRequest(request)
	if nil != err {
		fmt.Println(err)
	}

redistools

函数	入参数	返回值	方法说明
ConnRedis	*RedisClient	error	链接Redis
Lock	*RedisClient	ok bool, err error	加锁，outTime 加锁时长(秒)，ok 成功为 true
UnLock	*RedisClient,key string	error	解锁

使用

	rc := redistools.RedisClient{
		Conf: &redistools.RedisConf{
			Addr: "127.0.0.1:6379",
		},
	}
	err := rc.ConnRedis()
	if nil != err {
		panic(err)
	}

    var ctx = context.Background()

	rc.Client.SetNX(ctx,"key", "value", time.Second*time.Duration(30))

	//add sync lock
	rc.Lock(ctx,"LOCK_KEY",30)
	//del sync lock
	rc.UnLock(ctx,"LOCK_KEY")

mysqltools

函数	入参数	返回值	方法说明
Connect	*MysqlClient	error	链接mysql服务
CheckMonitor	*MysqlClient	error	检测链接有效性

单数据库使用

	//get one db conf
	dbJson := "{\"db_dsn\":\"root:root@tcp(127.0.0.1:3306)/api_platform?clientFoundRows=false&parseTime=true&loc=Asia%2FShanghai&timeout=5s&collation=utf8mb4_bin&interpolateParams=true\",\"max_open\":100,\"max_idle\":100,\"db_name\":\"api_platform\"}"
	mysqlDbConf := mysqltools.MySqlConf{}
	err := json.Unmarshal([]byte(dbJson), &mysqlDbConf)
	if nil != err {
		panic(err)
	}

	var MasterDb *sql.DB

	//connect db
	mysqlClient := mysqltools.MysqlClient{
		Conf: &mysqlDbConf,
	}
	err = mysqlClient.Connect()
	if nil != err {
		panic(err)
	}
	MasterDb = mysqlClient.Client
	//check db connect
	go func(mysqlClient mysqltools.MysqlClient) {
		//5 second check once
		time.Sleep(time.Second * time.Duration(5))
		err := mysqlClient.CheckMonitor()
		if nil != err {
			//Try to reconnect
			for i := 0; i <= 3; i++ {
				err := mysqlClient.Connect()
				if nil != err {
					time.Sleep(time.Second * time.Duration(i*3+1))
				} else {
					MasterDb = mysqlClient.Client
					break
				}
			}
			err := MasterDb.Ping()
			if nil != err {
				panic(err)
			}
		}
	}(mysqlClient)

一主多从数据库使用

	//get more db conf
	dbJson := "{\"master\":{\"db_dsn\":\"root:root@tcp(127.0.0.1:3306)/api_platform?clientFoundRows=false&parseTime=true&loc=Asia%2FShanghai&timeout=5s&collation=utf8mb4_bin&interpolateParams=true\",\"max_open\":100,\"max_idle\":100,\"db_name\":\"api_platform\"},\"slave\":{\"db_dsn\":\"root:root@tcp(127.0.0.1:3306)/api_platform?clientFoundRows=false&parseTime=true&loc=Asia%2FShanghai&timeout=5s&collation=utf8mb4_bin&interpolateParams=true\",\"max_open\":100,\"max_idle\":100,\"db_name\":\"api_platform\"}}"
	type DbStruct struct {
		Master mysqltools.MySqlConf `json:"master"`
		Slave  mysqltools.MySqlConf `json:"slave"`
	}

	mysqlDbConf := DbStruct{}
	err := json.Unmarshal([]byte(dbJson), &mysqlDbConf)
	if nil != err {
		panic(err)
	}

	var MasterDb *sql.DB
	var SlaveDb *sql.DB

	//connect db
	var MasterDbClient = connectDb(mysqlDbConf.Master)
	var SlaveDbClient = connectDb(mysqlDbConf.Slave)

	MasterDb = MasterDbClient.Client
	SlaveDb = SlaveDbClient.Client

	//check db

func connectDb(mysqlDbConf mysqltools.MySqlConf) (mysqlClient *mysqltools.MysqlClient) {
	mysqlClient = &mysqltools.MysqlClient{
		Conf: &mysqlDbConf,
	}
	err := mysqlClient.Connect()
	if nil != err {
		panic(err)
	}
	return mysqlClient
}