diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index c3b4b80a2..e034e5c00 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1981,23 +1981,21 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { SELECT * FROM sku_name where img like '%origin%' ORDER BY img ` dao.GetRows(db, &skuNames, sql) - task := tasksch.NewParallelTask("aaa", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, - func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - skuName := batchItemList[0].(*model.SkuName) - if data, _, err := jxutils.DownloadFileByURL(skuName.Img); err != nil || data == nil { - skuList, _ := dao.GetSkus(db, nil, []int{skuName.ID}, nil, nil, nil) - orderSku := &model.OrderSku{} - sql := ` + fmt.Println("exeNoImg len", len(skuNames)) + for _, skuName := range skuNames { + if data, _, err := jxutils.DownloadFileByURL(skuName.Img); err != nil || data == nil { + skuList, _ := dao.GetSkus(db, nil, []int{skuName.ID}, nil, nil, nil) + fmt.Println("exeNoImg img", skuList[0].ID) + orderSku := &model.OrderSku{} + sql := ` SELECT * FROM order_sku WHERE order_created_at > '2021-09-13' AND sku_id = ? ` - sqlParams := []int{skuList[0].ID} - if err = dao.GetRow(db, &orderSku, sql, sqlParams); err == nil && orderSku == nil { - fmt.Println("exeNoImg, sku_id : ", skuList[0].ID) - } + sqlParams := []int{skuList[0].ID} + if err = dao.GetRow(db, &orderSku, sql, sqlParams); err == nil && orderSku == nil { + fmt.Println("exeNoImg order, sku_id : ", skuList[0].ID) } - return retVal, err - }, skuNames) - task.GetResult(0) + } + } return err }