feat(wechat): upload image to oa

ArtisanCloud · Nov 20, 2023 · 4be82f6 · 4be82f6
1 parent 9dc32c9
commit 4be82f6
Show file tree

Hide file tree

Showing 9 changed files with 174 additions and 12 deletions.
diff --git a/api/admin/wechat/officialaccount/media.api b/api/admin/wechat/officialaccount/media.api
@@ -16,7 +16,7 @@ info(
 
 service PowerX {
     @doc "查询菜单列表"
-    @handler GetMediaList
+    @handler GetOAMediaList
     post /medias/page-list (GetOAMediaListRequest) returns (GetOAMediaListReply)
 
     @doc "查询菜单列表"
@@ -28,6 +28,11 @@ service PowerX {
     post /medias/:mediaId (GetOAMediaRequest) returns (GetOAMediaReply)
 
 
+    @doc "创建菜单"
+    @handler UploadOAMedia
+    post /medias/upload returns (CreateOAMediaReply)
+
+
     @doc "创建菜单"
     @handler CreateOAMedia
     post /medias (CreateOAMediaRequest) returns (CreateOAMediaReply)

diff --git a/internal/handler/admin/wechat/officialaccount/media/getmedialisthandler.go b/internal/handler/admin/wechat/officialaccount/media/getmedialisthandler.go
@@ -17,8 +17,8 @@ func GetMediaListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 			return
 		}
 
-		l := media.NewGetMediaListLogic(r.Context(), svcCtx)
-		resp, err := l.GetMediaList(&req)
+		l := media.NewGetOAMediaListLogic(r.Context(), svcCtx)
+		resp, err := l.GetOAMediaList(&req)
 		if err != nil {
 			httpx.ErrorCtx(r.Context(), w, err)
 		} else {

diff --git a/internal/handler/admin/wechat/officialaccount/media/getoamedialisthandler.go b/internal/handler/admin/wechat/officialaccount/media/getoamedialisthandler.go
@@ -0,0 +1,28 @@
+package media
+
+import (
+	"net/http"
+
+	"PowerX/internal/logic/admin/wechat/officialaccount/media"
+	"PowerX/internal/svc"
+	"PowerX/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func GetOAMediaListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.GetOAMediaListRequest
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := media.NewGetOAMediaListLogic(r.Context(), svcCtx)
+		resp, err := l.GetOAMediaList(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}
diff --git a/internal/handler/admin/wechat/officialaccount/media/uploadoamediahandler.go b/internal/handler/admin/wechat/officialaccount/media/uploadoamediahandler.go
@@ -0,0 +1,21 @@
+package media
+
+import (
+	"net/http"
+
+	"PowerX/internal/logic/admin/wechat/officialaccount/media"
+	"PowerX/internal/svc"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func UploadOAMediaHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		l := media.NewUploadOAMediaLogic(r.Context(), svcCtx)
+		resp, err := l.UploadOAMedia(r)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}
diff --git a/internal/handler/routes.go b/internal/handler/routes.go
diff --git a/internal/logic/admin/wechat/officialaccount/media/deleteoamedialogic.go b/internal/logic/admin/wechat/officialaccount/media/deleteoamedialogic.go
@@ -1,6 +1,7 @@
 package media
 
 import (
+	"PowerX/internal/types/errorx"
 	"context"
 
 	"PowerX/internal/svc"
@@ -24,7 +25,17 @@ func NewDeleteOAMediaLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Del
 }
 
 func (l *DeleteOAMediaLogic) DeleteOAMedia(req *types.DeleteOAMediaRequest) (resp *types.DeleteOAMediaReply, err error) {
-	// todo: add your logic here and delete this line
+	res, err := l.svcCtx.PowerX.WechatOA.App.Material.Delete(l.ctx, req.MediaId)
+	if err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, err.Error())
+	}
+
+	if res.ErrCode != 0 {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, res.ErrMsg)
+	}
 
-	return
+	return &types.DeleteOAMediaReply{
+		Success: true,
+		Data:    nil,
+	}, nil
 }
diff --git a/...fficialaccount/media/getmedialistlogic.go → ...icialaccount/media/getoamedialistlogic.go b/...fficialaccount/media/getmedialistlogic.go → ...icialaccount/media/getoamedialistlogic.go
@@ -1,30 +1,31 @@
 package media
 
 import (
-	"PowerX/internal/svc"
-	"PowerX/internal/types"
 	"PowerX/internal/types/errorx"
 	"context"
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/officialAccount/material/request"
 
+	"PowerX/internal/svc"
+	"PowerX/internal/types"
+
 	"github.com/zeromicro/go-zero/core/logx"
 )
 
-type GetMediaListLogic struct {
+type GetOAMediaListLogic struct {
 	logx.Logger
 	ctx    context.Context
 	svcCtx *svc.ServiceContext
 }
 
-func NewGetMediaListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMediaListLogic {
-	return &GetMediaListLogic{
+func NewGetOAMediaListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetOAMediaListLogic {
+	return &GetOAMediaListLogic{
 		Logger: logx.WithContext(ctx),
 		ctx:    ctx,
 		svcCtx: svcCtx,
 	}
 }
 
-func (l *GetMediaListLogic) GetMediaList(req *types.GetOAMediaListRequest) (resp *types.GetOAMediaListReply, err error) {
+func (l *GetOAMediaListLogic) GetOAMediaList(req *types.GetOAMediaListRequest) (resp *types.GetOAMediaListReply, err error) {
 
 	if req.Count <= 0 {
 		req.Count = 10

diff --git a/internal/logic/admin/wechat/officialaccount/media/uploadoamedialogic.go b/internal/logic/admin/wechat/officialaccount/media/uploadoamedialogic.go
@@ -0,0 +1,84 @@
+package media
+
+import (
+	"PowerX/internal/logic/admin/mediaresource"
+	"PowerX/internal/types/errorx"
+	"context"
+	fmt2 "fmt"
+	"github.com/ArtisanCloud/PowerLibs/v3/object"
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/officialAccount/material/response"
+	"io"
+	"net/http"
+	"os"
+	"time"
+
+	"PowerX/internal/svc"
+	"PowerX/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type UploadOAMediaLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewUploadOAMediaLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadOAMediaLogic {
+	return &UploadOAMediaLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *UploadOAMediaLogic) UploadOAMedia(r *http.Request) (resp *types.CreateOAMediaReply, err error) {
+
+	err = r.ParseMultipartForm(mediaresource.MaxFileSize)
+	if err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, err.Error())
+	}
+
+	file, _, err := r.FormFile("file")
+	//fmt.Dump(handler.Filename)
+	if err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, err.Error())
+	}
+	defer file.Close()
+
+	// 读取文件内容
+	fileContents, err := io.ReadAll(file)
+	if err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, "failed to read file content")
+	}
+
+	// 获取文件的临时目录和文件名
+	tempDir := os.TempDir()
+	tempFileName := fmt2.Sprintf("%d_*.jpg", time.Now().Unix())
+
+	// 创建临时文件
+	tempFile, err := os.CreateTemp(tempDir, tempFileName)
+	if err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, "failed to create temporary file")
+	}
+	defer os.Remove(tempFile.Name()) // 删除临时文件，确保在函数退出时清理
+
+	// 将文件内容保存到临时文件
+	if err := os.WriteFile(tempFile.Name(), fileContents, 0644); err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, "failed to save file")
+	}
+	//fmt.Dump("temp", tempFile.Name(), "end")
+	paramValues := r.Form
+	res := &response.ResponseMaterialAddMaterial{}
+	_, err = l.svcCtx.PowerX.WechatOA.App.Material.Upload(l.ctx, paramValues.Get("type"), tempFile.Name(), &object.StringMap{}, res)
+	if err != nil {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, err.Error())
+	}
+	if res.ErrCode != 0 {
+		return nil, errorx.WithCause(errorx.ErrBadRequest, res.ErrMsg)
+	}
+
+	return &types.CreateOAMediaReply{
+		Success: true,
+	}, nil
+}
diff --git a/pkg/filex/filex.go b/pkg/filex/filex.go
@@ -4,6 +4,7 @@ import (
 	"io"
 	"mime/multipart"
 	"os"
+	"path/filepath"
 	"strings"
 )
 
@@ -41,3 +42,9 @@ func SaveFileToLocal(fileHeader *multipart.FileHeader, uploadPath string) error
 
 	return nil
 }
+
+func GetTempFilePath(fileName string) (string, error) {
+
+	filePath := filepath.Join(os.TempDir(), fileName)
+	return filePath, nil
+}