diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 553d6afed..314850791 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1766,8 +1766,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	task := tasksch.NewParallelTask("京东商城门店建商品1", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
 		func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			v := batchItemList[0].(*model.StoreSkuBind)
-			if v.JdsID != 0 {
-				task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
+			if v.JdsID != 0 && v.SubStoreID == 0 {
+				task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetParallelCount(2).SetIsContinueWhenError(true), ctx,
 					func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 						storeMap := batchItemList[0].(*model.StoreMap)
 						if err = api.JdShop2API.StoreSkuBindStore(false, []string{utils.Int64ToStr(v.JdsID)}, []string{storeMap.VendorStoreID}); err == nil {
@@ -1792,6 +1792,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 				tasksch.HandleTask(task, task2, true).Run()
 				_, err = task.GetResult(0)
 			}
+			v.SubStoreID = 1
+			dao.UpdateEntity(db, v, "SubStoreID")
 			return retVal, err
 		}, storeSkus)
 	tasksch.HandleTask(task, nil, true).Run()