From 24379b4008a27d78f39f0254dc8fd8d17c689bfd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Tue, 9 Apr 2024 17:13:43 +0800 Subject: [PATCH] 1 --- business/jxcallback/orderman/orderman_ext.go | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/business/jxcallback/orderman/orderman_ext.go b/business/jxcallback/orderman/orderman_ext.go index eb25fe0e4..3c364ae2a 100644 --- a/business/jxcallback/orderman/orderman_ext.go +++ b/business/jxcallback/orderman/orderman_ext.go @@ -1412,6 +1412,8 @@ func (c *OrderManager) AmendMissingOrders(ctx *jxcontext.Context, vendorIDs []in vendorDate := batchItemList[0].(*tDateVendorPair) if handler, _ := partner.GetPurchaseOrderHandlerFromVendorID(vendorDate.VendorID).(partner.IPurchasePlatformStoreSkuHandler); handler != nil { orderIDs, err2 := handler.ListOrders(ctx, vendorDate.VendorOrgCode, task, vendorDate.QueryDate, vendorStoreIDMap[vendorDate.VendorID]) + globals.SugarLogger.Debugf("========orderIDs := %s", utils.Format4Output(orderIDs, false)) + globals.SugarLogger.Debugf("========orderIDs := %v", err2) if err = err2; err == nil && len(orderIDs) > 0 { var orderList []*tOrderVendorPair for _, v := range orderIDs { @@ -1433,6 +1435,9 @@ func (c *OrderManager) AmendMissingOrders(ctx *jxcontext.Context, vendorIDs []in }, dateVendorList) tasksch.HandleTask(task1, task, true).Run() orderList, err2 := task1.GetResult(0) + globals.SugarLogger.Debugf("========orderList := %s", utils.Format4Output(orderList, false)) + globals.SugarLogger.Debugf("========err2 := %v", err2) + if err = err2; err != nil && !isContinueWhenError { return "", err } @@ -1464,15 +1469,19 @@ func (c *OrderManager) AmendMissingOrders(ctx *jxcontext.Context, vendorIDs []in } } } + globals.SugarLogger.Debugf("========missingOrderList := %s", utils.Format4Output(missingOrderList, false)) + globals.SugarLogger.Debugf("========updateOrderStatusList := %s", utils.Format4Output(updateOrderStatusList, false)) + case 1: task2 := tasksch.NewParallelTask("AmendMissingOrders GetOrders", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { pair := batchItemList[0].(*tOrderVendorPair) if handler := partner.GetPurchaseOrderHandlerFromVendorID(pair.VendorID); handler != nil { order, err2 := handler.GetOrder(pair.VendorOrgCode, pair.VendorOrderID, pair.VendorStoreID) - globals.SugarLogger.Debugf("========pair=%s", utils.Format4Output(pair, false)) - globals.SugarLogger.Debugf("=========order%s", utils.Format4Output(order, false)) - globals.SugarLogger.Debugf("=========err %v", err2) + + globals.SugarLogger.Debugf("========order GetOrders:= %s", utils.Format4Output(order, false)) + globals.SugarLogger.Debugf("========err2 GetOrders:= %v", err2) + if err = err2; err == nil { if order.VendorStoreID == "2391979" { return retVal, err