標籤: OMS 系統

// 蝦皮欄位名稱（底線命名）
@JsonProperty(“order_sn”)
private String orderSn;

@JsonProperty(“order_status”)
private String orderStatus;

@JsonProperty(“total_amount”)
private BigDecimal totalAmount;

@JsonProperty(“create_time”)
private Long createTime; // Unix timestamp

@JsonProperty(“buyer_username”)
private String buyerUsername;

@JsonProperty(“item_list”)
private List<ShopeeOrderItem> itemList;
}

// Momo 欄位名稱（駝峰命名）
private String orderNo;
private String orderStatus;
private BigDecimal orderAmount;
private String orderDate; // yyyy/MM/dd HH:mm
private String customerName;
private List<MomoOrderItem> products;
}

// 統一的欄位命名
private String orderId;
private String platformOrderId;
private ChannelType channel;
private OrderStatus status;
private BigDecimal totalAmount;
private ZonedDateTime createdAt; // 統一用 ZonedDateTime
private String buyerName;
private List<OrderItemDTO> items;
}

/**
* 蝦皮格式 → 內部格式
*/
public OrderDTO toOrderDTO(ShopeeGetOrderResponse response) {
return OrderDTO.builder()
.platformOrderId(response.getOrderSn())
.channel(ChannelType.SHOPEE)
.status(mapStatus(response.getOrderStatus()))
.totalAmount(response.getTotalAmount())
.createdAt(convertTimestamp(response.getCreateTime()))
.buyerName(response.getBuyerUsername())
.items(convertItems(response.getItemList()))
.build();
}

// Unix timestamp → ZonedDateTime
private ZonedDateTime convertTimestamp(Long timestamp) {
return Instant.ofEpochSecond(timestamp)
.atZone(ZoneId.of(“Asia/Taipei”));
}

// 蝦皮狀態 → 系統狀態
private OrderStatus mapStatus(String shopeeStatus) {
return switch (shopeeStatus) {
case “UNPAID” -> OrderStatus.PENDING_PAYMENT;
case “READY_TO_SHIP” -> OrderStatus.PENDING_SHIPMENT;
case “SHIPPED” -> OrderStatus.SHIPPED;
case “COMPLETED” -> OrderStatus.COMPLETED;
case “CANCELLED” -> OrderStatus.CANCELLED;
default -> OrderStatus.UNKNOWN;
};
}
}

private static final DateTimeFormatter MOMO_DATE_FORMAT =
DateTimeFormatter.ofPattern(“yyyy/MM/dd HH:mm”);

/**
* Momo 格式 → 內部格式
*/
public OrderDTO toOrderDTO(MomoGetOrderResponse response) {
return OrderDTO.builder()
.platformOrderId(response.getOrderNo())
.channel(ChannelType.MOMO)
.status(mapStatus(response.getOrderStatus()))
.totalAmount(response.getOrderAmount())
.createdAt(convertDate(response.getOrderDate()))
.buyerName(response.getCustomerName())
.items(convertItems(response.getProducts()))
.build();
}

// Momo 日期格式 → ZonedDateTime
private ZonedDateTime convertDate(String dateStr) {
LocalDateTime ldt = LocalDateTime.parse(dateStr, MOMO_DATE_FORMAT);
return ldt.atZone(ZoneId.of(“Asia/Taipei”));
}
}

@Autowired private ShopeeConverter shopeeConverter;
@Autowired private MomoConverter momoConverter;

public List<OrderDTO> syncOrders(ChannelType channel, Merchant merchant) {

if (channel == ChannelType.SHOPEE) {
// 呼叫蝦皮 API，取得蝦皮格式
List<ShopeeGetOrderResponse> shopeeOrders = shopeeApi.getOrders();

// 轉換成內部格式
return shopeeOrders.stream()
.map(shopeeConverter::toOrderDTO)
.toList();
}

if (channel == ChannelType.MOMO) {
// 呼叫 Momo API，取得 Momo 格式
List<MomoGetOrderResponse> momoOrders = momoApi.getOrders();

// 轉換成內部格式
return momoOrders.stream()
.map(momoConverter::toOrderDTO)
.toList();
}

// … 其他平台
}
}

// 取得平台設定（API URL、版本等）
ChannelSetting getSetting();

// 取得平台授權 Token
TokenResult getAccessToken(Merchant merchant);

// 驗證必要資料是否齊全
boolean validateRequired(ActionRequest request);

// 執行實際動作（同步訂單、更新庫存等）
ActionResult execute(ActionRequest request);
}

@Override
public ChannelSetting getSetting() {
return ChannelSetting.builder()
.apiUrl(“https://partner.shopeemobile.com”)
.version(“v2”)
.authType(AuthType.OAUTH2)
.build();
}

@Override
public TokenResult getAccessToken(Merchant merchant) {
// 蝦皮使用 OAuth2 + 簽章驗證
String signature = generateSignature(merchant);
return callShopeeAuthAPI(merchant, signature);
}

@Override
public ActionResult execute(ActionRequest request) {
// 呼叫蝦皮 API 執行動作
return callShopeeAPI(request);
}
}

@Override
public ChannelSetting getSetting() {
return ChannelSetting.builder()
.apiUrl(“https://api.momo.com.tw”)
.version(“v1”)
.authType(AuthType.API_KEY)
.build();
}

@Override
public TokenResult getAccessToken(Merchant merchant) {
// Momo 使用 API Key 驗證
return TokenResult.of(merchant.getMomoApiKey());
}

@Override
public ActionResult execute(ActionRequest request) {
// 呼叫 Momo API 執行動作
return callMomoAPI(request);
}
}

private final Map<ChannelType, ChannelAction> actionMap;

// Spring 自動注入所有 ChannelAction 實作
public ChannelFactory(List<ChannelAction> actions) {
this.actionMap = actions.stream()
.collect(Collectors.toMap(
action -> action.getSetting().getChannelType(),
action -> action
));
}

/**
* 根據通路類型取得對應的實作
*/
public ChannelAction getAction(ChannelType channelType) {
ChannelAction action = actionMap.get(channelType);
if (action == null) {
throw new UnsupportedChannelException(
“不支援的通路: “ + channelType
);
}
return action;
}
}

@Autowired
private ChannelFactory channelFactory;

public SyncResult syncOrders(ChannelType channel, Merchant merchant) {
// 1. 取得對應的通路實作
ChannelAction action = channelFactory.getAction(channel);

// 2. 取得授權 Token
TokenResult token = action.getAccessToken(merchant);

// 3. 執行同步
ActionRequest request = ActionRequest.builder()
.merchant(merchant)
.token(token)
.actionType(ActionType.SYNC_ORDERS)
.build();

return action.execute(request);
}
}

@Override
public ChannelSetting getSetting() {
return ChannelSetting.builder()
.apiUrl(“https://api-gateway.coupang.com”)
.version(“v2”)
.authType(AuthType.HMAC)
.build();
}

// … 實作其他方法
}