fusenapi/service/repositories/image_handle.go

package repositories

import (
	"context"
	"encoding/json"
	"errors"
	"fusenapi/constants"
	"fusenapi/model/gmodel"
	"fusenapi/utils/curl"
	"fusenapi/utils/file"
	"fusenapi/utils/hash"
	"io"
	"strings"
	"time"

	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/zeromicro/go-zero/core/logx"
	"gorm.io/gorm"
)

func NewImageHandle(gormDB *gorm.DB, bLMServiceUrl *string, awsSession *session.Session) ImageHandle {
	return &defaultImageHandle{
		MysqlConn:     gormDB,
		BLMServiceUrl: bLMServiceUrl,
		AwsSession:    awsSession,
	}
}

type (
	defaultImageHandle struct {
		MysqlConn     *gorm.DB
		BLMServiceUrl *string
		AwsSession    *session.Session
	}

	ImageHandle = interface {

		// logo合图
		LogoCombine(ctx context.Context, in *LogoCombineReq) (*LogoCombineRes, error)
	}
)

/* logo合图 */
type (
	LogoCombineReq struct {
		UserId      int64  `json:"user_id"`
		GuestId     int64  `json:"guest_id"`
		TemplateId  int64  `json:"template_id"`
		TemplateTag string `json:"template_tag"`
		Website     string `json:"website"` // 合图参数
		Slogan      string `json:"slogan"`  // 合图参数
		Address     string `json:"address"` // 合图参数
		Phone       string `json:"phone"`   // 合图参数
		Qrcode      string `json:"qrcode"`  // 合图参数
	}
	LogoCombineRes struct {
		ResourceId  string
		ResourceUrl *string
		Metadata    *string
	}
)

func (l *defaultImageHandle) LogoCombine(ctx context.Context, in *LogoCombineReq) (*LogoCombineRes, error) {
	// 根据hash 查询数据资源
	var hashKeyData = *in
	hashKeyData.GuestId = 0
	hashKeyData.UserId = 0
	var resourceId string = hash.JsonHashKey(hashKeyData)

	resourceModel := gmodel.NewFsResourceModel(l.MysqlConn)
	resourceInfo, err := resourceModel.FindOneById(ctx, resourceId)
	if err == nil && resourceInfo.ResourceId != "" {
		return &LogoCombineRes{
			ResourceId:  resourceId,
			ResourceUrl: resourceInfo.ResourceUrl,
		}, nil
	} else {
		if err != nil {
			if !errors.Is(err, gorm.ErrRecordNotFound) {
				logx.Error(err)
				return nil, err
			}
		}
	}

	// 没有查到，先根据模版id 查询模版数据 请求算法数据
	productTemplateV2Model := gmodel.NewFsProductTemplateV2Model(l.MysqlConn)
	productTemplateV2Info, err := productTemplateV2Model.FindOne(ctx, in.TemplateId)

	if err != nil {
		logx.Error(err)
		return nil, err
	}
	var groupOptions map[string]interface{}
	if productTemplateV2Info.GroupOptions != nil {
		err = json.Unmarshal([]byte(*productTemplateV2Info.GroupOptions), &groupOptions)

		if err != nil {
			logx.Error(err)
			return nil, err
		}
	}

	var materialList []interface{}
	if productTemplateV2Info.TemplateInfo != nil {
		var templateInfo map[string]interface{}
		err = json.Unmarshal([]byte(*productTemplateV2Info.TemplateInfo), &templateInfo)

		if err != nil {
			logx.Error(err)
			return nil, err
		}
		materialList = templateInfo["materialList"].([]interface{})
	}

	var moduleDataMap = make(map[string]interface{}, 4)
	moduleDataMap["id"] = productTemplateV2Info.Id
	moduleDataMap["material"] = productTemplateV2Info.MaterialImg
	moduleDataMap["groupOptions"] = groupOptions
	moduleDataMap["materialList"] = materialList

	// 查询logo最新基础信息
	var metadata *string
	userMaterialModel := gmodel.NewFsUserMaterialModel(l.MysqlConn)
	userMaterialInfo, err := userMaterialModel.FindLatestOne(ctx, in.UserId, in.GuestId)

	if err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			userMaterialInfoDefault, err := userMaterialModel.FindOneById(ctx, 0)
			if err != nil {
				logx.Error(err)
				return nil, err
			}
			metadata = userMaterialInfoDefault.Metadata
		} else {
			logx.Error(err)
			return nil, err
		}
	} else {
		metadata = userMaterialInfo.Metadata
	}

	var combineParam map[string]interface{}
	json.Unmarshal([]byte(*metadata), &combineParam)
	combineParam["template_tagid"] = in.TemplateTag
	combineParam["website"] = in.Website
	combineParam["slogan"] = in.Slogan
	combineParam["phone"] = in.Phone
	combineParam["address"] = in.Address
	combineParam["qrcode"] = in.Qrcode

	var postMap = make(map[string]interface{}, 2)
	postMap["module_data"] = moduleDataMap
	postMap["param_data"] = combineParam
	postMapB, _ := json.Marshal(postMap)

	var headerData = make(map[string]string, 1)
	headerData["Content-Type"] = "application/json"
	result, err := curl.ApiCall(*l.BLMServiceUrl+constants.BLMServiceUrlLogoCombine, "POST", headerData, strings.NewReader(string(postMapB)), time.Second*20)

	if err != nil {
		logx.Error(err)
		return nil, err
	}
	defer result.Body.Close()
	b, err := io.ReadAll(result.Body)
	if err != nil {
		logx.Error(err)
		return nil, err
	}
	var resultStr string
	if string(b) == "Internal Server Error" {
		err = errors.New("BLMService fail Internal Server Error")
		logx.Error(err)
		return nil, err
	} else {
		var resData map[string]interface{}
		err = json.Unmarshal(b, &resData)
		if err != nil || resData == nil {
			logx.Error(err)
			return nil, err
		}

		if resData != nil {
			if resData["code"].(string) == "200" {
				resultStr = resData["data"].(string)
			} else {
				logx.Error(err)
				return nil, err
			}
		} else {
			logx.Error(err)
			return nil, err
		}
	}

	var resultData map[string]interface{}
	err = json.Unmarshal([]byte(resultStr), &resultData)
	if err != nil || resultData == nil {
		logx.Error(err)
		return nil, err
	}
	// {
	// 	id: "",
	// 	logo_url:"https://s3.amazon.com/xxxx"，
	// 	result: "$saa541afaldjaldjasldjsadjsapsaasda"
	// }
	var fileBase = resultData["result"]

	// 上传文件
	var upload = file.Upload{
		Ctx:        ctx,
		MysqlConn:  l.MysqlConn,
		AwsSession: l.AwsSession,
	}
	uploadRes, err := upload.UploadFileByBase64(&file.UploadBaseReq{
		FileHash:     resourceId,
		FileData:     fileBase.(string),
		UploadBucket: 1,
		ApiType:      2,
		UserId:       in.UserId,
		GuestId:      in.GuestId,
	})
	if err != nil {
		logx.Error(err)
		return nil, err
	}
	return &LogoCombineRes{
		ResourceId:  uploadRes.ResourceId,
		ResourceUrl: &uploadRes.ResourceUrl,
	}, nil
}

/* logo合图 */