图文生成openAPI

InteractTextRequest request = InteractTextRequest.builder()
                .agentId("1")
//                .sessionId("1")
                .content("测试").build();
        ResponseIterable<InteractTextResponseBody> responseBodies = client.interactTextWithResponseIterable(request);
        Gson gson = new Gson();
        System.out.println("------------");
        System.out.println(gson.toJson(request));
        System.out.println();
        for (InteractTextResponseBody responseBody : responseBodies) {
            System.out.print(responseBody.getMessage());
            if (responseBody.getEnd()) {
                System.out.println("\n\n请求已经结束： sessionId=" + responseBody.getSessionId());
                if (responseBody.getRelatedImages() != null && !responseBody.getRelatedImages().isEmpty()) {
                    System.out.println("相关图片：" + responseBody.getRelatedImages());
                }
                if (responseBody.getRelatedVideos() != null && !responseBody.getRelatedVideos().isEmpty()) {
                    System.out.println("相关视频：" + responseBody.getRelatedVideos());
                }
                break;
            }
        }
        System.out.println();
        System.out.println();
        System.out.println();
        System.out.println("-------------");
        System.out.println(responseBodies.getHeaders());

public static void main(String[] args) {
        StaticCredentialProvider provider = StaticCredentialProvider.create(
                Credential.builder()
                        .accessKeyId(ak)
                        .accessKeySecret(sk)
                        .build()
        );

        AsyncClient client = AsyncClient.builder()
                .region("cn-hangzhou")
                .credentialsProvider(provider)
                .serviceConfiguration(Configuration.create()
                        .setSignatureVersion(SignatureVersion.V3)
                )
                .overrideConfiguration(
                        ClientOverrideConfiguration.create()
                                .setProtocol("HTTPS")
                                .setEndpointOverride(url)
                )
                .build();

        QueryTextStreamRequest request = QueryTextStreamRequest.builder().textId(329L).build();
        ResponseIterable<QueryTextStreamResponseBody> responseBodies = client.queryTextStreamWithResponseIterable(request);
        for (QueryTextStreamResponseBody responseBody : responseBodies) {
             if (responseBody.getType().equals(0)) {
                 // 心跳检测无需输出
                continue;
            }
            if (responseBody.getType().equals(3)) {
                 // 异常信息，进行告警
                break;
            }
            System.out.print(responseBody.getMessage());

            if (responseBody.getEnd()) {
                System.out.println("\n\n请求已经结束：" + responseBody.getType() + "  -- " + responseBody.getIndex());
            }
        }
        System.out.println();
        System.out.println();
        System.out.println();
        System.out.println(responseBodies.getHeaders());


    }

{
    "number": 2,
    "textModeType": "Generate",
    "style": "WECHAT_MOMENT",
    "industry": "CulturalTour", 
    "introduction": "九寨沟山清水秀，环境优美。" ,
    "themes": [
      "TOUR_ROUTE",
      "ATTRACTION_TICKET"
    ]
}

{
    "number": 2,
    "textModeType": "Generate",
    "style": "RED_BOOK",
    "industry": "CulturalTour",
    "contentRequirement": "厦门4日游",
    "introduction": "路线安排 第1️⃣天: 中山路➡️猫街➡️沙坡尾➡️黄厝沙滩（日出）➡️曾厝按 第2️⃣天: 厦门植物园➡️厦门大学（需预约）➡️南普陀寺➡️钟鼓索道➡️演武大桥(观日落) 第3️⃣天: 鼓浪屿➡️八市 第4️⃣天: 海上地铁➡️海堤路➡️集美学村➡️厦门北",
    "point": "景点旅游线路",
    "target": "Seller",
    "themes": [
      "TOUR_ROUTE"
    ]
}

{
        "requestId": "0987EED3-752A-150A-B78B-ABCDD4890507",
        "availableIndustry": {
            "textModeTypes": [
                {
                    "name": "Generate",
                    "textStyles": [
                        {
                            "name": "RED_BOOK",
                            "disabled": false,
                            "desc": "小红书"
                        },
                        {
                            "name": "WECHAT_MOMENT",
                            "disabled": false,
                            "desc": "朋友圈"
                        }
                    ]
                },
                {
                    "name": "Rewrite",
                    "textStyles": [
                        {
                            "name": "RED_BOOK",
                            "disabled": false,
                            "desc": "小红书"
                        },
                        {
                            "name": "WECHAT_MOMENT",
                            "disabled": false,
                            "desc": "朋友圈"
                        }
                    ]
                }
            ],
            "name": "Common"
        }
    }

[
    [
        "user_id",
        "username",
        "sex_name",
        "city",
        "birthday",
        "height",
        "age",
        "consumer_behavior",
        "purchase_time"
    ],
    [
        "123456",
        "王**",
        "男",
        "杭州",
        "1989/10",
        "180",
        "30",
        "偏好服饰类目",
        "2024/12/20"
    ]
]

Car: 汽车行业
Common: 通用行业
CulturalTour: 文旅行业
Garment: 运动户外行业
Internet: 互联网工具行业

RED_BOOK ： 小红书
WECHAT_MOMENT ：朋友圈
TIKTOK ：抖音
ZHIHU ：知乎
QIWEI_TEXT ：企微话术

require 'vendor/autoload.php';
use AlibabaCloud\SDK\Imarketing\V20220704\Models\GetOssUploadSignatureRequest;
use AlibabaCloud\SDK\IntelligentCreation\V20240313\IntelligentCreation;
use Darabonba\OpenApi\Models\Config as AlibabaConfig;

