测试消息推送

main.go

@@ -10,7 +10,9 @@ import (
 
 	_ "eta_gn/eta_api/global"
 	_ "eta_gn/eta_api/routers"
-	"eta_gn/eta_api/services"
+
+	//"eta_gn/eta_api/services"
+	"eta_gn/eta_api/services/ice_message"
 	"eta_gn/eta_api/utils"
 
 	"github.com/beego/beego/v2/adapter/logs"
@@ -26,8 +28,20 @@ func main() {
 	// 服务名称
 	web.BConfig.ServerName = `server`
 
-	go services.Task()
-
+	//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")
+	}
 	// 初始化表数据入库
 	models.AfterInitTable()