..

main.go

@@ -11,8 +11,7 @@ import (
 	_ "eta_gn/eta_api/global"
 	_ "eta_gn/eta_api/routers"
 
-	//"eta_gn/eta_api/services"
-	"eta_gn/eta_api/services/ice_message"
+	"eta_gn/eta_api/services"
 	"eta_gn/eta_api/utils"
 
 	"github.com/beego/beego/v2/adapter/logs"
@@ -28,20 +27,7 @@ func main() {
 	// 服务名称
 	web.BConfig.ServerName = `server`
 
-	//go services.Task()
-	url := ""
-	// 生成taskId
-	
-	reportId := 1
-	pptId := 0
-	// 生成taskId
-	taskId := utils.MD5(fmt.Sprintf("%s_%s_%s_%s", reportId, pptId, "1", time.Now().Format("20060102150405")))
-	err := ice_message.PushIceMessage("测试标题", "", "", "e0174539", taskId, reportId, pptId, url, "煤炭市场日报")
-	if err != nil {
-		fmt.Println("PushIceMessage error:", err)
-	} else {
-		fmt.Println("PushIceMessage success")
-	}
+	go services.Task()
 	// 初始化表数据入库
 	models.AfterInitTable()