Order with an Assembly Line

var session = await P21Session.CreateAsync(
    "https://play.p21server.com", "api_user", "api_pass");
var http = session.Http;
var iapi = $"{session.UiServer}/api/ui/interactive";

bool IsBlocked(JObject r) =>
    r["Status"]?.ToString() is "3" or "Blocked";  // int or string form

List<string> PopupIds(JObject r) =>
    (r["Events"] as JArray ?? new JArray())
        .Where(e => e["Name"]?.ToString() == "windowopened")
        .SelectMany(e => e["Data"] as JArray ?? new JArray())
        .Where(kv => kv["Key"]?.ToString() == "windowid")
        .Select(kv => kv["Value"]!.ToString())
        .ToList();

// Answer every popup the last action opened; button null => first proceed button.
async Task<JObject> AnswerResponseWindowsAsync(JObject result, string? button = null)
{
    foreach (var popupId in PopupIds(result))
    {
        // Tools endpoint takes ?windowId=, NOT ?id=
        var toolsResp = await http.GetAsync($"{iapi}/v2/tools?windowId={popupId}");
        toolsResp.EnsureSuccessStatusCode();
        var available = JArray.Parse(await toolsResp.Content.ReadAsStringAsync())
            .Select(t => (t["Name"] ?? t["ToolName"])?.ToString()).ToList();
        var pick = button
            ?? new[] { "cb_ok", "cb_1", "cb_yes" }.FirstOrDefault(available.Contains)
            ?? throw new InvalidOperationException(
                $"Popup {popupId}: buttons [{string.Join(", ", available)}]");
        var clickBody = new JObject { ["WindowId"] = popupId, ["ToolName"] = pick };
        var clickResp = await http.PostAsync($"{iapi}/v2/tools",
            new StringContent(clickBody.ToString(), Encoding.UTF8, "application/json"));
        clickResp.EnsureSuccessStatusCode();
        result = JObject.Parse(await clickResp.Content.ReadAsStringAsync());
    }
    return result;
}

async Task<JObject> ChangeAsync(string windowId, string tab, string dw,
    string field, string value, string? answer = null)
{
    var body = new JObject
    {
        ["WindowId"] = windowId,
        ["List"] = new JArray { new JObject
        {
            ["TabName"] = tab,
            ["DatawindowName"] = dw,   // required on 25.2+
            ["FieldName"] = field,
            ["Value"] = value,
        }},
    };
    var resp = await http.PutAsync($"{iapi}/v2/change",
        new StringContent(body.ToString(), Encoding.UTF8, "application/json"));
    resp.EnsureSuccessStatusCode();
    var result = JObject.Parse(await resp.Content.ReadAsStringAsync());
    if (result["Status"]?.ToString() is "2" or "Failure")
        throw new InvalidOperationException($"{field}: {result["Messages"]}");
    return IsBlocked(result) ? await AnswerResponseWindowsAsync(result, answer) : result;
}

// 1. Session with response-window handling ON
var sessBody = new JObject { ["ResponseWindowHandlingEnabled"] = true };
(await http.PostAsync($"{iapi}/sessions",
    new StringContent(sessBody.ToString(), Encoding.UTF8, "application/json")))
    .EnsureSuccessStatusCode();

// 2. Open the Order window
var winBody = new JObject { ["ServiceName"] = "Order" };
var winResp = await http.PostAsync($"{iapi}/v2/window",
    new StringContent(winBody.ToString(), Encoding.UTF8, "application/json"));
winResp.EnsureSuccessStatusCode();
var windowId = JObject.Parse(await winResp.Content.ReadAsStringAsync())["WindowId"]!.ToString();

