Улучшение #19474

Синхронизация фраз

app/Console/Commands/DictionaryCampaignsSyncByCampaign.php

@@ -129,7 +129,7 @@ class DictionaryCampaignsSyncByCampaign extends Command
                         INNER JOIN ad_groups ag on k.ad_group_id = ag.id
                         INNER JOIN ad_groups ag on k.ad_group_id = ag.id
                         INNER JOIN goal_ad_groups gag on ag.id = gag.ad_group_id
                         INNER JOIN goal_ad_groups gag on ag.id = gag.ad_group_id
                          LEFT JOIN goal_keywords gk on k.id = gk.keyword_id AND gk.goal_ad_group_id=gag.id
                          LEFT JOIN goal_keywords gk on k.id = gk.keyword_id AND gk.goal_ad_group_id=gag.id
-                    WHERE gk.keyword_id is null
+                    WHERE gk.keyword_id is null AND k.deleted_at is null
                             ");
                             ");
 
 
         //грузим ключевые фразы которых по какой то причне нет в целевых.
         //грузим ключевые фразы которых по какой то причне нет в целевых.

app/Console/Commands/KeywordsDelete.php

@@ -6,6 +6,7 @@ use App\Models\Tokens;
 use App\Service\API\API;
 use App\Service\API\API;
 use App\Service\Requests\APIRequest;
 use App\Service\Requests\APIRequest;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
 
 
 class KeywordsDelete extends Command
 class KeywordsDelete extends Command
 {
 {
@@ -47,16 +48,27 @@ class KeywordsDelete extends Command
             ->where('type', '!=', Tokens::MAIN)
             ->where('type', '!=', Tokens::MAIN)
             ->get();
             ->get();
 
 
-        foreach ($tokens as $token) {
+
+
+        foreach (Tokens::where('type', '!=', Tokens::MAIN)->get() as $token) {
+            $sql = "SELECT gk.external_id
+                FROM goal_keywords gk
+                INNER JOIN keywords k ON gk.keyword_id=k.id
+                INNER JOIN dictionary_campaigns c ON c.id=gk.dictionary_campaign_id
+                INNER JOIN dictionaries d ON d.id=c.dictionary_id
+                WHERE k.deleted_at is not null AND d.token_id=" . $token->id;
+            $result = DB::select($sql);
+            $ids = [];
+            foreach ($result as $item){
+                $ids[] = $item->external_id;
+            }
+
             $factory = APIRequest::getInstance(API::YANDEX);
             $factory = APIRequest::getInstance(API::YANDEX);
             $factory->setToken($token);
             $factory->setToken($token);
 
 
             $factory->getRequest('Keywords', 'delete')
             $factory->getRequest('Keywords', 'delete')
                 ->call([
                 ->call([
-                    'ids' => $token->dictionaryCampaignsForExternalWithTrashed->pluck('goalKeywordsDelete')
-                        ->collapse()
-                        ->pluck('external_id')
-                        ->toArray(),
+                    'ids' => $ids
                 ]);
                 ]);
         }
         }
 
 

app/Models/Keyword.php

@@ -111,21 +111,21 @@ class Keyword extends Model
     {
     {
         parent::boot();
         parent::boot();
 
 
-        static::deleted(function (Keyword $keyword) {
-
-            if (!$keyword->isForceDeleting()) {
-
-                $keyword->goalKeywords->each(function (GoalKeyword $goalKeyword) {
-
-                    GoalKeywordDelete::updateOrCreateByMain($goalKeyword);
-
-                    $goalKeyword->delete();
-
-                });
-
-            }
-
-        });
+//        static::deleted(function (Keyword $keyword) {
+//
+//            if (!$keyword->isForceDeleting()) {
+//
+//                $keyword->goalKeywords->each(function (GoalKeyword $goalKeyword) {
+//
+//                    GoalKeywordDelete::updateOrCreateByMain($goalKeyword);
+//
+//                    $goalKeyword->delete();
+//
+//                });
+//
+//            }
+//
+//        });
     }
     }
 
 
     public function goalKeywords()
     public function goalKeywords()

app/Service/Requests/Direct/DeleteKeywords.php

@@ -61,7 +61,7 @@ class DeleteKeywords extends DirectRequest
 
 
                 $external_id = (string)$delete_result['Id'];
                 $external_id = (string)$delete_result['Id'];
 
 
-                GoalKeywordDelete::where('external_id', $external_id)->delete();
+                GoalKeyword::where('external_id', $external_id)->delete();
 
 
             }
             }
         } catch (\Exception $e) {
         } catch (\Exception $e) {

app/Service/Requests/Direct/GetKeywords.php

@@ -120,6 +120,7 @@ class GetKeywords extends DirectRequest
                     'state' => $keyword['State'],
                     'state' => $keyword['State'],
                     'status' => $keyword['Status'],
                     'status' => $keyword['Status'],
                     'serving_status' => $keyword['ServingStatus'],
                     'serving_status' => $keyword['ServingStatus'],
+                    'updated_at'    =>  DB::raw('now()'),
                     'deleted_at'    =>  null//не забыть убрать признак удаления, если вдруг опять пришла удаленная ранее фраза
                     'deleted_at'    =>  null//не забыть убрать признак удаления, если вдруг опять пришла удаленная ранее фраза
                 ];
                 ];
 
 
@@ -141,7 +142,12 @@ class GetKeywords extends DirectRequest
             }
             }
 
 
             foreach (array_chunk($insertData, 1000) as $data) {
             foreach (array_chunk($insertData, 1000) as $data) {
+                $items = [];
+                foreach ($data as $item){
+                    $items[] = $item['external_id'];
+                }
                 Keyword::insertOrIgnore($data);
                 Keyword::insertOrIgnore($data);
+                Keyword::whereIn('external_id', $items)->update(['updated_at'    =>  DB::raw('now()')]);
             }
             }
 
 
 
 
@@ -194,13 +200,16 @@ class GetKeywords extends DirectRequest
                 //это означает что этой фразы не было в результатах и в БД она по этой причине не обновилась
                 //это означает что этой фразы не было в результатах и в БД она по этой причине не обновилась
                 //надо такие пометить на удаление
                 //надо такие пометить на удаление
                 //при удалении для всех таких надо будет удалить фразы из целевых и потом удалить их сами
                 //при удалении для всех таких надо будет удалить фразы из целевых и потом удалить их сами
+
                 $sql = "UPDATE keywords k
                 $sql = "UPDATE keywords k
                                 INNER JOIN ad_groups ag ON k.ad_group_id=ag.id
                                 INNER JOIN ad_groups ag ON k.ad_group_id=ag.id
-                        SET k.deleted_at = now(),
-                            ag.keywords_loaded_at=now()
-                        WHERE k.updated_at>ag.keywords_loaded_at
+                        SET k.deleted_at = now()
+                        WHERE k.updated_at<=ag.keywords_loaded_at
                             AND k.deleted_at is null
                             AND k.deleted_at is null
-                            AND ag.id in (" . implode(", ", $ag_groups) . ")";
+                            AND ag.external_id in (" . implode(", ", $ag_groups) . ")";
+                DB::update($sql);
+
+                $sql = "UPDATE ad_groups SET keywords_loaded_at=now() WHERE external_id in (" . implode(", ", $ag_groups) . ")";
                 DB::update($sql);
                 DB::update($sql);
             }
             }
         } catch (\Exception $e) {
         } catch (\Exception $e) {