12. Order 服务

通过 client.order() 访问。以基于 ISA-88 的状态机管理工单(Work Order)从创建 → 开始 → 中断/恢复 → 结束的完整生命周期。

11.1 工单状态(基于 ISA-88)

CREATE → WAIT ──start()──► START ──pause()──► PAUSE
                            │                  │
                            │                  resume()
                            │                  │
                            ▼                  ▼
                           END ◄──end()──── START
                            │
                            └─ (또는) ──abort()──► ABORTED

状态	含义	转换方法
WAIT	等待(创建后的初始状态)	create() 结果
START	进行中	start()、resume()
PAUSE	暂停	pause()
END	正常完成	end()
ABORTED	异常结束	abort()

对于无法进行状态转换的调用(例如已处于 START 状态时再次调用 start()),服务器返回 OK + data.success=false 响应,V5 方法则返回 false。

11.2 方法一览

CRUD

方法	返回类型	HTTP	端点
create(OrderRequestV5)	OrderResponseV5 或 null	POST	/api/v5/order
update(order_id, OrderRequestV5)	OrderResponseV5 或 null	PUT	/api/v5/order/{id}
delete(order_id)	boolean	DELETE	/api/v5/order/{id}
get(order_id)	OrderResponseV5 或 null	GET	/api/v5/order/{id}
list()	List<OrderResponseV5>	GET	/api/v5/order
exists(order_id)	boolean	GET	/api/v5/order/{id}/exists

生命周期(均返回 boolean)

方法	HTTP	端点
start(order_id)	POST	/api/v5/order/{id}/start
end(order_id)	POST	/api/v5/order/{id}/end
pause(order_id)	POST	/api/v5/order/{id}/pause
resume(order_id)	POST	/api/v5/order/{id}/resume
abort(order_id)	POST	/api/v5/order/{id}/abort

11.3 OrderRequestV5 / OrderResponseV5

字段	类型	说明
order_id	String	工单 ID(PK)
title	String	工单标题
description	String	说明
site_id	String	所属站点
asset_id	String	目标资产(Equipment)
customer_id	String	客户(可选)
product_id	String	生产的产品
employee_id	String	负责员工(可选)
target_units	long	目标数量
unit	String	单位(EA、KG 等)
time_per_unit_in_ms	long	单位标准工时
fix_start_timestamp	long	计划开始时刻(毫秒)
fix_end_timestamp	long	计划结束时刻(毫秒)
external_order_id	String	外部系统订单 ID
status	String	(仅响应)当前状态

11.4 使用示例

创建工单

import plantpulse.api.v5.dto.request.OrderRequestV5;
import plantpulse.api.v5.dto.response.OrderResponseV5;

OrderRequestV5 req = new OrderRequestV5();
req.setOrder_id("ORD_20260514_001");
req.setTitle("5월 14일 1교대 생산");
req.setDescription("PROD_A001 500개 생산");
req.setSite_id("SITE_DJ");
req.setAsset_id("ASSET_DJ_M_0001");
req.setProduct_id("PROD_A001");
req.setCustomer_id("CUST_001");
req.setEmployee_id("EMP_E12345");
req.setTarget_units(500);
req.setUnit("EA");
req.setTime_per_unit_in_ms(5_000);

long now = System.currentTimeMillis();
req.setFix_start_timestamp(now);
req.setFix_end_timestamp(now + 4 * 3600_000L);
req.setExternal_order_id("MES-2026-0514-001");

OrderResponseV5 created = client.order().create(req);

标准生命周期

String orderId = "ORD_20260514_001";

// WAIT → START
if (!client.order().start(orderId)) {
    System.err.println("시작 실패 — fix_start_timestamp가 미래이거나 이미 진행중");
    return;
}

// 잠시 후 — 일시중지
client.order().pause(orderId);

// 재개
client.order().resume(orderId);

// 정상 종료
client.order().end(orderId);

异常结束

// abort 는 별도 인자 없이 호출. 상세 사유는 update() 로 description/notes 에 기록.
if (!client.order().abort("ORD_20260514_001")) {
    System.err.println("중단 실패");
}

单条查询 / 存在性确认

OrderResponseV5 o = client.order().get("ORD_20260514_001");
if (o != null) {
    System.out.println("상태: " + o.getStatus());
    System.out.println("목표: " + o.getTarget_units() + " " + o.getUnit());
}

boolean exists = client.order().exists("ORD_20260514_001");

全部列表

import java.util.List;

List<OrderResponseV5> all = client.order().list();
for (OrderResponseV5 o : all) {
    System.out.printf("[%s] %s — %s%n",
        o.getStatus(), o.getOrder_id(), o.getTitle());
}

仅进行中的工单(客户端侧过滤)

import java.util.stream.Collectors;

List<OrderResponseV5> active = client.order().list().stream()
        .filter(o -> "START".equals(o.getStatus())
                  || "PAUSE".equals(o.getStatus()))
        .collect(Collectors.toList());

按资产查询工单

String assetId = "ASSET_DJ_M_0001";
List<OrderResponseV5> assetOrders = client.order().list().stream()
        .filter(o -> assetId.equals(o.getAsset_id()))
        .collect(Collectors.toList());

按状态统计

import java.util.Map;

Map<String, Long> byStatus = client.order().list().stream()
        .collect(Collectors.groupingBy(
                OrderResponseV5::getStatus,
                Collectors.counting()));

byStatus.forEach((status, count) ->
    System.out.printf("%s: %d건%n", status, count));

修改 / 删除

// 수정 (계획 시간 연장)
OrderRequestV5 update = new OrderRequestV5();
update.setOrder_id("ORD_20260514_001");
update.setTitle("5월 14일 1교대 생산 (연장)");
// ... 모든 필드 다시 세팅 ...
update.setFix_end_timestamp(System.currentTimeMillis() + 8 * 3600_000L);
client.order().update("ORD_20260514_001", update);

// 삭제 (취소 처리)
client.order().delete("ORD_20260514_001");

11.5 应用场景

场景 — MES 联动自动创建工单

import java.text.SimpleDateFormat;
import java.util.Date;

SimpleDateFormat df = new SimpleDateFormat("yyyyMMdd");
String today = df.format(new Date());

// 외부 MES 큐에서 받은 주문을 V5 Order로 변환
for (MesOrder mes : mesQueue) {
    OrderRequestV5 req = new OrderRequestV5();
    req.setOrder_id("ORD_" + today + "_" + String.format("%03d", mes.seq));
    req.setSite_id("SITE_DJ");
    req.setAsset_id(mes.equipId);
    req.setProduct_id(mes.productId);
    req.setTarget_units(mes.qty);
    req.setExternal_order_id(mes.mesOrderId);
    req.setFix_start_timestamp(mes.plannedStart);
    req.setFix_end_timestamp(mes.plannedEnd);
    client.order().create(req);
}

场景 — 安全的状态转换辅助方法

public static boolean safeStart(APIClient_V5 client, String orderId) {
    OrderResponseV5 o = client.order().get(orderId);
    if (o == null) {
        log.warn("작업지시 없음: " + orderId);
        return false;
    }
    if (!"WAIT".equals(o.getStatus())) {
        log.warn("WAIT 상태가 아님: " + o.getStatus());
        return false;
    }
    return client.order().start(orderId);
}

后续步骤

• Customer 服务、Employee 服务、Product 服务 — 附加到 Order 的主数据
• Calendar 服务 — 工单与巡检计划的冲突检查