@@ -49,38 +49,28 @@ private Mono<Void> fixModelStructure() {
4949
5050 return mongoTemplate .find (new Query (), AIModel .class )
5151 .flatMap (model -> {
52- // Check if this is a model with the old structure
52+ // Sadece geçerli modelId'ye sahip modelleri işle
5353 if (model .getModelId () == null ) {
5454 log .warn ("Model has null modelId: {}" , model );
5555 return Mono .empty ();
5656 }
5757
58- // Create a new AIModel with the correct structure
59- AIModel fixedModel = new AIModel ();
60- fixedModel .setModelId (model .getModelId ());
61- fixedModel .setModelName (model .getModelName ());
62- fixedModel .setProvider (model .getProvider ());
63- fixedModel .setMaxInputTokens (model .getMaxInputTokens ());
64- fixedModel .setRequiredPlan (model .getRequiredPlan ());
65- fixedModel .setCreditCost (model .getCreditCost ());
66- fixedModel .setCreditType (model .getCreditType ());
67- fixedModel .setCategory (model .getCategory ());
68- fixedModel .setContextLength (model .getContextLength ());
69- fixedModel .setDefaultTemperature (model .getDefaultTemperature ());
70- fixedModel .setIcon (model .getIcon ());
71- fixedModel .setDescription (model .getDescription ());
72- fixedModel .setFee (model .getFee ());
73- fixedModel .setFeatured (model .getFeatured ());
74- fixedModel .setMaxTokens (model .getMaxTokens ());
75- fixedModel .setMultimodal (model .getMultimodal ());
76- fixedModel .setActive (model .getActive ());
58+ // Eğer hem id hem de modelId varsa ve bunlar farklı ise düzelt
59+ if (model .getId () != null && !model .getId ().equals (model .getModelId ())) {
60+ log .info ("Fixing model with mismatched id ({}) and modelId ({})" ,
61+ model .getId (), model .getModelId ());
62+
63+ // MongoDB'den önce eski modeli sil
64+ return mongoTemplate .remove (model )
65+ .then (modelRepository .save (model ))
66+ .onErrorResume (e -> {
67+ log .error ("Error fixing model {}: {}" , model .getModelId (), e .getMessage ());
68+ return Mono .empty ();
69+ });
70+ }
7771
78- return modelRepository .save (fixedModel )
79- .doOnSuccess (saved -> log .info ("Fixed model: {}" , saved .getModelId ()))
80- .onErrorResume (e -> {
81- log .error ("Error fixing model {}: {}" , model .getModelId (), e .getMessage ());
82- return Mono .empty ();
83- });
72+ // Model düzgün, değişiklik yapma
73+ return Mono .empty ();
8474 })
8575 .then ();
8676 }
0 commit comments