From 73b6baf6af3d88cdcb0e2df7932a9bd96b0b85c5 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期一, 01 七月 2024 22:32:34 +0800
Subject: [PATCH] 月度统计出入库按类型汇总报表定时任务和手动跑任务接口

---
 main.go |   12 +++++++++++-
 1 files changed, 11 insertions(+), 1 deletions(-)

diff --git a/main.go b/main.go
index 1801bbf..a2ea7c2 100644
--- a/main.go
+++ b/main.go
@@ -19,6 +19,8 @@
 	"wms/proto/purchase_wms"
 	"wms/router"
 	"wms/service"
+	"wms/task"
+	"wms/utils/dingtalkrobot"
 )
 
 func main() {
@@ -60,7 +62,6 @@
 			logx.Errorf("grpc server init error: %v", err.Error())
 			panic(fmt.Sprintf("grpc server init error: %v", err.Error()))
 		}
-		fmt.Println("-----------鐩戝惉绔彛: ", conf.WebConf.GrpcPort)
 		s := grpc.NewServer()
 		//todo 娣诲姞鍏蜂綋鏈嶅姟
 		product_inventory.RegisterProductInventoryServiceServer(s, &product_inventory.Server{})
@@ -76,6 +77,15 @@
 	go service.InitLocationReportData()
 	go service.InitHistoryReportData()
 
+	//瀹氭椂浠诲姟鍒濆鍖�
+	if err := task.Init(); err != nil {
+		logx.Errorf("task init error: %v", err.Error())
+		return
+	}
+
+	//閽夐拤鏈哄櫒浜哄垵濮嬪寲
+	dingtalkrobot.Init(conf.DingTalkConf.AlarmKey, conf.DingTalkConf.AlarmUrl)
+
 	logx.Error(server.ListenAndServe().Error())
 }
 

--
Gitblit v1.8.0