| | |
| | | "wms/proto/purchase_wms" |
| | | "wms/router" |
| | | "wms/service" |
| | | "wms/task" |
| | | "wms/utils/dingtalkrobot" |
| | | ) |
| | | |
| | | func main() { |
| | |
| | | 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{}) |
| | |
| | | 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()) |
| | | } |
| | | |