$config = new AlibabaConfig();
$config->accessKeyId = '****';
$config->accessKeySecret = '****';
$config->endpoint = "intelligentcreation.cn-zhangjiakou.aliyuncs.com";

$intelligentCreationClient = new IntelligentCreation($config);

// GetOssUploadToken 接口示例
$request = new GetOssUploadSignatureRequest();
$request->fileName = 'xxx.png';
$request->fileType = "ProductImage";
try {
    $response = $intelligentCreationClient->getOssUploadToken($request);
    var_dump($response->toMap());
} catch (TeaError $e) {
    Log::error($e);
}

composer require alibabacloud/intelligentcreation-20240313 2.12.0

package com.aliyun;

import com.aliyun.intelligentcreation20240313.Client;
import com.aliyun.intelligentcreation20240313.models.GetOssUploadTokenRequest;
import com.aliyun.intelligentcreation20240313.models.GetOssUploadTokenResponse;
import com.aliyun.intelligentcreation20240313.models.UploadInfo;
import com.aliyun.teaopenapi.models.Config;

import java.util.HashMap;
import java.util.Map;

public class Test {

    public static void main(String[] args) throws Exception {
  //初始化配置
        Config config = new Config().setAccessKeyId("test").setAccessKeySecret("test").setEndpoint("intelligentcreation.cn-zhangjiakou.aliyuncs.com");
// 创建客户端
        Client client = new Client(config);

        Map<String, Object> map = new HashMap<>();
        map.put("fileName","xxx.png");
        map.put("fileType","ProductImage");
        GetOssUploadTokenRequest request = GetOssUploadTokenRequest.build(map);
// 请求接口
        GetOssUploadTokenResponse response = client.getOssUploadToken(request);
        if (response.getStatusCode().equals(200)) {
            System.out.println("请求成功");
            UploadInfo uploadInfo = response.getBody().getUploadInfo();
            System.out.println("请求出参：" + uploadInfo);
        }

    }
}

<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>intelligentcreation20240313</artifactId>
  <version>2.12.0</version>
</dependency>

public static void main(String[] args) {
        StaticCredentialProvider provider = StaticCredentialProvider.create(
                Credential.builder()
                        .accessKeyId(ak)
                        .accessKeySecret(sk)
                        .build()
        );

        AsyncClient client = AsyncClient.builder()
                .region("cn-zhangjiakou")
                .credentialsProvider(provider)
                .serviceConfiguration(Configuration.create()
                        .setSignatureVersion(SignatureVersion.V3)
                )
                .overrideConfiguration(
                        ClientOverrideConfiguration.create()
                                .setProtocol("HTTPS")
                                .setEndpointOverride(url)
                )
                .build();

        QueryTextStreamRequest request = QueryTextStreamRequest.builder().textId(329L).build();
        ResponseIterable<QueryTextStreamResponseBody> responseBodies = client.queryTextStreamWithResponseIterable(request);
        for (QueryTextStreamResponseBody responseBody : responseBodies) {
             if (responseBody.getType().equals(0)) {
                 // 心跳检测无需输出
                continue;
            }
            if (responseBody.getType().equals(3)) {
                 // 异常信息，进行告警
                break;
            }
            System.out.print(responseBody.getMessage());

            if (responseBody.getEnd()) {
                System.out.println("\n\n请求已经结束：" + responseBody.getType() + "  -- " + responseBody.getIndex());
            }
        }
        System.out.println(responseBodies.getHeaders());

    }

<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>alibabacloud-intelligentcreation20240313</artifactId>
  <version>2.0.7</version>
</dependency>

package main

import (
	"fmt"

	openapi "github.com/alibabacloud-go/darabonba-openapi/v2/client"
	intelligentcreation20240313 "github.com/alibabacloud-go/intelligentcreation-20240313/v2"
	util "github.com/alibabacloud-go/tea-utils/v2/service"
	"github.com/alibabacloud-go/tea/tea"
	
)

func CreateClient() (_result *intelligentcreation20240313.Client, _err error) {
	config := &openapi.Config{
		 // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
		 AccessKeyId: tea.String(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")),
		 // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
		 AccessKeySecret: tea.String(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")),
	}
	config.Endpoint = tea.String("intelligentcreation.cn-zhangjiakou.aliyuncs.com")
	_result = &intelligentcreation20240313.Client{}
	_result, _err = intelligentcreation20240313.NewClient(config)
	return _result, _err
}

func main() {
	client, _err := CreateClient()
	if _err != nil {
		panic(_err)
	}
	queryIndividuationTextTaskRequest := &intelligentcreation20240313.QueryIndividuationTextTaskRequest{
	// 文案任务id
		 TaskId: tea.String("1111"),
	}
	resp, tryErr := func() (response *intelligentcreation20240313.QueryIndividuationTextTaskResponse, _e error) {
		defer func() {
			if r := tea.Recover(recover()); r != nil {
				_e = r
			}
		}()
		// 复制代码运行请自行打印 API 的返回值
		response, _err = client.QueryIndividuationTextTask(queryIndividuationTextTaskRequest)
		if _err != nil {
			return response, _err
		}
		return response, nil
	}()

	if tryErr != nil {
		if sdkError, ok := tryErr.(*tea.SDKError); ok {
			// 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
			fmt.Println(tea.StringValue(sdkError.Message))
			fmt.Println(tea.StringValue(sdkError.Code))
			fmt.Println(tea.StringValue(sdkError.Data))
		} else {
			// 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
			fmt.Println(tea.String(tryErr.Error()))
		}
	} else {
		fmt.Println("Response:", resp) // 输出响应
	}
}

go get github.com/alibabacloud-go/intelligentcreation-20240313/v2