ai_old/llm/zhipu/gc.go

package zhipu

import (
	"apigo.cc/ai/ai/llm"
	"apigo.cc/ai/ai/llm/zhipu/zhipu"
	"context"
	"errors"
	"time"
)

func (lm *LLM) FastMakeImage(prompt string, config llm.GCConfig) ([]string, error) {
	config.Model = ModelCogView3Plus
	return lm.MakeImage(prompt, config)
}

func (lm *LLM) BestMakeImage(prompt string, config llm.GCConfig) ([]string, error) {
	config.Model = ModelCogView3
	return lm.MakeImage(prompt, config)
}

func (lm *LLM) MakeImage(prompt string, config llm.GCConfig) ([]string, error) {
	c, err := zhipu.NewClient(zhipu.WithAPIKey(lm.config.ApiKey), zhipu.WithBaseURL(lm.config.Endpoint))
	if err != nil {
		return nil, err
	}

	config.SetDefault(&lm.config.GCConfig)
	cc := c.ImageGeneration(config.Model).SetPrompt(prompt)
	cc.SetSize(config.GetSize())

	if r, err := cc.Do(context.Background()); err == nil {
		results := make([]string, 0)
		for _, item := range r.Data {
			results = append(results, item.URL)
		}
		return results, nil
	} else {
		return nil, err
	}
}

func (lm *LLM) FastMakeVideo(prompt string, config llm.GCConfig) ([]string, []string, error) {
	config.Model = ModelCogVideoX
	return lm.MakeVideo(prompt, config)
}

func (lm *LLM) BestMakeVideo(prompt string, config llm.GCConfig) ([]string, []string, error) {
	config.Model = ModelCogVideoX
	return lm.MakeVideo(prompt, config)
}

func (lm *LLM) MakeVideo(prompt string, config llm.GCConfig) ([]string, []string, error) {
	c, err := zhipu.NewClient(zhipu.WithAPIKey(lm.config.ApiKey), zhipu.WithBaseURL(lm.config.Endpoint))
	if err != nil {
		return nil, nil, err
	}

	config.SetDefault(&lm.config.GCConfig)
	cc := c.VideoGeneration(config.Model).SetPrompt(prompt)
	cc.SetImageURL(config.GetRef())

	if resp, err := cc.Do(context.Background()); err == nil {
		for i := 0; i < 1200; i++ {
			r, err := c.AsyncResult(resp.ID).Do(context.Background())
			if err != nil {
				return nil, nil, err
			}
			if r.TaskStatus == zhipu.VideoGenerationTaskStatusSuccess {
				covers := make([]string, 0)
				results := make([]string, 0)
				for _, item := range r.VideoResult {
					results = append(results, item.URL)
					covers = append(covers, item.CoverImageURL)
				}
				return results, covers, nil
			}
			if r.TaskStatus == zhipu.VideoGenerationTaskStatusFail {
				return nil, nil, errors.New("fail on task " + resp.ID)
			}
			time.Sleep(3 * time.Second)
		}
		return nil, nil, errors.New("timeout on task " + resp.ID)
	} else {
		return nil, nil, err
	}
}