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

aa

Browse Source
This commit is contained in:
suyl
2021-10-13 10:08:27 +08:00
parent f42d2ceaf6
commit 1e17ae8e11
1 changed files with 12 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
business/jxstore/tempop/tempop.go
View File

@@ -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
}