85 lines
1.8 KiB
Go
85 lines
1.8 KiB
Go
package model
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/go-redis/redis"
|
|
_ "github.com/go-sql-driver/mysql"
|
|
"go.uber.org/zap"
|
|
"hpds-iot-web/config"
|
|
"os"
|
|
"time"
|
|
"xorm.io/xorm"
|
|
"xorm.io/xorm/dialects"
|
|
)
|
|
|
|
var (
|
|
DB *xorm.Engine
|
|
Redis *redis.Client
|
|
)
|
|
|
|
func New(driveName, dsn string) {
|
|
DB, _ = NewDbConnection(dsn)
|
|
DB.ShowSQL(true)
|
|
DB.Dialect().SetQuotePolicy(dialects.QuotePolicyReserved)
|
|
err := DB.Sync2(
|
|
&Brand{},
|
|
&DetectionTask{},
|
|
&Device{},
|
|
&DeviceType{},
|
|
&Disease{},
|
|
&MatterAttribute{},
|
|
&MatterCategory{},
|
|
&MatterEvent{},
|
|
&MatterEventParams{},
|
|
&MatterModel{},
|
|
&MatterService{},
|
|
&MatterServiceParams{},
|
|
&MatterVersion{},
|
|
&Model{},
|
|
&ModelVersion{},
|
|
&Node{},
|
|
&OriginalData{},
|
|
&Owner{},
|
|
&Project{},
|
|
&SystemMenu{},
|
|
&OperationLog{},
|
|
&SystemRoleMenu{},
|
|
&SystemRoleRoute{},
|
|
&SystemRole{},
|
|
&SystemUser{},
|
|
)
|
|
if err != nil {
|
|
zap.L().Error("同步数据库表结构", zap.Error(err))
|
|
os.Exit(1)
|
|
}
|
|
}
|
|
|
|
func NewDbConnection(dsn string) (db *xorm.Engine, err error) {
|
|
db, err = xorm.NewEngine("mysql", dsn)
|
|
if err != nil {
|
|
zap.L().Error("创建数据库连接", zap.Error(err))
|
|
os.Exit(-1)
|
|
}
|
|
db.SetMaxOpenConns(300)
|
|
return
|
|
}
|
|
|
|
func NewCache(c config.CacheConfig) {
|
|
Redis = redis.NewClient(&redis.Options{
|
|
Addr: fmt.Sprintf("%s:%d", c.Host, c.Port),
|
|
Password: c.Pass, // no password set
|
|
DB: c.DB, // use default DB
|
|
PoolSize: c.PoolSize, // Redis连接池大小
|
|
MaxRetries: 3, // 最大重试次数
|
|
IdleTimeout: 10 * time.Second, // 空闲链接超时时间
|
|
})
|
|
pong, err := Redis.Ping().Result()
|
|
if err == redis.Nil {
|
|
zap.L().Error("访问Redis异常", zap.Error(fmt.Errorf("redis.Nil")))
|
|
} else if err != nil {
|
|
zap.L().Error("访问Redis异常", zap.Error(err))
|
|
} else {
|
|
zap.L().Info("Redis连接成功", zap.String("pong", pong))
|
|
}
|
|
}
|