liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2024-08-21 09:39:42 +08:00
parent 17c35377dc
commit ed6b57368e
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jxcallback/orderman/orderman_ext.go
View File

@@ -1377,6 +1377,9 @@ func (c *OrderManager) AmendMissingOrders(ctx *jxcontext.Context, vendorIDs []in
if toDate.Sub(fromDate) > 7*24*time.Hour { if toDate.Sub(fromDate) > 7*24*time.Hour {
return "", fmt.Errorf("最多一次一周，请调整时间") return "", fmt.Errorf("最多一次一周，请调整时间")
} }
if time.Now().Sub(fromDate) > 5*27*time.Hour {
return "", fmt.Errorf("仅支持查询近5天内的订单")
}
type tDateVendorPair struct { type tDateVendorPair struct {
QueryDate time.Time QueryDate time.Time
@@ -1422,7 +1425,6 @@ func (c *OrderManager) AmendMissingOrders(ctx *jxcontext.Context, vendorIDs []in
task1 := tasksch.NewParallelTask("AmendMissingOrders ListOrders", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, task1 := tasksch.NewParallelTask("AmendMissingOrders ListOrders", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
vendorDate := batchItemList[0].(*tDateVendorPair) vendorDate := batchItemList[0].(*tDateVendorPair)
globals.SugarLogger.Debugf("==========================vendorDate := %s", utils.Format4Output(vendorDate, false))
if handler, _ := partner.GetPurchaseOrderHandlerFromVendorID(vendorDate.VendorID).(partner.IPurchasePlatformStoreSkuHandler); handler != nil { if handler, _ := partner.GetPurchaseOrderHandlerFromVendorID(vendorDate.VendorID).(partner.IPurchasePlatformStoreSkuHandler); handler != nil {
orderIDs, err2 := handler.ListOrders(ctx, vendorDate.VendorOrgCode, task, vendorDate.QueryDate, vendorStoreIDMap[vendorDate.VendorID]) orderIDs, err2 := handler.ListOrders(ctx, vendorDate.VendorOrgCode, task, vendorDate.QueryDate, vendorStoreIDMap[vendorDate.VendorID])
if err = err2; err == nil && len(orderIDs) > 0 { if err = err2; err == nil && len(orderIDs) > 0 {

4
business/partner/purchase/mtwm/order.go
View File

@@ -764,10 +764,6 @@ func (c *PurchaseHandler) ListOrders(ctx *jxcontext.Context, vendorOrgCode strin
} else { } else {
endData = time.Now() endData = time.Now()
} }
if vendorStoreID == "23932637" {
globals.SugarLogger.Debugf("======queryDate := %s", utils.Format4Output(queryDate, false))
globals.SugarLogger.Debugf("======endData := %s", utils.Format4Output(endData, false))
}
var vendorStoreIDs []string var vendorStoreIDs []string
if vendorStoreID == "" { if vendorStoreID == "" {