fix

main.go

@@ -19,8 +19,8 @@ func main() {
 		web.BConfig.WebConfig.DirectoryIndex = true
 		web.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
 	}
-	//go services.Task()
-	services.TaskTest()
+	go services.Task()
+	//services.TaskTest()
 	web.BConfig.RecoverFunc = Recover
 	web.Run()
 }

services/data/trade_position_analysis.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"hongze/hongze_task/models/data_manage"
+	"hongze/hongze_task/services/alarm_msg"
 	"hongze/hongze_task/utils"
 	"sort"
 	"strconv"
@@ -38,6 +39,13 @@ func InitPositionTask(cont context.Context) (err error) {
 }
 
 func InitTradePosition(exchange, startDate, endDate string) (err error, errMsg string) {
+	defer func() {
+		if err != nil {
+			tips := fmt.Sprintf("统计今日交易所的持仓分析数据失败, Exchange: %s, Err: %s, Msg: %s", exchange, err.Error(), errMsg)
+			alarm_msg.SendAlarmMsg(tips, 3)
+		}
+	}()
+
 	// 批量插入今日的初始值
 	num, err := data_manage.GetTradePositionTopCountByExchangeDataTime(exchange, startDate, endDate)
 	if err != nil {

services/task.go

@@ -225,18 +225,18 @@ func releaseTask() {
 	task.AddTask("每日更新每刻报销-客户档案", syncMaycurCompanyProfile)
 }
 
-func TaskTest() {
-	fmt.Println("The task is start")
-
-	e, msg := data.InitTradePosition("shanghai", "2023-02-13", "2023-02-13")
-	if e != nil {
-		fmt.Println(e.Error())
-		fmt.Println(msg)
-	}
-
-	//task.StartTask()
-	fmt.Println("The task is end")
-}
+//func TaskTest() {
+//	fmt.Println("The task is start")
+//
+//	e, msg := data.InitTradePosition("shanghai", "2023-05-05", "2023-05-05")
+//	if e != nil {
+//		fmt.Println(e.Error())
+//		fmt.Println(msg)
+//	}
+//
+//	//task.StartTask()
+//	fmt.Println("The task is end")
+//}
 
 func SendEmail(cont context.Context) (err error) {
 	//报告历史访问次数