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:
邹宗楠
2026-01-30 09:00:42 +08:00
parent a86a0c43db
commit 40d288aacf
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
business/jxstore/cms/sku.go
View File

@@ -3063,12 +3063,13 @@ func UpdateVendorImg(ctx *jxcontext.Context, i, storeId int, imgWaterMark string
task := tasksch.NewParallelTask("刷新商品前缀水印图", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError), ctx, task := tasksch.NewParallelTask("刷新商品前缀水印图", tasksch.NewParallelConfig().SetParallelCount(1).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) {
storeDetail, err := dao.GetStoreDetail(db, storeId, vendorID, "")
if err != nil {
return nil, err
}
switch vendorID { switch vendorID {
case model.VendorIDMTWM: case model.VendorIDMTWM:
storeDetail, err := dao.GetStoreDetail(db, storeId, vendorID, "")
if err != nil {
return nil, err
}
var api *mtwmapi.API //= mtwm.GetAPI(fromStore.VendorOrgCode, fromStore.ID, fromStore.VendorStoreID) var api *mtwmapi.API //= mtwm.GetAPI(fromStore.VendorOrgCode, fromStore.ID, fromStore.VendorStoreID)
if storeDetail.VendorOrgCode == globals.Mtwm2Code { if storeDetail.VendorOrgCode == globals.Mtwm2Code {
api = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "") api = mtwmapi.New(beego.AppConfig.DefaultString("mtwmAppID2", ""), beego.AppConfig.DefaultString("mtwmSecret2", ""), beego.AppConfig.DefaultString("mtwmCallbackURL2", ""), "")
@@ -3127,6 +3128,8 @@ func UpdateVendorImg(ctx *jxcontext.Context, i, storeId int, imgWaterMark string
jxutils.DeleteExportContent(strings.Split(v, "/")[3]) jxutils.DeleteExportContent(strings.Split(v, "/")[3])
time.Sleep(100 * time.Microsecond) time.Sleep(100 * time.Microsecond)
} }
case model.VendorIDEBAI:
} }
return retVal, err return retVal, err
}, []int{1}) }, []int{1})