jyInfo/rpc/consumer/internal/logic/infofiledellogic.go

package logic

import (
	IC "app.yhyue.com/moapp/jyInfo/rpc/consumer/init"
	model "app.yhyue.com/moapp/jyInfo/rpc/model/oss"
	"context"
	"fmt"
	"log"

	"app.yhyue.com/moapp/jyInfo/rpc/consumer/consumerclient"
	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"

	"github.com/zeromicro/go-zero/core/logx"
)

type InfoFileDelLogic struct {
	ctx    context.Context
	svcCtx *svc.ServiceContext
	logx.Logger
}

func NewInfoFileDelLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoFileDelLogic {
	return &InfoFileDelLogic{
		ctx:    ctx,
		svcCtx: svcCtx,
		Logger: logx.WithContext(ctx),
	}
}

// 删除附件
func (l *InfoFileDelLogic) InfoFileDel(in *consumerclient.InfoFileDelReq) (*consumerclient.BaseResp, error) {
	var resp = &consumerclient.BaseResp{}
	if in.Fid != "" && IC.C.Oss.OssBucketName != "" {
		b, err := model.OssDelObject(in.Fid, IC.C.Oss.OssBucketName)
		if !b || err != nil {
			log.Println("rpc fileDel false :", err)
			resp.ErrCode = -1
			resp.ErrMsg = fmt.Sprintf("附件 %s 删除异常", in.Fname)
		}
	}
	return resp, nil
}