string? orderNo = null;
try
{
    // 3. Header -- TABPAGE_1 / datawindow "order". quote OFF = real order.
    await ChangeAsync(windowId, "TABPAGE_1", "order", "quote", "OFF");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "sales_loc_id", "10");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "source_loc_id", "10");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "customer_id", "100198");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "ship_to_id", "200");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "contact_id", "300");
    // Dates fire the w_response_common date-cascade prompt even on a NEW order
    await ChangeAsync(windowId, "TABPAGE_1", "order", "order_date", "2030-01-05", "cb_ok");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "requested_date", "2030-01-06", "cb_ok");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "po_no", "PO-TEST-001");
    await ChangeAsync(windowId, "TABPAGE_1", "order", "taker", "JSMITH"); // else = API user

    // 4. Lines tab
    var tabBody = new JObject { ["WindowId"] = windowId, ["PageName"] = "TP_ITEMS" };
    (await http.PutAsync($"{iapi}/v2/tab",
        new StringContent(tabBody.ToString(), Encoding.UTF8, "application/json")))
        .EnsureSuccessStatusCode();

    // 5. Item on the EXISTING items row; assembly prompt: cb_1 = Yes (explode)
    await ChangeAsync(windowId, "TP_ITEMS", "items", "oe_order_item_id", "WIDGET-001", "cb_1");
    // 6. Quantity
    await ChangeAsync(windowId, "TP_ITEMS", "items", "unit_quantity", "5");

    // 7. Save -- v2 body is the bare window-ID JSON string (an object => 422)
    var saveResp = await http.PutAsync($"{iapi}/v2/data",
        new StringContent($"\"{windowId}\"", Encoding.UTF8, "application/json"));
    saveResp.EnsureSuccessStatusCode();
    var result = JObject.Parse(await saveResp.Content.ReadAsStringAsync());
    while (IsBlocked(result))  // follow-on prompts: answer with proceed button
        result = await AnswerResponseWindowsAsync(result);
    if (result["Status"]?.ToString() is "2" or "Failure")
        throw new InvalidOperationException($"Save failed: {result["Messages"]}");

    // 8. Read order_no back -- /v2/data returns the ACTIVE surface, so
    //    switch back to the header tab first.
    var backBody = new JObject { ["WindowId"] = windowId, ["PageName"] = "TABPAGE_1" };
    (await http.PutAsync($"{iapi}/v2/tab",
        new StringContent(backBody.ToString(), Encoding.UTF8, "application/json")))
        .EnsureSuccessStatusCode();
    var dataResp = await http.GetAsync($"{iapi}/v2/data?id={windowId}");
    dataResp.EnsureSuccessStatusCode();
    foreach (var dw in JArray.Parse(await dataResp.Content.ReadAsStringAsync()))
    {
        if (dw["Name"]?.ToString() != "order") continue;
        var columns = (dw["Columns"] as JArray)!.Select(c => c.ToString()).ToList();
        var row = (dw["Data"] as JArray)![(int?)dw["ActiveRow"] ?? 0];
        orderNo = row[columns.IndexOf("order_no")]?.ToString();
        Console.WriteLine($"Created order_no: {orderNo}");
    }
}
finally
{
    // 9. Clean up (window uses ?id=; sessions endpoint takes no parameter)
    await http.DeleteAsync($"{iapi}/v2/window?id={windowId}");
    await http.DeleteAsync($"{iapi}/sessions");
}

// 10. Verify via OData (mirrors the Verify section): assembly codes on the
//     lines, and the production-order link for the assembly line.
var lineResp = await http.GetAsync(
    "https://play.p21server.com/odataservice/odata/table/oe_line" +
    $"?$filter=order_no eq '{orderNo}'");
lineResp.EnsureSuccessStatusCode();
foreach (var line in (JArray)JObject.Parse(await lineResp.Content.ReadAsStringAsync())["value"]!)
{
    // assembly: B = kit parent, N = component, P = production-order line,
    // S = build-to-stock allocation
    Console.WriteLine($"Line {line["line_no"]}: assembly={line["assembly"]}");
    if (line["assembly"]?.ToString() != "P") continue;
    var linkResp = await http.GetAsync(
        "https://play.p21server.com/odataservice/odata/table/prod_order_line_link" +
        $"?$filter=transaction_uid eq {line["oe_line_uid"]} and trans_type eq 'O'");
    linkResp.EnsureSuccessStatusCode();
    var linked = ((JArray)JObject.Parse(await linkResp.Content.ReadAsStringAsync())["value"]!).Any();
    Console.WriteLine($"  prod_order_line_link: {(linked ? "present" : "MISSING")}");
}