Roc hai 2 meses
pai
achega
9b7f2f7afb
Modificáronse 3 ficheiros con 6 adicións e 4 borrados
  1. 4 0
      global/initDb.go
  2. 1 3
      main.go
  3. 1 1
      models/data_manage/edb_source.go

+ 4 - 0
global/initDb.go

@@ -13,6 +13,7 @@ import (
 	"io"
 	"log"
 	"os"
+	"strings"
 	"time"
 )
 
@@ -74,6 +75,9 @@ func connectDb(dsn, aliasName string, newLogger logger.Interface, dbMap map[stri
 	var dialector gorm.Dialector
 	switch utils.DbDriverName {
 	case utils.DbDriverByMysql:
+		if !strings.Contains(dsn, `parseTime`) {
+			dsn += `&parseTime=true`
+		}
 		dialector = mysql.Open(dsn)
 	case utils.DbDriverByDm:
 		dialector = dm.Open(dsn)

+ 1 - 3
main.go

@@ -1,7 +1,7 @@
 package main
 
 import (
-	"eta/eta_task/models"
+	_ "eta/eta_task/models"
 	_ "eta/eta_task/routers"
 	"eta/eta_task/services"
 	"eta/eta_task/services/alarm_msg"
@@ -21,8 +21,6 @@ func main() {
 		web.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
 	}
 	go services.Task()
-	// 初始化表数据入库
-	models.AfterInitTable()
 
 	//services.TaskInit()
 	web.BConfig.RecoverFunc = Recover

+ 1 - 1
models/data_manage/edb_source.go

@@ -39,7 +39,7 @@ func GetEdbSourceItemsByCondition(condition string, pars []interface{}, fieldArr
 		order = ` ORDER BY ` + orderRule
 	}
 	sql := fmt.Sprintf(`SELECT %s FROM edb_source WHERE 1=1 %s %s`, fields, condition, order)
-	err = global.DbMap[utils.DbNameIndex].Raw(sql, pars).Find(&items).Error
+	err = global.DbMap[utils.DbNameIndex].Raw(sql, pars...).Find(&items).Error
 	return
 }