如何在Java Pact契约中动态注入Body ID

@Slf4j
@Provider("Assignments API")
@Consumer("LTI-AGS-Tool")
@VerificationReports(value = {"console", "markdown"}, reportDir = "target/pacts")
class PactProviderLTIAGSIT {

    private HashMap<String, String> headers = new HashMap<>();
    private String updateAssignmentId; // 用于存储动态生成的ID
    private final String SERVICE_TOKEN = "myToken";

    @BeforeEach
    void createTeacherAssignment() {
        // ... (省略创建assignmentBody的逻辑) ...
        String assignmentBody = createBodyStringForStudentAssignmentSetup(); // 假设此方法生成初始body
        assignmentBody = assignmentBody.replace("CPWAG", "OTHER_TEXT_RESOURCE");

        headers.put("Content-Type", "application/json");
        headers.put("Authorization", SERVICE_TOKEN); // 使用SERVICE_TOKEN

        // 假设 Util.getRequestSpecification() 提供了一个可配置的 RequestSpecification
        RequestSpecification rq = Util.getRequestSpecification().baseUri(baseAssignmentUrl).headers(headers);
        Response response = rq.body(assignmentBody).post();
        assertEquals(201, response.getStatusCode());

        // 从响应中提取动态生成的ID
        updateAssignmentId = response.jsonPath().get("assignments[0].refId");
        log.info("assignment id is " + updateAssignmentId);
    }

    // 定义一个Provider State，用于将动态ID传递给消费者
    @State("Scoring info is passed between ags-tool and assignmentapi")
    Map<String, Object> getScoringInfo() {
        Map<String, Object> map = new HashMap<>();
        // 将动态生成的ID放入map中，Pact将通过此map传递给消费者契约
        map.put("assignmentId", updateAssignmentId);
        return map;
    }

    @BeforeEach
    void before(PactVerificationContext context) {
        // 设置Pact验证的目标服务
        context.setTarget(new HttpsTestTarget(BASE_PACT_TEACHER_ASSIGNMENTS_URL, 443, ""));
    }

    @TestTemplate
    @ExtendWith(PactVerificationInvocationContextProvider.class)
    void pactTestTemplate(PactVerificationContext context, HttpRequest request) {
        request.addHeader("Authorization", SERVICE_TOKEN);
        // logCurlFromPact(context, request); // 可选：打印CURL请求
        context.verifyInteraction();
    }
}

@ExtendWith(PactConsumerTestExt.class)
class PactConsumerSendScoreIT {

    private final Map<String, String> headers = new HashMap<>();
    private final String path = "/v5/assignmentStatus/update";

    @Pact(provider = PACT_PROVIDER, consumer = PACT_CONSUMER)
    public RequestResponsePact scoreConsumerPact(PactDslWithProvider builder) {

        headers.put("Content-Type", "application/json");

        DslPart body = new PactDslJsonBody()
                // 关键：使用 valueFromProviderState 动态注入 ID
                // 第一个参数: 契约中此字段的名称
                // 第二个参数: 引用Provider State中map的键，对于字符串类型需要使用 ${} 进行插值
                // 第三个参数: 消费者端测试时使用的示例值（当没有真实Provider时）
                .valueFromProviderState("assignmentId", "${assignmentId}", "c1ef3bbf-55a2-4638-8f93-22b2916fe085")
                .stringType("timestamp", DateTime.now().plusHours(3).toString())
                .decimalType("scoreGiven", 75.00)
                .decimalType("scoreMaximum", 100.00)
                .stringType("comment", "Good work!")
                .stringType("status", "IN_PROGRESS")
                .stringType("userId", "c2ef3bbf-55a2-4638-8f93-22b2916fe085")
                .close();

        return builder
                // 声明此契约依赖于名为 "Scoring info is passed between ags-tool and assignmentapi" 的Provider State
                .given("Scoring info is passed between ags-tool and assignmentapi")
                .uponReceiving("Scoring info is passed between ags-tool and assignmentapi")
                .path(path)
                .method("POST")
                .body(body)
                .headers(headers)
                .willRespondWith()
                .status(201)
                .body(body) // 响应体中也可能包含动态ID，此处示例与请求体相同
                .toPact();
    }

    @Test
    @PactTestFor(pactMethod = "scoreConsumerPact", providerName = PACT_PROVIDER, port = "8080", pactVersion = PactSpecVersion.V3)
    void runTest(MockServer mockServer) {
        // 消费者测试时，使用示例值或者自行模拟一个ID
        String updateAssignmentId = "c2ef3bbf-55a2-4638-8f93-22b2916fe085";

        HashMap<String, Object> map = new HashMap<>();
        map.put("timestamp", DateTime.now().plusHours(3).toString());
        map.put("scoreGiven", 75.00);
        map.put("scoreMaximum", 100.00);
        map.put("comment", "Good work!");
        map.put("status", "IN_PROGRESS");
        map.put("userId", "c2ef3bbf-55a2-4638-8f93-22b2916fe085");
        map.put("assignmentId", updateAssignmentId); // 消费者测试时使用此ID

        RequestSpecification rq = Util.getRequestSpecification().baseUri(mockServer.getUrl()).headers(headers);

        Response response = rq.body(map)
                .post(path);

        assertEquals(201, response.getStatusCode());
    }
}