Compare commits

...

3 Commits

Author SHA1 Message Date
zhuotianyuan 7a25a685a5 style(logistics): 修复代码格式和缩进问题 2026-01-22 14:52:14 +08:00
zhuotianyuan c592310fa9 style: 修复代码缩进和格式问题
统一调整代码缩进格式,删除多余空格和空行,保持代码风格一致
2026-01-22 14:49:22 +08:00
zhuotianyuan acecd3bef4 fix(logistics): 修复物流服务中订单状态和唯一ID的赋值逻辑
修正uniuni和其他平台下unique_id和state的赋值问题,确保不同平台使用正确的值
同时将partnerOrderNumber格式修改为siteId-externalOrderId组合
2026-01-22 14:37:46 +08:00
3 changed files with 65 additions and 59 deletions

View File

@ -21,7 +21,7 @@ export class SyncTmsJob implements IJob {
shipmentModel: Repository<Shipment>
async onTick() {
const shipments:Shipment[] = await this.shipmentModel.findBy({ tracking_provider: 'freightwaves',finished: false });
const shipments: Shipment[] = await this.shipmentModel.findBy({ tracking_provider: 'freightwaves', finished: false });
const results = await Promise.all(
shipments.map(async shipment => {
return await this.logisticsService.updateFreightwavesShipmentState(shipment);

View File

@ -140,10 +140,10 @@ interface QueryOrderResponseData {
}
// 修改订单响应数据接口
interface ModifyOrderResponseData extends CreateOrderResponseData {}
interface ModifyOrderResponseData extends CreateOrderResponseData { }
// 订单退款响应数据接口
interface RefundOrderResponseData {}
interface RefundOrderResponseData { }
@Provide()
export class FreightwavesService {
@ -180,11 +180,11 @@ export class FreightwavesService {
};
// 记录请求前的详细信息
console.log(`Sending request to: ${this.config.apiBaseUrl}${url}`,JSON.stringify({
console.log(`Sending request to: ${this.config.apiBaseUrl}${url}`, JSON.stringify({
headers,
data
}))
console.log('Request data:', `${this.config.apiBaseUrl}${url}`, data,headers);
console.log('Request data:', `${this.config.apiBaseUrl}${url}`, data, headers);
// 发送请求 - 临时禁用SSL证书验证以解决UNABLE_TO_VERIFY_LEAF_SIGNATURE错误
const response = await axios.post<FreightwavesResponse<T>>(
`${this.config.apiBaseUrl}${url}`,

View File

@ -141,7 +141,7 @@ export class LogisticsService {
}
//"expressFinish": 0, //是否快递创建完成1完成 0未完成需要轮询 2:失败)
//"expressFinish": 0, //是否快递创建完成1完成 0未完成需要轮询 2:失败)
async updateFreightwavesShipmentState(shipment: Shipment) {
try {
const data = await this.freightwavesService.queryOrder({ shipOrderId: shipment.order_id.toString() });
@ -372,7 +372,7 @@ export class LogisticsService {
// }
// }
resShipmentOrder =await this.mepShipment(data,order);
resShipmentOrder = await this.mepShipment(data, order);
// if (data.shipmentPlatform === 'uniuni') {
// // 添加运单
@ -385,7 +385,7 @@ export class LogisticsService {
// }
// 记录物流信息,并将订单状态转到完成
if (resShipmentOrder.status === 'SUCCESS'||resShipmentOrder.code === '00000200') {
if (resShipmentOrder.status === 'SUCCESS' || resShipmentOrder.code === '00000200') {
order.orderStatus = ErpOrderStatus.COMPLETED;
} else {
throw new Error('运单生成失败');
@ -398,11 +398,17 @@ export class LogisticsService {
const shipmentRepo = manager.getRepository(Shipment);
const tracking_provider = data.shipmentPlatform; // todo: id未确定,后写进常数
let co:any;
let co: any;
let unique_id: any;
let state: any;
if (data.shipmentPlatform === 'uniuni') {
co = resShipmentOrder.data.tno;
}else{
unique_id = resShipmentOrder.data.uni_order_sn;
state = resShipmentOrder.data.uni_status_code;
} else {
co = resShipmentOrder.data?.shipOrderId;
unique_id = resShipmentOrder.data?.shipOrderId;
state = ErpOrderStatus.COMPLETED;
}
// 同步物流信息到woocommerce
const site = await this.siteService.get(Number(order.siteId), true);
@ -415,10 +421,10 @@ export class LogisticsService {
const shipment = await shipmentRepo.save({
tracking_provider: tracking_provider,
tracking_id: res.data.tracking_id,
unique_id: resShipmentOrder.data.uni_order_sn,
unique_id: unique_id,
stockPointId: String(data.stockPointId), // todo
state: resShipmentOrder.data.uni_status_code,
return_tracking_number: resShipmentOrder.data.tno,
state: state,
return_tracking_number: co,
fee: data.details.shipmentFee,
order: order
});
@ -427,7 +433,7 @@ export class LogisticsService {
}
// 同步订单状态到woocommerce
if(order.source_type!="shopyy"){
if (order.source_type != "shopyy") {
if (order.status !== OrderStatus.COMPLETED) {
await this.wpService.updateOrder(site, order.externalOrderId, {
status: OrderStatus.COMPLETED,
@ -687,7 +693,7 @@ export class LogisticsService {
async mepShipment(data: ShipmentBookDTO,order:Order) {
async mepShipment(data: ShipmentBookDTO, order: Order) {
try {
const stock_point = await this.stockPointModel.findOneBy({ id: data.stockPointId });
let resShipmentOrder;
@ -729,7 +735,7 @@ export class LogisticsService {
// 根据TMS系统对接说明文档格式化参数
const reqBody: any = {
shipCompany: 'UPSYYZ7000NEW',
partnerOrderNumber: order.externalOrderId ,
partnerOrderNumber: order.siteId + '-' + order.externalOrderId,
warehouseId: '25072621030107400060',
shipper: {
name: data.details.origin.contact_name, // 姓名
@ -772,7 +778,7 @@ export class LogisticsService {
weightUnit: (data.details.packaging_properties.packages[0].measurements.weight.unit === 'kg' ? 'KG' : 'LB') as 'KG' | 'LB' // 重量单位LB,KG
},
currency: 'CAD', // 币种默认CAD
description: '订单编号:'+order.externalOrderId // 包裹描述(确保是字符串类型)
description: '订单编号:' + order.externalOrderId // 包裹描述(确保是字符串类型)
}
],
signService: 0