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-02-02 09:19:05 +08:00
parent 40d288aacf
commit cfdf36e4bd
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -3043,13 +3043,14 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
return hint, err return hint, err
} }
func UpdateVendorImg(ctx *jxcontext.Context, i, storeId int, imgWaterMark string, vendorID int, exPrefix string, fromTime, toTime string, isAsync, isContinueWhenError bool) (hint string, err error) { func UpdateVendorImg(ctx *jxcontext.Context, storeId int, imgWaterMark string, vendorID int, exPrefix string, fromTime, toTime string, isAsync, isContinueWhenError bool) (hint string, err error) {
var ( var (
fromTimeP time.Time fromTimeP time.Time
toTimeP time.Time toTimeP time.Time
db = dao.GetDB() db = dao.GetDB()
// skuIDs []int // skuIDs []int
imgList = make([]string, 0, 0) i int = 0
imgList = make([]string, 0, 0)
) )
if fromTime != "" { if fromTime != "" {
fromTimeP = utils.Time2Date(utils.Str2Time(fromTime)) fromTimeP = utils.Time2Date(utils.Str2Time(fromTime))
@@ -3117,13 +3118,11 @@ func UpdateVendorImg(ctx *jxcontext.Context, i, storeId int, imgWaterMark string
imgList = append(imgList, qiNiuImg, ImgMix) imgList = append(imgList, qiNiuImg, ImgMix)
time.Sleep(100 * time.Microsecond) time.Sleep(100 * time.Microsecond)
} }
globals.SugarLogger.Debugf("----i := %d,len := %d", i, len(foodList))
if len(foodList) < 100 { if len(foodList) < 100 {
break break
} }
i++ i++
} }
for _, v := range imgList { for _, v := range imgList {
jxutils.DeleteExportContent(strings.Split(v, "/")[3]) jxutils.DeleteExportContent(strings.Split(v, "/")[3])
time.Sleep(100 * time.Microsecond) time.Sleep(100 * time.Microsecond)

3
controllers/cms_sku.go
View File

@@ -623,7 +623,6 @@ func (c *SkuController) UpdateSkuExinfoMap() {
// @Param imgWaterMark formData string false "商品水印图" // @Param imgWaterMark formData string false "商品水印图"
// @Param vendorID formData int true "平台ID" // @Param vendorID formData int true "平台ID"
// @Param storeId formData int true "京西门店ID" // @Param storeId formData int true "京西门店ID"
// @Param offset formData int true "跳过页数"
// @Param isAsync formData bool false "是否异步" // @Param isAsync formData bool false "是否异步"
// @Param isContinueWhenError formData bool false "单个同步失败是否继续，缺省false" // @Param isContinueWhenError formData bool false "单个同步失败是否继续，缺省false"
// @Success 200 {object} controllers.CallResult // @Success 200 {object} controllers.CallResult
@@ -631,7 +630,7 @@ func (c *SkuController) UpdateSkuExinfoMap() {
// @router /UpdateVendorSkuImg [put] // @router /UpdateVendorSkuImg [put]
func (c *SkuController) UpdateVendorSkuImg() { func (c *SkuController) UpdateVendorSkuImg() {
c.callUpdateVendorSkuImg(func(params *tSkuUpdateVendorSkuImgParams) (retVal interface{}, errCode string, err error) { c.callUpdateVendorSkuImg(func(params *tSkuUpdateVendorSkuImgParams) (retVal interface{}, errCode string, err error) {
retVal, err = cms.UpdateVendorImg(params.Ctx, params.Offset, params.StoreId, params.ImgWaterMark, params.VendorID, params.ExPrefix, params.FromDate, params.ToDate, params.IsAsync, params.IsContinueWhenError) retVal, err = cms.UpdateVendorImg(params.Ctx, params.StoreId, params.ImgWaterMark, params.VendorID, params.ExPrefix, params.FromDate, params.ToDate, params.IsAsync, params.IsContinueWhenError)
return retVal, "", err return retVal, "", err
}) })
} }