aa

business/jxstore/tempop/tempop.go

@@ -1753,10 +1753,12 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	)
 	sql := `
 		SELECT * from store_map where vendor_id = 5 and deleted_at = '1970-01-01 00:00:00' and vendor_org_code = 2
-		AND store_id = 667431
 	`
 	dao.GetRows(db, &storeMaps, sql, nil)
-	for _, v := range storeMaps {
+	// for _, v := range storeMaps {
+	task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			v := batchItemList[0].(*model.StoreMap)
 			detail, _ := api.JdShop2API.ShopDetail(utils.Str2Int(v.VendorStoreID))
 			storeDetail, _ := dao.GetStoreDetail(db, v.StoreID, model.VendorIDJDShop, "2")
 			// var (
@@ -1832,7 +1834,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 					},
 				},
 			})
-	}
+			return retVal, err
+		}, storeMaps)
+	tasksch.HandleTask(task, nil, true).Run()
+	task.GetID()
 	// var (
 	// 	db             = dao.GetDB()
 	// 	vendorThingIDs []int64