jianghan7 1 anno fa
parent
commit
a377e64d39
3 ha cambiato i file con 8 aggiunte e 10 eliminazioni
  1. 5 6
      src/main.go
  2. 2 3
      src/util/config.go
  3. 1 1
      src/util/elasticSim.go

+ 5 - 6
src/main.go

@@ -1,7 +1,6 @@
 package main
 
 import (
-	util "common_utils"
 	"crons"
 	_ "filter"
 	"front"
@@ -31,21 +30,21 @@ func init() {
 	xweb.RootApp().AppConfig.CacheTemplates = false
 	xweb.AddAction(&front.Front{})
 	xweb.RootApp().AppConfig.SessionTimeout = 1 * time.Hour
-	xweb.RootApp().Logger.SetOutputLevel(4)
+	xweb.RootApp().Logger.SetOutputLevel(3)
 	//xweb.AddTmplVar("add", func(a, b int) int { return a + b })
 
 }
 
 func cronTask() {
-	defer util.Catch()
+	defer qu.Catch()
 	c := cron.New()
 	biddingHConf := Sysconfig["high_mark"].(map[string]interface{})
 	if biddingHConf["spec"] == nil || biddingHConf["spec"] == "" {
-		util.Debug("高质量库 定时任务 为空,请配置")
+		qu.Debug("高质量库 定时任务 为空,请配置")
 	} else {
 		err := c.AddFunc(biddingHConf["spec"].(string), crons.MarkTask)
 		if err != nil {
-			util.Debug("cronTask err", err)
+			qu.Debug("cronTask err", err)
 		}
 
 		c.Start()
@@ -56,6 +55,6 @@ func cronTask() {
 }
 
 func main() {
-	go cronTask()
+	//go cronTask()
 	xweb.Run(":" + qu.ObjToString(Sysconfig["port"]))
 }

+ 2 - 3
src/util/config.go

@@ -1,7 +1,6 @@
 package util
 
 import (
-	util "common_utils"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo"
 	"mongodb"
@@ -102,12 +101,12 @@ func InitConfig() {
 
 	biddingHConf := Sysconfig["high_mark"].(map[string]interface{})
 	if biddingHConf == nil || len(biddingHConf) == 0 {
-		util.Debug("high_mark 配置项为空,请配置高质量库参数")
+		qu.Debug("high_mark 配置项为空,请配置高质量库参数")
 	}
 	//高质量库
 	MgoHM = &mongodb.MongodbSim{
 		MongodbAddr: biddingHConf["addr"].(string),
-		Size:        util.IntAllDef(biddingHConf["size"], 5),
+		Size:        qu.IntAllDef(biddingHConf["size"], 5),
 		DbName:      biddingHConf["db"].(string),
 		UserName:    biddingHConf["username"].(string),
 		Password:    biddingHConf["password"].(string),

+ 1 - 1
src/util/elasticSim.go

@@ -5,7 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	es "github.com/olivere/elastic/v7"
+	es "gopkg.in/olivere/elastic.v7"
 	"log"
 	"qfw/util"
 	"runtime"