From f9c73558a12fef8c17cc74a9d4507bc5dc91340f Mon Sep 17 00:00:00 2001 From: mayiming <1627832236@qq.com> Date: Wed, 29 Oct 2025 11:44:33 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E7=A4=BE=E4=BC=9A=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E4=B8=9A=E5=8A=A1=E5=B1=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../createsocialservicehandler.go | 21 ++++++++++++++++++- .../deletesocialservicehandler.go | 21 ++++++++++++++++++- .../socialService/getsocialservicehandler.go | 21 ++++++++++++++++++- .../socialService/listsocialservicehandler.go | 21 ++++++++++++++++++- .../updatesocialservicehandler.go | 21 ++++++++++++++++++- .../socialService/createsocialservicelogic.go | 1 - 6 files changed, 100 insertions(+), 6 deletions(-) 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 }