delete invalid sku while sync skus

pkg/compute/service/service.go

@@ -63,7 +63,6 @@ func StartService() {
 
 			cron.AddJob2("AutoDiskSnapshot", options.Options.AutoSnapshotDay, options.Options.AutoSnapshotHour, 0, 0, models.DiskManager.AutoDiskSnapshot, false)
 			cron.AddJob2("SyncSkus", options.Options.SyncSkusDay, options.Options.SyncSkusHour, 0, 0, skus.SyncSkus, true)
-			cron.AddJob2("CleanInvalidSkus", options.Options.SyncSkusDay, options.Options.SyncSkusHour, 0, 0, skus.DeleteInvalidSkus, true) // skus只在启动时进行清理
 
 			cron.Start()
 			defer cron.Stop()

pkg/compute/skus/skus.go

@@ -321,6 +321,10 @@ func SyncSkus(ctx context.Context, userCred mcclient.TokenCredential, isStart bo
 	if e := skus.SyncToLocalDB(); e != nil {
 		log.Errorf("SyncSkus sync to local db failed, %s", e.Error())
 	}
+
+	// 清理无效的sku
+	log.Debugf("DeleteInvalidSkus in processing...")
+	models.ServerSkuManager.PendingDeleteInvalidSku()
 }
 
 // 同步指定provider sku列表
@@ -337,11 +341,3 @@ func SyncSkusByProviderIds(providerIds []string) error {
 
 	return nil
 }
-
-// 伪删除无效的sku.只在启动进程时进行清理。
-func DeleteInvalidSkus(ctx context.Context, userCred mcclient.TokenCredential, isStart bool) {
-	if isStart {
-		log.Debugf("DeleteInvalidSkus in processing...")
-		models.ServerSkuManager.PendingDeleteInvalidSku()
-	}
-}