diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index d61d42264..a439d155e 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -3063,12 +3063,13 @@ func UpdateVendorImg(ctx *jxcontext.Context, i, storeId int, imgWaterMark string task := tasksch.NewParallelTask("刷新商品前缀水印图", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError), ctx, 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 { 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) if storeDetail.VendorOrgCode == globals.Mtwm2Code { 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]) time.Sleep(100 * time.Microsecond) } + case model.VendorIDEBAI: + } return retVal, err }, []int{1})