把京西有，平台无且没有待创建标记的商品加上待创建标记

business/jxstore/cms/sync_store_sku.go

@@ -550,6 +550,65 @@ func PruneMissingStoreSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, ven
 	return hint, err
 }
 
+// 把京西有，平台无且没有待创建标记的商品加上待创建标记
+func AddCreateFlagForJxStoreSku(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorID, storeID int, vendorStoreID string, isAsync, isContinueWhenError bool) (hint string, err error) {
+	handler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreStoreSkuHandler)
+	if handler == nil {
+		return "", fmt.Errorf("平台:%s不支持此操作", model.VendorChineseNames[vendorID])
+	}
+	db := dao.GetDB()
+	localSkuList, err := dao.GetStoreSkus2(db, vendorID, storeID, nil, false)
+	if err != nil {
+		return "", err
+	}
+
+	var skuIDList []int
+	seqTaskFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
+		switch step {
+		case 0:
+			remoteSkuList, err2 := handler.GetStoreSkusFullInfo(ctx, task, storeID, vendorStoreID, nil)
+			if err = err2; err == nil {
+				remoteSkuMap := make(map[int]*partner.SkuNameInfo)
+				for _, value := range remoteSkuList {
+					for _, skuInfo := range value.SkuList {
+						remoteSkuMap[skuInfo.SkuID] = value
+					}
+				}
+				for _, v := range localSkuList {
+					if remoteSkuMap[v.SkuID] == nil && !model.IsSyncStatusNew(v.StoreSkuSyncStatus) && !model.IsSyncStatusDelete(v.StoreSkuSyncStatus) {
+						skuIDList = append(skuIDList, v.SkuID)
+					}
+				}
+			}
+		case 1:
+			if len(skuIDList) > 0 {
+				storeSkuList, err := dao.GetStoresSkusInfo(db, []int{storeID}, skuIDList)
+				if err == nil {
+					for _, skuBind := range storeSkuList {
+						if vendorID == model.VendorIDMTWM {
+							skuBind.MtwmSyncStatus |= model.SyncFlagNewMask
+						} else if vendorID == model.VendorIDEBAI {
+							skuBind.EbaiSyncStatus |= model.SyncFlagNewMask
+						} else if vendorID == model.VendorIDJD {
+							skuBind.JdSyncStatus |= model.SyncFlagNewMask
+						}
+						dao.UpdateEntity(db, skuBind)
+					}
+				}
+			}
+		}
+		return nil, err
+	}
+	task := tasksch.NewSeqTask(fmt.Sprintf("处理京西门店商品加待创建标记:%s", model.VendorChineseNames[vendorID]), ctx, seqTaskFunc, 2)
+	tasksch.HandleTask(task, parentTask, true).Run()
+	if isAsync {
+		hint = task.GetID()
+	} else {
+		_, err = task.GetResult(0)
+	}
+	return hint, err
+}
+
 func ClearRemoteStoreStuffAndSetNew(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorID, storeID int, vendorStoreID string, isAsync, isContinueWhenError bool) (hint string, err error) {
 	userName := ctx.GetUserName()
 	globals.SugarLogger.Debugf("ClearRemoteStoreStuffAndSetNew storeID:%d, isContinueWhenError:%t, userName:%s", storeID, isContinueWhenError, userName)