Ver código fonte

fix:打开定时任务,过滤没有数据的异常

Roc 2 anos atrás
pai
commit
ccb5cd7211
2 arquivos alterados com 20 adições e 20 exclusões
  1. 19 19
      init_serve/task.go
  2. 1 1
      services/index.go

+ 19 - 19
init_serve/task.go

@@ -22,25 +22,25 @@ func InitTask() {
 	}
 
 	////每30分钟检测一次,周度指标刷新
-	//_, err = c.AddFunc("0 */30 * * * *", services.IndexRefreshWeek)
-	//if err != nil {
-	//	global.LOG.Info("DownloadCvTask err" + err.Error())
-	//	panic("DownloadCvTask err" + err.Error())
-	//}
-
-	////其他指标刷新
-	//_, err := c.AddFunc("0 00 03 * * *", services.IndexRefreshAll)
-	//if err != nil {
-	//	global.LOG.Info("DownloadCvTask err" + err.Error())
-	//	panic("DownloadCvTask err" + err.Error())
-	//}
-	//
-	////其他指标刷新
-	//_, err = c.AddFunc("0 30 12 * * *", services.IndexRefreshAll)
-	//if err != nil {
-	//	global.LOG.Info("DownloadCvTask err" + err.Error())
-	//	panic("DownloadCvTask err" + err.Error())
-	//}
+	_, err = c.AddFunc("0 */30 * * * *", services.IndexRefreshWeek)
+	if err != nil {
+		global.LOG.Info("DownloadCvTask err" + err.Error())
+		panic("DownloadCvTask err" + err.Error())
+	}
+
+	//其他指标刷新
+	_, err = c.AddFunc("0 00 03 * * *", services.IndexRefreshAll)
+	if err != nil {
+		global.LOG.Info("DownloadCvTask err" + err.Error())
+		panic("DownloadCvTask err" + err.Error())
+	}
+
+	//其他指标刷新
+	_, err = c.AddFunc("0 30 12 * * *", services.IndexRefreshAll)
+	if err != nil {
+		global.LOG.Info("DownloadCvTask err" + err.Error())
+		panic("DownloadCvTask err" + err.Error())
+	}
 	c.Start()
 
 	go watch.ListenFolderNew()

+ 1 - 1
services/index.go

@@ -31,7 +31,7 @@ func IndexCreateCheck() (err error) {
 	fmt.Println("IndexCreateCheck")
 	indexObj := new(index.BaseFromMysteelChemicalIndex)
 	list, err := indexObj.GetIndexCreate()
-	if err != nil {
+	if err != nil && err !=utils.ErrNoRow {
 		return
 	}
 	fmt.Println("listLen:", len(list))