diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go
index 6e9702138..a05685086 100644
--- a/business/jxstore/cms/store_sku.go
+++ b/business/jxstore/cms/store_sku.go
@@ -268,10 +268,10 @@ func getGetStoresSkusBaseSQL(db *dao.DaoDB, storeIDs, skuIDs []int, isFocus bool
 		}
 		sql += ")"
 	}
-	if params["jdID"] != nil {
-		sql += " AND t1.jd_id = ?"
-		sqlParams = append(sqlParams, params["jdID"].(int))
-	}
+	// if params["jdID"] != nil {
+	// 	sql += " AND t1.jd_id = ?"
+	// 	sqlParams = append(sqlParams, params["jdID"].(int))
+	// }
 	if params["name"] != nil {
 		sql += " AND t1.name LIKE ?"
 		sqlParams = append(sqlParams, "%"+params["name"].(string)+"%")
@@ -315,7 +315,6 @@ func getGetStoresSkusBaseSQL(db *dao.DaoDB, storeIDs, skuIDs []int, isFocus bool
 				return "", nil, err
 			}
 			sql += " AND ( 1 = 0"
-			// TODO
 			if params["jdSyncStatus"] != nil && realVendorMap[model.VendorIDJD] == 1 {
 				sql += " OR (t4.jd_sync_status & ? <> 0 AND t2.jd_id <> 0 AND t1.status = ? AND t2.status = ?)"
 				sqlParams = append(sqlParams, params["jdSyncStatus"], model.SkuStatusNormal, model.SkuStatusNormal)
diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go
index 0fed8bc08..29a4cf774 100644
--- a/business/jxstore/cms/sync.go
+++ b/business/jxstore/cms/sync.go
@@ -188,9 +188,6 @@ func (v *VendorSync) oldSyncReorderCategories(ctx *jxcontext.Context, db *dao.Da
 
 func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID, storeID int, isAsync bool, userName string) (hint string, err error) {
 	globals.SugarLogger.Debugf("SyncStore, storeID:%d", storeID)
-	if vendorID == model.VendorIDJX {
-		return "1", nil
-	}
 	var vendorIDs []int
 	if vendorID != -1 {
 		vendorIDs = []int{
@@ -200,35 +197,38 @@ func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID,
 	hint, err = v.LoopStoresMap(ctx, db, fmt.Sprintf("同步门店信息:%d", storeID), isAsync, false, vendorIDs, []int{storeID}, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (resultList interface{}, err error) {
 		loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
 		handler := v.GetStoreHandler(loopMapInfo.VendorID)
-		if len(loopMapInfo.StoreMapList) > 1 {
-			loopStoreTask := tasksch.NewParallelTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]), nil, ctx,
-				func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-					var resultList []interface{}
-					storeMap := batchItemList[0].(*model.StoreMap)
-					db2 := db
-					if len(loopMapInfo.StoreMapList) > 1 {
-						db2 = dao.GetDB()
-					}
-					if err = handler.UpdateStore(db2, storeMap.StoreID, userName); err == nil {
-						storeMap.SyncStatus = 0
-						_, err = dao.UpdateEntity(db2, storeMap, model.FieldSyncStatus)
-						resultList = append(resultList, 1)
-					}
-					return resultList, err
-				}, loopMapInfo.StoreMapList)
-			t.AddChild(loopStoreTask).Run()
-			resultList, err = loopStoreTask.GetResult(0)
-		} else {
-			storeMap := loopMapInfo.StoreMapList[0]
-			if err = handler.UpdateStore(db, storeMap.StoreID, userName); err == nil {
-				storeMap.SyncStatus = 0
-				_, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus)
-			}
-			if err == nil {
-				resultList = []interface{}{1}
+		if handler != nil {
+			if len(loopMapInfo.StoreMapList) > 1 {
+				loopStoreTask := tasksch.NewParallelTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]), nil, ctx,
+					func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+						var resultList []interface{}
+						storeMap := batchItemList[0].(*model.StoreMap)
+						db2 := db
+						if len(loopMapInfo.StoreMapList) > 1 {
+							db2 = dao.GetDB()
+						}
+						if err = handler.UpdateStore(db2, storeMap.StoreID, userName); err == nil {
+							storeMap.SyncStatus = 0
+							_, err = dao.UpdateEntity(db2, storeMap, model.FieldSyncStatus)
+							resultList = append(resultList, 1)
+						}
+						return resultList, err
+					}, loopMapInfo.StoreMapList)
+				t.AddChild(loopStoreTask).Run()
+				resultList, err = loopStoreTask.GetResult(0)
+			} else {
+				storeMap := loopMapInfo.StoreMapList[0]
+				if err = handler.UpdateStore(db, storeMap.StoreID, userName); err == nil {
+					storeMap.SyncStatus = 0
+					_, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus)
+				}
+				if err == nil {
+					resultList = []interface{}{1}
+				}
 			}
+			err = partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
 		}
-		return resultList, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
+		return resultList, err
 	}, true)
 	return hint, makeSyncError(err)
 }