解决冲突

server/home-user-auth/internal/handler/userorderdeletehandler.go

@@ -15,7 +15,7 @@ func UserOrderDeleteHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
 
 		var req types.UserOrderDeleteReq
-		userinfo, err := basic.RequestParse(w, r, svcCtx, &req)
+		userinfo, err := basic.RequestParse(w, r, svcCtx.SharedState, &req)
 		if err != nil {
 			return
 		}

server/pay/internal/handler/orderpaymentintenthandler.go

@@ -15,7 +15,7 @@ func OrderPaymentIntentHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
 
 		var req types.OrderPaymentIntentReq
-		userinfo, err := basic.RequestParse(w, r, svcCtx, &req)
+		userinfo, err := basic.RequestParse(w, r, svcCtx.SharedState, &req)
 		if err != nil {
 			return
 		}

server/pay/internal/svc/servicecontext.go

@@ -3,7 +3,9 @@ package svc
 import (
 	"errors"
 	"fmt"
+	"fusenapi/fsm"
 	"fusenapi/server/pay/internal/config"
+	"fusenapi/utils/autoconfig"
 	"net/http"
 
 	"fusenapi/initalize"
@@ -14,18 +16,22 @@ import (
 )
 
 type ServiceContext struct {
-	Config config.Config
+	Config      config.Config
+	SharedState *fsm.StateCluster
 
 	MysqlConn *gorm.DB
 	AllModels *gmodel.AllModelsGen
 }
 
 func NewServiceContext(c config.Config) *ServiceContext {
+	conn := initalize.InitMysql(c.SourceMysql)
+	StateServer := fsm.StartNode(c.Name, fmt.Sprintf("%s:%d", c.Host, c.Port-2000), autoconfig.AutoGetAllServerConfig(), conn)
 
 	return &ServiceContext{
-		Config:    c,
-		MysqlConn: initalize.InitMysql(c.SourceMysql),
-		AllModels: gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
+		Config:      c,
+		MysqlConn:   conn,
+		SharedState: StateServer,
+		AllModels:   gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
 	}
 }
 

server/product-template-tag/internal/handler/getproducttemplatetagshandler.go

@@ -15,7 +15,7 @@ func GetProductTemplateTagsHandler(svcCtx *svc.ServiceContext) http.HandlerFunc
 	return func(w http.ResponseWriter, r *http.Request) {
 
 		var req types.GetProductTemplateTagsReq
-		userinfo, err := basic.RequestParse(w, r, svcCtx, &req)
+		userinfo, err := basic.RequestParse(w, r, svcCtx.SharedState, &req)
 		if err != nil {
 			return
 		}

server/product-template-tag/internal/svc/servicecontext.go

@@ -3,7 +3,9 @@ package svc
 import (
 	"errors"
 	"fmt"
+	"fusenapi/fsm"
 	"fusenapi/server/product-template-tag/internal/config"
+	"fusenapi/utils/autoconfig"
 	"net/http"
 
 	"fusenapi/initalize"
@@ -14,18 +16,22 @@ import (
 )
 
 type ServiceContext struct {
-	Config config.Config
+	Config      config.Config
+	SharedState *fsm.StateCluster
 
 	MysqlConn *gorm.DB
 	AllModels *gmodel.AllModelsGen
 }
 
 func NewServiceContext(c config.Config) *ServiceContext {
+	conn := initalize.InitMysql(c.SourceMysql)
+	StateServer := fsm.StartNode(c.Name, fmt.Sprintf("%s:%d", c.Host, c.Port-2000), autoconfig.AutoGetAllServerConfig(), conn)
 
 	return &ServiceContext{
-		Config:    c,
-		MysqlConn: initalize.InitMysql(c.SourceMysql),
-		AllModels: gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
+		Config:      c,
+		MysqlConn:   conn,
+		SharedState: StateServer,
+		AllModels:   gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
 	}
 }
 

server/websocket/internal/handler/rendernotifyhandler.go

@@ -12,7 +12,7 @@ import (
 func RenderNotifyHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
 		var req types.RenderNotifyReq
-		_, err := basic.RequestParse(w, r, svcCtx, &req)
+		_, err := basic.RequestParse(w, r, svcCtx.SharedState, &req)
 		if err != nil {
 			return
 		}

server/websocket/internal/svc/servicecontext.go

@@ -3,7 +3,9 @@ package svc
 import (
 	"errors"
 	"fmt"
+	"fusenapi/fsm"
 	"fusenapi/server/websocket/internal/config"
+	"fusenapi/utils/autoconfig"
 	"net/http"
 
 	"fusenapi/initalize"
@@ -14,21 +16,24 @@ import (
 )
 
 type ServiceContext struct {
-	Config config.Config
+	Config      config.Config
+	SharedState *fsm.StateCluster
 
 	MysqlConn *gorm.DB
 	AllModels *gmodel.AllModelsGen
 }
 
 func NewServiceContext(c config.Config) *ServiceContext {
+	conn := initalize.InitMysql(c.SourceMysql)
+	StateServer := fsm.StartNode(c.Name, fmt.Sprintf("%s:%d", c.Host, c.Port-2000), autoconfig.AutoGetAllServerConfig(), conn)
 
 	return &ServiceContext{
-		Config:    c,
-		MysqlConn: initalize.InitMysql(c.SourceMysql),
-		AllModels: gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
+		Config:      c,
+		MysqlConn:   conn,
+		SharedState: StateServer,
+		AllModels:   gmodel.NewAllModels(initalize.InitMysql(c.SourceMysql)),
 	}
 }
-
 func (svcCtx *ServiceContext) ParseJwtToken(r *http.Request) (jwt.MapClaims, error) {
 	AuthKey := r.Header.Get("Authorization")
 	if AuthKey == "" {