diff --git a/server/internal/social_service/handler/socialService/createsocialservicehandler.go b/server/internal/social_service/handler/socialService/createsocialservicehandler.go index b67ea54a..2b42a5f1 100644 --- a/server/internal/social_service/handler/socialService/createsocialservicehandler.go +++ b/server/internal/social_service/handler/socialService/createsocialservicehandler.go @@ -4,11 +4,14 @@ package socialService import ( + "fmt" "net/http" "github.com/JACKYMYPERSON/hldrCenter/config" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/logic/socialService" + "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/model" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/types" + "github.com/zeromicro/go-zero/core/stores/sqlx" "github.com/zeromicro/go-zero/rest/httpx" ) @@ -20,7 +23,23 @@ func CreateSocialServiceHandler(cfg *config.Config) http.HandlerFunc { return } - l := socialService.NewCreateSocialServiceLogic(r.Context(), svcCtx) + mysqlCfg := cfg.MySQL + dsn := fmt.Sprintf( + "%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local", + mysqlCfg.Username, + mysqlCfg.Password, + mysqlCfg.Host, + mysqlCfg.Port, + mysqlCfg.Database, + mysqlCfg.Charset, + ) + fmt.Println("接收到articlePost请求") + + conn := sqlx.NewSqlConn("mysql", dsn) + + meetingModel := model.NewSocialServiceModel(conn) + + l := socialService.NewCreateSocialServiceLogic(r.Context(), cfg, meetingModel) resp, err := l.CreateSocialService(&req) if err != nil { httpx.ErrorCtx(r.Context(), w, err) diff --git a/server/internal/social_service/handler/socialService/deletesocialservicehandler.go b/server/internal/social_service/handler/socialService/deletesocialservicehandler.go index a2dcf1ce..5da10a2f 100644 --- a/server/internal/social_service/handler/socialService/deletesocialservicehandler.go +++ b/server/internal/social_service/handler/socialService/deletesocialservicehandler.go @@ -4,11 +4,14 @@ package socialService import ( + "fmt" "net/http" "github.com/JACKYMYPERSON/hldrCenter/config" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/logic/socialService" + "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/model" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/types" + "github.com/zeromicro/go-zero/core/stores/sqlx" "github.com/zeromicro/go-zero/rest/httpx" ) @@ -20,7 +23,23 @@ func DeleteSocialServiceHandler(cfg *config.Config) http.HandlerFunc { return } - l := socialService.NewDeleteSocialServiceLogic(r.Context(), svcCtx) + mysqlCfg := cfg.MySQL + dsn := fmt.Sprintf( + "%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local", + mysqlCfg.Username, + mysqlCfg.Password, + mysqlCfg.Host, + mysqlCfg.Port, + mysqlCfg.Database, + mysqlCfg.Charset, + ) + fmt.Println("接收到articlePost请求") + + conn := sqlx.NewSqlConn("mysql", dsn) + + meetingModel := model.NewSocialServiceModel(conn) + + l := socialService.NewDeleteSocialServiceLogic(r.Context(), cfg, meetingModel) resp, err := l.DeleteSocialService(&req) if err != nil { httpx.ErrorCtx(r.Context(), w, err) diff --git a/server/internal/social_service/handler/socialService/getsocialservicehandler.go b/server/internal/social_service/handler/socialService/getsocialservicehandler.go index bc658727..0bd9559d 100644 --- a/server/internal/social_service/handler/socialService/getsocialservicehandler.go +++ b/server/internal/social_service/handler/socialService/getsocialservicehandler.go @@ -4,11 +4,14 @@ package socialService import ( + "fmt" "net/http" "github.com/JACKYMYPERSON/hldrCenter/config" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/logic/socialService" + "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/model" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/types" + "github.com/zeromicro/go-zero/core/stores/sqlx" "github.com/zeromicro/go-zero/rest/httpx" ) @@ -20,7 +23,23 @@ func GetSocialServiceHandler(cfg *config.Config) http.HandlerFunc { return } - l := socialService.NewGetSocialServiceLogic(r.Context(), svcCtx) + mysqlCfg := cfg.MySQL + dsn := fmt.Sprintf( + "%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local", + mysqlCfg.Username, + mysqlCfg.Password, + mysqlCfg.Host, + mysqlCfg.Port, + mysqlCfg.Database, + mysqlCfg.Charset, + ) + fmt.Println("接收到articlePost请求") + + conn := sqlx.NewSqlConn("mysql", dsn) + + meetingModel := model.NewSocialServiceModel(conn) + + l := socialService.NewGetSocialServiceLogic(r.Context(), cfg, meetingModel) resp, err := l.GetSocialService(&req) if err != nil { httpx.ErrorCtx(r.Context(), w, err) diff --git a/server/internal/social_service/handler/socialService/listsocialservicehandler.go b/server/internal/social_service/handler/socialService/listsocialservicehandler.go index 77df1ff4..084db6ac 100644 --- a/server/internal/social_service/handler/socialService/listsocialservicehandler.go +++ b/server/internal/social_service/handler/socialService/listsocialservicehandler.go @@ -4,11 +4,14 @@ package socialService import ( + "fmt" "net/http" "github.com/JACKYMYPERSON/hldrCenter/config" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/logic/socialService" + "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/model" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/types" + "github.com/zeromicro/go-zero/core/stores/sqlx" "github.com/zeromicro/go-zero/rest/httpx" ) @@ -20,7 +23,23 @@ func ListSocialServiceHandler(cfg *config.Config) http.HandlerFunc { return } - l := socialService.NewListSocialServiceLogic(r.Context(), svcCtx) + mysqlCfg := cfg.MySQL + dsn := fmt.Sprintf( + "%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local", + mysqlCfg.Username, + mysqlCfg.Password, + mysqlCfg.Host, + mysqlCfg.Port, + mysqlCfg.Database, + mysqlCfg.Charset, + ) + fmt.Println("接收到articlePost请求") + + conn := sqlx.NewSqlConn("mysql", dsn) + + meetingModel := model.NewSocialServiceModel(conn) + + l := socialService.NewListSocialServiceLogic(r.Context(), cfg, meetingModel) resp, err := l.ListSocialService(&req) if err != nil { httpx.ErrorCtx(r.Context(), w, err) diff --git a/server/internal/social_service/handler/socialService/updatesocialservicehandler.go b/server/internal/social_service/handler/socialService/updatesocialservicehandler.go index 4014cf64..e7648b57 100644 --- a/server/internal/social_service/handler/socialService/updatesocialservicehandler.go +++ b/server/internal/social_service/handler/socialService/updatesocialservicehandler.go @@ -4,11 +4,14 @@ package socialService import ( + "fmt" "net/http" "github.com/JACKYMYPERSON/hldrCenter/config" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/logic/socialService" + "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/model" "github.com/JACKYMYPERSON/hldrCenter/internal/social_service/internal/types" + "github.com/zeromicro/go-zero/core/stores/sqlx" "github.com/zeromicro/go-zero/rest/httpx" ) @@ -20,7 +23,23 @@ func UpdateSocialServiceHandler(cfg *config.Config) http.HandlerFunc { return } - l := socialService.NewUpdateSocialServiceLogic(r.Context(), svcCtx) + mysqlCfg := cfg.MySQL + dsn := fmt.Sprintf( + "%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local", + mysqlCfg.Username, + mysqlCfg.Password, + mysqlCfg.Host, + mysqlCfg.Port, + mysqlCfg.Database, + mysqlCfg.Charset, + ) + fmt.Println("接收到articlePost请求") + + conn := sqlx.NewSqlConn("mysql", dsn) + + meetingModel := model.NewSocialServiceModel(conn) + + l := socialService.NewUpdateSocialServiceLogic(r.Context(), cfg, meetingModel) resp, err := l.UpdateSocialService(&req) if err != nil { httpx.ErrorCtx(r.Context(), w, err) diff --git a/server/internal/social_service/internal/logic/socialService/createsocialservicelogic.go b/server/internal/social_service/internal/logic/socialService/createsocialservicelogic.go index 1d87547c..4b0f479c 100644 --- a/server/internal/social_service/internal/logic/socialService/createsocialservicelogic.go +++ b/server/internal/social_service/internal/logic/socialService/createsocialservicelogic.go @@ -30,7 +30,6 @@ func NewCreateSocialServiceLogic(ctx context.Context, cfg *config.Config, model } func (l *CreateSocialServiceLogic) CreateSocialService(req *types.CreateSocialServiceReq) (resp *types.CreateSocialServiceResp, err error) { - // todo: add your logic here and delete this line return }