58 lines
3.4 KiB
Java
58 lines
3.4 KiB
Java
package com.baiyue.lastleg.appointmentplanning;
|
|
|
|
import com.baiyue.common.core.api.PageResult;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.http.HttpStatus;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.web.server.ResponseStatusException;
|
|
import java.util.List;
|
|
import java.util.Set;
|
|
|
|
@Service
|
|
public class AppointmentCargoService {
|
|
private final AppointmentCargoMapper mapper;
|
|
private final AppointmentWarehouseClient warehouses;
|
|
private final String token;
|
|
|
|
public AppointmentCargoService(AppointmentCargoMapper mapper, AppointmentWarehouseClient warehouses,
|
|
@Value("${baiyue.security.internal-service-token:}") String token) {
|
|
this.mapper = mapper; this.warehouses = warehouses; this.token = token;
|
|
}
|
|
|
|
public PageResult<AppointmentCargo> page(int page, int size, String warehouseId, String destination, String keyword) {
|
|
if (page < 1 || size < 1 || size > 100) throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "每页数量必须为1至100");
|
|
if (keyword != null && keyword.length() > 128) throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "搜索词过长");
|
|
var scope = scope();
|
|
var origins = scope.origins();
|
|
var destinations = scope.destinations();
|
|
warehouseId = clean(warehouseId); destination = clean(destination); keyword = clean(keyword);
|
|
if (warehouseId != null && !origins.contains(warehouseId) || destination != null && !destinations.contains(destination)) {
|
|
throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "请选择已启用的美国接仓点及FBA目的仓");
|
|
}
|
|
if (origins.isEmpty() || destinations.isEmpty()) return new PageResult<>(List.of(), page, size, 0, 0);
|
|
long total = mapper.count(origins, destinations, warehouseId, destination, keyword);
|
|
var rows = mapper.page(origins, destinations, warehouseId, destination, keyword, size, (long) (page - 1) * size);
|
|
return new PageResult<>(rows, page, size, total, (total + size - 1) / size);
|
|
}
|
|
|
|
private record Scope(List<String> origins, List<String> destinations) { }
|
|
private Scope scope() {
|
|
final List<AppointmentWarehouseClient.Warehouse> catalog;
|
|
try {
|
|
var result = warehouses.catalog(token);
|
|
if (result == null || !result.successful() || result.data() == null) throw new IllegalStateException();
|
|
catalog = result.data();
|
|
} catch (RuntimeException error) {
|
|
throw new ResponseStatusException(HttpStatus.SERVICE_UNAVAILABLE, "仓库目录暂不可用，无法核实美国货物范围", error);
|
|
}
|
|
var us = catalog.stream().filter(w -> w != null && w.id() != null && w.id() > 0 && "US".equals(w.countryCode())).toList();
|
|
var origins = us.stream().filter(w -> Set.of("OVERSEAS", "OVERSEAS_PARTNER").contains(w.warehouseType() == null ? "" : w.warehouseType()))
|
|
.map(w -> w.id().toString()).distinct().toList();
|
|
var destinations = us.stream().filter(w -> "FBA".equals(w.warehouseType()) && clean(w.warehouseCode()) != null)
|
|
.map(AppointmentWarehouseClient.Warehouse::warehouseCode).distinct().toList();
|
|
return new Scope(origins, destinations);
|
|
}
|
|
|
|
private static String clean(String value) { return value == null || value.isBlank() ? null : value.trim(); }
|
|
}
|