| | |
|---|
| | | "aps_crm/initialize" |
|---|
| | | "aps_crm/middleware" |
|---|
| | | "aps_crm/model" |
|---|
| | | "aps_crm/model/grpc_init" |
|---|
| | | "aps_crm/pkg/logx" |
|---|
| | | "aps_crm/proto/product_inventory" |
|---|
| | | "aps_crm/router" |
|---|
| | |
|---|
| | | ReadTimeout: 5 * time.Second, |
|---|
| | | WriteTimeout: 5 * time.Second, |
|---|
| | | } |
|---|
| | | |
|---|
| | | //启动grpc客户端 |
|---|
| | | go v1.InitProductServiceConn() |
|---|
| | | go middleware.InitUserConn() |
|---|
| | | go v1.InitCodeServiceConn() |
|---|
| | | go v1.InitProductInventoryServiceConn() |
|---|
| | | go grpc_init.InitCrmApsGrpcServiceConn() |
|---|
| | | //启动grpc服务 |
|---|
| | | go func() { |
|---|
| | | ln, err := net.Listen("tcp", ":"+conf.Conf.System.GrpcPort) |
|---|
| | |
|---|
| | | panic(fmt.Sprintf("grpc server init error: %v", err.Error())) |
|---|
| | | } |
|---|
| | | }() |
|---|
| | | //c := cron.New() |
|---|
| | | //c.AddFunc("@every 15s", service.SyncUserInfo) // 每15秒同步一次 |
|---|
| | | //c.Start() |
|---|
| | | |
|---|
| | | middleware.InitRefreshUserManager(5, 5, 3600) |
|---|
| | | middleware.RunRefreshUser() ///定时对活跃用户更新用户详情 |
|---|
| | | |
|---|
| | | logx.Error(server.ListenAndServe().Error()) |
|---|
| | | } |
|---|
| | |
|---|
| | | signal.Notify(quit, syscall.SIGKILL, syscall.SIGQUIT, syscall.SIGINT, syscall.SIGTERM) |
|---|
| | | <-quit |
|---|
| | | |
|---|
| | | v1.CloseProductServiceConn() |
|---|
| | | v1.CloseCodeServiceConn() |
|---|
| | | middleware.StopRefreshUser() |
|---|
| | | v1.CloseProductInventoryServiceConn() |
|---|
| | | middleware.CloseUserConn() |
|---|
| | | grpc_init.CloseCrmApsGrpcServiceConn() |
|---|
| | | |
|---|
| | | logx.Infof("aps-crm exited...") |
|---|
| | | os.Exit(0) |
|---|
