如何使用Pact Java在契约体中注入动态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() {
        // 模拟创建资源并获取其ID
        String assignmentBody = createBodyStringForStudentAssignmentSetup();
        assignmentBody = assignmentBody.replace("CPWAG", "OTHER_TEXT_RESOURCE");

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

        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);
    }

    @TestTemplate
    @ExtendWith(PactVerificationInvocationContextProvider.class)
    void pactTestTemplate(PactVerificationContext context, HttpRequest request) {
        request.addHeader("Authorization", SERVICE_TOKEN);
        logCurlFromPact(context, request);
        context.verifyInteraction();
    }

    @BeforeEach
    void before(PactVerificationContext context) {
        context.setTarget(new HttpsTestTarget(BASE_PACT_TEACHER_ASSIGNMENTS_URL, 443, ""));
    }

    /**
     * 定义Provider状态，并暴露动态ID
     * 当Consumer契约声明需要"Scoring info is passed between ags-tool and assignmentapi"状态时，
     * 此方法将被调用，并返回一个包含动态ID的Map。
     */
    @State("Scoring info is passed between ags-tool and assignmentapi")
    Map<String, Object> getScoringInfo() {
        Map<String, Object> map = new HashMap<>();
        map.put("assignmentId", updateAssignmentId); // 将动态ID放入Map中
        return map;
    }
}

@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 引用Provider状态中的动态ID
                // 第一个参数是JSON体中的键名
                // 第二个参数是Provider状态Map中的键名，需要用 ${} 包裹以进行字符串插值
                // 第三个参数是Consumer测试时的示例值（用于Consumer端Mock Server匹配）
                .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
                .given("Scoring info is passed between ags-tool and assignmentapi") // 声明依赖的Provider状态
                .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) {
        // Consumer测试时，可以继续使用示例值，因为MockServer会根据契约匹配
        // 或者在实际请求中构造动态数据（如果Consumer自身也需要动态数据）
        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); // Consumer测试时使用的示例ID

        RequestSpecification rq = Util.getRequestSpecification().baseUri(mockServer.getUrl()).headers(headers);
        Response response = rq.body(map).post(path);
        assertEquals(201, response.getStatusCode());
    }
}